Add new Adapter and Action interfaces, add new Next.js handler implementation, remove middlewares

.changeset/hip-queens-roll.md

@@ -0,0 +1,5 @@
+---
+"@saleor/app-sdk": patch
+---
+
+Removed `/middlewares`, you should use `/handlers` instead.

.changeset/kind-zoos-raise.md

@@ -0,0 +1,9 @@
+---
+"@saleor/app-sdk": major
+---
+
+Removed deprecated fields fields and methods in `/handlers`:
+
+- `SaleorAsyncWebhook` and `SaleorSyncWebhook` - removed `asyncEvent` and `subscriptionQueryAst`
+- Removed `processSaleorWebhook` and `processProtectedHandler` methods
+- Some types were moved from `/next` to `/shared`

.changeset/sixty-taxis-glow.md

@@ -0,0 +1,7 @@
+---
+"@saleor/app-sdk": patch
+---
+
+Added abstract `PlatformAdapterInterface` and `ActionHandlerInterface` to enable cross-framework handler implementations.
+
+Next.js handlers were rewritten to use the new interface.

.changeset/tough-socks-tease.md

@@ -2,4 +2,4 @@
 "@saleor/app-sdk": major
 ---
 
-Breaking change: Remove checking "domain" header from Saleor requests. It should be replaced with the "saleor-api-url" header.
+Breaking change: SDK will no longer check `saleor-domain` header when validating Saleor requests, instead it will check `saleor-api-url` header.

package.json

@@ -41,7 +41,6 @@
     "debug": "4.3.4",
     "jose": "4.14.4",
     "raw-body": "2.5.2",
-    "retes": "0.33.0",
     "uuid": "9.0.0"
   },
   "devDependencies": {
@@ -126,11 +125,6 @@
       "import": "./settings-manager/index.mjs",
       "require": "./settings-manager/index.js"
     },
-    "./middleware": {
-      "types": "./middleware/index.d.ts",
-      "import": "./middleware/index.mjs",
-      "require": "./middleware/index.js"
-    },
     "./urls": {
       "types": "./urls.d.ts",
       "import": "./urls.mjs",

src/handlers/actions/manifest-action-handler.test.ts

@@ -0,0 +1,81 @@
+import { beforeEach, describe, expect, it, vi } from "vitest";
+
+import { SALEOR_SCHEMA_VERSION } from "@/const";
+import { MockAdapter } from "@/test-utils/mock-adapter";
+import { AppManifest } from "@/types";
+
+import { ManifestActionHandler } from "./manifest-action-handler";
+
+describe("ManifestActionHandler", () => {
+  const mockManifest: AppManifest = {
+    id: "test-app",
+    name: "Test Application",
+    version: "1.0.0",
+    appUrl: "http://example.com",
+    permissions: [],
+    tokenTargetUrl: "http://example.com/token",
+  };
+
+  let adapter: MockAdapter;
+
+  beforeEach(() => {
+    adapter = new MockAdapter({
+      mockHeaders: {
+        [SALEOR_SCHEMA_VERSION]: "3.20",
+      },
+      baseUrl: "http://example.com",
+    });
+    adapter.method = "GET";
+  });
+
+  it("should call manifest factory and return 200 status when it resolves", async () => {
+    const handler = new ManifestActionHandler(adapter);
+    const manifestFactory = vi.fn().mockResolvedValue(mockManifest);
+
+    const result = await handler.handleAction({ manifestFactory });
+
+    expect(result.status).toBe(200);
+    expect(result.body).toEqual(mockManifest);
+    expect(manifestFactory).toHaveBeenCalledWith({
+      appBaseUrl: "http://example.com",
+      request: {},
+      schemaVersion: 3.20,
+    });
+  });
+
+  it("should call manifest factory and return 500 when it throws an error", async () => {
+    const handler = new ManifestActionHandler(adapter);
+    const manifestFactory = vi.fn().mockRejectedValue(new Error("Test error"));
+
+    const result = await handler.handleAction({ manifestFactory });
+
+    expect(result.status).toBe(500);
+    expect(result.body).toBe("Error resolving manifest file.");
+  });
+
+  it("should return 405 when not called using HTTP GET method", async () => {
+    adapter.method = "POST";
+    const handler = new ManifestActionHandler(adapter);
+
+    const manifestFactory = vi.fn().mockResolvedValue(mockManifest);
+
+    const result = await handler.handleAction({ manifestFactory });
+
+    expect(result.status).toBe(405);
+    expect(result.body).toBe("Method not allowed");
+    expect(manifestFactory).not.toHaveBeenCalled();
+  })
+
+  it("should return 400 when receives null schema version header from unsupported legacy Saleor version", async () => {
+    adapter.getHeader = vi.fn().mockReturnValue(null);
+    const handler = new ManifestActionHandler(adapter);
+
+    const manifestFactory = vi.fn().mockResolvedValue(mockManifest);
+
+    const result = await handler.handleAction({ manifestFactory });
+
+    expect(result.status).toBe(400);
+    expect(result.body).toBe("Missing schema version header");
+    expect(manifestFactory).not.toHaveBeenCalled();
+  });
+});

src/handlers/actions/manifest-action-handler.ts

@@ -0,0 +1,71 @@
+import { createDebug } from "@/debug";
+import { AppManifest } from "@/types";
+
+import {
+  ActionHandlerInterface,
+  ActionHandlerResult,
+  PlatformAdapterInterface,
+} from "../shared/generic-adapter-use-case-types";
+import { SaleorRequestProcessor } from "../shared/saleor-request-processor";
+
+const debug = createDebug("create-manifest-handler");
+
+export type CreateManifestHandlerOptions<T> = {
+  manifestFactory(context: {
+    appBaseUrl: string;
+    request: T;
+    /** Added in Saleor 3.15 */
+    schemaVersion: number;
+  }): AppManifest | Promise<AppManifest>;
+};
+
+export class ManifestActionHandler<I> implements ActionHandlerInterface {
+  constructor(private adapter: PlatformAdapterInterface<I>) {}
+
+  private requestProcessor = new SaleorRequestProcessor(this.adapter);
+
+  async handleAction(options: CreateManifestHandlerOptions<I>): Promise<ActionHandlerResult> {
+    const { schemaVersion } = this.requestProcessor.getSaleorHeaders();
+    const baseURL = this.adapter.getBaseUrl();
+
+    debug("Received request with schema version \"%s\" and base URL \"%s\"", schemaVersion, baseURL);
+
+    const invalidMethodResponse = this.requestProcessor.withMethod(["GET"]);
+
+    if (invalidMethodResponse) {
+      return invalidMethodResponse;
+    }
+
+    if (!schemaVersion) {
+      return {
+        status: 400,
+        bodyType: "string",
+        body: "Missing schema version header",
+      };
+    }
+
+    try {
+      const manifest = await options.manifestFactory({
+        appBaseUrl: baseURL,
+        request: this.adapter.request,
+        schemaVersion,
+      });
+
+      debug("Executed manifest file");
+
+      return {
+        status: 200,
+        bodyType: "json",
+        body: manifest,
+      };
+    } catch (e) {
+      debug("Error while resolving manifest: %O", e);
+
+      return {
+        status: 500,
+        bodyType: "string",
+        body: "Error resolving manifest file.",
+      };
+    }
+  }
+}