dumpParserImporter.php

Go to the documentation of this file.

#!/usr/bin/php
<?php 
require_once dirname(__FILE__) . '/BayEOSBinaryTypes.php';

if($argc<6)
    die("Usage: dumpImporter.php BAYEOS.DB.File url name pw timeoffset\n");

if(! is_readable($argv[1]))
    die("File $argv[1] not readable\n");

$data="sender=$argv[3]&password=$argv[4]";
$frames='';

$fp=fopen($argv[1],"r");
if(! isset($argv[5]) ) $argv[5]=0;
$pos=0;
while(! feof($fp)){
    //read timestamp, length and bayeosframe
    $ts_bin=fread($fp,4);
    $ts=BayEOSType::unpackUINT32($ts_bin)+$argv[5];
    $ts_bin=BayEOSType::UINT32($ts);
    $length_bin=fread($fp,1);
    $length=BayEOSType::unpackUINT8($length_bin);
    if($length) $bayeosframe=fread($fp,$length);
    else $bayeosframe='';
    if($bayeosframe){
        $bayeosframe=pack("C",0x9).$ts_bin.$bayeosframe;
        $frames.="&bayeosframes[]=".base64_encode($bayeosframe);
    }
    if(strlen($frames)>3000){
        send($argv[2],$data.$frames);
        $frames='';
    }
        
//  echo date('Y-m-d h:i:s',$ts+$ref_date->format('U'))." - $length: ";
//  for($offset=3;$offset<$length;$offset+=4){
//      echo "ch".(($offset+1)/4).": ".BayEOSType::unpackFLOAT32(substr($bayeosframe,$offset,4))." ";
//  }
//  echo "\n";
}
if(strlen($frames)>0){
    send($argv[2],$data.$frames);
    $frames='';
}

function send($url,$data){
    while(! $fp = fsockopen($url, 8090)){
      sleep(1); 
    }
//  if(! $fp) die("fsockopen failed");
    
    fputs($fp, "POST / HTTP/1.1\r\n");
    fputs($fp, "Content-type: application/x-www-form-urlencoded\r\n");
    fputs($fp, "User-Agent: PHP-Importer\r\n");
    fputs($fp, "Content-length: ". strlen($data) ."\r\n");
    fputs($fp, "Connection: close\r\n\r\n");
    fputs($fp, $data);
    
    echo "Sending ...";
    
    $header=1;
    while(!feof($fp)) {
        $res=rtrim(fgets($fp, 128));
        if(strlen($res)==0) $header=0;
    
        if(! $header) echo $res."\n";
    }
    fclose($fp);
}


?>