BAD_REQUEST Input validation failed

[saurabhpolicybazaar]

Below is my use case, and I'm getting 'Input validation failed'. I'm facing the below issues; please have a look.

1. Getting a validation error.
2. Unable to access req body within route. Do I have to add any body parser?
3. what input is expected only body schema or body, head, query everything.

private mountOrpcRoutes(): void {
   const handler = new RPCHandler(orpcRouter, {
     plugins: [
       new CORSPlugin(),
       new BodyLimitPlugin({
         maxBodySize: 1024 * 1024, // 1MB
       }),
       new RequestHeadersPlugin(), // context.reqHeaders
       new StrictGetMethodPlugin(),
     ],
   });
   this.app.use(`${config.app.basePath}/rpc/*`, async (c, next) => {
     const session = {} as unknown as Session["session"];
     const user = {} as unknown as Session["user"];

     const { matched, response } = await handler.handle(c.req.raw, {
       prefix: `${config.app.basePath}/rpc` as `/${string}`,
       context: {
         headers: c.req.raw.headers,
         session: {
           session: c.get("session") || session,
           user: c.get("user") || user,
         },
       },
     });

     if (matched) {
       logger.info(`matched: ${matched}`);
       const rawBody = await response.json();

       // Remove "json" key if present
       if (rawBody && typeof rawBody === "object" && "json" in rawBody) {
         return c.json(rawBody.json, response);
       }

       // Otherwise return as-is
       return c.json(rawBody, response);
     }

     // Only call next if no match
     return await next();
   });
 }

import {
  getAllActiveRolesRequestSchema,
  getAllActiveRolesResponseSchema,
  type getAllActiveRolesResponseType,
  type getAllActiveRolesType,
} from "@posp-banking/schema/masters";

import { protectedProcedure } from "@/lib/orpc";
import { convertToSuccessResponse } from "@/lib/responseHandler";
import { getAllActiveRoles } from "@/orpc/service/masters.service";

/**
 * Get all active roles from Db
 */
export const getAllActiveRolesRoute = protectedProcedure
  .input(getAllActiveRolesRequestSchema)
  .output(getAllActiveRolesResponseSchema)
  .handler(async (ctx) : Promise<getAllActiveRolesResponseType>=> {
    const roles: getAllActiveRolesType = await getAllActiveRoles();
    return convertToSuccessResponse(roles);
  });

postman curl
curl --location 'http://localhost:3000/banking/v1/rpc/getAllActiveRolesRoute' \
--header 'Content-Type: application/json' \
--header 'Cookie: better-auth.session_token=wpxnrY7yrWtm1jVzL2arg6VIcpZGszl0.T4wv3TtlXlX32ixWpAxXebHD1xQ2oPz2CKkaEeGoCDU%3D' \
--data '{
    "id" : 1,
    "name" : "test"
}'

{
    "isSuccess": false,
    "error": {
        "code": "BAD_REQUEST",
        "message": "Input validation failed",
        "cause": {
            "issues": [
                {
                    "expected": "object",
                    "code": "invalid_type",
                    "path": [],
                    "message": "Invalid input: expected object, received undefined"
                }
            ]
        }
    }
}

[unnoq]

RPCHandler not design for directly call, please check OpenAPIHandler instead.

[saurabhpolicybazaar]

Once I send a request like below from postman, it worked

{
"json": {
"id" : 1,
"name": "test"
}
}

[DIEGOHORVATTI]

Assim que enviei uma solicitação como a abaixo do carteiro, funcionou

{ "json": { "id" : 1, "nome": "teste" } }

There is no way to remove this "json:"? @saurabhpolicybazaar

[unnoq]

@DIEGOHORVATTI Please use OpenAPIHandler

[DIEGOHORVATTI]

@DIEGOHORVATTI Please use OpenAPIHandler

My mistake was not using 'Content-Type': 'application/json', this caused the playload model to not be correct so it inferred json: in front of my object, I struggled to resolve this hahaaha

import type { ContractRouterClient } from '@orpc/contract'
import type { JsonifiedClient } from '@orpc/openapi-client'

import { toast } from 'sonner'
import { contracts } from '@repo/contracts'
import { createORPCClient } from '@orpc/client'
import { OpenAPILink } from '@orpc/openapi-client/fetch'
import { createORPCReactQueryUtils } from '@orpc/react-query'
import { QueryCache, QueryClient } from '@tanstack/react-query'

export const queryClient = new QueryClient({
  queryCache: new QueryCache({
    onError: (error) => {
      toast.error(`Error: ${error.message}`, {
        action: {
          label: 'retry',
          onClick: () => {
            queryClient.invalidateQueries()
          },
        },
      })
    },
  }),
})

// Use OpenAPILink which is designed to work with OpenAPIHandler
export const link = new OpenAPILink(contracts, {
  url: 'http://localhost:8000/api',
  headers: () => ({
    'Content-Type': 'application/json',
  }),
})

// Cliente ORPC para chamadas imperativas
export const orpcClient: JsonifiedClient<ContractRouterClient<typeof contracts>> =
  createORPCClient(link)

// Cliente ORPC com React Query hooks
export const orpc = createORPCReactQueryUtils(orpcClient)

[DIEGOHORVATTI]

@DIEGOHORVATTI Please use OpenAPIHandler

using oRPC is a love-hate cycle haahah but after that it's all good, (it's all good)

the ORPC is sooo beautiful

import { pub } from '@repo/service-core'
import { getAnimal, listAnimals, createAnimal, deleteAnimal, updateAnimal } from '@/container'

export const listAnimalsRoute = pub.animals.listAnimals.handler(async ({ input }) => {
  const result = await listAnimals(input.page, input.limit)

  return result
})

export const getAnimalRoute = pub.animals.getAnimal.handler(async ({ input }) => {
  const result = await getAnimal(input.id)

  return result
})

export const createAnimalRoute = pub.animals.createAnimal.handler(async ({ input }) => {
  const result = await createAnimal(input)

  return result
})

export const updateAnimalRoute = pub.animals.updateAnimal.handler(
  async ({ input: { id, data } }) => {
    const result = await updateAnimal(id, data)

    return result
  }
)

export const deleteAnimalRoute = pub.animals.deleteAnimal.handler(async ({ input: { id } }) => {
  const result = await deleteAnimal(id)

  return result
})