Dynamic Websocket Node

This node is a dynamic websocket node.

Installation

1npm install @erhansiraci/dynamic-websocket

Usage

This node is a dynamic websocket node. It can be used to create a websocket connection to a server. The url of the server can be set dynamically by msg.uri prop of the input message. The node will try to connect to the server and send the message to the server. The node will also receive the message from the server and send it to the output message.

Example

1[
2    {
3        "id": "67e096bb997ecf28",
4        "type": "debug",
5        "z": "e453a28f46a90931",
6        "name": "debug 29",
7        "active": true,
8        "tosidebar": true,
9        "console": false,
10        "tostatus": false,
11        "complete": "true",
12        "targetType": "full",
13        "statusVal": "",
14        "statusType": "auto",
15        "x": 320,
16        "y": 320,
17        "wires": []
18    },
19    {
20        "id": "5990d0c629e115ba",
21        "type": "websocket in",
22        "z": "e453a28f46a90931",
23        "name": "",
24        "server": "6637e80e61fae304",
25        "client": "",
26        "x": 130,
27        "y": 320,
28        "wires": [
29            [
30                "67e096bb997ecf28"
31            ]
32        ]
33    },
34    {
35        "id": "32a9621309520400",
36        "type": "websocket in",
37        "z": "e453a28f46a90931",
38        "name": "",
39        "server": "66cdf876c88c0df7",
40        "client": "",
41        "x": 130,
42        "y": 260,
43        "wires": [
44            [
45                "dc0f26e8db57aede"
46            ]
47        ]
48    },
49    {
50        "id": "dc0f26e8db57aede",
51        "type": "debug",
52        "z": "e453a28f46a90931",
53        "name": "out_test2",
54        "active": true,
55        "tosidebar": true,
56        "console": false,
57        "tostatus": false,
58        "complete": "payload",
59        "targetType": "msg",
60        "statusVal": "",
61        "statusType": "auto",
62        "x": 320,
63        "y": 260,
64        "wires": []
65    },
66    {
67        "id": "030905b080a5a585",
68        "type": "inject",
69        "z": "e453a28f46a90931",
70        "name": "test1",
71        "props": [
72            {
73                "p": "uri",
74                "v": "ws://127.0.0.1:1880/ws/test1",
75                "vt": "str"
76            },
77            {
78                "p": "payload"
79            }
80        ],
81        "repeat": "",
82        "crontab": "",
83        "once": false,
84        "onceDelay": 0.1,
85        "topic": "",
86        "payload": "",
87        "payloadType": "date",
88        "x": 150,
89        "y": 80,
90        "wires": [
91            [
92                "238a88e3da7c6636"
93            ]
94        ]
95    },
96    {
97        "id": "6ec8b68b4cc52b04",
98        "type": "debug",
99        "z": "e453a28f46a90931",
100        "name": "out_websocket",
101        "active": true,
102        "tosidebar": true,
103        "console": false,
104        "tostatus": false,
105        "complete": "payload",
106        "targetType": "msg",
107        "statusVal": "",
108        "statusType": "auto",
109        "x": 570,
110        "y": 140,
111        "wires": []
112    },
113    {
114        "id": "238a88e3da7c6636",
115        "type": "dynamic-websocket",
116        "z": "e453a28f46a90931",
117        "name": "dynamic-websocket",
118        "x": 360,
119        "y": 140,
120        "wires": [
121            [
122                "6ec8b68b4cc52b04"
123            ]
124        ]
125    },
126    {
127        "id": "874ad9f0d6b30f9c",
128        "type": "inject",
129        "z": "e453a28f46a90931",
130        "name": "test2",
131        "props": [
132            {
133                "p": "uri",
134                "v": "ws://127.0.0.1:1880/ws/test2",
135                "vt": "str"
136            },
137            {
138                "p": "payload"
139            }
140        ],
141        "repeat": "",
142        "crontab": "",
143        "once": false,
144        "onceDelay": 0.1,
145        "topic": "",
146        "payload": "",
147        "payloadType": "date",
148        "x": 150,
149        "y": 200,
150        "wires": [
151            [
152                "238a88e3da7c6636"
153            ]
154        ]
155    },
156    {
157        "id": "0a79a663bbc0d464",
158        "type": "inject",
159        "z": "e453a28f46a90931",
160        "name": "empty",
161        "props": [
162            {
163                "p": "payload"
164            }
165        ],
166        "repeat": "",
167        "crontab": "",
168        "once": false,
169        "onceDelay": 0.1,
170        "topic": "",
171        "payload": "",
172        "payloadType": "date",
173        "x": 150,
174        "y": 140,
175        "wires": [
176            [
177                "238a88e3da7c6636"
178            ]
179        ]
180    },
181    {
182        "id": "14edf6c99cb90e5d",
183        "type": "inject",
184        "z": "e453a28f46a90931",
185        "name": "",
186        "props": [
187            {
188                "p": "payload"
189            }
190        ],
191        "repeat": "",
192        "crontab": "",
193        "once": false,
194        "onceDelay": 0.1,
195        "topic": "",
196        "payload": "{\"reply\":\"test\"}",
197        "payloadType": "json",
198        "x": 120,
199        "y": 380,
200        "wires": [
201            [
202                "b889b69550c1cccb"
203            ]
204        ]
205    },
206    {
207        "id": "b889b69550c1cccb",
208        "type": "websocket out",
209        "z": "e453a28f46a90931",
210        "name": "",
211        "server": "6637e80e61fae304",
212        "client": "",
213        "x": 340,
214        "y": 380,
215        "wires": []
216    },
217    {
218        "id": "aca5baacb0a4a33a",
219        "type": "inject",
220        "z": "e453a28f46a90931",
221        "name": "",
222        "props": [
223            {
224                "p": "payload"
225            }
226        ],
227        "repeat": "",
228        "crontab": "",
229        "once": false,
230        "onceDelay": 0.1,
231        "topic": "",
232        "payload": "{\"reply\":\"test2\"}",
233        "payloadType": "json",
234        "x": 120,
235        "y": 440,
236        "wires": [
237            [
238                "67ce4606921215b1"
239            ]
240        ]
241    },
242    {
243        "id": "67ce4606921215b1",
244        "type": "websocket out",
245        "z": "e453a28f46a90931",
246        "name": "",
247        "server": "66cdf876c88c0df7",
248        "client": "",
249        "x": 340,
250        "y": 440,
251        "wires": []
252    },
253    {
254        "id": "6637e80e61fae304",
255        "type": "websocket-listener",
256        "path": "/ws/test1",
257        "wholemsg": "false"
258    },
259    {
260        "id": "66cdf876c88c0df7",
261        "type": "websocket-listener",
262        "path": "/ws/test2",
263        "wholemsg": "false"
264    }
265]

License

No License

Author

Erhan Siraci

Alper Yazir