@@ -136,6 +194,96 @@ defmodule SimpleshopThemeWeb.AdminLive.OrderShow do
"""
end
+ @impl true
+ def handle_event("submit_to_provider", _params, socket) do
+ order = socket.assigns.order
+
+ case Orders.submit_to_provider(order) do
+ {:ok, updated} ->
+ socket =
+ socket
+ |> assign(:order, updated)
+ |> put_flash(:info, "Order submitted to provider")
+
+ {:noreply, socket}
+
+ {:error, _reason} ->
+ order = Orders.get_order(order.id)
+
+ socket =
+ socket
+ |> assign(:order, order)
+ |> put_flash(:error, order.fulfilment_error || "Submission failed")
+
+ {:noreply, socket}
+ end
+ end
+
+ def handle_event("refresh_status", _params, socket) do
+ order = socket.assigns.order
+
+ case Orders.refresh_fulfilment_status(order) do
+ {:ok, updated} ->
+ socket =
+ socket
+ |> assign(:order, updated)
+ |> put_flash(:info, "Status refreshed")
+
+ {:noreply, socket}
+
+ {:error, reason} ->
+ {:noreply, put_flash(socket, :error, "Failed to refresh: #{inspect(reason)}")}
+ end
+ end
+
+ defp can_submit?(order) do
+ order.payment_status == "paid" and order.fulfilment_status in ["unfulfilled", "failed"]
+ end
+
+ defp can_refresh?(order) do
+ not is_nil(order.provider_order_id) and
+ order.fulfilment_status in ["submitted", "processing", "shipped"]
+ end
+
+ defp fulfilment_badge(assigns) do
+ {bg, text, ring, icon} =
+ case assigns.status do
+ "submitted" ->
+ {"bg-blue-50", "text-blue-700", "ring-blue-600/20", "hero-paper-airplane-mini"}
+
+ "processing" ->
+ {"bg-amber-50", "text-amber-700", "ring-amber-600/20", "hero-cog-6-tooth-mini"}
+
+ "shipped" ->
+ {"bg-purple-50", "text-purple-700", "ring-purple-600/20", "hero-truck-mini"}
+
+ "delivered" ->
+ {"bg-green-50", "text-green-700", "ring-green-600/20", "hero-check-circle-mini"}
+
+ "failed" ->
+ {"bg-red-50", "text-red-700", "ring-red-600/20", "hero-x-circle-mini"}
+
+ "cancelled" ->
+ {"bg-zinc-50", "text-zinc-600", "ring-zinc-500/10", "hero-no-symbol-mini"}
+
+ _ ->
+ {"bg-zinc-50", "text-zinc-600", "ring-zinc-500/10", "hero-minus-circle-mini"}
+ end
+
+ assigns = assign(assigns, bg: bg, text: text, ring: ring, icon: icon)
+
+ ~H"""
+
+ <.icon name={@icon} class="size-3" /> {@status}
+
+ """
+ end
+
defp status_badge(assigns) do
{bg, text, ring, icon} =
case assigns.status do
diff --git a/lib/simpleshop_theme_web/live/admin_live/orders.ex b/lib/simpleshop_theme_web/live/admin_live/orders.ex
index d551391..0d0c6e7 100644
--- a/lib/simpleshop_theme_web/live/admin_live/orders.ex
+++ b/lib/simpleshop_theme_web/live/admin_live/orders.ex
@@ -86,6 +86,9 @@ defmodule SimpleshopThemeWeb.AdminLive.Orders do
<:col :let={order} label="Customer">{order.customer_email || "—"}
<:col :let={order} label="Total">{Cart.format_price(order.total)}
<:col :let={order} label="Status"><.status_badge status={order.payment_status} />
+ <:col :let={order} label="Fulfilment">
+ <.fulfilment_badge status={order.fulfilment_status} />
+
@@ -156,6 +159,45 @@ defmodule SimpleshopThemeWeb.AdminLive.Orders do
Calendar.strftime(datetime, "%d %b %Y %H:%M")
end
+ defp fulfilment_badge(assigns) do
+ {bg, text, ring, icon} =
+ case assigns.status do
+ "submitted" ->
+ {"bg-blue-50", "text-blue-700", "ring-blue-600/20", "hero-paper-airplane-mini"}
+
+ "processing" ->
+ {"bg-amber-50", "text-amber-700", "ring-amber-600/20", "hero-cog-6-tooth-mini"}
+
+ "shipped" ->
+ {"bg-purple-50", "text-purple-700", "ring-purple-600/20", "hero-truck-mini"}
+
+ "delivered" ->
+ {"bg-green-50", "text-green-700", "ring-green-600/20", "hero-check-circle-mini"}
+
+ "failed" ->
+ {"bg-red-50", "text-red-700", "ring-red-600/20", "hero-x-circle-mini"}
+
+ "cancelled" ->
+ {"bg-zinc-50", "text-zinc-600", "ring-zinc-500/10", "hero-no-symbol-mini"}
+
+ _ ->
+ {"bg-zinc-50", "text-zinc-600", "ring-zinc-500/10", "hero-minus-circle-mini"}
+ end
+
+ assigns = assign(assigns, bg: bg, text: text, ring: ring, icon: icon)
+
+ ~H"""
+
+ <.icon name={@icon} class="size-3" /> {@status}
+
+ """
+ end
+
defp total_count(counts) do
counts |> Map.values() |> Enum.sum()
end
diff --git a/mix.exs b/mix.exs
index c6e8293..9aab2fd 100644
--- a/mix.exs
+++ b/mix.exs
@@ -48,6 +48,7 @@ defmodule SimpleshopTheme.MixProject do
{:phoenix_html, "~> 4.1"},
{:phoenix_live_reload, "~> 1.2", only: :dev},
{:phoenix_live_view, "~> 1.1.0"},
+ {:mox, "~> 1.0", only: :test},
{:lazy_html, ">= 0.1.0", only: :test},
{:phoenix_live_dashboard, "~> 0.8.3"},
{:esbuild, "~> 0.10", runtime: Mix.env() == :dev},
diff --git a/mix.lock b/mix.lock
index 16d3ff6..8e8a2fd 100644
--- a/mix.lock
+++ b/mix.lock
@@ -37,7 +37,9 @@
"mime": {:hex, :mime, "2.0.7", "b8d739037be7cd402aee1ba0306edfdef982687ee7e9859bee6198c1e7e2f128", [:mix], [], "hexpm", "6171188e399ee16023ffc5b76ce445eb6d9672e2e241d2df6050f3c771e80ccd"},
"mimerl": {:hex, :mimerl, "1.4.0", "3882a5ca67fbbe7117ba8947f27643557adec38fa2307490c4c4207624cb213b", [:rebar3], [], "hexpm", "13af15f9f68c65884ecca3a3891d50a7b57d82152792f3e19d88650aa126b144"},
"mint": {:hex, :mint, "1.7.1", "113fdb2b2f3b59e47c7955971854641c61f378549d73e829e1768de90fc1abf1", [:mix], [{:castore, "~> 0.1.0 or ~> 1.0", [hex: :castore, repo: "hexpm", optional: true]}, {:hpax, "~> 0.1.1 or ~> 0.2.0 or ~> 1.0", [hex: :hpax, repo: "hexpm", optional: false]}], "hexpm", "fceba0a4d0f24301ddee3024ae116df1c3f4bb7a563a731f45fdfeb9d39a231b"},
+ "mox": {:hex, :mox, "1.2.0", "a2cd96b4b80a3883e3100a221e8adc1b98e4c3a332a8fc434c39526babafd5b3", [:mix], [{:nimble_ownership, "~> 1.0", [hex: :nimble_ownership, repo: "hexpm", optional: false]}], "hexpm", "c7b92b3cc69ee24a7eeeaf944cd7be22013c52fcb580c1f33f50845ec821089a"},
"nimble_options": {:hex, :nimble_options, "1.1.1", "e3a492d54d85fc3fd7c5baf411d9d2852922f66e69476317787a7b2bb000a61b", [:mix], [], "hexpm", "821b2470ca9442c4b6984882fe9bb0389371b8ddec4d45a9504f00a66f650b44"},
+ "nimble_ownership": {:hex, :nimble_ownership, "1.0.2", "fa8a6f2d8c592ad4d79b2ca617473c6aefd5869abfa02563a77682038bf916cf", [:mix], [], "hexpm", "098af64e1f6f8609c6672127cfe9e9590a5d3fcdd82bc17a377b8692fd81a879"},
"nimble_parsec": {:hex, :nimble_parsec, "1.4.2", "8efba0122db06df95bfaa78f791344a89352ba04baedd3849593bfce4d0dc1c6", [:mix], [], "hexpm", "4b21398942dda052b403bbe1da991ccd03a053668d147d53fb8c4e0efe09c973"},
"nimble_pool": {:hex, :nimble_pool, "1.1.0", "bf9c29fbdcba3564a8b800d1eeb5a3c58f36e1e11d7b7fb2e084a643f645f06b", [:mix], [], "hexpm", "af2e4e6b34197db81f7aad230c1118eac993acc0dae6bc83bac0126d4ae0813a"},
"oban": {:hex, :oban, "2.20.2", "f23313d83b578305cafa825a036cad84e7e2d61549ecbece3a2e6526d347cc3b", [:mix], [{:ecto_sql, "~> 3.10", [hex: :ecto_sql, repo: "hexpm", optional: false]}, {:ecto_sqlite3, "~> 0.9", [hex: :ecto_sqlite3, repo: "hexpm", optional: true]}, {:igniter, "~> 0.5", [hex: :igniter, repo: "hexpm", optional: true]}, {:jason, "~> 1.1", [hex: :jason, repo: "hexpm", optional: true]}, {:myxql, "~> 0.7", [hex: :myxql, repo: "hexpm", optional: true]}, {:postgrex, "~> 0.20", [hex: :postgrex, repo: "hexpm", optional: true]}, {:telemetry, "~> 1.3", [hex: :telemetry, repo: "hexpm", optional: false]}], "hexpm", "523365ef0217781c061d15f496e3200a5f1b43e08b1a27c34799ef8bfe95815f"},
diff --git a/priv/repo/migrations/20260207234225_add_fulfilment_fields_to_orders.exs b/priv/repo/migrations/20260207234225_add_fulfilment_fields_to_orders.exs
new file mode 100644
index 0000000..295c7ff
--- /dev/null
+++ b/priv/repo/migrations/20260207234225_add_fulfilment_fields_to_orders.exs
@@ -0,0 +1,20 @@
+defmodule SimpleshopTheme.Repo.Migrations.AddFulfilmentFieldsToOrders do
+ use Ecto.Migration
+
+ def change do
+ alter table(:orders) do
+ add :fulfilment_status, :string, null: false, default: "unfulfilled"
+ add :provider_order_id, :string
+ add :provider_status, :string
+ add :fulfilment_error, :string
+ add :tracking_number, :string
+ add :tracking_url, :string
+ add :submitted_at, :utc_datetime
+ add :shipped_at, :utc_datetime
+ add :delivered_at, :utc_datetime
+ end
+
+ create index(:orders, [:fulfilment_status])
+ create index(:orders, [:provider_order_id])
+ end
+end
diff --git a/test/simpleshop_theme/orders/fulfilment_status_worker_test.exs b/test/simpleshop_theme/orders/fulfilment_status_worker_test.exs
new file mode 100644
index 0000000..1483301
--- /dev/null
+++ b/test/simpleshop_theme/orders/fulfilment_status_worker_test.exs
@@ -0,0 +1,84 @@
+defmodule SimpleshopTheme.Orders.FulfilmentStatusWorkerTest do
+ use SimpleshopTheme.DataCase, async: false
+
+ import Mox
+ import SimpleshopTheme.OrdersFixtures
+
+ alias SimpleshopTheme.Orders
+ alias SimpleshopTheme.Orders.FulfilmentStatusWorker
+ alias SimpleshopTheme.Providers.MockProvider
+
+ setup :verify_on_exit!
+
+ setup do
+ Application.put_env(:simpleshop_theme, :provider_modules, %{
+ "printify" => MockProvider
+ })
+
+ on_exit(fn -> Application.delete_env(:simpleshop_theme, :provider_modules) end)
+ :ok
+ end
+
+ describe "perform/1" do
+ test "no-op when no submitted orders" do
+ assert :ok = FulfilmentStatusWorker.perform(%Oban.Job{args: %{}})
+ end
+
+ test "updates status from submitted to processing" do
+ {order, _variant, _product, _conn} = submitted_order_fixture()
+
+ expect(MockProvider, :get_order_status, fn _conn, provider_order_id ->
+ assert provider_order_id == order.provider_order_id
+
+ {:ok,
+ %{
+ status: "processing",
+ provider_status: "in-production",
+ tracking_number: nil,
+ tracking_url: nil,
+ shipments: []
+ }}
+ end)
+
+ assert :ok = FulfilmentStatusWorker.perform(%Oban.Job{args: %{}})
+
+ updated = Orders.get_order(order.id)
+ assert updated.fulfilment_status == "processing"
+ assert updated.provider_status == "in-production"
+ end
+
+ test "sets tracking info when shipped" do
+ {order, _variant, _product, _conn} = submitted_order_fixture()
+
+ expect(MockProvider, :get_order_status, fn _conn, _pid ->
+ {:ok,
+ %{
+ status: "shipped",
+ provider_status: "shipped",
+ tracking_number: "1Z999AA10123456784",
+ tracking_url: "https://tracking.example.com/1Z999AA10123456784",
+ shipments: []
+ }}
+ end)
+
+ assert :ok = FulfilmentStatusWorker.perform(%Oban.Job{args: %{}})
+
+ updated = Orders.get_order(order.id)
+ assert updated.fulfilment_status == "shipped"
+ assert updated.tracking_number == "1Z999AA10123456784"
+ assert updated.tracking_url == "https://tracking.example.com/1Z999AA10123456784"
+ assert updated.shipped_at != nil
+ end
+
+ test "handles provider error gracefully" do
+ {_order, _variant, _product, _conn} = submitted_order_fixture()
+
+ expect(MockProvider, :get_order_status, fn _conn, _pid ->
+ {:error, {500, %{"message" => "Internal error"}}}
+ end)
+
+ # Should not raise, just log the error
+ assert :ok = FulfilmentStatusWorker.perform(%Oban.Job{args: %{}})
+ end
+ end
+end
diff --git a/test/simpleshop_theme/orders/order_submission_worker_test.exs b/test/simpleshop_theme/orders/order_submission_worker_test.exs
new file mode 100644
index 0000000..6631482
--- /dev/null
+++ b/test/simpleshop_theme/orders/order_submission_worker_test.exs
@@ -0,0 +1,112 @@
+defmodule SimpleshopTheme.Orders.OrderSubmissionWorkerTest do
+ use SimpleshopTheme.DataCase, async: false
+
+ import Mox
+ import SimpleshopTheme.OrdersFixtures
+
+ alias SimpleshopTheme.Orders
+ alias SimpleshopTheme.Orders.OrderSubmissionWorker
+ alias SimpleshopTheme.Providers.MockProvider
+
+ setup :verify_on_exit!
+
+ setup do
+ Application.put_env(:simpleshop_theme, :provider_modules, %{
+ "printify" => MockProvider
+ })
+
+ on_exit(fn -> Application.delete_env(:simpleshop_theme, :provider_modules) end)
+ :ok
+ end
+
+ describe "perform/1" do
+ test "cancels if order not found" do
+ fake_id = Ecto.UUID.generate()
+
+ assert {:cancel, :order_not_found} =
+ OrderSubmissionWorker.perform(%Oban.Job{args: %{"order_id" => fake_id}})
+ end
+
+ test "cancels if order is not paid" do
+ order = order_fixture()
+ assert order.payment_status == "pending"
+
+ assert {:cancel, :not_paid} =
+ OrderSubmissionWorker.perform(%Oban.Job{args: %{"order_id" => order.id}})
+ end
+
+ test "returns :ok if already submitted" do
+ {order, _variant, _product, _conn} = submitted_order_fixture()
+
+ assert :ok =
+ OrderSubmissionWorker.perform(%Oban.Job{args: %{"order_id" => order.id}})
+ end
+
+ test "errors if no shipping address (will retry)" do
+ order = order_fixture(payment_status: "paid")
+ assert order.shipping_address == %{}
+
+ assert {:error, :no_shipping_address} =
+ OrderSubmissionWorker.perform(%Oban.Job{args: %{"order_id" => order.id}})
+ end
+
+ test "submits to provider successfully" do
+ {order, _variant, _product, _conn} = paid_order_with_products_fixture()
+
+ expect(MockProvider, :submit_order, fn _conn, order_data ->
+ assert order_data.order_number == order.order_number
+ assert length(order_data.line_items) == 1
+ {:ok, %{provider_order_id: "printify_order_123"}}
+ end)
+
+ assert :ok =
+ OrderSubmissionWorker.perform(%Oban.Job{args: %{"order_id" => order.id}})
+
+ updated = Orders.get_order(order.id)
+ assert updated.fulfilment_status == "submitted"
+ assert updated.provider_order_id == "printify_order_123"
+ assert updated.submitted_at != nil
+ end
+
+ test "sets failed status when provider returns error" do
+ {order, _variant, _product, _conn} = paid_order_with_products_fixture()
+
+ expect(MockProvider, :submit_order, fn _conn, _order_data ->
+ {:error, {422, %{"message" => "Invalid address"}}}
+ end)
+
+ assert {:error, {422, _}} =
+ OrderSubmissionWorker.perform(%Oban.Job{args: %{"order_id" => order.id}})
+
+ updated = Orders.get_order(order.id)
+ assert updated.fulfilment_status == "failed"
+ assert updated.fulfilment_error =~ "Provider API error (422)"
+ end
+
+ test "sets failed status when variant not found in local DB" do
+ # Create order with a variant_id that doesn't exist in product variants
+ order =
+ order_fixture(%{
+ variant_id: Ecto.UUID.generate(),
+ payment_status: "paid",
+ shipping_address: %{
+ "name" => "Test",
+ "line1" => "1 Street",
+ "city" => "London",
+ "postal_code" => "SW1",
+ "country" => "GB"
+ }
+ })
+
+ # Need a printify connection for the lookup to proceed
+ SimpleshopTheme.ProductsFixtures.provider_connection_fixture(%{provider_type: "printify"})
+
+ assert {:error, {:variant_not_found, _, _}} =
+ OrderSubmissionWorker.perform(%Oban.Job{args: %{"order_id" => order.id}})
+
+ updated = Orders.get_order(order.id)
+ assert updated.fulfilment_status == "failed"
+ assert updated.fulfilment_error =~ "no longer exists"
+ end
+ end
+end
diff --git a/test/simpleshop_theme/orders_test.exs b/test/simpleshop_theme/orders_test.exs
index 86cf614..b81d820 100644
--- a/test/simpleshop_theme/orders_test.exs
+++ b/test/simpleshop_theme/orders_test.exs
@@ -1,10 +1,14 @@
defmodule SimpleshopTheme.OrdersTest do
use SimpleshopTheme.DataCase, async: false
- alias SimpleshopTheme.Orders
-
+ import Mox
import SimpleshopTheme.OrdersFixtures
+ alias SimpleshopTheme.Orders
+ alias SimpleshopTheme.Providers.MockProvider
+
+ setup :verify_on_exit!
+
describe "list_orders/1" do
test "returns all orders" do
order1 = order_fixture()
@@ -62,4 +66,154 @@ defmodule SimpleshopTheme.OrdersTest do
assert counts["failed"] == 1
end
end
+
+ describe "submit_to_provider/1" do
+ setup do
+ Application.put_env(:simpleshop_theme, :provider_modules, %{
+ "printify" => MockProvider
+ })
+
+ on_exit(fn -> Application.delete_env(:simpleshop_theme, :provider_modules) end)
+ :ok
+ end
+
+ test "submits order and sets fulfilment status" do
+ {order, _variant, _product, _conn} = paid_order_with_products_fixture()
+
+ expect(MockProvider, :submit_order, fn _conn, order_data ->
+ assert order_data.order_number == order.order_number
+ assert is_list(order_data.line_items)
+ assert hd(order_data.line_items).quantity == 1
+ {:ok, %{provider_order_id: "pfy_123"}}
+ end)
+
+ assert {:ok, updated} = Orders.submit_to_provider(order)
+ assert updated.fulfilment_status == "submitted"
+ assert updated.provider_order_id == "pfy_123"
+ assert updated.submitted_at != nil
+ assert updated.fulfilment_error == nil
+ end
+
+ test "is idempotent when already submitted" do
+ {order, _variant, _product, _conn} = submitted_order_fixture()
+
+ # No mock expectations — provider should not be called
+ assert {:ok, ^order} = Orders.submit_to_provider(order)
+ end
+
+ test "sets failed status on provider error" do
+ {order, _variant, _product, _conn} = paid_order_with_products_fixture()
+
+ expect(MockProvider, :submit_order, fn _conn, _data ->
+ {:error, {500, %{"message" => "Server error"}}}
+ end)
+
+ assert {:error, {500, _}} = Orders.submit_to_provider(order)
+
+ updated = Orders.get_order(order.id)
+ assert updated.fulfilment_status == "failed"
+ assert updated.fulfilment_error =~ "Provider API error (500)"
+ end
+ end
+
+ describe "refresh_fulfilment_status/1" do
+ setup do
+ Application.put_env(:simpleshop_theme, :provider_modules, %{
+ "printify" => MockProvider
+ })
+
+ on_exit(fn -> Application.delete_env(:simpleshop_theme, :provider_modules) end)
+ :ok
+ end
+
+ test "updates tracking info from provider" do
+ {order, _variant, _product, _conn} = submitted_order_fixture()
+
+ expect(MockProvider, :get_order_status, fn _conn, pid ->
+ assert pid == order.provider_order_id
+
+ {:ok,
+ %{
+ status: "shipped",
+ provider_status: "shipped",
+ tracking_number: "TRACK123",
+ tracking_url: "https://track.example.com/TRACK123"
+ }}
+ end)
+
+ assert {:ok, updated} = Orders.refresh_fulfilment_status(order)
+ assert updated.fulfilment_status == "shipped"
+ assert updated.tracking_number == "TRACK123"
+ assert updated.tracking_url == "https://track.example.com/TRACK123"
+ assert updated.shipped_at != nil
+ end
+
+ test "no-op when no provider_order_id" do
+ order = order_fixture(payment_status: "paid")
+ assert is_nil(order.provider_order_id)
+
+ assert {:ok, ^order} = Orders.refresh_fulfilment_status(order)
+ end
+ end
+
+ describe "update_fulfilment/2" do
+ test "updates fulfilment fields" do
+ order = order_fixture()
+
+ assert {:ok, updated} =
+ Orders.update_fulfilment(order, %{
+ fulfilment_status: "submitted",
+ provider_order_id: "test_123"
+ })
+
+ assert updated.fulfilment_status == "submitted"
+ assert updated.provider_order_id == "test_123"
+ end
+
+ test "validates fulfilment status inclusion" do
+ order = order_fixture()
+
+ assert {:error, changeset} =
+ Orders.update_fulfilment(order, %{fulfilment_status: "bogus"})
+
+ assert errors_on(changeset).fulfilment_status != []
+ end
+ end
+
+ describe "list_submitted_orders/0" do
+ test "returns orders with submitted or processing status" do
+ {submitted, _v, _p, _c} = submitted_order_fixture()
+
+ {processing, _v2, _p2, _c2} = submitted_order_fixture()
+
+ {:ok, processing} =
+ Orders.update_fulfilment(processing, %{fulfilment_status: "processing"})
+
+ _unfulfilled = order_fixture(payment_status: "paid")
+
+ orders = Orders.list_submitted_orders()
+ ids = Enum.map(orders, & &1.id)
+
+ assert submitted.id in ids
+ assert processing.id in ids
+ assert length(orders) == 2
+ end
+
+ test "returns empty list when no submitted orders" do
+ order_fixture()
+ assert Orders.list_submitted_orders() == []
+ end
+ end
+
+ describe "get_order_by_number/1" do
+ test "finds order by order number" do
+ order = order_fixture()
+ found = Orders.get_order_by_number(order.order_number)
+ assert found.id == order.id
+ end
+
+ test "returns nil for unknown order number" do
+ assert is_nil(Orders.get_order_by_number("SS-000000-XXXX"))
+ end
+ end
end
diff --git a/test/simpleshop_theme/webhooks_test.exs b/test/simpleshop_theme/webhooks_test.exs
index 2c0ee55..e729e62 100644
--- a/test/simpleshop_theme/webhooks_test.exs
+++ b/test/simpleshop_theme/webhooks_test.exs
@@ -1,19 +1,19 @@
defmodule SimpleshopTheme.WebhooksTest do
- use SimpleshopTheme.DataCase
+ use SimpleshopTheme.DataCase, async: false
+ alias SimpleshopTheme.Orders
alias SimpleshopTheme.Webhooks
import SimpleshopTheme.ProductsFixtures
+ import SimpleshopTheme.OrdersFixtures
setup do
conn = provider_connection_fixture(%{provider_type: "printify"})
{:ok, provider_connection: conn}
end
- describe "handle_printify_event/2" do
+ describe "handle_printify_event/2 — product events" do
test "product:updated triggers sync", %{provider_connection: _conn} do
- # With inline Oban, the job executes immediately (and fails due to no real API key)
- # But the handler should still return {:ok, _} after inserting the job
result =
Webhooks.handle_printify_event(
"product:updated",
@@ -52,7 +52,6 @@ defmodule SimpleshopTheme.WebhooksTest do
end
test "returns error when no provider connection" do
- # Delete all connections first
SimpleshopTheme.Repo.delete_all(SimpleshopTheme.Products.ProviderConnection)
assert {:error, :no_connection} =
@@ -62,4 +61,75 @@ defmodule SimpleshopTheme.WebhooksTest do
)
end
end
+
+ describe "handle_printify_event/2 — order events" do
+ test "order:sent-to-production updates fulfilment status" do
+ {order, _v, _p, _c} = submitted_order_fixture()
+
+ assert {:ok, updated} =
+ Webhooks.handle_printify_event("order:sent-to-production", %{
+ "id" => "printify_abc",
+ "external_id" => order.order_number
+ })
+
+ assert updated.fulfilment_status == "processing"
+ assert updated.provider_status == "in-production"
+ end
+
+ test "order:shipment:created sets tracking info and shipped_at" do
+ {order, _v, _p, _c} = submitted_order_fixture()
+
+ assert {:ok, updated} =
+ Webhooks.handle_printify_event("order:shipment:created", %{
+ "id" => "printify_abc",
+ "external_id" => order.order_number,
+ "shipments" => [
+ %{
+ "tracking_number" => "1Z999AA1",
+ "tracking_url" => "https://ups.com/track/1Z999AA1"
+ }
+ ]
+ })
+
+ assert updated.fulfilment_status == "shipped"
+ assert updated.tracking_number == "1Z999AA1"
+ assert updated.tracking_url == "https://ups.com/track/1Z999AA1"
+ assert updated.shipped_at != nil
+ end
+
+ test "order:shipment:delivered sets delivered_at" do
+ {order, _v, _p, _c} = submitted_order_fixture()
+
+ # First mark as shipped
+ {:ok, order} =
+ Orders.update_fulfilment(order, %{
+ fulfilment_status: "shipped",
+ shipped_at: DateTime.utc_now() |> DateTime.truncate(:second)
+ })
+
+ assert {:ok, updated} =
+ Webhooks.handle_printify_event("order:shipment:delivered", %{
+ "id" => "printify_abc",
+ "external_id" => order.order_number
+ })
+
+ assert updated.fulfilment_status == "delivered"
+ assert updated.delivered_at != nil
+ end
+
+ test "order event with unknown external_id returns error" do
+ assert {:error, :order_not_found} =
+ Webhooks.handle_printify_event("order:sent-to-production", %{
+ "id" => "printify_abc",
+ "external_id" => "SS-000000-NOPE"
+ })
+ end
+
+ test "order event with missing external_id returns error" do
+ assert {:error, :missing_external_id} =
+ Webhooks.handle_printify_event("order:sent-to-production", %{
+ "id" => "printify_abc"
+ })
+ end
+ end
end
diff --git a/test/simpleshop_theme_web/live/admin_live/orders_test.exs b/test/simpleshop_theme_web/live/admin_live/orders_test.exs
index 06720ee..bde4809 100644
--- a/test/simpleshop_theme_web/live/admin_live/orders_test.exs
+++ b/test/simpleshop_theme_web/live/admin_live/orders_test.exs
@@ -115,5 +115,76 @@ defmodule SimpleshopThemeWeb.AdminLive.OrdersTest do
{:error, {:live_redirect, %{to: "/admin/orders"}}} =
live(conn, ~p"/admin/orders/#{fake_id}")
end
+
+ test "shows fulfilment card", %{conn: conn} do
+ order = order_fixture(payment_status: "paid")
+
+ {:ok, _view, html} = live(conn, ~p"/admin/orders/#{order}")
+
+ assert html =~ "Fulfilment"
+ assert html =~ "unfulfilled"
+ end
+
+ test "shows submit button for paid unfulfilled orders", %{conn: conn} do
+ order = order_fixture(payment_status: "paid")
+
+ {:ok, _view, html} = live(conn, ~p"/admin/orders/#{order}")
+
+ assert html =~ "Submit to provider"
+ end
+
+ test "shows retry button for failed fulfilment", %{conn: conn} do
+ order = order_fixture(payment_status: "paid")
+
+ {:ok, order} =
+ SimpleshopTheme.Orders.update_fulfilment(order, %{fulfilment_status: "failed"})
+
+ {:ok, _view, html} = live(conn, ~p"/admin/orders/#{order}")
+
+ assert html =~ "Retry submission"
+ end
+
+ test "shows refresh button for submitted orders", %{conn: conn} do
+ {order, _v, _p, _c} =
+ SimpleshopTheme.OrdersFixtures.submitted_order_fixture()
+
+ {:ok, _view, html} = live(conn, ~p"/admin/orders/#{order}")
+
+ assert html =~ "Refresh status"
+ end
+
+ test "shows tracking info when available", %{conn: conn} do
+ {order, _v, _p, _c} =
+ SimpleshopTheme.OrdersFixtures.submitted_order_fixture()
+
+ {:ok, order} =
+ SimpleshopTheme.Orders.update_fulfilment(order, %{
+ fulfilment_status: "shipped",
+ tracking_number: "TRACK123",
+ tracking_url: "https://track.example.com/TRACK123",
+ shipped_at: DateTime.utc_now() |> DateTime.truncate(:second)
+ })
+
+ {:ok, _view, html} = live(conn, ~p"/admin/orders/#{order}")
+
+ assert html =~ "TRACK123"
+ assert html =~ "https://track.example.com/TRACK123"
+ end
+ end
+
+ describe "order list fulfilment column" do
+ setup %{conn: conn, user: user} do
+ conn = log_in_user(conn, user)
+ %{conn: conn}
+ end
+
+ test "shows fulfilment badge in table", %{conn: conn} do
+ order_fixture(payment_status: "paid")
+
+ {:ok, _view, html} = live(conn, ~p"/admin/orders")
+
+ assert html =~ "Fulfilment"
+ assert html =~ "unfulfilled"
+ end
end
end
diff --git a/test/support/fixtures/orders_fixtures.ex b/test/support/fixtures/orders_fixtures.ex
index 0fe781d..a61ea95 100644
--- a/test/support/fixtures/orders_fixtures.ex
+++ b/test/support/fixtures/orders_fixtures.ex
@@ -5,12 +5,14 @@ defmodule SimpleshopTheme.OrdersFixtures do
alias SimpleshopTheme.Orders
+ import SimpleshopTheme.ProductsFixtures
+
def order_fixture(attrs \\ %{}) do
attrs = Enum.into(attrs, %{})
items = [
%{
- variant_id: "var_#{System.unique_integer([:positive])}",
+ variant_id: Map.get(attrs, :variant_id, "var_#{System.unique_integer([:positive])}"),
name: Map.get(attrs, :product_name, "Test product"),
variant: Map.get(attrs, :variant_title, "Red / Large"),
price: Map.get(attrs, :unit_price, 1999),
@@ -26,6 +28,17 @@ defmodule SimpleshopTheme.OrdersFixtures do
{:ok, order} = Orders.create_order(order_attrs)
+ # Apply shipping address if provided
+ order =
+ case attrs[:shipping_address] do
+ nil ->
+ order
+
+ addr ->
+ {:ok, order} = Orders.update_order(order, %{shipping_address: addr})
+ order
+ end
+
case attrs[:payment_status] do
"paid" ->
{:ok, order} = Orders.mark_paid(order, "pi_test_#{System.unique_integer([:positive])}")
@@ -39,4 +52,59 @@ defmodule SimpleshopTheme.OrdersFixtures do
order
end
end
+
+ @doc """
+ Creates a paid order with real product variants in the DB,
+ so enrich_items/1 can look up provider IDs. Also sets a shipping
+ address matching Stripe's format.
+
+ Returns `{order, variant, product, conn}`.
+ """
+ def paid_order_with_products_fixture(attrs \\ %{}) do
+ attrs = Enum.into(attrs, %{})
+ conn = provider_connection_fixture(%{provider_type: "printify"})
+ product = product_fixture(%{provider_connection: conn})
+ variant = product_variant_fixture(%{product: product})
+
+ shipping =
+ Map.get(attrs, :shipping_address, %{
+ "name" => "Jane Doe",
+ "line1" => "42 Test Street",
+ "line2" => nil,
+ "city" => "London",
+ "postal_code" => "SW1A 1AA",
+ "state" => nil,
+ "country" => "GB"
+ })
+
+ order =
+ order_fixture(%{
+ variant_id: variant.id,
+ payment_status: "paid",
+ shipping_address: shipping,
+ customer_email: Map.get(attrs, :customer_email, "buyer@example.com")
+ })
+
+ {order, variant, product, conn}
+ end
+
+ @doc """
+ Creates a submitted order (has provider_order_id set).
+ Returns `{order, variant, product, conn}`.
+ """
+ def submitted_order_fixture(attrs \\ %{}) do
+ {order, variant, product, conn} = paid_order_with_products_fixture(attrs)
+
+ attrs = Enum.into(attrs, %{})
+
+ {:ok, order} =
+ Orders.update_fulfilment(order, %{
+ fulfilment_status: "submitted",
+ provider_order_id:
+ Map.get(attrs, :provider_order_id, "printify_#{System.unique_integer([:positive])}"),
+ submitted_at: DateTime.utc_now() |> DateTime.truncate(:second)
+ })
+
+ {order, variant, product, conn}
+ end
end
diff --git a/test/support/mocks.ex b/test/support/mocks.ex
new file mode 100644
index 0000000..0961abb
--- /dev/null
+++ b/test/support/mocks.ex
@@ -0,0 +1,3 @@
+Mox.defmock(SimpleshopTheme.Providers.MockProvider,
+ for: SimpleshopTheme.Providers.Provider
+)