The workflow JSON
Copy or download the full n8n JSON below. Paste it into a new n8n workflow, add your credentials, activate. Full import guide →
{
"name": "YST New Holder Welcome",
"nodes": [
{
"parameters": {
"rule": {
"interval": [
{
"field": "minutes",
"minutesInterval": 30
}
]
}
},
"id": "c3d4e5f6-0003-0003-0003-000000000001",
"name": "Schedule Trigger (30min)",
"type": "n8n-nodes-base.scheduleTrigger",
"typeVersion": 1.1,
"position": [
240,
380
]
},
{
"parameters": {
"jsCode": "// Load known holders from static data before making the RPC call\nconst staticData = $getWorkflowStaticData('global');\nif (!staticData.knownHolders) {\n staticData.knownHolders = {};\n}\n// Pass the known holders count downstream for logging\nreturn [{ json: { knownHolderCount: Object.keys(staticData.knownHolders).length, ready: true } }];"
},
"id": "c3d4e5f6-0003-0003-0003-000000000007",
"name": "Load Known Holders",
"type": "n8n-nodes-base.code",
"typeVersion": 2,
"position": [
490,
380
]
},
{
"parameters": {
"method": "POST",
"url": "https://api.mainnet-beta.solana.com",
"sendHeaders": true,
"headerParameters": {
"parameters": [
{
"name": "Content-Type",
"value": "application/json"
}
]
},
"sendBody": true,
"specifyBody": "json",
"jsonBody": "={\"jsonrpc\":\"2.0\",\"id\":1,\"method\":\"getTokenLargestAccounts\",\"params\":[\"jYwmSavfx69a35JEkpyrxu9JUjvswEvfnhLCDV9vREV\"]}",
"options": {
"timeout": 30000
}
},
"id": "c3d4e5f6-0003-0003-0003-000000000002",
"name": "RPC getTokenLargestAccounts",
"type": "n8n-nodes-base.httpRequest",
"typeVersion": 4.2,
"position": [
740,
380
],
"notes": "Uses Solana public RPC \u2014 no API key required. Returns top 20 token account holders for $YST mint.",
"continueOnFail": true
},
{
"parameters": {
"jsCode": "// Compare current top holder list with stored list to find NEW holders\n// Uses Solana RPC getTokenLargestAccounts which returns top 20 accounts\n\nconst responseData = $input.first().json;\n\n// RPC response format: { result: { value: [ { address, amount, decimals, uiAmount, uiAmountString } ] } }\nconst accounts = responseData?.result?.value || [];\n\nif (accounts.length === 0) {\n return [{ json: { newHolders: [], totalHolders: 0, checkTimestamp: new Date().toISOString(), hasNewHolders: false, error: 'No accounts returned from RPC' } }];\n}\n\n// Build current holder map: { tokenAccountAddress -> uiAmount }\n// Note: getTokenLargestAccounts returns token account addresses (not wallet addresses)\n// We use them as unique identifiers for tracking purposes\nconst currentHolders = {};\nfor (const acct of accounts) {\n const address = acct.address || '';\n const balance = acct.uiAmount || parseFloat(acct.uiAmountString || '0');\n if (address && balance > 0) {\n currentHolders[address] = balance;\n }\n}\n\n// Retrieve previously stored holder list from Static Data\nconst staticData = $getWorkflowStaticData('global');\nif (!staticData.knownHolders) {\n staticData.knownHolders = {};\n}\n\nconst knownHolders = staticData.knownHolders;\nconst newHolders = [];\n\n// Find accounts in currentHolders not in knownHolders\nfor (const [address, balance] of Object.entries(currentHolders)) {\n if (!knownHolders[address]) {\n const shortAddr = address.length > 8\n ? address.slice(0, 4) + '...' + address.slice(-4)\n : address;\n newHolders.push({\n wallet: address,\n balance,\n shortAddr\n });\n }\n}\n\n// Update stored holder list with all current holders\nObject.assign(staticData.knownHolders, currentHolders);\n\nconst totalHolders = Object.keys(currentHolders).length;\nconst checkTimestamp = new Date().toISOString();\n\nif (newHolders.length === 0) {\n return [{ json: { newHolders: [], totalHolders, checkTimestamp, hasNewHolders: false } }];\n}\n\n// Return one item per new holder for individual Telegram messages\nreturn newHolders.map(h => ({\n json: {\n ...h,\n totalHolders,\n checkTimestamp,\n hasNewHolders: true,\n allNewHolders: newHolders\n }\n}));"
},
"id": "c3d4e5f6-0003-0003-0003-000000000003",
"name": "Detect New Holders",
"type": "n8n-nodes-base.code",
"typeVersion": 2,
"position": [
990,
380
]
},
{
"parameters": {
"conditions": {
"options": {
"caseSensitive": true,
"leftValue": "",
"typeValidation": "strict"
},
"conditions": [
{
"id": "new-holder-check",
"leftValue": "={{ $json.hasNewHolders }}",
"rightValue": true,
"operator": {
"type": "boolean",
"operation": "equals"
}
}
],
"combinator": "and"
},
"options": {}
},
"id": "c3d4e5f6-0003-0003-0003-000000000004",
"name": "New Holders Found?",
"type": "n8n-nodes-base.if",
"typeVersion": 2,
"position": [
1240,
380
]
},
{
"parameters": {
"jsCode": "// Format welcome message for each new holder\nconst d = $input.first().json;\nconst balanceFormatted = new Intl.NumberFormat('en-US').format(Math.round(d.balance));\nconst solscanUrl = `https://solscan.io/account/${d.wallet}`;\n\nreturn [{\n json: {\n ...d,\n telegramMessage: `\ud83d\udc4b NEW YAKK HOLDER!\\n\\n\ud83c\udfe0 Account: \\`${d.shortAddr}\\`\\n\ud83d\udcb0 Balance: ${balanceFormatted} $YST\\n\ud83c\udf89 Welcome to the YAKK den!\\n\\n\ud83d\udc65 Top Holders Tracked: ${d.totalHolders}\\n\ud83d\udd0d [View on Solscan](${solscanUrl})\\n\\n$YST #YakkStudios #Solana`\n }\n}];"
},
"id": "c3d4e5f6-0003-0003-0003-000000000005",
"name": "Format Welcome Message",
"type": "n8n-nodes-base.code",
"typeVersion": 2,
"position": [
1490,
280
]
},
{
"parameters": {
"method": "POST",
"url": "=https://api.telegram.org/bot{{ $credentials.httpHeaderAuth.value }}/sendMessage",
"sendHeaders": true,
"headerParameters": {
"parameters": [
{
"name": "Content-Type",
"value": "application/json"
}
]
},
"sendBody": true,
"specifyBody": "json",
"jsonBody": "={\"chat_id\":\"@yakkstudios\",\"text\":\"{{ $json.telegramMessage }}\",\"parse_mode\":\"Markdown\",\"disable_web_page_preview\":false}",
"options": {
"timeout": 30000,
"continueOnFail": true
}
},
"id": "c3d4e5f6-0003-0003-0003-000000000006",
"name": "Telegram Welcome Message",
"type": "n8n-nodes-base.httpRequest",
"typeVersion": 4.2,
"position": [
1740,
280
],
"notes": "Create a Header Auth credential named 'Telegram Bot Token' with Name: Authorization, Value: <your_bot_token> (just the token, no Bearer prefix).",
"credentials": {
"httpHeaderAuth": {
"name": "<your credential>"
}
},
"continueOnFail": true
}
],
"connections": {
"Schedule Trigger (30min)": {
"main": [
[
{
"node": "Load Known Holders",
"type": "main",
"index": 0
}
]
]
},
"Load Known Holders": {
"main": [
[
{
"node": "RPC getTokenLargestAccounts",
"type": "main",
"index": 0
}
]
]
},
"RPC getTokenLargestAccounts": {
"main": [
[
{
"node": "Detect New Holders",
"type": "main",
"index": 0
}
]
]
},
"Detect New Holders": {
"main": [
[
{
"node": "New Holders Found?",
"type": "main",
"index": 0
}
]
]
},
"New Holders Found?": {
"main": [
[
{
"node": "Format Welcome Message",
"type": "main",
"index": 0
}
],
[]
]
},
"Format Welcome Message": {
"main": [
[
{
"node": "Telegram Welcome Message",
"type": "main",
"index": 0
}
]
]
}
},
"settings": {
"executionOrder": "v1",
"saveManualExecutions": true,
"callerPolicy": "workflowsFromSameOwner",
"errorWorkflow": ""
},
"staticData": null,
"tags": [
{
"createdAt": "2026-03-29T02:00:00.000Z",
"updatedAt": "2026-03-29T02:00:00.000Z",
"id": "yst-tag-1",
"name": "YakkStudios"
}
],
"triggerCount": 1,
"updatedAt": "2026-03-29T02:00:00.000Z",
"versionId": "new-holder-welcome-v2",
"active": false
}
Credentials you'll need
Each integration node will prompt for credentials when you import. We strip credential IDs before publishing — you'll add your own.
httpHeaderAuth
Pro
For the full experience including quality scoring and batch install features for each workflow upgrade to Pro
About this workflow
YST New Holder Welcome. Uses httpRequest. Scheduled trigger; 7 nodes.
Source: https://github.com/yakkstudios/yakkstudios/blob/ca06dc05d3aaec894666343cfd9ead9f9d19614b/n8n-workflows/new-holder-welcome.json — original creator credit. Request a take-down →
Related workflows
Workflows that share integrations, category, or trigger type with this one. All free to copy and import.
As n8n instances scale, teams often lose track of sub-workflows—who uses them, where they are referenced, and whether they can be safely updated. This leads to inefficiencies like unnecessary copies o
HTTP Request, n8n, N8N Trigger +1
This workflow is an improvement of this workflow by Greg Brzezinka.
HTTP Request, Email Send, XML +1
N8N-Workflow-Github-Manager. Uses github, httpRequest, n8n. Scheduled trigger; 38 nodes.
GitHub, HTTP Request, n8n
This workflow uses KlickTipp community nodes, available for self-hosted n8n instances only.
N8N Nodes Klicktipp, Salesforce, Salesforce Trigger +1
This workflow acts as an automated engagement bot. It sends a Direct Message (DM) with a link or resource to any follower who replies to your post with a specific target keyword.
HTTP Request