feat: add Shopify orders create webhook payload and event classes

Author: nicosammito

actions/shopify-action/src/data_types/shopifyOrdersCreateWebhookPayload.ts

@@ -0,0 +1,11 @@
+import {Identifier, Name, Schema} from "@code0-tech/hercules";
+import {schemaForWebhook} from "shopify-webhook-schemas";
+import { z } from "zod";
+
+const schema = schemaForWebhook("2026-04", "orders/create");
+const ShopifyOrdersCreatePayloadSchema = z.fromJSONSchema(schema);
+
+@Identifier("ShopifyOrdersCreateWebhookPayload")
+@Name({ code: "en-US", content: "ShopifyOrdersCreateWebhookPayload" })
+@Schema(ShopifyOrdersCreatePayloadSchema)
+export class ShopifyOrdersCreateWebhookPayload {}

actions/shopify-action/src/events/shopifyOrdersCreateWebhook.ts

@@ -0,0 +1,21 @@
+import {DisplayIcon, DisplayMessage, EventSetting, Identifier, Rest, Signature} from "@code0-tech/hercules";
+
+@Identifier("ShopifyOrdersCreateWebhook")
+@DisplayIcon("simple:shopify")
+@DisplayMessage({ code: "en-US", content: "Shopify orders create on ${httpURL}" })
+@Signature("<A extends REST_AUTH_TYPE>(httpSchema: HTTP_SCHEMA, httpURL: HTTP_URL, httpMethod: HTTP_METHOD, httpAuth: A, httpAuthValue: REST_AUTH_VALUE<A>, input_schema?: ShopifyOrdersCreateWebhookPayload): REST_ADAPTER_INPUT<ShopifyOrdersCreateWebhookPayload>")
+@EventSetting({
+    identifier: "input_schema",
+    hidden: true
+})
+@EventSetting({
+    identifier: "httpMethod",
+    hidden: true,
+    defaultValue: "POST"
+})
+@EventSetting({
+    identifier: "httpSchema",
+    hidden: true,
+    defaultValue: "application/json"
+})
+export class ShopifyOrdersCreateWebhook extends Rest {}

actions/shopify-action/src/index.ts

@@ -0,0 +1,43 @@
+import {Action, CodeZeroEvent} from "@code0-tech/hercules";
+import {ShopifyOrdersCreateWebhookPayload} from "./data_types/shopifyOrdersCreateWebhookPayload.ts";
+import {ShopifyOrdersCreateWebhook} from "./events/shopifyOrdersCreateWebhook.ts";
+
+const action = new Action(
+    process.env.ACTION_ID ?? "shopify-action",
+    process.env.VERSION ?? "1.0.0",
+    process.env.AQUILA_URL ?? "127.0.0.1:8081",
+    "code0-tech",
+    "simple:shopify",
+    "",
+    [{code: "en-US", content: "Shopify"}],
+    []
+)
+
+action.registerDataTypeClass(ShopifyOrdersCreateWebhookPayload)
+action.registerEventClass(ShopifyOrdersCreateWebhook)
+
+action.on(CodeZeroEvent.connected, () => {
+    console.log("Connected to aquila");
+});
+
+action.on(CodeZeroEvent.error, (error: Error) => {
+    console.error("Stream error:", error.message);
+    console.log("Attempting to reconnect in 5s...");
+    setTimeout(() => {
+        action.connect(process.env.AUTH_TOKEN ?? "your_auth_token_here").catch((err: unknown) => {
+            console.error("Reconnect failed:", err);
+        });
+    }, 5000);
+});
+
+action.connect(process.env.AUTH_TOKEN ?? "your_auth_token_here").catch((err: unknown) => {
+    console.error("Failed to connect:", err);
+    process.exit(1);
+});
+
+action.on(CodeZeroEvent.moduleUpdated, (message: any) => {
+    console.dir(message, {depth: null});
+    console.dir(action.configs.values(), {depth: null})
+})
+
+export {action};