init

.gitignore

@@ -0,0 +1 @@
+.htpasswd

.htaccess

@@ -0,0 +1,14 @@
+AuthUserFile /var/sms/.htpasswd
+AuthType Basic
+AuthName "SMS Service"
+
+Require valid-user
+<Files register.php>
+	Require user __gates__
+</Files>
+<Files sent.php>
+	Require user __gates__
+</Files>
+<Files received.php>
+	Require user __gates__
+</Files>

gates.php

@@ -0,0 +1,27 @@
+<?php
+require_once "sql.php";
+
+$where = "";
+$array = array();
+if(isset($_GET['id']))
+{
+	$id = intval($_GET['id']);
+	if($id <= 0)
+		error("Invalid id");
+
+	$where = "WHERE id=:id";
+	$array = array(":id" => $id);
+}
+
+$select = $db->prepare("SELECT * FROM gates ".$where);
+if(!$select->execute($array))
+	error("Unable to read gates");
+$gates = array();
+while($gate = $select->fetch())
+	$gates[] = array("id" => intval($gate['id']), "name" => $gate['name'],
+		"number" => $gate['number'], "address" => $gate['address'],
+		"port" => intval($gate['port']), "lastSeen" =>
+		strtotime($gate['lastSeen']));
+
+echo json_encode(array("timestamp" => time(), "gateTimeout" => $gateTimeout, "gates" => $gates));
+?>

messages.php

@@ -0,0 +1,54 @@
+<?php
+require_once "sql.php";
+
+$where = "";
+$array = array();
+
+if(isset($_GET['ids']))
+{
+	$ids = explode(",", $_GET['ids']);
+	$where = "WHERE id=0";
+	foreach($ids as $id)
+	{
+		$id = trim($id);
+		if($id != "")
+		{
+			$id = intval($id);
+			if($id <= 0)
+				error("Invalid ids");
+			$array[] = $id;
+			$where = $where." OR id=?";
+		}
+	}
+	if(count($array) == 0)
+		$where = "";
+}
+else if(isset($_GET['lastMessages']))
+{
+	$l = intval($_GET['lastMessages']);
+	if($l <= 0)
+		error("Invalid last messages");
+	$where = "ORDER BY id DESC LIMIT $l OFFSET 0";
+}
+else if(isset($_GET['lastMessagesTime']))
+{
+	$l = intval($_GET['lastMessagesTime']);
+	if($l <= 0)
+		error("Invalid last time messages");
+	$where = "WHERE time>=:time";
+	$array = array(":time" => date("Y-m-d H:i:s", time() - $l));
+}
+
+$select = $db->prepare("SELECT * FROM sent ".$where);
+
+if(!$select->execute($array))
+	error("Unable to read messages");
+$messages = array();
+while($msg = $select->fetch())
+	$messages[] = array("id" => intval($msg['id']), "recipient" => $msg['recipient'],
+		"text" => $msg['text'], "time" => strtotime($msg['time']),
+		"status" => intval($msg['status']), "gate" => intval($msg['gate']),
+		"timeStatus" => $msg['timeStatus'] ? strtotime($msg['timeStatus']) : 0);
+
+echo json_encode(array("timestamp" => time(), "messages" => $messages));
+?>

received.php

@@ -0,0 +1,29 @@
+<?php
+require_once "sql.php";
+if(isset($_GET['sender']))
+	$sender = $_GET['sender'];
+else
+	$sender = "";
+if(isset($_GET['text']))
+	$text = $_GET['text'];
+else
+	$text = "";
+
+if($sender == "")
+	error("Empty sender");
+
+$select = $db->prepare("SELECT id FROM gates WHERE address=:address");
+if(!$select->execute(array(":address" => $_SERVER['REMOTE_ADDR'])))
+	error("Unable to retrieve gate details");
+
+if($g = $select->fetch())
+{
+	$insert = $db->prepare("INSERT INTO `received` (`sender`, `text`, `gate`) VALUES (:sender, :text, :gate)");
+	if(!$insert->execute(array(":sender" => $sender, ":text" => $text, ":gate" => $g['id'])))
+		error("Failed to update database: ".$insert->errorInfo()[2]);
+	else
+		echo json_encode(array("id" => $db->lastInsertId()));
+}
+else
+	error("You're not allowed to do this");
+?>

register.php

@@ -0,0 +1,48 @@
+<?php
+require_once "sql.php";
+if(isset($_GET['name']))
+	$name = $_GET['name'];
+else
+	$name = "";
+if(isset($_GET['number']))
+	$number = $_GET['number'];
+else
+	$number = "";
+if(isset($_GET['port']))
+	$port = $_GET['port'];
+else
+	$port = "";
+
+if($name == "")
+	error("Empty name");
+if($number == "")
+	error("Empty number");
+if($port == "")
+	error("Empty port");
+$port = intval($port);
+if($port < 1 || $port > 65535)
+	error("Invalid port (1 <= port <= 65535)");
+
+$select = $db->prepare("SELECT id FROM gates WHERE number=:number");
+if($select->execute(array(":number" => $number)))
+{
+	if($g = $select->fetch())
+	{
+		$update = $db->prepare("UPDATE gates SET name=:name, address=:address, port=:port, lastSeen=NULL WHERE id=:id");
+		if($update->execute(array(":name" => $name, ":address" => $_SERVER['REMOTE_ADDR'], ":port" => $port, ":id" => $g['id'])))
+			echo json_encode(array("id" => intval($g['id']), "gateTimeout" => $gateTimeout));
+		else
+			error("Failed to update database");
+	}
+	else
+	{
+		$insert = $db->prepare("INSERT INTO gates (name, number, address, port) VALUES (:name, :number, :address, :port) ON DUPLICATE KEY UPDATE lastSeen=NULL");
+		if($insert->execute(array(":name" => $name, ":number" => $number, ":address" => $_SERVER['REMOTE_ADDR'], ":port" => $port)))
+			echo json_encode(array("id" => intval($db->lastInsertId()), "gateTimeout" => $gateTimeout));
+		else
+			error("Failed to insert into database");
+	}
+}
+else
+	error("Failed to query gates");
+?>

send.php

@@ -0,0 +1,104 @@
+<?php
+/*
+Status codes:
+0: sending
+1: sent
+2: failed to contact gate
+3: generic error
+4: no service
+5: no pdu
+6: radio off
+7: unknown error
+*/
+require_once "sql.php";
+if(isset($_GET['to']))
+	$to = $_GET['to'];
+else
+	$to = "";
+if(isset($_GET['gate']))
+	$gate = $_GET['gate'];
+else
+	$gate = "";
+if(isset($_GET['text']))
+	$text = $_GET['text'];
+else
+	$text = "";
+if(isset($_GET['maxWait']))
+	$maxWait = $_GET['maxWait'];
+else
+	$maxWait = "";
+
+if($to == "")
+	error("Empty recipient");
+if($text == "")
+	error("Empty text");
+if($gate == "")
+	error("No gate provided");
+if($maxWait == "")
+	error("Empty max wait");
+
+$gate = intval($gate);
+if($gate <= 0)
+	error("Invalid gate");
+$maxWait = intval($maxWait);
+if($maxWait < 0 || !is_numeric($_GET['maxWait']))
+	error("Invalid max wait");
+
+$select = $db->prepare("SELECT address, port, lastSeen FROM gates WHERE id=:gate");
+if(!$select->execute(array(":gate" => $gate)))
+	error("Unable to retrieve gate details");
+
+if($g = $select->fetch())
+{
+	if(intval(strtotime($g['lastSeen'])) < time() - $gateTimeout)
+		error("Gate is down");
+
+	$insert = $db->prepare("INSERT INTO `sent` (`recipient`, `text`, `status`, `gate`) VALUES (:recipient, :text, :status, :gate)");
+	if(!$insert->execute(array(":recipient" => $to, ":text" => $text, ":status" => 0, ":gate" => $gate)))
+		error("Failed to save message");
+	else
+	{
+		$id = intval($db->lastInsertId());
+		$out = http_get("http:/"."/".$g['address'].":".$g['port']."/send.php?to=".urlencode($to)."&text=".urlencode($text)."&id=".$id,
+				array("timeout" => 10, "connecttimeout" => 10));
+		if($out == "")
+		{
+			$update = $db->prepare("UPDATE sent SET `status`=2, `timeStatus`=NOW() WHERE `id`=:id");
+			if(!$update->execute(array(":id" => $id)))
+				error("Failed to update database after failed to contact gate (general failure)");
+			else
+				echo json_encode(array("id" => $id, "status" => 2));
+		}
+		else
+		{
+			$out = json_decode(http_parse_message($out)->body);
+			if(isset($out->error))
+			{
+				$update = $db->prepare("UPDATE sent SET `status`=7, `timeStatus`=NOW() WHERE `id`=:id");
+				if(!$update->execute(array(":id" => $id)))
+					error("Failed to update database after failed to contact gate (general failure)");
+				else
+					echo json_encode(array("id" => $id, "status" => 7, "error" => $out->error));
+			}
+			else
+			{
+				$status = 0;
+				$maxWait *= 1000;
+				do
+				{
+					$select = $db->prepare("SELECT status FROM sent WHERE id=:id");
+					if($select->execute(array(":id" => $id)))
+						if($f = $select->fetch())
+							$status = $f['status'];
+					$maxWait -= 100;
+					if($maxWait > 0)
+						usleep(100000);
+				} while($maxWait > 0 && $status == 0);
+				echo json_encode(array("id" => $id, "status" => $status));
+			}
+		}
+	}
+}
+else
+	error("Gate not found");
+?>

sent.php

@@ -0,0 +1,51 @@
+<?php
+/*
+Status codes:
+0: sending
+1: sent
+2: failed to contact gate
+3: generic error
+4: no service
+5: no pdu
+6: radio off
+7: unknown error
+*/
+require_once "sql.php";
+if(isset($_GET['id']))
+	$id = $_GET['id'];
+else
+	$id = "";
+if(isset($_GET['status']))
+	$status = $_GET['status'];
+else
+	$status = "";
+
+if($id == "")
+	error("Empty id");
+if($status == "")
+	error("Empty status");
+
+$id = intval($id);
+if($id <= 0)
+	error("Invalid id");
+$status = intval($status);
+if($status < 1 || $status > 7)
+	error("Invalid status");
+
+$select = $db->prepare("SELECT timeStatus, status FROM sent WHERE id=:id AND gate=(SELECT id FROM gates WHERE address=:address)");
+if(!$select->execute(array(":address" => $_SERVER['REMOTE_ADDR'], ":id" => $id)))
+	error("Unable to retrieve gate details");
+
+if($g = $select->fetch())
+{
+	if($g['timeStatus'] || $g['status'] != 0)
+		error("This status has already been set: ".$g['status']);
+	$update = $db->prepare("UPDATE sent SET `status`=:status, `timeStatus`=NOW() WHERE `id`=:id");
+	if(!$update->execute(array(":id" => $id, ":status" => $status)))
+		error("Failed to update database");
+	else
+		echo json_encode(array("id" => $id, "status" => $status));
+}
+else
+	error("You're not allowed to do this");
+?>

sql.php

@@ -0,0 +1,16 @@
+<?php
+function error($str)
+{
+	die(json_encode(array("error" => $str)));
+}
+
+try
+{
+	$db = new PDO('mysql:host=localhost;dbname=sms', "sms", "cWrzmRByJtjZ2ax4");
+}
+catch(Exception $e)
+{
+	error("Unable to connect to the database");
+}
+$gateTimeout = 5 * 60;
+?>