23 lines
709 B
TypeScript
23 lines
709 B
TypeScript
import { hatchet } from "./client";
|
|
import { processTelegramInbound, processTelegramOutbound } from "./tasks";
|
|
import path from "node:path";
|
|
import { fileURLToPath } from "node:url";
|
|
|
|
async function main() {
|
|
const worker = await hatchet.worker("telegram-worker", {
|
|
workflows: [processTelegramInbound, processTelegramOutbound],
|
|
});
|
|
|
|
await worker.start();
|
|
}
|
|
|
|
const isMain = process.argv[1] && path.resolve(process.argv[1]) === fileURLToPath(import.meta.url);
|
|
|
|
if (isMain) {
|
|
main().catch((error) => {
|
|
const message = error instanceof Error ? error.stack || error.message : String(error);
|
|
console.error(`[telegram_worker/hatchet] worker failed: ${message}`);
|
|
process.exitCode = 1;
|
|
});
|
|
}
|