- added fifo_server.php, a fifo net relay, on behalf of Juha Heinanen

  With fifo_server.php you can run ser on one machine and serweb (or other
  fifo dependent stuff) on another one

utils/fifo_relay/fifo_server.php

@@ -0,0 +1,194 @@
+#!/usr/bin/php4 -q
+<?php
+// $Id$
+// fifo_server.php - fifo/internet relay
+
+
+/*
+ * Copyright (C) 2004 Juha Heinanen
+ *
+ * This file is part of ser, a free SIP server.
+ *
+ * ser is free software; you can redistribute it and/or modify
+ * it under the terms of the GNU General Public License as published by
+ * the Free Software Foundation; either version 2 of the License, or
+ * (at your option) any later version
+ *
+ * For a license to use the ser software under conditions
+ * other than those described here, or to purchase support for this
+ * software, please contact iptel.org by e-mail at the following addresses:
+ *    [email protected]
+ *
+ * ser is distributed in the hope that it will be useful,
+ * but WITHOUT ANY WARRANTY; without even the implied warranty of
+ * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
+ * GNU General Public License for more details.
+ *
+ * You should have received a copy of the GNU General Public License 
+ * along with this program; if not, write to the Free Software 
+ * Foundation, Inc., 59 Temple Place, Suite 330, Boston, MA  02111-1307  USA
+ *
+ * History:
+ * -------
+ * 2004-06-11: fifo_server.php introduced as interim solution
+ *             until ser fifo natively supports tcp/ip access
+ */
+
+error_reporting (E_ALL);
+
+require("/etc/ser/fifo_server.cfg");
+
+/* Check if fifo server is needed */
+if ($fifo_server_address == NULL) {
+  return;
+}
+
+/* Allow the script to hang around waiting for connections. */
+set_time_limit (0);
+
+/* Turn on implicit output flushing so we see what we're getting
+ * as it comes in. */
+ob_implicit_flush ();
+
+$fifo_clients = "/etc/ser/fifo_server.clients";
+
+global $mtime, $clients;
+$mtime = 0;
+
+function fifo_allow($fifo_clients, $addr) {
+  global $mtime, $clients;
+  $long_addr = ip2long($addr);
+  if (!file_exists($fifo_clients)) {
+    echo "fifo_server.clients file does not exist!\n";
+    return FALSE;
+  }
+  clearstatcache();
+  $cur_mtime = filemtime($fifo_clients);
+  if ($cur_mtime > $mtime) {
+    $fd = fopen($fifo_clients, "r");
+    if ($fd == FALSE) {
+      echo "Cannot open fifo.clients file!\n";
+      return FALSE;
+    }
+    $clients = array();
+    while (!feof ($fd)) {
+      $client = ip2long(fgets($fd, 4096));
+      if ($client != -1) {
+	$clients[] = $client;
+      }
+    }
+    fclose ($fd);
+    $mtime = $cur_mtime;
+  }
+  return in_array($long_addr, $clients, TRUE);
+}
+
+if (($sock = socket_create (AF_INET, SOCK_STREAM, 0)) < 0) {
+    echo "socket_create() failed: " . socket_strerror ($sock) . "\n";
+    return;
+}
+
+if (($ret = socket_bind($sock, $fifo_server_address, $fifo_server_port)) < 0) {
+  echo "socket_bind() failed: " . socket_strerror ($ret) . "\n";
+  socket_close($sock);
+  return;
+}
+
+if (($ret = socket_listen ($sock, 5)) < 0) {
+  echo "socket_listen() failed: " . socket_strerror ($ret) . "\n";
+  socket_close($sock);
+  return;
+}
+
+do {
+  if (($msgsock = socket_accept($sock)) < 0) {
+    echo "socket_accept() failed: ".socket_strerror($msgsock)."\n";
+    socket_close($msgsock);
+    continue;
+  }
+
+  socket_getpeername($msgsock, $addr);
+
+  if (!fifo_allow($fifo_clients, $addr)) {
+    $msg = "403 Forbidden\n";
+    socket_write($msgsock, $msg, strlen($msg));
+    socket_shutdown($msgsock);
+    socket_close($msgsock);
+    continue;
+  }
+      
+  if (FALSE === ($fifo_cmd = socket_read ($msgsock, 8192, PHP_BINARY_READ))) {
+    echo "socket_read() failed: ".socket_strerror(socket_last_error($msgsock))."\n";
+    socket_shutdown($msgsock);
+    socket_close($msgsock);
+    continue;
+  }
+
+  $fifo_reply_file_name = "ser_fifo_reply_".rand();
+  $fifo_reply_file = "/tmp/".$fifo_reply_file_name;
+
+  $fifo_cmd = str_replace("REPLY_FILE_NAME", $fifo_reply_file_name, $fifo_cmd);
+  
+  /* add command separator */
+  $fifo_cmd=$fifo_cmd."\n";
+  
+  $fifo_handle=fopen( "/tmp/ser_fifo", "w" );
+  if (!$fifo_handle) {
+    $msg = "sorry -- cannot open write fifo";
+    socket_write($msgsock, $msg, strlen($msg));
+    socket_shutdown($msgsock);
+    socket_close($msgsock);
+    continue;
+  }
+  
+  /* create fifo for replies */
+  @system("mkfifo -m 666 ".$fifo_reply_file);
+
+  /* write fifo command */
+  if (fwrite( $fifo_handle, $fifo_cmd) == -1) {
+    @unlink($fifo_reply_file);
+    @fclose($fifo_handle);
+    $msg = "sorry -- fifo writing error";
+    socket_write($msgsock, $msg, strlen($msg));
+    socket_shutdown($msgsock);
+    socket_close($msgsock);
+    continue;
+  }
+
+  @fclose($fifo_handle);
+  
+  /* read output now */
+  @$fp = fopen($fifo_reply_file, "r");
+  if (!$fp) {
+    @unlink($fifo_reply_file);
+    $msg = "sorry -- reply fifo opening error";
+    socket_write($msgsock, $msg, strlen($msg));
+    socket_shutdown($msgsock);
+    socket_close($msgsock);
+    continue;
+  }
+  $status = fgetS($fp, 256);
+  
+  if (!$status) {
+    @unlink($fifo_reply_file);
+    $msg = "sorry -- reply fifo reading error";
+    socket_write($msgsock, $msg, strlen($msg));
+    socket_shutdown($msgsock);
+    socket_close($msgsock);
+    continue;
+  }
+  
+  socket_write($msgsock, $status, strlen($status));
+  
+  $rest = fread($fp, 8192);
+  @unlink($fifo_reply_file);
+
+  socket_write($msgsock, $rest, strlen($rest));
+
+  socket_close ($msgsock);
+
+} while (true);
+
+socket_close ($sock);
+
+?>