* add trigger * small fixes * add missing workflow DTOs * small fixes * use activeOnWithChildren * fix active on when switching trigger type * remove add variable dropdown * feat: lang support * fix: type errors * feat: select voice agent * refactor: address feedback * refactor: address feedback * refactor: missing import * fix: types * add getAllWorkflowsFromRoutingForm to WorkflowService * fix error caused by undefined evt * fix type error * fix type error * fix tests * feat: add inbound calls * chore: formatting * chore * feat: finish inbound call * chore: formatting * fix: update bug * fix: types * code clean up * final fixes and clean up * remove console.log * remove template text form from triggers * add routing form repoditory function * refactor: Agent Configuration Sheet (#23930) * refactor: agent configuration sheet * chore: use default phone numbre * refactor: improvements * refactor: improvements * fix: types * fix: feedback * fix bug with key * chore: * fix: feedback * fix: prompt * add comments * fix: review * fix: review * refactor: class * refactor: class * fix test * allow cal ai action on form triggers * move any reusable code to scheduleAIPhoneCall * add missing await * use predefined FormSubmissionData type * add .trim() to sms message * pass contextData instead * finish base setup * add missing trigger in update-workflow.input.ts * allow cal.ai action for form triggers in handler * chore: add support for form workflows on api v2 * fixup! chore: add support for form workflows on api v2 * ai phone call on form submissions (WIP) * use existing type for Option array * pass chosen event type id * refactor: rename * Update apps/web/public/static/locales/en/common.json * Update apps/web/public/static/locales/en/common.json * add missing imports * chore: update set value * fix: remove index * fix: type error * fix: update tetss * use only repository functions in update handler * move all prisma queries from list.handler * review suggestions * fix: use logger * chore: handle workflows api v2 * chore: handle workflows api v2, split in 2 endpoints * fix workflow step creation * remove connect agent and fixes types * add type to workflow * chore: use workflow type in apiv2 WorkflowsOutputService * update worklfow type on update * chore: use workflow type in apiv2 WorkflowsOutputService * fix template body for torm trigger * some UI fixes for email subject/body * resetting email body when changing form triggers * use type field to query workflows * clean up all old active on values * remove responseId from all funciton calls * remove undefined from updateTemplate * refactor: don't use static * fix: type * refactor: split routing form and event-type workflows code * refactor: split routing form and event-type workflows code * fix template text when adding action * chore: don't rename WorkflowActivationDto to avoid ci blocking * refine update schedule to use only allowed actions * fix type error * don't allow whatsapp action with form trigger * fix type error * return early if activeOn array is empty * fix: from step type in BaseFormWorkflowStepDto * fixup! fix: from step type in BaseFormWorkflowStepDto * api v2 updates * move all prisma calls to repository (service/workflows.ts) * use FORM_TRIGGER_WORKFLOW_EVENTS for form queries * use userRepository * use FORM_TRIGGER_WORKFLOW_EVENTS in isFormTrigger * code clean up * code clean up * use repository functions in formSubmissionValidation.ts * fix: schema * refactor: * remove action check in update handler * add event type selection * event type selector improvements * adjust update.handler * set outboundEventTypeId * add back trpc import * fix agent repository functions * clean up * fix bugs caused by merge * pass eventTypeId to updateToolsFromAgentId * add migration for outboundEventTypeId * add SMS actions to allowed form action constants * add cal ai to allowed form actions * pick correct event type for web call * pass correct routed event type id * remove unsued import * fixes for offset api v2 * add missing responseId * fix failing test * fix failing test * improve error message * remove unused imports * chore: handle sms step action for form worklfow in dtos * fix typo * missing missing newStep * minor fixes * remove changes * add routedEventTypeId * fix type error * fix type error * fix typ error in executAPIPhoneCall.tsx * add back inboundEventTypeId * remove console.log * remove outdated code * small fixes * don't throw error for missing phone number * add back filtered triggerOptions * fix eventTypeId in testCall handler * fix type error * update migration * fix trigger is not defined * convert eventTypeId to string * only use outboundEventTypeId for FORM_SUBMITTED trigger * show toast when no event type selected * fix type errors * add missing translation * fix type error * remove callType * fix tests * small fixes * clean up AgentConfigurationSheet * remove EventTypeSelector file * code clean up * clean up * clean up * use resusable function for TestPhoneCallDialog and WebCallDialog * rename result * fix types for event type id * use repository runction in workflowReminder.ts * fix type error * pass eventTypeIds correctly * fix typo * Update apps/web/public/static/locales/en/common.json Co-authored-by: Udit Takkar <53316345+Udit-takkar@users.noreply.github.com> * use watch instead of getValues * change to z.record(z.unknown()) instead of any() * fix type of eventTypeId * check permissinon for outBoundEventTypeId * add isNaN check * improve function name * update tools when outbound agent event type id changes * pass missing outboundEventTypeId * update migration * fix test * remove cal-ai step from test --------- Co-authored-by: CarinaWolli <wollencarina@gmail.com> Co-authored-by: Udit Takkar <udit222001@gmail.com> Co-authored-by: Udit Takkar <53316345+Udit-takkar@users.noreply.github.com> Co-authored-by: Benny Joo <sldisek783@gmail.com> Co-authored-by: cal.com <morgan@cal.com> Co-authored-by: Morgan <33722304+ThyMinimalDev@users.noreply.github.com> Co-authored-by: Peer Richelsen <peeroke@gmail.com>
424 lines
11 KiB
TypeScript
424 lines
11 KiB
TypeScript
import type { Logger } from "tslog";
|
|
|
|
import type { RetellAIPhoneServiceProviderTypeMap } from "../providers/retellAI";
|
|
|
|
/**
|
|
* Enum for supported AI phone service providers
|
|
*/
|
|
export enum AIPhoneServiceProviderType {
|
|
RETELL_AI = "retellAI",
|
|
// Add other providers here as needed
|
|
}
|
|
|
|
/**
|
|
* Generic type map for provider-specific types
|
|
* This allows the interface layer to remain provider-agnostic while supporting type safety
|
|
*
|
|
* Usage examples:
|
|
* - Retell AI provider: AIPhoneServiceProvider<AIPhoneServiceProviderType.RETELL_AI>
|
|
* - Generic usage: AIPhoneServiceProvider (defaults to union of all providers)
|
|
*
|
|
* Providers implement this by exporting a consolidated type map from their module:
|
|
* ```typescript
|
|
* // In providers/retellAI/index.ts
|
|
* export interface RetellAIPhoneServiceProviderTypeMap {
|
|
* Configuration: RetellAIConfigurationSetup;
|
|
* Agent: RetellAgent;
|
|
* AgentWithDetails: RetellAgentWithDetails;
|
|
* // ... other types
|
|
* }
|
|
*
|
|
* // In interfaces/AIPhoneService.interface.ts
|
|
* import type { RetellAIPhoneServiceProviderTypeMap } from "../providers/retellAI";
|
|
*
|
|
* export interface AIPhoneServiceProviderTypeMap {
|
|
* [AIPhoneServiceProviderType.RETELL_AI]: RetellAIPhoneServiceProviderTypeMap;
|
|
* }
|
|
* ```
|
|
*/
|
|
export interface AIPhoneServiceProviderTypeMap {
|
|
[AIPhoneServiceProviderType.RETELL_AI]: RetellAIPhoneServiceProviderTypeMap;
|
|
}
|
|
|
|
/**
|
|
* Generic types that resolve to provider-specific types based on the provider type parameter
|
|
*/
|
|
export type AIPhoneServiceConfiguration<T extends AIPhoneServiceProviderType = AIPhoneServiceProviderType> =
|
|
AIPhoneServiceProviderTypeMap[T]["Configuration"];
|
|
|
|
export type AIPhoneServiceUpdateModelParams<
|
|
T extends AIPhoneServiceProviderType = AIPhoneServiceProviderType
|
|
> = AIPhoneServiceProviderTypeMap[T]["UpdateModelParams"];
|
|
|
|
export type AIPhoneServiceModel<T extends AIPhoneServiceProviderType = AIPhoneServiceProviderType> =
|
|
AIPhoneServiceProviderTypeMap[T]["Model"];
|
|
|
|
export type AIPhoneServiceAgent<T extends AIPhoneServiceProviderType = AIPhoneServiceProviderType> =
|
|
AIPhoneServiceProviderTypeMap[T]["Agent"];
|
|
|
|
export type AIPhoneServiceCall<T extends AIPhoneServiceProviderType = AIPhoneServiceProviderType> =
|
|
AIPhoneServiceProviderTypeMap[T]["Call"];
|
|
|
|
export type AIPhoneServicePhoneNumber<T extends AIPhoneServiceProviderType = AIPhoneServiceProviderType> =
|
|
AIPhoneServiceProviderTypeMap[T]["PhoneNumber"];
|
|
|
|
export type AIPhoneServiceUpdatePhoneNumberParams<
|
|
T extends AIPhoneServiceProviderType = AIPhoneServiceProviderType
|
|
> = AIPhoneServiceProviderTypeMap[T]["UpdatePhoneNumberParams"];
|
|
|
|
export type AIPhoneServiceCreatePhoneNumberParams<
|
|
T extends AIPhoneServiceProviderType = AIPhoneServiceProviderType
|
|
> = AIPhoneServiceProviderTypeMap[T]["CreatePhoneNumberParams"];
|
|
|
|
export type AIPhoneServiceImportPhoneNumberParams<
|
|
T extends AIPhoneServiceProviderType = AIPhoneServiceProviderType
|
|
> = AIPhoneServiceProviderTypeMap[T]["ImportPhoneNumberParams"];
|
|
|
|
export type AIPhoneServiceUpdateAgentParams<
|
|
T extends AIPhoneServiceProviderType = AIPhoneServiceProviderType
|
|
> = AIPhoneServiceProviderTypeMap[T]["UpdateAgentParams"];
|
|
|
|
export type AIPhoneServiceTools<T extends AIPhoneServiceProviderType = AIPhoneServiceProviderType> =
|
|
AIPhoneServiceProviderTypeMap[T]["Tools"];
|
|
|
|
export type AIPhoneServiceCreatePhoneCallParams<
|
|
T extends AIPhoneServiceProviderType = AIPhoneServiceProviderType
|
|
> = AIPhoneServiceProviderTypeMap[T]["CreatePhoneCallParams"];
|
|
|
|
export type AIPhoneServiceAgentWithDetails<
|
|
T extends AIPhoneServiceProviderType = AIPhoneServiceProviderType
|
|
> = AIPhoneServiceProviderTypeMap[T]["AgentWithDetails"];
|
|
|
|
export type AIPhoneServiceListCallsParams<T extends AIPhoneServiceProviderType = AIPhoneServiceProviderType> =
|
|
AIPhoneServiceProviderTypeMap[T]["ListCallsParams"];
|
|
|
|
export type AIPhoneServiceListCallsResponse<
|
|
T extends AIPhoneServiceProviderType = AIPhoneServiceProviderType
|
|
> = AIPhoneServiceProviderTypeMap[T]["ListCallsResponse"];
|
|
|
|
export type AIPhoneServiceVoice<T extends AIPhoneServiceProviderType = AIPhoneServiceProviderType> =
|
|
AIPhoneServiceProviderTypeMap[T]["Voice"];
|
|
|
|
export interface AIPhoneServiceDeletion {
|
|
modelId?: string;
|
|
agentId?: string;
|
|
}
|
|
|
|
export interface AIPhoneServiceDeletionResult {
|
|
success: boolean;
|
|
errors: string[];
|
|
deleted: {
|
|
model: boolean;
|
|
agent: boolean;
|
|
};
|
|
}
|
|
|
|
export type AIPhoneServiceCallData<T extends AIPhoneServiceProviderType = AIPhoneServiceProviderType> =
|
|
AIPhoneServiceCreatePhoneCallParams<T>;
|
|
|
|
// Extended import phone number params with additional fields
|
|
export type AIPhoneServiceImportPhoneNumberParamsExtended<
|
|
T extends AIPhoneServiceProviderType = AIPhoneServiceProviderType
|
|
> = AIPhoneServiceImportPhoneNumberParams<T> & {
|
|
userId: number;
|
|
teamId?: number;
|
|
agentId?: string | null;
|
|
};
|
|
|
|
export interface AIPhoneServiceAgentListItem {
|
|
id: string;
|
|
name: string;
|
|
providerAgentId: string;
|
|
enabled: boolean;
|
|
userId: number | null;
|
|
teamId: number | null;
|
|
createdAt: Date;
|
|
updatedAt: Date;
|
|
outboundPhoneNumbers: {
|
|
id: number;
|
|
phoneNumber: string;
|
|
subscriptionStatus: string | null;
|
|
provider: string | null;
|
|
}[];
|
|
team: {
|
|
id: number;
|
|
name: string | null | undefined;
|
|
slug: string | null | undefined;
|
|
} | null;
|
|
user: {
|
|
id: number;
|
|
name: string | null | undefined;
|
|
email: string | null;
|
|
} | null;
|
|
}
|
|
|
|
/**
|
|
* Generic interface for AI phone service providers
|
|
* This interface abstracts away provider-specific details using generics
|
|
*/
|
|
export interface AIPhoneServiceProvider<T extends AIPhoneServiceProviderType = AIPhoneServiceProviderType> {
|
|
/**
|
|
* Setup AI configuration
|
|
*/
|
|
setupConfiguration(config: AIPhoneServiceConfiguration<T>): Promise<{
|
|
modelId: string;
|
|
agentId: string;
|
|
}>;
|
|
|
|
/**
|
|
* Delete AI configuration
|
|
*/
|
|
deleteConfiguration(config: AIPhoneServiceDeletion): Promise<AIPhoneServiceDeletionResult>;
|
|
|
|
/**
|
|
* Update model configuration
|
|
*/
|
|
updateModelConfiguration(
|
|
modelId: string,
|
|
data: AIPhoneServiceUpdateModelParams<T>
|
|
): Promise<AIPhoneServiceModel<T>>;
|
|
|
|
/**
|
|
* Get model details
|
|
*/
|
|
getModelDetails(modelId: string): Promise<AIPhoneServiceModel<T>>;
|
|
|
|
/**
|
|
* Get agent details
|
|
*/
|
|
getAgent(agentId: string): Promise<AIPhoneServiceAgent<T>>;
|
|
|
|
/**
|
|
* Update agent configuration
|
|
*/
|
|
updateAgent(agentId: string, data: AIPhoneServiceUpdateAgentParams<T>): Promise<AIPhoneServiceAgent<T>>;
|
|
|
|
/**
|
|
* Create a phone call
|
|
*/
|
|
createPhoneCall(data: AIPhoneServiceCallData<T>): Promise<AIPhoneServiceCall<T>>;
|
|
|
|
/**
|
|
* Create a phone number
|
|
*/
|
|
createPhoneNumber(
|
|
data: AIPhoneServiceCreatePhoneNumberParams<T>
|
|
): Promise<AIPhoneServicePhoneNumber<T> & { provider: string }>;
|
|
|
|
/**
|
|
* Delete a phone number
|
|
*/
|
|
deletePhoneNumber(params: {
|
|
phoneNumber: string;
|
|
userId: number;
|
|
teamId?: number;
|
|
deleteFromDB: boolean;
|
|
}): Promise<void>;
|
|
|
|
/**
|
|
* Get phone number details
|
|
*/
|
|
getPhoneNumber(phoneNumber: string): Promise<AIPhoneServicePhoneNumber<T>>;
|
|
|
|
/**
|
|
* Update phone number configuration
|
|
*/
|
|
updatePhoneNumber(
|
|
phoneNumber: string,
|
|
data: AIPhoneServiceUpdatePhoneNumberParams<T>
|
|
): Promise<AIPhoneServicePhoneNumber<T>>;
|
|
|
|
/**
|
|
* Import a phone number
|
|
*/
|
|
importPhoneNumber(
|
|
data: AIPhoneServiceImportPhoneNumberParamsExtended<T>
|
|
): Promise<AIPhoneServicePhoneNumber<T>>;
|
|
|
|
/**
|
|
* Generate a checkout session for phone number subscription
|
|
*/
|
|
generatePhoneNumberCheckoutSession(params: {
|
|
userId: number;
|
|
teamId?: number;
|
|
agentId?: string | null;
|
|
workflowId?: string;
|
|
}): Promise<{ url: string; message: string }>;
|
|
|
|
/**
|
|
* Cancel a phone number subscription
|
|
*/
|
|
cancelPhoneNumberSubscription(params: {
|
|
phoneNumberId: number;
|
|
userId: number;
|
|
teamId?: number;
|
|
}): Promise<{ success: boolean; message: string }>;
|
|
|
|
/**
|
|
* Update phone number with agent assignments
|
|
*/
|
|
updatePhoneNumberWithAgents(params: {
|
|
phoneNumber: string;
|
|
userId: number;
|
|
teamId?: number;
|
|
inboundAgentId?: string | null;
|
|
outboundAgentId?: string | null;
|
|
}): Promise<{ message: string }>;
|
|
|
|
/**
|
|
* List agents with user access
|
|
*/
|
|
listAgents(params: { userId: number; teamId?: number; scope?: "personal" | "team" | "all" }): Promise<{
|
|
totalCount: number;
|
|
filtered: AIPhoneServiceAgentListItem[];
|
|
}>;
|
|
|
|
/**
|
|
* Get agent with detailed information
|
|
*/
|
|
getAgentWithDetails(params: {
|
|
id: string;
|
|
userId: number;
|
|
teamId?: number;
|
|
}): Promise<AIPhoneServiceAgentWithDetails<T>>;
|
|
|
|
/**
|
|
* Create a new agent
|
|
*/
|
|
createOutboundAgent(params: {
|
|
name?: string;
|
|
userId: number;
|
|
teamId?: number;
|
|
workflowStepId?: number;
|
|
generalPrompt?: string;
|
|
beginMessage?: string;
|
|
generalTools?: AIPhoneServiceTools<T>;
|
|
voiceId?: string;
|
|
userTimeZone: string;
|
|
}): Promise<{
|
|
id: string;
|
|
providerAgentId: string;
|
|
message: string;
|
|
}>;
|
|
|
|
/**
|
|
* Create a new inbound agent
|
|
*/
|
|
createInboundAgent(params: {
|
|
name?: string;
|
|
phoneNumber: string;
|
|
userId: number;
|
|
teamId?: number;
|
|
workflowStepId: number;
|
|
userTimeZone: string;
|
|
}): Promise<{
|
|
id: string;
|
|
providerAgentId: string;
|
|
message: string;
|
|
}>;
|
|
|
|
/**
|
|
* Update agent configuration
|
|
*/
|
|
updateAgentConfiguration(params: {
|
|
id: string;
|
|
userId: number;
|
|
teamId?: number;
|
|
name?: string;
|
|
enabled?: boolean;
|
|
generalPrompt?: string | null;
|
|
beginMessage?: string | null;
|
|
generalTools?: AIPhoneServiceTools<T>;
|
|
voiceId?: string;
|
|
language?: string;
|
|
outboundEventTypeId?: number;
|
|
timeZone?: string;
|
|
}): Promise<{ message: string }>;
|
|
|
|
/**
|
|
* Delete an agent
|
|
*/
|
|
deleteAgent(params: { id: string; userId: number; teamId?: number }): Promise<{ message: string }>;
|
|
|
|
/**
|
|
* Create a test call
|
|
*/
|
|
createTestCall(params: {
|
|
agentId: string;
|
|
phoneNumber?: string;
|
|
userId: number;
|
|
teamId?: number;
|
|
timeZone: string;
|
|
eventTypeId: number;
|
|
}): Promise<{
|
|
callId: string;
|
|
status: string;
|
|
message: string;
|
|
}>;
|
|
|
|
/**
|
|
* Create a web call
|
|
*/
|
|
createWebCall(params: {
|
|
agentId: string;
|
|
userId: number;
|
|
teamId?: number;
|
|
timeZone: string;
|
|
eventTypeId: number;
|
|
}): Promise<{
|
|
callId: string;
|
|
accessToken: string;
|
|
agentId: string;
|
|
}>;
|
|
|
|
/**
|
|
* Update tools from event type ID
|
|
*/
|
|
updateToolsFromAgentId(
|
|
agentId: string,
|
|
data: { eventTypeId: number | null; timeZone: string; userId: number | null; teamId?: number | null }
|
|
): Promise<void>;
|
|
|
|
/**
|
|
* Remove tools for event types
|
|
*/
|
|
removeToolsForEventTypes(agentId: string, eventTypeIds: number[]): Promise<void>;
|
|
|
|
/**
|
|
* List calls with optional filters
|
|
*/
|
|
listCalls(params: {
|
|
limit?: number;
|
|
offset?: number;
|
|
filters: {
|
|
fromNumber: string[];
|
|
toNumber?: string[];
|
|
startTimestamp?: { lower_threshold?: number; upper_threshold?: number };
|
|
};
|
|
}): Promise<AIPhoneServiceListCallsResponse<T>>;
|
|
|
|
/**
|
|
* List available voices
|
|
*/
|
|
listVoices(): Promise<AIPhoneServiceVoice<T>[]>;
|
|
}
|
|
|
|
/**
|
|
* Configuration for AI phone service providers
|
|
*/
|
|
export interface AIPhoneServiceProviderConfig {
|
|
apiKey?: string;
|
|
baseUrl?: string;
|
|
enableLogging?: boolean;
|
|
logger?: Logger<unknown>;
|
|
}
|
|
|
|
/**
|
|
* Factory interface for creating AI phone service providers
|
|
*/
|
|
export interface AIPhoneServiceProviderFactory<
|
|
T extends AIPhoneServiceProviderType = AIPhoneServiceProviderType
|
|
> {
|
|
create(config: AIPhoneServiceProviderConfig): AIPhoneServiceProvider<T>;
|
|
}
|