diff --git a/cli/bootstrap/script_bootstrap.ts b/cli/bootstrap/script_bootstrap.ts index bd609ae9ed..79ca7d92b7 100644 --- a/cli/bootstrap/script_bootstrap.ts +++ b/cli/bootstrap/script_bootstrap.ts @@ -77,6 +77,7 @@ func main() (interface{}, error) { bash: `echo "Hello world" `, + oracledb: `SELECT 'Hello world' AS message`, powershell: `Write-Output "Hello world"`, php: ` => { return __request(OpenAPI, { @@ -667,12 +667,17 @@ export const getCurrentEmail = (): CancelablePromise => /** * refresh the current token - * @returns string free usage + * @param data The data for the request. + * @param data.ifExpiringInLessThanS + * @returns string new token * @throws ApiError */ -export const refreshUserToken = (): CancelablePromise => { return __request(OpenAPI, { +export const refreshUserToken = (data: RefreshUserTokenData = {}): CancelablePromise => { return __request(OpenAPI, { method: 'GET', - url: '/users/refresh_token' + url: '/users/refresh_token', + query: { + if_expiring_in_less_than_s: data.ifExpiringInLessThanS + } }); }; /** @@ -957,6 +962,24 @@ export const changeWorkspaceId = (data: ChangeWorkspaceIdData): CancelablePromis mediaType: 'application/json' }); }; +/** + * change workspace id + * @param data The data for the request. + * @param data.workspace + * @param data.requestBody + * @returns string status + * @throws ApiError + */ +export const changeWorkspaceColor = (data: ChangeWorkspaceColorData): CancelablePromise => { return __request(OpenAPI, { + method: 'POST', + url: '/w/{workspace}/workspaces/change_workspace_color', + path: { + workspace: data.workspace + }, + body: data.requestBody, + mediaType: 'application/json' +}); }; + /** * whois * @param data The data for the request. @@ -1101,6 +1124,39 @@ export const setAutomaticBilling = (data: SetAutomaticBillingData): CancelablePr mediaType: 'application/json' }); }; +/** + * get threshold alert info + * @param data The data for the request. + * @param data.workspace + * @returns unknown status + * @throws ApiError + */ +export const getThresholdAlert = (data: GetThresholdAlertData): CancelablePromise => { return __request(OpenAPI, { + method: 'GET', + url: '/w/{workspace}/workspaces/threshold_alert', + path: { + workspace: data.workspace + } +}); }; + +/** + * set threshold alert info + * @param data The data for the request. + * @param data.workspace + * @param data.requestBody threshold alert info + * @returns string status + * @throws ApiError + */ +export const setThresholdAlert = (data: SetThresholdAlertData): CancelablePromise => { return __request(OpenAPI, { + method: 'POST', + url: '/w/{workspace}/workspaces/threshold_alert', + path: { + workspace: data.workspace + }, + body: data.requestBody, + mediaType: 'application/json' +}); }; + /** * edit slack command * @param data The data for the request. @@ -1785,7 +1841,7 @@ export const listContextualVariables = (data: ListContextualVariablesData): Canc * @param data.page * @param data.pageSize * @param data.acknowledged - * @returns CriticalAlert Successfully retrieved all critical alerts + * @returns unknown Successfully retrieved all critical alerts * @throws ApiError */ export const workspaceGetCriticalAlerts = (data: WorkspaceGetCriticalAlertsData): CancelablePromise => { return __request(OpenAPI, { @@ -2455,6 +2511,21 @@ export const getHubAppById = (data: GetHubAppByIdData): CancelablePromise => { return __request(OpenAPI, { + method: 'GET', + url: '/apps_u/public_app_by_custom_path/{custom_path}', + path: { + custom_path: data.customPath + } +}); }; + /** * get hub script content by path * @param data The data for the request. @@ -2708,12 +2779,19 @@ export const toggleWorkspaceErrorHandlerForScript = (data: ToggleWorkspaceErrorH /** * get all instance custom tags (tags are used to dispatch jobs to different worker groups) + * @param data The data for the request. + * @param data.workspace + * @param data.showWorkspaceRestriction * @returns string list of custom tags * @throws ApiError */ -export const getCustomTags = (): CancelablePromise => { return __request(OpenAPI, { +export const getCustomTags = (data: GetCustomTagsData = {}): CancelablePromise => { return __request(OpenAPI, { method: 'GET', - url: '/workers/custom_tags' + url: '/workers/custom_tags', + query: { + workspace: data.workspace, + show_workspace_restriction: data.showWorkspaceRestriction + } }); }; /** @@ -3784,6 +3862,23 @@ export const getAppByPath = (data: GetAppByPathData): CancelablePromise => { return __request(OpenAPI, { + method: 'GET', + url: '/w/{workspace}/apps/get/lite/{path}', + path: { + workspace: data.workspace, + path: data.path + } +}); }; + /** * get app by path with draft * @param data The data for the request. @@ -4017,6 +4112,23 @@ export const updateApp = (data: UpdateAppData): CancelablePromise => { return __request(OpenAPI, { + method: 'GET', + url: '/w/{workspace}/apps/custom_path_exists/{custom_path}', + path: { + workspace: data.workspace, + custom_path: data.customPath + } +}); }; + /** * executeComponent * @param data The data for the request. @@ -4934,6 +5046,39 @@ export const getResumeUrls = (data: GetResumeUrlsData): CancelablePromise => { return __request(OpenAPI, { + method: 'GET', + url: '/w/{workspace}/jobs/slack_approval/{id}', + path: { + workspace: data.workspace, + id: data.id + }, + query: { + approver: data.approver, + message: data.message, + slack_resource_path: data.slackResourcePath, + channel_id: data.channelId, + flow_step_id: data.flowStepId, + default_args_json: data.defaultArgsJson, + dynamic_enums_json: data.dynamicEnumsJson + } +}); }; + /** * resume a job for a suspended flow * @param data The data for the request. @@ -5591,6 +5736,278 @@ export const setWebsocketTriggerEnabled = (data: SetWebsocketTriggerEnabledData) mediaType: 'application/json' }); }; +/** + * create kafka trigger + * @param data The data for the request. + * @param data.workspace + * @param data.requestBody new kafka trigger + * @returns string kafka trigger created + * @throws ApiError + */ +export const createKafkaTrigger = (data: CreateKafkaTriggerData): CancelablePromise => { return __request(OpenAPI, { + method: 'POST', + url: '/w/{workspace}/kafka_triggers/create', + path: { + workspace: data.workspace + }, + body: data.requestBody, + mediaType: 'application/json' +}); }; + +/** + * update kafka trigger + * @param data The data for the request. + * @param data.workspace + * @param data.path + * @param data.requestBody updated trigger + * @returns string kafka trigger updated + * @throws ApiError + */ +export const updateKafkaTrigger = (data: UpdateKafkaTriggerData): CancelablePromise => { return __request(OpenAPI, { + method: 'POST', + url: '/w/{workspace}/kafka_triggers/update/{path}', + path: { + workspace: data.workspace, + path: data.path + }, + body: data.requestBody, + mediaType: 'application/json' +}); }; + +/** + * delete kafka trigger + * @param data The data for the request. + * @param data.workspace + * @param data.path + * @returns string kafka trigger deleted + * @throws ApiError + */ +export const deleteKafkaTrigger = (data: DeleteKafkaTriggerData): CancelablePromise => { return __request(OpenAPI, { + method: 'DELETE', + url: '/w/{workspace}/kafka_triggers/delete/{path}', + path: { + workspace: data.workspace, + path: data.path + } +}); }; + +/** + * get kafka trigger + * @param data The data for the request. + * @param data.workspace + * @param data.path + * @returns KafkaTrigger kafka trigger deleted + * @throws ApiError + */ +export const getKafkaTrigger = (data: GetKafkaTriggerData): CancelablePromise => { return __request(OpenAPI, { + method: 'GET', + url: '/w/{workspace}/kafka_triggers/get/{path}', + path: { + workspace: data.workspace, + path: data.path + } +}); }; + +/** + * list kafka triggers + * @param data The data for the request. + * @param data.workspace + * @param data.page which page to return (start at 1, default 1) + * @param data.perPage number of items to return for a given page (default 30, max 100) + * @param data.path filter by path + * @param data.isFlow + * @param data.pathStart + * @returns KafkaTrigger kafka trigger list + * @throws ApiError + */ +export const listKafkaTriggers = (data: ListKafkaTriggersData): CancelablePromise => { return __request(OpenAPI, { + method: 'GET', + url: '/w/{workspace}/kafka_triggers/list', + path: { + workspace: data.workspace + }, + query: { + page: data.page, + per_page: data.perPage, + path: data.path, + is_flow: data.isFlow, + path_start: data.pathStart + } +}); }; + +/** + * does kafka trigger exists + * @param data The data for the request. + * @param data.workspace + * @param data.path + * @returns boolean kafka trigger exists + * @throws ApiError + */ +export const existsKafkaTrigger = (data: ExistsKafkaTriggerData): CancelablePromise => { return __request(OpenAPI, { + method: 'GET', + url: '/w/{workspace}/kafka_triggers/exists/{path}', + path: { + workspace: data.workspace, + path: data.path + } +}); }; + +/** + * set enabled kafka trigger + * @param data The data for the request. + * @param data.workspace + * @param data.path + * @param data.requestBody updated kafka trigger enable + * @returns string kafka trigger enabled set + * @throws ApiError + */ +export const setKafkaTriggerEnabled = (data: SetKafkaTriggerEnabledData): CancelablePromise => { return __request(OpenAPI, { + method: 'POST', + url: '/w/{workspace}/kafka_triggers/setenabled/{path}', + path: { + workspace: data.workspace, + path: data.path + }, + body: data.requestBody, + mediaType: 'application/json' +}); }; + +/** + * create nats trigger + * @param data The data for the request. + * @param data.workspace + * @param data.requestBody new nats trigger + * @returns string nats trigger created + * @throws ApiError + */ +export const createNatsTrigger = (data: CreateNatsTriggerData): CancelablePromise => { return __request(OpenAPI, { + method: 'POST', + url: '/w/{workspace}/nats_triggers/create', + path: { + workspace: data.workspace + }, + body: data.requestBody, + mediaType: 'application/json' +}); }; + +/** + * update nats trigger + * @param data The data for the request. + * @param data.workspace + * @param data.path + * @param data.requestBody updated trigger + * @returns string nats trigger updated + * @throws ApiError + */ +export const updateNatsTrigger = (data: UpdateNatsTriggerData): CancelablePromise => { return __request(OpenAPI, { + method: 'POST', + url: '/w/{workspace}/nats_triggers/update/{path}', + path: { + workspace: data.workspace, + path: data.path + }, + body: data.requestBody, + mediaType: 'application/json' +}); }; + +/** + * delete nats trigger + * @param data The data for the request. + * @param data.workspace + * @param data.path + * @returns string nats trigger deleted + * @throws ApiError + */ +export const deleteNatsTrigger = (data: DeleteNatsTriggerData): CancelablePromise => { return __request(OpenAPI, { + method: 'DELETE', + url: '/w/{workspace}/nats_triggers/delete/{path}', + path: { + workspace: data.workspace, + path: data.path + } +}); }; + +/** + * get nats trigger + * @param data The data for the request. + * @param data.workspace + * @param data.path + * @returns NatsTrigger nats trigger deleted + * @throws ApiError + */ +export const getNatsTrigger = (data: GetNatsTriggerData): CancelablePromise => { return __request(OpenAPI, { + method: 'GET', + url: '/w/{workspace}/nats_triggers/get/{path}', + path: { + workspace: data.workspace, + path: data.path + } +}); }; + +/** + * list nats triggers + * @param data The data for the request. + * @param data.workspace + * @param data.page which page to return (start at 1, default 1) + * @param data.perPage number of items to return for a given page (default 30, max 100) + * @param data.path filter by path + * @param data.isFlow + * @param data.pathStart + * @returns NatsTrigger nats trigger list + * @throws ApiError + */ +export const listNatsTriggers = (data: ListNatsTriggersData): CancelablePromise => { return __request(OpenAPI, { + method: 'GET', + url: '/w/{workspace}/nats_triggers/list', + path: { + workspace: data.workspace + }, + query: { + page: data.page, + per_page: data.perPage, + path: data.path, + is_flow: data.isFlow, + path_start: data.pathStart + } +}); }; + +/** + * does nats trigger exists + * @param data The data for the request. + * @param data.workspace + * @param data.path + * @returns boolean nats trigger exists + * @throws ApiError + */ +export const existsNatsTrigger = (data: ExistsNatsTriggerData): CancelablePromise => { return __request(OpenAPI, { + method: 'GET', + url: '/w/{workspace}/nats_triggers/exists/{path}', + path: { + workspace: data.workspace, + path: data.path + } +}); }; + +/** + * set enabled nats trigger + * @param data The data for the request. + * @param data.workspace + * @param data.path + * @param data.requestBody updated nats trigger enable + * @returns string nats trigger enabled set + * @throws ApiError + */ +export const setNatsTriggerEnabled = (data: SetNatsTriggerEnabledData): CancelablePromise => { return __request(OpenAPI, { + method: 'POST', + url: '/w/{workspace}/nats_triggers/setenabled/{path}', + path: { + workspace: data.workspace, + path: data.path + }, + body: data.requestBody, + mediaType: 'application/json' +}); }; + /** * list instance groups * @returns InstanceGroup instance group list @@ -6245,56 +6662,104 @@ export const removeGranularAcls = (data: RemoveGranularAclsData): CancelableProm }); }; /** - * update flow preview capture + * set capture config * @param data The data for the request. * @param data.workspace - * @param data.path - * @returns void flow preview captured + * @param data.requestBody capture config + * @returns unknown capture config set * @throws ApiError */ -export const updateCapture = (data: UpdateCaptureData): CancelablePromise => { return __request(OpenAPI, { +export const setCaptureConfig = (data: SetCaptureConfigData): CancelablePromise => { return __request(OpenAPI, { method: 'POST', - url: '/w/{workspace}/capture_u/{path}', + url: '/w/{workspace}/capture/set_config', + path: { + workspace: data.workspace + }, + body: data.requestBody, + mediaType: 'application/json' +}); }; + +/** + * ping capture config + * @param data The data for the request. + * @param data.workspace + * @param data.triggerKind + * @param data.runnableKind + * @param data.path + * @returns unknown capture config pinged + * @throws ApiError + */ +export const pingCaptureConfig = (data: PingCaptureConfigData): CancelablePromise => { return __request(OpenAPI, { + method: 'POST', + url: '/w/{workspace}/capture/ping_config/{trigger_kind}/{runnable_kind}/{path}', path: { workspace: data.workspace, + trigger_kind: data.triggerKind, + runnable_kind: data.runnableKind, path: data.path } }); }; /** - * create flow preview capture + * get capture configs for a script or flow * @param data The data for the request. * @param data.workspace + * @param data.runnableKind * @param data.path - * @returns unknown flow preview capture created + * @returns CaptureConfig capture configs for a script or flow * @throws ApiError */ -export const createCapture = (data: CreateCaptureData): CancelablePromise => { return __request(OpenAPI, { - method: 'PUT', - url: '/w/{workspace}/capture/{path}', - path: { - workspace: data.workspace, - path: data.path - } -}); }; - -/** - * get flow preview capture - * @param data The data for the request. - * @param data.workspace - * @param data.path - * @returns unknown captured flow preview - * @throws ApiError - */ -export const getCapture = (data: GetCaptureData): CancelablePromise => { return __request(OpenAPI, { +export const getCaptureConfigs = (data: GetCaptureConfigsData): CancelablePromise => { return __request(OpenAPI, { method: 'GET', - url: '/w/{workspace}/capture/{path}', + url: '/w/{workspace}/capture/get_configs/{runnable_kind}/{path}', path: { workspace: data.workspace, + runnable_kind: data.runnableKind, + path: data.path + } +}); }; + +/** + * list captures for a script or flow + * @param data The data for the request. + * @param data.workspace + * @param data.runnableKind + * @param data.path + * @param data.triggerKind + * @param data.page which page to return (start at 1, default 1) + * @param data.perPage number of items to return for a given page (default 30, max 100) + * @returns Capture list of captures for a script or flow + * @throws ApiError + */ +export const listCaptures = (data: ListCapturesData): CancelablePromise => { return __request(OpenAPI, { + method: 'GET', + url: '/w/{workspace}/capture/list/{runnable_kind}/{path}', + path: { + workspace: data.workspace, + runnable_kind: data.runnableKind, path: data.path }, - errors: { - 404: 'capture does not exist for this flow' + query: { + trigger_kind: data.triggerKind, + page: data.page, + per_page: data.perPage + } +}); }; + +/** + * delete a capture + * @param data The data for the request. + * @param data.workspace + * @param data.id + * @returns unknown capture deleted + * @throws ApiError + */ +export const deleteCapture = (data: DeleteCaptureData): CancelablePromise => { return __request(OpenAPI, { + method: 'DELETE', + url: '/w/{workspace}/capture/{id}', + path: { + workspace: data.workspace, + id: data.id } }); }; @@ -6342,6 +6807,7 @@ export const unstar = (data: UnstarData): CancelablePromise => { * @param data.runnableType * @param data.page which page to return (start at 1, default 1) * @param data.perPage number of items to return for a given page (default 30, max 100) + * @param data.includePreview * @returns Input Input history for completed jobs * @throws ApiError */ @@ -6355,7 +6821,8 @@ export const getInputHistory = (data: GetInputHistoryData): CancelablePromise => { return __request(OpenAPI, { + method: 'DELETE', + url: '/srch/index/delete/{idx_name}', + path: { + idx_name: data.idxName + } }); }; \ No newline at end of file diff --git a/cli/gen/types.gen.ts b/cli/gen/types.gen.ts index f5e2a460d4..ee075449a9 100644 --- a/cli/gen/types.gen.ts +++ b/cli/gen/types.gen.ts @@ -30,8 +30,8 @@ export type Script = { }; lock?: string; lock_error_logs?: string; - language: 'python3' | 'deno' | 'go' | 'bash' | 'powershell' | 'postgresql' | 'mysql' | 'bigquery' | 'snowflake' | 'mssql' | 'graphql' | 'nativets' | 'bun' | 'php' | 'rust' | 'ansible'; - kind: 'script' | 'failure' | 'trigger' | 'command' | 'approval'; + language: 'python3' | 'deno' | 'go' | 'bash' | 'powershell' | 'postgresql' | 'mysql' | 'bigquery' | 'snowflake' | 'mssql' | 'oracledb' | 'graphql' | 'nativets' | 'bun' | 'php' | 'rust' | 'ansible' | 'csharp'; + kind: 'script' | 'failure' | 'trigger' | 'command' | 'approval' | 'preprocessor'; starred: boolean; tag?: string; has_draft?: boolean; @@ -51,11 +51,12 @@ export type Script = { no_main_func: boolean; codebase?: string; has_preprocessor: boolean; + on_behalf_of_email?: string; }; -export type language = 'python3' | 'deno' | 'go' | 'bash' | 'powershell' | 'postgresql' | 'mysql' | 'bigquery' | 'snowflake' | 'mssql' | 'graphql' | 'nativets' | 'bun' | 'php' | 'rust' | 'ansible'; +export type language = 'python3' | 'deno' | 'go' | 'bash' | 'powershell' | 'postgresql' | 'mysql' | 'bigquery' | 'snowflake' | 'mssql' | 'oracledb' | 'graphql' | 'nativets' | 'bun' | 'php' | 'rust' | 'ansible' | 'csharp'; -export type kind = 'script' | 'failure' | 'trigger' | 'command' | 'approval'; +export type kind = 'script' | 'failure' | 'trigger' | 'command' | 'approval' | 'preprocessor'; export type NewScript = { path: string; @@ -68,8 +69,8 @@ export type NewScript = { }; is_template?: boolean; lock?: string; - language: 'python3' | 'deno' | 'go' | 'bash' | 'powershell' | 'postgresql' | 'mysql' | 'bigquery' | 'snowflake' | 'mssql' | 'graphql' | 'nativets' | 'bun' | 'php' | 'rust' | 'ansible'; - kind?: 'script' | 'failure' | 'trigger' | 'command' | 'approval'; + language: 'python3' | 'deno' | 'go' | 'bash' | 'powershell' | 'postgresql' | 'mysql' | 'bigquery' | 'snowflake' | 'mssql' | 'oracledb' | 'graphql' | 'nativets' | 'bun' | 'php' | 'rust' | 'ansible' | 'csharp'; + kind?: 'script' | 'failure' | 'trigger' | 'command' | 'approval' | 'preprocessor'; tag?: string; draft_only?: boolean; envs?: Array<(string)>; @@ -88,6 +89,7 @@ export type NewScript = { no_main_func?: boolean; codebase?: string; has_preprocessor?: boolean; + on_behalf_of_email?: string; }; export type NewScriptWithDraft = NewScript & { @@ -146,7 +148,7 @@ export type QueuedJob = { canceled_by?: string; canceled_reason?: string; last_ping?: string; - job_kind: 'script' | 'preview' | 'dependencies' | 'flowdependencies' | 'appdependencies' | 'flow' | 'flowpreview' | 'script_hub' | 'identity' | 'deploymentcallback' | 'singlescriptflow'; + job_kind: 'script' | 'preview' | 'dependencies' | 'flowdependencies' | 'appdependencies' | 'flow' | 'flowpreview' | 'script_hub' | 'identity' | 'deploymentcallback' | 'singlescriptflow' | 'flowscript' | 'flownode' | 'appscript'; schedule_path?: string; /** * The user (u/userfoo) or group (g/groupfoo) whom @@ -157,7 +159,7 @@ export type QueuedJob = { flow_status?: FlowStatus; raw_flow?: FlowValue; is_flow_step: boolean; - language?: 'python3' | 'deno' | 'go' | 'bash' | 'powershell' | 'postgresql' | 'mysql' | 'bigquery' | 'snowflake' | 'mssql' | 'graphql' | 'nativets' | 'bun' | 'php' | 'rust' | 'ansible'; + language?: 'python3' | 'deno' | 'go' | 'bash' | 'powershell' | 'postgresql' | 'mysql' | 'bigquery' | 'snowflake' | 'mssql' | 'oracledb' | 'graphql' | 'nativets' | 'bun' | 'php' | 'rust' | 'ansible' | 'csharp'; email: string; visible_to_owner: boolean; mem_peak?: number; @@ -168,7 +170,7 @@ export type QueuedJob = { suspend?: number; }; -export type job_kind = 'script' | 'preview' | 'dependencies' | 'flowdependencies' | 'appdependencies' | 'flow' | 'flowpreview' | 'script_hub' | 'identity' | 'deploymentcallback' | 'singlescriptflow'; +export type job_kind = 'script' | 'preview' | 'dependencies' | 'flowdependencies' | 'appdependencies' | 'flow' | 'flowpreview' | 'script_hub' | 'identity' | 'deploymentcallback' | 'singlescriptflow' | 'flowscript' | 'flownode' | 'appscript'; export type CompletedJob = { workspace_id?: string; @@ -189,7 +191,7 @@ export type CompletedJob = { canceled: boolean; canceled_by?: string; canceled_reason?: string; - job_kind: 'script' | 'preview' | 'dependencies' | 'flow' | 'flowdependencies' | 'appdependencies' | 'flowpreview' | 'script_hub' | 'identity' | 'deploymentcallback' | 'singlescriptflow'; + job_kind: 'script' | 'preview' | 'dependencies' | 'flow' | 'flowdependencies' | 'appdependencies' | 'flowpreview' | 'script_hub' | 'identity' | 'deploymentcallback' | 'singlescriptflow' | 'flowscript' | 'flownode' | 'appscript'; schedule_path?: string; /** * The user (u/userfoo) or group (g/groupfoo) whom @@ -200,7 +202,7 @@ export type CompletedJob = { flow_status?: FlowStatus; raw_flow?: FlowValue; is_flow_step: boolean; - language?: 'python3' | 'deno' | 'go' | 'bash' | 'powershell' | 'postgresql' | 'mysql' | 'bigquery' | 'snowflake' | 'mssql' | 'graphql' | 'nativets' | 'bun' | 'php' | 'rust' | 'ansible'; + language?: 'python3' | 'deno' | 'go' | 'bash' | 'powershell' | 'postgresql' | 'mysql' | 'bigquery' | 'snowflake' | 'mssql' | 'oracledb' | 'graphql' | 'nativets' | 'bun' | 'php' | 'rust' | 'ansible' | 'csharp'; is_skipped: boolean; email: string; visible_to_owner: boolean; @@ -230,6 +232,7 @@ export type User = { email: string; username: string; is_admin: boolean; + name?: string; is_super_admin: boolean; created_at: string; operator: boolean; @@ -373,7 +376,7 @@ export type Preview = { content?: string; path?: string; args: ScriptArgs; - language?: 'python3' | 'deno' | 'go' | 'bash' | 'powershell' | 'postgresql' | 'mysql' | 'bigquery' | 'snowflake' | 'mssql' | 'graphql' | 'nativets' | 'bun' | 'php' | 'rust' | 'ansible'; + language?: 'python3' | 'deno' | 'go' | 'bash' | 'powershell' | 'postgresql' | 'mysql' | 'bigquery' | 'snowflake' | 'mssql' | 'oracledb' | 'graphql' | 'nativets' | 'bun' | 'php' | 'rust' | 'ansible' | 'csharp'; tag?: string; kind?: 'code' | 'identity' | 'http'; dedicated_worker?: boolean; @@ -488,6 +491,7 @@ export type Schedule = { no_flow_overlap?: boolean; tag?: string; paused_until?: string; + cron_version?: string; }; export type ScheduleWJobs = Schedule & { @@ -521,6 +525,7 @@ export type NewSchedule = { summary?: string; tag?: string; paused_until?: string; + cron_version?: string; }; export type EditSchedule = { @@ -542,6 +547,7 @@ export type EditSchedule = { summary?: string; tag?: string; paused_until?: string; + cron_version?: string; }; export type HttpTrigger = { @@ -607,6 +613,8 @@ export type TriggersCount = { webhook_count?: number; email_count?: number; websocket_count?: number; + kafka_count?: number; + nats_count?: number; }; export type WebsocketTrigger = { @@ -629,8 +637,8 @@ export type WebsocketTrigger = { key: string; value: unknown; }>; - initial_messages: Array; - url_runnable_args: ScriptArgs; + initial_messages?: Array; + url_runnable_args?: ScriptArgs; }; export type NewWebsocketTrigger = { @@ -643,8 +651,8 @@ export type NewWebsocketTrigger = { key: string; value: unknown; }>; - initial_messages: Array; - url_runnable_args: ScriptArgs; + initial_messages?: Array; + url_runnable_args?: ScriptArgs; }; export type EditWebsocketTrigger = { @@ -656,8 +664,8 @@ export type EditWebsocketTrigger = { key: string; value: unknown; }>; - initial_messages: Array; - url_runnable_args: ScriptArgs; + initial_messages?: Array; + url_runnable_args?: ScriptArgs; }; export type WebsocketTriggerInitialMessage = { @@ -670,6 +678,90 @@ export type WebsocketTriggerInitialMessage = { }; }; +export type KafkaTrigger = { + path: string; + edited_by: string; + edited_at: string; + script_path: string; + kafka_resource_path: string; + group_id: string; + topics: Array<(string)>; + is_flow: boolean; + extra_perms: { + [key: string]: (boolean); + }; + email: string; + workspace_id: string; + server_id?: string; + last_server_ping?: string; + error?: string; + enabled: boolean; +}; + +export type NewKafkaTrigger = { + path: string; + script_path: string; + is_flow: boolean; + kafka_resource_path: string; + group_id: string; + topics: Array<(string)>; + enabled?: boolean; +}; + +export type EditKafkaTrigger = { + kafka_resource_path: string; + group_id: string; + topics: Array<(string)>; + path: string; + script_path: string; + is_flow: boolean; +}; + +export type NatsTrigger = { + path: string; + edited_by: string; + edited_at: string; + script_path: string; + nats_resource_path: string; + use_jetstream: boolean; + stream_name?: string; + consumer_name?: string; + subjects: Array<(string)>; + is_flow: boolean; + extra_perms: { + [key: string]: (boolean); + }; + email: string; + workspace_id: string; + server_id?: string; + last_server_ping?: string; + error?: string; + enabled: boolean; +}; + +export type NewNatsTrigger = { + path: string; + script_path: string; + is_flow: boolean; + nats_resource_path: string; + use_jetstream: boolean; + stream_name?: string; + consumer_name?: string; + subjects: Array<(string)>; + enabled?: boolean; +}; + +export type EditNatsTrigger = { + nats_resource_path: string; + use_jetstream: boolean; + stream_name?: string; + consumer_name?: string; + subjects: Array<(string)>; + path: string; + script_path: string; + is_flow: boolean; +}; + export type Group = { name: string; summary?: string; @@ -724,6 +816,7 @@ export type UserWorkspaceList = { id: string; name: string; username: string; + color: string; }>; }; @@ -731,6 +824,7 @@ export type CreateWorkspace = { id: string; name: string; username?: string; + color?: string; }; export type Workspace = { @@ -738,6 +832,7 @@ export type Workspace = { name: string; owner: string; domain?: string; + color?: string; }; export type WorkspaceInvite = { @@ -751,6 +846,7 @@ export type GlobalUserInfo = { email: string; login_type: 'password' | 'github'; super_admin: boolean; + devops?: boolean; verified: boolean; name?: string; company?: string; @@ -781,6 +877,7 @@ export type FlowMetadata = { dedicated_worker?: boolean; timeout?: number; visible_to_runner_only?: boolean; + on_behalf_of_email?: string; }; export type OpenFlowWPath = OpenFlow & { @@ -791,6 +888,7 @@ export type OpenFlowWPath = OpenFlow & { dedicated_worker?: boolean; timeout?: number; visible_to_runner_only?: boolean; + on_behalf_of_email?: string; }; export type FlowPreview = { @@ -870,6 +968,7 @@ export type AppWithLastVersion = { extra_perms: { [key: string]: (boolean); }; + custom_path?: string; }; export type AppWithLastVersionWDraft = AppWithLastVersion & { @@ -1012,7 +1111,7 @@ export type MetricDataPoint = { export type RawScriptForDependencies = { raw_code: string; path: string; - language: 'python3' | 'deno' | 'go' | 'bash' | 'powershell' | 'postgresql' | 'mysql' | 'bigquery' | 'snowflake' | 'mssql' | 'graphql' | 'nativets' | 'bun' | 'php' | 'rust' | 'ansible'; + language: 'python3' | 'deno' | 'go' | 'bash' | 'powershell' | 'postgresql' | 'mysql' | 'bigquery' | 'snowflake' | 'mssql' | 'oracledb' | 'graphql' | 'nativets' | 'bun' | 'php' | 'rust' | 'ansible' | 'csharp'; }; export type ConcurrencyGroup = { @@ -1107,6 +1206,23 @@ export type CriticalAlert = { workspace_id?: (string) | null; }; +export type CaptureTriggerKind = 'webhook' | 'http' | 'websocket' | 'kafka' | 'email' | 'nats'; + +export type Capture = { + trigger_kind: CaptureTriggerKind; + payload: unknown; + trigger_extra?: unknown; + id: number; + created_at: string; +}; + +export type CaptureConfig = { + trigger_config?: unknown; + trigger_kind: CaptureTriggerKind; + error?: string; + last_server_ping?: string; +}; + export type OpenFlow = { summary: string; description?: string; @@ -1204,7 +1320,7 @@ export type RawScript = { [key: string]: InputTransform; }; content: string; - language: 'deno' | 'bun' | 'python3' | 'go' | 'bash' | 'powershell' | 'postgresql' | 'mysql' | 'bigquery' | 'snowflake' | 'mssql' | 'graphql' | 'nativets' | 'php'; + language: 'deno' | 'bun' | 'python3' | 'go' | 'bash' | 'powershell' | 'postgresql' | 'mysql' | 'bigquery' | 'snowflake' | 'mssql' | 'oracledb' | 'graphql' | 'nativets' | 'php'; path?: string; lock?: string; type: 'rawscript'; @@ -1215,7 +1331,7 @@ export type RawScript = { is_trigger?: boolean; }; -export type language2 = 'deno' | 'bun' | 'python3' | 'go' | 'bash' | 'powershell' | 'postgresql' | 'mysql' | 'bigquery' | 'snowflake' | 'mssql' | 'graphql' | 'nativets' | 'php'; +export type language2 = 'deno' | 'bun' | 'python3' | 'go' | 'bash' | 'powershell' | 'postgresql' | 'mysql' | 'bigquery' | 'snowflake' | 'mssql' | 'oracledb' | 'graphql' | 'nativets' | 'php'; export type PathScript = { input_transforms: { @@ -1345,6 +1461,8 @@ export type ParameterJobId = string; export type ParameterPath = string; +export type ParameterCustomPath = string; + export type ParameterPathId = number; export type ParameterPathVersion = number; @@ -1551,6 +1669,8 @@ export type ParameterGetStarted = boolean; export type ParameterConcurrencyId = string; +export type ParameterRunnableKind = 'script' | 'flow'; + export type BackendVersionResponse = (string); export type BackendUptodateResponse = (string); @@ -1705,6 +1825,7 @@ export type GlobalUserUpdateData = { */ requestBody: { is_super_admin?: boolean; + is_devops?: boolean; name?: string; }; }; @@ -1865,7 +1986,17 @@ export type GetCriticalAlertsData = { pageSize?: number; }; -export type GetCriticalAlertsResponse = (Array); +export type GetCriticalAlertsResponse = ({ + alerts?: Array; + /** + * Total number of rows matching the query. + */ + total_rows?: number; + /** + * Total number of pages based on the page size. + */ + total_pages?: number; +}); export type AcknowledgeCriticalAlertData = { /** @@ -1932,6 +2063,10 @@ export type ListGlobalSettingsResponse = (Array); export type GetCurrentEmailResponse = (string); +export type RefreshUserTokenData = { + ifExpiringInLessThanS?: number; +}; + export type RefreshUserTokenResponse = (string); export type GetTutorialProgressResponse = ({ @@ -2088,6 +2223,15 @@ export type ChangeWorkspaceIdData = { export type ChangeWorkspaceIdResponse = (string); +export type ChangeWorkspaceColorData = { + requestBody?: { + color?: string; + }; + workspace: string; +}; + +export type ChangeWorkspaceColorResponse = (string); + export type WhoisData = { username: string; workspace: string; @@ -2152,6 +2296,7 @@ export type GetSettingsResponse = ({ default_app?: string; default_scripts?: WorkspaceDefaultScripts; mute_critical_alerts?: boolean; + color?: string; }); export type GetDeployToData = { @@ -2177,6 +2322,7 @@ export type GetPremiumInfoResponse = ({ usage?: number; seats?: number; automatic_billing: boolean; + owner: string; }); export type SetAutomaticBillingData = { @@ -2192,6 +2338,27 @@ export type SetAutomaticBillingData = { export type SetAutomaticBillingResponse = (string); +export type GetThresholdAlertData = { + workspace: string; +}; + +export type GetThresholdAlertResponse = ({ + threshold_alert_amount?: number; + last_alert_sent?: string; +}); + +export type SetThresholdAlertData = { + /** + * threshold alert info + */ + requestBody: { + threshold_alert_amount?: number; + }; + workspace: string; +}; + +export type SetThresholdAlertResponse = (string); + export type EditSlackCommandData = { /** * WorkspaceInvite @@ -2417,6 +2584,8 @@ export type GetUsedTriggersData = { export type GetUsedTriggersResponse = ({ http_routes_used: boolean; websocket_used: boolean; + kafka_used: boolean; + nats_used: boolean; }); export type ListUsersData = { @@ -2589,7 +2758,17 @@ export type WorkspaceGetCriticalAlertsData = { workspace: string; }; -export type WorkspaceGetCriticalAlertsResponse = (Array); +export type WorkspaceGetCriticalAlertsResponse = ({ + alerts?: Array; + /** + * Total number of rows matching the query. + */ + total_rows?: number; + /** + * Total number of pages based on the page size. + */ + total_pages?: number; +}); export type WorkspaceAcknowledgeCriticalAlertData = { /** @@ -2983,6 +3162,14 @@ export type GetHubAppByIdResponse = ({ }; }); +export type GetPublicAppByCustomPathData = { + customPath: string; +}; + +export type GetPublicAppByCustomPathResponse = ((AppWithLastVersion & { + workspace_id?: string; +})); + export type GetHubScriptContentByPathData = { path: string; }; @@ -3212,6 +3399,11 @@ export type ToggleWorkspaceErrorHandlerForScriptData = { export type ToggleWorkspaceErrorHandlerForScriptResponse = (string); +export type GetCustomTagsData = { + showWorkspaceRestriction?: boolean; + workspace?: string; +}; + export type GetCustomTagsResponse = (Array<(string)>); export type GeDefaultTagsResponse = (Array<(string)>); @@ -3887,6 +4079,7 @@ export type CreateAppData = { policy: Policy; draft_only?: boolean; deployment_message?: string; + custom_path?: string; }; workspace: string; }; @@ -3908,6 +4101,13 @@ export type GetAppByPathData = { export type GetAppByPathResponse = (AppWithLastVersion); +export type GetAppLiteByPathData = { + path: string; + workspace: string; +}; + +export type GetAppLiteByPathResponse = (AppWithLastVersion); + export type GetAppByPathWithDraftData = { path: string; workspace: string; @@ -4025,12 +4225,20 @@ export type UpdateAppData = { value?: unknown; policy?: Policy; deployment_message?: string; + custom_path?: string; }; workspace: string; }; export type UpdateAppResponse = (string); +export type CustomPathExistsData = { + customPath: string; + workspace: string; +}; + +export type CustomPathExistsResponse = (boolean); + export type ExecuteComponentData = { path: string; /** @@ -4039,6 +4247,7 @@ export type ExecuteComponentData = { requestBody: { component: string; path?: string; + version?: number; args: unknown; raw_code?: { content: string; @@ -4047,6 +4256,7 @@ export type ExecuteComponentData = { lock?: string; cache_ttl?: number; }; + id?: number; force_viewer_static_fields?: { [key: string]: unknown; }; @@ -4892,6 +5102,20 @@ export type GetResumeUrlsResponse = ({ cancel: string; }); +export type GetSlackApprovalPayloadData = { + approver?: string; + channelId: string; + defaultArgsJson?: string; + dynamicEnumsJson?: string; + flowStepId: string; + id: string; + message?: string; + slackResourcePath: string; + workspace: string; +}; + +export type GetSlackApprovalPayloadResponse = (unknown); + export type ResumeSuspendedJobGetData = { approver?: string; id: string; @@ -4997,6 +5221,7 @@ export type PreviewScheduleData = { requestBody: { schedule: string; timezone: string; + cron_version?: string; }; }; @@ -5265,6 +5490,156 @@ export type SetWebsocketTriggerEnabledData = { export type SetWebsocketTriggerEnabledResponse = (string); +export type CreateKafkaTriggerData = { + /** + * new kafka trigger + */ + requestBody: NewKafkaTrigger; + workspace: string; +}; + +export type CreateKafkaTriggerResponse = (string); + +export type UpdateKafkaTriggerData = { + path: string; + /** + * updated trigger + */ + requestBody: EditKafkaTrigger; + workspace: string; +}; + +export type UpdateKafkaTriggerResponse = (string); + +export type DeleteKafkaTriggerData = { + path: string; + workspace: string; +}; + +export type DeleteKafkaTriggerResponse = (string); + +export type GetKafkaTriggerData = { + path: string; + workspace: string; +}; + +export type GetKafkaTriggerResponse = (KafkaTrigger); + +export type ListKafkaTriggersData = { + isFlow?: boolean; + /** + * which page to return (start at 1, default 1) + */ + page?: number; + /** + * filter by path + */ + path?: string; + pathStart?: string; + /** + * number of items to return for a given page (default 30, max 100) + */ + perPage?: number; + workspace: string; +}; + +export type ListKafkaTriggersResponse = (Array); + +export type ExistsKafkaTriggerData = { + path: string; + workspace: string; +}; + +export type ExistsKafkaTriggerResponse = (boolean); + +export type SetKafkaTriggerEnabledData = { + path: string; + /** + * updated kafka trigger enable + */ + requestBody: { + enabled: boolean; + }; + workspace: string; +}; + +export type SetKafkaTriggerEnabledResponse = (string); + +export type CreateNatsTriggerData = { + /** + * new nats trigger + */ + requestBody: NewNatsTrigger; + workspace: string; +}; + +export type CreateNatsTriggerResponse = (string); + +export type UpdateNatsTriggerData = { + path: string; + /** + * updated trigger + */ + requestBody: EditNatsTrigger; + workspace: string; +}; + +export type UpdateNatsTriggerResponse = (string); + +export type DeleteNatsTriggerData = { + path: string; + workspace: string; +}; + +export type DeleteNatsTriggerResponse = (string); + +export type GetNatsTriggerData = { + path: string; + workspace: string; +}; + +export type GetNatsTriggerResponse = (NatsTrigger); + +export type ListNatsTriggersData = { + isFlow?: boolean; + /** + * which page to return (start at 1, default 1) + */ + page?: number; + /** + * filter by path + */ + path?: string; + pathStart?: string; + /** + * number of items to return for a given page (default 30, max 100) + */ + perPage?: number; + workspace: string; +}; + +export type ListNatsTriggersResponse = (Array); + +export type ExistsNatsTriggerData = { + path: string; + workspace: string; +}; + +export type ExistsNatsTriggerResponse = (boolean); + +export type SetNatsTriggerEnabledData = { + path: string; + /** + * updated nats trigger enable + */ + requestBody: { + enabled: boolean; + }; + workspace: string; +}; + +export type SetNatsTriggerEnabledResponse = (string); + export type ListInstanceGroupsResponse = (Array); export type GetInstanceGroupData = { @@ -5612,7 +5987,7 @@ export type ListAutoscalingEventsData = { export type ListAutoscalingEventsResponse = (Array); export type GetGranularAclsData = { - kind: 'script' | 'group_' | 'resource' | 'schedule' | 'variable' | 'flow' | 'folder' | 'app' | 'raw_app' | 'http_trigger' | 'websocket_trigger'; + kind: 'script' | 'group_' | 'resource' | 'schedule' | 'variable' | 'flow' | 'folder' | 'app' | 'raw_app' | 'http_trigger' | 'websocket_trigger' | 'kafka_trigger' | 'nats_trigger'; path: string; workspace: string; }; @@ -5622,7 +5997,7 @@ export type GetGranularAclsResponse = ({ }); export type AddGranularAclsData = { - kind: 'script' | 'group_' | 'resource' | 'schedule' | 'variable' | 'flow' | 'folder' | 'app' | 'raw_app' | 'http_trigger' | 'websocket_trigger'; + kind: 'script' | 'group_' | 'resource' | 'schedule' | 'variable' | 'flow' | 'folder' | 'app' | 'raw_app' | 'http_trigger' | 'websocket_trigger' | 'kafka_trigger' | 'nats_trigger'; path: string; /** * acl to add @@ -5637,7 +6012,7 @@ export type AddGranularAclsData = { export type AddGranularAclsResponse = (string); export type RemoveGranularAclsData = { - kind: 'script' | 'group_' | 'resource' | 'schedule' | 'variable' | 'flow' | 'folder' | 'app' | 'raw_app' | 'http_trigger' | 'websocket_trigger'; + kind: 'script' | 'group_' | 'resource' | 'schedule' | 'variable' | 'flow' | 'folder' | 'app' | 'raw_app' | 'http_trigger' | 'websocket_trigger' | 'kafka_trigger' | 'nats_trigger'; path: string; /** * acl to add @@ -5650,26 +6025,63 @@ export type RemoveGranularAclsData = { export type RemoveGranularAclsResponse = (string); -export type UpdateCaptureData = { - path: string; +export type SetCaptureConfigData = { + /** + * capture config + */ + requestBody: { + trigger_kind: CaptureTriggerKind; + path: string; + is_flow: boolean; + trigger_config?: { + [key: string]: unknown; + }; + }; workspace: string; }; -export type UpdateCaptureResponse = (void); +export type SetCaptureConfigResponse = (unknown); -export type CreateCaptureData = { +export type PingCaptureConfigData = { path: string; + runnableKind: 'script' | 'flow'; + triggerKind: CaptureTriggerKind; workspace: string; }; -export type CreateCaptureResponse = (unknown); +export type PingCaptureConfigResponse = (unknown); -export type GetCaptureData = { +export type GetCaptureConfigsData = { path: string; + runnableKind: 'script' | 'flow'; workspace: string; }; -export type GetCaptureResponse = (unknown); +export type GetCaptureConfigsResponse = (Array); + +export type ListCapturesData = { + /** + * which page to return (start at 1, default 1) + */ + page?: number; + path: string; + /** + * number of items to return for a given page (default 30, max 100) + */ + perPage?: number; + runnableKind: 'script' | 'flow'; + triggerKind?: CaptureTriggerKind; + workspace: string; +}; + +export type ListCapturesResponse = (Array); + +export type DeleteCaptureData = { + id: number; + workspace: string; +}; + +export type DeleteCaptureResponse = (unknown); export type StarData = { requestBody?: { @@ -5692,6 +6104,7 @@ export type UnstarData = { export type UnstarResponse = (unknown); export type GetInputHistoryData = { + includePreview?: boolean; /** * which page to return (start at 1, default 1) */ @@ -6223,7 +6636,6 @@ export type SearchLogsIndexResponse = ({ }); export type CountSearchLogsIndexData = { - hosts: string; maxTs?: string; minTs?: string; searchQuery: string; @@ -6240,4 +6652,10 @@ export type CountSearchLogsIndexResponse = ({ count_per_host?: { [key: string]: unknown; }; -}); \ No newline at end of file +}); + +export type ClearIndexData = { + idxName: 'JobIndex' | 'ServiceLogIndex'; +}; + +export type ClearIndexResponse = (string); \ No newline at end of file diff --git a/openflow.openapi.yaml b/openflow.openapi.yaml index 25e8e14bce..309b154c6f 100644 --- a/openflow.openapi.yaml +++ b/openflow.openapi.yaml @@ -250,6 +250,7 @@ components: - bigquery - snowflake - mssql + - oracledb - graphql - nativets - php