import z from "zod";
import { ServiceClient } from "../../service-client";
import { CreateScheduledJobSchema, ListScheduledJobsSchema, GetScheduledJobSchema, ListExecutionsSchema, GetDailyExecutionTrendSchema, GetTopFailedJobsSchema, GetJobStatsSchema, ListAvgExecutionsSchema, UpdateJobSchema, DeleteJobSchema, QueueJobSchema, DeleteExecutionsSchema } from "./schema";
import { AvgExecution, Execution, ExecutionTrend, FailedJob, JobMetrics, JobStats, ScheduledJob } from "./types";

export class ScheduledJobService extends ServiceClient {
    protected getServiceName(): string {
        return 'com.appconda.service.scheduled-jobs';
    }

    public async CreateScheduledJob(payload: z.infer<typeof CreateScheduledJobSchema>): Promise<ScheduledJob> {
        return await this.actionCall('CreateScheduledJob', payload);
    }

    public async ListScheduledJobs(payload: z.infer<typeof ListScheduledJobsSchema>): Promise<ScheduledJob[]> {
        return await this.actionCall('ListScheduledJobs', payload);
    }

    public async GetScheduledJob(payload: z.infer<typeof GetScheduledJobSchema>): Promise<ScheduledJob> {
        return await this.actionCall('GetScheduledJob', payload);
    }

    public async ListExecutions(payload: z.infer<typeof ListExecutionsSchema>): Promise<Execution[]> {
        return await this.actionCall('ListExecutions', payload);
    }

    public async ListAvgExecutions(payload: z.infer<typeof ListAvgExecutionsSchema>): Promise<AvgExecution[]> {
        return await this.actionCall('ListAvgExecutions', payload);
    }

    public async UpdateJob(payload: z.infer<typeof UpdateJobSchema>): Promise<ScheduledJob> {
        return await this.actionCall('UpdateJob', payload);
    }

    public async GetDailyExecutionTrend(payload: z.infer<typeof GetDailyExecutionTrendSchema>): Promise<ExecutionTrend[]> {
        return await this.actionCall('GetDailyExecutionTrend', payload);
    }

    public async GetTopFailedJobs(payload: z.infer<typeof GetTopFailedJobsSchema>): Promise<FailedJob> {
        return await this.actionCall('GetTopFailedJobs', payload);
    }

    public async GetJobStats(payload: z.infer<typeof GetJobStatsSchema>): Promise<JobStats> {
        return await this.actionCall('GetJobStats', payload);
    }

    public async DeleteJob(payload: z.infer<typeof DeleteJobSchema>): Promise<void> {
        return await this.actionCall('DeleteJob', payload);
    }

    public async GetJobMetrics(): Promise<JobMetrics> {
        return await this.actionCall('GetJobMetrics', {});
    }

    public async QueueJob(payload: z.infer<typeof QueueJobSchema>): Promise<void> {
        return await this.actionCall('QueueJob', payload);
    }
    
    public async DeleteExecutions(payload: z.infer<typeof DeleteExecutionsSchema>): Promise<void> {
        return await this.actionCall('DeleteExecutions', payload);
    }
}