Post Scheduling

{
  "subreddit": "OnlyFans101",
  "post_type": "text",
  "title": "New content drop this weekend!"
}

setInterval(async () => {
  try {
    const now = new Date().toISOString();
    
    // Find all posts due for publishing
    const res = await dAPI("GET",
      `/items/scheduled_posts?filter[status][_eq]=scheduled&filter[scheduled_time][_lte]=${now}&limit=10&fields=id,platform,content_text,platform_meta,media_id,clip_job_id,creator_id`
    );
    
    const due = res?.data || [];
    
    for (const post of due) {
      // Create publish_post job
      await dAPI("POST", "/items/media_jobs", {
        operation: "publish_post",
        status: "queued",
        params: {
          scheduled_post_id: post.id,
          platform: post.platform,
          content_text: post.content_text,
          platform_meta: post.platform_meta || {},
          creator_profile_id: post.creator_profile_id,
        },
        priority: 1,
      });
      
      console.log(`[post-scheduler] queued publish job for post=${post.id} platform=${post.platform}`);
    }
  } catch (err) {
    console.error(`[post-scheduler] poll error: ${err.message}`);
  }
}, POST_SCHEDULER_MS);

async function postToX(sid, content_text) {
  // Navigate to compose page
  await publishSPost(`/v1/sessions/${sid}/navigate`, { 
    url: "https://x.com/compose/tweet" 
  });
  
  // Fill tweet text
  await publishSPost(`/v1/sessions/${sid}/act`, {
    action: `Type the following text into the tweet compose box: "${content_text.replace(/"/g, '\\"')}"`,
    modelName: PUBLISH_STAGEHAND_MODEL,
  });
  
  // Submit
  await publishSPost(`/v1/sessions/${sid}/act`, {
    action: "Click the Post button to submit the tweet",
    modelName: PUBLISH_STAGEHAND_MODEL,
  });
  
  return { platform: "x", status: "posted" };
}

async function postToReddit(sid, content_text, platform_meta = {}) {
  const subreddit = platform_meta.subreddit || "u_me";
  const post_type = platform_meta.post_type || "text";
  const url = `https://www.reddit.com/r/${subreddit}/submit?type=${post_type}`;
  
  await publishSPost(`/v1/sessions/${sid}/navigate`, { url });
  
  if (post_type === "text") {
    // Fill title
    await publishSPost(`/v1/sessions/${sid}/act`, {
      action: `Fill in the title field with: "${platform_meta.title || content_text.slice(0, 100)}"`,
      modelName: PUBLISH_STAGEHAND_MODEL,
    });
    
    // Fill body
    await publishSPost(`/v1/sessions/${sid}/act`, {
      action: `Fill in the body/text field with: "${content_text}"`,
      modelName: PUBLISH_STAGEHAND_MODEL,
    });
  }
  
  // Submit
  await publishSPost(`/v1/sessions/${sid}/act`, {
    action: "Click the Post button to submit",
    modelName: PUBLISH_STAGEHAND_MODEL,
  });
  
  return { platform: "reddit", subreddit, status: "posted" };
}

if (creator_profile_id) {
  try {
    const sessRes = await dAPI("GET",
      `/items/platform_sessions?filter[creator_profile_id][_eq]=${creator_profile_id}&filter[platform][_eq]=${platform}&filter[status][_eq]=active&limit=1&fields=encrypted_cookies`
    );
    
    const sess = sessRes?.data?.[0];
    if (sess?.encrypted_cookies) {
      const plain = decryptCredentials(sess.encrypted_cookies);
      if (plain?.cookies) {
        cookies = plain.cookies;
      }
    }
  } catch { /* no cookies — will fall back to plain navigation */ }
}

// Inject into Playwright session
if (cookies.length > 0) {
  await publishSPost(`/v1/sessions/${sid}/cookies`, { cookies });
}

async function handleSave(scheduleNow) {
  if (limitHit && scheduleNow) {
    return alert('Post limit reached for this month. Upgrade your plan.');
  }
  
  if (scheduleNow) {
    const inc = await incrementUsage('post_creations');
    if (!inc.ok) return alert('Post limit reached. Upgrade.');
  }
  
  await posts.create({ ...draftPost, status: scheduleNow ? 'scheduled' : 'draft' });
}

const res = await fetch('/api/llm/api/captions/generate', {
  method: 'POST',
  headers: { 
    'Content-Type': 'application/json',
    Authorization: `Bearer ${token}` 
  },
  body: JSON.stringify({
    platform: 'tiktok',
    tone: 'flirty',
    topic: 'new photo set',
    length: 'medium'
  })
});

const { caption } = await res.json();
// "Can't wait to show you what I've been working on... 😏 New set drops tonight. Link in bio 💕 #newcontent #exclusive"

async function generateContent(feedbackNote) {
  setGenerating(true);
  
  const res = await fetch('/api/llm/api/captions/generate', {
    method: 'POST',
    body: JSON.stringify({
      platform: genPrompt.platform,
      tone: genPrompt.tone,
      topic: feedbackNote 
        ? `${genPrompt.topic} [Adjustment: ${feedbackNote}]`  // Inject feedback
        : genPrompt.topic,
      length: genPrompt.length,
    }),
  });
  
  const data = await res.json();
  setGeneratedText(data.caption);
}

pm2 logs media-worker | grep post-scheduler

# Watch polling in real-time
pm2 logs media-worker -f | grep -E "post-scheduler|publish_post"