apps/engine/src/routes/transactions/index.ts

import type { Bindings } from "@engine/common/bindings";
import { ErrorSchema } from "@engine/common/schema";
import { Provider } from "@engine/providers";
import { createErrorResponse } from "@engine/utils/error";
import { createRoute, OpenAPIHono } from "@hono/zod-openapi";
import { env } from "hono/adapter";
import { TransactionsParamsSchema, TransactionsSchema } from "./schema";

const app = new OpenAPIHono<{ Bindings: Bindings }>().openapi(
  createRoute({
    method: "get",
    path: "/",
    summary: "Get transactions",
    request: {
      query: TransactionsParamsSchema,
    },
    responses: {
      200: {
        content: {
          "application/json": {
            schema: TransactionsSchema,
          },
        },
        description: "Retrieve transactions",
      },
      400: {
        content: {
          "application/json": {
            schema: ErrorSchema,
          },
        },
        description: "Returns an error",
      },
    },
  }),
  async (c) => {
    const envs = env(c);
    const { provider, accountId, accountType, latest, accessToken } =
      c.req.valid("query");

    const api = new Provider({
      provider,
      fetcher: c.env.TELLER_CERT,
      kv: c.env.KV,
      envs,
    });

    try {
      const data = await api.getTransactions({
        accountId,
        accessToken,
        accountType,
        latest,
      });

      return c.json(
        {
          data,
        },
        200,
      );
    } catch (error) {
      const errorResponse = createErrorResponse(error);

      return c.json(errorResponse, 400);
    }
  },
);

export default app;