support-db

src/api.ts

@@ -16,6 +16,7 @@ export const { inject: injectUrl, access: accessUrl } = context((): string => {
 
 type Medium =
   | "whatsapp"
+  | "instantdb"
   | "green-api"
   | "telegram"
   | "websocket"

src/database.ts

@@ -0,0 +1,23 @@
+import type { TaskHandler } from "./api.ts";
+import type { Endpoint } from "./taskBouncer.ts";
+import { makeKey, now, websocketInject } from "./websocket.ts";
+
+type ClientRequest = { from: string; text: string };
+
+export const makeInstantDbHandler = (
+    storer: <T>(value: T) => Promise<void>,
+    doTask: TaskHandler,
+    path: string,
+    botName: string,
+): Endpoint => ({
+    bounce: true,
+    method: "POST",
+    path,
+    handler: async ({ from, text }: ClientRequest) => {
+        await storer({ from, key: makeKey(), text, time: now() });
+        return websocketInject(
+            (x) => storer({ ...x, time: now(), from: botName }),
+            from,
+        )(doTask)({ text });
+    },
+});

src/index.ts

@@ -1,5 +1,6 @@
 export * from "./api.ts";
 export * from "./greenApi.ts";
+export * from "./database.ts";
 export * from "./taskBouncer.ts";
 export * from "./telegram.ts";
 export * from "./websocket.ts";

src/telegram.ts

@@ -127,7 +127,7 @@ export const sendTelegramMessage = (token: string) =>
   );
 
 export const setTelegramWebhook = (token: string, url: string) =>
-  fetch(tokenToTelegramURL(token) + `setWebhook?url=${url}`);
+  fetch(`${tokenToTelegramURL(token)}setWebhook?url=${url}`);
 
 const fileIdToContentBase64 =
   (token: string) => async (fileId: string): Promise<string> => {
@@ -158,7 +158,7 @@ const sharedOwnPhone = (
 ) => (user_id === ownId) ? phone_number : undefined;
 
 const contactToFullName = ({ first_name, last_name }: grammy.Contact) =>
-  first_name + (last_name ? " " + last_name : "");
+  first_name + (last_name ? ` ${last_name}` : "");
 
 export const getBestPhoneFromContactShared = ({
   phone_number,
@@ -210,7 +210,9 @@ export const makeTelegramHandler = (
           letIn(
             {
               id: message.from.id,
-              tgm: new Telegraf(telegramToken, { handlerTimeout: Number.POSITIVE_INFINITY })
+              tgm: new Telegraf(telegramToken, {
+                handlerTimeout: Number.POSITIVE_INFINITY,
+              })
                 .telegram,
             },
             ({ id, tgm }) =>

src/websocket.ts

@@ -28,9 +28,11 @@ type Manager = {
   buffered: Record<string, WeboscketMessage[]>;
 };
 
-const makeKey = () => crypto.randomUUID();
+export const makeKey = () => crypto.randomUUID();
 
-const inject = <T extends TaskHandler>(
+export const now = () => Date.now();
+
+export const websocketInject = <T extends TaskHandler>(
   send: (x: WeboscketMessage) => Promise<void>,
   userId: string,
 ) =>
@@ -61,7 +63,7 @@ const inject = <T extends TaskHandler>(
 const jsonOnSocket = <T>(msg: T) => (socket: WebSocket) =>
   new Promise<void>((resolve) =>
     socket.send(
-      JSON.stringify({ timestamp: Date.now(), ...msg }),
+      JSON.stringify({ timestamp: now(), ...msg }),
       () => resolve(),
     )
   );
@@ -129,7 +131,7 @@ export const setupWebsocketOnServer = (
       const { uniqueId, humanReadableId } = loginResult;
       addSocket(ws, uniqueId);
       if (!text) return;
-      inject(sendToUser(uniqueId), humanReadableId)(doTask)({ text });
+      websocketInject(sendToUser(uniqueId), humanReadableId)(doTask)({ text });
     });
     ws.on("close", () => {
       removeSocket(ws);