186 lines
3.5 KiB
PHP
186 lines
3.5 KiB
PHP
<?php
|
|
/**
|
|
* Created by PhpStorm.
|
|
* User: lucas
|
|
* Date: 07/12/17
|
|
* Time: 19:48
|
|
*/
|
|
|
|
namespace api\module;
|
|
|
|
|
|
use \database\core\Repo;
|
|
use \error\core\Error;
|
|
use \error\core\Err;
|
|
use kwebsocket\core\wsinterop;
|
|
|
|
class message
|
|
{
|
|
|
|
public function GET_emergency($argv){
|
|
extract($argv);
|
|
|
|
$messages = [];
|
|
|
|
return ["sent" => true, "messages" => $messages];
|
|
//TODO: tout poster dans la BDD
|
|
}
|
|
|
|
public function POST_emergency($argv){
|
|
extract($argv);
|
|
|
|
/* (1) Get ID_USER if connected
|
|
---------------------------------------------------------*/
|
|
$id_user = null;
|
|
$name = null;
|
|
|
|
if( count($_SESSION['ADMIN']) > 0 )
|
|
$id_user = $_SESSION['ADMIN']['id'];
|
|
|
|
elseif( count($_SESSION['USER']) > 0 )
|
|
$id_user = $_SESSION['USER']['id'];
|
|
|
|
else
|
|
$name = $_SESSION['NAME'];
|
|
|
|
|
|
/* (2) Create emergenct
|
|
---------------------------------------------------------*/
|
|
/* (1) Try to create entry */
|
|
$id_created = Repo::request('emergency', 'create',
|
|
$id_user,
|
|
$name,
|
|
$message,
|
|
0,
|
|
$location[0],
|
|
$location[1],
|
|
$URL_0
|
|
);
|
|
|
|
/* (2) If cannot create -> dispatch error */
|
|
if( $id_created === false )
|
|
return ['error' => new Error(Err::RepoError)];
|
|
|
|
|
|
|
|
/* (3) Send to WebSocket
|
|
---------------------------------------------------------*/
|
|
/* (1) Open socket */
|
|
$wsi = new wsinterop('localhost', 9998);
|
|
|
|
/* (2) Send data */
|
|
$wsi->send([
|
|
'operation' => 'PostMessage',
|
|
'message' => $message,
|
|
'username' => $_SESSION['NAME'],
|
|
'location' => $location,
|
|
'id' => $id_created,
|
|
'channelType' => 'Emergency',
|
|
'channelName' => "$URL_0"
|
|
]);
|
|
|
|
/* (3) Close socket */
|
|
$wsi->close();
|
|
|
|
|
|
return ['sent' => intval($id_created) ];
|
|
}
|
|
|
|
public function DELETE_emergency($argv){
|
|
extract($argv);
|
|
|
|
$wsi = new wsinterop("localhost",9998);
|
|
|
|
$wsi->send([
|
|
"operation" => "DelMessage",
|
|
"id" => $id,
|
|
"channelType" => "Emergency",
|
|
"channelName" => is_null($URL_0) ? "" : "$URL_0"
|
|
]);
|
|
|
|
$wsi->close();
|
|
|
|
return ["sent" => true];
|
|
//TODO: tout poster dans la BDD
|
|
}
|
|
|
|
public function PUT_emergency($argv){
|
|
extract($argv);
|
|
|
|
$wsi = new wsinterop("localhost",9998);
|
|
|
|
$wsi->send([
|
|
"operation" => "UpdMessage",
|
|
"id" => $id,
|
|
"message" => $message,
|
|
"channelType" => "Emergency",
|
|
"channelName" => is_null($URL_0) ? "" : "$URL_0"
|
|
]);
|
|
|
|
$wsi->close();
|
|
|
|
return ["sent" => true];
|
|
//TODO: tout poster dans la BDD
|
|
}
|
|
|
|
public function POST_event($argv){
|
|
extract($argv);
|
|
|
|
$wsi = new wsinterop("localhost",9998);
|
|
|
|
$wsi->send([
|
|
"operation" => "PostMessage",
|
|
"message" => $message,
|
|
"username" => $_SESSION['NAME'],
|
|
"location" => $location,
|
|
"type" => $type,
|
|
//TODO implémenter la récupération d'id depuis la bdd
|
|
"id" => uniqid(),
|
|
"channelType" => "Event",
|
|
"channelName" => is_null($URL_0) ? "" : "$URL_0"
|
|
]);
|
|
|
|
$wsi->close();
|
|
|
|
return ["sent" => true];
|
|
//TODO: tout poster dans la BDD
|
|
}
|
|
|
|
public function DELETE_event($argv){
|
|
extract($argv);
|
|
|
|
$wsi = new wsinterop("localhost",9998);
|
|
|
|
$wsi->send([
|
|
"operation" => "DelMessage",
|
|
"id" => $id,
|
|
"channelType" => "Event",
|
|
"channelName" => is_null($URL_0) ? "" : "$URL_0"
|
|
]);
|
|
|
|
$wsi->close();
|
|
|
|
return ["sent" => true];
|
|
//TODO: tout poster dans la BDD
|
|
}
|
|
|
|
public function PUT_event($argv){
|
|
extract($argv);
|
|
|
|
$wsi = new wsinterop("localhost",9998);
|
|
|
|
$wsi->send([
|
|
"operation" => "UpdMessage",
|
|
"id" => $id,
|
|
"message" => $message,
|
|
"channelType" => "Event",
|
|
"channelName" => is_null($URL_0) ? "" : "$URL_0"
|
|
]);
|
|
|
|
$wsi->close();
|
|
|
|
return ["sent" => true];
|
|
//TODO: tout poster dans la BDD
|
|
}
|
|
|
|
} |