92 lines
3.5 KiB
TypeScript
92 lines
3.5 KiB
TypeScript
import type { Command } from 'commander';
|
|
import type { CliContext, MediaSpec } from '../cli/shared.js';
|
|
import { formatTweetUrlLine } from '../lib/output.js';
|
|
import { TwitterClient } from '../lib/twitter-client.js';
|
|
|
|
async function uploadMediaOrExit(
|
|
client: TwitterClient,
|
|
media: MediaSpec[],
|
|
ctx: CliContext,
|
|
): Promise<string[] | undefined> {
|
|
if (media.length === 0) {
|
|
return undefined;
|
|
}
|
|
|
|
const uploaded: string[] = [];
|
|
for (const item of media) {
|
|
const res = await client.uploadMedia({ data: item.buffer, mimeType: item.mime, alt: item.alt });
|
|
if (!res.success || !res.mediaId) {
|
|
console.error(`${ctx.p('err')}Media upload failed: ${res.error ?? 'Unknown error'}`);
|
|
process.exit(1);
|
|
}
|
|
uploaded.push(res.mediaId);
|
|
}
|
|
return uploaded;
|
|
}
|
|
|
|
export function registerPostCommands(program: Command, ctx: CliContext): void {
|
|
program
|
|
.command('tweet')
|
|
.description('Post a new tweet')
|
|
.argument('<text>', 'Tweet text')
|
|
.action(async (text: string) => {
|
|
const opts = program.opts();
|
|
const timeoutMs = ctx.resolveTimeoutFromOptions(opts);
|
|
const quoteDepth = ctx.resolveQuoteDepthFromOptions(opts);
|
|
let media: MediaSpec[] = [];
|
|
try {
|
|
media = ctx.loadMedia({ media: opts.media ?? [], alts: opts.alt ?? [] });
|
|
} catch (error) {
|
|
console.error(`${ctx.p('err')}${error instanceof Error ? error.message : String(error)}`);
|
|
process.exit(1);
|
|
}
|
|
const relayBaseUrl = ctx.resolveRelayBaseUrlFromOptions(opts);
|
|
const profileName = ctx.resolveProfileNameFromOptions(opts);
|
|
const client = new TwitterClient({ relayBaseUrl, profileName, timeoutMs, quoteDepth });
|
|
const mediaIds = await uploadMediaOrExit(client, media, ctx);
|
|
const result = await client.tweet(text, mediaIds);
|
|
|
|
if (result.success) {
|
|
console.log(`${ctx.p('ok')}Tweet posted successfully!`);
|
|
console.log(formatTweetUrlLine(result.tweetId, ctx.getOutput()));
|
|
} else {
|
|
console.error(`${ctx.p('err')}Failed to post tweet: ${result.error}`);
|
|
process.exit(1);
|
|
}
|
|
});
|
|
|
|
program
|
|
.command('reply')
|
|
.description('Reply to an existing tweet')
|
|
.argument('<tweet-id-or-url>', 'Tweet ID or URL to reply to')
|
|
.argument('<text>', 'Reply text')
|
|
.action(async (tweetIdOrUrl: string, text: string) => {
|
|
const opts = program.opts();
|
|
const timeoutMs = ctx.resolveTimeoutFromOptions(opts);
|
|
const quoteDepth = ctx.resolveQuoteDepthFromOptions(opts);
|
|
let media: MediaSpec[] = [];
|
|
try {
|
|
media = ctx.loadMedia({ media: opts.media ?? [], alts: opts.alt ?? [] });
|
|
} catch (error) {
|
|
console.error(`${ctx.p('err')}${error instanceof Error ? error.message : String(error)}`);
|
|
process.exit(1);
|
|
}
|
|
const tweetId = ctx.extractTweetId(tweetIdOrUrl);
|
|
const relayBaseUrl = ctx.resolveRelayBaseUrlFromOptions(opts);
|
|
const profileName = ctx.resolveProfileNameFromOptions(opts);
|
|
console.error(`${ctx.p('info')}Replying to tweet: ${tweetId}`);
|
|
|
|
const client = new TwitterClient({ relayBaseUrl, profileName, timeoutMs, quoteDepth });
|
|
const mediaIds = await uploadMediaOrExit(client, media, ctx);
|
|
const result = await client.reply(text, tweetId, mediaIds);
|
|
|
|
if (result.success) {
|
|
console.log(`${ctx.p('ok')}Reply posted successfully!`);
|
|
console.log(formatTweetUrlLine(result.tweetId, ctx.getOutput()));
|
|
} else {
|
|
console.error(`${ctx.p('err')}Failed to post reply: ${result.error}`);
|
|
process.exit(1);
|
|
}
|
|
});
|
|
}
|