Add transform function support to sync and sync_render (#99)

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,25 @@
+# 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/
+
+/persistent/

apps/plug_sync/README.md

@@ -0,0 +1,7 @@
+# PlugSync
+
+A 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.insert.ex

@@ -0,0 +1,37 @@
+defmodule Mix.Tasks.PlugSync.Insert do
+  use Mix.Task
+
+  @shortdoc "Inserts sample data into the database for testing PlugSync"
+
+    alias PlugSync.Repo
+    alias PlugSync.Tasks.Task
+    alias PlugSync.Tasks.Step
+
+  def run(args) do
+    {opts, _, _} = OptionParser.parse(args, strict: [rows: :integer, data_size: :integer])
+
+    # {:ok, repo} = Repo.start_link()
+    Application.ensure_all_started(:plug_sync) |> dbg
+
+    data_size = Keyword.get(opts, :data_size, 1024)
+    rows = Keyword.get(opts, :rows, 1024)
+
+    Repo.transaction(fn ->
+
+      items = Stream.repeatedly(fn -> item(data_size) end) |> Enum.take(rows)
+      Repo.insert_all(PlugSync.Item, items)
+
+    end)
+
+    IO.puts("Sample data inserted successfully.")
+  end
+
+  defp item(data_size) do
+    %{
+      value: Enum.random(1..100_000),
+      data: :crypto.strong_rand_bytes(div(data_size , 2) ) |> Base.encode16(),
+      inserted_at: NaiveDateTime.utc_now() |> NaiveDateTime.truncate(:second),
+      updated_at: NaiveDateTime.utc_now() |> NaiveDateTime.truncate(:second),
+    }
+  end
+end

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