@prpc/core
Advanced tools
+7
-4
@@ -63,3 +63,3 @@ // src/error.ts | ||
| } | ||
| async function tryAndWrap(queryFn, input) { | ||
| async function tryAndWrap(queryFn, input, handleRedirect) { | ||
| try { | ||
@@ -77,2 +77,4 @@ const response = await queryFn(unwrapValue(input)); | ||
| return await optionalData(response); | ||
| } else { | ||
| handleRedirect?.(url, response); | ||
| } | ||
@@ -95,3 +97,3 @@ } | ||
| var callMiddleware$ = async (request, middlewares, ctx) => { | ||
| let currentCtx = ctx ?? {}; | ||
| let currentCtx = ctx ? { ...ctx, request$: request } : { request$: request }; | ||
| if (Array.isArray(middlewares)) { | ||
@@ -157,7 +159,8 @@ for (const middleware of middlewares) { | ||
| queryFn: args[0][isMutation ? "mutationFn" : "queryFn"], | ||
| key: args[0].key | ||
| key: args[0].key, | ||
| cfg: args[0].cfg | ||
| }; | ||
| } else { | ||
| const [queryFn, key] = args; | ||
| return { queryFn, key }; | ||
| return { queryFn, key, cfg: {} }; | ||
| } | ||
@@ -164,0 +167,0 @@ }; |
+4
-3
@@ -44,13 +44,14 @@ import * as zod from 'zod'; | ||
| declare function figureOutMessageError(err: any): any; | ||
| declare function tryAndWrap<Fn extends ExpectedFn<any>>(queryFn: Fn, input: AsParam<Fn, false | true>): Promise<any>; | ||
| declare function tryAndWrap<Fn extends ExpectedFn<any>>(queryFn: Fn, input: AsParam<Fn, false | true>, handleRedirect?: (url: string, response: Response) => any): Promise<any>; | ||
| declare const middleware$: <Mw extends IMiddleware<CurrentContext>, CurrentContext = unknown>(mw: Mw) => Mw; | ||
| type Flattened<T> = T extends Array<infer U> ? Flattened<U> : T; | ||
| declare const pipe$: <CurrentMw extends IMiddleware<any> | IMiddleware<any>[], Mw extends IMiddleware<FilterOutResponse<InferFinalMiddlware<CurrentMw>>>[]>(currentMw: CurrentMw, ...middlewares: Mw) => Flattened<Mw>; | ||
| declare const callMiddleware$: <Mw extends IMiddleware<any>[]>(request: Request, middlewares: Mw, ctx: any) => Promise<any>; | ||
| declare const callMiddleware$: <Mw extends IMiddleware<any>[]>(request: Request, middlewares: Mw, ctx?: any) => Promise<any>; | ||
| declare const hideRequest: <T>(ctx$: T, fully?: boolean) => any; | ||
| declare const error$: (error: any, init?: ResponseInit) => Response; | ||
| declare const validateZod: <Schema extends ZodSchema<any, zod.ZodTypeDef, any>>(payload: any, schema: Schema) => Promise<any>; | ||
| declare const getParams: (isMutation: boolean, ...args: any[]) => { | ||
| declare const getParams: <T = Record<any, any>>(isMutation: boolean, ...args: any[]) => { | ||
| queryFn: ExpectedFn<any>; | ||
| key: string; | ||
| cfg: T; | ||
| }; | ||
@@ -57,0 +58,0 @@ |
+7
-4
@@ -63,3 +63,3 @@ // src/error.ts | ||
| } | ||
| async function tryAndWrap(queryFn, input) { | ||
| async function tryAndWrap(queryFn, input, handleRedirect) { | ||
| try { | ||
@@ -77,2 +77,4 @@ const response = await queryFn(unwrapValue(input)); | ||
| return await optionalData(response); | ||
| } else { | ||
| handleRedirect?.(url, response); | ||
| } | ||
@@ -95,3 +97,3 @@ } | ||
| var callMiddleware$ = async (request, middlewares, ctx) => { | ||
| let currentCtx = ctx ?? {}; | ||
| let currentCtx = ctx ? { ...ctx, request$: request } : { request$: request }; | ||
| if (Array.isArray(middlewares)) { | ||
@@ -157,7 +159,8 @@ for (const middleware of middlewares) { | ||
| queryFn: args[0][isMutation ? "mutationFn" : "queryFn"], | ||
| key: args[0].key | ||
| key: args[0].key, | ||
| cfg: args[0].cfg | ||
| }; | ||
| } else { | ||
| const [queryFn, key] = args; | ||
| return { queryFn, key }; | ||
| return { queryFn, key, cfg: {} }; | ||
| } | ||
@@ -164,0 +167,0 @@ }; |
+1
-1
| { | ||
| "name": "@prpc/core", | ||
| "description": "Package for easily creating server rpc functions in solid-start with goodies baked in", | ||
| "version": "0.3.9", | ||
| "version": "0.3.10", | ||
| "type": "module", | ||
@@ -6,0 +6,0 @@ "exports": { |
14288
2.92%424
1.68%