Feat: also store stream_uuid on essig_signals table

lib/event_store/append_to_stream.ex

@@ -34,7 +34,7 @@ defmodule Essig.EventStore.AppendToStream do
       Essig.Crud.StreamsCrud.update_stream(stream, %{seq: last_event.seq})
     end)
     |> Ecto.Multi.run(:signal_new_events, fn _repo, _ ->
-      signal_new_events()
+      signal_new_events(stream_uuid)
     end)
   end
 
@@ -98,12 +98,16 @@ defmodule Essig.EventStore.AppendToStream do
     end
   end
 
-  defp signal_new_events() do
+  defp signal_new_events(stream_uuid) do
     scope_uuid = Essig.Context.current_scope()
     bin_uuid = Ecto.UUID.dump!(scope_uuid)
+    stream_uuid = Ecto.UUID.dump!(stream_uuid)
 
     {:ok, _} =
-      Repo.query("insert into essig_signals(scope_uuid) values ($1)", [bin_uuid])
+      Repo.query("insert into essig_signals(scope_uuid, stream_uuid) values ($1, $2)", [
+        bin_uuid,
+        stream_uuid
+      ])
 
     {:ok, true}
   end

lib/migrations/migration003.ex

@@ -5,6 +5,7 @@ defmodule Migrations.Migration003 do
     create table(:essig_signals, primary_key: false) do
       add(:id, :bigserial, primary_key: true)
       add(:scope_uuid, :uuid, null: false, default: fragment("gen_random_uuid()"))
+      add(:stream_uuid, :uuid, null: false)
       add(:txid, :bigint)
       add(:snapmin, :bigint)
     end
@@ -27,6 +28,7 @@ defmodule Migrations.Migration003 do
                 -- Function to notify on new transactions (events) via pg_notify
                 payload := json_build_object(
                   'scope_uuid', NEW.scope_uuid,
+                  'stream_uuid', NEW.stream_uuid,
                   'txid', NEW.txid,
                   'snapmin', NEW.snapmin
                 );