Skip to content

Commit 47b4505

Browse files
committed
feat(n8n): implement JSON PRC method getNextScanOfSubscriptions
1 parent a3f804e commit 47b4505

File tree

1 file changed

+30
-83
lines changed

1 file changed

+30
-83
lines changed

n8n/workflows.json

Lines changed: 30 additions & 83 deletions
Original file line numberDiff line numberDiff line change
@@ -15651,7 +15651,7 @@
1565115651
]
1565215652
]
1565315653
},
15654-
"Construct Response": {
15654+
"Code": {
1565515655
"main": [
1565615656
[
1565715657
{
@@ -15662,7 +15662,7 @@
1566215662
]
1566315663
]
1566415664
},
15665-
"Delete Private Key": {
15665+
"Construct Response": {
1566615666
"main": [
1566715667
[
1566815668
{
@@ -15673,7 +15673,7 @@
1567315673
]
1567415674
]
1567515675
},
15676-
"Edit Fields": {
15676+
"Delete Private Key": {
1567715677
"main": [
1567815678
[
1567915679
{
@@ -15684,7 +15684,7 @@
1568415684
]
1568515685
]
1568615686
},
15687-
"Edit Fields1": {
15687+
"Edit Fields": {
1568815688
"main": [
1568915689
[
1569015690
{
@@ -15695,40 +15695,40 @@
1569515695
]
1569615696
]
1569715697
},
15698-
"Edit Fields10": {
15698+
"Edit Fields1": {
1569915699
"main": [
1570015700
[
1570115701
{
1570215702
"index": 0,
15703-
"node": "Aggregate4",
15703+
"node": "Respond to Webhook",
1570415704
"type": "main"
1570515705
}
1570615706
]
1570715707
]
1570815708
},
15709-
"Edit Fields11": {
15709+
"Edit Fields10": {
1571015710
"main": [
1571115711
[
1571215712
{
1571315713
"index": 0,
15714-
"node": "Edit Fields12",
15714+
"node": "Aggregate4",
1571515715
"type": "main"
1571615716
}
1571715717
]
1571815718
]
1571915719
},
15720-
"Edit Fields12": {
15720+
"Edit Fields11": {
1572115721
"main": [
1572215722
[
1572315723
{
1572415724
"index": 0,
15725-
"node": "Respond to Webhook",
15725+
"node": "Edit Fields12",
1572615726
"type": "main"
1572715727
}
1572815728
]
1572915729
]
1573015730
},
15731-
"Edit Fields13": {
15731+
"Edit Fields12": {
1573215732
"main": [
1573315733
[
1573415734
{
@@ -16577,7 +16577,7 @@
1657716577
[
1657816578
{
1657916579
"index": 0,
16580-
"node": "n8n",
16580+
"node": "Code",
1658116581
"type": "main"
1658216582
}
1658316583
],
@@ -16644,17 +16644,6 @@
1664416644
}
1664516645
]
1664616646
]
16647-
},
16648-
"n8n": {
16649-
"main": [
16650-
[
16651-
{
16652-
"index": 0,
16653-
"node": "Edit Fields13",
16654-
"type": "main"
16655-
}
16656-
]
16657-
]
1665816647
}
1665916648
},
1666016649
"createdAt": "2025-04-22T13:36:59.745Z",
@@ -17278,7 +17267,7 @@
1727817267
"operation": "equals",
1727917268
"type": "string"
1728017269
},
17281-
"rightValue": "getLastScanOfSubscriptions"
17270+
"rightValue": "getNextScanOfSubscriptions"
1728217271
}
1728317272
],
1728417273
"options": {
@@ -17288,7 +17277,7 @@
1728817277
"version": 2
1728917278
}
1729017279
},
17291-
"outputKey": "getLastScanOfSubscriptions",
17280+
"outputKey": "getNextScanOfSubscriptions",
1729217281
"renameOutput": true
1729317282
},
1729417283
{
@@ -20194,62 +20183,6 @@
2019420183
"type": "n8n-nodes-base.postgres",
2019520184
"typeVersion": 2.6
2019620185
},
20197-
{
20198-
"credentials": {
20199-
"n8nApi": {
20200-
"id": "29pMkB66wmwgdc6w",
20201-
"name": "n8n account"
20202-
}
20203-
},
20204-
"id": "653774f7-c4a8-4094-ba2a-7f5c253b17b1",
20205-
"name": "n8n",
20206-
"parameters": {
20207-
"filters": {
20208-
"workflowId": {
20209-
"__rl": true,
20210-
"cachedResultName": "forecast-reddits (#hUnkG6eBZZZGN97V)",
20211-
"mode": "list",
20212-
"value": "hUnkG6eBZZZGN97V"
20213-
}
20214-
},
20215-
"limit": 1,
20216-
"options": {
20217-
},
20218-
"requestOptions": {
20219-
},
20220-
"resource": "execution"
20221-
},
20222-
"position": [
20223-
2300,
20224-
4720
20225-
],
20226-
"type": "n8n-nodes-base.n8n",
20227-
"typeVersion": 1
20228-
},
20229-
{
20230-
"id": "bf0503f4-eee5-4d5c-b40b-b06584d92692",
20231-
"name": "Edit Fields13",
20232-
"parameters": {
20233-
"assignments": {
20234-
"assignments": [
20235-
{
20236-
"id": "6d78cfe8-dbb5-4258-9539-dc98f8a7d691",
20237-
"name": "result.lastScanAt",
20238-
"type": "string",
20239-
"value": "={{ $json.startedAt }}"
20240-
}
20241-
]
20242-
},
20243-
"options": {
20244-
}
20245-
},
20246-
"position": [
20247-
2520,
20248-
4720
20249-
],
20250-
"type": "n8n-nodes-base.set",
20251-
"typeVersion": 3.4
20252-
},
2025320186
{
2025420187
"id": "6b735279-04b2-4a8e-80e5-4f1368a3a904",
2025520188
"name": "CallWebhook",
@@ -20274,6 +20207,20 @@
2027420207
],
2027520208
"type": "n8n-nodes-base.httpRequest",
2027620209
"typeVersion": 4.2
20210+
},
20211+
{
20212+
"id": "620374fa-5220-4593-a781-1a113d4e6db3",
20213+
"name": "Code",
20214+
"parameters": {
20215+
"jsCode": "const date = new Date();\n\n// every 1h at 2nd minute\nconst EVERY_HOURS = 1;\nconst AT_PAST_MINUTES = 2;\n\ndate.setSeconds(0, 0);\n\nif (date.getMinutes() >= AT_PAST_MINUTES) {\n date.setHours(date.getHours() + EVERY_HOURS);\n}\n\ndate.setMinutes(AT_PAST_MINUTES);\n\n$input.item.json = {\n result: {\n nextScanAt: date.toISOString()\n }\n};\n\nreturn $input.item;",
20216+
"mode": "runOnceForEachItem"
20217+
},
20218+
"position": [
20219+
2300,
20220+
4720
20221+
],
20222+
"type": "n8n-nodes-base.code",
20223+
"typeVersion": 2
2027720224
}
2027820225
],
2027920226
"pinData": {
@@ -20285,8 +20232,8 @@
2028520232
"tags": [
2028620233
],
2028720234
"triggerCount": 1,
20288-
"updatedAt": "2025-05-06T14:52:37.000Z",
20289-
"versionId": "3f032c90-f483-46b7-ae94-dccde50113ba"
20235+
"updatedAt": "2025-05-06T15:17:22.000Z",
20236+
"versionId": "38b33a3c-6ca2-45f1-9c91-0d5463e80dd9"
2029020237
},
2029120238
{
2029220239
"active": true,

0 commit comments

Comments
 (0)