Pass repo_options to repo.insert! to support TenantFactories

README.md

@@ -370,6 +370,24 @@ change this line in `mix.exs`:
 defp elixirc_paths(:test), do: ["lib", "web", "test/support", "test/factories"]
 ```
 
+## Multi-tenant support
+
+If you are depending on query prefixes to switch between tenant schemas you can 
+pass `repo_options` to your factory which can be used to set the `:prefix` on your insert queries.
+This allows you to create a factory per tenant.
+
+```elixir
+defmodule MyApp.TenantFactory
+  use ExMachina.Ecto, repo: MyApp.Repo, repo_options: [prefix: "test_tenant"]
+
+  def user_factory do
+    ...
+  end
+
+  ...
+end
+```
+
 ## Custom Strategies
 
 You can use ExMachina without Ecto, by using just the `build` functions, or you

lib/ex_machina/ecto.ex

@@ -17,7 +17,9 @@ defmodule ExMachina.Ecto do
 
     quote do
       use ExMachina
-      use ExMachina.EctoStrategy, repo: unquote(Keyword.get(opts, :repo))
+      use ExMachina.EctoStrategy,
+        repo: unquote(Keyword.get(opts, :repo)),
+        repo_options: unquote(Keyword.get(opts, :repo_options, []))
 
       def params_for(factory_name, attrs \\ %{}) do
         ExMachina.Ecto.params_for(__MODULE__, factory_name, attrs)

lib/ex_machina/ecto_strategy.ex

@@ -20,10 +20,10 @@ defmodule ExMachina.EctoStrategy do
     """
   end
 
-  def handle_insert(%{__meta__: %{__struct__: Ecto.Schema.Metadata}} = record, %{repo: repo}) do
+  def handle_insert(%{__meta__: %{__struct__: Ecto.Schema.Metadata}} = record, %{repo: repo} = opts) do
     record
     |> cast
-    |> repo.insert!
+    |> repo.insert!(opts[:repo_options] || [])
   end
 
   def handle_insert(record, %{repo: _repo}) do

test/ex_machina/ecto_test.exs

@@ -36,6 +36,22 @@ defmodule ExMachina.EctoTest do
       end
     end
 
+    defmodule MockRepo do
+      def insert!(_model, opts), do: opts
+    end
+
+    defmodule MockedTenantFactory do
+      use ExMachina.Ecto, repo: MockRepo, repo_options: [prefix: "test_tenant"]
+
+      def user_factory do
+        %ExMachina.User{}
+      end
+    end
+
+    test "it passes repo_options to Repo.insert!" do
+      assert [prefix: "test_tenant"] == MockedTenantFactory.insert(:user)
+    end
+
     test "params_for/1 still works as expected" do
       user_params = NoRepoTestFactory.params_for(:user)