From: Vincent <vincent@enhydra.fr>
Date: Sat, 24 Oct 2020 17:10:22 +0000 (+0200)
Subject: .
X-Git-Url: http://git.cubedesigners.com/?a=commitdiff_plain;h=e6c1af692a850abb010e02bb8c6ae6350c29a245;p=tortuga-home.git

.
---

diff --git a/.idea/workspace.xml b/.idea/workspace.xml
index 623af14..1366b27 100644
--- a/.idea/workspace.xml
+++ b/.idea/workspace.xml
@@ -2,13 +2,10 @@
 <project version="4">
   <component name="ChangeListManager">
     <list default="true" id="352ce63a-b52a-41a2-979b-becda7920939" name="Default" comment=".">
+      <change afterPath="$PROJECT_DIR$/servers/hue.php" afterDir="false" />
       <change beforePath="$PROJECT_DIR$/.idea/workspace.xml" beforeDir="false" afterPath="$PROJECT_DIR$/.idea/workspace.xml" afterDir="false" />
-      <change beforePath="$PROJECT_DIR$/config/global.php" beforeDir="false" afterPath="$PROJECT_DIR$/config/global.php" afterDir="false" />
-      <change beforePath="$PROJECT_DIR$/config/rooms.php" beforeDir="false" afterPath="$PROJECT_DIR$/config/rooms.php" afterDir="false" />
-      <change beforePath="$PROJECT_DIR$/scripts/domoticz_device_event.php" beforeDir="false" afterPath="$PROJECT_DIR$/scripts/domoticz_device_event.php" afterDir="false" />
-      <change beforePath="$PROJECT_DIR$/scripts/lib/off.php" beforeDir="false" afterPath="$PROJECT_DIR$/scripts/lib/off.php" afterDir="false" />
+      <change beforePath="$PROJECT_DIR$/scripts/lib/hue.php" beforeDir="false" afterPath="$PROJECT_DIR$/scripts/lib/hue.php" afterDir="false" />
       <change beforePath="$PROJECT_DIR$/scripts/lib/scenes.php" beforeDir="false" afterPath="$PROJECT_DIR$/scripts/lib/scenes.php" afterDir="false" />
-      <change beforePath="$PROJECT_DIR$/scripts/lib/squeezebox.php" beforeDir="false" afterPath="$PROJECT_DIR$/scripts/lib/squeezebox.php" afterDir="false" />
     </list>
     <option name="SHOW_DIALOG" value="false" />
     <option name="HIGHLIGHT_CONFLICTS" value="true" />
@@ -236,7 +233,7 @@
     <property name="com.android.tools.idea.instantapp.provision.ProvisionBeforeRunTaskProvider.myTimeStamp" value="1553247665857" />
     <property name="dumpAutoload T:/Drive/Works/home/composer.json" value="--no-interaction --ansi --verbose --optimize" />
     <property name="editor.config.ad.shown" value="true" />
-    <property name="last_opened_file_path" value="$PROJECT_DIR$/config" />
+    <property name="last_opened_file_path" value="$PROJECT_DIR$/servers" />
     <property name="list.type.of.created.stylesheet" value="Less" />
     <property name="nodejs_package_manager_path" value="npm" />
     <property name="project.structure.last.edited" value="Project" />
@@ -245,6 +242,13 @@
     <property name="settings.editor.selected.configurable" value="preferences.pluginManager" />
   </component>
   <component name="RecentsManager">
+    <key name="CopyFile.RECENT_KEYS">
+      <recent name="T:\Drive\Works\home\servers" />
+      <recent name="T:\Drive\Works\home\config" />
+      <recent name="T:\Drive\Works\home\images\backgrounds" />
+      <recent name="T:\Drive\Works\home\tools\xplanet" />
+      <recent name="T:\Drive\Works\home\tools\pop" />
+    </key>
     <key name="MoveFile.RECENT_KEYS">
       <recent name="T:\Drive\Works\home\tools\xplanet" />
       <recent name="T:\Drive\Works\home\style\fonts\webfonts" />
@@ -252,13 +256,6 @@
       <recent name="T:\Drive\Works\home\images" />
       <recent name="D:\CloudStation\Works\home\style\fonts" />
     </key>
-    <key name="CopyFile.RECENT_KEYS">
-      <recent name="T:\Drive\Works\home\config" />
-      <recent name="T:\Drive\Works\home\images\backgrounds" />
-      <recent name="T:\Drive\Works\home\tools\xplanet" />
-      <recent name="T:\Drive\Works\home\tools\pop" />
-      <recent name="T:\Drive\Works\home\scripts\lib" />
-    </key>
   </component>
   <component name="RunManager">
     <configuration default="true" type="Applet">
@@ -273,6 +270,17 @@
         <option name="Make" enabled="true" />
       </method>
     </configuration>
+    <configuration default="true" type="ArquillianJUnit" factoryName="" nameIsGenerated="true">
+      <option name="arquillianRunConfiguration">
+        <value>
+          <option name="containerStateName" value="" />
+        </value>
+      </option>
+      <option name="TEST_OBJECT" value="class" />
+      <method v="2">
+        <option name="Make" enabled="true" />
+      </method>
+    </configuration>
     <configuration default="true" type="ArquillianTestNG" factoryName="">
       <option name="arquillianRunConfiguration">
         <value>
@@ -883,14 +891,8 @@
       <workItem from="1602581583330" duration="1284000" />
       <workItem from="1602862886793" duration="1014000" />
       <workItem from="1603095373591" duration="1368000" />
-      <workItem from="1603270756890" duration="2727000" />
-    </task>
-    <task id="LOCAL-00300" summary=".">
-      <created>1581951532460</created>
-      <option name="number" value="00300" />
-      <option name="presentableId" value="LOCAL-00300" />
-      <option name="project" value="LOCAL" />
-      <updated>1581951532461</updated>
+      <workItem from="1603270756890" duration="3366000" />
+      <workItem from="1603558842019" duration="446000" />
     </task>
     <task id="LOCAL-00301" summary=".">
       <created>1582014172949</created>
@@ -1228,7 +1230,14 @@
       <option name="project" value="LOCAL" />
       <updated>1603131455369</updated>
     </task>
-    <option name="localTasksCounter" value="349" />
+    <task id="LOCAL-00349" summary=".">
+      <created>1603276030272</created>
+      <option name="number" value="00349" />
+      <option name="presentableId" value="LOCAL-00349" />
+      <option name="project" value="LOCAL" />
+      <updated>1603276030273</updated>
+    </task>
+    <option name="localTasksCounter" value="350" />
     <servers />
   </component>
   <component name="TypeScriptGeneratedFilesManager">
@@ -1274,11 +1283,11 @@
       <screen x="0" y="0" width="2560" height="1040" />
     </state>
     <state x="872" y="161" key="#Plugins/0.0.2560.1040@0.0.2560.1040" timestamp="1596008801840" />
-    <state x="198" y="0" width="745" height="567" key="CommitChangelistDialog2" timestamp="1603131428714">
+    <state x="198" y="0" width="745" height="567" key="CommitChangelistDialog2" timestamp="1603275999359">
       <screen x="0" y="0" width="2560" height="1040" />
     </state>
     <state x="701" y="75" key="CommitChangelistDialog2/0.0.1920.1160@0.0.1920.1160" timestamp="1602171117745" />
-    <state x="198" y="0" width="745" height="567" key="CommitChangelistDialog2/0.0.2560.1040@0.0.2560.1040" timestamp="1603131428714" />
+    <state x="198" y="0" width="745" height="567" key="CommitChangelistDialog2/0.0.2560.1040@0.0.2560.1040" timestamp="1603275999359" />
     <state x="1114" y="443" key="NewPhpFileDialog" timestamp="1602146675515">
       <screen x="0" y="0" width="2560" height="1040" />
     </state>
@@ -1295,10 +1304,10 @@
       <screen x="0" y="0" width="2560" height="1040" />
     </state>
     <state x="295" y="0" width="1290" height="907" key="dock-window-1/0.0.2560.1040@0.0.2560.1040" timestamp="1603274697406" />
-    <state x="977" y="257" width="607" height="536" key="find.popup" timestamp="1598297024487">
+    <state x="977" y="257" width="607" height="536" key="find.popup" timestamp="1603559077781">
       <screen x="0" y="0" width="2560" height="1040" />
     </state>
-    <state x="977" y="257" width="607" height="536" key="find.popup/0.0.2560.1040@0.0.2560.1040" timestamp="1598297024487" />
+    <state x="977" y="257" width="607" height="536" key="find.popup/0.0.2560.1040@0.0.2560.1040" timestamp="1603559077781" />
   </component>
   <component name="antWorkspaceConfiguration">
     <option name="IS_AUTOSCROLL_TO_SOURCE" value="false" />
diff --git a/scripts/lib/hue.php b/scripts/lib/hue.php
index 8ab5f10..01372ff 100644
--- a/scripts/lib/hue.php
+++ b/scripts/lib/hue.php
@@ -11,20 +11,34 @@ function getHueInstance()
     return $hue;
 }
 
-//function hueScene($id,$intensity)
-//{
-//    $command=new Phue\Test\Command\
-//
-//    $hue = getHueInstance();
-//    $hue->sendCommand();
-//}
-
 function getHueState()
 {
     $hue = getHueInstance();
     return array('groups' => $hue->getGroups(), 'scenes' => $hue->getScenes(), 'lights' => $hue->getLights());
 }
 
+function hueCommand($action, $transitionTime)
+{
+    $redis = connectRedis();
+    $queue = $redis->igbget('hue_queue');
+    if (!is_array($queue)) {
+        $queue = [];
+    }
+    $command = $action;
+    $command['transitionTime'] = $transitionTime;
+    $queue[] = $command;
+    $redis->igbset('hue_queue', $queue);
+    $redis->publish('hue_queue', 'handle_queue');
+}
+
+function _hueCommand($action)
+{
+    if (isset($action['group'])) {
+        hueApplyScene($action['group'], $action['scene'], $action['transitionTime']);
+    } else if (isset($action['light'])) {
+        hueApplySceneLight($action['light'], $action['scene'], $action['transitionTime']);
+    }
+}
 
 function hueApplyScene($groupId, $sceneId, $transitionTime = null)
 {
diff --git a/scripts/lib/scenes.php b/scripts/lib/scenes.php
index 1e4c8c2..a92d4d3 100644
--- a/scripts/lib/scenes.php
+++ b/scripts/lib/scenes.php
@@ -738,11 +738,7 @@ function execScene($name, $fromUserAction = false, $transitionTime = null)
         }
 
         if ($action['type'] == 'hue') {
-            if (isset($action['group'])) {
-                hueApplyScene($action['group'], $action['scene'], $transitionTime);
-            } else if (isset($action['light'])) {
-                hueApplySceneLight($action['light'], $action['scene'], $transitionTime);
-            }
+            hueCommand($action,$transitionTime);
         } else if ($action['type'] == 'insteon') {
             insteonCommand($action['command']);
         } else if ($action['type'] == 'delay' || $action['type'] == 'scene') {
diff --git a/servers/hue.php b/servers/hue.php
new file mode 100644
index 0000000..9a7bd89
--- /dev/null
+++ b/servers/hue.php
@@ -0,0 +1,45 @@
+#!/usr/bin/php
+
+<?php
+require_once __DIR__ . "/../scripts/import.php";
+
+// Set time limit to indefinite execution
+set_time_limit(0);
+ignore_user_abort(true);
+
+echo 'Run hue server hue' . "\n";
+
+$redis = connectRedis();
+handleHueQueue();
+
+redisEventListener('hue_event', 'handleHueQueue');
+
+function handleHueQueue()
+{
+    global $redis;
+
+    while (true) {
+        $queue = $redis->igbget('hue_queue');
+        if (!is_array($queue)) {
+            $queue = [];
+            $redis->igbset('hue_queue', $queue);
+        }
+
+
+        if (!count($queue)) {
+            echo 'Queue empty ' . "\n";
+            break;
+        }
+
+        $queue = array_unique($queue);
+
+        echo 'Handle Queue : current state ' . json_encode($queue) . "\n";
+
+        $command = array_shift($queue);
+        $redis->igbset('hue_queue', $queue);
+        echo 'Run command ' . $command . "\n";
+        _hueCommand($command);
+        usleep(1000000 * 0.1);
+    }
+    echo 'End of handling queue' . "\n";
+}
\ No newline at end of file