import {
  router,
  publicProcedure,
  createCallerFactory,
} from "../../trpc/server";
import { createCaller as createConversationsCaller } from "./conversations.js";

export const messages = router({
  fetchByConversationId: publicProcedure
    .input((x) => x as { conversationId: string })
    .query(async ({ input: { conversationId } }) => {
      const caller = createConversationsCaller({});
      return await caller.fetchMessages({
        conversationId,
      });
    }),
});

export const createCaller = createCallerFactory(messages);