Add transform function support to sync and sync_render

Fixes #53

Author: magnetised

apps/plug_sync/.formatter.exs

@@ -0,0 +1,5 @@
+# Used by "mix format"
+[
+  import_deps: [:plug, :ecto, :phoenix_sync],
+  inputs: ["{mix,.formatter}.exs", "{config,lib,test}/**/*.{ex,exs}"]
+]

apps/plug_sync/.gitignore

@@ -0,0 +1,23 @@
+# The directory Mix will write compiled artifacts to.
+/_build/
+
+# If you run "mix test --cover", coverage assets end up here.
+/cover/
+
+# The directory Mix downloads your dependencies sources to.
+/deps/
+
+# Where third-party dependencies like ExDoc output generated docs.
+/doc/
+
+# If the VM crashes, it generates a dump, let's ignore it too.
+erl_crash.dump
+
+# Also ignore archive artifacts (built via "mix archive.build").
+*.ez
+
+# Ignore package tarball (built via "mix hex.build").
+plug_sync-*.tar
+
+# Temporary files, for example, from tests.
+/tmp/

apps/plug_sync/README.md

@@ -0,0 +1,7 @@
+# PlugSync
+
+An test Plug app for easy validation of Phoenix.Sync features within a real app.
+
+Use `PHOENIX_SYNC_MODE` to set the interaction mode, either `"http"` or `"embedded"`.
+
+In `http` mode, you should run an Electric server on port 3000.

apps/plug_sync/config/config.exs

@@ -0,0 +1,3 @@
+import Config
+
+import_config "#{config_env()}.exs"

apps/plug_sync/config/dev.exs

@@ -0,0 +1,35 @@
+import Config
+
+config :plug_sync, ecto_repos: [PlugSync.Repo], start_server: false
+
+case System.get_env("PHOENIX_SYNC_MODE", "embedded") do
+  "http" ->
+    IO.puts("Starting in HTTP mode")
+
+    config :phoenix_sync,
+      mode: :http,
+      env: config_env(),
+      url: "http://localhost:3000"
+
+    config :plug_sync, PlugSync.Repo,
+      username: "postgres",
+      password: "password",
+      hostname: "localhost",
+      database: "electric",
+      port: 54321
+
+  _ ->
+    IO.puts("Starting in embedded mode")
+
+    config :phoenix_sync,
+      mode: :embedded,
+      env: config_env(),
+      repo: PlugSync.Repo
+
+    config :plug_sync, PlugSync.Repo,
+      username: "postgres",
+      password: "password",
+      hostname: "localhost",
+      database: "plug_sync",
+      port: 55555
+end

apps/plug_sync/config/prod.exs

@@ -0,0 +1 @@
+import Config

apps/plug_sync/config/test.exs

@@ -0,0 +1,3 @@
+import Config
+
+config :phoenix_sync, mode: :sandbox, env: config_env()

apps/plug_sync/lib/mix/tasks/plug_sync.server.ex

@@ -0,0 +1,18 @@
+defmodule Mix.Tasks.PlugSync.Server do
+  use Mix.Task
+
+  @shortdoc "Starts a PlugSync server"
+
+  def run(_args) do
+    Application.put_env(:plug_sync, :server, true, persistent: true)
+    Mix.Tasks.Run.run(run_args())
+  end
+
+  defp run_args do
+    if iex_running?(), do: [], else: ["--no-halt"]
+  end
+
+  defp iex_running? do
+    Code.ensure_loaded?(IEx) and IEx.started?()
+  end
+end

apps/plug_sync/lib/plug_sync.ex

@@ -0,0 +1,18 @@
+defmodule PlugSync do
+  @moduledoc """
+  Documentation for `PlugSync`.
+  """
+
+  @doc """
+  Hello world.
+
+  ## Examples
+
+      iex> PlugSync.hello()
+      :world
+
+  """
+  def hello do
+    :world
+  end
+end

apps/plug_sync/lib/plug_sync/application.ex

@@ -0,0 +1,29 @@
+defmodule PlugSync.Application do
+  # See https://hexdocs.pm/elixir/Application.html
+  # for more information on OTP Applications
+  @moduledoc false
+
+  use Application
+
+  @impl true
+  def start(_type, _args) do
+    server =
+      if Application.get_env(:plug_sync, :server, false) do
+        [
+          {Bandit, plug: {PlugSync.Router, phoenix_sync: Phoenix.Sync.plug_opts()}, port: 4444}
+        ]
+      else
+        []
+      end
+
+    children =
+      [
+        PlugSync.Repo
+      ] ++ server
+
+    # See https://hexdocs.pm/elixir/Supervisor.html
+    # for other strategies and supported options
+    opts = [strategy: :one_for_one, name: PlugSync.Supervisor]
+    Supervisor.start_link(children, opts)
+  end
+end