Merge pull request #22 from ledjon-behluli/fix-storeId-stream-on-insert

ledjon-behluli · web-flow · commit 76fae164d131 · 2023-12-02T22:14:43.000+01:00
Fixes an issue with StoreId not being set when received via the stream
diff --git a/src/OrleanSpaces/Grains/Directors/BaseDirector.cs b/src/OrleanSpaces/Grains/Directors/BaseDirector.cs
@@ -88,7 +88,9 @@ public async Task<Guid> Insert(TupleAction<TTuple> action)
             await GrainFactory.GetGrain<TStore>(CreateStoreKey(CurrentStoreId)).Insert(action.StoreTuple.Tuple);
         }
 
-        await stream.OnNextAsync(action);
+        TupleAction<TTuple> newAction = new(action.AgentId, new(CurrentStoreId, action.StoreTuple.Tuple), action.Type);
+        await stream.OnNextAsync(newAction);
+
         return CurrentStoreId;
     }
 

Original file line number	Diff line number	Diff line change
`@@ -88,7 +88,9 @@ public async Task<Guid> Insert(TupleAction<TTuple> action)`
`88`	`88`	`await GrainFactory.GetGrain<TStore>(CreateStoreKey(CurrentStoreId)).Insert(action.StoreTuple.Tuple);`
`89`	`89`	`}`
`90`	`90`
`91`		`- await stream.OnNextAsync(action);`
	`91`	`+ TupleAction<TTuple> newAction = new(action.AgentId, new(CurrentStoreId, action.StoreTuple.Tuple), action.Type);`
	`92`	`+ await stream.OnNextAsync(newAction);`
	`93`	`+`
`92`	`94`	`return CurrentStoreId;`
`93`	`95`	`}`
`94`	`96`