Types

interface BaseConfig {
  id: ID!
  version: String
  createdAt: DateTime
  updatedAt: DateTime
}

union ConfigType = Workflow

type ApiConfig implements BaseConfig {
  id: ID!
  version: String
  createdAt: DateTime
  updatedAt: DateTime
  
  urlHost: String                   # Base URL for the API (e.g., "https://api.stripe.com")
  urlPath: String                   # Path component of the URL (e.g., "/v1/customers")
  method: HttpMethod                # HTTP method to use (default: GET)
  headers: JSON                     # Request headers (default: {})
  queryParams: JSON                 # URL query parameters (default: {})
  body: String                      # Request body for POST/PUT/PATCH requests
  instruction: String               # Natural language description
  authentication: AuthType          # Authentication method (default: NONE)
  responseSchema: JSONSchema        # Expected response format (auto-generated if not provided)
  responseMapping: JSONata          # JSONata transformation (optional)
  pagination: Pagination            # Pagination configuration (default: DISABLED)
  dataPath: String                  # JSONPath to extract data from response (e.g., "$.data")
  documentationUrl: String          # API documentation URL
}

type Workflow implements BaseConfig {
  id: ID!
  version: String
  createdAt: DateTime
  updatedAt: DateTime
  
  steps: [ExecutionStep!]           # Workflow execution steps
  integrationIds: [ID]              # Integration IDs used in workflow
  instruction: String               # Natural language description
  finalTransform: JSONata           # Final data transformation
  responseSchema: JSONSchema        # Expected final output format
  inputSchema: JSONSchema           # Expected input format
}

type WorkflowSchedule {
  id: ID!
  workflowId: String!               # ID of the workflow to execute
  cronExpression: String!           # Cron expression (5-field: minute hour day month weekday)
  timezone: String!                 # IANA timezone (e.g., "America/New_York", "UTC", "Europe/London")
  enabled: Boolean!                 # Whether the schedule is active
  payload: JSON                     # Input data to pass to workflow execution
  options: JSON                     # Execution options (timeout, retries, etc.)
  lastRunAt: DateTime               # Timestamp of last execution
  nextRunAt: DateTime!              # Calculated next execution time (in UTC)
  createdAt: DateTime!
  updatedAt: DateTime!
}

input WorkflowScheduleInput {
  id: ID                            # Schedule ID (for updates only)
  workflowId: ID                    # Workflow ID (required for new schedules)
  cronExpression: String            # Cron expression (required for new schedules)
  timezone: String                  # IANA timezone (required for new schedules)
  enabled: Boolean                  # Enable or disable the schedule
  payload: JSON                     # Input data for workflow execution
  options: JSON                     # Execution options
}

type ExecutionStep {
  id: String!
  apiConfig: ApiConfig!             # API configuration for this step
  integrationId: ID                 # Integration to use for this step
  executionMode: String             # DIRECT | LOOP
  loopSelector: JSONata             # JSONata expression for loop iteration
  loopMaxIters: Int                 # Maximum loop iterations
  inputMapping: JSONata             # Input data transformation
  responseMapping: JSONata          # Response data transformation
}

type Integration {
  id: ID!
  name: String                      # Human-readable name
  type: String                      # Integration type
  urlHost: String                   # Base host URL
  urlPath: String                   # Default path
  credentials: JSON                 # Stored credentials (encrypted at rest)
  documentationUrl: String          # Link to API documentation
  documentation: String             # Documentation content
  documentationPending: Boolean     # Whether documentation is being processed
  icon: String                      # Icon URL
  version: String                   # Integration version
  createdAt: DateTime
  updatedAt: DateTime
}

type SuggestedIntegration {
  integration: Integration!         # Full integration object
  reason: String!                   # Why this integration is relevant
}

type ToolStep {
  integrationId: String             # Integration used in this step
  instruction: String               # Step-level instruction
}

type SuggestedTool {
  id: ID!                           # Tool identifier
  instruction: String               # What the tool does
  inputSchema: JSONSchema           # Input schema for the tool
  steps: [ToolStep!]!               # Steps and integrations used
  responseSchema: JSONSchema        # Output schema for the tool
  reason: String!                   # Why this tool matches the search
}

type TenantInfo {
  email: String                     # Tenant email
  emailEntrySkipped: Boolean!       # Whether email entry was skipped
}

type WorkflowResult {
  id: ID!
  success: Boolean!
  data: JSON
  error: String
  startedAt: DateTime!
  completedAt: DateTime!
  config: Workflow
  stepResults: [WorkflowStepResult!]
}

type WorkflowStepResult {
  stepId: String!
  success: Boolean!
  rawData: JSON
  transformedData: JSON
  error: String
}

type RunResult {
  id: ID!
  success: Boolean!
  data: JSON
  error: String
  startedAt: DateTime!
  completedAt: DateTime!
  config: ConfigType
}

type Log {
  id: ID!
  message: String!
  level: LogLevel!
  timestamp: DateTime!
  runId: ID
}

type Pagination {
  type: PaginationType!             # Pagination strategy (OFFSET_BASED, PAGE_BASED, CURSOR_BASED, DISABLED)
  pageSize: String                  # Number of items per page (default: "100")
  cursorPath: String                # JSONPath to cursor field for cursor-based pagination (e.g., "$.next_cursor")
  stopCondition: String             # Condition to stop pagination (optional)
}

type RunList {
  items: [RunResult!]!
  total: Int!
}

type WorkflowList {
  items: [Workflow!]!
  total: Int!
}

type IntegrationList {
  items: [Integration!]!
  total: Int!
}

subscription {
  logs {
    id
    message
    level
    timestamp
    runId
  }
}

type WorkflowResult {
  id: ID!
  success: Boolean!
  data: JSON
  error: String
  startedAt: DateTime!
  completedAt: DateTime!
  config: Workflow
  stepResults: [WorkflowStepResult!]
}

type WorkflowStepResult {
  stepId: String!
  success: Boolean!
  rawData: JSON
  transformedData: JSON
  error: String
}

type ExecutionStep {
  id: String!
  apiConfig: ApiConfig!
  integrationId: ID
  executionMode: String     # DIRECT | LOOP
  loopSelector: JSONata
  loopMaxIters: Int
  inputMapping: JSONata
  responseMapping: JSONata
}

type SuggestedIntegration {
  id: String!
  reason: String!
  savedCredentials: [String!]!
}