X-Git-Url: http://git.pjr.cc/?p=ga4php.git;a=blobdiff_plain;f=gaas%2Fgaasd%2Fgaasd.php;h=9ce58c6fc063119469c6ef07ca92e0bfca98bcd9;hp=cb716a74d60697026ed2f61d66b4d9526eda6761;hb=01b5d6290a0d704099cef17071c1fc50b3049bee;hpb=1d6adec6039a635e97e31592bbbcbf4357e33c28

diff --git a/gaas/gaasd/gaasd.php b/gaas/gaasd/gaasd.php
index cb716a7..9ce58c6 100644
--- a/gaas/gaasd/gaasd.php
+++ b/gaas/gaasd/gaasd.php
@@ -1,7 +1,7 @@
 <?php 
 
 // get out master library for gaasd daemon
-require_once("../lib/lib.php");
+require_once("../lib/gaasdLib.php");
 
 // first we want to fork into the background like all good daemons should
 //$pid = pcntl_fork();
@@ -43,8 +43,50 @@ if($pid == -1) {
 		} else if(!$forked) {
 			// I am the child, i process the request
 			// all the shit down below goes in here
+			$recvd = "";
+			$continue = true;
+			while($continue) {
+				$size = socket_recv($data_socket, $recvd_a, 1024, 0);
+				$recvd .= $recvd_a;
+				if(preg_match("/.*\:EOD$/", $recvd)) {
+					// we have a full string... break out
+					$continue = false;
+					break;
+				}
+			}
+			
+			$xps = explode(":", $recvd);
+			$component =  unserialize(base64_decode($xps[1]));
+			$msg_type = $component["type"];
+			$msg = $component["data"];
+
+			$data_returned = processMessage($msg_type, $msg);
+			
+			$d_comp["type"] = $msg_type;
+			$d_comp["data"] = $data_returned;
+			
+			$realdata_returning = "AS:".base64_encode(serialize($d_comp)).":EOD";
+			
+			socket_send($data_socket, $realdata_returning, strlen($realdata_returning), 0);
+			socket_close($data_socket);
 		}
 	}
 }
 
+function processMessage($msg_type, $msg)
+{
+	global $MESSAGES;
+
+	$function = $MESSAGES[$msg_type]."_server";
+	
+	if(function_exists($function)) {
+		return $function($msg);
+	} else {
+		error_log("Call to undefined function! $function\n");
+		return false;
+	}
+	
+}
+
+
 ?>
\ No newline at end of file