import { fn, http, schedule, MemoryInterpreter } from '@versori/run';

const workflow = schedule('every-minute', '* * * * *')
    .then(
        fn('log', (ctx) => {
            ctx.log.debug('Hello, world!');

            return 42;
        })
    )
    .then(
        http('httpbin', { connection: 'httpbin' }, async ({ fetch, log }) => {
            // The `fetch` implementation passed on the context object is already authenticated and configured to
            // prepend the base URL to the final request based on how the connection is configured from the Versori
            // platform.
            const resp = await fetch('/headers');

            log.debug('response', { resp });

            return resp.json();
        })
    );

async function main(): Promise<void> {
    const interpreter = new MemoryInterpreter();

    interpreter.register(workflow);

    await interpreter.start();
}

main().catch((err) => {
    console.error('Failed to run workflow', err);
});