<?php
  require_once("../etc/whoiswho.conf.php");
  require_once("../include/mysql.inc.php");
  $i = 0;
  $db = dbconnect();
  $table = INCOMINGTABLE;
  $sql = "SELECT * FROM $table;";
  $sth = $db->query($sql);
  while ($row = $sth->fetch())
    {
      $i++;
      print "Processing Message: Time: ".$row['DeviceReportedTime']." Message: ".$row['Message']."\n";
      # ID
      $id = $row['ID'];
      # Time
      $time = $row['DeviceReportedTime'];
      # WLAN name
      $msg = explode(",", $row['Message']);
      $msgpart = ltrim($msg[0]);
      preg_match('/"[^"]*"/', $msgpart, $netnamemsg);
      $netnamemsg = str_replace(['"','<','>'], '', $netnamemsg);
      $netname = $netnamemsg[0];
      # getting MAC
      $macmsg = explode(" ", ltrim($msg[1]));
      $mac = implode(preg_grep('/([a-fA-F0-9]{2}[:|\-]?){6}/', $macmsg));
      $mac = str_replace(",", "", $mac);
      $mac = str_replace("-", ":", $mac);
      $mac = strtoupper($mac);
      # network type
      switch (true)
      {
        case (preg_grep('/new managed network/', $msg)):
          $type="access point";
        break;
        case (preg_grep('/new probe network/', $msg)):
          $type="client";
        break;
        case (preg_grep('/new ad-hoc network/', $msg)):
          $type="ad-hoc";
        break;
        case (preg_grep('/new data network/', $msg)):
          $type="data";
        break;
        default:
          $type="unknown";
      }
      # encryption
      $encmsg = explode(" ", $msg[2]);
      $enc = $encmsg[2];
      # channel
      $channelmsg = explode(" ", $msg[3]);
      $channel = $channelmsg[2];
      # bit rate
      $bitratemsg = explode(" ", $msg[4]);
      $bitrate = $bitratemsg[1];
      # insert into SEEN Table
      $inserttable = SEENTABLE;
      $insertsql = "INSERT INTO $inserttable (SyslogID,MAC,Time,Name,Type,Encryption,Channel,BitRate) values('$id','$mac','$time','$netname','$type','$enc','$channel','$bitrate');";
      $insertsth = $db->query($insertsql);
      $sql_rc = $db->errorCode();
      #print "$insertsql ...";
      #print "$sql_rc\n";
      # delete from INCOMING
      $delsql = "DELETE FROM $table WHERE ID ='$id';";
      $delsth = $db->query($delsql);
    }
  print "$i messages processed.\n";
?>