Chore: fix module name for EventStore.BaseQuery

maxohq · Sep 5, 2024 · d85687a · d85687a
1 parent c5fb31a
commit d85687a
Show file tree

Hide file tree

Showing 5 changed files with 5 additions and 5 deletions.
diff --git a/lib/event_store/base_query.ex b/lib/event_store/base_query.ex
@@ -1,4 +1,4 @@
-defmodule EventStore.BaseQuery do
+defmodule Essig.EventStore.BaseQuery do
   alias Essig.Schemas.Event
   use Essig.Repo
 

diff --git a/lib/event_store/read_all_stream_backward.ex b/lib/event_store/read_all_stream_backward.ex
@@ -6,7 +6,7 @@ defmodule Essig.EventStore.ReadAllStreamBackward do
   end
 
   def query(from_id, amount) do
-    EventStore.BaseQuery.query()
+    Essig.EventStore.BaseQuery.query()
     |> where([event], event.id < ^from_id)
     |> order_by(desc: :id)
     |> limit(^amount)

diff --git a/lib/event_store/read_all_stream_forward.ex b/lib/event_store/read_all_stream_forward.ex
@@ -6,7 +6,7 @@ defmodule Essig.EventStore.ReadAllStreamForward do
   end
 
   def query(from_id, amount) do
-    EventStore.BaseQuery.query()
+    Essig.EventStore.BaseQuery.query()
     |> where([event], event.id > ^from_id)
     |> order_by(asc: :id)
     |> limit(^amount)

diff --git a/lib/event_store/read_stream_backward.ex b/lib/event_store/read_stream_backward.ex
@@ -6,7 +6,7 @@ defmodule Essig.EventStore.ReadStreamBackward do
   end
 
   def query(stream_uuid, from_seq, amount) do
-    EventStore.BaseQuery.query()
+    Essig.EventStore.BaseQuery.query()
     |> where([event], event.stream_uuid == ^stream_uuid)
     |> where([event], event.seq < ^from_seq)
     |> order_by(desc: :seq)

diff --git a/lib/event_store/read_stream_forward.ex b/lib/event_store/read_stream_forward.ex
@@ -6,7 +6,7 @@ defmodule Essig.EventStore.ReadStreamForward do
   end
 
   def query(stream_uuid, from_seq, amount) do
-    EventStore.BaseQuery.query()
+    Essig.EventStore.BaseQuery.query()
     |> where([event], event.stream_uuid == ^stream_uuid)
     |> where([event], event.seq > ^from_seq)
     |> order_by(asc: :id)