feat: Add village query for temporarily

not-blond-beard · Apr 6, 2024 · decd04e · decd04e
1 parent 8a8c273
commit decd04e
Show file tree

Hide file tree

Showing 2 changed files with 11 additions and 4 deletions.
diff --git a/backend/app/Savor22b/GraphTypes/Query/Query.cs b/backend/app/Savor22b/GraphTypes/Query/Query.cs
@@ -10,7 +10,9 @@ namespace Savor22b.GraphTypes.Query;
 using Libplanet.Net;
 using Savor22b.Action;
 using Savor22b.GraphTypes.Types;
+using Savor22b.GraphTypes.Subscription;
 using Savor22b.States;
+using System.Reactive.Subjects;
 
 public class Query : ObjectGraphType
 {
@@ -22,7 +24,11 @@ public class Query : ObjectGraphType
     private readonly BlockChain _blockChain;
     private readonly Swarm _swarm;
 
-    public Query(BlockChain blockChain, Swarm? swarm = null)
+    public Query(
+        BlockChain blockChain,
+        Swarm? swarm = null,
+        Subject<Libplanet.Blocks.BlockHash>? subject = null
+    )
     {
         _blockChain = blockChain;
         _swarm = swarm;
@@ -532,6 +538,7 @@ swarm is null
         AddField(new CalculateRelocationCostQuery());
         AddField(new DungeonReturnRewardQuery());
         AddField(new ShopQuery());
+        AddField(new VillageField(blockChain, subject));
         AddField(new ShowMeTheMoney(blockChain, swarm));
     }
 

diff --git a/backend/app/Savor22b/GraphTypes/Subscription/VillageField.cs b/backend/app/Savor22b/GraphTypes/Subscription/VillageField.cs
@@ -17,9 +17,9 @@ namespace Savor22b.GraphTypes.Subscription;
 public class VillageField : FieldType
 {
     private readonly BlockChain _blockChain;
-    private readonly Subject<Libplanet.Blocks.BlockHash> _subject;
+    private readonly Subject<Libplanet.Blocks.BlockHash>? _subject;
 
-    public VillageField(BlockChain blockChain, Subject<Libplanet.Blocks.BlockHash> subject)
+    public VillageField(BlockChain blockChain, Subject<Libplanet.Blocks.BlockHash>? subject = null)
         : base()
     {
         _blockChain = blockChain;
@@ -53,7 +53,7 @@ public VillageField(BlockChain blockChain, Subject<Libplanet.Blocks.BlockHash> s
                 {
                     var villages = CsvDataHelper.GetVillageCSVData().ToArray();
 
-                    return _subject
+                    return _subject!
                         .DistinctUntilChanged()
                         .Select(
                             _ => GetVillageDetails(villages.ToImmutableList(), context, blockChain)