Merge pull request #66 from saiichihashimoto/revert

fix(next): Revert "fix(next): export app router separately"

README.md

@@ -56,7 +56,7 @@ export const EmailQueue = Queue(
   }
 );
 
-export const POST = EmailQueue.handler;
+export const POST = EmailQueue;
 ```
 
 Up top, we're importing `Queue`, which is a function that we use to declare a new Queue and export it as default.

src/next-app.test.ts

@@ -52,7 +52,7 @@ describe("next-app", () => {
               process.nextTick(resolve);
             });
 
-            queueResponse = await queue.handler({
+            queueResponse = await queue({
               text: async () => body,
               headers: new Headers({
                 "x-zeplo-id": "foo",
@@ -433,7 +433,7 @@ describe("next-app", () => {
 
   it("calls queue inline instead of waiting with mode=direct", async () => {
     fetchSpy.mockImplementation(async (input, { body, headers = {} } = {}) => {
-      queueResponse = await queue.handler({
+      queueResponse = await queue({
         text: async () => body,
         headers: new Headers({
           ...(!("X-Zeplo-Id" in headers)

src/next-app.ts

@@ -11,10 +11,9 @@ export const Queue = <Payload>(
 ) => {
   const zeplo = ZeploClient({ handler, route, options });
 
-  return {
-    enqueue: async (payload: Payload, options?: EnqueueOptions<Payload>) =>
-      zeplo.enqueue(payload, options),
-    handler: (async (req) => {
+  // eslint-disable-next-line fp/no-mutating-assign -- HACK
+  return Object.assign(
+    (async (req) => {
       const { status, body } = await zeplo.respondTo(
         await req.text(),
         Object.fromEntries(req.headers.entries())
@@ -28,5 +27,9 @@ export const Queue = <Payload>(
         { status }
       );
     }) satisfies (req: NextRequest) => Promise<NextResponse<string>>,
-  };
+    {
+      enqueue: async (payload: Payload, options?: EnqueueOptions<Payload>) =>
+        zeplo.enqueue(payload, options),
+    }
+  );
 };