Automate CodeCanyon Comment Assistant Pipeline

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": "CodeCanyon Comment Assistant \u2014 Auto Pipeline",
  "nodes": [
    {
      "id": "node-01-schedule",
      "name": "Schedule Trigger",
      "type": "n8n-nodes-base.scheduleTrigger",
      "typeVersion": 1.2,
      "position": [
        250,
        300
      ],
      "parameters": {
        "rule": {
          "interval": [
            {
              "field": "hours",
              "hoursInterval": 6
            }
          ]
        },
        "timezone": "Asia/Kolkata"
      }
    },
    {
      "id": "node-02-http-run",
      "name": "Trigger Pipeline",
      "type": "n8n-nodes-base.httpRequest",
      "typeVersion": 4.2,
      "position": [
        500,
        300
      ],
      "onError": "continueRegularOutput",
      "parameters": {
        "method": "GET",
        "url": "http://localhost:5001/run",
        "options": {
          "timeout": 120000,
          "response": {
            "response": {
              "responseFormat": "json"
            }
          }
        }
      }
    },
    {
      "id": "node-03-if",
      "name": "Pipeline Successful?",
      "type": "n8n-nodes-base.if",
      "typeVersion": 2,
      "position": [
        750,
        300
      ],
      "parameters": {
        "conditions": {
          "options": {
            "caseSensitive": true,
            "leftValue": "",
            "typeValidation": "strict"
          },
          "conditions": [
            {
              "id": "cond-status-completed",
              "leftValue": "={{ $json.status }}",
              "rightValue": "completed",
              "operator": {
                "type": "string",
                "operation": "equals"
              }
            }
          ],
          "combinator": "and"
        },
        "options": {}
      }
    },
    {
      "id": "node-04a-notify-success",
      "name": "Notify Success",
      "type": "n8n-nodes-base.httpRequest",
      "typeVersion": 4.2,
      "position": [
        1000,
        180
      ],
      "parameters": {
        "method": "POST",
        "url": "=`https://api.telegram.org/bot${$env.TELEGRAM_BOT_TOKEN}/sendMessage`",
        "sendBody": true,
        "bodyParameters": {
          "parameters": [
            {
              "name": "chat_id",
              "value": "={{ $env.TELEGRAM_CHAT_ID }}"
            },
            {
              "name": "parse_mode",
              "value": "HTML"
            },
            {
              "name": "text",
              "value": "=`\u2705 <b>Pipeline Run Complete</b>\n\n\ud83d\udce6 Products Processed: ${$node['Trigger Pipeline'].json.products_processed}\n\ud83d\udcac Comments Notified: ${$node['Trigger Pipeline'].json.comments_notified}\n\u274c Comments Failed: ${$node['Trigger Pipeline'].json.comments_failed}\n\n\ud83d\udd50 Run Time: ${new Date().toISOString()}`"
            }
          ]
        },
        "options": {}
      }
    },
    {
      "id": "node-04b-notify-failure",
      "name": "Notify Failure",
      "type": "n8n-nodes-base.httpRequest",
      "typeVersion": 4.2,
      "position": [
        1000,
        420
      ],
      "parameters": {
        "method": "POST",
        "url": "=`https://api.telegram.org/bot${$env.TELEGRAM_BOT_TOKEN}/sendMessage`",
        "sendBody": true,
        "bodyParameters": {
          "parameters": [
            {
              "name": "chat_id",
              "value": "={{ $env.TELEGRAM_CHAT_ID }}"
            },
            {
              "name": "parse_mode",
              "value": "HTML"
            },
            {
              "name": "text",
              "value": "=`\u274c <b>Pipeline Run Failed</b>\n\nThe CodeCanyon Comment Assistant pipeline did not complete successfully.\n\n\ud83d\udd50 Time: ${new Date().toISOString()}\n\nPlease check the Flask server logs.`"
            }
          ]
        },
        "options": {}
      }
    }
  ],
  "connections": {
    "Schedule Trigger": {
      "main": [
        [
          {
            "node": "Trigger Pipeline",
            "type": "main",
            "index": 0
          }
        ]
      ]
    },
    "Trigger Pipeline": {
      "main": [
        [
          {
            "node": "Pipeline Successful?",
            "type": "main",
            "index": 0
          }
        ]
      ]
    },
    "Pipeline Successful?": {
      "main": [
        [
          {
            "node": "Notify Success",
            "type": "main",
            "index": 0
          }
        ],
        [
          {
            "node": "Notify Failure",
            "type": "main",
            "index": 0
          }
        ]
      ]
    }
  },
  "settings": {
    "executionOrder": "v1"
  },
  "staticData": null,
  "tags": [
    {
      "createdAt": "2026-03-04T00:00:00.000Z",
      "updatedAt": "2026-03-04T00:00:00.000Z",
      "id": "tag-codecanyon",
      "name": "codecanyon"
    }
  ],
  "triggerCount": 0,
  "updatedAt": "2026-03-04T00:00:00.000Z",
  "versionId": "2"
}

About this workflow

CodeCanyon Comment Assistant — Auto Pipeline. Uses httpRequest. Scheduled trigger; 5 nodes.

Source: https://github.com/devv-gmits/codecanyon-comment-assistant/blob/014c48e3bfa5e8856ce9f7d84f8e0194ba1cd0d7/n8n/workflow_export.json — original creator credit. Request a take-down →

More General workflows → · Browse all categories →

Related workflows

Workflows that share integrations, category, or trigger type with this one. All free to copy and import.