Merge branch 'main' into feature/subtivity

src/fetch/history.ts

@@ -0,0 +1,25 @@
+import { makeQuery } from "../clickhouse/makeQuery.js";
+import { logger } from "../logger.js";
+import { UAWHistory, getUAWHistory } from "../queries.js";
+import * as prometheus from "../prometheus.js";
+import { BadRequest, toJSON } from "./cors.js";
+import { parseUAWResponse, verifyParameters } from "../utils.js";
+
+export default async function (req: Request) {
+  const parametersResult = await verifyParameters(req);
+  if(parametersResult instanceof Response) {
+    return parametersResult;
+  }
+  try {
+    const { searchParams } = new URL(req.url);
+    logger.info({searchParams: Object.fromEntries(Array.from(searchParams))});
+    const query = getUAWHistory(searchParams);
+    const response = await makeQuery<UAWHistory>(query)
+    const formatted = parseUAWResponse(response.data);
+    return toJSON(formatted);
+  } catch (e: any) {
+    logger.error(e);
+    prometheus.request_error.inc({pathname: "/uaw/history", status: 400});
+    return BadRequest
+  }
+}

src/fetch/uaw.ts

@@ -0,0 +1,24 @@
+import { makeQuery } from "../clickhouse/makeQuery.js";
+import { logger } from "../logger.js";
+import { getUAWFromDate } from "../queries.js";
+import * as prometheus from "../prometheus.js";
+import { BadRequest, toJSON } from "./cors.js";
+import { verifyParameters } from "../utils.js";
+
+export default async function (req: Request) {
+  const parametersResult = await verifyParameters(req);
+  if(parametersResult instanceof Response) {
+    return parametersResult;
+  }
+  try {
+    const { searchParams } = new URL(req.url);
+    logger.info({searchParams: Object.fromEntries(Array.from(searchParams))});
+    const query = getUAWFromDate(searchParams);
+    const response = await makeQuery<number>(query)
+    return toJSON(response.data);
+  } catch (e: any) {
+    logger.error(e);
+    prometheus.request_error.inc({pathname: "/uaw", status: 400});
+    return BadRequest
+  }
+}

src/utils.spec.ts

@@ -2,6 +2,7 @@ import { expect, test } from "bun:test";
 import { parseBlockId, parseBlockNumber, parseChain, parseLimit, parseSortBy,
      parseTimestamp, parseAggregateFunction, parseHistoryRange } from "./utils.js";
 import { DEFAULT_MAX_LIMIT, DEFAULT_SORT_BY } from "./config.js";
+import { parse } from "querystring";
 
 test("parseBlockId", () => {
     expect(parseBlockId()).toBeUndefined();