dify/web/contract/console/trigger.ts

import type {
  TriggerLogEntity,
  TriggerOAuthClientParams,
  TriggerOAuthConfig,
  TriggerProviderApiEntity,
  TriggerSubscription,
  TriggerSubscriptionBuilder,
} from '@/app/components/workflow/block-selector/types'
import { type } from '@orpc/contract'
import { base } from '../base'

export const triggersContract = base
  .route({ path: '/workspaces/current/triggers', method: 'GET' })
  .input(type<{ query?: { type?: string } }>())
  .output(type<TriggerProviderApiEntity[]>())

export const triggerProviderInfoContract = base
  .route({ path: '/workspaces/current/trigger-provider/{provider}/info', method: 'GET' })
  .input(type<{ params: { provider: string } }>())
  .output(type<TriggerProviderApiEntity>())

export const triggerSubscriptionsContract = base
  .route({ path: '/workspaces/current/trigger-provider/{provider}/subscriptions/list', method: 'GET' })
  .input(type<{ params: { provider: string } }>())
  .output(type<TriggerSubscription[]>())

export const triggerSubscriptionBuilderCreateContract = base
  .route({ path: '/workspaces/current/trigger-provider/{provider}/subscriptions/builder/create', method: 'POST' })
  .input(type<{
    params: { provider: string }
    body?: { credential_type?: string }
  }>())
  .output(type<{ subscription_builder: TriggerSubscriptionBuilder }>())

export const triggerSubscriptionBuilderUpdateContract = base
  .route({ path: '/workspaces/current/trigger-provider/{provider}/subscriptions/builder/update/{subscriptionBuilderId}', method: 'POST' })
  .input(type<{
    params: { provider: string, subscriptionBuilderId: string }
    body?: {
      name?: string
      properties?: Record<string, unknown>
      parameters?: Record<string, unknown>
      credentials?: Record<string, unknown>
    }
  }>())
  .output(type<TriggerSubscriptionBuilder>())

export const triggerSubscriptionBuilderVerifyUpdateContract = base
  .route({ path: '/workspaces/current/trigger-provider/{provider}/subscriptions/builder/verify-and-update/{subscriptionBuilderId}', method: 'POST' })
  .input(type<{
    params: { provider: string, subscriptionBuilderId: string }
    body?: { credentials?: Record<string, unknown> }
  }>())
  .output(type<{ verified: boolean }>())

export const triggerSubscriptionVerifyContract = base
  .route({ path: '/workspaces/current/trigger-provider/{provider}/subscriptions/verify/{subscriptionId}', method: 'POST' })
  .input(type<{
    params: { provider: string, subscriptionId: string }
    body?: { credentials?: Record<string, unknown> }
  }>())
  .output(type<{ verified: boolean }>())

export const triggerSubscriptionBuildContract = base
  .route({ path: '/workspaces/current/trigger-provider/{provider}/subscriptions/builder/build/{subscriptionBuilderId}', method: 'POST' })
  .input(type<{
    params: { provider: string, subscriptionBuilderId: string }
    body?: {
      name?: string
      parameters?: Record<string, unknown>
    }
  }>())
  .output(type<unknown>())

export const triggerSubscriptionDeleteContract = base
  .route({ path: '/workspaces/current/trigger-provider/{subscriptionId}/subscriptions/delete', method: 'POST' })
  .input(type<{ params: { subscriptionId: string } }>())
  .output(type<{ result: string }>())

export const triggerSubscriptionUpdateContract = base
  .route({ path: '/workspaces/current/trigger-provider/{subscriptionId}/subscriptions/update', method: 'POST' })
  .input(type<{
    params: { subscriptionId: string }
    body?: {
      name?: string
      properties?: Record<string, unknown>
      parameters?: Record<string, unknown>
      credentials?: Record<string, unknown>
    }
  }>())
  .output(type<{ result: string, id: string }>())

export const triggerSubscriptionBuilderLogsContract = base
  .route({ path: '/workspaces/current/trigger-provider/{provider}/subscriptions/builder/logs/{subscriptionBuilderId}', method: 'GET' })
  .input(type<{ params: { provider: string, subscriptionBuilderId: string } }>())
  .output(type<{ logs: TriggerLogEntity[] }>())

export const triggerOAuthConfigContract = base
  .route({ path: '/workspaces/current/trigger-provider/{provider}/oauth/client', method: 'GET' })
  .input(type<{ params: { provider: string } }>())
  .output(type<TriggerOAuthConfig>())

export const triggerOAuthConfigureContract = base
  .route({ path: '/workspaces/current/trigger-provider/{provider}/oauth/client', method: 'POST' })
  .input(type<{
    params: { provider: string }
    body: { client_params?: TriggerOAuthClientParams, enabled: boolean }
  }>())
  .output(type<{ result: string }>())

export const triggerOAuthDeleteContract = base
  .route({ path: '/workspaces/current/trigger-provider/{provider}/oauth/client', method: 'DELETE' })
  .input(type<{ params: { provider: string } }>())
  .output(type<{ result: string }>())

export const triggerOAuthInitiateContract = base
  .route({ path: '/workspaces/current/trigger-provider/{provider}/subscriptions/oauth/authorize', method: 'GET' })
  .input(type<{ params: { provider: string } }>())
  .output(type<{ authorization_url: string, subscription_builder: TriggerSubscriptionBuilder }>())