workflows/02-ingest-cointelegraph.json Repository StreszCzarka---Krypto-AI-news-serwis Original path workflows/02-ingest-cointelegraph.jsonRole CONFIG Size 24461 bytes Lines 756 SHA-256 74df29db07d23f0713c75accd681337b9078f16f0d5347ab76f289f217714b0bDisplayed range 1–500 Previous file/page · Project index · Next file/page
{
"name": "StreszCzarka - ingest Cointelegraph",
"nodes": [
{
"parameters": {},
"type": "n8n-nodes-base.manualTrigger",
"typeVersion": 1,
"position": [
-304,
48
],
"id": "0a41f849-b2a8-49c3-876f-1c8e103521f4",
"name": "When clicking ‘Test workflow’",
"disabled": true
},
{
"parameters": {
"assignments": {
"assignments": [
{
"id": "d781a357-a35e-4408-9630-5eac391cec14",
"name": "tytuł",
"value": "={{ $json.title }}",
"type": "string"
},
{
"id": "f72dd82b-27c0-4a47-8e45-4936f4900274",
"name": "Link",
"value": "={{ $json.link }}",
"type": "string"
}
]
},
"options": {}
},
"type": "n8n-nodes-base.set",
"typeVersion": 3.4,
"position": [
368,
112
],
"id": "cf89230d-5565-47c7-b1f4-efdafaecc5e8",
"name": "Edit Fields"
},
{
"parameters": {
"method": "POST",
"url": "={{ $env.STRESZCZARKA_EXTRACTOR_URL + '/extract' }}",
"sendHeaders": true,
"headerParameters": {
"parameters": [
{
"name": "Content-Type",
"value": "application/json"
},
{
"name": "X-API-Key",
"value": "={{ $env.STRESZCZARKA_INTERNAL_API_KEY }}"
}
]
},
"sendBody": true,
"bodyParameters": {
"parameters": [
{
"name": "url",
"value": "={{ $json.originalLink }}"
}
]
},
"options": {}
},
"type": "n8n-nodes-base.httpRequest",
"typeVersion": 4.2,
"position": [
-80,
480
],
"id": "2ed87f5b-8cf0-45d3-bc40-3affcb0dc78e",
"name": "pobierator artykułu",
"retryOnFail": true,
"maxTries": 2,
"waitBetweenTries": 5000
},
{
"parameters": {
"model": "mistral-small-latest",
"options": {
"temperature": 0
}
},
"type": "@n8n/n8n-nodes-langchain.lmChatMistralCloud",
"typeVersion": 1,
"position": [
304,
576
],
"id": "d16e1792-f8cb-4252-a5d9-3e1a7a0dba0a",
"name": "Mistral Cloud Chat Model"
},
{
"parameters": {
"promptType": "define",
"text": "=Streść ten artykuł w sposób zwięzły i profesjonalny do kilku najważniejszych krótkich punktów (1-4 zdania) skup się na wyciagnięciu faktów, ale nie zgób ogólnego sensu przekazu:{{ $json.content }} \nNa koniec wklej link:\n{{ $json.link }}"
},
"type": "@n8n/n8n-nodes-langchain.chainLlm",
"typeVersion": 1.6,
"position": [
400,
480
],
"id": "0ef659dd-2245-4401-b5b9-94e6a68d6690",
"name": "Streszczarka"
},
{
"parameters": {
"rule": {
"interval": [
{
"field": "minutes",
"minutesInterval": 3
}
]
}
},
"type": "n8n-nodes-base.scheduleTrigger",
"typeVersion": 1.2,
"position": [
-192,
256
],
"id": "197587bd-713c-4be8-bcc6-9caf93a561de",
"name": "Schedule Trigger"
},
{
"parameters": {
"jsCode": "// Sprawdź, czy mamy prawidłowy content i title\nif (!$json.content || !$json.title) {\n return []; // Jeśli nie, przerwij działanie\n}\n\n// Pobierz link z node'a o nazwie \"Edit Fields\"\nconst link = $('Edit Fields').first().json.Link;\n\n// Oczyść tekst\nconst cleaned = $json.content\n .split('\\n')\n .map(line => line.trim())\n .filter(line =>\n line.length > 30 &&\n !/^\\d+$/.test(line) &&\n !line.toLowerCase().includes(\"cookie\") &&\n !line.toLowerCase().includes(\"newsletter\") &&\n !line.toLowerCase().includes(\"subscribe\") &&\n !line.toLowerCase().includes(\"follow us\") &&\n !line.toLowerCase().includes(\"advertise\") &&\n !line.toLowerCase().includes(\"copyright\") &&\n !line.toLowerCase().includes(\"about\") &&\n !line.toLowerCase().includes(\"terms\") &&\n !line.toLowerCase().includes(\"privacy\")\n )\n .slice(0, 40)\n .join(\"\\n\\n\");\n\nreturn [\n {\n json: {\n title: $json.title,\n content: cleaned,\n link: link || null // osobne pole na link (null jeśli brak)\n }\n }\n];\n"
},
"type": "n8n-nodes-base.code",
"typeVersion": 2,
"position": [
144,
480
],
"id": "79f40c6e-f4d9-4ff9-a12d-bb7cb9e44a0a",
"name": "wycinator tekstu"
},
{
"parameters": {
"jsCode": "// Link do sprawdzenia\nconst newArticleLink = $('Code in JavaScript1').first().json.link?.trim();\n\n// Lista linków z inputów\nconst existingLinks = $items().map(item => item.json.link?.trim()).filter(Boolean);\n\n// Sprawdzenie duplikatu\nconst isDuplicate = existingLinks.some(link => link === newArticleLink);\n\nreturn [\n {\n json: {\n duplicate: isDuplicate\n }\n }\n];\n"
},
"type": "n8n-nodes-base.code",
"typeVersion": 2,
"position": [
720,
128
],
"id": "e4ea978a-acd5-4a3c-b05b-54563c155ca1",
"name": "Code"
},
{
"parameters": {
"conditions": {
"options": {
"caseSensitive": true,
"leftValue": "",
"typeValidation": "strict",
"version": 2
},
"conditions": [
{
"id": "8b3fd920-8001-45ea-871c-5e52644f5ce9",
"leftValue": "={{ $json.duplicate }}",
"rightValue": "",
"operator": {
"type": "boolean",
"operation": "true",
"singleValue": true
}
}
],
"combinator": "and"
},
"options": {}
},
"type": "n8n-nodes-base.if",
"typeVersion": 2.2,
"position": [
896,
240
],
"id": "34f892f0-a1b7-4e97-8990-8bf6d4522e82",
"name": "If"
},
{
"parameters": {
"jsCode": "// Pobieramy link z nodu \"Edit Fields\"\nconst link = $('Edit Fields').first().json.Link;\n\n// Przykładowo budujemy URL do API z tym linkiem jako parametrem (jeśli potrzebujesz)\nconst finalUrl = `https://api.example.com/parse?url=${encodeURIComponent(link)}`;\n\n// Przekazujemy dalej jako output do HTTP Request node\nreturn [\n {\n json: {\n url: finalUrl,\n originalLink: link\n }\n }\n];\n"
},
"type": "n8n-nodes-base.code",
"typeVersion": 2,
"position": [
-320,
480
],
"id": "fd8f31b8-8742-4ae3-83f9-009455765307",
"name": "Parser linku"
},
{
"parameters": {
"promptType": "define",
"text": "=Masz za zadanie sklasyfikować artykuły branżowe o kryptowalutach do jednej z dwóch kategorii: SZUM lub INFORMACJA.\n\nSZUM oznacza treści, które:\n\nopierają się na czyichś opiniach, przewidywaniach, prognozach, hipotezach (W „mogłoby się zdarzyć”, „może nastąpić”, „możliwe, że”),\n\nkomentują codzienne wahania cen kryptowalut lub doniesienia medialne, które nie są faktami,\n\nartykuły oparte na wypowiedziach ekspertów\n\nartykuły o zmianach kadrowych w firmach i urzędach\n\nzawierają niepotwierdzone informacje o działaniach osób, firm, polityków lub instytucji, które są spekulacjami, opiniami lub sugestiami,\n\nopisują potencjalne scenariusze prawne, regulacyjne lub rynkowe w trybie przypuszczającym.\n\npropozycje zmian prawnych\n\nOpisujące procesy sądowe i ataki hakerskie, oraz fuzje firm nie wnoszące zmian strukturalnych na rynku\n\nDotyczą memcoinów\n\nINFORMACJA oznacza treści, które:\n\nopisują faktyczne wydarzenia lub decyzje, np. realną adopcję kryptowalut przez instytucje lub państwa,\n\nprzedstawiają prawnie obowiązujące przepisy lub zmiany w prawie, które już weszły w życie lub są formalnie wprowadzone,\n\nraportują rzeczywiste wpływy/odpływy kapitału do funduszy ETF kryptowalutowych,\n\ndokumentują duże, faktyczne skoki cen wiodących kryptowalut,\n\nopisują nowe technologie blockchain lub ich adopcję w rzeczywistości,\n\nwyjaśniają zjawiska rynkowe, technologiczne lub prawne w sposób obiektywny, bez trybu przypuszczającego.\n\nZadanie: Przeczytaj poniższy artykuł i zaklasyfikuj go jako SZUM lub INFORMACJA. Odpowiedz tylko jedną słowem: SZUM lub INFORMACJA.\n\n\nArtykuł:\n {{ $json.text }}",
"options": {}
},
"type": "@n8n/n8n-nodes-langchain.agent",
"typeVersion": 2.2,
"position": [
752,
480
],
"id": "532f6967-3560-40be-96f2-0bb2dda47ccf",
"name": "AI Agent"
},
{
"parameters": {
"model": "mistral-small-latest",
"options": {
"temperature": 0
}
},
"type": "@n8n/n8n-nodes-langchain.lmChatMistralCloud",
"typeVersion": 1,
"position": [
624,
688
],
"id": "1dbffd2a-b6ff-42a1-a687-8fc49c508cb9",
"name": "Mistral Cloud Chat Model1"
},
{
"parameters": {
"sessionIdType": "customKey",
"sessionKey": "akapity"
},
"type": "@n8n/n8n-nodes-langchain.memoryBufferWindow",
"typeVersion": 1.3,
"position": [
768,
688
],
"id": "3838509f-a04a-4f93-bfc4-2dfd9de2db46",
"name": "Simple Memory"
},
{
"parameters": {
"jsCode": "// Normalizujemy wynik klasyfikacji i przekazujemy dane dalej.\nconst classification = ($input.first().json.output || \"\")\n .toUpperCase()\n .replace(/\\*/g, \"\")\n .trim();\n\nconst originalLink = $('Parser linku').first().json.originalLink;\nconst text = $('Streszczarka').first().json.text;\nconst tytul = $('wycinator tekstu').first().json.title;\nconst data_powstania = new Date().toISOString();\n\nreturn [\n {\n json: {\n classification,\n originalLink,\n text,\n tytul,\n data_powstania\n }\n }\n];\n"
},
"type": "n8n-nodes-base.code",
"typeVersion": 2,
"position": [
1104,
336
],
"id": "4b3b085a-698a-44b2-9870-4521775ba914",
"name": "Code in JavaScript"
},
{
"parameters": {
"url": "https://cointelegraph.com/rss",
"options": {}
},
"type": "n8n-nodes-base.httpRequest",
"typeVersion": 4.2,
"position": [
0,
0
],
"id": "c570841d-b2ae-44b0-9395-74d96d20ae75",
"name": "HTTP Request"
},
{
"parameters": {
"jsCode": "// Pobierz XML z HTTP Request\nconst xml = $input.item.json.data;\n\n// Pomocnicza funkcja do czyszczenia CDATA i HTML-escape\nfunction cleanCDATA(value) {\n if (!value) return \"\";\n return value\n .replace(/<!\\[CDATA\\[(.*?)\\]\\]>/gs, \"$1\") // usuń CDATA\n .replace(/&/g, \"&\")\n .replace(/</g, \"<\")\n .replace(/>/g, \">\")\n .replace(/"/g, '\"')\n .replace(/'/g, \"'\")\n .trim();\n}\n\n// Prosty parser RSS 2.0 (bez bibliotek)\nfunction parseRSS(xmlString) {\n const items = [];\n const itemRegex = /<item>([\\s\\S]*?)<\\/item>/g;\n let match;\n\n while ((match = itemRegex.exec(xmlString)) !== null) {\n const itemXML = match[1];\n\n const title = cleanCDATA(\n (itemXML.match(/<title>([\\s\\S]*?)<\\/title>/)?.[1]) || \"\"\n );\n const link = cleanCDATA(\n (itemXML.match(/<link>([\\s\\S]*?)<\\/link>/)?.[1]) || \"\"\n );\n const pubDate = cleanCDATA(\n (itemXML.match(/<pubDate>([\\s\\S]*?)<\\/pubDate>/)?.[1]) || \"\"\n );\n const description = cleanCDATA(\n (itemXML.match(/<description>([\\s\\S]*?)<\\/description>/)?.[1]) || \"\"\n );\n\n items.push({ title, link, pubDate, description });\n }\n\n return items;\n}\n\n// Parsujemy feed\nconst feedItems = parseRSS(xml);\n\n// Jeśli brak itemów\nif (!feedItems.length) {\n throw new Error(\"Brak rekordów w RSS feedzie lub niepoprawny format XML\");\n}\n\n// Funkcja do parsowania daty\nfunction parseDate(dateString) {\n return new Date(dateString);\n}\n\n// Znajdź najświeższy rekord\nlet newestItem = feedItems[0];\nlet newestDate = parseDate(newestItem.pubDate);\n\nfor (let i = 1; i < feedItems.length; i++) {\n const currentDate = parseDate(feedItems[i].pubDate);\n if (currentDate > newestDate) {\n newestItem = feedItems[i];\n newestDate = currentDate;\n }\n}\n\n// Zwróć najnowszy wpis\nreturn [\n {\n json: newestItem,\n },\n];\n"
},
"type": "n8n-nodes-base.code",
"typeVersion": 2,
"position": [
208,
0
],
"id": "72a020f0-cc27-42f0-ad46-0a0d300cfbb6",
"name": "Code in JavaScript1"
},
{
"parameters": {
"url": "={{ $env.STRESZCZARKA_STORAGE_API_URL + '/api/archiwum' }}",
"sendHeaders": true,
"headerParameters": {
"parameters": [
{
"name": "Content-Type",
"value": "application/json"
},
{
"name": "X-API-Key",
"value": "={{ $env.STRESZCZARKA_INTERNAL_API_KEY }}"
}
]
},
"options": {
"response": {
"response": {
"responseFormat": "json"
}
}
}
},
"type": "n8n-nodes-base.httpRequest",
"typeVersion": 4.3,
"position": [
528,
272
],
"id": "4ccd88b3-7672-4993-9b5e-27e03539e929",
"name": "Archiwum"
},
{
"parameters": {
"conditions": {
"options": {
"caseSensitive": true,
"leftValue": "",
"typeValidation": "strict",
"version": 3
},
"conditions": [
{
"id": "55f43ac5-80d1-4fcc-84fc-287874601475",
"leftValue": "={{ $('AI Agent').item.json.output }}",
"rightValue": "INFORMACJA",
"operator": {
"type": "string",
"operation": "equals"
}
}
],
"combinator": "and"
},
"options": {}
},
"type": "n8n-nodes-base.if",
"typeVersion": 2.3,
"position": [
1312,
480
],
"id": "194ddf72-4e5a-460e-96ad-8c802c33d246",
"name": "If1"
},
{
"parameters": {
"method": "POST",
"url": "={{ $env.STRESZCZARKA_STORAGE_API_URL + '/api/Artykuly' }}",
"sendHeaders": true,
"headerParameters": {
"parameters": [
{
"name": "Content-Type",
"value": "application/json"
},
{
"name": "X-API-Key",
"value": "={{ $env.STRESZCZARKA_INTERNAL_API_KEY }}"
}
]
},
"sendBody": true,
"bodyParameters": {
"parameters": [
{
"name": "tytul",
"value": "={{ $json.tytul }}"
},
{
"name": "tresc",
"value": "={{ $json.tresc }}"
},
{
"name": "data_powstania",
"value": "={{ $json.data_powstania }}"
}
]
},
"options": {}
},
"type": "n8n-nodes-base.httpRequest",
"typeVersion": 4.3,
"position": [
1648,
384
],
"id": "c58b4244-4de0-4e5f-8160-ee1f265537d3",
"name": "Informacja"
},
{
"parameters": {
"method": "POST",
"url": "={{ $env.STRESZCZARKA_STORAGE_API_URL + '/api/szum' }}",
"sendHeaders": true,
"headerParameters": {
"parameters": [
{
"name": "Content-Type",
"value": "application/json"
},
{
"name": "X-API-Key",
"value": "={{ $env.STRESZCZARKA_INTERNAL_API_KEY }}"
}
]
},
"sendBody": true,
"bodyParameters": {
"parameters": [
{
"name": "tytul",
"value": "={{ $json.tytul }}"
},
{
"name": "tresc",
"value": "={{ $json.tresc }}"
},
{
"name": "data_powstania",
"value": "={{ $json.data_powstania }}"
}
]
},
"options": {}
},
"type": "n8n-nodes-base.httpRequest",
"typeVersion": 4.3,
"position": [
1648,
576
],
"id": "fe7ee748-ab48-4c3d-9013-614c392ebaae",
"name": "Szum"
},
{
"parameters": {
"method": "POST",
"url": "={{ $env.STRESZCZARKA_STORAGE_API_URL + '/api/archiwum' }}",
"sendHeaders": true,
"headerParameters": {
"parameters": [
{
"name": "Content-Type",
"value": "application/json"
},
{
"name": "X-API-Key",
"value": "={{ $env.STRESZCZARKA_INTERNAL_API_KEY }}"
}
]
},
"sendBody": true,
"bodyParameters": {
"parameters": [
{
"name": "tytul",
"value": "={{ $json.tytul }}"
},
{
"name": "link",
"value": "={{ $json.originalLink }}"
},
{
"name": "data_powstania",
"value": "={{ $json.data_powstania }}"
}
]
},
"options": {}
},
"type": "n8n-nodes-base.httpRequest",
"typeVersion": 4.3,
"position": [
1104,
608
],
"id": "a4340eac-5e43-4352-bb2b-b3819cf61bc5",
"name": "Archiwum zapis"
},
{
"parameters": {
"jsCode": "// n8n Code node (JavaScript)\n\n// Pobieramy tytuł i datę powstania z poprzedniego węzła (np. node, który wstawił wiersz do DB)\nconst tytul = $input.first().json.row.tytul;\nconst data_powstania = $input.first().json.row.data_powstania;\n\n// Pobieramy treść z innego węzła (Code in JavaScript)\nconst tresc = $('Code in JavaScript').first().json.text;\n\n// Zwracamy jako wynik do dalszego workflow\nreturn [\n {\n json: {\n tytul,\n data_powstania,\n tresc,\n }\n }\n];\n"
},
"type": "n8n-nodes-base.code",
"typeVersion": 2,
"position": [