Skip to content

Feature/psd 459 move etw inject node into this repo #93

New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Open
DianaStefan5Minds wants to merge 23 commits into
base: develop
Choose a base branch
from
Open

Feature/psd 459 move etw inject node into this repo #93

Show file tree
Hide file tree
Changes from all commits
Commits
Show all changes
23 commits
Select commit Hold shift + click to select a range
dbab022
New version with updated client.ts (#89)
moellenbeck Jul 16, 2025
84a9eae
Release v1.15.4
process-engine-ci Jul 16, 2025
cb5c0f0
Merge branch 'develop'
moellenbeck Jul 22, 2025
139f9c1
Release v1.15.5
process-engine-ci Jul 22, 2025
416295f
Make scope for processcube-engine-config configurable via string, sec…
moellenbeck Jul 25, 2025
c164678
Release v1.16.0
process-engine-ci Jul 25, 2025
20e5fa6
Rename vars NODE_RED -> NODERED; Disconnect hooks after Node is close…
moellenbeck Oct 27, 2025
98532f2
Release v1.16.1
process-engine-ci Oct 27, 2025
9f26f34
Add etw-input-inject-node
DianaStefan5Minds Nov 5, 2025
936155f
Change group and color
DianaStefan5Minds Nov 5, 2025
05e6b2e
Add a button like the inject node has
DianaStefan5Minds Nov 5, 2025
c3448df
Add message to etw input inject
DianaStefan5Minds Nov 6, 2025
93de520
Disable cyclic timer creating to many db connections killing the engine
DianaStefan5Minds Nov 6, 2025
15eb4f8
Fix message spamming debug log
DianaStefan5Minds Nov 6, 2025
f1b5d81
Remove etw dropdown selection
DianaStefan5Minds Nov 7, 2025
dba8db7
Add default payload
DianaStefan5Minds Nov 7, 2025
1c39da2
Add needed variables and eventEmmiter
DianaStefan5Minds Nov 7, 2025
920190c
Add field for task property
DianaStefan5Minds Nov 7, 2025
8c95487
Rename the node to externaltask-inject
DianaStefan5Minds Nov 7, 2025
73180f3
Update icon and color
DianaStefan5Minds Nov 7, 2025
d6ebc6a
Update documentation
DianaStefan5Minds Nov 7, 2025
a7117fc
Fix type not being saved
DianaStefan5Minds Nov 7, 2025
5e019fb
Update flows
DianaStefan5Minds Nov 7, 2025
File filter

Filter by extension

Filter by extension
Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
11 changes: 11 additions & 0 deletions .processcube/nodered/.config.nodes.json
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -477,6 +477,17 @@
"module": "@5minds/node-red-contrib-processcube",
"file": "/usr/src/node-red/node_modules/@5minds/node-red-contrib-processcube/externaltask-input.js"
},
"externaltaskInject": {
"name": "externaltaskInject",
"types": [
"externaltask-inject"
],
"enabled": true,
"local": false,
"user": false,
"module": "@5minds/node-red-contrib-processcube",
"file": "/usr/src/node-red/node_modules/@5minds/node-red-contrib-processcube/externaltask-inject.js"
},
"externaltaskOutput": {
"name": "externaltaskOutput",
"types": [
Expand Down
148 changes: 146 additions & 2 deletions .processcube/nodered/.flows.json.backup
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -7,6 +7,14 @@
"info": "",
"env": []
},
{
"id": "f05192d33ea2cd16",
"type": "tab",
"label": "External Task Inject",
"disabled": false,
"info": "",
"env": []
},
{
"id": "c9ab699769824f2f",
"type": "tab",
Expand Down Expand Up @@ -1776,6 +1784,137 @@
"y": 1480,
"wires": []
},
{
"id": "9c5af4ae5b0cf8a9",
"type": "externaltask-input",
"z": "f05192d33ea2cd16",
"name": "ETWInjectTest",
"workername": "",
"engine": "42e6796dddd9d4db",
"topic": "ETWInjectTest",
"topicType": "str",
"workerConfig": "{}",
"workerConfigType": "json",
"traces": [],
"x": 170,
"y": 200,
"wires": [
[
"062e0b79deadef16"
]
]
},
{
"id": "062e0b79deadef16",
"type": "function",
"z": "f05192d33ea2cd16",
"name": "Do nothing",
"func": "throw new Error(\"Test Error\");\n\nreturn msg;",
"outputs": 1,
"timeout": 0,
"noerr": 0,
"initialize": "",
"finalize": "",
"libs": [],
"x": 420,
"y": 200,
"wires": [
[
"361649281d1662a2",
"f945c48d5e863bbc"
]
]
},
{
"id": "361649281d1662a2",
"type": "debug",
"z": "f05192d33ea2cd16",
"name": "ETWInjectTest",
"active": true,
"tosidebar": true,
"console": false,
"tostatus": false,
"complete": "payload",
"targetType": "msg",
"statusVal": "",
"statusType": "auto",
"x": 660,
"y": 240,
"wires": []
},
{
"id": "f945c48d5e863bbc",
"type": "externaltask-output",
"z": "f05192d33ea2cd16",
"name": "ETWInjectTest",
"x": 660,
"y": 200,
"wires": []
},
{
"id": "5b7f97c66d771f9b",
"type": "catch",
"z": "f05192d33ea2cd16",
"name": "",
"scope": null,
"uncaught": false,
"x": 160,
"y": 100,
"wires": [
[
"00b75b06e082244f"
]
]
},
{
"id": "00b75b06e082244f",
"type": "externaltask-error",
"z": "f05192d33ea2cd16",
"name": "",
"error": "",
"message": "",
"x": 410,
"y": 100,
"wires": [
[
"d11ab2e71de8c4e8"
]
]
},
{
"id": "d11ab2e71de8c4e8",
"type": "debug",
"z": "f05192d33ea2cd16",
"name": "ETWInjectTest Error",
"active": true,
"tosidebar": true,
"console": false,
"tostatus": false,
"complete": "payload",
"targetType": "msg",
"statusVal": "",
"statusType": "auto",
"x": 650,
"y": 100,
"wires": []
},
{
"id": "7cac91868f5d61d5",
"type": "externaltask-inject",
"z": "f05192d33ea2cd16",
"name": "",
"payloadType": "jsonata",
"payload": "{\"Test\": 1}",
"taskType": "str",
"task": "{\t \"Test\": true\t}",
"x": 180,
"y": 280,
"wires": [
[
"062e0b79deadef16"
]
]
},
{
"id": "82533b02fb9a9f04",
"type": "comment",
Expand Down Expand Up @@ -4071,8 +4210,8 @@
"z": "9f5057a8990f0afb",
"g": "f60a74efecfd30bf",
"name": "",
"template_link": "https://drive.google.com/file/d/1uJYKmkJpmINiSlmO1bTQNizroRgUc5iU/view?usp=drive_link",
"template_link_type": "str",
"template_link": "template_link",
"template_link_type": "msg",
"x": 520,
"y": 320,
"wires": [
Expand All @@ -4090,6 +4229,11 @@
"props": [
{
"p": "payload"
},
{
"p": "template_link",
"v": "https://drive.google.com/file/d/1uJYKmkJpmINiSlmO1bTQNizroRgUc5iU/view?usp=drive_link",
"vt": "str"
}
],
"repeat": "",
Expand Down
139 changes: 139 additions & 0 deletions .processcube/nodered/flows.json
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -7,6 +7,14 @@
"info": "",
"env": []
},
{
"id": "f05192d33ea2cd16",
"type": "tab",
"label": "External Task Inject",
"disabled": false,
"info": "",
"env": []
},
{
"id": "c9ab699769824f2f",
"type": "tab",
Expand Down Expand Up @@ -1776,6 +1784,137 @@
"y": 1480,
"wires": []
},
{
"id": "9c5af4ae5b0cf8a9",
"type": "externaltask-input",
"z": "f05192d33ea2cd16",
"name": "ETWInjectTest",
"workername": "",
"engine": "42e6796dddd9d4db",
"topic": "ETWInjectTest",
"topicType": "str",
"workerConfig": "{}",
"workerConfigType": "json",
"traces": [],
"x": 170,
"y": 200,
"wires": [
[
"062e0b79deadef16"
]
]
},
{
"id": "062e0b79deadef16",
"type": "function",
"z": "f05192d33ea2cd16",
"name": "Do nothing",
"func": "throw new Error(\"Test Error\");\n\nreturn msg;",
"outputs": 1,
"timeout": 0,
"noerr": 0,
"initialize": "",
"finalize": "",
"libs": [],
"x": 420,
"y": 200,
"wires": [
[
"361649281d1662a2",
"f945c48d5e863bbc"
]
]
},
{
"id": "361649281d1662a2",
"type": "debug",
"z": "f05192d33ea2cd16",
"name": "ETWInjectTest",
"active": true,
"tosidebar": true,
"console": false,
"tostatus": false,
"complete": "payload",
"targetType": "msg",
"statusVal": "",
"statusType": "auto",
"x": 660,
"y": 240,
"wires": []
},
{
"id": "f945c48d5e863bbc",
"type": "externaltask-output",
"z": "f05192d33ea2cd16",
"name": "ETWInjectTest",
"x": 660,
"y": 200,
"wires": []
},
{
"id": "5b7f97c66d771f9b",
"type": "catch",
"z": "f05192d33ea2cd16",
"name": "",
"scope": null,
"uncaught": false,
"x": 160,
"y": 100,
"wires": [
[
"00b75b06e082244f"
]
]
},
{
"id": "00b75b06e082244f",
"type": "externaltask-error",
"z": "f05192d33ea2cd16",
"name": "",
"error": "",
"message": "",
"x": 410,
"y": 100,
"wires": [
[
"d11ab2e71de8c4e8"
]
]
},
{
"id": "d11ab2e71de8c4e8",
"type": "debug",
"z": "f05192d33ea2cd16",
"name": "ETWInjectTest Error",
"active": true,
"tosidebar": true,
"console": false,
"tostatus": false,
"complete": "payload",
"targetType": "msg",
"statusVal": "",
"statusType": "auto",
"x": 650,
"y": 100,
"wires": []
},
{
"id": "7cac91868f5d61d5",
"type": "externaltask-inject",
"z": "f05192d33ea2cd16",
"name": "",
"payloadType": "json",
"payload": "{\"Test\": 1}",
"taskType": "jsonata",
"task": "{\t \"payload\": msg.payload\t}",
"x": 180,
"y": 280,
"wires": [
[
"062e0b79deadef16"
]
]
},
{
"id": "82533b02fb9a9f04",
"type": "comment",
Expand Down
6 changes: 3 additions & 3 deletions externaltask-error.js
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -3,10 +3,10 @@ module.exports = function (RED) {
RED.nodes.createNode(this, config);
var node = this;

node.on('input', function (msg) {
node.on('input', function (msg) {
const flowNodeInstanceId = msg.flowNodeInstanceId;
const etw_input_node_id = msg.etw_input_node_id;

if (!etw_input_node_id) {
node.error('Error: The message did not contain the required etw_input_node_id.');
} else {
Expand All @@ -24,7 +24,7 @@ module.exports = function (RED) {
if (msgError.code) {
errorCode = msgError.code;
errorMessage = msgError.message;
}
}
} else if (msg.errorCode) {
errorCode = msg.errorCode;
errorMessage = msg.errorMessage;
Expand Down
Loading