Changeset 161 for mods

Timestamp:

12/23/06 02:17:16 (16 years ago)

Author:

exi

Message:

Modified the sync server to be able to handle item values.

Location:

mods/Sync_Server

Files:

• globals.php (modified) (1 diff)
• sync_server.php (modified) (6 diffs)

mods/Sync_Server/globals.php

@@ -2 +2 @@
 // current version: major.minor.sub
 // unpair numbers for minor = development version
-define('KB_VERSION', '1.1.44');
+define('KB_VERSION', '1.2.2');
 
 // set the running-server for id-syncs here
-define('KB_SYNCURL', 'http://www.eve-dev.net/killboard_testing/?a=sync_server');
+define('KB_SYNCURL', 'http://sync.eve-dev.net/?a=sync_server');
 
 // add new corporations here once you've added the logo to img/corps/

mods/Sync_Server/sync_server.php

@@ -18 +18 @@
 if ($version[0] <= 1 && $version[1] < 1)
 {
-    echo "Your Killboard is too old, please upgrade to 1.2.0 or newer<br>\n";
+    echo "Your Killboard is too old, please upgrade to 1.2.2 or newer<br>\n";
     return;
+}
+
+if (!function_exists('apache_request_headers'))
+{
+    function apache_request_headers()
+    {
+        return getallheaders();
+    }
+}
+$header = apache_request_headers();
+foreach ($header as $key => $value)
+{
+    if ($key == 'X-KBHost')
+    {
+        $host = base64_decode($value);
+    }
 }
 
@@ -25 +41 @@
 if (!file_exists($_FILES['data']['tmp_name']))
 {
+    var_dump($_REQUEST);
     var_dump($_FILES);
     echo "malformed request, expecting data-file<br>\n";
@@ -35 +52 @@
 // get all names we'll find
 preg_match_all("^!(.*?)\|(.*?)-^", &$data, $matches);
-unset($data);
+$data = strstr($data, 'ITEMS_START');
 $results = count($matches[1]);
 if ($results == 0)
@@ -45 +62 @@
 }
 
+$s_data = array();
 // construct an array with name as key and id as value
 for ($i = 0; $i<$results; $i++)
@@ -50 +68 @@
     $s_data[$matches[1][$i]] = $matches[2][$i];
 }
+unset($matches);
+
+if ($host)
+{
+    $qry = new DBQuery();
+    $qry->execute("show tables like '%item_%'");
+    while ($row = $qry->getRow())
+    {
+        $tables .= array_pop($row);
+    }
+    if (!strstr($tables, 'kb3_item_stats'))
+    {
+        $qry->execute("CREATE TABLE `kb3_item_stats` (\n `itm_name` varchar(128) NOT NULL,\n `kb_host` int(11) NOT NULL,\n `itm_externalid` int(11) NOT NULL,\n `itm_value` bigint(4) NOT NULL,\n PRIMARY KEY (`itm_name`,`kb_host`)\n) TYPE=MyISAM");
+        $qry->execute("CREATE TABLE `kb3_item_hosts` (\n `kb_host` int(11) NOT NULL,\n `kb_name` varchar(255) NOT NULL,\n `itm_update` timestamp NOT NULL default '0000-00-00 00:00:00',\n RPIMARY KEY (`kb_host`)\n) TYPE=MyISAM");
+    }
+    preg_match_all('^§(.*?)\|(.*?)\|(.*?)-^', &$data, $matches);
+
+    $hostid = abs(crc32($host));
+    $qry->execute('replace into kb3_item_hosts (kb_host, kb_name, itm_update) VALUES (\''.$hostid.'\',\''.addslashes($host).'\',\''.date('Y-m-d H:i:s').'\')');
+
+    $results = count($matches[1]);
+    for ($i = 0; $i<$results; $i++)
+    {
+        $qry->execute("replace into kb3_item_stats (itm_name,kb_host,itm_externalid,itm_value) VALUES ('".addslashes($matches[1][$i])."','".$hostid."','".addslashes($matches[2][$i])."','".addslashes($matches[3][$i])."')");
+    }
+}
+unset($data);
 
 // now get our list from the database
@@ -83 +128 @@
 }
 
+$data_array = $data_values = array();
+$qry->execute('select itm_name, itm_externalid, itm_value from kb3_item_stats order by itm_name asc, itm_value asc');
+while ($data = $qry->getRow())
+{
+    $data_array[$data['itm_name']] = $data;
+    $data_values[$data['itm_name']][] = $data['itm_value'];
+}
+
+$content_file .= 'ITEMS_START';
+foreach ($data_array as $data)
+{
+    // get the median value for every item
+    $val_cnt = count($data_values[$data['itm_name']]);
+    $val_cnt = min(ceil($val_cnt/2), $val_cnt)-1;
+    $value = $data_values[$data['itm_name']][$val_cnt];
+
+    $content_file .= '§'.$data['itm_name'].'|'.$data['itm_externalid'].'|'.$value.'-';
+}
+
 // return the compressed data back to the client
 echo gzdeflate($content_file);