Started rewriting the new version

json_sms.php already reflects that. The old class files are still around, though.
This commit is contained in:
Gergely Polonkai (W00d5t0ck) 2012-09-25 18:56:03 +02:00
parent 2fecdaf169
commit 80376ff566
9 changed files with 271 additions and 26 deletions

10
.htaccess Normal file
View File

@ -0,0 +1,10 @@
<IfModule mod_rewrite.c>
RewriteEngine On
#<IfModule mod_vhost_alias.c>
# RewriteBase /
#</IfModule>
RewriteCond %{REQUEST_FILENAME} !-f
RewriteRule ^(.*)$ json_sms.php [QSA,L]
</IfModule>

View File

@ -1,39 +1,107 @@
<?php <?php
require_once 'jsonRPCServer.php'; require __DIR__.'/vendor/autoload.php';
require_once 'smsSender.php';
require_once 'postgresGatewayBackend.php';
require_once 'gnokiiSMSBackend.php';
session_start(); use Symfony\Component\HttpFoundation\Request;
use Symfony\Component\HttpFoundation\Response;
use Symfony\Component\Routing\RouteCollection;
use Symfony\Component\Routing\Route;
use Symfony\Component\Routing\RequestContext;
use Symfony\Component\Routing\Matcher\UrlMatcher;
use Symfony\Component\Routing\Exception\ResourceNotFoundException;
use Symfony\Component\Routing\Exception\MethodNotAllowedException;
try use SmsGateway\Sender\GnokiiSender;
{ use SmsGateway\Logger\DatabaseLogger;
$dbBackend = new postgresGatewayBackend('localhost', 'sms_gateway', 'quaiy8Zu', 'sms_gateway'); use SmsGateway\Backend\DatabaseBackend;
} use SmsGateway\RpcServer;
catch (PDOException $e)
{ $request = Request::createFromGlobals();
header('Status: 500 Internal Server Error (DB)');
$routes = new RouteCollection();
$routes->add('jsonHandle', new Route('/', array('controller' => 'handleJson'), array('_method' => 'POST')));
$context = new RequestContext();
$context->fromRequest($request);
$matcher = new UrlMatcher($routes, $context);
try {
$parameters = $matcher->match($request->getPathInfo());
} catch (ResourceNotFoundException $e) {
$response = new Response('Bad Request', 400);
$response->send();
exit;
} catch (MethodNotAllowedException $e) {
$response = new Response('Bad Request', 400);
$response->send();
exit; exit;
} }
try if ($request->getContentType() != 'json') {
{ $response = new Response('Bad Request', 400);
$smsBackend = new gnokiiSMSBackend(); $response->send();
}
catch (Exception $e)
{
header('Status: 500 Internal Server Error (SMS)');
exit; exit;
} }
try $jsonData = json_decode($request->getContent(), true);
{ if ($jsonData === null) {
$smsSender = new smsSender($dbBackend, $smsBackend, session_id()); $response = new Response('Bad Request', 400);
$response->send();
exit;
} }
catch (Exception $e) if (!array_key_exists('method', $jsonData) || !array_key_exists('params', $jsonData) || !is_array($jsonData['params'])) {
{ $response = new Response('Bad Request', 400);
header('Status: 500 Internal Server Error'); $response->send();
exit;
}
$wantResponse = (!empty($jsonData['id']));
try {
$sender = new GnokiiSender();
} catch (Exception $e) {
$response = new Response('Internal Server Error: Sender cannot be instantiated.', 500);
$response->send();
exit; exit;
} }
jsonRPCServer::handle($smsSender); try {
$logger = new DatabaseLogger('pgsql:host=127.0.0.1;dbname=smsgateway', 'smsgateway', 'Imuiwai8');
} catch (PDOException $e) {
$response = new Response('Internal Server Error: Logger cannot be instantiated.', 500);
$response->send();
exit;
}
try {
$backend = new DatabaseBackend();
} catch (Exception $e) {
$response = new Response('Internal Server Error: Backend cannot be instantiated.', 500);
$response->send();
exit;
}
$handler = new RpcServer($backend, $logger, $sender);
try {
$result = $handler->handle($request, $jsonData);
} catch (Exception $e) {
if ($wantResponse) {
$jsonResponse = array(
'id' => $jsonData['id'],
'result' => null,
'error' => $e->getMessage(),
);
$response = new Response(json_encode($jsonResponse));
$response->send();
}
exit;
}
if ($wantResponse) {
$jsonResponse = array(
'id' => $jsonData['id'],
'result' => $result,
'error' => null,
);
$response = new Response(json_encode($jsonResponse), 200, array('Content-Type' => 'application/json'));
$response->send();
}

View File

@ -0,0 +1,8 @@
<?php
namespace SmsGateway\Backend;
use SmsGateway\BackendInterface;
class DatabaseBackend implements BackendInterface
{
}

View File

@ -0,0 +1,6 @@
<?php
namespace SmsGateway;
interface BackendInterface
{
}

View File

@ -0,0 +1,45 @@
<?php
namespace SmsGateway\Logger;
use SmsGateway\LoggerInterface;
use PDO;
class DatabaseLogger implements LoggerInterface
{
/**
* Constructor
*
* @param string $dsn The PDO datasource string
* @param string $username The username to use during the connection
* @param string $password The password for the above username
* @throws PDOException Upon database connection error
*/
public function __construct($dsn, $username, $password)
{
$this->dbh = new PDO($dsn, $username, $password, array(PDO::ATTR_ERRMODE => PDO::ERRMODE_EXCEPTION));
}
/**
* Log an audit event
*
* @param integer $type The message type
* @param string $username The user this audit log connects to. Can be
* NULL if the user is unauthenticated
* @param string $message The audit message
* @return boolean TRUE if the message was saved, FALSE otherwise
*/
public function auditLog($type, $username, $message)
{
}
/**
* Log a sent message
*
* @param string $username The username who sent this message
* @param string $recipient The recipient of the message
* @param string $message The message itself
*/
public function messageLog($username, $recipient, $message)
{
}
}

View File

@ -0,0 +1,27 @@
<?php
namespace SmsGateway;
interface LoggerInterface
{
const SMSSENDER_AUDIT_LOGIN = 1;
/**
* Log an audit event
*
* @param integer $type The message type
* @param string $username The user this audit log connects to. Can be
* NULL if the user is unauthenticated
* @param string $message The audit message
* @return boolean TRUE if the message was saved, FALSE otherwise
*/
public function auditLog($type, $username, $message);
/**
* Log a sent message
*
* @param string $username The username who sent this message
* @param string $recipient The recipient of the message
* @param string $message The message itself
*/
public function messageLog($username, $recipient, $message);
}

View File

@ -0,0 +1,67 @@
<?php
namespace SmsGateway;
use Symfony\Component\HttpFoundation\Request;
use SmsGateway\BackendInterface;
use SmsGateway\LoggerInterface;
use SmsGateway\SenderInterface;
class RpcServer
{
/**
* The user backend
*
* @var SmsGateway\BackendInterface $backend
*/
private $backend;
/**
* The logger
*
* @var SmsGateway\LoggerInterface $logger
*/
private $logger;
/**
* The sender
*
* @var SmsGateway\SenderInterface $sender
*/
private $sender;
public function __construct(BackendInterface $backend, LoggerInterface $logger, SenderInterface $sender)
{
}
protected function login(array $params)
{
return true;
}
protected function send(array $params)
{
return true;
}
protected function logout(array $params)
{
return true;
}
public function handle(Request $request, array $jsonData)
{
$params = $jsonData['params'];
switch ($jsonData['method']) {
case 'login':
break;
case 'send':
break;
case 'logout':
break;
default:
throw new \Exception('Invalid request');
}
return 'ajaj';
}
}

View File

@ -0,0 +1,8 @@
<?php
namespace SmsGateway\Sender;
use SmsGateway\SenderInterface;
class GnokiiSender implements SenderInterface
{
}

View File

@ -0,0 +1,6 @@
<?php
namespace SmsGateway;
interface SenderInterface
{
}