remove makefile

daemons/Webhook.php

@@ -0,0 +1,111 @@
+<?php
+
+/*
+ * This file is part of RaspiSMS.
+ *
+ * (c) Pierre-Lin Bonnemaison <plebwebsas@gmail.com>
+ *
+ * This source file is subject to the GPL-3.0 license that is bundled
+ * with this source code in the file LICENSE.
+ */
+
+namespace daemons;
+
+use Monolog\Handler\StreamHandler;
+use Monolog\Logger;
+
+/**
+ * Phone daemon class.
+ */
+class Webhook extends AbstractDaemon
+{
+    private $webhook_queue;
+    private $last_message_at;
+    private $phone;
+    private $adapter;
+    private $bdd;
+
+    /**
+     * Constructor.
+     *
+     * @param array $phone : A phone table entry
+     */
+    public function __construct()
+    {
+        $name = 'RaspiSMS Daemon Webhook';
+        $logger = new Logger($name);
+        $logger->pushHandler(new StreamHandler(PWD_LOGS . '/raspisms.log', Logger::DEBUG));
+        $pid_dir = PWD_PID;
+        $no_parent = false; //Sended should be rattach to manager, so manager can stop him easily
+        $additional_signals = [];
+        $uniq = true; //Sender should be uniq
+
+        //Construct the daemon
+        parent::__construct($name, $logger, $pid_dir, $no_parent, $additional_signals, $uniq);
+
+        parent::start();
+    }
+
+    public function run()
+    {
+        $find_message = true;
+        while ($find_message)
+        {
+            //Call message
+            $msgtype = null;
+            $maxsize = 409600;
+            $message = null;
+
+            $error_code = null;
+            $success = msg_receive($this->webhook_queue, QUEUE_TYPE_WEBHOOK, $msgtype, $maxsize, $message, true, 0, $error_code);
+            if (!$success)
+            {
+                $this->logger->critical('Error for webhook queue reading, error code : ' . $error_code);
+            }
+
+            if (!$message)
+            {
+                $find_message = false;
+
+                continue;
+            }
+
+            $this->logger->info('Trigger webhook : ' . json_encode($message));
+
+            //Do the webhook http query
+            $curl = curl_init();
+            curl_setopt($curl, CURLOPT_URL, $message['url']);
+            curl_setopt($curl, CURLOPT_FOLLOWLOCATION, true);
+            curl_setopt($curl, CURLOPT_POST, true);
+            curl_setopt($curl, CURLOPT_POSTFIELDS, $message['datas']);
+            curl_exec($curl);
+            curl_close($curl);
+        }
+
+        usleep(0.5 * 1000000);
+    }
+
+    public function on_start()
+    {
+        //Set last message at to construct time
+        $this->last_message_at = microtime(true);
+
+        $this->webhook_queue = msg_get_queue(QUEUE_ID_WEBHOOK);
+
+        $this->logger->info('Starting Webhook daemon with pid ' . getmypid());
+    }
+
+    public function on_stop()
+    {
+        //Delete queue on daemon close
+        $this->logger->info('Closing queue : ' . QUEUE_ID_WEBHOOK);
+        msg_remove_queue($this->webhook_queue);
+
+        $this->logger->info('Stopping Webhook daemon with pid ' . getmypid());
+    }
+
+    public function handle_other_signals($signal)
+    {
+        $this->logger->info('Signal not handled by ' . $this->name . ' Daemon : ' . $signal);
+    }
+}