#!/usr/bin/env node
/**
 * Trigger a one-shot WeChat news morning draft push on the Portal worker.
 * Sets news_morning_draft.forcePushOnce; worker picks it up on the next scan (~30s).
 *
 * Usage:
 *   node scripts/push-wechat-news-morning-draft.mjs
 *   node scripts/push-wechat-news-morning-draft.mjs --apply
 *   node scripts/push-wechat-news-morning-draft.mjs --apply --allow-yesterday
 */
import process from 'node:process';
import mysql from 'mysql2/promise';
import { loadH5Environment } from './load-env.mjs';

loadH5Environment(import.meta.dirname);

const CONFIG_KEY = 'news_morning_draft';
const CONFIG_TABLE = 'h5_wechat_admin_config';

async function main() {
  const apply = process.argv.includes('--apply');
  const allowYesterday = process.argv.includes('--allow-yesterday');
  if (!process.env.DATABASE_URL) {
    console.error('DATABASE_URL missing');
    process.exit(1);
  }

  const pool = mysql.createPool({ uri: process.env.DATABASE_URL, connectionLimit: 2 });
  const [rows] = await pool.query(
    `SELECT config_json FROM ${CONFIG_TABLE} WHERE config_key = ? LIMIT 1`,
    [CONFIG_KEY],
  );
  const current = rows[0]?.config_json
    ? (typeof rows[0].config_json === 'string'
      ? JSON.parse(rows[0].config_json)
      : rows[0].config_json)
    : {};
  const next = {
    ...current,
    enabled: current.enabled !== false,
    forcePushOnce: true,
    forcePushRequireToday: !allowYesterday,
  };

  console.log(JSON.stringify({
    apply,
    allowYesterday,
    sourceUserId: current.sourceUserId ?? null,
    enabled: next.enabled,
    forcePushRequireToday: next.forcePushRequireToday,
  }, null, 2));

  if (apply) {
    const now = Date.now();
    await pool.query(
      `INSERT INTO ${CONFIG_TABLE} (config_key, config_json, updated_by, updated_at)
       VALUES (?, ?, ?, ?)
       ON DUPLICATE KEY UPDATE
         config_json = VALUES(config_json),
         updated_by = VALUES(updated_by),
         updated_at = VALUES(updated_at)`,
      [CONFIG_KEY, JSON.stringify(next), 'manual-push-draft', now],
    );
    console.log('forcePushOnce=true persisted; Portal worker should push draft within ~30s');
  }

  await pool.end();
}

main().catch((error) => {
  console.error(error instanceof Error ? error.message : error);
  process.exit(1);
});