Get latest block information

NineChroniclesUtilBackend.Store/Client/EmptyChronicleClient.cs

@@ -3,12 +3,12 @@
 
 namespace NineChroniclesUtilBackend.Store.Client;
 
-public class EmptyChroniclesClient
+public class EmptyChronicleClient
 {
     private readonly HttpClient _httpClient;
     private readonly string _baseUrl;
 
-    public EmptyChroniclesClient(string baseUrl)
+    public EmptyChronicleClient(string baseUrl)
     {
         _baseUrl = baseUrl;
         _httpClient = new HttpClient();
@@ -36,4 +36,28 @@ public async Task<StateResponse> GetStateByAddressAsync(string address, string?
 
         return stateResponse;
     }
+
+    public async Task<BlockResponse> GetLatestBlock()
+    {
+        var url = $"{_baseUrl}/api/blocks/latest";
+
+        var response = await _httpClient.GetAsync(url);
+
+        response.EnsureSuccessStatusCode();
+
+        var content = await response.Content.ReadAsStringAsync();
+
+        var stateResponse = JsonConvert.DeserializeObject<BlockResponse>(content);
+        if (stateResponse == null)
+        {
+            throw new InvalidOperationException("StateResponse is null.");
+        }
+
+        return stateResponse;
+    }
+
+    // public async Task<StateResponse> GetBlock(int index)
+    // {
+    //     return stateResponse;
+    // }
 }

NineChroniclesUtilBackend.Store/Models/BlockResponse.cs

@@ -0,0 +1,13 @@
+namespace NineChroniclesUtilBackend.Store.Models;
+
+public class BlockResponse
+{
+    public string Hash { get; }
+    public long Index { get; }
+
+    public BlockResponse(string hash, long index)
+    {
+        Hash = hash;
+        Index = index;
+    }
+}

NineChroniclesUtilBackend.Store/Program.cs

@@ -15,7 +15,7 @@
 builder.Services.AddSingleton(serviceProvider =>
 {
     var config = serviceProvider.GetRequiredService<IOptions<Configuration>>().Value;
-    return new EmptyChroniclesClient(config.EmptyChronicleBaseUrl);
+    return new EmptyChronicleClient(config.EmptyChronicleBaseUrl);
 });
 
 builder.Services.AddSingleton(serviceProvider =>

NineChroniclesUtilBackend.Store/Scrapper/ArenaScrapper.cs

@@ -1,6 +1,7 @@
 using NineChroniclesUtilBackend.Store.Events;
 using NineChroniclesUtilBackend.Store.Services;
 using NineChroniclesUtilBackend.Store.Models;
+using NineChroniclesUtilBackend.Store.Client;
 using Nekoyume.TableData;
 using Libplanet.Crypto;
 
@@ -12,12 +13,14 @@ public class ArenaScrapper
     public readonly ScrapperResult Result = new ScrapperResult();
 
     private StateGetter _stateGetter;
+    private EmptyChronicleClient _client;
     public event EventHandler<ArenaDataCollectedEventArgs> OnDataCollected;
 
-    public ArenaScrapper(ILogger<ArenaScrapper> logger, IStateService service)
+    public ArenaScrapper(ILogger<ArenaScrapper> logger, IStateService service, EmptyChronicleClient client)
     {
         _stateGetter = new StateGetter(service);
         _logger = logger;
+        _client = client;
     }
 
     protected virtual void RaiseDataCollected(ArenaData arenaData, AvatarData avatarData)
@@ -28,8 +31,9 @@ protected virtual void RaiseDataCollected(ArenaData arenaData, AvatarData avatar
     public async Task ExecuteAsync()
     {
         Result.StartTime = DateTime.UtcNow;
+        var latestBlock = await _client.GetLatestBlock();
 
-        var roundData = await GetArenaRoundData(900000);
+        var roundData = await GetArenaRoundData(latestBlock.Index);
 
         var arenaParticipants = await _stateGetter.GetArenaParticipantsState(roundData.ChampionshipId, roundData.Round);
 
@@ -47,7 +51,7 @@ public async Task ExecuteAsync()
         Result.TotalElapsedMinutes = DateTime.UtcNow.Subtract(Result.StartTime).Minutes;
     }
 
-    public async Task<ArenaSheet.RoundData> GetArenaRoundData(int index)
+    public async Task<ArenaSheet.RoundData> GetArenaRoundData(long index)
     {
         var arenaSheet = await _stateGetter.GetSheet<ArenaSheet>();
         var roundData = arenaSheet.GetRoundByBlockIndex(index);

NineChroniclesUtilBackend.Store/Services/EmptyChronicleStateService.cs

@@ -9,10 +9,10 @@ namespace NineChroniclesUtilBackend.Store.Services;
 
 public class EmptyChronicleStateService : IStateService
 {
-    private readonly EmptyChroniclesClient client;
+    private readonly EmptyChronicleClient client;
     private static readonly Codec Codec = new();
 
-    public EmptyChronicleStateService(EmptyChroniclesClient client)
+    public EmptyChronicleStateService(EmptyChronicleClient client)
     {
         this.client = client;
     }

NineChroniclesUtilBackend.Store/Worker.cs

@@ -1,5 +1,6 @@
 using NineChroniclesUtilBackend.Store.Events;
 using NineChroniclesUtilBackend.Store.Scrapper;
+using NineChroniclesUtilBackend.Store.Client;
 using NineChroniclesUtilBackend.Store.Services;
 
 namespace NineChroniclesUtilBackend.Store;
@@ -11,12 +12,17 @@ public class Worker : BackgroundService
     private readonly ILogger<Worker> _logger;
     private readonly IStateService _stateService;
 
-    public Worker(ILogger<Worker> logger,  ILogger<ArenaScrapper> scrapperLogger, IStateService stateService, MongoDbStore store)
+    public Worker(
+        ILogger<Worker> logger,
+        ILogger<ArenaScrapper> scrapperLogger,
+        IStateService stateService,
+        MongoDbStore store,
+        EmptyChronicleClient client)
     {
         _logger = logger;
         _stateService = stateService;
         _store = store;
-        _scrapper = new ArenaScrapper(scrapperLogger, _stateService);
+        _scrapper = new ArenaScrapper(scrapperLogger, _stateService, client);
         _scrapper.OnDataCollected += HandleDataCollected;
     }