| 1 | import { env } from "cloudflare:workers"; |
| 2 | |
| 3 | import { |
| 4 | accountsClient, |
| 5 | actionsClient, |
| 6 | advisoriesClient, |
| 7 | agentsClient, |
| 8 | billingClient, |
| 9 | chatClient, |
| 10 | contextClient, |
| 11 | deploymentsClient, |
| 12 | docsClient, |
| 13 | foliosClient, |
| 14 | memoryReviewClient, |
| 15 | mirrorsClient, |
| 16 | packagesClient, |
| 17 | projectsClient, |
| 18 | eventsClient, |
| 19 | guardrailsClient, |
| 20 | identityClient, |
| 21 | inboxClient, |
| 22 | integrationsClient, |
| 23 | reposClient, |
| 24 | searchClient, |
| 25 | securityClient, |
| 26 | securitySuiteClient, |
| 27 | webhooksClient, |
| 28 | workClient, |
| 29 | skillLibraryClient, |
| 30 | workspaceAgentsClient, |
| 31 | } from "@g1t/contracts"; |
| 32 | import { telemetryClient } from "@g1t/contracts/telemetry"; |
| 33 | |
| 34 | import { instrumented } from "./perf.server"; |
| 35 | |
| 36 | /** |
| 37 | * Each binding the clients use, timed for `Server-Timing` and, for the |
| 38 | * services that read D1 with sessions, told where to read (lib/perf.ts). |
| 39 | */ |
| 40 | const IDENTITY = instrumented("identity", env.IDENTITY); |
| 41 | const REPOS = instrumented("repos", env.REPOS); |
| 42 | const WORK = instrumented("work", env.WORK); |
| 43 | const BILLING = instrumented("billing", env.BILLING); |
| 44 | const EVENTS = instrumented("events", env.EVENTS); |
| 45 | const INTEGRATIONS = instrumented("integrations", env.INTEGRATIONS); |
| 46 | const WEBHOOKS = instrumented("webhooks", env.WEBHOOKS); |
| 47 | const ACTIONS = instrumented("actions", env.ACTIONS); |
| 48 | const DEPLOYMENTS = instrumented("deployments", env.DEPLOYMENTS); |
| 49 | const PROJECTS = instrumented("projects", env.PROJECTS); |
| 50 | const SECURITY = instrumented("security", env.SECURITY); |
| 51 | const CONTEXT = instrumented("context", env.CONTEXT); |
| 52 | const SEARCH = instrumented("search", env.SEARCH); |
| 53 | const PACKAGES = instrumented("packages", env.PACKAGES); |
| 54 | const CHAT = instrumented("chat", env.CHAT); |
| 55 | const AGENTS = instrumented("agents", env.AGENTS); |
| 56 | const ARTIFACTS = instrumented("artifacts", env.ARTIFACTS); |
| 57 | const TELEMETRY = env.TELEMETRY ? instrumented("telemetry", env.TELEMETRY) : null; |
| 58 | |
| 59 | export const identity = identityClient(IDENTITY); |
| 60 | /** A person's email addresses and account security: methods of identity. */ |
| 61 | export const accounts = accountsClient(IDENTITY); |
| 62 | export const repos = reposClient(REPOS); |
| 63 | export const work = workClient(WORK); |
| 64 | export const billing = billingClient(BILLING); |
| 65 | export const events = eventsClient(EVENTS); |
| 66 | /** Each person's inbox, which the events service keeps. */ |
| 67 | export const inbox = inboxClient(EVENTS); |
| 68 | export const integrations = integrationsClient(INTEGRATIONS); |
| 69 | /** Mirroring: a repository's remotes, takeovers and hand-backs, kept by integrations. */ |
| 70 | export const mirrors = mirrorsClient(INTEGRATIONS); |
| 71 | export const webhooks = webhooksClient(WEBHOOKS); |
| 72 | export const actions = actionsClient(ACTIONS); |
| 73 | export const deployments = deploymentsClient(DEPLOYMENTS); |
| 74 | export const projects = projectsClient(PROJECTS); |
| 75 | export const security = securityClient(SECURITY); |
| 76 | /** The security suite: patterns, bypasses, code scanning, the dependency graph, settings. */ |
| 77 | export const securitySuite = securitySuiteClient(SECURITY); |
| 78 | /** Security advisories and private vulnerability reports: methods of the security service. */ |
| 79 | export const advisories = advisoriesClient(SECURITY); |
| 80 | /** Agent runs, sessions and memory: methods of the work service. */ |
| 81 | export const agents = agentsClient(WORK); |
| 82 | /** What agents may do in a sandbox: methods of the work service. */ |
| 83 | export const guardrails = guardrailsClient(WORK); |
| 84 | /** The context hub: catalog, search and scorecards. */ |
| 85 | export const context = contextClient(CONTEXT); |
| 86 | /** Search across all of g1t, and Explore. */ |
| 87 | export const search = searchClient(SEARCH); |
| 88 | /** The workspace's registries: container images, and more to come. */ |
| 89 | export const packages = packagesClient(PACKAGES); |
| 90 | /** Memory candidates and their review: methods of the work service. */ |
| 91 | export const memoryReview = memoryReviewClient(WORK); |
| 92 | /** Channels, direct messages and threads, where people and agents talk. */ |
| 93 | export const chat = chatClient(CHAT); |
| 94 | /** The workspace's own agents: who they are, their limits and their desks. */ |
| 95 | export const workspaceAgents = workspaceAgentsClient(AGENTS); |
| 96 | /** The workspace's skill library: skills, their versions and where they are attached (the agents service). */ |
| 97 | export const skillLibrary = skillLibraryClient(AGENTS); |
| 98 | /** The artifacts service's spaces (Artifacts' spaces) and projects' docs. Its old pages are no longer read. */ |
| 99 | export const docs = docsClient(ARTIFACTS); |
| 100 | /** Artifacts (folios): docs, and later slides, designs and dashboards, kept by the artifacts service. */ |
| 101 | export const folios = foliosClient(ARTIFACTS); |
| 102 | |
| 103 | /** |
| 104 | * Observability (services/telemetry): a project's requests, logs, traces, |
| 105 | * metrics and errors. Null where it is not deployed; the pages say so. |
| 106 | */ |
| 107 | export const telemetry = TELEMETRY ? telemetryClient(TELEMETRY) : null; |