console: added notifications endpoint

Author: absorbb

webapps/console/lib/server/clickhouse.ts

@@ -19,3 +19,7 @@ export const clickhouse = createClient({
     response: true,
   },
 });
+
+export function dateToClickhouse(date: Date): string {
+  return date.toISOString().replace("T", " ").replace("Z", "").split(".")[0];
+}

webapps/console/pages/api/[workspaceId]/reports/active-events.ts

@@ -1,6 +1,6 @@
 import { z } from "zod";
 import { createRoute, verifyAccess, getWorkspace } from "../../../../lib/api";
-import { clickhouse } from "../../../../lib/server/clickhouse";
+import { clickhouse, dateToClickhouse } from "../../../../lib/server/clickhouse";
 import dayjs from "dayjs";
 import utc from "dayjs/plugin/utc";
 import { getServerLog } from "../../../../lib/server/log";
@@ -33,8 +33,8 @@ export default createRoute()
     await verifyAccess(user, workspace.id);
     const metricsSchema =
       process.env.CLICKHOUSE_METRICS_SCHEMA || process.env.CLICKHOUSE_DATABASE || "newjitsu_metrics";
-    const end = query.end ? query.end.toISOString() : new Date().toISOString();
-    const start = query.start ? query.start.toISOString() : dayjs(end).subtract(1, "month").toDate().toISOString();
+    const end = query.end || new Date();
+    const start = query.start || dayjs(end).subtract(1, "month").toDate();
 
     const sql = `
         select
@@ -54,8 +54,8 @@ export default createRoute()
       await clickhouse.query({
         query: sql,
         query_params: {
-          start: isoDateTOClickhouse(start),
-          end: isoDateTOClickhouse(end),
+          start: dateToClickhouse(start),
+          end: dateToClickhouse(end),
           workspace: workspace.id,
           granularity: query.granularity,
         },
@@ -77,7 +77,3 @@ export default createRoute()
     };
   })
   .toNextApiHandler();
-
-function isoDateTOClickhouse(date: string): string {
-  return date.replace("T", " ").replace("Z", "").split(".")[0];
-}

webapps/console/pages/api/admin/events-log-init.ts

@@ -12,7 +12,7 @@ export default createRoute()
       token: z.string().optional(),
     }),
   })
-  .handler(async ({ req, res, query, user }) => {
+  .handler(async ({ req, res, query }) => {
     let initTokenUsed = false;
     if (process.env.CONSOLE_INIT_TOKEN && query.token) {
       if (checkRawToken(process.env.CONSOLE_INIT_TOKEN, query.token)) {