custom-predicate

example/example.ts

@@ -22,7 +22,7 @@ const whatsappPath = "/whatsapp-url-suffix";
 const handleMessage = async (task: AbstractIncomingMessage) => {
   console.log("got task", task);
   await withSpinner("waiting needlessly", sleep)(5000);
-  return reply("hi there i got " + JSON.stringify(task));
+  return reply(`hi there i got ${JSON.stringify(task)}`);
 };
 
 const url = coerce(Deno.env.get("URL"));

src/database.ts

@@ -12,8 +12,7 @@ export const makeDatabaseHandler = (
     authenticate: (token: string, userId: string) => Promise<boolean>,
 ): Endpoint => ({
     bounce: true,
-    method: "POST",
-    path,
+    predicate: ({ url, method }) => url === path && method === "POST",
     handler: async ({ from, text, token }: ClientRequest) => {
         if (!await authenticate(token, from)) return;
         await storer({ from, to: botName, key: makeKey(), text, time: now() });

src/greenApi.ts

@@ -142,8 +142,7 @@ export const greenApiHandler = (
   doTask: TaskHandler,
 ): Endpoint => ({
   bounce: true,
-  method: "POST",
-  path,
+  predicate: ({ url, method }) => url === path && method === "POST",
   handler: (msg: GreenApiMessage) =>
     communications(
       greenApi.restAPI(credentials),

src/taskBouncer.ts

@@ -154,25 +154,21 @@ type Handler = (payload: Task["payload"]) => Promise<any>;
 export type Endpoint = {
   bounce: boolean;
   handler: Handler;
-  method: "POST" | "GET";
-  path: string;
+  predicate: (task: Task) => boolean;
 };
 
 export const bouncerHandler = (domain: string, endpoints: Endpoint[]) =>
   bouncer(
     domain,
     (task: Task) =>
-      endpoints.find(({ path, method }) =>
-        path === task.url && method === task.method
-      )?.bounce ?? false,
+      endpoints.find(({ predicate }) => predicate(task))?.bounce ?? false,
     (task: Task) => {
       for (
-        const { handler } of endpoints.filter(({ path, method }) =>
-          path === task.url && method === task.method
+        const { handler } of endpoints.filter(({ predicate }) =>
+          predicate(task)
         )
       ) return injectUrl(() => task.url)(handler)(task.payload);
-      console.log("no handler for request", task);
-      return Promise.resolve();
+      throw new Error("No handler for request");
     },
   );
 

src/telegram.test.ts

@@ -20,6 +20,6 @@ TEL;CELL;PREF:+${alicePhone}
 TEL;HOME:+97236746666
 END:VCARD`,
     }),
-    "+" + alicePhone,
+    `+${alicePhone}`,
   );
 });

src/telegram.ts

@@ -201,8 +201,7 @@ export const makeTelegramHandler = (
 ): Endpoint => (
   {
     bounce: true,
-    method: "POST",
-    path,
+    predicate: ({ url, method }) => url === path && method === "POST",
     handler: ({ message }: grammy.Update) =>
       message?.from && message.text
         ? pipe(

src/whatsapp.ts

@@ -274,9 +274,8 @@ export const whatsappWebhookVerificationHandler = (
   verifyToken: string,
   path: string,
 ): Endpoint => ({
-  method: "GET",
+  predicate: ({ url, method }) => url === path && method === "POST",
   bounce: false,
-  path,
   handler: (msg: WebhookVerification) =>
     (
         msg["hub.mode"] === "subscribe" &&
@@ -306,12 +305,11 @@ const getContacts = (
 
 export const whatsappBusinessHandler = (
   token: string,
-  whatsappPath: string,
+  path: string,
   doTask: TaskHandler,
 ): Endpoint => ({
   bounce: true,
-  method: "POST",
-  path: whatsappPath,
+  predicate: ({ url, method }) => url === path && method === "POST",
   handler: (msg: WhatsappMessage) =>
     msg.entry[0].changes[0].value.messages
       ? letIn(