sean-brydonGitHubClaude Opus 4.5Devin AI <158243242+devin-ai-integration[bot]@users.noreply.github.com>* feat: add proration invoice and reminder email templates Add email templates for monthly proration billing notifications: - ProrationInvoiceEmail: Sent when invoice is created for additional seats - ProrationReminderEmail: Sent 7 days later if invoice remains unpaid Includes: - React email templates using V2BaseEmailHtml - BaseEmail classes for rendering - Billing email service functions - Translation keys for email content Co-Authored-By: Claude Opus 4.5 <noreply@anthropic.com> * feat: add tasker integration for proration email notifications Add task handlers for proration billing email flow: - sendProrationInvoiceEmail: Sends invoice email and schedules reminder - sendProrationReminderEmail: Sends reminder if invoice still unpaid - cancelProrationReminder: Cancels scheduled reminder on payment success The calling job should trigger these tasks after: 1. MonthlyProrationService.createProrationForTeam() succeeds with invoice 2. handleProrationPaymentSuccess() is called (to cancel reminder) Co-Authored-By: Claude Opus 4.5 <noreply@anthropic.com> * feat: i18n + feedback from cubic + morgan * fix: use default tasker import instead of non-existent getTasker Co-Authored-By: unknown <> * fix: add trigger tasks plus DI * use for await * fix query * fix: remove duplicate JOIN alias in findTeamMembersWithPermission query The raw SQL query had two INNER JOINs using the same alias 'u': - INNER JOIN "users" u ON m."userId" = u.id - INNER JOIN "User" u ON m."userId" = u.id This would cause a SQL error at runtime. Removed the duplicate JOIN with incorrect table name ("User" instead of "users"). Fixes issue identified by Cubic AI review. Co-Authored-By: unknown <> --------- Co-authored-by: Claude Opus 4.5 <noreply@anthropic.com> Co-authored-by: Devin AI <158243242+devin-ai-integration[bot]@users.noreply.github.com>
72 lines
3.2 KiB
TypeScript
72 lines
3.2 KiB
TypeScript
import type { FORM_SUBMITTED_WEBHOOK_RESPONSES } from "@calcom/app-store/routing-forms/lib/formSubmissionUtils";
|
|
import type { BookingAuditTaskConsumerPayload } from "@calcom/features/booking-audit/lib/types/bookingAuditTask";
|
|
import type { z } from "zod";
|
|
|
|
export type TaskerTypes = "internal" | "redis";
|
|
type TaskPayloads = {
|
|
sendWebhook: string;
|
|
sendSms: string;
|
|
triggerHostNoShowWebhook: z.infer<
|
|
typeof import("./tasks/triggerNoShow/schema").ZSendNoShowWebhookPayloadSchema
|
|
>;
|
|
triggerGuestNoShowWebhook: z.infer<
|
|
typeof import("./tasks/triggerNoShow/schema").ZSendNoShowWebhookPayloadSchema
|
|
>;
|
|
triggerFormSubmittedNoEventWebhook: z.infer<
|
|
typeof import("./tasks/triggerFormSubmittedNoEvent/triggerFormSubmittedNoEventWebhook").ZTriggerFormSubmittedNoEventWebhookPayloadSchema
|
|
>;
|
|
triggerFormSubmittedNoEventWorkflow: z.infer<
|
|
typeof import("./tasks/triggerFormSubmittedNoEvent/triggerFormSubmittedNoEventWorkflow").ZTriggerFormSubmittedNoEventWorkflowPayloadSchema
|
|
>;
|
|
translateEventTypeData: z.infer<
|
|
typeof import("./tasks/translateEventTypeData").ZTranslateEventDataPayloadSchema
|
|
>;
|
|
createCRMEvent: z.infer<typeof import("./tasks/crm/schema").createCRMEventSchema>;
|
|
sendWorkflowEmails: z.infer<typeof import("./tasks/sendWorkflowEmails").ZSendWorkflowEmailsSchema>;
|
|
scanWorkflowBody: z.infer<typeof import("./tasks/scanWorkflowBody").scanWorkflowBodySchema>;
|
|
scanWorkflowUrls: z.infer<typeof import("./tasks/scanWorkflowUrls").scanWorkflowUrlsSchema>;
|
|
sendAnalyticsEvent: z.infer<typeof import("./tasks/analytics/schema").sendAnalyticsEventSchema>;
|
|
executeAIPhoneCall: {
|
|
workflowReminderId: number;
|
|
agentId: string;
|
|
fromNumber: string;
|
|
toNumber: string;
|
|
bookingUid: string | null;
|
|
userId: number | null;
|
|
teamId: number | null;
|
|
providerAgentId: string;
|
|
responses?: FORM_SUBMITTED_WEBHOOK_RESPONSES | null;
|
|
routedEventTypeId?: number | null;
|
|
};
|
|
bookingAudit: BookingAuditTaskConsumerPayload;
|
|
sendAwaitingPaymentEmail: z.infer<
|
|
typeof import("./tasks/sendAwaitingPaymentEmail").sendAwaitingPaymentEmailPayloadSchema
|
|
>;
|
|
sendProrationInvoiceEmail: z.infer<
|
|
typeof import("./tasks/sendProrationInvoiceEmail").sendProrationInvoiceEmailPayloadSchema
|
|
>;
|
|
sendProrationReminderEmail: z.infer<
|
|
typeof import("./tasks/sendProrationReminderEmail").sendProrationReminderEmailPayloadSchema
|
|
>;
|
|
cancelProrationReminder: z.infer<
|
|
typeof import("./tasks/cancelProrationReminder").cancelProrationReminderPayloadSchema
|
|
>;
|
|
webhookDelivery: z.infer<
|
|
typeof import("@calcom/features/webhooks/lib/types/webhookTask").webhookTaskPayloadSchema
|
|
>;
|
|
};
|
|
export type TaskTypes = keyof TaskPayloads;
|
|
export type TaskHandler = (payload: string, taskId?: string) => Promise<void>;
|
|
export type TaskerCreate = <TaskKey extends keyof TaskPayloads>(
|
|
type: TaskKey,
|
|
payload: TaskPayloads[TaskKey],
|
|
options?: { scheduledAt?: Date; maxAttempts?: number; referenceUid?: string }
|
|
) => Promise<string>;
|
|
export interface Tasker {
|
|
/** Create a new task with the given type and payload. */
|
|
create: TaskerCreate;
|
|
cleanup(): Promise<void>;
|
|
cancel(id: string): Promise<string>;
|
|
cancelWithReference(referenceUid: string, type: TaskTypes): Promise<string | null>;
|
|
}
|