File size: 3,446 Bytes
89a2873 | 1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33 34 35 36 37 38 39 40 41 42 43 44 45 46 47 48 49 50 51 52 53 54 55 56 57 58 59 60 61 62 63 64 65 66 67 68 69 70 71 72 73 74 75 76 77 78 79 80 81 82 83 84 85 86 87 88 89 90 91 92 93 94 95 96 97 98 99 100 101 102 103 104 105 | import { Integration } from "@opencode-ai/core/integration"
import { Effect } from "effect"
import { HttpApiBuilder, HttpApiSchema } from "effect/unstable/httpapi"
import { Api } from "../api"
import { InvalidRequestError } from "@opencode-ai/protocol/errors"
import { response } from "../location"
const authorize = <A, R>(effect: Effect.Effect<A, Integration.AuthorizationError, R>) =>
effect.pipe(
Effect.mapError(
() =>
new InvalidRequestError({
message: "Authentication failed",
kind: "integration_authorization",
}),
),
)
export const IntegrationHandler = HttpApiBuilder.group(Api, "server.integration", (handlers) =>
Effect.gen(function* () {
return handlers
.handle(
"integration.list",
Effect.fn(function* () {
const service = yield* Integration.Service
return yield* response(service.list())
}),
)
.handle(
"integration.get",
Effect.fn(function* (ctx) {
const service = yield* Integration.Service
return yield* response(service.get(ctx.params.integrationID))
}),
)
.handle(
"integration.connect.key",
Effect.fn(function* (ctx) {
const service = yield* Integration.Service
yield* authorize(
service.connection.key({
integrationID: ctx.params.integrationID,
key: ctx.payload.key,
label: ctx.payload.label,
}),
)
return HttpApiSchema.NoContent.make()
}),
)
.handle(
"integration.connect.oauth",
Effect.fn(function* (ctx) {
const service = yield* Integration.Service
return yield* response(
authorize(
service.connection.oauth({
integrationID: ctx.params.integrationID,
methodID: ctx.payload.methodID,
inputs: ctx.payload.inputs,
label: ctx.payload.label,
}),
),
)
}),
)
.handle(
"integration.attempt.status",
Effect.fn(function* (ctx) {
const service = yield* Integration.Service
return yield* response(service.attempt.status(ctx.params.attemptID))
}),
)
.handle(
"integration.attempt.complete",
Effect.fn(function* (ctx) {
const service = yield* Integration.Service
yield* service.attempt.complete({ attemptID: ctx.params.attemptID, code: ctx.payload.code }).pipe(
Effect.mapError(
(error) =>
new InvalidRequestError({
message:
error._tag === "Integration.CodeRequired"
? "Authorization code is required"
: "Authentication failed",
kind:
error._tag === "Integration.CodeRequired"
? "integration_code_required"
: "integration_authorization",
}),
),
)
return HttpApiSchema.NoContent.make()
}),
)
.handle(
"integration.attempt.cancel",
Effect.fn(function* (ctx) {
const service = yield* Integration.Service
yield* service.attempt.cancel(ctx.params.attemptID)
return HttpApiSchema.NoContent.make()
}),
)
}),
)
|