Upload 6 files

workflows/n8n/README.md

@@ -0,0 +1,227 @@
+# n8n Workflows
+
+## Docker Compose n8n
+
+The project Docker Compose stack includes n8n at:
+
+```text
+http://localhost:5678
+```
+
+Copy `.env.example` to `.env`, then set at least:
+
+```env
+MAESTER_API_KEY=your_maester_api_key
+N8N_ENCRYPTION_KEY=generate_a_long_stable_random_value
+PEXELS_API_KEY=your_pexels_api_key
+```
+
+The compose file injects these values into n8n:
+
+```env
+MAESTER_BASE_URL=http://maester-enterprise:7860
+MAESTER_API_KEY=your_maester_api_key
+OPENAI_API_KEY=your_openai_api_key
+GEMINI_API_KEY=your_gemini_api_key
+OPENROUTER_API_KEY=your_openrouter_api_key
+AI_PROVIDER=openai
+LLM_PROVIDER=openai
+PEXELS_API_KEY=your_pexels_api_key
+LLM_MODEL=gpt-4o-mini
+KTTS_MODEL=kokoro-v0_19.onnx
+KTTS_VOICE=af_bella.pt
+```
+
+Import any workflow JSON from this folder into n8n after the stack is running.
+
+## AI Provider Smoke Test
+
+Import:
+
+```text
+ai_provider_smoke_test.json
+```
+
+Set `AI_PROVIDER` or `LLM_PROVIDER` in `.env` to one of:
+
+```text
+openai
+gemini
+openrouter
+```
+
+The workflow uses these provider-specific variables:
+
+```env
+OPENAI_API_KEY=
+OPENAI_BASE_URL=https://api.openai.com/v1
+OPENAI_MODEL=gpt-4o-mini
+
+GEMINI_API_KEY=
+GEMINI_BASE_URL=https://generativelanguage.googleapis.com/v1beta
+GEMINI_MODEL=gemini-1.5-flash
+
+OPENROUTER_API_KEY=
+OPENROUTER_BASE_URL=https://openrouter.ai/api/v1
+OPENROUTER_MODEL=openai/gpt-4o-mini
+OPENROUTER_SITE_URL=http://localhost:5678
+OPENROUTER_APP_NAME=Maester Enterprise
+```
+
+OpenRouter uses the OpenAI-compatible chat completions format. Gemini uses the `generateContent` endpoint and returns a Gemini-shaped response.
+
+## Webhook TikTok Storytelling With Pexels
+
+Import:
+
+```text
+webhook_tiktok_storytelling_pexels.json
+```
+
+This workflow exposes an n8n webhook at:
+
+```text
+POST /webhook/maester/create-tiktok-story
+```
+
+Example payload:
+
+```json
+{
+  "topic": "a founder saves 10 hours a week with automation",
+  "series_title": "Automation Proof",
+  "audience": "small business owners",
+  "scene_count": 5,
+  "scene_duration": 5,
+  "output_name": "automation_proof_episode_01.mp4"
+}
+```
+
+The webhook creates a TikTok render payload, searches Pexels for portrait clips, submits the job to `/services/render/render`, and returns Maester's `job_id`, `status_url`, and `download_url`. Poll `MAESTER_BASE_URL + status_url` until the job state is complete, then download from `MAESTER_BASE_URL + download_url`.
+
+## TikTok Storytelling Mini Series With Pexels
+
+Import `tiktok_storytelling_pexels.json` into n8n.
+
+For the full autonomous version from the project specification, import:
+
+```text
+autonomous_tiktok_storytelling_miniseries.json
+```
+
+Required n8n environment variables:
+
+```env
+MAESTER_BASE_URL=https://your-maester-space.hf.space
+MAESTER_API_KEY=your_maester_api_key
+PEXELS_API_KEY=your_pexels_api_key
+OPENAI_API_KEY=your_openai_api_key
+LLM_MODEL=gpt-4o-mini
+KTTS_MODEL=kokoro-v0_19.onnx
+KTTS_VOICE=af_bella.pt
+```
+
+What the workflow does:
+
+1. Builds a five-scene TikTok storytelling episode.
+2. Searches Pexels videos for each scene query.
+3. Picks portrait MP4 assets when available.
+4. Creates a Maester render payload with scene captions, text overlays, blur background, and per-scene effects.
+5. Submits the render job to `/services/render/render`.
+
+The workflow expects all services to be enabled in Maester:
+
+```env
+MAESTER_MOUNT_SERVICES=true
+MAESTER_ENABLE_RENDER_ENGINE=true
+```
+
+The final node returns the render job response. Add a `Wait` node and an HTTP Request node against the returned `status_url` if you want automatic polling.
+
+Pexels attribution metadata is included in each scene under `metadata.pexels` so you can preserve attribution data in downstream reports.
+
+## Autonomous Mini-Series Workflow
+
+`autonomous_tiktok_storytelling_miniseries.json` implements this production pipeline:
+
+1. Configures the topic: `The Girl Who Disappeared Every Midnight`.
+2. Calls OpenAI Chat Completions and requests strict JSON story output.
+3. Validates the returned story schema.
+4. Creates a Maester campaign record through `/automation/campaigns`.
+5. Runs Maester quality and compliance checks.
+6. Loops through scenes inside an n8n Code node.
+7. Searches Pexels portrait videos with retry queries.
+8. Generates KTTS narration for every scene through `/services/ktts/v1/audio/speech`.
+9. Uploads scene narration files to `/services/render/upload`.
+10. Generates and uploads a full episode narration track for the final render engine voiceover.
+11. Builds a 1080x1920 TikTok render payload with captions, blur background, scene effects, animated subtitle settings, and Pexels attribution metadata.
+12. Submits the final render to `/services/render/render`.
+
+The render engine accepts one global `voiceover` track, so the workflow generates per-scene narration artifacts for traceability and also creates one combined narration track for final video rendering.
+
+## Islamic Motivation TikTok Automation Pipeline
+
+Import:
+
+```text
+islamic_motivation_tiktok_pipeline.json
+```
+
+This workflow implements the Islamic motivation pipeline:
+
+1. Runs once per day from an n8n Schedule Trigger.
+2. Calls GPT-4o for a respectful Islamic motivational topic and narration.
+3. Calls GPT-4o again for exactly five cinematic Pexels-optimized scenes.
+4. Searches Pexels portrait videos scene by scene, with `nature` fallback.
+5. Downloads each clip and sends it to Maester FFmpeg automation.
+6. Trims and resizes each clip to 1080x1920 / 9:16.
+7. Concats clips in deterministic scene order.
+8. Searches Archive.org for an Islamic nasheed and continues without music if none is found.
+9. Burns TikTok-style ASS captions into the video.
+10. Merges nasheed audio at low volume.
+11. Normalizes the final MP4 for TikTok compatibility.
+12. Uploads the final file to Maester render inspection and validates duration, size, audio, and video stream metadata.
+13. Uploads to TikTok if `TIKTOK_UPLOAD_ENABLED=true`; otherwise returns a dry-run render result.
+14. Sends Google Sheets and Telegram status updates.
+
+Required environment variables:
+
+```env
+MAESTER_BASE_URL=https://your-maester-space.hf.space
+MAESTER_API_KEY=your_maester_api_key
+OPENAI_API_KEY=your_openai_api_key
+PEXELS_API_KEY=your_pexels_api_key
+```
+
+Optional publishing/logging variables:
+
+```env
+TELEGRAM_BOT_TOKEN=123456:telegram_bot_token
+TELEGRAM_CHAT_ID=123456789
+GOOGLE_SHEETS_WEBHOOK_URL=https://script.google.com/macros/s/your-script-id/exec
+TIKTOK_UPLOAD_ENABLED=false
+TIKTOK_ACCESS_TOKEN=your_tiktok_content_posting_access_token
+```
+
+Required Maester services:
+
+```env
+MAESTER_MOUNT_SERVICES=true
+MAESTER_ENABLE_FFMPEG_AUTOMATION=true
+MAESTER_ENABLE_RENDER_ENGINE=true
+```
+
+The workflow uses these Maester endpoints:
+
+- `/automation/campaigns`
+- `/automation/compliance/check`
+- `/services/ffmpeg/n8n/execute/trim`
+- `/services/ffmpeg/n8n/execute/resize_916`
+- `/services/ffmpeg/n8n/execute/concat`
+- `/services/ffmpeg/n8n/execute/add_subtitles`
+- `/services/ffmpeg/n8n/execute/merge_music`
+- `/services/ffmpeg/n8n/execute/normalize`
+- `/services/render/upload`
+- `/services/render/inspect`
+
+TikTok upload is intentionally dry-run by default. Enable it only after your TikTok Content Posting API app is approved and tested.

workflows/n8n/ai_provider_smoke_test.json

@@ -0,0 +1,57 @@
+{
+  "name": "Maester - AI Provider Smoke Test",
+  "nodes": [
+    {
+      "parameters": {},
+      "id": "manual-trigger",
+      "name": "Manual Trigger",
+      "type": "n8n-nodes-base.manualTrigger",
+      "typeVersion": 1,
+      "position": [
+        0,
+        0
+      ]
+    },
+    {
+      "parameters": {
+        "jsCode": "const provider = ($env.LLM_PROVIDER || $env.AI_PROVIDER || 'openai').toLowerCase();\nconst prompt = 'Return one short sentence confirming the Maester AI provider is working.';\n\nasync function callOpenAiCompatible({ apiKey, baseUrl, model, extraHeaders = {} }) {\n  if (!apiKey) throw new Error(`Missing API key for ${provider}.`);\n  return await this.helpers.httpRequest({\n    method: 'POST',\n    url: `${baseUrl.replace(/\\/$/, '')}/chat/completions`,\n    headers: {\n      Authorization: `Bearer ${apiKey}`,\n      'Content-Type': 'application/json',\n      ...extraHeaders\n    },\n    body: JSON.stringify({\n      model,\n      messages: [\n        { role: 'system', content: 'You are a concise operational test assistant.' },\n        { role: 'user', content: prompt }\n      ]\n    }),\n    json: true,\n    timeout: 60000\n  });\n}\n\nlet response;\nif (provider === 'openai') {\n  response = await callOpenAiCompatible.call(this, {\n    apiKey: $env.OPENAI_API_KEY,\n    baseUrl: $env.OPENAI_BASE_URL || 'https://api.openai.com/v1',\n    model: $env.OPENAI_MODEL || $env.LLM_MODEL || 'gpt-4o-mini'\n  });\n} else if (provider === 'openrouter') {\n  response = await callOpenAiCompatible.call(this, {\n    apiKey: $env.OPENROUTER_API_KEY,\n    baseUrl: $env.OPENROUTER_BASE_URL || 'https://openrouter.ai/api/v1',\n    model: $env.OPENROUTER_MODEL || $env.LLM_MODEL || 'openai/gpt-4o-mini',\n    extraHeaders: {\n      'HTTP-Referer': $env.OPENROUTER_SITE_URL || 'http://localhost:5678',\n      'X-Title': $env.OPENROUTER_APP_NAME || 'Maester Enterprise'\n    }\n  });\n} else if (provider === 'gemini') {\n  const apiKey = $env.GEMINI_API_KEY;\n  if (!apiKey) throw new Error('Missing GEMINI_API_KEY.');\n  const baseUrl = ($env.GEMINI_BASE_URL || 'https://generativelanguage.googleapis.com/v1beta').replace(/\\/$/, '');\n  const model = $env.GEMINI_MODEL || $env.LLM_MODEL || 'gemini-1.5-flash';\n  response = await this.helpers.httpRequest({\n    method: 'POST',\n    url: `${baseUrl}/models/${model}:generateContent?key=${apiKey}`,\n    headers: { 'Content-Type': 'application/json' },\n    body: JSON.stringify({\n      contents: [\n        {\n          role: 'user',\n          parts: [{ text: prompt }]\n        }\n      ]\n    }),\n    json: true,\n    timeout: 60000\n  });\n} else {\n  throw new Error(`Unsupported AI provider: ${provider}`);\n}\n\nreturn [{ json: { ok: true, provider, response } }];"
+      },
+      "id": "call-provider",
+      "name": "Call Selected Provider",
+      "type": "n8n-nodes-base.code",
+      "typeVersion": 2,
+      "position": [
+        260,
+        0
+      ]
+    }
+  ],
+  "connections": {
+    "Manual Trigger": {
+      "main": [
+        [
+          {
+            "node": "Call Selected Provider",
+            "type": "main",
+            "index": 0
+          }
+        ]
+      ]
+    }
+  },
+  "pinData": {},
+  "settings": {
+    "executionOrder": "v1"
+  },
+  "staticData": null,
+  "tags": [
+    {
+      "name": "maester"
+    },
+    {
+      "name": "ai-provider"
+    }
+  ],
+  "triggerCount": 0,
+  "versionId": "maester-ai-provider-smoke-test-v1"
+}

workflows/n8n/autonomous_tiktok_storytelling_miniseries.json

@@ -0,0 +1,193 @@
+{
+  "name": "Maester - Autonomous TikTok Storytelling Mini-Series Generator",
+  "nodes": [
+    {
+      "parameters": {},
+      "id": "manual-trigger",
+      "name": "Manual Trigger",
+      "type": "n8n-nodes-base.manualTrigger",
+      "typeVersion": 1,
+      "position": [0, 0]
+    },
+    {
+      "parameters": {
+        "jsCode": "return [{\n  json: {\n    topic: 'The Girl Who Disappeared Every Midnight',\n    maesterBaseUrl: $env.MAESTER_BASE_URL || 'http://localhost:7860',\n    maesterApiKey: $env.MAESTER_API_KEY || 'replace_with_maester_api_key',\n    pexelsApiKey: $env.PEXELS_API_KEY || 'replace_with_pexels_api_key',\n    openAiApiKey: $env.OPENAI_API_KEY || 'replace_with_openai_api_key',\n    llmModel: $env.LLM_MODEL || 'gpt-4o-mini',\n    kttsModel: $env.KTTS_MODEL || 'kokoro-v0_19.onnx',\n    kttsVoice: $env.KTTS_VOICE || 'af_bella.pt',\n    sceneCount: 6,\n    defaultSceneDuration: 6,\n    platform: 'tiktok',\n    template: 'tiktok_classic',\n    creativeStyle: 'cinematic_story',\n    outputName: 'the_girl_who_disappeared_every_midnight_ep01.mp4',\n    targetResolution: '1080x1920',\n    backgroundEffect: 'blur',\n    cinematicEffects: ['slow_zoom', 'film_grain', 'vignette', 'push_in', 'light_leak', 'caption_pop'],\n    captionStyle: 'animated_ass',\n    musicMoodFallback: 'dark emotional piano',\n    voiceSpeed: 0.95\n  }\n}];"
+      },
+      "id": "configure-pipeline",
+      "name": "Configure Pipeline",
+      "type": "n8n-nodes-base.code",
+      "typeVersion": 2,
+      "position": [240, 0]
+    },
+    {
+      "parameters": {
+        "method": "POST",
+        "url": "https://api.openai.com/v1/chat/completions",
+        "sendHeaders": true,
+        "headerParameters": {
+          "parameters": [
+            {
+              "name": "Authorization",
+              "value": "={{'Bearer ' + $json.openAiApiKey}}"
+            },
+            {
+              "name": "Content-Type",
+              "value": "application/json"
+            }
+          ]
+        },
+        "sendBody": true,
+        "contentType": "json",
+        "jsonBody": "={{JSON.stringify({ model: $json.llmModel, response_format: { type: 'json_object' }, messages: [ { role: 'system', content: 'You are a short-form TikTok storytelling writer. Return strict JSON only. No markdown. No extra text.' }, { role: 'user', content: `Create episode 1 of a cinematic TikTok storytelling mini-series from this topic: ${$json.topic}. The story must be suspenseful but platform-safe. Return exactly this JSON schema: {\"title\":\"string\",\"description\":\"string\",\"hashtags\":[\"#tag\"],\"music_mood\":\"string\",\"scenes\":[{\"scene\":1,\"duration\":6,\"search_query\":\"portrait cinematic stock video query\",\"caption\":\"short subtitle overlay\",\"tts_script\":\"narration sentence\"}]}. Requirements: ${$json.sceneCount} scenes, each ${$json.defaultSceneDuration} seconds unless story pacing requires a small adjustment. Pexels search queries must be visual, cinematic, portrait-friendly, and specific. Captions must be short enough for TikTok overlays. TTS scripts should join into one coherent narration.` } ] })}}",
+        "options": {
+          "timeout": 120000
+        }
+      },
+      "id": "generate-story-json",
+      "name": "Generate Story JSON",
+      "type": "n8n-nodes-base.httpRequest",
+      "typeVersion": 4.2,
+      "position": [520, 0]
+    },
+    {
+      "parameters": {
+        "jsCode": "const config = $('Configure Pipeline').first().json;\nconst response = items[0].json;\nconst raw = response.choices?.[0]?.message?.content;\nif (!raw) throw new Error('LLM response did not include choices[0].message.content');\nlet story;\ntry {\n  story = JSON.parse(raw);\n} catch (error) {\n  throw new Error(`LLM did not return valid JSON: ${error.message}`);\n}\nif (!Array.isArray(story.scenes) || !story.scenes.length) {\n  throw new Error('Story JSON must include a non-empty scenes array.');\n}\nstory.scenes = story.scenes.map((scene, index) => ({\n  scene: Number(scene.scene || index + 1),\n  duration: Number(scene.duration || config.defaultSceneDuration),\n  search_query: String(scene.search_query || `${config.topic} cinematic night vertical video`),\n  caption: String(scene.caption || '').slice(0, 120),\n  tts_script: String(scene.tts_script || scene.caption || '').trim()\n}));\nreturn [{ json: { ...config, story } }];"
+      },
+      "id": "validate-story-json",
+      "name": "Validate Story JSON",
+      "type": "n8n-nodes-base.code",
+      "typeVersion": 2,
+      "position": [800, 0]
+    },
+    {
+      "parameters": {
+        "method": "POST",
+        "url": "={{$json.maesterBaseUrl + '/automation/campaigns'}}",
+        "sendHeaders": true,
+        "headerParameters": {
+          "parameters": [
+            {
+              "name": "X-API-Key",
+              "value": "={{$json.maesterApiKey}}"
+            },
+            {
+              "name": "Content-Type",
+              "value": "application/json"
+            }
+          ]
+        },
+        "sendBody": true,
+        "contentType": "json",
+        "jsonBody": "={{JSON.stringify({ name: $json.story.title, topic: $json.topic, niche: 'fiction storytelling', platforms: ['tiktok'], quantity: $json.story.scenes.length, tone: 'cinematic suspense storytelling', metadata: { source: 'n8n_autonomous_storytelling', description: $json.story.description, hashtags: $json.story.hashtags, music_mood: $json.story.music_mood } })}}",
+        "options": {
+          "timeout": 60000
+        }
+      },
+      "id": "create-maester-campaign",
+      "name": "Create Maester Campaign",
+      "type": "n8n-nodes-base.httpRequest",
+      "typeVersion": 4.2,
+      "position": [1080, 0]
+    },
+    {
+      "parameters": {
+        "jsCode": "const config = $('Validate Story JSON').first().json;\nconst campaign = items[0].json;\nreturn [{ json: { ...config, campaign } }];"
+      },
+      "id": "attach-campaign",
+      "name": "Attach Campaign",
+      "type": "n8n-nodes-base.code",
+      "typeVersion": 2,
+      "position": [1320, 0]
+    },
+    {
+      "parameters": {
+        "jsCode": "const input = items[0].json;\nconst base = input.maesterBaseUrl.replace(/\\/$/, '');\nconst headers = { 'X-API-Key': input.maesterApiKey, 'Content-Type': 'application/json' };\n\nfunction requireSecret(name, value) {\n  if (!value || value.startsWith('replace_with_')) throw new Error(`Set ${name} in n8n environment variables.`);\n}\nrequireSecret('MAESTER_API_KEY', input.maesterApiKey);\nrequireSecret('PEXELS_API_KEY', input.pexelsApiKey);\n\nasync function maesterJson(path, body) {\n  return await this.helpers.httpRequest({ method: 'POST', url: `${base}${path}`, headers, body: JSON.stringify(body), json: true, timeout: 120000 });\n}\n\nasync function searchPexels(scene) {\n  const queries = [scene.search_query, scene.search_query.replace(/ at night| rainy| dark/gi, '').trim(), `${input.topic} cinematic vertical story`];\n  let lastError;\n  for (const query of queries) {\n    try {\n      const result = await this.helpers.httpRequest({\n        method: 'GET',\n        url: 'https://api.pexels.com/videos/search',\n        headers: { Authorization: input.pexelsApiKey },\n        qs: { query, orientation: 'portrait', size: 'medium', per_page: 10 },\n        json: true,\n        timeout: 90000\n      });\n      const candidates = (result.videos || [])\n        .filter(video => Number(video.duration || 0) >= Number(scene.duration || input.defaultSceneDuration))\n        .map(video => {\n          const files = (video.video_files || []).filter(file => file.file_type === 'video/mp4' && file.link);\n          const best = files.sort((a, b) => {\n            const aPortrait = (a.height || 0) > (a.width || 0) ? 1 : 0;\n            const bPortrait = (b.height || 0) > (b.width || 0) ? 1 : 0;\n            return (bPortrait * 100000000 + (b.height || 0) * (b.width || 0)) - (aPortrait * 100000000 + (a.height || 0) * (a.width || 0));\n          })[0];\n          return best ? { video, file: best, query } : null;\n        })\n        .filter(Boolean);\n      if (candidates.length) {\n        const picked = candidates[0];\n        return { media: picked.file.link, pexels: { id: picked.video.id, url: picked.video.url, user: picked.video.user?.name, query, duration: picked.video.duration, width: picked.file.width, height: picked.file.height } };\n      }\n    } catch (error) {\n      lastError = error;\n    }\n  }\n  throw new Error(`No suitable Pexels portrait video for scene ${scene.scene}. ${lastError?.message || ''}`);\n}\n\nasync function generateTts(text, filename) {\n  const audio = await this.helpers.httpRequest({\n    method: 'POST',\n    url: `${base}/services/ktts/v1/audio/speech`,\n    headers,\n    body: JSON.stringify({ input: text, model: input.kttsModel, voice: input.kttsVoice, speed: input.voiceSpeed }),\n    json: false,\n    encoding: null,\n    timeout: 240000\n  });\n  return { filename, audio };\n}\n\nasync function uploadAudio(audio, filename) {\n  const upload = await this.helpers.httpRequest({\n    method: 'POST',\n    url: `${base}/services/render/upload`,\n    headers: { 'X-API-Key': input.maesterApiKey },\n    formData: { files: { value: audio, options: { filename, contentType: 'audio/wav' } } },\n    json: true,\n    timeout: 240000\n  });\n  const asset = upload.assets?.[0];\n  if (!asset?.path) throw new Error(`Audio upload failed for ${filename}`);\n  return asset.path;\n}\n\nconst quality = await maesterJson('/automation/quality/hook', { hook: input.story.scenes[0].caption });\nconst compliance = await maesterJson('/automation/compliance/check', { platform: 'tiktok', title: input.story.title, caption: input.story.description, hashtags: input.story.hashtags || [], duration_seconds: input.story.scenes.reduce((sum, scene) => sum + Number(scene.duration || input.defaultSceneDuration), 0), has_disclosure: false });\n\nconst resolvedScenes = [];\nconst sceneAudio = [];\nfor (const scene of input.story.scenes) {\n  const stock = await searchPexels.call(this, scene);\n  const sceneTts = await generateTts.call(this, scene.tts_script, `scene_${scene.scene}_narration.wav`);\n  const sceneAudioPath = await uploadAudio.call(this, sceneTts.audio, sceneTts.filename);\n  sceneAudio.push({ scene: scene.scene, audio_path: sceneAudioPath, tts_script: scene.tts_script });\n  const effect = input.cinematicEffects[(scene.scene - 1) % input.cinematicEffects.length];\n  resolvedScenes.push({\n    start: resolvedScenes.reduce((sum, item) => sum + Number(item.duration || 0), 0),\n    duration: Number(scene.duration || input.defaultSceneDuration),\n    media: stock.media,\n    caption: scene.caption,\n    transition: scene.scene === 1 ? 'fade' : 'smooth',\n    background: input.backgroundEffect,\n    layout: 'fill',\n    effect,\n    metadata: { pexels: stock.pexels, scene_audio_path: sceneAudioPath, tts_script: scene.tts_script }\n  });\n}\n\nconst fullNarration = input.story.scenes.map(scene => scene.tts_script).join('\\n');\nconst fullTts = await generateTts.call(this, fullNarration, 'full_episode_narration.wav');\nconst fullVoiceoverPath = await uploadAudio.call(this, fullTts.audio, fullTts.filename);\n\nconst renderPayload = {\n  template: input.template,\n  creative_style: input.creativeStyle,\n  platform: input.platform,\n  preset: 'tiktok_9_16_fast',\n  output_name: input.outputName,\n  voiceover: fullVoiceoverPath,\n  music_volume: 0.24,\n  music_ducking: true,\n  voice_volume: 1.0,\n  subtitle_format: 'ass',\n  auto_subtitles: true,\n  subtitle_language: 'en',\n  audio_normalize: true,\n  normalize: true,\n  metadata: { title: input.story.title, description: input.story.description, hashtags: input.story.hashtags, music_mood: input.story.music_mood || input.musicMoodFallback, campaign_id: input.campaign.id, scene_audio, quality, compliance },\n  scenes: resolvedScenes\n};\n\nreturn [{ json: { ...input, quality, compliance, resolvedScenes, sceneAudio, fullVoiceoverPath, renderPayload } }];"
+      },
+      "id": "process-scenes",
+      "name": "Process Scenes: Pexels + TTS + Upload",
+      "type": "n8n-nodes-base.code",
+      "typeVersion": 2,
+      "position": [1600, 0]
+    },
+    {
+      "parameters": {
+        "method": "POST",
+        "url": "={{$json.maesterBaseUrl + '/services/render/render'}}",
+        "sendHeaders": true,
+        "headerParameters": {
+          "parameters": [
+            {
+              "name": "X-API-Key",
+              "value": "={{$json.maesterApiKey}}"
+            },
+            {
+              "name": "Content-Type",
+              "value": "application/json"
+            }
+          ]
+        },
+        "sendBody": true,
+        "contentType": "json",
+        "jsonBody": "={{JSON.stringify($json.renderPayload)}}",
+        "options": {
+          "timeout": 180000
+        }
+      },
+      "id": "submit-final-render",
+      "name": "Submit Final TikTok Render",
+      "type": "n8n-nodes-base.httpRequest",
+      "typeVersion": 4.2,
+      "position": [1880, 0]
+    },
+    {
+      "parameters": {
+        "jsCode": "const pipeline = $('Process Scenes: Pexels + TTS + Upload').first().json;\nconst render = items[0].json;\nreturn [{\n  json: {\n    status: 'render_submitted',\n    title: pipeline.story.title,\n    description: pipeline.story.description,\n    hashtags: pipeline.story.hashtags,\n    campaign_id: pipeline.campaign.id,\n    render_job: render,\n    status_url: render.status_url,\n    download_url: render.download_url,\n    quality: pipeline.quality,\n    compliance: pipeline.compliance,\n    scenes: pipeline.resolvedScenes.map(scene => ({ caption: scene.caption, media: scene.media, effect: scene.effect, pexels: scene.metadata.pexels })),\n    scene_audio: pipeline.sceneAudio,\n    note: 'Poll status_url until the render job is COMPLETED, then download the MP4 from download_url.'\n  }\n}];"
+      },
+      "id": "return-job-details",
+      "name": "Return Job Details",
+      "type": "n8n-nodes-base.code",
+      "typeVersion": 2,
+      "position": [2160, 0]
+    }
+  ],
+  "connections": {
+    "Manual Trigger": {
+      "main": [[{ "node": "Configure Pipeline", "type": "main", "index": 0 }]]
+    },
+    "Configure Pipeline": {
+      "main": [[{ "node": "Generate Story JSON", "type": "main", "index": 0 }]]
+    },
+    "Generate Story JSON": {
+      "main": [[{ "node": "Validate Story JSON", "type": "main", "index": 0 }]]
+    },
+    "Validate Story JSON": {
+      "main": [[{ "node": "Create Maester Campaign", "type": "main", "index": 0 }]]
+    },
+    "Create Maester Campaign": {
+      "main": [[{ "node": "Attach Campaign", "type": "main", "index": 0 }]]
+    },
+    "Attach Campaign": {
+      "main": [[{ "node": "Process Scenes: Pexels + TTS + Upload", "type": "main", "index": 0 }]]
+    },
+    "Process Scenes: Pexels + TTS + Upload": {
+      "main": [[{ "node": "Submit Final TikTok Render", "type": "main", "index": 0 }]]
+    },
+    "Submit Final TikTok Render": {
+      "main": [[{ "node": "Return Job Details", "type": "main", "index": 0 }]]
+    }
+  },
+  "pinData": {},
+  "settings": {
+    "executionOrder": "v1"
+  },
+  "staticData": null,
+  "tags": [
+    { "name": "maester" },
+    { "name": "tiktok" },
+    { "name": "storytelling" },
+    { "name": "pexels" },
+    { "name": "tts" }
+  ],
+  "triggerCount": 0,
+  "versionId": "maester-autonomous-tiktok-storytelling-v1"
+}

workflows/n8n/islamic_motivation_tiktok_pipeline.json

@@ -0,0 +1,210 @@
+{
+  "name": "Maester - Islamic Motivation TikTok Automation Pipeline",
+  "nodes": [
+    {
+      "parameters": {
+        "rule": {
+          "interval": [
+            {
+              "field": "days",
+              "triggerAtHour": 7
+            }
+          ]
+        }
+      },
+      "id": "schedule-trigger",
+      "name": "Schedule Trigger - Daily",
+      "type": "n8n-nodes-base.scheduleTrigger",
+      "typeVersion": 1.2,
+      "position": [0, 0]
+    },
+    {
+      "parameters": {
+        "jsCode": "return [{\n  json: {\n    maesterBaseUrl: $env.MAESTER_BASE_URL || 'http://localhost:7860',\n    maesterApiKey: $env.MAESTER_API_KEY || 'replace_with_maester_api_key',\n    openAiApiKey: $env.OPENAI_API_KEY || 'replace_with_openai_api_key',\n    pexelsApiKey: $env.PEXELS_API_KEY || 'replace_with_pexels_api_key',\n    llmModel: $env.LLM_MODEL || 'gpt-4o',\n    telegramBotToken: $env.TELEGRAM_BOT_TOKEN || '',\n    telegramChatId: $env.TELEGRAM_CHAT_ID || '',\n    googleSheetsWebhookUrl: $env.GOOGLE_SHEETS_WEBHOOK_URL || '',\n    tiktokUploadEnabled: ($env.TIKTOK_UPLOAD_ENABLED || 'false').toLowerCase() === 'true',\n    tiktokAccessToken: $env.TIKTOK_ACCESS_TOKEN || '',\n    pexelsFallbackQuery: 'nature sunrise mountains peaceful sky clouds',\n    archiveQuery: 'Islamic nasheed vocals only royalty free',\n    sceneCount: 5,\n    sceneDuration: 5,\n    width: 1080,\n    height: 1920,\n    fps: 30,\n    nasheedVolume: 0.18,\n    optionalWatermark: $env.VIDEO_WATERMARK || '',\n    startedAt: new Date().toISOString(),\n    configNote: 'Prompts, API keys, schedule, and upload flags are centralized here.'\n  }\n}];"
+      },
+      "id": "central-config",
+      "name": "Central Config",
+      "type": "n8n-nodes-base.code",
+      "typeVersion": 2,
+      "position": [240, 0]
+    },
+    {
+      "parameters": {
+        "method": "POST",
+        "url": "https://api.openai.com/v1/chat/completions",
+        "sendHeaders": true,
+        "headerParameters": {
+          "parameters": [
+            {
+              "name": "Authorization",
+              "value": "={{'Bearer ' + $json.openAiApiKey}}"
+            },
+            {
+              "name": "Content-Type",
+              "value": "application/json"
+            }
+          ]
+        },
+        "sendBody": true,
+        "contentType": "json",
+        "jsonBody": "={{JSON.stringify({ model: $json.llmModel, response_format: { type: 'json_object' }, messages: [ { role: 'system', content: 'You are an Islamic motivation content agent for short-form video. Return strict JSON only. Do not fabricate Quran or hadith. Quote Quran only when authentic and cite surah/ayah when used. Quote hadith only when confidence is high and identify the source. Keep respectful tone.' }, { role: 'user', content: `Generate one Islamic motivational TikTok topic for today. Keep narration under 60 seconds. Produce engaging hook and respectful language. Return exactly: {\"title\":\"string\",\"message\":\"narration under 60 seconds\",\"description\":\"short description\",\"hashtags\":[\"#tag\"],\"sceneCount\":${$json.sceneCount}}. Avoid sectarian claims, fabricated narrations, and sensationalism.` } ] })}}",
+        "options": {
+          "timeout": 120000
+        }
+      },
+      "id": "islamic-motivation-agent",
+      "name": "Islamic Motivation Agent - GPT-4o",
+      "type": "n8n-nodes-base.httpRequest",
+      "typeVersion": 4.2,
+      "position": [520, 0],
+      "retryOnFail": true,
+      "maxTries": 2,
+      "waitBetweenTries": 3000,
+      "continueOnFail": true
+    },
+    {
+      "parameters": {
+        "jsCode": "const config = $('Central Config').first().json;\nasync function notify(message) {\n  if (!config.telegramBotToken || !config.telegramChatId) return;\n  await this.helpers.httpRequest({ method: 'POST', url: `https://api.telegram.org/bot${config.telegramBotToken}/sendMessage`, body: { chat_id: config.telegramChatId, text: message }, json: true, timeout: 30000 }).catch(() => undefined);\n}\nconst response = items[0].json;\nif (response.error) {\n  await notify(`❌ GPT topic generation failed after retry.\\n${response.error.message || JSON.stringify(response.error)}`);\n  throw new Error('GPT topic generation failed');\n}\nconst raw = response.choices?.[0]?.message?.content;\nif (!raw) {\n  await notify('❌ GPT topic generation returned no content.');\n  throw new Error('Missing GPT topic content');\n}\nlet motivation;\ntry { motivation = JSON.parse(raw); } catch (error) {\n  await notify(`❌ GPT topic JSON parse failed: ${error.message}`);\n  throw error;\n}\nfor (const key of ['title', 'message', 'description', 'hashtags']) {\n  if (motivation[key] === undefined) throw new Error(`Motivation JSON missing ${key}`);\n}\nmotivation.sceneCount = Number(motivation.sceneCount || config.sceneCount);\nmotivation.hashtags = Array.isArray(motivation.hashtags) ? motivation.hashtags : ['#islam', '#motivation'];\nreturn [{ json: { ...config, motivation } }];"
+      },
+      "id": "parse-agent-output",
+      "name": "Parse Agent Output",
+      "type": "n8n-nodes-base.code",
+      "typeVersion": 2,
+      "position": [800, 0]
+    },
+    {
+      "parameters": {
+        "method": "POST",
+        "url": "https://api.openai.com/v1/chat/completions",
+        "sendHeaders": true,
+        "headerParameters": {
+          "parameters": [
+            {
+              "name": "Authorization",
+              "value": "={{'Bearer ' + $json.openAiApiKey}}"
+            },
+            {
+              "name": "Content-Type",
+              "value": "application/json"
+            }
+          ]
+        },
+        "sendBody": true,
+        "contentType": "json",
+        "jsonBody": "={{JSON.stringify({ model: $json.llmModel, response_format: { type: 'json_object' }, messages: [ { role: 'system', content: 'You generate cinematic stock-footage scene plans for respectful Islamic motivational videos. Return strict JSON only.' }, { role: 'user', content: `Create exactly ${$json.sceneCount} scenes from this narration: ${$json.motivation.message}\\n\\nReturn {\"scenes\":[{\"scene\":1,\"search_query\":\"\",\"caption\":\"\",\"duration\":5,\"visual_description\":\"\"}]}. Each search_query must be optimized for Pexels portrait stock videos. Avoid humans dancing, music visuals, uncovered women, nightlife, inappropriate visuals, or disrespectful religious imagery. Prefer nature, sunrise, mosque exterior, desert, rain, mountains, Quran pages, prayer silhouettes, sky, clouds, calm water, and peaceful landscapes. Captions must be TikTok-short and match narration. Duration should be ${$json.sceneDuration}.` } ] })}}",
+        "options": {
+          "timeout": 120000
+        }
+      },
+      "id": "scene-generator",
+      "name": "Scene Generator - GPT-4o",
+      "type": "n8n-nodes-base.httpRequest",
+      "typeVersion": 4.2,
+      "position": [1080, 0],
+      "retryOnFail": true,
+      "maxTries": 2,
+      "waitBetweenTries": 3000,
+      "continueOnFail": true
+    },
+    {
+      "parameters": {
+        "jsCode": "const base = $('Parse Agent Output').first().json;\nasync function notify(message) {\n  if (!base.telegramBotToken || !base.telegramChatId) return;\n  await this.helpers.httpRequest({ method: 'POST', url: `https://api.telegram.org/bot${base.telegramBotToken}/sendMessage`, body: { chat_id: base.telegramChatId, text: message }, json: true, timeout: 30000 }).catch(() => undefined);\n}\nconst response = items[0].json;\nif (response.error) {\n  await notify(`❌ Scene generation failed after retry.\\n${response.error.message || JSON.stringify(response.error)}`);\n  throw new Error('Scene generation failed');\n}\nconst raw = response.choices?.[0]?.message?.content;\nif (!raw) throw new Error('Missing scene JSON content');\nlet parsed;\ntry { parsed = JSON.parse(raw); } catch (error) {\n  await notify(`❌ Scene JSON parse failed: ${error.message}`);\n  throw error;\n}\nlet scenes = Array.isArray(parsed.scenes) ? parsed.scenes : [];\nif (scenes.length !== base.sceneCount) throw new Error(`Expected ${base.sceneCount} scenes, got ${scenes.length}`);\nscenes = scenes\n  .map((scene, index) => ({\n    scene: Number(scene.scene || index + 1),\n    search_query: String(scene.search_query || base.pexelsFallbackQuery),\n    caption: String(scene.caption || '').slice(0, 120),\n    duration: Number(scene.duration || base.sceneDuration),\n    visual_description: String(scene.visual_description || scene.search_query || '')\n  }))\n  .sort((a, b) => a.scene - b.scene);\nreturn [{ json: { ...base, scenes } }];"
+      },
+      "id": "parse-scene-json",
+      "name": "Parse Scene JSON",
+      "type": "n8n-nodes-base.code",
+      "typeVersion": 2,
+      "position": [1360, 0]
+    },
+    {
+      "parameters": {
+        "jsCode": "const input = items[0].json;\nconst baseUrl = input.maesterBaseUrl.replace(/\\/$/, '');\nconst started = Date.now();\nconst maesterHeaders = { 'X-API-Key': input.maesterApiKey, 'Content-Type': 'application/json' };\n\nfunction requireValue(name, value) {\n  if (!value || String(value).startsWith('replace_with_')) throw new Error(`Missing required environment variable: ${name}`);\n}\nfunction toBase64(data) { return Buffer.from(data).toString('base64'); }\nfunction fromBase64(data) { return Buffer.from(data, 'base64'); }\nfunction secondsToAss(seconds) {\n  const h = Math.floor(seconds / 3600);\n  const m = Math.floor((seconds % 3600) / 60);\n  const s = Math.floor(seconds % 60);\n  const cs = Math.floor((seconds - Math.floor(seconds)) * 100);\n  return `${h}:${String(m).padStart(2, '0')}:${String(s).padStart(2, '0')}.${String(cs).padStart(2, '0')}`;\n}\nfunction buildAss(scenes) {\n  let body = '[Script Info]\\nScriptType: v4.00+\\nPlayResX: 1080\\nPlayResY: 1920\\nWrapStyle: 0\\nScaledBorderAndShadow: yes\\n\\n[V4+ Styles]\\nFormat: Name,Fontname,Fontsize,PrimaryColour,SecondaryColour,OutlineColour,BackColour,Bold,Italic,Underline,StrikeOut,ScaleX,ScaleY,Spacing,Angle,BorderStyle,Outline,Shadow,Alignment,MarginL,MarginR,MarginV,Encoding\\nStyle: TikTok,DejaVu Sans,72,&H00FFFFFF,&H00FFFFFF,&H00000000,&H7F000000,1,0,0,0,100,100,0,0,1,5,3,5,80,80,120,1\\n\\n[Events]\\nFormat: Layer,Start,End,Style,Name,MarginL,MarginR,MarginV,Effect,Text\\n';\n  let cursor = 0;\n  for (const scene of scenes) {\n    const end = cursor + Number(scene.duration || input.sceneDuration);\n    const text = String(scene.caption || '').replace(/[{}]/g, '').replace(/\\n/g, ' ');\n    body += `Dialogue: 0,${secondsToAss(cursor)},${secondsToAss(end)},TikTok,,0,0,0,,${text}\\n`;\n    cursor = end;\n  }\n  return body;\n}\nasync function notifyTelegram(message) {\n  if (!input.telegramBotToken || !input.telegramChatId) return { skipped: true };\n  return await this.helpers.httpRequest({ method: 'POST', url: `https://api.telegram.org/bot${input.telegramBotToken}/sendMessage`, body: { chat_id: input.telegramChatId, text: message }, json: true, timeout: 30000 }).catch(error => ({ error: error.message }));\n}\nasync function requestWithRetry(options, attempts = 3) {\n  let lastError;\n  for (let attempt = 1; attempt <= attempts; attempt++) {\n    try { return await this.helpers.httpRequest(options); } catch (error) { lastError = error; }\n  }\n  throw lastError;\n}\nasync function maesterJson(path, body) {\n  return await requestWithRetry.call(this, { method: 'POST', url: `${baseUrl}${path}`, headers: maesterHeaders, body: JSON.stringify(body), json: true, timeout: 120000 }, 2);\n}\nasync function ffmpegTask(task, files, options = {}) {\n  const payload = { ...options, files };\n  return await requestWithRetry.call(this, { method: 'POST', url: `${baseUrl}/services/ffmpeg/n8n/execute/${task}`, headers: maesterHeaders, body: JSON.stringify(payload), json: false, encoding: null, timeout: 600000 }, 1);\n}\nasync function searchPexels(scene) {\n  const queries = [scene.search_query, input.pexelsFallbackQuery];\n  for (const query of queries) {\n    const result = await requestWithRetry.call(this, { method: 'GET', url: 'https://api.pexels.com/videos/search', headers: { Authorization: input.pexelsApiKey }, qs: { query, orientation: 'portrait', size: 'medium', per_page: 10 }, json: true, timeout: 90000 }, 3).catch(() => ({ videos: [] }));\n    const candidates = (result.videos || [])\n      .filter(video => Number(video.duration || 0) >= Number(scene.duration || input.sceneDuration))\n      .map(video => {\n        const files = (video.video_files || []).filter(file => file.file_type === 'video/mp4' && file.link && (file.height || 0) >= 720);\n        const best = files.sort((a, b) => {\n          const ap = (a.height || 0) > (a.width || 0) ? 1 : 0;\n          const bp = (b.height || 0) > (b.width || 0) ? 1 : 0;\n          return (bp * 100000000 + (b.height || 0) * (b.width || 0)) - (ap * 100000000 + (a.height || 0) * (a.width || 0));\n        })[0];\n        return best ? { video, file: best, query } : null;\n      })\n      .filter(Boolean);\n    if (candidates.length) return candidates[0];\n  }\n  throw new Error(`Missing Pexels result for scene ${scene.scene}`);\n}\nasync function archiveNasheed() {\n  try {\n    const search = await requestWithRetry.call(this, { method: 'GET', url: 'https://archive.org/advancedsearch.php', qs: { q: input.archiveQuery, fl: 'identifier,title', rows: 8, output: 'json' }, json: true, timeout: 90000 }, 2);\n    for (const doc of search.response?.docs || []) {\n      const meta = await requestWithRetry.call(this, { method: 'GET', url: `https://archive.org/metadata/${doc.identifier}`, json: true, timeout: 90000 }, 2).catch(() => null);\n      const file = (meta?.files || []).find(item => /\\.(mp3|ogg|m4a)$/i.test(item.name || '') && !/sample|preview/i.test(item.name || ''));\n      if (file) {\n        const url = `https://archive.org/download/${doc.identifier}/${encodeURIComponent(file.name)}`;\n        const audio = await requestWithRetry.call(this, { method: 'GET', url, json: false, encoding: null, timeout: 180000 }, 2);\n        return { audio, filename: file.name, source_url: url, identifier: doc.identifier };\n      }\n    }\n  } catch (error) {\n    return { error: error.message };\n  }\n  return null;\n}\nasync function uploadForInspect(videoBuffer) {\n  const upload = await requestWithRetry.call(this, { method: 'POST', url: `${baseUrl}/services/render/upload`, headers: { 'X-API-Key': input.maesterApiKey }, formData: { files: { value: videoBuffer, options: { filename: 'islamic_motivation_final.mp4', contentType: 'video/mp4' } } }, json: true, timeout: 240000 }, 2);\n  const asset = upload.assets?.[0];\n  if (!asset?.path) throw new Error('Final upload for validation failed.');\n  const inspect = await requestWithRetry.call(this, { method: 'POST', url: `${baseUrl}/services/render/inspect`, headers: { 'X-API-Key': input.maesterApiKey }, qs: { path: asset.path }, json: true, timeout: 120000 }, 2);\n  return { asset, inspect };\n}\nasync function uploadTikTok(videoBuffer, title, description, hashtags) {\n  if (!input.tiktokUploadEnabled) return { skipped: true, status: 'dry_run' };\n  if (!input.tiktokAccessToken) throw new Error('TIKTOK_UPLOAD_ENABLED=true but TIKTOK_ACCESS_TOKEN is missing.');\n  const size = videoBuffer.length;\n  const init = await requestWithRetry.call(this, { method: 'POST', url: 'https://open.tiktokapis.com/v2/post/publish/video/init/', headers: { Authorization: `Bearer ${input.tiktokAccessToken}`, 'Content-Type': 'application/json' }, body: JSON.stringify({ post_info: { title: `${title}\\n\\n${hashtags.join(' ')}`.slice(0, 2200), privacy_level: 'SELF_ONLY', disable_duet: false, disable_comment: false, disable_stitch: false }, source_info: { source: 'FILE_UPLOAD', video_size: size, chunk_size: size, total_chunk_count: 1 } }), json: true, timeout: 120000 }, 2);\n  const uploadUrl = init.data?.upload_url || init.upload_url;\n  const publishId = init.data?.publish_id || init.publish_id;\n  if (!uploadUrl) throw new Error(`TikTok init did not return upload_url: ${JSON.stringify(init)}`);\n  await requestWithRetry.call(this, { method: 'PUT', url: uploadUrl, headers: { 'Content-Type': 'video/mp4', 'Content-Length': String(size), 'Content-Range': `bytes 0-${size - 1}/${size}` }, body: videoBuffer, json: false, timeout: 600000 }, 2);\n  return { status: 'uploaded', publish_id: publishId, init };\n}\ntry {\n  requireValue('MAESTER_API_KEY', input.maesterApiKey);\n  requireValue('OPENAI_API_KEY', input.openAiApiKey);\n  requireValue('PEXELS_API_KEY', input.pexelsApiKey);\n  const campaign = await maesterJson.call(this, '/automation/campaigns', { name: input.motivation.title, topic: input.motivation.message, niche: 'islamic motivation', platforms: ['tiktok'], quantity: input.sceneCount, tone: 'respectful Islamic motivation', metadata: { description: input.motivation.description, hashtags: input.motivation.hashtags } });\n  const compliance = await maesterJson.call(this, '/automation/compliance/check', { platform: 'tiktok', title: input.motivation.title, caption: input.motivation.description, hashtags: input.motivation.hashtags, duration_seconds: input.scenes.reduce((sum, scene) => sum + Number(scene.duration || input.sceneDuration), 0), has_disclosure: false });\n  const resizedClips = [];\n  const pexelsSources = [];\n  for (const scene of input.scenes) {\n    const match = await searchPexels.call(this, scene);\n    pexelsSources.push({ scene: scene.scene, query: match.query, pexels_id: match.video.id, url: match.video.url, user: match.video.user?.name });\n    const rawVideo = await requestWithRetry.call(this, { method: 'GET', url: match.file.link, json: false, encoding: null, timeout: 180000 }, 3);\n    const trimmed = await ffmpegTask.call(this, 'trim', [{ fileName: `scene_${scene.scene}.mp4`, mimeType: 'video/mp4', data: toBase64(rawVideo) }], { start_time: '0', end_time: String(scene.duration) });\n    const resized = await ffmpegTask.call(this, 'resize_916', [{ fileName: `scene_${scene.scene}_trimmed.mp4`, mimeType: 'video/mp4', data: toBase64(trimmed) }], { aspect_ratio: '9:16' });\n    resizedClips.push({ fileName: `scene_${scene.scene}_resized.mp4`, mimeType: 'video/mp4', data: toBase64(resized) });\n  }\n  const concatVideo = await ffmpegTask.call(this, 'concat', resizedClips, {});\n  const ass = buildAss(input.scenes);\n  const subtitled = await ffmpegTask.call(this, 'add_subtitles', [\n    { fileName: 'concat.mp4', mimeType: 'video/mp4', data: toBase64(concatVideo) },\n    { fileName: 'captions.ass', mimeType: 'text/plain', data: toBase64(Buffer.from(ass, 'utf8')) }\n  ], {});\n  let finalVideo = subtitled;\n  const nasheed = await archiveNasheed.call(this);\n  if (nasheed?.audio) {\n    finalVideo = await ffmpegTask.call(this, 'merge_music', [\n      { fileName: 'subtitled.mp4', mimeType: 'video/mp4', data: toBase64(subtitled) },\n      { fileName: nasheed.filename || 'nasheed.mp3', mimeType: 'audio/mpeg', data: toBase64(nasheed.audio) }\n    ], { volume: String(input.nasheedVolume) });\n  }\n  const normalized = await ffmpegTask.call(this, 'normalize', [{ fileName: 'final_precheck.mp4', mimeType: 'video/mp4', data: toBase64(finalVideo) }], { resolution: '1080p', crf: '23', preset: 'veryfast' });\n  const validation = await uploadForInspect.call(this, normalized);\n  const meta = validation.inspect || {};\n  const sizeOk = normalized.length > 1024 * 1024;\n  const durationOk = Number(meta.duration || 0) > 0;\n  const audioOk = Boolean(meta.has_audio);\n  const videoOk = Number(meta.width || 0) > 0 && Number(meta.height || 0) > 0;\n  if (!sizeOk || !durationOk || !audioOk || !videoOk) throw new Error(`Validation failed: ${JSON.stringify({ sizeOk, durationOk, audioOk, videoOk, meta })}`);\n  const tiktok = await uploadTikTok.call(this, normalized, input.motivation.title, input.motivation.description, input.motivation.hashtags);\n  const renderTimeSeconds = Math.round((Date.now() - started) / 1000);\n  return [{ json: { ok: true, status: tiktok.skipped ? 'rendered_not_published' : 'published', title: input.motivation.title, description: input.motivation.description, hashtags: input.motivation.hashtags, campaign_id: campaign.id, tiktok, tiktok_post_id: tiktok.publish_id || 'dry_run', duration: meta.duration, render_time_seconds: renderTimeSeconds, validation: { size_bytes: normalized.length, metadata: meta }, pexels_sources: pexelsSources, nasheed: nasheed?.source_url ? { source_url: nasheed.source_url, identifier: nasheed.identifier } : { skipped: true, reason: nasheed?.error || 'not_found' }, googleSheetsRow: { date: new Date().toISOString(), title: input.motivation.title, tiktok_post_id: tiktok.publish_id || 'dry_run', duration: meta.duration, render_time_seconds: renderTimeSeconds, status: tiktok.skipped ? 'rendered_not_published' : 'published' }, telegramMessage: `✅ Video ${tiktok.skipped ? 'Rendered' : 'Published'}\\n\\nTitle:\\n${input.motivation.title}\\n\\nTikTok ID:\\n${tiktok.publish_id || 'dry_run'}\\n\\nDuration:\\n${meta.duration}s` } }];\n} catch (error) {\n  const message = `❌ Islamic Motivation Pipeline Failed\\n\\n${error.message}`;\n  await notifyTelegram.call(this, message);\n  return [{ json: { ok: false, status: 'failed', error: error.message, telegramMessage: message, googleSheetsRow: { date: new Date().toISOString(), title: input.motivation?.title || 'unknown', tiktok_post_id: '', duration: '', render_time_seconds: Math.round((Date.now() - started) / 1000), status: 'failed' } } }];\n}"
+      },
+      "id": "render-edit-publish",
+      "name": "Render/Edit/Publish with Maester",
+      "type": "n8n-nodes-base.code",
+      "typeVersion": 2,
+      "position": [1640, 0]
+    },
+    {
+      "parameters": {
+        "conditions": {
+          "boolean": [
+            {
+              "value1": "={{$json.ok}}",
+              "value2": true
+            }
+          ]
+        }
+      },
+      "id": "validation-success",
+      "name": "Validation Success?",
+      "type": "n8n-nodes-base.if",
+      "typeVersion": 1,
+      "position": [1900, 0]
+    },
+    {
+      "parameters": {
+        "jsCode": "const input = items[0].json;\nconst config = $('Central Config').first().json;\nif (config.googleSheetsWebhookUrl) {\n  await this.helpers.httpRequest({ method: 'POST', url: config.googleSheetsWebhookUrl, body: input.googleSheetsRow, json: true, timeout: 30000 }).catch(() => undefined);\n}\nif (config.telegramBotToken && config.telegramChatId) {\n  await this.helpers.httpRequest({ method: 'POST', url: `https://api.telegram.org/bot${config.telegramBotToken}/sendMessage`, body: { chat_id: config.telegramChatId, text: input.telegramMessage }, json: true, timeout: 30000 }).catch(() => undefined);\n}\nreturn [{ json: { ...input, notifications_sent: true } }];"
+      },
+      "id": "google-sheets-telegram-success",
+      "name": "Google Sheets + Telegram Success",
+      "type": "n8n-nodes-base.code",
+      "typeVersion": 2,
+      "position": [2160, -120]
+    },
+    {
+      "parameters": {
+        "jsCode": "const input = items[0].json;\nconst config = $('Central Config').first().json;\nif (config.googleSheetsWebhookUrl) {\n  await this.helpers.httpRequest({ method: 'POST', url: config.googleSheetsWebhookUrl, body: input.googleSheetsRow, json: true, timeout: 30000 }).catch(() => undefined);\n}\nif (config.telegramBotToken && config.telegramChatId) {\n  await this.helpers.httpRequest({ method: 'POST', url: `https://api.telegram.org/bot${config.telegramBotToken}/sendMessage`, body: { chat_id: config.telegramChatId, text: input.telegramMessage }, json: true, timeout: 30000 }).catch(() => undefined);\n}\nreturn [{ json: { ...input, failure_notified: true } }];"
+      },
+      "id": "telegram-failure",
+      "name": "Telegram Failure + Failure Log",
+      "type": "n8n-nodes-base.code",
+      "typeVersion": 2,
+      "position": [2160, 120]
+    }
+  ],
+  "connections": {
+    "Schedule Trigger - Daily": {
+      "main": [[{ "node": "Central Config", "type": "main", "index": 0 }]]
+    },
+    "Central Config": {
+      "main": [[{ "node": "Islamic Motivation Agent - GPT-4o", "type": "main", "index": 0 }]]
+    },
+    "Islamic Motivation Agent - GPT-4o": {
+      "main": [[{ "node": "Parse Agent Output", "type": "main", "index": 0 }]]
+    },
+    "Parse Agent Output": {
+      "main": [[{ "node": "Scene Generator - GPT-4o", "type": "main", "index": 0 }]]
+    },
+    "Scene Generator - GPT-4o": {
+      "main": [[{ "node": "Parse Scene JSON", "type": "main", "index": 0 }]]
+    },
+    "Parse Scene JSON": {
+      "main": [[{ "node": "Render/Edit/Publish with Maester", "type": "main", "index": 0 }]]
+    },
+    "Render/Edit/Publish with Maester": {
+      "main": [[{ "node": "Validation Success?", "type": "main", "index": 0 }]]
+    },
+    "Validation Success?": {
+      "main": [
+        [{ "node": "Google Sheets + Telegram Success", "type": "main", "index": 0 }],
+        [{ "node": "Telegram Failure + Failure Log", "type": "main", "index": 0 }]
+      ]
+    }
+  },
+  "pinData": {},
+  "settings": {
+    "executionOrder": "v1"
+  },
+  "staticData": null,
+  "tags": [
+    { "name": "maester" },
+    { "name": "islamic-motivation" },
+    { "name": "tiktok" },
+    { "name": "pexels" },
+    { "name": "archive-org" }
+  ],
+  "triggerCount": 1,
+  "versionId": "maester-islamic-motivation-tiktok-v1"
+}

workflows/n8n/tiktok_storytelling_pexels.json

@@ -0,0 +1,159 @@
+{
+  "name": "Maester - TikTok Storytelling Mini Series with Pexels",
+  "nodes": [
+    {
+      "parameters": {},
+      "id": "manual-trigger",
+      "name": "Manual Trigger",
+      "type": "n8n-nodes-base.manualTrigger",
+      "typeVersion": 1,
+      "position": [0, 0]
+    },
+    {
+      "parameters": {
+        "jsCode": "const maesterBaseUrl = $env.MAESTER_BASE_URL || 'http://localhost:7860';\nconst maesterApiKey = $env.MAESTER_API_KEY || 'replace_with_maester_api_key';\nconst pexelsApiKey = $env.PEXELS_API_KEY || 'replace_with_pexels_api_key';\n\nreturn [{\n  json: {\n    maesterBaseUrl,\n    maesterApiKey,\n    pexelsApiKey,\n    seriesTitle: 'The Hidden Cost of Ignoring AI Automation',\n    episodeNumber: 1,\n    topic: 'a founder who saves their business by automating repetitive work',\n    audience: 'small business owners and creators',\n    platform: 'tiktok',\n    sceneCount: 5,\n    sceneDuration: 5,\n    template: 'tiktok_classic',\n    creativeStyle: 'fast_hook',\n    outputName: 'tiktok_storytelling_episode_01.mp4',\n    backgroundEffect: 'blur',\n    effects: ['slow_zoom', 'push_in', 'film_grain', 'vignette', 'caption_pop'],\n    musicVolume: 0.22,\n    captionTone: 'dramatic, simple, curiosity-driven'\n  }\n}];"
+      },
+      "id": "configure-story",
+      "name": "Configure Story",
+      "type": "n8n-nodes-base.code",
+      "typeVersion": 2,
+      "position": [240, 0]
+    },
+    {
+      "parameters": {
+        "jsCode": "const input = items[0].json;\nconst title = input.seriesTitle;\nconst topic = input.topic;\nconst audience = input.audience;\nconst count = Number(input.sceneCount || 5);\nconst duration = Number(input.sceneDuration || 5);\n\nconst sceneTemplates = [\n  {\n    query: `${topic} stressed entrepreneur office night`,\n    caption: `Episode ${input.episodeNumber}: Nobody noticed the warning signs.`\n  },\n  {\n    query: `${topic} business owner overwhelmed laptop paperwork`,\n    caption: 'Every day, the same tasks stole hours from the business.'\n  },\n  {\n    query: `${topic} automation dashboard computer workflow`,\n    caption: 'Then one workflow changed the entire routine.'\n  },\n  {\n    query: `${topic} team celebrating small business success`,\n    caption: 'The work did not disappear. It finally moved faster.'\n  },\n  {\n    query: `${topic} creator planning content calendar phone`,\n    caption: 'Follow for part two: the exact workflow behind it.'\n  }\n];\n\nconst scenes = Array.from({ length: count }, (_, index) => {\n  const template = sceneTemplates[index % sceneTemplates.length];\n  return {\n    index,\n    start: index * duration,\n    duration,\n    query: template.query,\n    caption: template.caption,\n    transition: index === 0 ? 'fade' : 'smooth',\n    background: input.backgroundEffect,\n    effect: input.effects[index % input.effects.length],\n    layout: 'fill'\n  };\n});\n\nreturn [{ json: { ...input, title, audience, scenes } }];"
+      },
+      "id": "build-scenes",
+      "name": "Build Story Scenes",
+      "type": "n8n-nodes-base.code",
+      "typeVersion": 2,
+      "position": [500, 0]
+    },
+    {
+      "parameters": {
+        "jsCode": "const input = items[0].json;\nif (!input.pexelsApiKey || input.pexelsApiKey === 'replace_with_pexels_api_key') {\n  throw new Error('Set PEXELS_API_KEY in n8n environment variables.');\n}\n\nasync function searchPexelsVideo(query) {\n  const response = await this.helpers.httpRequest({\n    method: 'GET',\n    url: 'https://api.pexels.com/videos/search',\n    headers: { Authorization: input.pexelsApiKey },\n    qs: {\n      query,\n      orientation: 'portrait',\n      size: 'medium',\n      per_page: 5\n    },\n    json: true\n  });\n\n  const videos = response.videos || [];\n  if (!videos.length) {\n    throw new Error(`No Pexels videos found for query: ${query}`);\n  }\n\n  const video = videos[0];\n  const files = (video.video_files || [])\n    .filter(file => file.file_type === 'video/mp4' && file.link)\n    .sort((a, b) => {\n      const aPortrait = (a.height || 0) > (a.width || 0) ? 1 : 0;\n      const bPortrait = (b.height || 0) > (b.width || 0) ? 1 : 0;\n      const aScore = aPortrait * 1000000 + (a.height || 0) * (a.width || 0);\n      const bScore = bPortrait * 1000000 + (b.height || 0) * (b.width || 0);\n      return bScore - aScore;\n    });\n\n  if (!files.length) {\n    throw new Error(`Pexels result had no mp4 files for query: ${query}`);\n  }\n\n  return {\n    media: files[0].link,\n    pexels: {\n      id: video.id,\n      url: video.url,\n      image: video.image,\n      user: video.user?.name,\n      query\n    }\n  };\n}\n\nconst resolvedScenes = [];\nfor (const scene of input.scenes) {\n  const asset = await searchPexelsVideo.call(this, scene.query);\n  resolvedScenes.push({\n    start: scene.start,\n    duration: scene.duration,\n    media: asset.media,\n    caption: scene.caption,\n    transition: scene.transition,\n    background: scene.background,\n    effect: scene.effect,\n    layout: scene.layout,\n    metadata: { pexels: asset.pexels }\n  });\n}\n\nconst renderPayload = {\n  template: input.template,\n  creative_style: input.creativeStyle,\n  platform: input.platform,\n  output_name: input.outputName,\n  subtitle_format: 'ass',\n  auto_subtitles: false,\n  normalize: true,\n  audio_normalize: true,\n  music_volume: input.musicVolume,\n  metadata: {\n    series_title: input.seriesTitle,\n    episode_number: input.episodeNumber,\n    topic: input.topic,\n    audience: input.audience,\n    source: 'n8n_pexels_storytelling_workflow'\n  },\n  scenes: resolvedScenes\n};\n\nreturn [{ json: { ...input, resolvedScenes, renderPayload } }];"
+      },
+      "id": "search-pexels",
+      "name": "Search Pexels Videos",
+      "type": "n8n-nodes-base.code",
+      "typeVersion": 2,
+      "position": [780, 0]
+    },
+    {
+      "parameters": {
+        "method": "POST",
+        "url": "={{$json.maesterBaseUrl + '/services/render/render'}}",
+        "sendHeaders": true,
+        "headerParameters": {
+          "parameters": [
+            {
+              "name": "X-API-Key",
+              "value": "={{$json.maesterApiKey}}"
+            },
+            {
+              "name": "Content-Type",
+              "value": "application/json"
+            }
+          ]
+        },
+        "sendBody": true,
+        "contentType": "json",
+        "jsonBody": "={{JSON.stringify($json.renderPayload)}}",
+        "options": {
+          "timeout": 180000
+        }
+      },
+      "id": "submit-render",
+      "name": "Submit Render to Maester",
+      "type": "n8n-nodes-base.httpRequest",
+      "typeVersion": 4.2,
+      "position": [1060, 0]
+    },
+    {
+      "parameters": {
+        "jsCode": "const response = items[0].json;\nreturn [{\n  json: {\n    status: 'submitted',\n    render_response: response,\n    next_steps: [\n      'Use the returned status_url to poll render progress.',\n      'Use the returned download_url when the job is completed.',\n      'Add a Wait node and HTTP Request node if you want automatic polling.'\n    ]\n  }\n}];"
+      },
+      "id": "final-response",
+      "name": "Return Render Job",
+      "type": "n8n-nodes-base.code",
+      "typeVersion": 2,
+      "position": [1320, 0]
+    }
+  ],
+  "connections": {
+    "Manual Trigger": {
+      "main": [
+        [
+          {
+            "node": "Configure Story",
+            "type": "main",
+            "index": 0
+          }
+        ]
+      ]
+    },
+    "Configure Story": {
+      "main": [
+        [
+          {
+            "node": "Build Story Scenes",
+            "type": "main",
+            "index": 0
+          }
+        ]
+      ]
+    },
+    "Build Story Scenes": {
+      "main": [
+        [
+          {
+            "node": "Search Pexels Videos",
+            "type": "main",
+            "index": 0
+          }
+        ]
+      ]
+    },
+    "Search Pexels Videos": {
+      "main": [
+        [
+          {
+            "node": "Submit Render to Maester",
+            "type": "main",
+            "index": 0
+          }
+        ]
+      ]
+    },
+    "Submit Render to Maester": {
+      "main": [
+        [
+          {
+            "node": "Return Render Job",
+            "type": "main",
+            "index": 0
+          }
+        ]
+      ]
+    }
+  },
+  "pinData": {},
+  "settings": {
+    "executionOrder": "v1"
+  },
+  "staticData": null,
+  "tags": [
+    {
+      "name": "maester"
+    },
+    {
+      "name": "tiktok"
+    },
+    {
+      "name": "pexels"
+    }
+  ],
+  "triggerCount": 0,
+  "updatedAt": "2026-07-13T00:00:00.000Z",
+  "versionId": "maester-tiktok-storytelling-pexels-v1"
+}

workflows/n8n/webhook_tiktok_storytelling_pexels.json

@@ -0,0 +1,160 @@
+{
+  "name": "Maester - Webhook TikTok Storytelling with Pexels",
+  "nodes": [
+    {
+      "parameters": {
+        "httpMethod": "POST",
+        "path": "maester/create-tiktok-story",
+        "responseMode": "lastNode",
+        "options": {
+          "responseCode": 202
+        }
+      },
+      "id": "webhook-trigger",
+      "name": "Create TikTok Story Webhook",
+      "type": "n8n-nodes-base.webhook",
+      "typeVersion": 2,
+      "position": [
+        0,
+        0
+      ],
+      "webhookId": "maester-create-tiktok-story"
+    },
+    {
+      "parameters": {
+        "jsCode": "const payload = items[0].json.body || items[0].json;\nconst maesterBaseUrl = ($env.MAESTER_BASE_URL || 'http://maester-enterprise:7860').replace(/\\/$/, '');\nconst maesterApiKey = $env.MAESTER_API_KEY || 'replace_with_maester_api_key';\nconst pexelsApiKey = $env.PEXELS_API_KEY || 'replace_with_pexels_api_key';\n\nif (!maesterApiKey || maesterApiKey === 'replace_with_maester_api_key') {\n  throw new Error('Set MAESTER_API_KEY in the n8n environment.');\n}\nif (!pexelsApiKey || pexelsApiKey === 'replace_with_pexels_api_key') {\n  throw new Error('Set PEXELS_API_KEY in the n8n environment.');\n}\n\nconst topic = payload.topic || 'a creator builds a simple automation that saves their day';\nconst sceneCount = Math.max(1, Math.min(Number(payload.scene_count || payload.sceneCount || 5), 8));\nconst sceneDuration = Math.max(3, Math.min(Number(payload.scene_duration || payload.sceneDuration || 5), 12));\n\nreturn [{\n  json: {\n    maesterBaseUrl,\n    maesterApiKey,\n    pexelsApiKey,\n    topic,\n    seriesTitle: payload.series_title || payload.seriesTitle || 'Maester Automation Story',\n    episodeNumber: Number(payload.episode_number || payload.episodeNumber || 1),\n    audience: payload.audience || 'short-form video viewers',\n    platform: payload.platform || 'tiktok',\n    sceneCount,\n    sceneDuration,\n    template: payload.template || 'tiktok_classic',\n    creativeStyle: payload.creative_style || payload.creativeStyle || 'fast_hook',\n    outputName: payload.output_name || payload.outputName || 'maester_webhook_tiktok_story.mp4',\n    backgroundEffect: payload.background_effect || payload.backgroundEffect || 'blur',\n    effects: payload.effects || ['slow_zoom', 'push_in', 'film_grain', 'vignette', 'caption_pop'],\n    musicVolume: Number(payload.music_volume || payload.musicVolume || 0.22)\n  }\n}];"
+      },
+      "id": "normalize-request",
+      "name": "Normalize Request",
+      "type": "n8n-nodes-base.code",
+      "typeVersion": 2,
+      "position": [
+        260,
+        0
+      ]
+    },
+    {
+      "parameters": {
+        "jsCode": "const input = items[0].json;\nconst templates = [\n  {\n    query: `${input.topic} stressed person working late vertical video`,\n    caption: `Episode ${input.episodeNumber}: The problem was hiding in plain sight.`\n  },\n  {\n    query: `${input.topic} laptop workflow dashboard vertical video`,\n    caption: 'The repetitive work kept taking the best hours.'\n  },\n  {\n    query: `${input.topic} automation technology computer vertical video`,\n    caption: 'Then one workflow changed the routine.'\n  },\n  {\n    query: `${input.topic} creator planning content calendar phone vertical video`,\n    caption: 'The system started moving before the day got busy.'\n  },\n  {\n    query: `${input.topic} successful small business owner team vertical video`,\n    caption: 'The result: more output, less manual chasing.'\n  }\n];\n\nconst scenes = Array.from({ length: input.sceneCount }, (_, index) => {\n  const template = templates[index % templates.length];\n  return {\n    index,\n    start: index * input.sceneDuration,\n    duration: input.sceneDuration,\n    query: template.query,\n    caption: template.caption,\n    transition: index === 0 ? 'fade' : 'smooth',\n    background: input.backgroundEffect,\n    effect: input.effects[index % input.effects.length],\n    layout: 'fill'\n  };\n});\n\nreturn [{ json: { ...input, scenes } }];"
+      },
+      "id": "build-scenes",
+      "name": "Build Scenes",
+      "type": "n8n-nodes-base.code",
+      "typeVersion": 2,
+      "position": [
+        520,
+        0
+      ]
+    },
+    {
+      "parameters": {
+        "jsCode": "const input = items[0].json;\n\nasync function searchPexelsVideo(query) {\n  const response = await this.helpers.httpRequest({\n    method: 'GET',\n    url: 'https://api.pexels.com/videos/search',\n    headers: { Authorization: input.pexelsApiKey },\n    qs: {\n      query,\n      orientation: 'portrait',\n      size: 'medium',\n      per_page: 8\n    },\n    json: true,\n    timeout: 90000\n  });\n\n  const videos = response.videos || [];\n  if (!videos.length) {\n    throw new Error(`No Pexels videos found for query: ${query}`);\n  }\n\n  for (const video of videos) {\n    const files = (video.video_files || [])\n      .filter(file => file.file_type === 'video/mp4' && file.link)\n      .sort((a, b) => {\n        const aPortrait = (a.height || 0) > (a.width || 0) ? 1 : 0;\n        const bPortrait = (b.height || 0) > (b.width || 0) ? 1 : 0;\n        const aScore = aPortrait * 100000000 + (a.height || 0) * (a.width || 0);\n        const bScore = bPortrait * 100000000 + (b.height || 0) * (b.width || 0);\n        return bScore - aScore;\n      });\n    if (files.length) {\n      return {\n        media: files[0].link,\n        pexels: {\n          id: video.id,\n          url: video.url,\n          image: video.image,\n          user: video.user?.name,\n          query,\n          width: files[0].width,\n          height: files[0].height\n        }\n      };\n    }\n  }\n\n  throw new Error(`Pexels returned no usable mp4 files for query: ${query}`);\n}\n\nconst resolvedScenes = [];\nfor (const scene of input.scenes) {\n  const asset = await searchPexelsVideo.call(this, scene.query);\n  resolvedScenes.push({\n    start: scene.start,\n    duration: scene.duration,\n    media: asset.media,\n    caption: scene.caption,\n    transition: scene.transition,\n    background: scene.background,\n    effect: scene.effect,\n    layout: scene.layout,\n    metadata: { pexels: asset.pexels }\n  });\n}\n\nconst renderPayload = {\n  template: input.template,\n  creative_style: input.creativeStyle,\n  platform: input.platform,\n  output_name: input.outputName,\n  subtitle_format: 'ass',\n  auto_subtitles: false,\n  normalize: true,\n  audio_normalize: true,\n  music_volume: input.musicVolume,\n  metadata: {\n    series_title: input.seriesTitle,\n    episode_number: input.episodeNumber,\n    topic: input.topic,\n    audience: input.audience,\n    source: 'n8n_webhook_pexels_storytelling_workflow'\n  },\n  scenes: resolvedScenes\n};\n\nreturn [{ json: { ...input, renderPayload } }];"
+      },
+      "id": "search-pexels",
+      "name": "Search Pexels Videos",
+      "type": "n8n-nodes-base.code",
+      "typeVersion": 2,
+      "position": [
+        780,
+        0
+      ]
+    },
+    {
+      "parameters": {
+        "method": "POST",
+        "url": "={{$json.maesterBaseUrl + '/services/render/render'}}",
+        "sendHeaders": true,
+        "headerParameters": {
+          "parameters": [
+            {
+              "name": "X-API-Key",
+              "value": "={{$json.maesterApiKey}}"
+            },
+            {
+              "name": "Content-Type",
+              "value": "application/json"
+            }
+          ]
+        },
+        "sendBody": true,
+        "contentType": "json",
+        "jsonBody": "={{JSON.stringify($json.renderPayload)}}",
+        "options": {
+          "timeout": 180000
+        }
+      },
+      "id": "submit-render",
+      "name": "Submit Render to Maester",
+      "type": "n8n-nodes-base.httpRequest",
+      "typeVersion": 4.2,
+      "position": [
+        1060,
+        0
+      ]
+    }
+  ],
+  "connections": {
+    "Create TikTok Story Webhook": {
+      "main": [
+        [
+          {
+            "node": "Normalize Request",
+            "type": "main",
+            "index": 0
+          }
+        ]
+      ]
+    },
+    "Normalize Request": {
+      "main": [
+        [
+          {
+            "node": "Build Scenes",
+            "type": "main",
+            "index": 0
+          }
+        ]
+      ]
+    },
+    "Build Scenes": {
+      "main": [
+        [
+          {
+            "node": "Search Pexels Videos",
+            "type": "main",
+            "index": 0
+          }
+        ]
+      ]
+    },
+    "Search Pexels Videos": {
+      "main": [
+        [
+          {
+            "node": "Submit Render to Maester",
+            "type": "main",
+            "index": 0
+          }
+        ]
+      ]
+    }
+  },
+  "settings": {
+    "executionOrder": "v1"
+  },
+  "staticData": null,
+  "pinData": {},
+  "versionId": "maester-webhook-tiktok-storytelling-pexels",
+  "triggerCount": 0,
+  "tags": [
+    {
+      "name": "maester"
+    },
+    {
+      "name": "webhook"
+    },
+    {
+      "name": "tiktok"
+    }
+  ]
+}