chore(mix): install commanded_ecto_projections

Author: ChristianAlexander

config/config.exs

@@ -31,6 +31,8 @@ config :todo_backend, TodoBackend.App,
   pubsub: :local,
   registry: :local
 
+config :commanded_ecto_projections, repo: TodoBackend.Repo
+
 config :todo_backend, event_stores: [TodoBackend.EventStore]
 
 # Import environment specific config. This must remain at the bottom

mix.exs

@@ -43,7 +43,8 @@ defmodule TodoBackend.MixProject do
       {:plug_cowboy, "~> 2.5"},
       {:commanded, "~> 1.3"},
       {:commanded_eventstore_adapter, "~> 1.2"},
-      {:cors_plug, "~> 3.0"}
+      {:cors_plug, "~> 3.0"},
+      {:commanded_ecto_projections, "~> 1.2"}
     ]
   end
 

mix.lock

@@ -1,6 +1,7 @@
 %{
   "backoff": {:hex, :backoff, "1.1.6", "83b72ed2108ba1ee8f7d1c22e0b4a00cfe3593a67dbc792799e8cce9f42f796b", [:rebar3], [], "hexpm", "cf0cfff8995fb20562f822e5cc47d8ccf664c5ecdc26a684cbe85c225f9d7c39"},
   "commanded": {:hex, :commanded, "1.3.1", "d18a73bface68c04cbbda69647604a3cc1918fbdf8af4a784fc3a3a30ca34a13", [:mix], [{:backoff, "~> 1.1", [hex: :backoff, repo: "hexpm", optional: false]}, {:elixir_uuid, "~> 1.2", [hex: :elixir_uuid, repo: "hexpm", optional: false]}, {:jason, "~> 1.2", [hex: :jason, repo: "hexpm", optional: true]}, {:phoenix_pubsub, "~> 2.0", [hex: :phoenix_pubsub, repo: "hexpm", optional: true]}, {:telemetry, "~> 0.4 or ~> 1.0", [hex: :telemetry, repo: "hexpm", optional: false]}, {:telemetry_registry, "~> 0.2", [hex: :telemetry_registry, repo: "hexpm", optional: false]}], "hexpm", "9bd03ef6fc05e3a8fb4d0808f13a2106688e60ee4b2bdb78cf7e63a6788c9faf"},
+  "commanded_ecto_projections": {:hex, :commanded_ecto_projections, "1.2.1", "ad1e274d2458a4dab268deb95601e0fb644ab141fb14995f540c66de1788731f", [:mix], [{:commanded, "~> 1.2", [hex: :commanded, repo: "hexpm", optional: false]}, {:ecto, "~> 3.5", [hex: :ecto, repo: "hexpm", optional: false]}, {:ecto_sql, "~> 3.5", [hex: :ecto_sql, repo: "hexpm", optional: false]}, {:jason, "~> 1.2", [hex: :jason, repo: "hexpm", optional: true]}], "hexpm", "461a1e3489c56f6e7564f54e4200a41afcab5618fdf396e0c00269613328f00c"},
   "commanded_eventstore_adapter": {:hex, :commanded_eventstore_adapter, "1.2.0", "a311247d70ce775b2d4b5484d09dbefd27911025ac7deb3e5b79b79f243e6fb1", [:mix], [{:commanded, "~> 1.2", [hex: :commanded, repo: "hexpm", optional: false]}, {:eventstore, "~> 1.1", [hex: :eventstore, repo: "hexpm", optional: false]}, {:jason, "~> 1.2", [hex: :jason, repo: "hexpm", optional: true]}], "hexpm", "b2cce46dfccf400f3956322a72997e591c0f833d0c20557e1074c7609564dae2"},
   "connection": {:hex, :connection, "1.1.0", "ff2a49c4b75b6fb3e674bfc5536451607270aac754ffd1bdfe175abe4a6d7a68", [:mix], [], "hexpm", "722c1eb0a418fbe91ba7bd59a47e28008a189d47e37e0e7bb85585a016b2869c"},
   "cors_plug": {:hex, :cors_plug, "3.0.3", "7c3ac52b39624bc616db2e937c282f3f623f25f8d550068b6710e58d04a0e330", [:mix], [{:plug, "~> 1.13", [hex: :plug, repo: "hexpm", optional: false]}], "hexpm", "3f2d759e8c272ed3835fab2ef11b46bddab8c1ab9528167bd463b6452edf830d"},

priv/repo/migrations/20220508025039_create_projection_versions.exs

@@ -0,0 +1,11 @@
+defmodule CreateProjectionVersions do
+  use Ecto.Migration
+
+  def change do
+    create table(:projection_versions, primary_key: false) do
+      add(:projection_name, :text, primary_key: true)
+      add(:last_seen_event_number, :bigint)
+      timestamps(type: :naive_datetime_usec)
+    end
+  end
+end