From 9366c6d468002076dcc451d07620113601d1dba7 Mon Sep 17 00:00:00 2001
From: "Carlos R. L. Rodrigues"
 <37986729+carlos-r-l-rodrigues@users.noreply.github.com>
Date: Sun, 14 Dec 2025 08:02:53 -0300
Subject: [PATCH] feat: order export and upload stream (#14243)

* feat: order export

* Merge branch 'develop' of https://github.com/medusajs/medusa into feat/order-export

* normalize status

* rm util

* serialize totals

* test

* lock

* comments

* configurable order list
---
 .../dashboard-app/routes/get-route.map.tsx    |   6 +
 .../admin/dashboard/src/hooks/api/orders.tsx  |  19 +-
 .../src/i18n/translations/$schema.json        |  40 ++++
 .../dashboard/src/i18n/translations/en.json   |  12 ++
 .../components/export-filters.tsx             |  22 +++
 .../src/routes/orders/order-export/index.ts   |   1 +
 .../orders/order-export/order-export.tsx      |  66 +++++++
 .../configurable-order-list-table.tsx         |  20 +-
 .../order-list-table/order-list-table.tsx     |  10 +-
 .../src/order/steps/export-orders.ts          | 178 ++++++++++++++++++
 .../core/core-flows/src/order/steps/index.ts  |   3 +-
 .../src/order/workflows/export-orders.ts      | 142 ++++++++++++++
 .../core-flows/src/order/workflows/index.ts   |   5 +-
 packages/core/js-sdk/src/admin/order.ts       |  34 +++-
 packages/core/types/src/file/provider.ts      |  34 +++-
 packages/core/types/src/file/service.ts       |  21 ++-
 .../types/src/http/order/admin/responses.ts   |   7 +
 .../utils/src/file/abstract-file-provider.ts  |  32 +++-
 .../src/api/admin/orders/export/route.ts      |  20 ++
 .../src/api/admin/orders/middlewares.ts       |  10 +
 .../src/api/admin/orders/query-config.ts      |  30 +++
 .../file/src/services/file-module-service.ts  |  29 ++-
 .../src/services/file-provider-service.ts     |  11 +-
 .../__fixtures__/catphoto.jpg                 | Bin 0 -> 24003 bytes
 .../__tests__/services.spec.ts                | 119 ++++++++++++
 .../modules/providers/file-local/package.json |   1 +
 .../file-local/src/services/local-file.ts     |  57 +++++-
 .../__tests__/services.spec.ts                |  48 ++++-
 .../modules/providers/file-s3/package.json    |   1 +
 .../providers/file-s3/src/services/s3-file.ts |  54 +++++-
 yarn.lock                                     |  46 ++++-
 31 files changed, 1041 insertions(+), 37 deletions(-)
 create mode 100644 packages/admin/dashboard/src/routes/orders/order-export/components/export-filters.tsx
 create mode 100644 packages/admin/dashboard/src/routes/orders/order-export/index.ts
 create mode 100644 packages/admin/dashboard/src/routes/orders/order-export/order-export.tsx
 create mode 100644 packages/core/core-flows/src/order/steps/export-orders.ts
 create mode 100644 packages/core/core-flows/src/order/workflows/export-orders.ts
 create mode 100644 packages/medusa/src/api/admin/orders/export/route.ts
 create mode 100644 packages/modules/providers/file-local/integration-tests/__fixtures__/catphoto.jpg
 create mode 100644 packages/modules/providers/file-local/integration-tests/__tests__/services.spec.ts

diff --git a/packages/admin/dashboard/src/dashboard-app/routes/get-route.map.tsx b/packages/admin/dashboard/src/dashboard-app/routes/get-route.map.tsx
index e2a7732707..182bf48bb4 100644
--- a/packages/admin/dashboard/src/dashboard-app/routes/get-route.map.tsx
+++ b/packages/admin/dashboard/src/dashboard-app/routes/get-route.map.tsx
@@ -300,6 +300,12 @@ export function getRouteMap({
                 {
                   path: "",
                   lazy: () => import("../../routes/orders/order-list"),
+                  children: [
+                    {
+                      path: "export",
+                      lazy: () => import("../../routes/orders/order-export"),
+                    },
+                  ],
                 },
                 {
                   path: ":id",
diff --git a/packages/admin/dashboard/src/hooks/api/orders.tsx b/packages/admin/dashboard/src/hooks/api/orders.tsx
index d7bfffe7ac..299f75d80b 100644
--- a/packages/admin/dashboard/src/hooks/api/orders.tsx
+++ b/packages/admin/dashboard/src/hooks/api/orders.tsx
@@ -10,8 +10,8 @@ import {
 import { sdk } from "../../lib/client"
 import { queryClient } from "../../lib/query-client"
 import { queryKeysFactory, TQueryKey } from "../../lib/query-key-factory"
-import { reservationItemsQueryKeys } from "./reservations"
 import { inventoryItemsQueryKeys } from "./inventory"
+import { reservationItemsQueryKeys } from "./reservations"
 
 const ORDERS_QUERY_KEY = "orders" as const
 const _orderKeys = queryKeysFactory(ORDERS_QUERY_KEY) as TQueryKey<"orders"> & {
@@ -438,3 +438,20 @@ export const useUpdateOrderChange = (
     ...options,
   })
 }
+
+export const useExportOrders = (
+  query?: HttpTypes.AdminOrderFilters,
+  options?: UseMutationOptions<
+    { transaction_id: string },
+    FetchError,
+    HttpTypes.AdminOrderFilters
+  >
+) => {
+  return useMutation({
+    mutationFn: () => sdk.admin.order.export(query),
+    onSuccess: (data, variables, context) => {
+      options?.onSuccess?.(data, variables, context)
+    },
+    ...options,
+  })
+}
diff --git a/packages/admin/dashboard/src/i18n/translations/$schema.json b/packages/admin/dashboard/src/i18n/translations/$schema.json
index d1da922930..cb547d3c13 100644
--- a/packages/admin/dashboard/src/i18n/translations/$schema.json
+++ b/packages/admin/dashboard/src/i18n/translations/$schema.json
@@ -4049,6 +4049,45 @@
           "required": ["noRecordsMessage"],
           "additionalProperties": false
         },
+        "export": {
+          "type": "object",
+          "properties": {
+            "header": {
+              "type": "string"
+            },
+            "description": {
+              "type": "string"
+            },
+            "success": {
+              "type": "object",
+              "properties": {
+                "title": {
+                  "type": "string"
+                },
+                "description": {
+                  "type": "string"
+                }
+              },
+              "required": ["title", "description"],
+              "additionalProperties": false
+            },
+            "filters": {
+              "type": "object",
+              "properties": {
+                "title": {
+                  "type": "string"
+                },
+                "description": {
+                  "type": "string"
+                }
+              },
+              "required": ["title", "description"],
+              "additionalProperties": false
+            }
+          },
+          "required": ["header", "description", "success", "filters"],
+          "additionalProperties": false
+        },
         "status": {
           "type": "object",
           "properties": {
@@ -5740,6 +5779,7 @@
         "orderCanceled",
         "onDateFromSalesChannel",
         "list",
+        "export",
         "status",
         "summary",
         "transfer",
diff --git a/packages/admin/dashboard/src/i18n/translations/en.json b/packages/admin/dashboard/src/i18n/translations/en.json
index 6c7ee59d6c..08a9b566c9 100644
--- a/packages/admin/dashboard/src/i18n/translations/en.json
+++ b/packages/admin/dashboard/src/i18n/translations/en.json
@@ -1080,6 +1080,18 @@
     "list": {
       "noRecordsMessage": "Your orders will show up here."
     },
+    "export": {
+      "header": "Export Order List",
+      "description": "Export the order list to a CSV file.",
+      "success": {
+        "title": "Export started",
+        "description": "You will be notified when the export is ready."
+      },
+      "filters": {
+        "title": "Filters",
+        "description": "The following filters will be applied to the export."
+      }
+    },
     "status": {
       "not_paid": "Not paid",
       "pending": "Pending",
diff --git a/packages/admin/dashboard/src/routes/orders/order-export/components/export-filters.tsx b/packages/admin/dashboard/src/routes/orders/order-export/components/export-filters.tsx
new file mode 100644
index 0000000000..594e28d939
--- /dev/null
+++ b/packages/admin/dashboard/src/routes/orders/order-export/components/export-filters.tsx
@@ -0,0 +1,22 @@
+import { Heading, Text } from "@medusajs/ui"
+import { useTranslation } from "react-i18next"
+import { DataTableFilter } from "../../../../components/table/data-table/data-table-filter"
+import { useOrderTableFilters } from "../../order-list/components/order-list-table/use-order-table-filters"
+
+export const ExportFilters = () => {
+  const { t } = useTranslation()
+  const filters = useOrderTableFilters()
+
+  return (
+    <div>
+      <Heading level="h2">{t("orders.export.filters.title")}</Heading>
+      <Text size="small" className="text-ui-fg-subtle">
+        {t("orders.export.filters.description")}
+      </Text>
+
+      <div className="mt-4">
+        <DataTableFilter filters={filters} readonly />
+      </div>
+    </div>
+  )
+}
diff --git a/packages/admin/dashboard/src/routes/orders/order-export/index.ts b/packages/admin/dashboard/src/routes/orders/order-export/index.ts
new file mode 100644
index 0000000000..7e1b227fb2
--- /dev/null
+++ b/packages/admin/dashboard/src/routes/orders/order-export/index.ts
@@ -0,0 +1 @@
+export { OrderExport as Component } from "./order-export"
diff --git a/packages/admin/dashboard/src/routes/orders/order-export/order-export.tsx b/packages/admin/dashboard/src/routes/orders/order-export/order-export.tsx
new file mode 100644
index 0000000000..a7ffbbeec2
--- /dev/null
+++ b/packages/admin/dashboard/src/routes/orders/order-export/order-export.tsx
@@ -0,0 +1,66 @@
+import { Button, Heading, toast } from "@medusajs/ui"
+import { useTranslation } from "react-i18next"
+import { RouteDrawer, useRouteModal } from "../../../components/modals"
+import { useExportOrders } from "../../../hooks/api"
+import { useOrderTableQuery } from "../../../hooks/table/query"
+import { ExportFilters } from "./components/export-filters"
+
+export const OrderExport = () => {
+  const { t } = useTranslation()
+
+  return (
+    <RouteDrawer>
+      <RouteDrawer.Header>
+        <RouteDrawer.Title asChild>
+          <Heading>{t("orders.export.header")}</Heading>
+        </RouteDrawer.Title>
+        <RouteDrawer.Description className="sr-only">
+          {t("orders.export.description")}
+        </RouteDrawer.Description>
+      </RouteDrawer.Header>
+      <OrderExportContent />
+    </RouteDrawer>
+  )
+}
+
+const OrderExportContent = () => {
+  const { t } = useTranslation()
+  const { searchParams } = useOrderTableQuery({})
+
+  const { mutateAsync } = useExportOrders(searchParams)
+  const { handleSuccess } = useRouteModal()
+
+  const handleExportRequest = async () => {
+    await mutateAsync(searchParams, {
+      onSuccess: () => {
+        toast.info(t("orders.export.success.title"), {
+          description: t("orders.export.success.description"),
+        })
+        handleSuccess()
+      },
+      onError: (err) => {
+        toast.error(err.message)
+      },
+    })
+  }
+
+  return (
+    <>
+      <RouteDrawer.Body>
+        <ExportFilters />
+      </RouteDrawer.Body>
+      <RouteDrawer.Footer>
+        <div className="flex items-center gap-x-2">
+          <RouteDrawer.Close asChild>
+            <Button size="small" variant="secondary">
+              {t("actions.cancel")}
+            </Button>
+          </RouteDrawer.Close>
+          <Button onClick={handleExportRequest} size="small">
+            {t("actions.export")}
+          </Button>
+        </div>
+      </RouteDrawer.Footer>
+    </>
+  )
+}
diff --git a/packages/admin/dashboard/src/routes/orders/order-list/components/order-list-table/configurable-order-list-table.tsx b/packages/admin/dashboard/src/routes/orders/order-list/components/order-list-table/configurable-order-list-table.tsx
index b5b5a5c8a8..10b4d05094 100644
--- a/packages/admin/dashboard/src/routes/orders/order-list/components/order-list-table/configurable-order-list-table.tsx
+++ b/packages/admin/dashboard/src/routes/orders/order-list/components/order-list-table/configurable-order-list-table.tsx
@@ -1,16 +1,24 @@
 import { useTranslation } from "react-i18next"
+import { Outlet, useLocation } from "react-router-dom"
+
 import { ConfigurableDataTable } from "../../../../../components/table/configurable-data-table"
 import { useOrderTableAdapter } from "./order-table-adapter"
 
 export const ConfigurableOrderListTable = () => {
   const { t } = useTranslation()
-  const orderAdapter = useOrderTableAdapter()
+  const location = useLocation()
+  const adapter = useOrderTableAdapter()
 
   return (
-    <ConfigurableDataTable
-      adapter={orderAdapter}
-      heading={t("orders.domain")}
-      layout="fill"
-    />
+    <>
+      <ConfigurableDataTable
+        adapter={adapter}
+        heading={t("orders.domain")}
+        actions={[
+          { label: t("actions.export"), to: `export${location.search}` },
+        ]}
+      />
+      <Outlet />
+    </>
   )
 }
diff --git a/packages/admin/dashboard/src/routes/orders/order-list/components/order-list-table/order-list-table.tsx b/packages/admin/dashboard/src/routes/orders/order-list/components/order-list-table/order-list-table.tsx
index cb10250a67..1dfdbe79b4 100644
--- a/packages/admin/dashboard/src/routes/orders/order-list/components/order-list-table/order-list-table.tsx
+++ b/packages/admin/dashboard/src/routes/orders/order-list/components/order-list-table/order-list-table.tsx
@@ -1,15 +1,16 @@
-import { Container, Heading } from "@medusajs/ui"
+import { Button, Container, Heading } from "@medusajs/ui"
 import { keepPreviousData } from "@tanstack/react-query"
 import { useTranslation } from "react-i18next"
+import { Link, Outlet, useLocation } from "react-router-dom"
 
 import { _DataTable } from "../../../../../components/table/data-table/data-table"
 import { useOrders } from "../../../../../hooks/api/orders"
 import { useOrderTableColumns } from "../../../../../hooks/table/columns/use-order-table-columns"
-import { useOrderTableFilters } from "./use-order-table-filters"
 import { useOrderTableQuery } from "../../../../../hooks/table/query/use-order-table-query"
 import { useDataTable } from "../../../../../hooks/use-data-table"
 import { useFeatureFlag } from "../../../../../providers/feature-flag-provider"
 import { ConfigurableOrderListTable } from "./configurable-order-list-table"
+import { useOrderTableFilters } from "./use-order-table-filters"
 
 import { DEFAULT_FIELDS } from "../../const"
 
@@ -17,6 +18,7 @@ const PAGE_SIZE = 20
 
 export const OrderListTable = () => {
   const { t } = useTranslation()
+  const location = useLocation()
   const isViewConfigEnabled = useFeatureFlag("view_configurations")
 
   // If feature flag is enabled, use the new configurable table
@@ -57,6 +59,9 @@ export const OrderListTable = () => {
     <Container className="divide-y p-0">
       <div className="flex items-center justify-between px-6 py-4">
         <Heading>{t("orders.domain")}</Heading>
+        <Button size="small" variant="secondary" asChild>
+          <Link to={`export${location.search}`}>{t("actions.export")}</Link>
+        </Button>
       </div>
       <_DataTable
         columns={columns}
@@ -78,6 +83,7 @@ export const OrderListTable = () => {
           message: t("orders.list.noRecordsMessage"),
         }}
       />
+      <Outlet />
     </Container>
   )
 }
diff --git a/packages/core/core-flows/src/order/steps/export-orders.ts b/packages/core/core-flows/src/order/steps/export-orders.ts
new file mode 100644
index 0000000000..b0ea335bec
--- /dev/null
+++ b/packages/core/core-flows/src/order/steps/export-orders.ts
@@ -0,0 +1,178 @@
+import {
+  FilterableOrderProps,
+  IFileModuleService,
+  OrderDTO,
+} from "@medusajs/framework/types"
+import {
+  ContainerRegistrationKeys,
+  Modules,
+  deduplicate,
+} from "@medusajs/framework/utils"
+import { StepResponse, createStep } from "@medusajs/framework/workflows-sdk"
+import { json2csv } from "json-2-csv"
+
+import {
+  getLastFulfillmentStatus,
+  getLastPaymentStatus,
+} from "../utils/aggregate-status"
+
+export type ExportOrdersStepInput = {
+  batch_size?: number | string
+  select: string[]
+  filter?: FilterableOrderProps
+}
+
+export type ExportOrdersStepOutput = {
+  id: string
+  filename: string
+}
+
+export const exportOrdersStepId = "export-orders"
+
+const normalizeOrderForExport = (order: OrderDTO): object => {
+  const order_ = order as any
+  const customer = order_.customer || {}
+  const shippingAddress = order_.shipping_address || {}
+
+  return JSON.parse(
+    JSON.stringify({
+      Order_ID: order.id,
+      Display_ID: order.display_id,
+      "Order status": order.status,
+      Date: order.created_at,
+      "Customer First name": customer.first_name || "",
+      "Customer Last name": customer.last_name || "",
+      "Customer Email": customer.email || "",
+      "Customer ID": customer.id || "",
+      "Shipping Address 1": shippingAddress.address_1 || "",
+      "Shipping Address 2": shippingAddress.address_2 || "",
+      "Shipping Country Code": shippingAddress.country_code || "",
+      "Shipping City": shippingAddress.city || "",
+      "Shipping Postal Code": shippingAddress.postal_code || "",
+      "Shipping Region ID": order.region_id,
+      "Fulfillment Status": order_.fulfillment_status,
+      "Payment Status": order_.payment_status,
+      Subtotal: order.subtotal,
+      "Shipping Total": order.shipping_total,
+      "Discount Total": order.discount_total,
+      "Gift Card Total": order.gift_card_total,
+      "Refunded Total": order_.refunded_total,
+      "Tax Total": order.tax_total,
+      Total: order.total,
+      "Currency Code": order.currency_code,
+    })
+  )
+}
+
+export const exportOrdersStep = createStep(
+  exportOrdersStepId,
+  async (input: ExportOrdersStepInput, { container }) => {
+    const query = container.resolve(ContainerRegistrationKeys.QUERY)
+    const fileModule = container.resolve(Modules.FILE)
+
+    const filename = `${Date.now()}-order-exports.csv`
+    const { writeStream, promise, fileKey } = await fileModule.getUploadStream({
+      filename,
+      mimeType: "text/csv",
+    })
+
+    const pageSize = !isNaN(parseInt(input?.batch_size as string))
+      ? parseInt(input?.batch_size as string, 10)
+      : 50
+
+    let page = 0
+    let hasHeader = false
+
+    const fields = deduplicate([
+      ...input.select,
+      "id",
+      "status",
+      "items.*",
+      "customer.*",
+      "shipping_address.*",
+      "payment_collections.status",
+      "payment_collections.amount",
+      "payment_collections.captured_amount",
+      "payment_collections.refunded_amount",
+      "fulfillments.packed_at",
+      "fulfillments.shipped_at",
+      "fulfillments.delivered_at",
+      "fulfillments.canceled_at",
+    ])
+
+    while (true) {
+      const { data: orders } = await query.graph({
+        entity: "order",
+        filters: {
+          ...input.filter,
+          status: {
+            $ne: "draft",
+          },
+        },
+        pagination: {
+          skip: page * pageSize,
+          take: pageSize,
+        },
+        fields,
+      })
+
+      if (orders.length === 0) {
+        break
+      }
+
+      for (let i = 0; i < orders.length; i++) {
+        const order = orders[i]
+        const order_ = order as any
+
+        order_.payment_status = getLastPaymentStatus(order_)
+        order_.fulfillment_status = getLastFulfillmentStatus(order_)
+
+        delete order_.version
+        delete order.payment_collections
+        delete order.fulfillments
+
+        orders[i] = normalizeOrderForExport(order)
+      }
+
+      const batchCsv = json2csv(orders, {
+        prependHeader: !hasHeader,
+        arrayIndexesAsKeys: true,
+        expandNestedObjects: true,
+        expandArrayObjects: true,
+        unwindArrays: false,
+        preventCsvInjection: true,
+        emptyFieldValue: "",
+      })
+
+      const ok = writeStream.write((hasHeader ? "\n" : "") + batchCsv)
+      if (!ok) {
+        await new Promise((resolve) => writeStream.once("drain", resolve))
+      }
+
+      hasHeader = true
+
+      if (orders.length < pageSize) {
+        break
+      }
+
+      page += 1
+    }
+
+    writeStream.end()
+
+    await promise
+
+    return new StepResponse(
+      { id: fileKey, filename } as ExportOrdersStepOutput,
+      fileKey
+    )
+  },
+  async (fileId, { container }) => {
+    if (!fileId) {
+      return
+    }
+
+    const fileModule: IFileModuleService = container.resolve(Modules.FILE)
+    await fileModule.deleteFiles(fileId)
+  }
+)
diff --git a/packages/core/core-flows/src/order/steps/index.ts b/packages/core/core-flows/src/order/steps/index.ts
index a0422edaa6..3cea34b177 100644
--- a/packages/core/core-flows/src/order/steps/index.ts
+++ b/packages/core/core-flows/src/order/steps/index.ts
@@ -17,10 +17,11 @@ export * from "./delete-order-change-actions"
 export * from "./delete-order-changes"
 export * from "./delete-order-shipping-methods"
 export * from "./exchange/cancel-exchange"
-export * from "./list-order-change-actions-by-type"
 export * from "./exchange/create-exchange"
 export * from "./exchange/create-exchange-items-from-actions"
 export * from "./exchange/delete-exchanges"
+export * from "./export-orders"
+export * from "./list-order-change-actions-by-type"
 export * from "./preview-order-change"
 export * from "./register-delivery"
 export * from "./register-fulfillment"
diff --git a/packages/core/core-flows/src/order/workflows/export-orders.ts b/packages/core/core-flows/src/order/workflows/export-orders.ts
new file mode 100644
index 0000000000..308c58d4a2
--- /dev/null
+++ b/packages/core/core-flows/src/order/workflows/export-orders.ts
@@ -0,0 +1,142 @@
+import { FilterableOrderProps } from "@medusajs/framework/types"
+import {
+  WorkflowData,
+  createWorkflow,
+  transform,
+} from "@medusajs/framework/workflows-sdk"
+import { useRemoteQueryStep } from "../../common"
+import { notifyOnFailureStep, sendNotificationsStep } from "../../notification"
+import { exportOrdersStep } from "../steps"
+
+/**
+ * The data to export orders.
+ */
+export type ExportOrdersDTO = {
+  /**
+   * The fields to select. These fields will be passed to
+   * [Query](https://docs.medusajs.com/learn/fundamentals/module-links/query), so you can
+   * pass order properties or any relation names, including custom links.
+   */
+  select: string[]
+  /**
+   * The filters to select which orders to export.
+   */
+  filter?: FilterableOrderProps
+}
+
+export const exportOrdersWorkflowId = "export-orders"
+/**
+ * This workflow exports orders matching the specified filters. It's used to
+ * export orders to a CSV file.
+ *
+ * :::note
+ *
+ * This workflow doesn't return the exported orders. Instead, it sends a notification to the admin
+ * users that they can download the exported orders.
+ *
+ * :::
+ *
+ * @example
+ * To export all orders:
+ *
+ * ```ts
+ * const { result } = await exportOrdersWorkflow(container)
+ * .run({
+ *   input: {
+ *     select: ["*"],
+ *   }
+ * })
+ * ```
+ *
+ * To export orders matching a criteria:
+ *
+ * ```ts
+ * const { result } = await exportOrdersWorkflow(container)
+ * .run({
+ *   input: {
+ *     select: ["*"],
+ *     filter: {
+ *       created_at: {
+ *         $gte: "2024-01-01",
+ *         $lte: "2024-12-31"
+ *       }
+ *     }
+ *   }
+ * })
+ * ```
+ *
+ * To export orders within a date range:
+ *
+ * ```ts
+ * const { result } = await exportOrdersWorkflow(container)
+ * .run({
+ *   input: {
+ *     select: ["*"],
+ *     filter: {
+ *       created_at: {
+ *         $gte: "2024-01-01T00:00:00Z",
+ *         $lte: "2024-01-31T23:59:59Z"
+ *       }
+ *     }
+ *   }
+ * })
+ * ```
+ *
+ * @summary
+ *
+ * Export orders with filtering capabilities.
+ */
+export const exportOrdersWorkflow = createWorkflow(
+  exportOrdersWorkflowId,
+  (input: WorkflowData<ExportOrdersDTO>): WorkflowData<void> => {
+    const file = exportOrdersStep(input).config({
+      async: true,
+      backgroundExecution: true,
+    })
+
+    const failureNotification = transform({ input }, (data) => {
+      return [
+        {
+          // We don't need the recipient here for now, but if we want to push feed notifications to a specific user we could add it.
+          to: "",
+          channel: "feed",
+          template: "admin-ui",
+          data: {
+            title: "Order export",
+            description: `Failed to export orders, please try again later.`,
+          },
+        },
+      ]
+    })
+    notifyOnFailureStep(failureNotification)
+
+    const fileDetails = useRemoteQueryStep({
+      fields: ["id", "url"],
+      entry_point: "file",
+      variables: { id: file.id },
+      list: false,
+    })
+
+    const notifications = transform({ fileDetails, file }, (data) => {
+      return [
+        {
+          // We don't need the recipient here for now, but if we want to push feed notifications to a specific user we could add it.
+          to: "",
+          channel: "feed",
+          template: "admin-ui",
+          data: {
+            title: "Order export",
+            description: "Order export completed successfully!",
+            file: {
+              filename: data.file.filename,
+              url: data.fileDetails.url,
+              mimeType: "text/csv",
+            },
+          },
+        },
+      ]
+    })
+
+    sendNotificationsStep(notifications)
+  }
+)
diff --git a/packages/core/core-flows/src/order/workflows/index.ts b/packages/core/core-flows/src/order/workflows/index.ts
index a972ad1905..6ba0edc16e 100644
--- a/packages/core/core-flows/src/order/workflows/index.ts
+++ b/packages/core/core-flows/src/order/workflows/index.ts
@@ -18,6 +18,7 @@ export * from "./claim/update-claim-add-item"
 export * from "./claim/update-claim-item"
 export * from "./claim/update-claim-shipping-method"
 export * from "./complete-orders"
+export * from "./compute-adjustments-for-preview"
 export * from "./create-fulfillment"
 export * from "./create-or-update-order-payment-collection"
 export * from "./create-order"
@@ -41,6 +42,7 @@ export * from "./exchange/remove-exchange-item-action"
 export * from "./exchange/remove-exchange-shipping-method"
 export * from "./exchange/update-exchange-add-item"
 export * from "./exchange/update-exchange-shipping-method"
+export * from "./export-orders"
 export * from "./fetch-shipping-option"
 export * from "./get-order-detail"
 export * from "./get-orders-list"
@@ -48,9 +50,9 @@ export * from "./list-shipping-options-for-order"
 export * from "./mark-order-fulfillment-as-delivered"
 export * from "./mark-payment-collection-as-paid"
 export * from "./maybe-refresh-shipping-methods"
+export * from "./on-carry-promotions-flag-set"
 export * from "./order-edit/begin-order-edit"
 export * from "./order-edit/cancel-begin-order-edit"
-export * from "./compute-adjustments-for-preview"
 export * from "./order-edit/confirm-order-edit-request"
 export * from "./order-edit/create-order-edit-shipping-method"
 export * from "./order-edit/order-edit-add-new-item"
@@ -81,7 +83,6 @@ export * from "./return/update-receive-item-return-request"
 export * from "./return/update-request-item-return"
 export * from "./return/update-return"
 export * from "./return/update-return-shipping-method"
-export * from "./on-carry-promotions-flag-set"
 export * from "./transfer/accept-order-transfer"
 export * from "./transfer/cancel-order-transfer"
 export * from "./transfer/decline-order-transfer"
diff --git a/packages/core/js-sdk/src/admin/order.ts b/packages/core/js-sdk/src/admin/order.ts
index 17bde8fa4e..233efd6051 100644
--- a/packages/core/js-sdk/src/admin/order.ts
+++ b/packages/core/js-sdk/src/admin/order.ts
@@ -638,7 +638,7 @@ export class Order {
    * This method updates an order change. It sends a request to the
    * [Update Order Change](https://docs.medusajs.com/api/admin#order-changes_postorder-changesid)
    * API route.
-   * 
+   *
    * @since 2.12.0
    *
    * @param id - The order change's ID.
@@ -674,4 +674,36 @@ export class Order {
       }
     )
   }
+
+  /**
+   * This method starts an order export process to retrieve a CSV of exported orders.
+   *
+   * You'll receive in the response the transaction ID of the workflow generating the CSV file.
+   * To check the status of the execution, send a `GET` request to
+   * `/admin/workflows-executions/export-orders/:transaction-id`.
+   *
+   * Once the execution finishes successfully, a notification is created for the export.
+   * You can retrieve the notifications using the `/admin/notification` API route to
+   * retrieve the file's download URL.
+   *
+   * @param query - Filters to specify which orders to export.
+   * @param headers - Headers to pass in the request.
+   * @returns The export's details.
+   *
+   * @example
+   * sdk.admin.order.export({})
+   * .then(({ transaction_id }) => {
+   *   console.log(transaction_id)
+   * })
+   */
+  async export(query?: HttpTypes.AdminOrderFilters, headers?: ClientHeaders) {
+    return await this.client.fetch<HttpTypes.AdminExportOrderResponse>(
+      `/admin/orders/export`,
+      {
+        method: "POST",
+        headers,
+        query,
+      }
+    )
+  }
 }
diff --git a/packages/core/types/src/file/provider.ts b/packages/core/types/src/file/provider.ts
index 66b263149e..c40118d603 100644
--- a/packages/core/types/src/file/provider.ts
+++ b/packages/core/types/src/file/provider.ts
@@ -1,4 +1,4 @@
-import { Readable } from "stream"
+import { Readable, Writable } from "stream"
 import { FileAccessPermission } from "./common"
 
 /**
@@ -109,6 +109,28 @@ export type ProviderGetPresignedUploadUrlDTO = {
   expiresIn?: number
 }
 
+/**
+ * @interface
+ *
+ * The details of the file to upload via a stream.
+ */
+export type ProviderUploadStreamDTO = {
+  /**
+   * The filename of the uploaded file
+   */
+  filename: string
+
+  /**
+   * The mimetype of the uploaded file
+   */
+  mimeType: string
+
+  /**
+   * The access level of the file. Defaults to private if not passed
+   */
+  access?: FileAccessPermission
+}
+
 export interface IFileProvider {
   /**
    * This method is used to upload a file
@@ -178,4 +200,14 @@ export interface IFileProvider {
    * Get the file contents as a Node.js Buffer
    */
   getAsBuffer(fileData: ProviderGetFileDTO): Promise<Buffer>
+
+  /**
+   * Get a writeable stream to upload a file.
+   */
+  getUploadStream(fileData: ProviderUploadStreamDTO): Promise<{
+    writeStream: Writable
+    promise: Promise<ProviderFileResultDTO>
+    url: string
+    fileKey: string
+  }>
 }
diff --git a/packages/core/types/src/file/service.ts b/packages/core/types/src/file/service.ts
index a3affff543..f1ddf9bf1d 100644
--- a/packages/core/types/src/file/service.ts
+++ b/packages/core/types/src/file/service.ts
@@ -1,10 +1,15 @@
+import type { Writable } from "stream"
 import { Readable } from "stream"
-import { IModuleService } from "../modules-sdk"
-import { FileDTO, FilterableFileProps, UploadFileUrlDTO } from "./common"
 import { FindConfig } from "../common"
+import { IModuleService } from "../modules-sdk"
 import { Context } from "../shared-context"
-import { IFileProvider } from "./provider"
+import { FileDTO, FilterableFileProps, UploadFileUrlDTO } from "./common"
 import { CreateFileDTO, GetUploadFileUrlDTO } from "./mutations"
+import {
+  IFileProvider,
+  ProviderFileResultDTO,
+  ProviderUploadStreamDTO,
+} from "./provider"
 
 export interface IFileModuleService extends IModuleService {
   /**
@@ -203,4 +208,14 @@ export interface IFileModuleService extends IModuleService {
    * contents.toString('utf-8')
    */
   getAsBuffer(id: string, sharedContext?: Context): Promise<Buffer>
+
+  /**
+   * Get a writeable stream to upload a file.
+   */
+  getUploadStream(fileData: ProviderUploadStreamDTO): Promise<{
+    writeStream: Writable
+    promise: Promise<ProviderFileResultDTO>
+    url: string
+    fileKey: string
+  }>
 }
diff --git a/packages/core/types/src/http/order/admin/responses.ts b/packages/core/types/src/http/order/admin/responses.ts
index 548e2631a1..aba222e4fb 100644
--- a/packages/core/types/src/http/order/admin/responses.ts
+++ b/packages/core/types/src/http/order/admin/responses.ts
@@ -47,3 +47,10 @@ export interface AdminOrderPreviewResponse {
    */
   order: AdminOrderPreview
 }
+
+export interface AdminExportOrderResponse {
+  /**
+   * The ID of the export order workflow's transaction.
+   */
+  transaction_id: string
+}
diff --git a/packages/core/utils/src/file/abstract-file-provider.ts b/packages/core/utils/src/file/abstract-file-provider.ts
index fe070684cf..be4dfc46c7 100644
--- a/packages/core/utils/src/file/abstract-file-provider.ts
+++ b/packages/core/utils/src/file/abstract-file-provider.ts
@@ -1,5 +1,5 @@
-import type { Readable } from "stream"
 import { FileTypes, IFileProvider } from "@medusajs/types"
+import type { Readable, Writable } from "stream"
 
 /**
  * ### constructor
@@ -234,4 +234,34 @@ export class AbstractFileProviderService implements IFileProvider {
   getAsBuffer(fileData: FileTypes.ProviderGetFileDTO): Promise<Buffer> {
     throw Error("getAsBuffer must be overridden by the child class")
   }
+
+  /**
+   * This method returns a writeable stream to upload a file.
+   *
+   * @param {FileTypes.ProviderUploadStreamDTO} fileData - The details of the file to upload.
+   * @returns {Promise<{ writeStream: Writable, promise: Promise<FileTypes.ProviderFileResultDTO>, url: string, fileKey: string }>} The writeable stream and upload promise.
+   *
+   * @since 2.8.0
+   *
+   * @example
+   * class MyFileProviderService extends AbstractFileProviderService {
+   *   // ...
+   *   async getUploadStream(fileData: FileTypes.ProviderUploadStreamDTO): Promise<{
+   *     writeStream: Writable
+   *     promise: Promise<FileTypes.ProviderFileResultDTO>
+   *     url: string
+   *     fileKey: string
+   *   }> {
+   *     // TODO logic to get the writeable stream
+   *   }
+   * }
+   */
+  getUploadStream(fileData: FileTypes.ProviderUploadStreamDTO): Promise<{
+    writeStream: Writable
+    promise: Promise<FileTypes.ProviderFileResultDTO>
+    url: string
+    fileKey: string
+  }> {
+    throw Error("getUploadStream must be overridden by the child class")
+  }
 }
diff --git a/packages/medusa/src/api/admin/orders/export/route.ts b/packages/medusa/src/api/admin/orders/export/route.ts
new file mode 100644
index 0000000000..12b0042af6
--- /dev/null
+++ b/packages/medusa/src/api/admin/orders/export/route.ts
@@ -0,0 +1,20 @@
+import { exportOrdersWorkflow } from "@medusajs/core-flows"
+import {
+  AuthenticatedMedusaRequest,
+  MedusaResponse,
+} from "@medusajs/framework/http"
+import { HttpTypes } from "@medusajs/framework/types"
+
+export const POST = async (
+  req: AuthenticatedMedusaRequest<{}, HttpTypes.AdminOrderFilters>,
+  res: MedusaResponse<HttpTypes.AdminExportOrderResponse>
+) => {
+  const selectFields = req.queryConfig.fields ?? []
+  const input = { select: selectFields, filter: req.filterableFields }
+
+  const { transaction } = await exportOrdersWorkflow(req.scope).run({
+    input,
+  })
+
+  res.status(202).json({ transaction_id: transaction.transactionId })
+}
diff --git a/packages/medusa/src/api/admin/orders/middlewares.ts b/packages/medusa/src/api/admin/orders/middlewares.ts
index 25266e0644..3e9b68d2b0 100644
--- a/packages/medusa/src/api/admin/orders/middlewares.ts
+++ b/packages/medusa/src/api/admin/orders/middlewares.ts
@@ -32,6 +32,16 @@ export const adminOrderRoutesMiddlewares: MiddlewareRoute[] = [
       ),
     ],
   },
+  {
+    method: ["POST"],
+    matcher: "/admin/orders/export",
+    middlewares: [
+      validateAndTransformQuery(
+        AdminGetOrdersParams,
+        QueryConfig.exportTransformQueryConfig
+      ),
+    ],
+  },
   {
     method: ["GET"],
     matcher: "/admin/orders/:id",
diff --git a/packages/medusa/src/api/admin/orders/query-config.ts b/packages/medusa/src/api/admin/orders/query-config.ts
index db7b886785..c91ee3f4c1 100644
--- a/packages/medusa/src/api/admin/orders/query-config.ts
+++ b/packages/medusa/src/api/admin/orders/query-config.ts
@@ -118,3 +118,33 @@ export const listShippingOptionsQueryConfig = {
   defaultLimit: 100,
   isList: true,
 }
+
+export const defaultAdminExportOrderFields = [
+  "id",
+  "display_id",
+  "status",
+  "created_at",
+  "updated_at",
+  "email",
+  "currency_code",
+  "region_id",
+  "subtotal",
+  "tax_total",
+  "shipping_total",
+  "discount_total",
+  "gift_card_total",
+  "total",
+  "*customer",
+  "*shipping_address",
+  "*billing_address",
+  "*sales_channel",
+  "*items",
+  "*shipping_methods",
+  "*payment_collections",
+  "*fulfillments",
+]
+
+export const exportTransformQueryConfig = {
+  defaults: defaultAdminExportOrderFields,
+  isList: true,
+}
diff --git a/packages/modules/file/src/services/file-module-service.ts b/packages/modules/file/src/services/file-module-service.ts
index d162ca6593..0dc5acb9de 100644
--- a/packages/modules/file/src/services/file-module-service.ts
+++ b/packages/modules/file/src/services/file-module-service.ts
@@ -1,19 +1,19 @@
-import type { Readable } from "stream"
 import {
   Context,
   CreateFileDTO,
-  GetUploadFileUrlDTO,
   FileDTO,
-  UploadFileUrlDTO,
   FileTypes,
   FilterableFileProps,
   FindConfig,
+  GetUploadFileUrlDTO,
   ModuleJoinerConfig,
+  UploadFileUrlDTO,
 } from "@medusajs/framework/types"
+import type { Readable, Writable } from "stream"
 
+import { MedusaError } from "@medusajs/framework/utils"
 import { joinerConfig } from "../joiner-config"
 import FileProviderService from "./file-provider-service"
-import { MedusaError } from "@medusajs/framework/utils"
 
 type InjectedDependencies = {
   fileProviderService: FileProviderService
@@ -172,4 +172,25 @@ export default class FileModuleService implements FileTypes.IFileModuleService {
   getAsBuffer(id: string): Promise<Buffer> {
     return this.fileProviderService_.getAsBuffer({ fileKey: id })
   }
+
+  /**
+   * Get a writeable stream to upload a file.
+   *
+   * @example
+   * const { writeStream, promise } = await fileModuleService.getUploadStream({
+   *   filename: "test.csv",
+   *   mimeType: "text/csv",
+   * })
+   *
+   * stream.pipe(writeStream)
+   * const result = await promise
+   */
+  getUploadStream(data: FileTypes.ProviderUploadStreamDTO): Promise<{
+    writeStream: Writable
+    promise: Promise<FileTypes.ProviderFileResultDTO>
+    url: string
+    fileKey: string
+  }> {
+    return this.fileProviderService_.getUploadStream(data)
+  }
 }
diff --git a/packages/modules/file/src/services/file-provider-service.ts b/packages/modules/file/src/services/file-provider-service.ts
index 959ab9c254..7568dceec0 100644
--- a/packages/modules/file/src/services/file-provider-service.ts
+++ b/packages/modules/file/src/services/file-provider-service.ts
@@ -1,7 +1,7 @@
-import type { Readable } from "stream"
 import { Constructor, FileTypes } from "@medusajs/framework/types"
 import { MedusaError } from "@medusajs/framework/utils"
 import { FileProviderRegistrationPrefix } from "@types"
+import type { Readable, Writable } from "stream"
 
 type InjectedDependencies = {
   [
@@ -81,4 +81,13 @@ export default class FileProviderService {
   getAsBuffer(fileData: FileTypes.ProviderGetFileDTO): Promise<Buffer> {
     return this.fileProvider_.getAsBuffer(fileData)
   }
+
+  getUploadStream(fileData: FileTypes.ProviderUploadStreamDTO): Promise<{
+    writeStream: Writable
+    promise: Promise<FileTypes.ProviderFileResultDTO>
+    url: string
+    fileKey: string
+  }> {
+    return this.fileProvider_.getUploadStream(fileData)
+  }
 }
diff --git a/packages/modules/providers/file-local/integration-tests/__fixtures__/catphoto.jpg b/packages/modules/providers/file-local/integration-tests/__fixtures__/catphoto.jpg
new file mode 100644
index 0000000000000000000000000000000000000000..6d44d5e1dde39713e44d7b7cf5479118b68fefdb
GIT binary patch
literal 24003
zcmb5VWmFtZ6DYj6LvZ&cIKf?lyR*2vyGw8aWLa1=5LjGxaS58>P6EL_cz{KM1_?<n
z&wIY_{=apmyKB1pR8`CL)Kt~{Tlu#G@Kg?Ua|QskwE<iJ000|+fkFsCea3K}lLiV6
z0OPqtc}_+swEq{kMBxCS{jdJHCo1XxhyT~>84PuG%$Sr675{gm_MHD$|G)CzIzSPC
zj)wN%g^q@ffsT%WiHn8#3<Nm1*tkRlFJ2H45D^lSQjrmpP?8W5k<*b=Qd85?(!L<0
zXQZcLq@tmv`Hu(+ItB(N1|~ih7CsFz5i!mGGyLlZ5Mu*2Q8ds{SOBQRC}_ke|Aqnd
z&x1ij`49dl`*VhYiH44ajfw)md2UvG0YF7TLqkRXA7G$i08mh$M?nlAVa607Ws%p%
zBD3>j6^w<FD;ShwHxJBG*za5bh5X|#DcLd=4ISbKpNY_*0RG3~|L5=@OLPnr0OoTW
zA29&+8Bm^CVE#9~&r^pAAVy;*5kUWsyd4Ispr3+4EOg+aw0ZX58UP;+<ym+%Vt^dr
zc(vYx+cTk6tSq)LDu`_9cN)hG;8laf;z`gP=OHs1y0jw!Wn<^OvgS@3ESSD|U4L&^
ze&b`qZgXS)@?iEM+G{>9vJ{p<>J362aT+ljE6pB9HH&n`l55n{Q#207Y?QH+%EDq|
zM4zB_PV4-_WUC1WbouIXw8(r*mrQVi<7~2KPu&=qvX`C6L%BilqOLYGRB=i;(Il>9
z&zf4_*tc9rvo7PK5c#{n1Tg-7Y+3Fk2!TsRH3-w)Qm^VlIx_NUB<@W{6bY<wKam)~
z-#7bkuv?m_E>IY&o4`G%TVF|i%M_{{(r6lK4%G^W1(gPgXmP7GkNyP~T_4F7j5*cx
z8ZS>yE(ja%j*yh~mJe=CFn|E9w)-wrkB6pzof(Kcu6Zwu3(m1V3p8dO?2K!#IGn#J
zppi7Q3f|+=G5s}*JTLyN_f5urPT8-j+GhmbzEE#obI3Cgi4@;&0f!^+w4wSmx_Y45
zBoi!fbVI8gKYfZ-rE7n7(W@&6o7yMknIp{4#z|?(YAqER{NnSA+K~bZlRXNBVUSpU
z^DlME!MQh*w)QND-OrWOT%S~ux#EvUVH~!9S*h_OKY!}&u2gkaEl>vW?X?rWKXwqU
zloyczjn6Eb-0ycpsa>7a@Oc+-lgjWrjRmA({v|dOA`-5nY{D}C6x0k-Fc2TJgCeqT
zZf29P71b=V&gvIm*V;P?wAbXjmS!f8@x-P`WB=MNZg}thGFP1`wT!e~v48Y^4F_xT
z)9?!PH(zwNyVPg7bfBOVcDZ2;VE^bLraOLk1Ob87<U77VwB$_Scf;p>WYB~SIcRk#
z)3s%B6CTv<FHvi(vAo#E@N|s^CDZXsZ}%NkN{R-6XjJGwEtpfvOn3E%_Ieu&jFO<a
zqC{DR&{7=AiMda6Q=edH?h#H3%Up`u+?w3@?K-Hjn<+Q?Kg(7qTrlXdX-+J8vriHJ
z{+gu671LQKpn4?dc9JfADN2PvJ4nzMGfMquHD6Wt8kdb10S51ZgmFQ$RtAY6;dq4j
z%(bj49g!7_X<GM0ka>#hF`OmmQlcWwmS9xS$d(_iC0%FpHYaPEF7A8f@h$^!;k&!!
z_gu)hJGz$uUW{r(MookNcRqu~r3G~3r;PY@<(zGg&??)WcbI1b=q|pGwqVAF+@pi?
zB=u;X^uFG(pY?QMGV&@)M@AdoH8Hwcr@(DOO?p;=Dp;L73*YHsNR;q|O3uv$?zo}f
z#FPU_ZU<PBp-wz5o%^%#Mac~682rM#Joo)4CJMuTG#kXe8s|4*-d$!~6zj)K+(wi&
z0a>cc7>UtFsxqj<1002M5_|tRc8ITpoax-SeF=j-)KwvNd@-V04>8_6mS+dsD>Bbi
z<IK<hwGCO*M?k-qg}LoLZFtKaH?$_0^|#yo>iMbUhMFrA%j6E>ayK_q!r1sVuuZ_d
zWSN_`=bmfK6MQCf^DrMo_Ln;P1**x_vF&5V30S{N+e|CbxOm7#x>=H(@rx#t2>yBP
z1ZbSbyEjx&%OY6C7t>#;rlhqo;mb9?9Exf~_7}1R5re@44ma~%1t2)J{0n8@x`9lC
z2DYW)z^DZJb=eYbXs$Y`_cz^=!@F6javmd37Aj|PU}2%#k-Wt_Tltjcd80){qd-jb
z%e~s&Sv^b&r~b3iWQ!wK{axu^hKS6~+p|pGF>=-3PKN5xmA7z22?RrJ5bP`Z=!#+a
z4<KMPg<qwZ1x}->{Ww2_0ujX(fCztb&|p%c<}D;@Xx+3((@tPH*Ho1koSJ!cx9tkf
zc5xO+Z(1-us-Ox_!Tj+TBz+7Kd+Xd^T9hOJS;H6CW-#m$j9<`oPvLZw>U&i)+8{If
zvcispn{?nXO+BogNnKMzObo^3PatYI%@*EZN3S|vp<5!69vW_^!HkE9P;(mp@Ew+M
z!-Ys!xgwNVoNga!{UNC;MZPi5m43Oseqlk?H@_eseVW$$d?#>tv{d$zXa7UaaT)BO
zJ;mP<Zb!54;;qZ`CdTn^!Hkc-YFOv^O$#-r9Rr4dU0f6A;N@|KV8niA#EAwxNt3Pn
z(2C2`)oY%NEA0DkJ+T!ZcC&--Ov-cyR{lMFq3M>VJM76U#euP}X4|PswQa`AhTi$d
zTsuG@R6unAow#TDbj_mzCX1-KBoT+dDv9NBAF%JVr4xiqaRU7M9iRiFDw;mD`3&Sa
zLQi|*kAH+2y5)9W^@@^R3c0X-=<8_2T0wfVLmt7ludF7ERHZxA_Q}eWoTga;aoFeB
zcfXHJv^L!HnIT@|dmA2_vP7nax)!g2lshyy<zwW{vGFY10W7iOe{H))0~-liVB|)Z
z<oOSVH+OUQ9Af0-P(#II@jXb6lanEL*R+mbW0XBAo9x7EXLhdYZv?=~AP^m@qyg}e
z6zp+B?r+JZkGRX#kHI-ZERLJQIZ-vA3>xzD6(<ds8M+;gCUV`(-G(8i7uchiLHfL!
zdi)<c9KZxrE&4JvlHB}UVdxIOmU1cVwhYAdbjk^wiOr3qbhbFyHI^li&Y7G}@5$x&
z`}+;c0^}{MH~<OCXX)Cwy=LrWD?*~9(mC|Ern~*n7oPOvCwxJIN>hN%oV5{E$yygo
z35{;eAF}ovM~h`(!!eRpM>;_DpFkCaxvBZ<M6#Oe7ol_Sa)=SJC2Kv2(gFqUp$uhi
z*tp3!Jh~{a@7N8jon@rFETlOB^@TXxTj4oaSj4eNO4dGqoW%mw>f<%y1xoCRI>bw<
zXK8)qHw75h!?4!>0gSWZF5zo%XSPZ=AaAb%fG7Gr?BO4vSEOkFf$-!wJ>Mri7LD%h
zZj`z2Y|9W?t5_|@8f^0);56!n<fqOzg^?UQe>FX-^p5sI3QV~I-~A9EiJbSEb>F?y
zugQ^YLPCBlBw<M;koPOPueJsmXntvxnSYAM&@dj2(>mCHqS)sLAi_1M!m6s?t4138
zcf0uF-+WLmqBj*&3J4Yl6p~ao-~Ajd@Jw|>|2C8S?d~k=*HUrPq`psA-a)A)7|Y=8
z)9YWNX^4LSS|)&$gI3$70T-NlKV_fIFGd^<<Q+%`f>y0)qQ2&ZJhFSXj_K+kKOH_q
zeKfWo4|ME&%Ym355&q#Srux!vI#tms7lghKIqdxH`pTg8n}%a0uIL?_W_I3jRemyt
zjX1govrvnKMc$)b?p}^>I5IKeQ)<z)YLr%ciaFK`TMoM1J^5WE0VH+YtcQ_*Pum!|
zm|5&N4hYEnT2Gt>tJpvtDV_Vvs}MO@9)8Xt^|xEftts?l86^)3S~g8Vcct6*DxMJO
zkF#|n-sLVgq!E_CF1s`-0=gL0jGx#+&u1m3PR_xpJ&B(gD4Dyi!Q!$uNtq#Vf-sqG
zt<B9lfPbSH#hI=%L#|1ZL)z%?$9=RZ;mMzM(S7+|S-KyTG_KRxsthsxlBDO2oNphW
z{ZL49h-UH##+@v2kX1g{NthkE7LshBA`~2>$!Jn#qE|`e`>YUn1yoZS7GQ{<*Ngl^
zHO_n`as@B1PN?&wQG~{b|GAY%%|Y*+mRQJ_t~9RAd5Ou5yXn1*K-4S=r#S@ouYEd(
zY<lLJ#v60Rm3N^@lDsTWEn)5HoFM?aH9&R>teTWiM$w3~>hV>x=r?}ID*zgyoborU
z;MgriSLeEd((#NDq8=ByDzG;0f)0i}e!v|KH!lydLG$bC^kwDY)(`+cD%-N!<@gls
zgu%lYmg-r+gsyI{nu4vb1=#&h(qJB@phg*0?4fM6;rDuCb$vR13D+@yajJO}ix@Ql
z`-9L-|JiTlT3;fEiLT~-RM(v}jNFUh(;AOiwZ1E^$Hb0Qc;|#~m%eY8ZM03#iJ#4Q
z3C64|uS#Y{Dg@DsL<vZ0DYJ0WT}ZoLug|LmwhxfM2T9K=l6gZPA|zOw<i4g`x@djX
zWb=aDsArnMwq7+#Sjzna9JaS;ri~3$X@MO42}<y{qpOb_KRoGt4g#7s{wY?xw<_d8
zsUJP=)n$7BrFyaXZ@eNmOGySfzqH-&M52yc!_h##nebG^3ltJj>6LfwGV0?rxmB)?
z_|))Aq`B-?dqDYMf1}~*B{}dMHKMLa!faQsNmYf2ETd<X7RFC>AaOfEy}ef?I5(rY
z7<el-#ggjY?MPz9TLB)%`3IPJ$2hJomG_{_8Yf(AVx#e$O-4q6TAr7XK_K^UQHA6A
zKY(;Z5gXxW#PPd&nK^b4B3W?UN*de~@KzoiR{@bNr#pf4$+I$jUCPaPkJd0JKaCaX
zZkxISMNOI(I<7E#!=jX(y(}di_|*w9nBeRHRQ27Y*!v@Km9^m@`v^C=w5hCtSJdR5
zON*ei*Lj-x`>ikEEc<cGCKQcZ|L9RP#>NQvtb={_h}`u0fvX&*^TRG}QhZs;GJ1GR
z%g|);se8f1u$t_rPOlrLZwTh-EbR5qH1?oZ_gSiL1ruH{SC{@cb>LdXwzol_VqwJJ
z?m5daGIwp;J4xi~V&Eyz40B{0Sj5=S`)x|4snlTqB+=piE}||Iffv-v6$efiZc%Th
zB(7OM7X)=mGJE|4klZ=)e-`PLoOFAgTQN#6Dwpg>a(Ep=cij2Vh>SxL88)1Ns5^P7
zShHaN09Ei+xEnX3_GNdgqVq?V1!GaaPyWVoe^w+O(auG(4W4wmgOGX_XJju6B9irK
z#+WYqXSi>o8~9Nex@DHFv>8=p8cV%$1U70}ifHP{1*I0nfs>~Zu{lcC*!}FRG+DAB
z!%}B43YH+MlZMP&&}7-6*~<~)gcLS=5;Arsbox%fUYArrZD294PGSkT%jfV-2xC<s
z<Q49HRcf0N$^NGg(haMJRD0BN`x0Y3WL0*AhcJ$1#`j?YH)rr>l!$ZlHF6>&(8PAL
zyeQys=(XxE$tlUWyK738rlNj6L3snB#whweOCW^xA7JA!-aV_!&GF{3>F{Qb?X%Ju
zuanc9dFO9xwwTeOv!33rg5=VTH%x$@0!l?8nKf$s4}?pKotdJ0%aBLA42(LvOn@{X
z5c-W0$9q$oo|j}dvjEFSROd?m_HIvNDUTN?JDWk3wbNSXErrnt<U>!E%jitz*c@@I
zczrT`{2&$;R#uv>4XcGsl(bj#vWHV^d=cL|mrK($(nu{~pPOM!3E2(x=Bd$msRFPH
z`n2Kb)0uO*hS$SXXQnc=t0vsAl$f&6G%ZM(COO3`&2eD*rds+)2~%>ia%0tCgGlRy
z`Ra|G;QpAV^va_hTgHUwS?A<6*mW`btx6mQm%^`^=q**&%mNxih7D11iBaKhSBi#O
z!E2Jj=IM{5lh~i|^PBud**oAP5_|rQ4re9F!;{x7{sFBpfvSn4@^D2u7hg2$Q^4G&
zxw7s7Z<1`nQNV-9qZW^8^n3ZZJ?dJcfXvl3nduKT?w0fE#EST~0TqwoYA0MzCcXfP
z{+oHQHik5_%AAZqjlcu7ESp!N6K!%Bd4ba!QAbr?d4q--ts5GQ?C8MCeNsc|cQRvk
z@Z6$T5yHuhRw`vwMtJ6Ha3_ksQtDo$3UkQbw{7>5#(2hu>bu38V<&-3%D~=YZRLLe
zeC>aLvwr|D-+PG`&oMrb{%h4qyvPm(t3C{r?UpN@bZteE?u@*8kb;C)31fS8r~%Ed
zR4SNf#}CDIqwdsA@r3uK`FrxY_+gJlQFh{&t1@4RCvG{FdHe<0UhT=%`l~d4<x-_B
z{eH#&N2pXr;w6yPqelAoQRSndu7)|)JBB?2{B}IT@_S>jkS%mKJ}7$s93dm}tG5lb
zfS!V`ABU+*gXY~?VN?So;8~f*stPhtZa@_6yEv^yGtm(QI?)AnN{e;g+IXiOp$9fN
zW}#)Mk7jYf`-nf4c<oW22l<7=+}%Y}#dVY8QQDgLTHETbMXBhAT{;&YB1hCt-w1e@
zkF+#!xM@k52y$~%h(Ar5{0WNJxA>C!i<8Tp>jdpA6$WDiKnDm|b1e6RsehknrCzaR
zDqs&#jkUKzT40C|wT`97;_s~Z$n+Q0yNhVubGfD={fQDfQDKir8|Gzx70i>TsV6?u
zcg&0b0Lg@G1)1H!=8x_guZKAc>eW3Xy!yu&ino-jx@X&D-5=dI@G&5^um2RYpVbZi
z_R7V5L`bGK8|srj?53bMR9rtipcQL5Xx!mN-ZYaMRM1^^JFx%e_|t~1w$R7L`tE?f
zyST>94nvt{8@?9+cyrj>GTqfHv$RP+S&*HQ6&WPJ6MOX<2n!n}e4^VIN<TQ<o3rM2
zAVT+_(pup-j)%f@v9O-^z87JK{-VevBKZxQvH@mATJ~vpO@09z``>6`r3j56XA#P-
ztlVt9JW17E&!ShV!maZohKlrBDv10~Nv@^`ts8vUiqJnmx4m6P^;t{Ky3Z!S+PN22
z%x>@!c#O1)k)E-L-$Tg7Rzt*Po%KfU3A@R<J2!K9Et@<fu*`n)r^fzSTJp3;y93al
zn(8pkqmSN4_?7~3*aK?I&ZFscuC7QWH=TEM`}ixfn&~YV-(P-O>ZCp$B0u&+eR>Hz
zeN^AJsO|IF8g<>NbFxWYXO{9Id4EUa^1$<)t+!aQ#7f?!`gpoRw6lbChA!hv&xJZq
zMb7q>7yygvG%9f2P-L^4y^6cE?4gu#YQvzgF&Tq|{=>s4ZLsR9MG+{k`kdRcquHHB
zv&3WhiyGLhY=FNmdJg;W80jm#la=m_MT<1_&W5G-9-v`RTndwej9N2V6{t1A;9vdy
z)2eq%`4@ZT9Fm!{y8fS2O3KJ>1k}A!nGl!TEp1@w@e!jJD#5wv@zb%Ud{&CVClQ-N
z)lPArD>~}gglkX-gyzRS4K}FYyIh*EE()BK%V9rOI+m4w)b(qqa6QboQgBuR*Fh}Y
z3<h$R*mzV#p)1#wQUW$-*eH@{JLx7X2<}F)cWhm}3&t8@9^4%U<)jkY%?Y;t8yQk*
z`=ses0jm19oYh@MHnF)<IcEeiq{^HuRPrywn{=htS;*PNS+pEWmImyQ$B25yi_Vq_
zulmm|iwjEzENWGb>0vGe16i(gwt!Q9!EUvR<CHh-w?%B)VU-=G#%lIeh@vMqZE2t#
zsE4k^84HbP{~th9goO}2ivho9j$WrN_~@`pz2oAV#{1A!nuO>8?H?ekh`6}noD$pW
z%u5>DV5E+&In$S)UVT!gTIzY@HzmyBSoOk5p=PVA#h2f&v-M5>Ybg>#ww4XvtFP&K
zFmcDwoGdh%LED}7IQeHIj_EdW@v9dibW{SF_sb@1wN-B4z-O>FZ#0Itf4lEEK5v$}
z!kOXa<*||Kj_@6`=z}0xpLW3j#4_H(5;vKNq&tVZyVdJ3EmI?BgMoM6Sg!g{ow81c
z(jH$M_jr7DaV_OYm};CafIM&-a1X(l?<tnV?~@AHUM!EWh?q@mt-LbZDxxaULqWA0
zh0h$r?_fhNyGh|$&G8@rshzRJRCh=oFhD!snHU6p3Ep6_<RiN?wHR9M#@X43`JKZY
z`*UVl*GL9rp(6xLT<kfa9mf~c+p@Xk98(U9a)vH)BnqHm-15SL(l*1B%9f44k`2fB
zs-FhBmm{h>Dc*TF$o{#7-9|b`58+=z&f>Qe-;KIRC&#UlD=WI}(oRduk;|X1$g~YO
zB0p-iUwrRkhlwOCaK<toEcA6sJJ{4OF4G~#&Bz#ay^JC$e0*bsUKv(eG}3j4E%w!*
z!Gtwr5tsU4L2lA9nxVQ@E|N25@t-HvA4CSziaGmlC0#GVyb7?#u@u|_L)`QAQM|Fl
zWl|PBvVT;*6O132KvOL1(H|i>HCTU(eiWr01v1Qu{UrYUdNNEWe8JtBcYtRh-7_rE
zmM^ZqemhHjjL;*|BowEicB!aQH&)3`{+$t2y?)G$sG1lWHvycO5WP!oG{DanWc5Tk
z-h9M&Mu{b~!1~4zxY1On(WzhP0!8HU6}Z!k1);+|(@c$R`PXcRYq-j1r@W&wOGnlE
z$C?&>in1O*+${vO(rsVX0QM|j8emqH&dWbrmls8U>8J(7-p=A}f%Gs~igH%|2vy>|
zny~1`4#uFmc4^Oh^=_xuNaZYNrV-8bLGFdLJ8GycEy+`khpvEoun{#cWM#T`$r=V%
z=u!D=Np5^7sRH{wlPDFR6+fL8xN);6m7?DnJlZ<5%a#{+%f-M*IzGznwOBsM|N3{*
zT<D$_S<Xc-KA6U?Czv+AL~uw;)GjuddaPsK$gzR!BQ3FN_Cs^!-Zd@bmy^(^J(-Zi
zs}|AilD~#q>LMMcCHWO=W~xoITs_nGK=c?g->%W1qVGTT$&J-f=~uXdL_H7I4L*s7
z*7dL(vS=aeV=T6m-D~S8KUqoUN~UJb|I*Cyq<B=~SL9oY#na@l9b;gU-nYw7p#tp9
z0CPk@f^8M5JpjVTZ?X*5G;s~riYDp=?j|cIZrdcBwq{Uu1-Z%u2f4?<ErNVOLRCYU
z23*0UnV+xX<o7|)uDK~3UU&I+t=Yo%3PId&eehYg>rnYLcd}r+12?s@hGZWb?;(YL
zA)L4n8b=k51}14IOlS-8VhbAdNWXCJmgpl)^`@u{AxNhX=%54d$KOceEsIS?h(5X_
zn(k1aWCR}u7?;W+->dt2JB%2AvPPz=l9L-GZq?Lu2LTIcVq6SH5ja8*>XW?@-c<WB
zLXiG_H<Iecb5bidcSi`P;6K32O6l)FM``XmK_<W-zsmKBtW6{rtJ_jE$DtiYQYi2@
z!x+r(5y`m2Gd5NOC;o!%I{viYkD(K-BQt)tcz?;UdhYCG9}b}hf#~h(U@O?}l5O4J
zS{x}$>MquO{sESyRMh?f9@5+E{sH<syc?^UZ!ykch^nNB1Sn{N#aVm-K7f;{imS#O
zo6|2LS*uDQGP>&3m|T-;##REwB_lfpt(MXKRj6{dsUs#lf&0k#vFqFvwX>(3utI@V
z4RLyk0t|{js0VW_xA$1F;)Ke^)k=yc7OXb5eDIXN{bBTK+H}ZuOwGjeFl0&Mkq3dY
z*dKDX+QY=pRhrjIoQ`qBl^bgss*=7mSs0t8FyItr2>$j(Pz3|hqXI+BS2??jcNXrr
zvlm5=fE}Z`lfyyoDg7J{W;j?GbNC(hrtx63I>u@qFPX!d8rNCQ1f*xaLosg7F3(l1
z1FgE;dxD|(BOzEeM)7z3-`aB3$Ke{Yvr&xNGJ2IAvt~I4p;=$`6hCFE4fTd(O3{C4
z{#h4a`G|V`4?rHIspHW2kylykXJl10(J(0nk5=(Fys#$S>yUw^oaK&MqM@0DS#yJK
z$#+E}-3?TS;B!3bS@Da-E?c~bUAm5r<|U^K=kglPaFQLL#*Ss9F)N<Hg|<0nLn(>D
zo&2PYe1&ucUkTc#O@xq*FQ8SgzpmzJo#%GY%-#KsF)Z_YtL9skTvZ(A!(#rd!e8a+
zcL&7X?bQPXxSTHSV`MK3RB^-^llld-wwSRMqWo@_=9iW}IC+_A2tyhM*u<S-W*xa|
z*>i@8V+Z0%ZW2#l<*+)J{6Ol?78QaU+{|%AWYRyWOdj4&cx5DBi=v)~u;SwGUzhI_
zA`WAI54QKEk_Q^)+zP>~<+WUQUz9qb*V)-XkCIewm>g){bZqc$x_G&=hEkZ1UbvO6
zk&RI+8K_B<_*-Csy{2CeOco4~q>kffD*B{oOKa;z@}Is90c4<NJEIrN&v<&AwoG}|
zYo?*Q#$~*JqVUBX$3%<Gu*|t?2z~nE3;6P-?3UrPw!y>2_cAHZrnQ&3l}srr7ihUm
zd5#Q)P?|%u1hj=T2T||bHcjCRYnHHD^g;1$gulL;{Ya52Ph|{BK+^4=`9FYsB&dD!
z*q!5?yq-XjpJe>x0C0#y%=!g@uL(e5f+o_oC2GoWMe4Y5dhsgSI;Rg5dypC&47_43
z%$$yD@*5>{c&&*chpxgJO*By8Gd?#TR6m0M^>a=AMfMsBSQSTlZ?QndVLfZTz2F4S
zdF<LbMM;~~D*GN%_NEhQhTOlDb+4~hrK7xlA@IwpoT1-Cl~aEYab^tu#h%7KyFXBl
z_O0f#+DCFyC}Rfa82xmgjif?%FDn<L0ON<k6Xn*~Z%QB9D_TjXrHG#0BBiKB?J8ts
zH#7?)DegSbYl&%wy!to?{Ms&|A>u71PF`Np_M@qs8_DpFg^E1PY6OPw6Nzkhz=ujV
z#8|opxdmP9NmU_>uQ<Kd_q<AFZShQ~nL2}~n{z{4?^po(q!Mr^cIm5U>x{C2zyDkP
zARo<2E71cmiOT!V1;UctmjuV%qKzr$>XGjmJ{=DheANbQbU}NrpU;(Q{M_n`qGTm$
zw0hK}Zpp+ehA5SwbKGuJsyn<q)EI2#H7uVf`s3fF)p<j~kFNeq#Bmbii)gRnC0u7v
z`r1=;Ny%1*;G_!OUNC}wOmsID|8nMN{%0p?o3W}H=HQC>?c7hj*$E9TB;n$Oq_<8N
zjx5D)Xugh?3-5vKn7(a<TQK*DuHJZmD{22|Iy}quw|iJgwSjSmy6T~zw*et$5LwQp
zF6{{GU+e9{W6sA}1cwl5A=jPVmU<pTV}{l>=FN@F?FG1tdS=d>tHyL-;pVb#Wc!*`
zR9uq411Z|N(B1aeKpcqV`cR;aIn*hHayT*mh`dw1F)A{1a34tlngG51UyB3j+~9kZ
zi^`&YU<-xl%Z=t5XSUeWe&ov&*9xDfja&%{nLaD#AS;cV`q7q6i*C8RaooQvdsxe6
zA7zl{xq9>+6w~1Qgyb(_WbYoo{^+UIHYHa1owCPtBs1qg$2uax<o)w+H^IEoSC;el
zm<B>UGHr4Ve7c$%7v+LYXET14FQwkFh-H8}MI@ncnAN*oRxx|OdW-G0a=2t%OK<pM
zMe3}|B7Vu80q%BG7<*B`t)Qkcxjn8UYs}XUxyIh^^6k#*<5vk{ICBNGMTa$9--)u&
z@4+#iEB>F~z7g8mGQV#kv}yZt<v(}w!}-OMh1)R~C$hG(GETx;Z9jL>5c_+;0mQCX
zx;+dFaG^HcbTXn0(hdNDv>GOul?>uoD8;XR31xc|!aZsmKFc^Zt-FPLaW$A|f?Ix+
zNoJ?)#Nx%(XIt*b=*XmF0lWSIZaOOAFCj&|#&_ZQ<w?0sm_;stA8J#@l9_7P?XPEk
z>`BfIzovL;;mGu%P=da+1`b7h3RkBP)R=@>)jvf38J8}!^;=g!lvltGuEZ!Hl&fvs
zRgr2CwQ&M)W9Mj;icrJv6S+9STLQX_&qlQv8kzWHu$KZcy`KC|+uIj95x=h*Z6e8v
z%NmG{)q#uS*BP8UUtmBFWJ?Tg#`ClD!f5}61YFPrxllMCgmR0KR9jh3?x8CzBK-9Q
z$@nJ~M>9>sr82s0vG?LL)ZS4)BYBRG9uIdq%m?VD4QANi@=}aGxvG)8MRzHJ7nLu*
zJt^OG^3hBmqOBln;i*^Dm<JkEzm;~1;Ysif<D!iLLBci%%KuVx8Qo})rnaMOn;6yO
z<S?Q7HYif4{!F}rJvn@Hv6?y`RXfKNRP>fuZ9G|$+sVyc^*}sG9Y~)jn|0yvV>`Wd
zM}dJ7ur=;}LU63?WjGf^$U=UFQ@fKO+=t<z@O=UPSgO?IVpcTV=#F{G#m6^zQSoJ*
zUc`DICwCM>GLOv+>F)9JX$J<OKdvNz3?_bbhh{+yUpBeJVSo0d43t?vEfRO;{h)BR
zI)Ox_ydd35k37aT$|cTL3cinZsJM^4{IxtEFL$xe$)>IK4d2d@5c&0hm06*L>KcRo
zox4r?-Lp3*$tV{W4|5cP?pR)zDJ{m&p-!&DZzO889kVKP5vW>r#8!puW~lyXq)an`
zr_96Rci%)%|Ko2J6_9h_y3kj|;>p_VoP0^As1^?&ya-OTm&-3Qv6Tly$I<>KK)5-_
z5#gj2{D%66W!>h>VfQw3xyZHfwJ8w-Z8p#d4%c${wpA{sufGHBB1je3Qn+K`Z5MjH
zR$!62UX{dcvh(T1yg@%2&|WKXqt{sl2+b(R7V7Wc^t_?e$vOI9MK-U@W+fu7PUEIK
zHE4k`(LYLPBw!<iu||kT;B>W8-c~yn)V<C|^5u%AAk;vtW{TfUOz<skgqNNQp~P%>
zs=J@wIYFCBtHoSZceXVbgNhkCdz6R-6|J7Axyd+fF^bA=h!8XtB>Y3et*WX*zhm;8
z(N~!+H~6WfgLQ~%O`zwShjN=m$tRvz2j!I{@$HKh5cY5H4ROPbeSGj$R8Dsl=czlo
zNS3r(Kb!DEe4yiYQ9>d+bTSrv4H2pof=i}>gk<YspMT=mXj*A%(s}GI0;`8e#q4&;
z>0+>QW&1hA53MB+>(50p*4ZmKGO+M4v;tbVn`T)34}YV~1e9&c`@p&<Tjci?a#}*`
zhVMVjNIS4&_1UTe_wN=xysR`0rpOnE45#bK;zFELMx`9V-V!s7Ug7<8&-%x{yU3Fq
za-xA;z-VDSS+693)**h#W#KWx!w0sh&y8r6?8l<BjhgP#tmfq6r8N0CfyTtFEPAYn
z1uiPt$G^M#^Km_x+m>R@cX)bs7-5!9NAz0Yta^8}-eLEJ!$z%3OAhXKp~E%9(5Y~L
zb}}nB=N4@Lq#t1_T}?~bH*e(O%}YQDsflD|w%YPCCnGHJN9(L!_#<hL5D|XYM(8gS
zI5pp@wV;0={{@pUDzGo|#GD8hR<zCmL`gmmo28NZ!zRLwK2X%Dma<Qz&Ce|J`j#w&
z`U$+s<Sq$TtHhp;Gu)apGjj=oSd}vcGu|$QSeI6GG_1OliEUYODFMf;-qbgZ$nM5_
zgp7YfYM8mcoDMZyKQ7A-$<C%a#AG6qY7H4{?=9T0`u>7E`0zU1Rc(QdIo%f=!~hgG
z9#!>HY$`kimDuTY2IS3nX*lm6D^2FOTa?y^t1rM$BivddEzgE+Nru`pfWc4w+iAi#
zBl96UYW_r?$L|YfNLjD^h#%fjBxdVvRJd4E<}98z_U8L6pqfq%O8l(!LDhBm?Mkgd
zlWi9ih-s@EorG<U0g#~ED`Gb>T9`6A!zCtK&Ja1hxt(^?)Xj0|A8Qc4o~I|LAAQfO
zA}@1Yr@zy*TJV;GhE&SBqOmIe09J?HJO*d%^KxUv|NClP(tg1!gexgYd=u>7$P^b4
zCqiiu$@G%aJ@5?{7R}*zM2jU4C=Ea5BauTxI(6eQN~)vP*MMDBBfZ<SxvJLiDN;al
zGgDT&70_ai%Vl%lGx%nXp1=r7yu#S<-pw1+1Z7#yYK?WbiGF|@^+=U<@yfzvFh-nr
zTJ`F0fkn?PU7nc&zdx3}Do@mH81EZtJE)_x?2shQ0?C{fgW3u^lLQsuWaTN)FsN&6
z(%r1&G7j?t=NMhcvU()7$Zasyk5FxGw)Z`QO*Q?3eAFp2znZAVB+lyA%RL1)&lbKo
zkhGF0dQERc1@+u`wa6A8yK%aD1?H$UbcQxJ9HqudFlC4m>HnBvLN4};ItP39*VJfM
zJep4~T6BZ!L-dzE-5Mb;C?Q6BQt@|O0eMsm22sNQ01KNSpQCqr-B#x}6e0MjJ1-|L
z6^aMB0J!hhPf;WerT1lQmRll)j|*-tUE#GP{_XcC8dJNR>_ZnRd{pdkd$Onq54<Cv
zx0J;xpRJ4Jmqk)|1Y=EaNmO@~Se{QfTGY;gQKK+_k<)hrVsJj8uXSJ7cZ=_bkNy_5
zj%a+AiTwOD7cEsl1`NK=jMfnX6BjvLMS3(K*IB+h9cvcxqJP0W{Dj*@uQmZx>r2MQ
z%P?vJypSJlle>(zZ=1Sk<Lwo%t%!A~P8Fw9zd~Z$iKWDLqKanV00hoXCW-_unH^i#
zP8YpPw{f)Fwz&xUy&oa|Ix%~Z$yA=-5A&1c=0qeT$|cjQdRYx7Ik}G+eDR%A195<=
zv>IpI4S=69wCVaaUd1>cN+sPJHs`-`16$glYCoaWcF-g$6il56X!^V<TTuJDXTf3A
zr|)j1(8^6uSe)XuCf6vr0&G2m&&+~Lb>YP8p8c}qb|iDh9?4ACVd4H_{$;Q(F}lxT
zM~&>tvJ6kL&{PhQp-{6C&##FRNNEkSOh9<9mfwN-)wGfAOQ9dq_$YVv7^s>iY@@*l
zNN~nv%h(}GMsE5frfHKA?kS<p=_3J2xA|J`KR{G$#Y<9C*2^3tKq^_OK=BtcfDG1p
zZ^IhY-BGwrDl$BXR60Y#*shOzH<)Te{t+K~gx$2)xhO`n*Ln{BSlJGO^zQj4xegoM
zr)5guQLQs(w~WO9>^v#+VI=bG<0g+bs26TpOX#JYj!7`4cDeSYm3q6*Xyp<`ti*da
z#Zib*H<3MziBTe=kyVSt2RChBPV0K%{sT}lk~<#5G9V)!#Y5d&XsS7$$=jf*CYwk=
z`8-cx&KQyeozF-~9a(#DxQp?(Qj(>)UPkJ5AE!*@w>rptE&UW>L=%R*T#k;!Hmd02
zHyQTu4na%i&W$)Hwt9HCwjL7sL-cB&W5C!FAp7Sd<q)jzSiPHOK-JK?{h+LZe*)h>
zEK_@x@8qQGoq+V!mX}F%N)hSBdEEIz9{Z;$8yTh9G8Hk-yj+kp0FOjn(!h2KdaRA|
zhv@b>tcAq0SJ4xNti01G5_s|;X-{o^tIGmhx~Ty%DXc@5*t(=0@x$+En3rWDJlZ#q
z1eQU<Rj*rAiM=idI^Q_r>fj9g1GL69Uu0GJ6qEHb5!QTC7P~--Ts$cr5F|3|3H*Lu
zHxGKJ`6Z7(gJoMH-I5~}Z~MKn;9U3YtXyGq_%Uj-@xA$ZapDBsw2gIr)b<~K?y{_S
z3(F`g^DJ~=f0uZjQc&46GA$GjLpj8FTZL8icGK3C4<sD)>dN1nc%*}u^re_>MgVLB
z5CL{$gm>%omH3Rd&yuQoL;LV6dgYS*Ce@<9{Q7wo)4!}PSr#Xi)*2YZf5w2lg2EJ5
z>~|<mMSXKtWc<Q}O%(qFv|DB{@VaNg40$a0vLZuVpcBa99r^XwdC)S2=0>_Zq#pE%
zQg0;fbw);%dOt(=-YPK30o}m(4C*$-HNyB~#_!MX*ffToTi(G<$F})3<c6Un2C4{m
z2Nsn~*EIaHCPE7z^14~_RgEmG*;%Hl*1WUtdIeWN;$d&=$?~vA(e78di^&iOhYL_#
zu25jG#wMU5g6AC%=_cZhb(xRYJG{S6X_#Vkmotw@lg~!02?3MoG~;omd&$Icx;c=7
z)fi#)LRQg<cRq_E@Zcik)Y)4G<G+>v01cH@_wix14Q@HvUQ!__>xP!_`VO_7%pG%z
zuqkO|In}R21^2H&KZ6kuf!6T>9Q_XVZ}b7n&867(4L=ej@9W`E2G>1j1}3@pIs1iw
zZZV4C+TVLQx$s0$a#c5TOlPXM(%2X&+8aXP${tZ%$<C(JVvL?h-S?<fdd*|>!tQXo
z7wY|t*A88?_$6sG_<=!UNIbBnt4NaBHRnd`SWfvPy?F_eRrxuLxFxbYQ?H}(__%Jp
zvO70Po?gT#M(INUgE|+^Q|(#pGWW;12QxOds?}`^QfB9n1EcWf8%dOG8@*2GY(Zil
zqQ*OjL@kG|3zt&XHZZCxO|V&w-ft+P$hO@>Gj-=V+DlcZbM0Nsm^pe*z2=S#aEdzH
z&OkA1tm$S}z_9blOl>xuo6jhh?$O1#21y{CdeT3g!y6@!KZ$;Y#w0$PPofk$)-~6=
z>*|)MO|xv8voI`5h>4KF{{CHm<JkObkZ=|Ta8G<bv_37#U*gcD9KTke$YRX?rDE7|
zMUogN#ld;EMe}#Zw#`V+WDt8?=!R_f3g3&m7;om#aT*O|Z&6YiU||-X5%6rdc&%RI
zKN{vuysWp&Bfy=+6rJ15(0lK`{A`WO^NrjmUwSv2sf~+XOZD1Up6)~;oXRm7dp4NS
zt_Wo;V2IZ}S~@(dqBh*WVobt;!IzeXS{uE&yI5?V=FBHqj-aGxPC_l7^aQfj@Ak-f
z)`7!Wg)%=pihXuFPlmg3C#a3HSLQ9CW(TQ>OO;-|ecnaI=Q7-$pY$f!q!aHT&mo3?
z={d5sl_Eu_ePwP&Fj~52^Tqi)uWj8t%Wm<l^b>o@OwA!Bvs1v`LcbRF(aUs)(TI@w
z<zcB)D{k)sLmOXlP+~c4k{H1xshek<kqhezp-?4ZO7A<XUAcmcP{F2^`%~4v2gcGz
zx4Yd<NM6mObN!FFidkX1d=moh4z3<D|1jCNSUMnv{P#aSvcP|%JM^X&qcrTgDjjwA
zgmiuy5dR9VWg4GBOI-i+u@A3k<>m{BKXvUMY3JyY3ewHdkL_`tm{^~o``d+GUUk-F
z$yWE#aIyP!E$yQE%Ry5*eAJ$zlygDV-XilM4IYq6uf`hZaDV7xa}6hs7R75!TCDU*
zEW0A*_YKO+3Lr3<)cMPi%kV!0&jBfV@>bEMW}i5;&SRJOJ8@R{78%}d-OknfC<lg^
zO`px*g}YmP$PK9qCQdk%nF+YXVqCWluP#3i1b*ogoK2sco_OI0F|DS%&;=f<VYBmn
z7vAMqPxLB{d`&2q*HNXrUW8gByYDVgn0oXMVi5hdw+iCA6n+57@7bB)>g$z?-m1!b
zME&@eK2ia?RyyoEdO2>CL3N?>`e%H6x?i>Thd#?Q;kE}@ojDU#O&Y|gs0);4nswX>
zyYEM%mYg(hS`Om%TJk5B_Mfb7K5Y8C=KOMUBmTn+Ge2a)_l8ZCkGJGmdH(>zi)!?H
zK$4BHkSGCYZ0#odqQ*DS5cBYZl9YWy5{ix(re#r2i<JMHg2}zkioiL~V7C>5#`GWT
z-yTu=$J*0wYVeHMpcfU}xn5n{`)`KQ*VVqthtQ_r6p7g*YXe1BMn*%+%;kYF3GqYP
zkno4kA&w!BCwYIRH};T!+n;C=-{JOE39}2V94={Z?J2<x5=^L@Gf@`3mRx+jbjd$p
zsQ^vo9!v!yU<CB$aJ_j6<X=4csXkJcMRk{8q)TcvRJKd{?(x`~>jSS}J{iYKffLrf
ze_dl~(t$_!{X$E+=;GQXqqD@RJUU}T0j~{~EaT0W?Caaa<JwxZ7}xT=$hxg>`Y23$
z?P_!(b0d(;fKMjc?(HBGT%1U%*zz(rEg?jcsTFNe9d!&-I(+nPWJ0cU7&2DMa44sI
zql^V-+*W00{ac0rM5s~Vi#kDOD4m0Qt1aR_PjY3y<AwmgNX{cBhO3qXf4&n7|GoZ4
zaVAt1olx0sO6Q1*9MqipYeV5_r<97|SXLf&iNXEw!pv1U9pTUOq7Oeo7Zci6ikweV
zWJh`}j3E2SFLH`Er$LRT_4L}Vl{FAYNC8kG`J&l@!@$2Hcl?HGNQ@@!evh2Ms{?KR
zX3E6O-7BQFsR0(2|HM(jianGF#F$o%r1Q%ZnV~f0V<eJH)v&j&TAJCFe>u>i55p}M
z{k}3SFFuVKwA2#VI=jMm$4(ke-Kk&^c!fQVmVp>%z!dmF--g;(#?))h+M!Ot#m(8J
zjz^Z#Qxp?0arhY3_9T%cLu@<jIBH{iZkwI+GaN>3&n7K?75Vicy#zgLtg-4t{fqkx
z<5?Q9u&MHXw%2N&0UdO)H={aP2FvVfw`9K}nlh#Z%S34vt|Bmh-py)+7pzo9XS+Go
z;MZfn%A^XuO0$}JXNuId%mvHv^vRhB({jSgQlvTAjo8Rl10Z7UF($Y4X9$~r03t)s
zYd_pDLf}9@`aeMXM_PkE!!dP3y+#W|jlNgBJYW_j&tN@FoQatRxK(vQfdpqwF3xUw
zd;lx{Xq`B_++y)^d(E%z6$*PaL7JC#A+grC!<x(?008t5Tc*uAcg6x^X<b(d*aezK
z!zPW98IUcGqRD)`87*7)DF=TQR4vHUYvH=%5?W2UT}E1$RtFV?n(@}z2=PSEVc}Na
zNX$mWAQGrZLul%kB$GK01(cr@OnCX@Ft1o40N~wd(!73Mi8@Hn_|Wjvf-)Jcwb;#A
z$t*XejrlC6^~p8iH_~l=6;ZzH)%yYIh@(1R+K;@0r3h4`(dVB7NORVj8>5C{hbsgx
zJKxlVIOxBGWVR%=H&hx}4aB6-_YuFnby)vd#pT`8snja(_k}o<T#qg+ATIPgP-EH+
zczKZUdD04E!y)&A$XMpGVn~hsVeQA%d$MNxf#C47F<YUs-RiD$PZ5y<+2^kU`>Kz#
zK(*}`ilnRpx9syqh?5_s&=U`6&e1A#aSMM>y71Q$tJg`sn@fs$d$`-0g1LwmOU>Dj
z^MI=J())K$=F7_7<)u|HrzvgenEm}bIV;~?jzx)?jAl_yZGS5oiDM*dy6=^tN|!C>
z2M!<q;S>C(amXe(o|@*M7mRd2u{vhE{A6!2nfe`sW<{wPQqg0PILZ0tV?`oE>6>^<
z)_D<*q0F==)lMh&FS@MCna7D}(bc^fHLud3bOSKUfY|<7qT(6xziSuvpEXzg94SWK
zf-V^|gXQz&|Fq@#<TiN34}+xnPEAh~SJ<kd>eSqo_Z)T>NxSc*4~s0r^E+-~U#nPK
z)QpIt8&WHN<N^R#Xw3@~j2T|rMB3p67>=G0-G(HJ5{;>ZIk<s-!10z@u}R>5W~?Eq
zcaYbY*N-RG5LjUdSl|(f+f7!JvJ1kF&Z99;6~lIS$aNo`c?-_o`TX~-4zKE-{-N#R
zHIW~}$JyOtJTQgcbSI-q_grFr(9l30mzo(;+MJQXjm{VVdoy&moH|;&l5aIu!NnM*
z4TR1a!11rYs42;5IX3?T<jAv|i)q?;kq0O5xzy&GhbE}&Gkd}Tm)nJjHumbQPraK}
zaR|oIGDyj&9D%tpZutrdn5aGJW-&V6?}GCzkbhpSUx(zqz?vFkfr^iT3{kWfNd}K)
z-h_f1lIb=riK{-x2();!sJFljb4#wWnv7yeS#AG?hE6)hYB&|q&a12x;$0DkK$N{A
zY}gV$P6@%^hUXUt^Q%fQM!mT|bU%5gJbQGOtBmw8!Qkvmpq|6L#oou>W1>6EktXQv
z);&HiJjp*Pg@2qKk=MD%$)`Xh!93|u6BTV^M*)G1it#n{C^T_tpGRQzWyczvtRlA|
z8t?a62<kz=6xvr#OobC;3?(6F73xRF20cN-uFdL_<4pt1;YpT$Ii3hU0R7mTmF@F+
z19h~?JBv7FJ~?78X0u9r6`|d*%fgU}J<~fY<Mr-0azown`i8j~N>)Y_XPp_+<xMt?
zUaDXL5k7Ab;#YwmMP#|}GpRD(&k1ox^@34ur5(VrMXz*i`HhC?eUjTwh|O@B1W7i3
z{RtiW2cVhlr8idgv!9cZn*4}K=A50F_MWs8ZB$-jefmT9UYQexTP=sJ7;YT;2(bdc
z-vn*)&tl7fnR%Uw;`v`XcEfa6{L#aViNOqM&Fe04$ATMG<q$X51E^KG%jhEa00=j1
z=B#e6KwhUZL@+LdPkc}AaP<A7`Hto#7Mx9|rM`1);Ul$URc17SCCXq4E})+=Z-G#F
zKJ>^M_HiA_)o|;-4u^jrT~gQc#W^kY^&e{jkVHqZzcff2==lc-fBZ_vATR;mH*ef(
z+&UK0m^>`N?&s3z<mjhh|I@YD*-hUtqslXZ`?No-v+n@><tsF>?Q%QaXzm$Qq#2&c
zkkxLqJg>+kZ)1WT#~<6}6_cr3U2-V--MfgEt(RMC3iWk!bC}L1tWe+%tJnc9<m^c_
z;zDf5Vxh!sqM_+no7$bDEi%YqjAL@JRQA%>7mbzQX%OtKVhHwMnSXISsZ&!|<m#a;
zG8gnxoc5A6Kl{od<00ct%2yt1xiB6%4L7IhJbntN@rc7@X3HMG0-x`wVx=42o>hA%
ze_DI2WP*g#bO^HSwkM^k$J#0atg-?AGBd{w6#gao5_&jrE8ZJDWqKkDgY})90pSZ7
z(Lwob;Rv;TC}giN;<$G#?Bk81x<J#`v8)40KC&ddbIPTilDB{C&DsjjFPwr8L-l1a
zb=*sRUJ-G>Vr#05==Cj)&n_3gtGJK;n%`QmNX1|xGwU`lp1smE3>d-RB$B=*o9HGR
zQGVd{WI2!#FtTqplBi<3ULBw5i;9XPdy`om5ry~Fl9^-r8v4?tuNV>~6eAbK9AwiU
z5rp96uDk0x;p}j7+u5-4msk_cTAzpB&Lu?onPBwl6z3jg&uFdc=9ePOa#R6i%<@#{
z5)4DSRPlI*_OEi>E4d0h$~U<w%G%Xw%+};}P4J9VhVN|ah)Srqp<6|v?VzsD6Lio|
z<g~v84b<CQHin;G{R3o-wdZ?+TGmcQ$gZqi*(>sbIbT+}&PM5Gz@_gd-4qYzs^pDY
zR8_Ll8kFkneZ@yt0k#6CV`qqk6&7Hsz`H8${bN|UMkgndtG;r5v?fXMlf-kF1~_;_
z{PDO0;d%Z2xB_uJ<)xlhHW2JJxufzU0IB=t*^1$E1I1>ksmV3vb_S;t9f&!&P6Md0
z<X+2JnbTY8%acoOK81Dc_=2C+Wjv;7-IJ{}DFziR{a0zG-dvW}sa2Uq)ulq9FQ}@b
zr)?Ti*Xw3aOW|E;6Bsg%3;Lva*ugF<9X|8sUpHOdf4G~IxzaegIcE$5f@l7k`(w6x
zjLg+@?pIdA>yk1>zq{r`WVZ<k+YDcEQjZ$Rx0$%Px-06Ueu<Z54q?$Q@x`HkyRP*|
z;F8dw)ceJv@i4#!he#0Rsp63@H!-NYVbqPe(y?JP-`p;(Ty6@odN!SxTh@?SG4yg@
z&tE~z?{1bs0)=#HLTmHf@aqDyLs6dqk;?(4fZ#j{o)rF2MWdNH=$+eeEWT%xUZ`aA
zp++D1)(~0YlDoHnOt4aWr%cW(Gy!CvT-bJ0+qx#wM}R<nJQKhR4yX<lzm)FAE4ixd
zxHbpcPV2I-!qCX=Dl>NRE$&HiM)}5IM7%!D0JAaQO8@!Te6bhk<Fbg7fC5WezPkTu
zMea-~*1X;vlX*dEbU`Xi=!eTwb2G!1jaT5JF5Zg+Bg``Knwq#V<C!=njQ4w63<Vy?
zA4XiXO@?%(a|mm}x#EB*%*?%#n(C^DBM)r>yD{H$+4l<~x1^u+DWH3KJ_qcXGSh+G
zhczanfoHJ4^}5%>2NhPU6SA*mEAHkqgDRWKauL<jn4vU>jBl+}>80%p0yAr)aZ5XA
z*3CIe`Ov7KngJayK2^|(jM;3sfhfE6zLJ^Wz_(RB97PmJkp0J4&)NXQsm>nc{yeB$
z9Oc{+qL=c6$zuqFHU8_{!<V-JzcI-NTykoMEqT8}r>eZ634pr@0!#W(Uw5+5CEW@H
z&d||$3r(UJu8$z#xMZFtA}k00xh3c>(?wU>>+m9mF2oUHvlbaCe7LB_T9+iz0_w3Z
zul%0?^BfH0&F0V8YBsja3d?U(MGz&Vt(Ij)k34W&jmOY0I+95siNWv<Lyzm1$Ui^^
ze|&xQHD`-kPJ!s?m<8S9RVGjzae~JK1KUC;U3slae;h4<^xY-ZDjq51rx4Uj1vNEo
zQHb(Ki%=O*k_Re)@!wc?LEP!Olz25=E!0<Zieuqd-L908!1&`HA*NO1`c$8(*G^h%
z>T2xsTj-vOddSgb@hR!dF~pqm>_8xKoc`ZjE8;g#->a$~wS~g#8h{PL`EZioPQyG$
zOHLUWrh8zPZsmP77HSp`Qfxqj_x}KYX!lKQp(rMzXst4Z0R=U5l@X7rRfQCvP7Xf0
z&Aun}_1?9S#jexTkPum^<%&pUd>=w&Y-$@F^7YZ^KjTZ4JtaD*@M+eV!GJvm?9TrH
zaT(9`Yf-n?+j{29BsB9>)KJKF%i*bk3x7^?oc{oSwx?Cm14cWMQ)gmwZEYQus#x55
z7U4xDvTqg$X^ONmIph<J6NAYg-&?oC`KfE@+L}s=X=<QQ(o-GE5xDFhpI*cJXr*19
z><#kthFI<BR8xkG%>uUXR&2=4`jOkP({+JqqC}~NDmg&hrQ(kaTb$=;<0rY)<TDyS
z5`t7Ngvfp^d?JmhX!^UQY-v6E%U2b`aZj}j@Wyh(fywn9`)eLIs*j6PFG$C1T928%
zM_U}qN$_A$3EVwK9hW~{b`MbB>#Vd=&L*a#1$aZZC2`N@{{TQg(_Fpq%IOzI{6xQ2
zQzDO^R7hG#T*L<AUuhijf6G>4UvIc<br<SC5~_52on_NK7i_W9Q$a~cu+u~WqDFRY
z81((W_||9fSXnCt#)|2hi$XxlKgiWH%r_nr!(MQ5eNTOB9X-{PT;K$)4Q>Y_DYh^^
zqXhTutJQSW<!5=QscC#%Dzio;4o9I=?X3K`S++F`7DYq7&SSLn)d;AyQS`q@K`dSt
zO?}cbhMEun!uBMeUPo?ot&`#Po2n;er*5F7rh+*<w);h)8Wc=%x=Av`{d4QU)ReZF
zZ?^$VvDVxH%Cb0Lm*dyL0D6DwI6k9W7fW=tzQIcwj*==lQ~`>7>_P3Y`hJ>T3@?$a
z#%9W@v?cG9`8p+zrJhCuo;HGiPTEnq(OaZP5?WW2m0>6<Pu!dX_tRDO^BoNo)oVNa
zv;di>rQI^Z2Xg4SWdj_N2pZ>(vG}uiuSRZ_6qnm%gKy8#R5Xe??Y<@)k7LO8)tP|$
zf54Jrvj_Z6>aLZryIO1QwX@u+2394ggd?f`uPMU)Kt9>h1)HU9bu<QB+f>C8o$4;N
ze=!tq&*f;uZ6CJ-2iWPB$1Q3_Sv~&%_=86)?(pZS6)`4B^T&{~Mfwsw!PlF_)kc<C
zX{*I`x*_<H%L>dC=Z*W5kGa6-zNQQYl2AeZDWCO+&qYH!*=i{yjy6?Kkfuor5Bb*{
zhi)4Kj`~cXjJ-lNRDwx=Gfdsf9(LsLG56Cg>ZkF9{{X}3p_)!oNGYBozxqlto_)qO
z0hKP%2#v8TPV6dXLAd7x<R3Tw;&kxBsxOZ23ag=d>K*ZTv#U7SA=%|`=G%gDKBJv1
z-eg)7@L{H`YJ$KAk)A-KJn+M4C+VlF;z@6fsl~aeP6p%zx&i0|D-3_%8dSN-BPvQf
zC@I$fK@_YqeMny9>DZWti*N{wwRa^l_*9`>C=Nd|l6`V>jGv~zU+L20XQ!G}WRjLm
ztu#FD&!acfw!BwcVu}iR=B^Bm#Z5c7-pAMh#(+;>Q1Cn+BTsLQ^0ei@l%G#?tu@^d
zAwM@1u2gf<$vY&BVP?)lWVhc@Q*C(n&d(x&jkx7Tj$El>l87}Jc;=0XDrF@~=oJi$
z4M=%k!U_q<kCXJ(0NTZk8TyuJg;Ka-97^0N?g#ql^Sv!>CRK)i5j{g~O#O#_3#zG#
zswBi=6lAkBM4bMb`EQga;TxGi8QYzpXirxNeIfdGiW+1xE6T_YM%;3Kx#wP@jMGz@
zB8oC!o$diE^aD`OTHhkE$wwI8KoXPO>*gw#cF9pA+qV&spYNsIDu?2!Z<Y?gjiZHO
zoak7b*0Y+Vj7(dWJ@xX2t!YBXFjtozVC|fK+PxKG)J^1x7%B8l+TxmoMZ%U~(8{ky
zLIoj7Qcw5O(7xQ10rRnpagELX`p+rMaT6h`XyymXil-R+=+f1pP)trvG%PI6si8li
zq<ON~I{3^0?Wo@)*YB_0*Phz0<uxn4LEJ+6>+DX<;2ywgPYh=#8u`5=d>s$o6tGcM
zJm*7dB~>IZ@2Tn>$~>N$86-?e$vPH>l62bO=Z~(b%>;=1m&`RZYmV$NKDzkT5$9+-
ziSz?HS^LI;x%v`f8;Stl<Yz=E?b27T&)g+gD1&3>W>W0u`eR?_KigI53@AKlsotam
z!mz><=rP^Du>0yN!*;vO8d!>`8xwKz#=gLM54O8nfL%fEp;#}`(MXh*H2DZ6V)IO(
zNmS?#0cj7F2|vn!p2Ln#v;MuE>10c#wnw$KcJU=`MME^}8u@T%Ief7v$r&EJ9A{3i
zU}mO_)YZtOWtteGAUC$>_5=LRt6zFRbx%xOs;<*Gq_xqz#ETz-o0U%0UgW4epK?Z|
z@>G<wCk&kJXEa}&_=cXxZ+pDX*lFrp!>8}u!Z2Uyz4`TB5wX?v&6EZ#YhEB!QI=JT
zoOcQ38$tg7kwyovJZiKT1Jbu3mv$*oThwkS00gl1Ir5KgeTKEpnVt&OidBTt)0Ey8
zM#CSk)4%R@n5<M#mAxM4-jn!|9aS<@^<)B`x=$;rM0V4HI2k|8eZ4d3&Y$fxR{FY7
zwmOh0-9{A~oO93pbwV0zO-hL6rHrZMjib%}!|Us-7W-|s-(2!jO3}*gyK0OD9@zBz
zYK6`L9Dp)XmJLWQpAD^*tV_hrD;$>GPJaIYPCI(`(sftD$sxH@Vilh;V6j{%&h8X`
zib?Kqk6mmw>#aGKNaf3fz|Vetv~6nb<?_Vjd9qg+)nTzXuwuc;hNgMa-wfh+M!G<f
zJ0juLNWt|ScN`9WpRTnlZ%5HumE;P7HX)oA&T;F{wlxA@=x8DgA9-Pb6lr?z)-B?&
zl0``J0rO;I-05c~EJJ2{i{vov+o`PGGGA#^QH{zKGF$9G=k2V2tiCbct`Rus`)f5y
zwi%^Ts>*v2`tj&TxYI>t*4b7IY^Qfah2(Rc2%hgp3cGD9fs6>jVf4qYvvYYYO%A1a
zu&5SB=0y#Ut9q8=Dte+?+f`~6dU~6EV?jD|oUDpLKTt+Tq0@yIPTOhgXRml_Bf6pn
zsJYTWA*wCv(#8U$z~jGj>c?Jg{c}lA3d>I-ylxKJ(lEhs-CaEo*Nq_GI;yh&02;|_
zX=0K#$avU-2irV<f74PNr{v0pGI|vqI-2AywwbHsqNBK5q92K0Zc_<}p2kR9gm0sT
z1n?Z|F__m^*2Q09c$y$LkC#S{q%Wu75_bXr04ZVb#;!zasqPe)7rsmULNeogCkV>i
z6>-MkeL>2f=2PEQt`rp4M0jWx8$Iea4v@+CRMmdJgURq)kIGKQ{!+cP#bDh)Dp$Cx
zUvrMWCyf#>oRUEttT!nqBoevcH@f5X9kgzSj+#0{PgOMWJ0h%WPcVgu9CDz4kvbhg
zN^VtBMSF>UZ~&4|v<iej^8<k69{y}#?juESHZw^~vRUG#no4)_JYW$nc;}E+zK8VF
zIa$;iA2DvEAgG!aFD*!uG3GTx8utV~-#6=^SK1gRRhpK8s3Z@Xxuh7}xa5taKdyar
zZk^(+c_~FDQq`jonI<ZL`jErSqxHtA-Xj+3KMtwHPc8$-krrkiq)E8sW1J8*P9`@J
z>p~(|e2rZ+kXj`$GP5a~D9eWXvFtxxDZt53C;k;=k>hVNlYrmfBTdk(5kG|s)JaPm
z?4@Iq3gaH5XgJW*X^OFGz)4uE<x21|?l|CURZR(=L?0{<G;-V^rr%Bn;znOA27kHG
zipnpX-y{*u6Ku?A9FU{bvC-;Ex;mR=)J#NGQSK_i*;tQEW6IhUJv?#SnUYy&+(3|_
z;~t=$G!p=bDw<lRRf;bZz=sm-Y;HP=8aTynRI){$Q1V8;Aem}iY3dQ8ZcZfh_BxuM
z#ZclXnVg&%0qyo0>C_>!4oWE=n_|=mHu4>m62EV41&UZHWhS0gtPR^B<m&K&s%e=J
z7>WGO#{~WJtJYg7+EM003E;0`r3MPShs3eerB5`AIwYvD$Bg5{<o>#6q7g#M%TXI-
zaDja_O5tFnr3Iy#o?<era##1!E}oh<R#;=+*uxFIv@F`O2?xZZSwkz;MrpiFzsyJg
z4H8w5C<WiPr>wR^H-`)_EMvT+wg!l;1*j+<B&P%V_0Zsn%A-5@g6o||)2hZp72{Fb
z?N>XT0Jc|-Mu~sHZ-6Q#Bj22A;;mOYGvoN&6qT@y<+JaNLnTOT_)#<I!i%LX^y!&d
zbMACap|jCKakGJ-r5%~?TOs``Gumou`jhx@l^<+qj6E+~QIjie{WN*6^w6mk(C6v~
zHBq{jb`7x=2c~(@9JtqA!Wi?v%|TOix66WBLdWlod!@BfKnqI1`}5!R)D^XrHEeuI
z&OMinK#o8m*tfP$qkOh>C28a9+|aDGG;zLIvjrYqqX2!iELX}##Bjj!H`k2{F{x9L
zll9eQU9FYid+C0zLD7w09~X5S#PUxAouL;VZJ-@6S*cd(X%_dR5m8D%8CY&<2t0m+
zzZyoj*OX;felj>z41aBFR56Nc1T`|#sMw|7#$X#^<dK2L+e`<VnI?4@>V)9$irp_)
zZtFVMmI(sOQpX4K#|nZ~f6MpOy&+L^x<MR_$gEdrX_(<ylY*=3^w!<+2E`9o`1O{Y
zQlV|J#LOB-AI#t$Ko}kLk8HFHWFa>`*nEHt10nwazg=YHC3RAaWH6SkvELdsfYhoe
z$=rZ5=jwZBzbD_*8fmmyCyf=Eikx>Rb9dzZ&%UO&!#hN(%ArmU-oOnr(Z*PXh~$o0
zfWRM5zLJ=k&gYvTQK?Rzh|tE%5I!RulicdnaCD@NP@V08^*-lDBct7d+-I=Wdb&^~
zjGjB{hQLu|<0Y8CTCGatmcqK8{)a%W2mb&L&Zta^!~VvN-WbapfHKH%54MF-PL)*U
zrc$ntvDe(|HzxEYxXo@W{{RJ!N8bwgMX*T&13uXF)hnf%w`fwz)Xjk)W+OQ4f6GqN
zLaJNB0g<@}>-7D!GQEQ%GJ+Tk;2&IjYFepCYnl3VZN7%0O3k3k?Y+F@jQunJ0B2TE
z!%jlQA~LY@>;Mu6q1EZ`inF?wRdpkB5=YpNOld=@>t<-CdP5v?L*^n!9Ovi{I^f)8
zlPg{&dD3Yi#D*qqgT>=NTyy*O)^B#LlBFbyId->*HU)KHt)AeXM<e~TR=VizBFQj|
zX~OuW7oW2OgQd{ZRMsO!1freSBo*Xf`}%g(_?EX4-$|qN?K{=m6x}I}S&tZa*efFX
zlsM!Q`IGYG<ZUFKd#|fn3dlZL-UeZaq*f^$xc>n3*f1aw>Zg(Y^b$3yq=Gt%dZj?B
zs?snyA90)&Ad#I{t*UDABva0dOb9Nl<s+zHW9-A+V1hJY@;izmq?HvbTjR(esG+Gj
zC?Pwk<UOztb@#@Wu2oPiB|}XlDO(E<%S_Bv{d1F#uOn6Zhs39ZOJSGiDV3BwQc0JH
z{X&tSzaafPXhpJ)OURBDk%O_sk%S{|efS64SK><9lDWMIVxEFZ+G^^GN{QNKkMQag
zVF2z_FARTdX(DQwW2oFgPdDO3PBK2EdL3z<Oz?jPh6;*!;%K5&@fQob2OQw!kD>4B
zq?l=ErdNS!T4a|EkgCc%_9vWY(^q3UksjjB(w>$|S9)oOha>01AmJGOHA<F-nx+&~
zk)e|WGJtTzee~N?Mib^1qLoMCV5~>Xo}q?-+0<3TBy-Lri1Pafn|G$0%i9DEz>~(v
z@_EuGLxn|zDf;8<s#KD)Oh=0(%*VS75u&$RGG>udMwG-x)4(U}HTY3ecw4G`7^TQy
z<x05!0DTpT-0;zs>C&l{rujK1Ps@-yeQ<PY$s|<}h|b8@cVW*usZU!ZaU_Ygk6`B@
zXI5jZnrY&evSP!t6;Qa;%ylSHxMH@R8Y*!+IINQZ7y@ukbUvQ4q3%#mNkA!Gj@J>U
z2koM5ENpPG{L`@VF5Dl`>V+M3bp?5*o+XXkaMIvlduz%`TAZ!iFHuoG=1QzOXDyW(
z)i%3QDI*i`al-NbT5Ey-007B9hRcjL2IHzk(-KIzN;B!<4nMY=gBfw57m<RUnccAU
zgw%30QN^`$uT>YSs-vF}fPbe#o*3pOf%6aVuZdD3@-WUcM<G3#dg4{+ORZNR{O-;7
zI{YUNzH|HPn@Cs_jA{TFw+D?Ro$5FVf5jiBqLNXL`PFxns&_hqDNKZh_0q|P7F$Ua
zWD}^_hWw3rFr1bjzP>Iw&Q85N1enfQcJr@M<8PUFeF@`L(SSS+T8>1=JI+6+8XLG(
zLKC-3H9jTUkj4)_9HKTqO!pevX;wRxg;Aqe<C+X@@i&2y{a(L)Vf1lHRU-IwvPipt
zG8JYE`)hFN-w*gLD$~d$R86~pz|XF$@x_up(>Kh}26HD;Ty9-Ibf~mYQO#QnhmQ?5
z06AjsA>#wvLTToS-Y1z1(#gul86*MjSo&zc$Eq8XT;&w8JvdJ>Zxeai59Zo(KTH#(
zUW>b^mlr9fsd90-_zwQcJD+lU4Q2owm4r0Bgw(ANNm$BRM~1(YV+uZ}J^ujLPIQsS
z41O3nAmog4PLS=lN}Hsjp45dS1bCGm-$nlbeLPT7r7~^FIOLLYPuE&lv4t9uyAojt
zhUV9r*f&Spw{3cW<+F@?Xo-V-c<+IY6Q!(LnlU!AlXmYY$vRJ-IVmb++CL47?;lad
zb*5F)o<=f8l<u@E7&riseLnj6zatwV>T2R}!U3qNUzbgoRu~7K$3OS`=|bspG@+hm
zW>tU8tC9z75$oGk`i^;M-a`{UHyK9WGF87X&=H^5Xbo>uQ(Y-uN^%^;>=`)(^Ugk_
z{dEfhb|uI@3=w;}Nl#XfOH`#MJUK%q-f`dCKAK6mU!FrFnIk1ZBp_b?{%`WmsopCj
zuazgIXMu@jWFV;9k}`j{I;kWxRTU4gvaT6+0!KWMeRWFX9huu8R9U)R&30e{RRpUL
zNM;=KwEK4BzMDEawmO<<gM;HMV{?M1chq;+rTBF%LkSi~G4NB4PJ8k@{=dGDMboQ5
zW6VsUe7oC|k7Mtq<jIV$6@aS1*@SB2r4;2VDbpi|9m50dkM+<x`R#PH6$(<SH*OJW
z*b*1mjPc0PD%*VVMJ+~5u?UXUV}qPv;QRd!vn!qADyvk`!z3$Eq_ie?F-V{2e&63m
z<DqDrt;R2kowf4T+mcGESes!~asVg3@#*^gHK6po!nbS0Wr)g2MlMT_Oe<t?KW$}}
z3QN1z<_4%TNcfn6y+9u4)E~Ll#YGDXLsKE9TZ(zmu48l~^C3O?7$e``TA2U_go#e9
zz;(2>(pFT}TpD_qq9vM1Ayp)Ev>X$hcg}@Vzs>EEMrUBfRnbVnKDY+}YV>vS)~!?C
zss2@7BNS8T%FWMl=zH=pptiUk3skiT+nhGd@gL2PPJ8~EdW}h&xF4vlP}`NZ%=HqZ
zZDn9`N8d}f!7EEFi5B=s$q}|2_toB@rjlO@qDFNL3CJ1GxIeCmTPWdzmF8vJF3s6o
zfIm%8X;v*kCJC#mrlgUkqcTpen3g%1We>R5nBi-|kLIdLj1R&C(Eart{a`i0(OtJL
z3ugd*^iQYC)3U~gxWV4MkFnC+@mmqt#hNnr$iYhkEVHsV7~C>5{#vO|MAN%GF4Exn
zOo@Sypd4wgXsN1{K!IJP{{YM+XBq(&Ec8{)O}MOCzzrv-r|GHH>=^R9h3(XlV49S8
z<RkM$<w(`Wv(O^2ZRS?|uJ5~X`s>sb%@ZS3F(@&DtJ_{Lp;9!F;#Nd%AAZn3Z(Va8
zvubhuq7tWQRuzh%8BQ^k<PBD9Dl-zQ_$MQis&utOYLMGTJED#TtsA{CBzUrG=zKIP
zrlwDj+>Gu;jn(-)9Z2-bM(^g-vg8gAeMVTQ!RJ_jP_sUg@2OGbVUdCdro6@<InJhZ
z4naDZ5F&f%K4Hj;Zcf=ctdW&+Fm-hfU!LCD`zAAxF|HlXgHkZ9w`kXl1P6AlZo(2i
z+N{}fbLpXkC*Z1auUmo-DIk&PbzBlV9aw-zmT8o_s*|)f+?;XFyeBG20zBDL&$RoK
zxAoS=(KRvC*<O()YN?<kl|mbCeKIwV{PfZ6XoPB2ff+!<_CA_s>8ok1v)!f@GgB~&
zW?*fcbDc98Ds?6DR5ES?>#F!}6|>uAfY;TN__VR$CgYqejt)=TI>hC)Lk-9+Gc1vV
zvO=fxoc>kzLGSC1eYEXUbsxf>D`hk^D&(Mb8{Y+pV$6ABaoqc!G??{Rx=e_q2qZB?
z3E*LKxQudn`wwkPtCOYCnys3qIvC-ni^Enb0F4hnbM(_~wsoC%Zp!=n>lf+j$A*dI
z9K7-rX7$E-=j*L9*HZo;gt%2y&l=dqc`Sj&7~cg-w7@52_0gD^Dh_$lMHN%6LNE1m
z`)QIYmN;)=+x5}ah`WSpAP*qNwwEtf^3cn$4c)ZHWgsgNk_M>NHsp3AxBF^rm{r9X
z)N-d&3hFz1c=D$i3dd*E^PO|`RZClLlT%9rgsLj>IvnkOK?m0v{YEv@e-UC3%S$vq
zNd&Bf`-T|jSVcv;How!&A>JjBzQQ<DgPeUbHS@VqFtrJ}g_|PWOsTTm<Hc1nIen*k
zo>ot|9rXLty&`T_^qQhC#&8@kINRGGX{N;tbx~C#AYTebkB?uk_tmOp6zK?u$?7q{
z7~@g9G0~I)J|%i9GSaI8+eUdA_4Ux|$SI`COHeS532m4pdmpc+biq>~SZ6MxK!?k_
zxX90aEnUcl63U^6n<2U64te%I-u&nlY|dPxI*WWYbj-2LB}Or{hhf0&_ZaWojdNYX
zIV!G`#}mA=G{j+owtL{I9=*G8MzpTI>I#}RsiUR?!VA03cOFhZPW{G|x?0pKE7qQ>
zQ!)v|DP<dmeKW1E9C~P2$e-TT8oD~mRZUF;OG@!hP8regSbawT{r;L|zE+j-qN<f<
zjv~2?0phE6;fUh{o^*EIZWO|*I3+0b>R2{17z~UMbH+58QwW0p09<NWs)VS|Dlx*o
zJ8(D$9>3dOL&({H`p}CM^r>>WPOVc{Jtj`XP!qrP56XVH)R!AlT98Lbl2kw&{{V84
z+yU*T8(lOeBU4VE2b*g~4pjYd@2YqGuB@OG!U70x-0IY8H6(FD=6O*<D!fQ&;XxFD
zvqj=^53V!FI<p!{6)a3w@ZnOkAd@afx}8@L!B{6X5Q8eC5bAJ22fl`dY16}2@WQU}
zah~3qsO~96N?Asm!H%6?Hjw$GY?l83Z8B0@g(Wj#<0m6-;7;GBbSem=mb5uQBaxJt
zz~N80_R|#eNk)nC&9TmW*w5|{eNN`h2|@~6pDilW7ZtK#{{Sda{zp>WE$GrAf5n)e
zC!Y<EuD)BOdS)_~5*8UDlw&%(cd3?<A(=`rnRo3dGN<TtwFJFJHkL$1L~(%AU?;n0
z^w8@0s%C^P@f?2bj{gAXt1{QOhO%s2$fG&|Smma}oPn($8xG`IvTA-tYGBG{BoFE2
mY9HcF{b&CG$bYt}TpPh+u@+uE^ee_X`fM1zvl}i=&;Qx~GPX<r

literal 0
HcmV?d00001

diff --git a/packages/modules/providers/file-local/integration-tests/__tests__/services.spec.ts b/packages/modules/providers/file-local/integration-tests/__tests__/services.spec.ts
new file mode 100644
index 0000000000..6b93255d83
--- /dev/null
+++ b/packages/modules/providers/file-local/integration-tests/__tests__/services.spec.ts
@@ -0,0 +1,119 @@
+import { FileSystem } from "@medusajs/utils"
+import fs from "fs/promises"
+import path from "path"
+import { LocalFileService } from "../../src/services/local-file"
+
+jest.setTimeout(10000)
+
+describe("Local File Plugin", () => {
+  let localService: LocalFileService
+
+  const fixtureImagePath =
+    process.cwd() + "/integration-tests/__fixtures__/catphoto.jpg"
+
+  const uploadDir = path.join(
+    process.cwd(),
+    "integration-tests/__tests__/uploads"
+  )
+
+  const fileSystem = new FileSystem(uploadDir)
+
+  beforeAll(async () => {
+    localService = new LocalFileService(
+      {
+        logger: console as any,
+      },
+      {
+        upload_dir: uploadDir,
+        backend_url: "http://localhost:9000/static",
+      }
+    )
+  })
+
+  afterAll(async () => {
+    await fileSystem.cleanup()
+  })
+
+  it(`should upload, read, and then delete a public file successfully`, async () => {
+    const fileContent = await fs.readFile(fixtureImagePath)
+    const fixtureAsBase64 = fileContent.toString("base64")
+
+    const resp = await localService.upload({
+      filename: "catphoto.jpg",
+      mimeType: "image/jpeg",
+      content: fileContent as any,
+      access: "public",
+    })
+
+    expect(resp).toEqual({
+      key: expect.stringMatching(/catphoto.*\.jpg/),
+      url: expect.stringMatching(
+        /http:\/\/localhost:9000\/static\/.*catphoto.*\.jpg/
+      ),
+    })
+
+    // For local file provider, we can verify the file exists on disk
+    const fileKey = resp.key
+    const baseDir = uploadDir
+    const filePath = path.join(baseDir, fileKey)
+
+    const fileOnDisk = await fs.readFile(filePath)
+
+    const fileOnDiskAsBase64 = fileOnDisk.toString("base64")
+
+    expect(fileOnDiskAsBase64).toEqual(fixtureAsBase64)
+
+    const signedUrl = await localService.getPresignedDownloadUrl({
+      fileKey: resp.key,
+    })
+
+    expect(signedUrl).toEqual(resp.url)
+
+    const buffer = await localService.getAsBuffer({ fileKey: resp.key })
+    expect(buffer).toEqual(fileContent)
+
+    await localService.delete({ fileKey: resp.key })
+
+    await expect(fs.access(filePath)).rejects.toThrow()
+  })
+
+  it("uploads using stream", async () => {
+    const fileContent = await fs.readFile(fixtureImagePath)
+
+    const { writeStream, promise } = await localService.getUploadStream({
+      filename: "catphoto-stream.jpg",
+      mimeType: "image/jpeg",
+      access: "public",
+    })
+
+    writeStream.write(fileContent)
+    writeStream.end()
+
+    const resp = await promise
+
+    expect(resp).toEqual({
+      key: expect.stringMatching(/catphoto-stream.*\.jpg/),
+      url: expect.stringMatching(
+        /http:\/\/localhost:9000\/static\/.*catphoto-stream.*\.jpg/
+      ),
+    })
+
+    const fileKey = resp.key
+    const filePath = path.join(uploadDir, fileKey)
+
+    const fileOnDisk = await fs.readFile(filePath)
+    expect(fileOnDisk).toEqual(fileContent)
+
+    const signedUrl = await localService.getPresignedDownloadUrl({
+      fileKey: resp.key,
+    })
+
+    expect(signedUrl).toEqual(resp.url)
+
+    const buffer = await localService.getAsBuffer({ fileKey: resp.key })
+    expect(buffer).toEqual(fileContent)
+
+    await localService.delete({ fileKey: resp.key })
+    await expect(fs.access(filePath)).rejects.toThrow()
+  })
+})
diff --git a/packages/modules/providers/file-local/package.json b/packages/modules/providers/file-local/package.json
index 8b63377efc..93f5a18c25 100644
--- a/packages/modules/providers/file-local/package.json
+++ b/packages/modules/providers/file-local/package.json
@@ -21,6 +21,7 @@
   "license": "MIT",
   "scripts": {
     "test": "../../../../node_modules/.bin/jest --passWithNoTests src",
+    "test:integration": "../../../../node_modules/.bin/jest --passWithNoTests --forceExit --testPathPattern=\"integration-tests/__tests__/[^/]*\\.spec\\.ts\"",
     "build": "yarn run -T rimraf dist && yarn run -T tsc --build ./tsconfig.json",
     "watch": "yarn run -T tsc --watch"
   },
diff --git a/packages/modules/providers/file-local/src/services/local-file.ts b/packages/modules/providers/file-local/src/services/local-file.ts
index 5ca891fbbe..534d5e5634 100644
--- a/packages/modules/providers/file-local/src/services/local-file.ts
+++ b/packages/modules/providers/file-local/src/services/local-file.ts
@@ -3,10 +3,10 @@ import {
   AbstractFileProviderService,
   MedusaError,
 } from "@medusajs/framework/utils"
-import { createReadStream } from "fs"
+import { createReadStream, createWriteStream } from "fs"
 import fs from "fs/promises"
 import path from "path"
-import type { Readable } from "stream"
+import type { Readable, Writable } from "stream"
 
 export class LocalFileService extends AbstractFileProviderService {
   static identifier = "localfs"
@@ -78,6 +78,59 @@ export class LocalFileService extends AbstractFileProviderService {
     }
   }
 
+  async getUploadStream(fileData: FileTypes.ProviderUploadStreamDTO): Promise<{
+    writeStream: Writable
+    promise: Promise<FileTypes.ProviderFileResultDTO>
+    url: string
+    fileKey: string
+  }> {
+    if (!fileData.filename) {
+      throw new MedusaError(
+        MedusaError.Types.INVALID_DATA,
+        `No filename provided`
+      )
+    }
+
+    const parsedFilename = path.parse(fileData.filename)
+    const baseDir =
+      fileData.access === "public" ? this.uploadDir_ : this.privateUploadDir_
+    await this.ensureDirExists(baseDir, parsedFilename.dir)
+
+    const fileKey = path.join(
+      parsedFilename.dir,
+      // We prepend "private" to the file key so deletions and presigned URLs can know which folder to look into
+      `${fileData.access === "public" ? "" : "private-"}${Date.now()}-${
+        parsedFilename.base
+      }`
+    )
+
+    const filePath = this.getUploadFilePath(baseDir, fileKey)
+    const fileUrl = this.getUploadFileUrl(fileKey)
+
+    const writeStream = createWriteStream(filePath)
+
+    const promise = new Promise<FileTypes.ProviderFileResultDTO>(
+      (resolve, reject) => {
+        writeStream.on("finish", () => {
+          resolve({
+            url: fileUrl,
+            key: fileKey,
+          })
+        })
+        writeStream.on("error", (err) => {
+          reject(err)
+        })
+      }
+    )
+
+    return {
+      writeStream,
+      promise,
+      url: fileUrl,
+      fileKey,
+    }
+  }
+
   async delete(
     files: FileTypes.ProviderDeleteFileDTO | FileTypes.ProviderDeleteFileDTO[]
   ): Promise<void> {
diff --git a/packages/modules/providers/file-s3/integration-tests/__tests__/services.spec.ts b/packages/modules/providers/file-s3/integration-tests/__tests__/services.spec.ts
index d205900601..ed914469f7 100644
--- a/packages/modules/providers/file-s3/integration-tests/__tests__/services.spec.ts
+++ b/packages/modules/providers/file-s3/integration-tests/__tests__/services.spec.ts
@@ -49,7 +49,7 @@ describe.skip("S3 File Plugin", () => {
 
       expect(resp).toEqual({
         key: expect.stringMatching(/tests\/catphoto.*\.jpg/),
-        url: expect.stringMatching(/https:\/\/.*\.jpg/),
+        url: expect.stringMatching(/https?:\/\/.*\.jpg/),
       })
 
       const urlResp = await axios.get(resp.url).catch((e) => e.response)
@@ -95,7 +95,7 @@ describe.skip("S3 File Plugin", () => {
 
     expect(resp).toEqual({
       key: expect.stringMatching(/tests\/catphoto-か.*\.jpg/),
-      url: expect.stringMatching(/https:\/\/.*\/catphoto-%E3%81%8B.*\.jpg/),
+      url: expect.stringMatching(/https?:\/\/.*\/catphoto-%E3%81%8B.*\.jpg/),
     })
   })
 
@@ -112,7 +112,7 @@ describe.skip("S3 File Plugin", () => {
 
     expect(resp).toEqual({
       key: expect.stringMatching(/tests\/catphoto.*\.jpg/),
-      url: expect.stringMatching(/https:\/\/.*\/cat%3Fphoto.*\.jpg/),
+      url: expect.stringMatching(/https?:\/\/.*\/cat%3Fphoto.*\.jpg/),
     })
   })
 
@@ -128,7 +128,7 @@ describe.skip("S3 File Plugin", () => {
 
     expect(resp).toEqual({
       key: expect.stringMatching(/tests\/catphoto.*\.jpg/),
-      url: expect.stringMatching(/https:\/\/.*catphoto\.jpg/),
+      url: expect.stringMatching(/https?:\/\/.*catphoto\.jpg/),
     })
 
     const uploadResp = await axios.put(resp.url, fileContent, {
@@ -169,7 +169,7 @@ describe.skip("S3 File Plugin", () => {
 
     expect(resp).toEqual({
       key: expect.stringMatching(/tests\/testfolder\/catphoto.*\.jpg/),
-      url: expect.stringMatching(/https:\/\/.*testfolder\/catphoto\.jpg/),
+      url: expect.stringMatching(/https?:\/\/.*testfolder\/catphoto\.jpg/),
     })
 
     const uploadResp = await axios.put(resp.url, fileContent, {
@@ -221,4 +221,42 @@ describe.skip("S3 File Plugin", () => {
       { fileKey: cat2.key },
     ])
   })
+
+  it("uploads using stream", async () => {
+    const fileContent = await fs.readFile(fixtureImagePath)
+    const fixtureAsBinary = fileContent.toString("binary")
+
+    const { writeStream, promise } = await s3Service.getUploadStream({
+      filename: "catphoto-stream.jpg",
+      mimeType: "image/jpeg",
+      access: "public",
+    })
+
+    writeStream.write(fileContent)
+    writeStream.end()
+
+    const resp = await promise
+
+    expect(resp).toEqual({
+      key: expect.stringMatching(/tests\/catphoto-stream.*\.jpg/),
+      url: expect.stringMatching(/https?:\/\/.*\.jpg/),
+    })
+
+    const urlResp = await axios.get(resp.url).catch((e) => e.response)
+    expect(urlResp.status).toEqual(200)
+
+    const signedUrl = await s3Service.getPresignedDownloadUrl({
+      fileKey: resp.key,
+    })
+
+    const signedUrlFile = Buffer.from(
+      await axios
+        .get(signedUrl, { responseType: "arraybuffer" })
+        .then((r) => r.data)
+    )
+
+    expect(signedUrlFile.toString("binary")).toEqual(fixtureAsBinary)
+
+    await s3Service.delete({ fileKey: resp.key })
+  })
 })
diff --git a/packages/modules/providers/file-s3/package.json b/packages/modules/providers/file-s3/package.json
index b460bb05e3..54bcf993f3 100644
--- a/packages/modules/providers/file-s3/package.json
+++ b/packages/modules/providers/file-s3/package.json
@@ -30,6 +30,7 @@
   },
   "dependencies": {
     "@aws-sdk/client-s3": "^3.556.0",
+    "@aws-sdk/lib-storage": "^3.556.0",
     "@aws-sdk/s3-request-presigner": "^3.556.0",
     "ulid": "^2.3.0"
   },
diff --git a/packages/modules/providers/file-s3/src/services/s3-file.ts b/packages/modules/providers/file-s3/src/services/s3-file.ts
index f617a722f8..83d76ac66b 100644
--- a/packages/modules/providers/file-s3/src/services/s3-file.ts
+++ b/packages/modules/providers/file-s3/src/services/s3-file.ts
@@ -7,6 +7,7 @@ import {
   S3Client,
   S3ClientConfigType,
 } from "@aws-sdk/client-s3"
+import { Upload } from "@aws-sdk/lib-storage"
 import { getSignedUrl } from "@aws-sdk/s3-request-presigner"
 import {
   FileTypes,
@@ -18,7 +19,7 @@ import {
   MedusaError,
 } from "@medusajs/framework/utils"
 import path from "path"
-import { Readable } from "stream"
+import { PassThrough, Readable, Writable } from "stream"
 import { ulid } from "ulid"
 
 type InjectedDependencies = {
@@ -165,6 +166,53 @@ export class S3FileService extends AbstractFileProviderService {
     }
   }
 
+  async getUploadStream(fileData: FileTypes.ProviderUploadStreamDTO): Promise<{
+    writeStream: Writable
+    promise: Promise<FileTypes.ProviderFileResultDTO>
+    url: string
+    fileKey: string
+  }> {
+    if (!fileData.filename) {
+      throw new MedusaError(
+        MedusaError.Types.INVALID_DATA,
+        `No filename provided`
+      )
+    }
+
+    const parsedFilename = path.parse(fileData.filename)
+    const fileKey = `${this.config_.prefix}${parsedFilename.name}-${ulid()}${
+      parsedFilename.ext
+    }`
+
+    const pass = new PassThrough()
+    const upload = new Upload({
+      client: this.client_,
+      params: {
+        ACL: fileData.access === "public" ? "public-read" : "private",
+        Bucket: this.config_.bucket,
+        Key: fileKey,
+        Body: pass,
+        ContentType: fileData.mimeType,
+        CacheControl: this.config_.cacheControl,
+        Metadata: {
+          "original-filename": encodeURIComponent(fileData.filename),
+        },
+      },
+    })
+
+    const promise = upload.done().then(() => ({
+      url: `${this.config_.fileUrl}/${fileKey}`,
+      key: fileKey,
+    }))
+
+    return {
+      writeStream: pass,
+      promise,
+      url: `${this.config_.fileUrl}/${fileKey}`,
+      fileKey,
+    }
+  }
+
   async delete(
     files: FileTypes.ProviderDeleteFileDTO | FileTypes.ProviderDeleteFileDTO[]
   ): Promise<void> {
@@ -207,7 +255,7 @@ export class S3FileService extends AbstractFileProviderService {
       Key: `${fileData.fileKey}`,
     })
 
-    return await getSignedUrl(this.client_, command, {
+    return await getSignedUrl(this.client_ as any, command as any, {
       expiresIn: this.config_.downloadFileDuration,
     })
   }
@@ -238,7 +286,7 @@ export class S3FileService extends AbstractFileProviderService {
       Key: fileKey,
     })
 
-    const signedUrl = await getSignedUrl(this.client_, command, {
+    const signedUrl = await getSignedUrl(this.client_ as any, command as any, {
       expiresIn:
         fileData.expiresIn ?? DEFAULT_UPLOAD_EXPIRATION_DURATION_SECONDS,
     })
diff --git a/yarn.lock b/yarn.lock
index ecedfd8e34..df1b7f2376 100644
--- a/yarn.lock
+++ b/yarn.lock
@@ -580,6 +580,23 @@ __metadata:
   languageName: node
   linkType: hard
 
+"@aws-sdk/lib-storage@npm:^3.556.0":
+  version: 3.948.0
+  resolution: "@aws-sdk/lib-storage@npm:3.948.0"
+  dependencies:
+    "@smithy/abort-controller": ^4.2.5
+    "@smithy/middleware-endpoint": ^4.3.14
+    "@smithy/smithy-client": ^4.9.10
+    buffer: 5.6.0
+    events: 3.3.0
+    stream-browserify: 3.0.0
+    tslib: ^2.6.2
+  peerDependencies:
+    "@aws-sdk/client-s3": ^3.948.0
+  checksum: 11edd46ee1f2ef74efbf9b5b422f77d2c792693bd90051ef3bda6ab36e76f2b6533f531df5d390da31c757efcc98b0513d70a14a28561eefa13e641847d1831d
+  languageName: node
+  linkType: hard
+
 "@aws-sdk/middleware-bucket-endpoint@npm:3.936.0":
   version: 3.936.0
   resolution: "@aws-sdk/middleware-bucket-endpoint@npm:3.936.0"
@@ -3580,6 +3597,7 @@ __metadata:
   resolution: "@medusajs/file-s3@workspace:packages/modules/providers/file-s3"
   dependencies:
     "@aws-sdk/client-s3": ^3.556.0
+    "@aws-sdk/lib-storage": ^3.556.0
     "@aws-sdk/s3-request-presigner": ^3.556.0
     "@medusajs/framework": 2.12.2
     ulid: ^2.3.0
@@ -13465,7 +13483,7 @@ __metadata:
   languageName: node
   linkType: hard
 
-"base64-js@npm:^1.2.0, base64-js@npm:^1.3.1":
+"base64-js@npm:^1.0.2, base64-js@npm:^1.2.0, base64-js@npm:^1.3.1":
   version: 1.5.1
   resolution: "base64-js@npm:1.5.1"
   checksum: f23823513b63173a001030fae4f2dabe283b99a9d324ade3ad3d148e218134676f1ee8568c877cd79ec1c53158dcf2d2ba527a97c606618928ba99dd930102bf
@@ -13769,6 +13787,16 @@ __metadata:
   languageName: node
   linkType: hard
 
+"buffer@npm:5.6.0":
+  version: 5.6.0
+  resolution: "buffer@npm:5.6.0"
+  dependencies:
+    base64-js: ^1.0.2
+    ieee754: ^1.1.4
+  checksum: 07037a0278b07fbc779920f1ba1b473933ffb4a2e2f7b387c55daf6ac64a05b58c27da9e85730a4046e8f97a49f8acd9f7bf89605c0a4dfda88ebfb7e08bfe4a
+  languageName: node
+  linkType: hard
+
 "buffer@npm:^5.2.1, buffer@npm:^5.5.0":
   version: 5.7.1
   resolution: "buffer@npm:5.7.1"
@@ -16661,7 +16689,7 @@ __metadata:
   languageName: node
   linkType: hard
 
-"events@npm:^3.3.0":
+"events@npm:3.3.0, events@npm:^3.3.0":
   version: 3.3.0
   resolution: "events@npm:3.3.0"
   checksum: d6b6f2adbccbcda74ddbab52ed07db727ef52e31a61ed26db9feb7dc62af7fc8e060defa65e5f8af9449b86b52cc1a1f6a79f2eafcf4e62add2b7a1fa4a432f6
@@ -18278,7 +18306,7 @@ __metadata:
   languageName: node
   linkType: hard
 
-"ieee754@npm:^1.1.13, ieee754@npm:^1.2.1":
+"ieee754@npm:^1.1.13, ieee754@npm:^1.1.4, ieee754@npm:^1.2.1":
   version: 1.2.1
   resolution: "ieee754@npm:1.2.1"
   checksum: b0782ef5e0935b9f12883a2e2aa37baa75da6e66ce6515c168697b42160807d9330de9a32ec1ed73149aea02e0d822e572bca6f1e22bdcbd2149e13b050b17bb
@@ -24170,7 +24198,7 @@ __metadata:
   languageName: node
   linkType: hard
 
-"readable-stream@npm:^3.0.2, readable-stream@npm:^3.1.1, readable-stream@npm:^3.4.0, readable-stream@npm:^3.6.0, readable-stream@npm:^3.6.2":
+"readable-stream@npm:^3.0.2, readable-stream@npm:^3.1.1, readable-stream@npm:^3.4.0, readable-stream@npm:^3.5.0, readable-stream@npm:^3.6.0, readable-stream@npm:^3.6.2":
   version: 3.6.2
   resolution: "readable-stream@npm:3.6.2"
   dependencies:
@@ -25791,6 +25819,16 @@ __metadata:
   languageName: node
   linkType: hard
 
+"stream-browserify@npm:3.0.0":
+  version: 3.0.0
+  resolution: "stream-browserify@npm:3.0.0"
+  dependencies:
+    inherits: ~2.0.4
+    readable-stream: ^3.5.0
+  checksum: ec3b975a4e0aa4b3dc5e70ffae3fc8fd29ac725353a14e72f213dff477b00330140ad014b163a8cbb9922dfe90803f81a5ea2b269e1bbfd8bd71511b88f889ad
+  languageName: node
+  linkType: hard
+
 "stream-shift@npm:^1.0.0, stream-shift@npm:^1.0.2":
   version: 1.0.3
   resolution: "stream-shift@npm:1.0.3"