How to Build an Automated TikTok Pipeline from UGC Clips

// Read candidate clips from workspace/hooks/ugc-clips/

const clipPool = fs.readdirSync('/Users/anicca/.openclaw/workspace/hooks/ugc-clips')

  .filter(f => f.endsWith('.mp4'));



// Select unused clips randomly

const selectedClips = clipPool

  .filter(clip => !usedClips.includes(clip))

  .sort(() => Math.random() - 0.5)

  .slice(0, 3); // Select 3 clips



// Save to slot JSON

const slotData = {

  clips: selectedClips.map(name => ({

    path: `/Users/anicca/.openclaw/workspace/hooks/ugc-clips/${name}`,

    duration: 10 // seconds (use ffprobe for accuracy)

  })),

  caption: generateCaption(), // Hook generation (separate function)

  hashtags: ['#selfcare', '#mindfulness', '#healing']

};

fs.writeFileSync(`workspace/hooks/slot-08-00-ja.json`, JSON.stringify(slotData, null, 2));

const ffmpeg = require('fluent-ffmpeg');

const slotData = JSON.parse(fs.readFileSync('workspace/hooks/slot-08-00-ja.json'));



// Trim each clip to 10 seconds

const trimmedPaths = [];

for (const [i, clip] of slotData.clips.entries()) {

  const outputPath = `/tmp/trimmed-${i}.mp4`;

  await new Promise((resolve, reject) => {

    ffmpeg(clip.path)

      .setStartTime(0)

      .setDuration(10)

      .output(outputPath)

      .on('end', resolve)

      .on('error', reject)

      .run();

  });

  trimmedPaths.push(outputPath);

}



// Concatenate 3 clips into 1

const finalPath = 'workspace/output/final-08-00-ja.mp4';

await new Promise((resolve, reject) => {

  const cmd = ffmpeg();

  trimmedPaths.forEach(path => cmd.input(path));

  cmd

    .complexFilter('[0:v][1:v][2:v]concat=n=3:v=1:a=0[outv]', ['outv'])

    .outputOptions('-map', '[outv]')

    .output(finalPath)

    .on('end', resolve)

    .on('error', reject)

    .run();

});



console.log(`Final video: ${finalPath}`);

const axios = require('axios');

const FormData = require('form-data');

const fs = require('fs');



const slotData = JSON.parse(fs.readFileSync('workspace/hooks/slot-08-00-ja.json'));

const videoPath = 'workspace/output/final-08-00-ja.mp4';



// 1. Upload video (Postiz Media API)

const form = new FormData();

form.append('file', fs.createReadStream(videoPath));

const uploadRes = await axios.post('https://api.postiz.com/public/v1/media/upload', form, {

  headers: { 

    ...form.getHeaders(),

    'Authorization': process.env.POSTIZ_API_KEY 

  }

});

const mediaId = uploadRes.data.id;



// 2. Create post (Postiz Posts API)

await axios.post('https://api.postiz.com/public/v1/posts', {

  integrationId: process.env.POSTIZ_TIKTOK_JP_INTEGRATION_ID, // TikTok JP

  content: `${slotData.caption}\n\n${slotData.hashtags.join(' ')}`,

  mediaIds: [mediaId],

  scheduleAt: new Date().toISOString() // Immediate posting

}, {

  headers: { 'Authorization': process.env.POSTIZ_API_KEY }

});



console.log('Posted to TikTok via Postiz');

# ~/.openclaw/workspace/cron-jobs.json (OpenClaw Gateway)

{

  "name": "mau-tiktok-ja-morning",

  "schedule": { "kind": "cron", "expr": "0 8 * * *", "tz": "Asia/Tokyo" },

  "payload": {

    "kind": "agentTurn",

    "message": "Execute mau-tiktok skill for JA morning slot (08:00)"

  },

  "sessionTarget": "isolated"

}