ceda_ei
/
Zeeth-Naaw-Bot
mirror of https://gitlab.com/ceda_ei/Zeeth-Naaw-Bot
1
1
Fork 0
Code Issues Releases Wiki Activity

Bug Fixes, Add user exceptions, Add main body. 

Added bug fixes for SQL queries. Added exceptions table in update_user_by_username function.
Added main body, the file now queries t.me for every user to check the integrity of the chain. Then finds the longest chain, converts it to string and compares it to last sent chain. If the chains aren't same, it sends it and saves it in its place.
This commit is contained in:
Ceda EI 2018-04-04 13:38:31 +05:30
parent 67ac825615
commit 5b9cdd5b5a
1 changed files with 28 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

34
update_chain.php
View File

@ -31,7 +31,7 @@ function get_chain_from_user($user) {
$output = array($user); $output = array($user);
$last_user_id = $user['user_id']; $last_user_id = $user['user_id'];
while (true) { while (true) {
$query = "SELECT user_id, username from users where follows = $last_user_id"; $query = "SELECT user_id, username from users where follows = $last_user_id ;";
$result = $conn->query($query); $result = $conn->query($query);
if ($result->num_rows > 0){ if ($result->num_rows > 0){
# Code executed if this isn't the last user # Code executed if this isn't the last user
@ -59,7 +59,7 @@ function get_longest_chain() {
} }
$chains = array(); $chains = array();
while ($end_point = $end_points->fetch_assoc()){ while ($end_point = $end_points->fetch_assoc()){
$chain = get_chain_from_user($end_points); $chain = get_chain_from_user($end_point);
array_push($chains, $chain); array_push($chains, $chain);
} }
$longest_chain_index = 0; $longest_chain_index = 0;
@ -91,17 +91,39 @@ function update_user_by_username($username) {
$dom->preserveWhiteSpace = false; $dom->preserveWhiteSpace = false;
$xpath = new \DOMXPath($dom); $xpath = new \DOMXPath($dom);
foreach ($xpath->query("descendant-or-self::div[@class and contains(concat(' ', normalize-space(@class), ' '), ' tgme_page_description ')]/a") as $node){ foreach ($xpath->query("descendant-or-self::div[@class and contains(concat(' ', normalize-space(@class), ' '), ' tgme_page_description ')]/a") as $node){
$username = preg_replace('/^@/', '', $node->nodeValue); $username_follows = preg_replace('/^@/', '', $node->nodeValue);
$query = "SELECT user_id FROM users WHERE username = " . $username ; $query = "SELECT user_id FROM users WHERE username = '" . $username_follows . "';" ;
$result = $conn->query($query); $result = $conn->query($query);
if ($result->num_rows > 0) { $query2 = "SELECT * FROM exceptions WHERE username = '" . $username . "' AND points_to = '" . $username_follows . "';";
$exceptions = $conn->query($query2);
if ($result->num_rows > 0 && $exceptions->num_rows == 0) {
$row = $result->fetch_assoc(); $row = $result->fetch_assoc();
$query = "UPDATE users SET follows = " . $row['user_id'] . " WHERE username = " . $username . ";" ; $query = "UPDATE users SET follows = " . $row['user_id'] . " WHERE username = '" . $username . "';" ;
$conn->query($query); $conn->query($query);
return; return;
} }
} }
} }
# Update users
$query = "SELECT username FROM users;";
$users = $conn->query($query);
while ($user = $users->fetch_assoc()) {
update_user_by_username($user['username']);
}
# Get longest chain and compare it to old chain and send it.
$chain = get_longest_chain();
$chain_string = chain_to_string($chain);
$saved_chain = include('chain.php');
if ($saved_chain != $chain_string) {
send_code($chain_string);
$file = fopen('chain.php', 'w');
$contents = "<?php return '". $chain_string . "'; ?>";
fwrite($file, $contents);
fclose($file);
}
$conn->close(); $conn->close();
?> ?>