45 lines
1.3 KiB
TypeScript
45 lines
1.3 KiB
TypeScript
import { Effect, Match } from "effect"
|
|
import type { TRPCContextTransaction } from "./TRPCContext"
|
|
import { importTRPCServer } from "./importTRPCServer"
|
|
|
|
|
|
export const ExpressOnly = importTRPCServer.pipe(Effect.map(({
|
|
experimental_standaloneMiddleware,
|
|
TRPCError,
|
|
}) => experimental_standaloneMiddleware<{
|
|
ctx: { readonly transaction: TRPCContextTransaction }
|
|
}>().create(opts =>
|
|
Match.value(opts.ctx.transaction).pipe(
|
|
Match.tag("Express", transaction =>
|
|
opts.next({ ctx: { transaction } })
|
|
),
|
|
|
|
Match.orElse(() => {
|
|
throw new TRPCError({
|
|
code: "BAD_REQUEST",
|
|
message: "Only Express transport is supported by this procedure",
|
|
})
|
|
}),
|
|
)
|
|
)))
|
|
|
|
export const WebSocketOnly = importTRPCServer.pipe(Effect.map(({
|
|
experimental_standaloneMiddleware,
|
|
TRPCError,
|
|
}) => experimental_standaloneMiddleware<{
|
|
ctx: { readonly transaction: TRPCContextTransaction }
|
|
}>().create(opts =>
|
|
Match.value(opts.ctx.transaction).pipe(
|
|
Match.tag("WebSocket", transaction =>
|
|
opts.next({ ctx: { transaction } })
|
|
),
|
|
|
|
Match.orElse(() => {
|
|
throw new TRPCError({
|
|
code: "BAD_REQUEST",
|
|
message: "Only WebSocket transport is supported by this procedure",
|
|
})
|
|
}),
|
|
)
|
|
)))
|