Something went wrong. Try again.
opencode v2 mirror
Something went wrong. Try again.
TypeScript
123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209import { Integration } from "@opencode/schema/integration"import { Location } from "@opencode/schema/location"import { Form } from "@opencode/schema/form"import { Schema } from "effect"import { HttpApiEndpoint, HttpApiGroup, HttpApiSchema, OpenApi } from "effect/unstable/httpapi"import { IntegrationAttemptNotFoundError, IntegrationMethodNotFoundError, IntegrationNotFoundError, InvalidRequestError,} from "../errors.js"import { LocationQuery, locationQueryOpenApi } from "./location.js"
export const IntegrationGroup = HttpApiGroup.make("server.integration") .add( HttpApiEndpoint.get("integration.list", "/api/integration", { query: LocationQuery, success: Location.response(Schema.Array(Integration.Info)), }) .annotateMerge(locationQueryOpenApi) .annotateMerge( OpenApi.annotations({ identifier: "integration.list", summary: "List integrations", description: "Retrieve available integrations and their authentication methods.", }), ), ) .add( HttpApiEndpoint.get("integration.get", "/api/integration/:integrationID", { params: { integrationID: Integration.ID }, query: LocationQuery, success: Location.response(Integration.Info), error: IntegrationNotFoundError, }) .annotateMerge(locationQueryOpenApi) .annotateMerge( OpenApi.annotations({ identifier: "integration.get", summary: "Get integration", description: "Retrieve one integration and its authentication methods.", }), ), ) .add( HttpApiEndpoint.post("integration.wellknown.add", "/api/experimental/integration/wellknown", { query: LocationQuery, payload: Schema.Struct({ url: Schema.String }), success: HttpApiSchema.NoContent, error: InvalidRequestError, }) .annotateMerge(locationQueryOpenApi) .annotateMerge( OpenApi.annotations({ identifier: "experimental.integration.wellknown.add", summary: "Add wellknown integration", description: "Discover and persist an experimental wellknown integration source.", }), ), ) .add( HttpApiEndpoint.post("integration.connect.key", "/api/integration/:integrationID/connect/key", { params: { integrationID: Integration.ID }, query: LocationQuery, payload: Schema.Struct({ key: Schema.String, answer: Schema.optional(Form.Answer), label: Schema.optional(Schema.String), }), success: HttpApiSchema.NoContent, error: [IntegrationNotFoundError, InvalidRequestError], }) .annotateMerge(locationQueryOpenApi) .annotateMerge( OpenApi.annotations({ identifier: "integration.connect.key", summary: "Connect with key", description: "Run a key authentication method and store the resulting credential.", }), ), ) .add( HttpApiEndpoint.post("integration.oauth.connect", "/api/integration/:integrationID/connect/oauth", { params: { integrationID: Integration.ID }, query: LocationQuery, payload: Schema.Struct({ methodID: Integration.MethodID, answer: Schema.optional(Form.Answer), label: Schema.optional(Schema.String), }), success: Location.response(Integration.Attempt), error: InvalidRequestError, }) .annotateMerge(locationQueryOpenApi) .annotateMerge( OpenApi.annotations({ identifier: "integration.oauth.connect", summary: "Begin OAuth connection", description: "Start an OAuth attempt and return the authorization details.", }), ), ) .add( HttpApiEndpoint.get("integration.oauth.status", "/api/integration/:integrationID/connect/oauth/:attemptID", { params: { integrationID: Integration.ID, attemptID: Integration.AttemptID }, query: LocationQuery, success: Location.response(Integration.AttemptStatus), error: [IntegrationNotFoundError, IntegrationAttemptNotFoundError], }) .annotateMerge(locationQueryOpenApi) .annotateMerge( OpenApi.annotations({ identifier: "integration.oauth.status", summary: "Get OAuth attempt status", description: "Poll the current status of an OAuth attempt.", }), ), ) .add( HttpApiEndpoint.post( "integration.oauth.complete", "/api/integration/:integrationID/connect/oauth/:attemptID/complete", { params: { integrationID: Integration.ID, attemptID: Integration.AttemptID }, query: LocationQuery, payload: Schema.Struct({ code: Schema.optional(Schema.String) }), success: HttpApiSchema.NoContent, error: [IntegrationNotFoundError, IntegrationAttemptNotFoundError, InvalidRequestError], }, ) .annotateMerge(locationQueryOpenApi) .annotateMerge( OpenApi.annotations({ identifier: "integration.oauth.complete", summary: "Complete OAuth connection", description: "Complete a code-based OAuth attempt and store the resulting credential.", }), ), ) .add( HttpApiEndpoint.delete("integration.oauth.cancel", "/api/integration/:integrationID/connect/oauth/:attemptID", { params: { integrationID: Integration.ID, attemptID: Integration.AttemptID }, query: LocationQuery, success: HttpApiSchema.NoContent, }) .annotateMerge(locationQueryOpenApi) .annotateMerge( OpenApi.annotations({ identifier: "integration.oauth.cancel", summary: "Cancel OAuth connection", description: "Cancel an OAuth attempt and release its resources.", }), ), ) .add( HttpApiEndpoint.post("integration.command.connect", "/api/integration/:integrationID/connect/command", { params: { integrationID: Integration.ID }, query: LocationQuery, payload: Schema.Struct({ methodID: Integration.MethodID, label: Schema.optional(Schema.String), }), success: Location.response(Integration.CommandAttempt), error: [IntegrationNotFoundError, IntegrationMethodNotFoundError, InvalidRequestError], }) .annotateMerge(locationQueryOpenApi) .annotateMerge( OpenApi.annotations({ identifier: "integration.command.connect", summary: "Begin command connection", description: "Start a command authentication attempt.", }), ), ) .add( HttpApiEndpoint.get("integration.command.status", "/api/integration/:integrationID/connect/command/:attemptID", { params: { integrationID: Integration.ID, attemptID: Integration.AttemptID }, query: LocationQuery, success: Location.response(Integration.CommandAttemptStatus), error: [IntegrationNotFoundError, IntegrationAttemptNotFoundError], }) .annotateMerge(locationQueryOpenApi) .annotateMerge( OpenApi.annotations({ identifier: "integration.command.status", summary: "Get command attempt status", description: "Poll the current status and output of a command authentication attempt.", }), ), ) .add( HttpApiEndpoint.delete("integration.command.cancel", "/api/integration/:integrationID/connect/command/:attemptID", { params: { integrationID: Integration.ID, attemptID: Integration.AttemptID }, query: LocationQuery, success: HttpApiSchema.NoContent, }) .annotateMerge(locationQueryOpenApi) .annotateMerge( OpenApi.annotations({ identifier: "integration.command.cancel", summary: "Cancel command connection", description: "Cancel a command authentication attempt and terminate its process.", }), ), ) .annotateMerge( OpenApi.annotations({ title: "integration", description: "Integration discovery and authentication routes." }), )