Setup prerelease for streaming aggregate events

.github/workflows/ci.yml

@@ -1,7 +1,7 @@
 name: Contracts CI/CD
 
 env:
-  PRERELEASE_BRANCHES: mithrandir
+  PRERELEASE_BRANCHES: treebeard
 
 on:
   push:

Source/Runtime/Events/Committed.proto

@@ -34,9 +34,11 @@ message CommittedAggregateEvents {
         artifacts.Artifact eventType = 4;
         bool public = 5;
         string content = 6;
+        uint64 aggregateRootVersion = 7; // The aggregate root version the event was applied to
     }
     string eventSourceId = 1;
     protobuf.Uuid aggregateRootId = 2;
-    uint64 aggregateRootVersion = 3;
+    uint64 aggregateRootVersion = 3 [deprecated = true]; // DEPRECATED Replaced by currentAggregateRootVersion
     repeated CommittedAggregateEvent events = 4;
+    uint64 currentAggregateRootVersion = 5; // Represents the current version of the aggregate root
 }

Source/Runtime/Events/EventStore.proto

@@ -3,6 +3,7 @@
 
 syntax = "proto3";
 
+import "Artifacts/Artifact.proto";
 import "Protobuf/Failure.proto";
 import "Services/CallContext.proto";
 import "Runtime/Events/Aggregate.proto";
@@ -28,6 +29,20 @@ message FetchForAggregateRequest {
     services.CallRequestContext callContext = 1;
     Aggregate aggregate = 2;
 }
+message FetchForAggregateInBatchesRequest {
+    services.CallRequestContext callContext = 1;
+    Aggregate aggregate = 2;
+    oneof Request {
+        FetchAllEventsForAggregateInBatchesRequest fetchAllEvents = 3;
+        FetchEventsForAggregateInBatchesRequest fetchEvents = 4;
+    }
+}
+message FetchAllEventsForAggregateInBatchesRequest {
+}
+
+message FetchEventsForAggregateInBatchesRequest {
+    repeated artifacts.Artifact eventTypes = 1;
+}
 
 message CommitEventsResponse {
     protobuf.Failure failure = 1; // not set if not failed
@@ -48,5 +63,6 @@ message FetchForAggregateResponse {
 service EventStore {
     rpc Commit(CommitEventsRequest) returns(CommitEventsResponse);
     rpc CommitForAggregate(CommitAggregateEventsRequest) returns(CommitAggregateEventsResponse);
-    rpc FetchForAggregate(FetchForAggregateRequest) returns(FetchForAggregateResponse);
+    rpc FetchForAggregate(FetchForAggregateRequest) returns(FetchForAggregateResponse); // DEPRECATED: This is superseeded by FetchForAggregateInBatches
+    rpc FetchForAggregateInBatches(FetchForAggregateInBatchesRequest) returns (stream FetchForAggregateResponse);
 }