it490/testRabbitMQServer.php at main · tomasGonz67/it490 · GitHub

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
#!/usr/bin/php
<?php
require_once('path.inc');
require_once('get_host_info.inc');
require_once('rabbitMQLib.inc');

function doLogin($username,$password)
{

    //return false if not valid
}


function requestProcessor($request)
{
  echo "received request".PHP_EOL;
  var_dump($request);
  if(!isset($request['type']))
  {
    return "ERROR: unsupported message type";
  }
  switch ($request['type'])
  {
    case "insertFightersDMZ":
      require_once 'mysqlconnect.php';
      return insertFighters($request['fighters']);
    /*
    case "getFightersDMZ":
      require_once 'DMZ.php';
      return getFighters();
    */
    case "addFighter":
      require_once 'mysqlconnect.php';
      return addFighter($request['session'], $request['name']);
    case "joinLeague":
      require_once 'mysqlconnect.php';
      return joinLeague($request['username'], $request['password'], $request['id']);
    case "createLeague":
      require_once 'mysqlconnect.php';
      return createLeague($request['session']);
    case "sendMessage":
      require_once 'mysqlconnect.php';
      return getMessage($request['name'], $request['message']);
    case "getFighters":
      require_once 'mysqlconnect.php';
      // NOTE: CONTACTS DMZ.
      return getFighters();
    case "logout":
      require_once 'mysqlconnect.php';
      return logout($request['session']);
    case "login":
      $id=uniqid();
      $hash = md5($id);
      require_once 'mysqlconnect.php';
      return checkLogin($request['username'],$request['password'], $hash);

    case "register":
      require_once 'mysqlconnect.php';
      return register($request['username'],$request['password'], $request['email']);

    case "validate_session":
      return doValidate($request['sessionId']);
  }
  return array("returnCode" => '0', 'message'=>"Server received request and processed");
}

$server = new rabbitMQServer("testRabbitMQ.ini","testServer");

echo "testRabbitMQServer BEGIN".PHP_EOL;
$server->process_requests('requestProcessor');
echo "testRabbitMQServer END".PHP_EOL;
exit();
?>