fs.ts

import { container } from "../../di/container";
import { MAIN_TOKENS } from "../../di/tokens";
import {
  fileExistsOutput,
  listRepoFilesInput,
  listRepoFilesOutput,
  readAbsoluteFileInput,
  readRepoFileInput,
  readRepoFileOutput,
  writeRepoFileInput,
} from "../../services/fs/schemas";
import type { FsService } from "../../services/fs/service";
import { publicProcedure, router } from "../trpc";

const getService = () => container.get<FsService>(MAIN_TOKENS.FsService);

export const fsRouter = router({
  listRepoFiles: publicProcedure
    .input(listRepoFilesInput)
    .output(listRepoFilesOutput)
    .query(({ input }) =>
      getService().listRepoFiles(input.repoPath, input.query, input.limit),
    ),

  readRepoFile: publicProcedure
    .input(readRepoFileInput)
    .output(readRepoFileOutput)
    .query(({ input }) =>
      getService().readRepoFile(input.repoPath, input.filePath),
    ),

  readAbsoluteFile: publicProcedure
    .input(readAbsoluteFileInput)
    .output(readRepoFileOutput)
    .query(({ input }) => getService().readAbsoluteFile(input.filePath)),

  fileExists: publicProcedure
    .input(readAbsoluteFileInput)
    .output(fileExistsOutput)
    .query(({ input }) => getService().fileExists(input.filePath)),

  readFileAsBase64: publicProcedure
    .input(readAbsoluteFileInput)
    .output(readRepoFileOutput)
    .query(({ input }) => getService().readFileAsBase64(input.filePath)),

  writeRepoFile: publicProcedure
    .input(writeRepoFileInput)
    .mutation(({ input }) =>
      getService().writeRepoFile(input.repoPath, input.filePath, input.content),
    ),
});