[Components] Mews

Author: jcortes

components/mews/actions/cancel-reservation/cancel-reservation.mjs

@@ -0,0 +1,32 @@
+import app from "../../mews.app.mjs";
+
+export default {
+  name: "Cancel Reservation",
+  description: "Cancel a reservation in Mews.",
+  key: "mews-cancel-reservation",
+  version: "0.0.1",
+  type: "action",
+  props: {
+    app,
+    reservationIds: {
+      type: "string[]",
+      label: "Reservation IDs",
+      description: "IDs of reservations to cancel",
+    },
+  },
+  async run({ $ }) {
+    const {
+      app: mews, reservationIds,
+    } = this;
+    const data = {
+      ReservationIds: reservationIds,
+    };
+    const response = await mews.reservationsCancel({
+      data,
+      $,
+    });
+    $.export("summary", `Cancelled ${reservationIds.length} reservation(s)`);
+    return response;
+  },
+};
+

components/mews/actions/create-reservation/create-reservation.mjs

@@ -0,0 +1,33 @@
+import app from "../../mews.app.mjs";
+
+export default {
+  name: "Create Reservation",
+  description: "Create a reservation in Mews.",
+  key: "mews-create-reservation",
+  version: "0.0.1",
+  type: "action",
+  props: {
+    app,
+    reservations: {
+      type: "string[]",
+      label: "Reservations (JSON)",
+      description: "Array of reservation objects as JSON strings, each per Mews API schema.",
+    },
+  },
+  async run({ $ }) {
+    const { app: mews } = this;
+    const reservations = (this.reservations || []).map((r) => {
+      try { return JSON.parse(r); } catch { return r; }
+    });
+    const data = {
+      Reservations: reservations,
+    };
+    const response = await mews.reservationsCreate({
+      data,
+      $,
+    });
+    $.export("summary", `Created ${reservations.length} reservation(s)`);
+    return response;
+  },
+};
+

components/mews/actions/fetch-customers/fetch-customers.mjs

@@ -0,0 +1,37 @@
+import app from "../../mews.app.mjs";
+import utils from "../../common/uilts.mjs";
+
+export default {
+  name: "Fetch Customers",
+  description: "Retrieve customers using Mews Connector API. [See the documentation](https://mews-systems.gitbook.io/connector-api/operations/customers#get-all-customers)",
+  key: "mews-fetch-customers",
+  version: "0.0.1",
+  type: "action",
+  props: {
+    app,
+    additionalFields: {
+      propDefinition: [
+        app,
+        "additionalFields",
+      ],
+    },
+  },
+  async run({ $ }) {
+    const {
+      app,
+      additionalFields,
+    } = this;
+
+    const items = await app.paginate({
+      requester: app.customersGetAll,
+      requesterArgs: {
+        $,
+        data: utils.parseJson(additionalFields),
+      },
+      resultKey: "Customers",
+    });
+    $.export("summary", `Successfully fetched ${items.length} customers`);
+    return items;
+  },
+};
+

components/mews/actions/fetch-order-items/fetch-order-items.mjs

@@ -0,0 +1,37 @@
+import app from "../../mews.app.mjs";
+import utils from "../../common/uilts.mjs";
+
+export default {
+  name: "Fetch Order Items",
+  description: "Retrieve order items using Mews Connector API. [See the documentation](https://mews-systems.gitbook.io/connector-api/operations/orderitems#get-all-order-items)",
+  key: "mews-fetch-order-items",
+  version: "0.0.1",
+  type: "action",
+  props: {
+    app,
+    additionalFields: {
+      propDefinition: [
+        app,
+        "additionalFields",
+      ],
+    },
+  },
+  async run({ $ }) {
+    const {
+      app,
+      additionalFields,
+    } = this;
+
+    const items = await app.paginate({
+      requester: app.orderItemsGetAll,
+      requesterArgs: {
+        $,
+        data: utils.parseJson(additionalFields),
+      },
+      resultKey: "OrderItems",
+    });
+    $.export("summary", `Successfully fetched ${items.length} order items`);
+    return items;
+  },
+};
+

components/mews/actions/fetch-products/fetch-products.mjs

@@ -0,0 +1,37 @@
+import app from "../../mews.app.mjs";
+import utils from "../../common/uilts.mjs";
+
+export default {
+  name: "Fetch Products",
+  description: "Retrieve products using Mews Connector API. [See the documentation](https://mews-systems.gitbook.io/connector-api/operations/products#get-all-products)",
+  key: "mews-fetch-products",
+  version: "0.0.1",
+  type: "action",
+  props: {
+    app,
+    additionalFields: {
+      propDefinition: [
+        app,
+        "additionalFields",
+      ],
+    },
+  },
+  async run({ $ }) {
+    const {
+      app,
+      additionalFields,
+    } = this;
+
+    const items = await app.paginate({
+      requester: app.productsGetAll,
+      requesterArgs: {
+        $,
+        data: utils.parseJson(additionalFields),
+      },
+      resultKey: "Products",
+    });
+    $.export("summary", `Successfully fetched ${items.length} products`);
+    return items;
+  },
+};
+

components/mews/actions/fetch-reservations/fetch-reservations.mjs

@@ -0,0 +1,38 @@
+import app from "../../mews.app.mjs";
+import utils from "../../common/uilts.mjs";
+
+export default {
+  name: "Fetch Reservations",
+  description: "Retrieve reservations using Mews Connector API. [See the documentation](https://mews-systems.gitbook.io/connector-api/operations/reservations#get-all-reservations-ver-2023-06-06)",
+  key: "mews-fetch-reservations",
+  version: "0.0.1",
+  type: "action",
+  props: {
+    app,
+    additionalFields: {
+      propDefinition: [
+        app,
+        "additionalFields",
+      ],
+    },
+  },
+  async run({ $ }) {
+    const {
+      app,
+      additionalFields,
+    } = this;
+
+    const items = await app.paginate({
+      requester: app.reservationsGetAll,
+      requesterArgs: {
+        $,
+        data: utils.parseJson(additionalFields),
+      },
+      resultKey: "Reservations",
+    });
+
+    $.export("summary", `Successfully fetched ${items.length} reservations`);
+    return items;
+  },
+};
+

components/mews/actions/update-reservation/update-reservation.mjs

@@ -0,0 +1,33 @@
+import app from "../../mews.app.mjs";
+
+export default {
+  name: "Update Reservation",
+  description: "Update an existing reservation in Mews.",
+  key: "mews-update-reservation",
+  version: "0.0.1",
+  type: "action",
+  props: {
+    app,
+    reservations: {
+      type: "string[]",
+      label: "Reservations (JSON)",
+      description: "Array of reservation objects with Id and fields to update, as JSON strings.",
+    },
+  },
+  async run({ $ }) {
+    const { app: mews } = this;
+    const reservations = (this.reservations || []).map((r) => {
+      try { return JSON.parse(r); } catch { return r; }
+    });
+    const data = {
+      Reservations: reservations,
+    };
+    const response = await mews.reservationsUpdate({
+      data,
+      $,
+    });
+    $.export("summary", `Updated ${reservations.length} reservation(s)`);
+    return response;
+  },
+};
+

components/mews/common/uilts.mjs

@@ -0,0 +1,44 @@
+const parseJson = (input, maxDepth = 100) => {
+  const seen = new WeakSet();
+  const parse = (value) => {
+    if (maxDepth <= 0) {
+      return value;
+    }
+    if (typeof(value) === "string") {
+      // Only parse if the string looks like a JSON object or array
+      const trimmed = value.trim();
+      if (
+        (trimmed.startsWith("{") && trimmed.endsWith("}")) ||
+        (trimmed.startsWith("[") && trimmed.endsWith("]"))
+      ) {
+        try {
+          return parseJson(JSON.parse(value), maxDepth - 1);
+        } catch (e) {
+          return value;
+        }
+      }
+      return value;
+    } else if (typeof(value) === "object" && value !== null && !Array.isArray(value)) {
+      if (seen.has(value)) {
+        return value;
+      }
+      seen.add(value);
+      return Object.entries(value)
+        .reduce((acc, [
+          key,
+          val,
+        ]) => Object.assign(acc, {
+          [key]: parse(val),
+        }), {});
+    } else if (Array.isArray(value)) {
+      return value.map((item) => parse(item));
+    }
+    return value;
+  };
+
+  return parse(input);
+};
+
+export default {
+  parseJson,
+};