hoge

caputomarcos · Dec 31, 2022 · 933bd02 · 933bd02
1 parent 4021b87
commit 933bd02
Show file tree

Hide file tree

Showing 5 changed files with 19 additions and 20 deletions.
diff --git a/docs/bus.htm b/docs/bus.htm
@@ -25,10 +25,8 @@
       var map = L.map('map');
       L.tileLayer('https://tile.openstreetmap.org/{z}/{x}/{y}.png').addTo(map);
       map.setView([35.3386861, 139.4870951], 7);
-        alert("msgData1");
       function debug(msgData) {
         var msg = JSON.parse(msgData);
-        alert(msg);
         //map.setView([msg.latitude, msg.longitude]);
         //L.marker([msg.latitude, msg.longitude],{"color": "#910000"}).addTo(map);
         for (var i = 0; i < msg.length; i++) {

diff --git a/docs/bus.wasm b/docs/bus.wasm
diff --git a/examples/bus.json b/examples/bus.json
@@ -2,7 +2,7 @@
     {
         "id": "8740d4c87aa226d5",
         "type": "http request",
-        "z": "506a7e799b8b8c67",
+        "z": "54d24c374bb820d2",
         "name": "",
         "method": "GET",
         "ret": "obj",
@@ -15,7 +15,7 @@
         "authType": "",
         "senderr": false,
         "headers": [],
-        "x": 390,
+        "x": 330,
         "y": 120,
         "wires": [
             [
@@ -26,7 +26,7 @@
     {
         "id": "7d5ef118b8c6f3cb",
         "type": "inject",
-        "z": "506a7e799b8b8c67",
+        "z": "54d24c374bb820d2",
         "name": "",
         "props": [
             {
@@ -37,14 +37,14 @@
                 "vt": "str"
             }
         ],
-        "repeat": "1",
+        "repeat": "",
         "crontab": "",
-        "once": false,
+        "once": true,
         "onceDelay": 0.1,
         "topic": "",
         "payload": "",
         "payloadType": "date",
-        "x": 210,
+        "x": 150,
         "y": 120,
         "wires": [
             [
@@ -55,7 +55,7 @@
     {
         "id": "9ae96b81d3eb6fe2",
         "type": "debug",
-        "z": "506a7e799b8b8c67",
+        "z": "54d24c374bb820d2",
         "name": "debug 1",
         "active": true,
         "tosidebar": true,
@@ -64,8 +64,8 @@
         "complete": "false",
         "statusVal": "",
         "statusType": "auto",
-        "x": 560,
+        "x": 500,
         "y": 120,
         "wires": []
     }
-]
+]
diff --git a/flows.go b/flows.go
@@ -4,7 +4,7 @@ func flows() string { return `
     {
         "id": "8740d4c87aa226d5",
         "type": "http request",
-        "z": "506a7e799b8b8c67",
+        "z": "54d24c374bb820d2",
         "name": "",
         "method": "GET",
         "ret": "obj",
@@ -17,7 +17,7 @@ func flows() string { return `
         "authType": "",
         "senderr": false,
         "headers": [],
-        "x": 390,
+        "x": 330,
         "y": 120,
         "wires": [
             [
@@ -28,7 +28,7 @@ func flows() string { return `
     {
         "id": "7d5ef118b8c6f3cb",
         "type": "inject",
-        "z": "506a7e799b8b8c67",
+        "z": "54d24c374bb820d2",
         "name": "",
         "props": [
             {
@@ -39,14 +39,14 @@ func flows() string { return `
                 "vt": "str"
             }
         ],
-        "repeat": "1",
+        "repeat": "",
         "crontab": "",
-        "once": false,
+        "once": true,
         "onceDelay": 0.1,
         "topic": "",
         "payload": "",
         "payloadType": "date",
-        "x": 210,
+        "x": 150,
         "y": 120,
         "wires": [
             [
@@ -57,7 +57,7 @@ func flows() string { return `
     {
         "id": "9ae96b81d3eb6fe2",
         "type": "debug",
-        "z": "506a7e799b8b8c67",
+        "z": "54d24c374bb820d2",
         "name": "debug 1",
         "active": true,
         "tosidebar": true,
@@ -66,7 +66,7 @@ func flows() string { return `
         "complete": "false",
         "statusVal": "",
         "statusType": "auto",
-        "x": 560,
+        "x": 500,
         "y": 120,
         "wires": []
     }

diff --git a/red.go b/red.go
@@ -27,8 +27,9 @@ func execute(nodeId string, msg string) {
 		var currentNodeId = flowItems[i]["id"]
 		var nodeWires = flowItems[i]["wires"].([]interface{})
 		if nodeType == "inject" && nodeId == "" {
+			int repeat, _ = strconv.Atoi(flowItems[i]["repeat"].(string))
 			go func() {
-				ticker := time.NewTicker(time.Second)
+				ticker := time.NewTicker(time.Second * repeat)
 				defer ticker.Stop()
 				done := make(chan bool)
 				go func() {