cli.js

#!/usr/bin/env node

const { program } = require('commander');
const fetch = require('node-fetch');

// Your worker URL
const WORKER_URL = 'https://autoblogger-agent.wzmcghee.workers.dev';
let accessToken = null;

async function getAccessToken() {
    if (!process.env.CF_ACCESS_EMAIL) {
        throw new Error('Please set CF_ACCESS_EMAIL environment variable');
    }

    const response = await fetch('https://autoblogger.cloudflareaccess.com/cdn-cgi/access/get-token', {
        method: 'POST',
        headers: { 'Content-Type': 'application/json' },
        body: JSON.stringify({ email: process.env.CF_ACCESS_EMAIL })
    });

    if (!response.ok) {
        throw new Error('Failed to get access token');
    }

    const data = await response.json();
    return data.token;
}

async function makeAuthenticatedRequest(path, method, body) {
    if (!accessToken) {
        accessToken = await getAccessToken();
    }

    const response = await fetch(`${WORKER_URL}${path}`, {
        method,
        headers: {
            'Content-Type': 'application/json',
            'Cf-Access-Jwt-Assertion': accessToken
        },
        body: body ? JSON.stringify(body) : undefined
    });

    if (response.status === 401) {
        // Token might be expired, try once more
        accessToken = await getAccessToken();
        return makeAuthenticatedRequest(path, method, body);
    }

    return response;
}

program
    .command('generate <topic>')
    .description('Generate a new blog post')
    .action(async (topic) => {
        try {
            const response = await makeAuthenticatedRequest('/generate', 'POST', { topic });
            console.log('Generated:', await response.json());
        } catch (error) {
            console.error('Error:', error);
        }
    });

program
    .command('publish <url>')
    .description('Publish a draft post')
    .action(async (url) => {
        try {
            const response = await makeAuthenticatedRequest('/publish', 'POST', { postUrl: url });
            console.log('Published:', await response.json());
        } catch (error) {
            console.error('Error:', error);
        }
    });

program
    .command('list')
    .description('List all posts')
    .action(async () => {
        try {
            const response = await makeAuthenticatedRequest('/posts', 'GET');
            console.log('Posts:', await response.json());
        } catch (error) {
            console.error('Error:', error);
        }
    });

program.parse(process.argv);