phackwer/Geolocation test

## Geolocation test
<?php

$listening = true;
$ip = '0.0.0.0';
$port = 9679;
$server = stream_socket_server("tcp://{$ip}:{$port}", $errno, $errstr);
$w = $e
= [];

if (!$server) {
    return false;
}

while ($listening) {
    while ($stream = @stream_socket_accept($server, 3, $peer)) {
        while ($listening) {
            stream_set_blocking($stream, 0);
            $sock_in_data = '';
            while (!strstr($sock_in_data, "\n")) {
                $sock_in_data .= fread($stream, 1);
            }

            //log.txt
            $log = 'RECV: ' . date('Y-m-d H:i:s') . ' ' . $peer . ' - ' . $sock_in_data;
            file_put_contents('log_received.txt', $log, FILE_APPEND | LOCK_EX);
            echo $log;

            //if (!strstr($sock_in_data, 'Q0')) {
                $sock_out_data = substr($sock_in_data, 0, 25);
                //$sock_out_data .= date('ymdHis').",L0,0#\n";
		$sock_out_data .= date('ymdHis').",D0#\n";
		//$sock_out_data .= date('ymdHis').",S8,10,0#\n";
		//$sock_out_data .= date('ymdHis').",G0#\n";
                $sock_out_data = str_replace('*CMDR','*CMDS',$sock_out_data);

                //Attempt format 1
                $sock_out_data1 = hex2bin(strtoupper('FFFF'.bin2hex($sock_out_data)));

                //log.txt
                //Send to client:
                if ((int) fwrite($stream, $sock_out_data1) < 1) {
                    trigger_error("Write to socket failed!");
                }

                $log = 'SEND: ' . date('Y-m-d H:i:s') . ' ' . $peer . ' - ' . $sock_out_data1;
                file_put_contents('log_sent.txt', $log, FILE_APPEND | LOCK_EX);
                echo $log;

            //}
        }
    }
}

## server.php
<?php

$port   = 9679;
$socket = stream_socket_server("tcp://0.0.0.0:{$port}", $errno, $errstr);
if (!$socket) {return false;}

while (1) {
    while ($conn = @stream_socket_accept($socket, 60, $peer)) {
        stream_set_blocking($conn, 0);
        $client_request = "";

        while (!strstr($client_request, "\n")) {
            $client_request .= fread($conn, 1);
        }

        $client_request = date('Y-m-d H:i:s') . ' ' . $peer . ' - ' . $client_request;

        //log.txt
        file_put_contents('log.txt', $client_request, FILE_APPEND | LOCK_EX);
        //cli
        echo $client_request;

        //Send to client:
        if (strstr($client_request, 'GET /')) {
            $headers = "HTTP/1.0 200 OK\n"
                . "Content-Type: text/html\n"
                . "\n";
            $body = "<h1>Greetings. You've reached our server!</h1>" . $client_request;
            $client_request = $headers.$body;
        }

        if ((int) fwrite($conn, $client_request) < 1) {
            trigger_error("Write to socket failed!");
        }

        stream_socket_shutdown($conn, STREAM_SHUT_WR);
        fclose($conn);
        fclose($socket);
        $socket = stream_socket_server("tcp://0.0.0.0:{$port}", $errno, $errstr);
    }
}

## server_fork.php
<?php

$listening = true;
$ip        = '0.0.0.0';
$port      = 9679;
$server    = stream_socket_server("tcp://{$ip}:{$port}", $errno, $errstr);
$w         = $e
    = [];

if (!$server) {
    return false;
}

while ($listening) {
    while ($stream = @stream_socket_accept($server, 3, $peer)) {
        stream_set_blocking($stream, 0);
        $processId = pcntl_fork();

        switch ($processId) {
            case -1:
                print "Could not fork!\n";
                exit;
            case 0:
                echo $processId;

                if (is_resource($stream)) {
                    $sock_in_data = '';
                    while (!strstr($sock_in_data, "\n") && !stream_get_meta_data($stream)['eof']) {
                        $sock_in_data .= fread($stream, 1);
                    }

                    //log.txt
                    $log = 'RECV: ' . date('Y-m-d H:i:s') . ' ' . $peer . ' - ' . $sock_in_data;
                    file_put_contents('log_unlock.txt', $log, FILE_APPEND | LOCK_EX);
                    echo $log;

                    $sock_out_data = substr($sock_in_data, 0, 38);
                    $sock_out_data .= "L0,0#\n";

                    //log.txt
                    //Send to client:
                    if ((int)fwrite($stream, $sock_out_data) < 1) {
                        trigger_error("Write to socket failed!");
                    }

                    $log = 'SEND: ' . date('Y-m-d H:i:s') . ' ' . $peer . ' - ' . $sock_out_data;
                    file_put_contents('log_multi_streams_fork.txt', $log, FILE_APPEND | LOCK_EX);
                    echo $log;

                    stream_socket_shutdown($stream, STREAM_SHUT_WR);
                    fclose($stream);
                    unset($stream);
                }
        }
        break;
    }

}
	<?php

	$listening = true;
	$ip = '0.0.0.0';
	$port = 9679;
	$server = stream_socket_server("tcp://{$ip}:{$port}", $errno, $errstr);
	$w = $e
	= [];

	if (!$server) {
	return false;
	}

	while ($listening) {
	while ($stream = @stream_socket_accept($server, 3, $peer)) {
	while ($listening) {
	stream_set_blocking($stream, 0);
	$sock_in_data = '';
	while (!strstr($sock_in_data, "\n")) {
	$sock_in_data .= fread($stream, 1);
	}

	//log.txt
	$log = 'RECV: ' . date('Y-m-d H:i:s') . ' ' . $peer . ' - ' . $sock_in_data;
	file_put_contents('log_received.txt', $log, FILE_APPEND \| LOCK_EX);
	echo $log;

	//if (!strstr($sock_in_data, 'Q0')) {
	$sock_out_data = substr($sock_in_data, 0, 25);
	//$sock_out_data .= date('ymdHis').",L0,0#\n";
	$sock_out_data .= date('ymdHis').",D0#\n";
	//$sock_out_data .= date('ymdHis').",S8,10,0#\n";
	//$sock_out_data .= date('ymdHis').",G0#\n";
	$sock_out_data = str_replace('CMDR','CMDS',$sock_out_data);

	//Attempt format 1
	$sock_out_data1 = hex2bin(strtoupper('FFFF'.bin2hex($sock_out_data)));

	//log.txt
	//Send to client:
	if ((int) fwrite($stream, $sock_out_data1) < 1) {
	trigger_error("Write to socket failed!");
	}

	$log = 'SEND: ' . date('Y-m-d H:i:s') . ' ' . $peer . ' - ' . $sock_out_data1;
	file_put_contents('log_sent.txt', $log, FILE_APPEND \| LOCK_EX);
	echo $log;

	//}
	}
	}
	}
	<?php

	$port = 9679;
	$socket = stream_socket_server("tcp://0.0.0.0:{$port}", $errno, $errstr);
	if (!$socket) {return false;}

	while (1) {
	while ($conn = @stream_socket_accept($socket, 60, $peer)) {
	stream_set_blocking($conn, 0);
	$client_request = "";

	while (!strstr($client_request, "\n")) {
	$client_request .= fread($conn, 1);
	}

	$client_request = date('Y-m-d H:i:s') . ' ' . $peer . ' - ' . $client_request;

	//log.txt
	file_put_contents('log.txt', $client_request, FILE_APPEND \| LOCK_EX);
	//cli
	echo $client_request;

	//Send to client:
	if (strstr($client_request, 'GET /')) {
	$headers = "HTTP/1.0 200 OK\n"
	. "Content-Type: text/html\n"
	. "\n";
	$body = "<h1>Greetings. You've reached our server!</h1>" . $client_request;
	$client_request = $headers.$body;
	}

	if ((int) fwrite($conn, $client_request) < 1) {
	trigger_error("Write to socket failed!");
	}

	stream_socket_shutdown($conn, STREAM_SHUT_WR);
	fclose($conn);
	fclose($socket);
	$socket = stream_socket_server("tcp://0.0.0.0:{$port}", $errno, $errstr);
	}
	}