"use strict";
Object.defineProperty(exports, "__esModule", { value: true });
exports.JobExecutor = void 0;
class JobExecutor {
    jobHandlers = new Map();
    constructor(opts) {
        if (opts.frpcPath && opts.frpcConfigPath) {
            require("./xxl-job/frpc").createFrpc(opts.frpcPath, opts.frpcConfigPath);
        }
        new (require("./xxl-job/index").XxlJobExecutor)(opts.xxlJob, this.jobHandlers).applyMiddleware({
            app: opts.app,
            domain: opts.appDomain
        });
        opts.app.listen(opts.port, () => {
            console.log(`[XXL-JOB] Executor "${opts.xxlJob.executorKey}" is running`);
            console.log(`- Local: http://localhost:${opts.port}`);
            console.log(`- Public: ${opts.appDomain}`);
        });
    }
    register(jobName, handler) {
        if (this.jobHandlers.has(jobName)) {
            throw new Error(`Job handler "${jobName}" is already registered`);
        }
        if (typeof handler !== 'function') {
            throw new Error(`Job handler "${jobName}" must be a function`);
        }
        console.log(`[XXL-JOB] Job "${jobName}" registered`);
        this.jobHandlers.set(jobName, async (...args) => {
            try {
                return await handler(...args);
            }
            catch (error) {
                console.error(`[XXL-JOB] Job "${jobName}" failed:`, error);
                return { error };
            }
        });
    }
    getJobHandler(jobName) {
        return this.jobHandlers.get(jobName);
    }
}
exports.JobExecutor = JobExecutor;
//# sourceMappingURL=index.js.map