Merge pull request #460 from moreal/fewer-transactions-fetches

Cache transactions request
planetarium · Oct 29, 2024 · 71a7cf3 · 71a7cf3
2 parents 6a3a3ce + 81c4e9b
commit 71a7cf3
Show file tree

Hide file tree

Showing 7 changed files with 15 additions and 10 deletions.
diff --git a/Lib9c.GraphQL/Lib9c.GraphQL.csproj b/Lib9c.GraphQL/Lib9c.GraphQL.csproj
@@ -15,7 +15,7 @@
             <IncludeAssets>runtime; build; native; contentfiles; analyzers; buildtransitive</IncludeAssets>
         </PackageReference>
         <PackageReference Include="Lib9c" Version="1.19.0" />
-        <PackageReference Include="Libplanet" Version="5.3.0-alpha.3" />
+        <PackageReference Include="Libplanet" Version="5.3.2-alpha.1" />
     </ItemGroup>
 
     <ItemGroup>

diff --git a/Lib9c.Models.Tests/Lib9c.Models.Tests.csproj b/Lib9c.Models.Tests/Lib9c.Models.Tests.csproj
@@ -13,7 +13,7 @@
     <ItemGroup>
         <PackageReference Include="coverlet.collector" Version="6.0.0"/>
         <PackageReference Include="Lib9c" Version="1.19.0" />
-        <PackageReference Include="Libplanet" Version="5.3.0-alpha.3" />
+        <PackageReference Include="Libplanet" Version="5.3.2-alpha.1" />
         <PackageReference Include="Microsoft.NET.Test.Sdk" Version="17.8.0"/>
         <PackageReference Include="xunit" Version="2.5.3"/>
         <PackageReference Include="xunit.runner.visualstudio" Version="2.5.3"/>

diff --git a/Lib9c.Models/Lib9c.Models.csproj b/Lib9c.Models/Lib9c.Models.csproj
@@ -10,7 +10,7 @@
     <ItemGroup>
         <PackageReference Include="HotChocolate.AspNetCore" Version="13.9.12" />
         <PackageReference Include="Lib9c" Version="1.19.0" />
-        <PackageReference Include="Libplanet" Version="5.3.0-alpha.3" />
+        <PackageReference Include="Libplanet" Version="5.3.2-alpha.1" />
         <PackageReference Include="MongoDB.Driver" Version="2.27.0" />
     </ItemGroup>
 

diff --git a/Mimir.MongoDB/Mimir.MongoDB.csproj b/Mimir.MongoDB/Mimir.MongoDB.csproj
@@ -10,7 +10,7 @@
         <PackageReference Include="HotChocolate.Abstractions" Version="13.9.12" />
         <PackageReference Include="HotChocolate.Data.MongoDb" Version="13.9.12" />
         <PackageReference Include="Lib9c" Version="1.19.0"/>
-        <PackageReference Include="Libplanet" Version="5.3.0-alpha.3" />
+        <PackageReference Include="Libplanet" Version="5.3.2-alpha.1" />
         <PackageReference Include="MongoDB.Bson" Version="2.27.0" />
         <PackageReference Include="MongoDB.Driver" Version="2.27.0" />
         <PackageReference Include="MongoDB.Driver.GridFS" Version="2.27.0" />

diff --git a/Mimir.Worker/Client/HeadlessGQLClient.cs b/Mimir.Worker/Client/HeadlessGQLClient.cs
@@ -2,6 +2,7 @@
 using System.Net.Http.Headers;
 using System.Text;
 using System.Text.Json;
+using BitFaster.Caching.Lru;
 using Libplanet.Crypto;
 using Microsoft.IdentityModel.Tokens;
 using Serilog;
@@ -16,6 +17,7 @@ public class HeadlessGQLClient : IHeadlessGQLClient
     private readonly Uri[] _urls;
     private readonly string? _issuer;
     private readonly string? _secret;
+    private readonly ConcurrentLru<long, GetTransactionsResponse> _transactionCache = new(10);
     private const int RetryAttempts = 3;
     private const int DelayInSeconds = 5;
 
@@ -207,10 +209,12 @@ public async Task<GetTransactionsResponse> GetTransactionsAsync(
         CancellationToken stoppingToken = default
     )
     {
-        return await PostGraphQLRequestAsync<GetTransactionsResponse>(
+        return await _transactionCache.GetOrAddAsync(
+            blockIndex,
+            async (index) => await PostGraphQLRequestAsync<GetTransactionsResponse>(
             GraphQLQueries.GetTransactions,
-            new { blockIndex, limit },
+            new { blockIndex=index, limit },
             stoppingToken
-        );
+        ));
     }
 }
diff --git a/Mimir.Worker/Mimir.Worker.csproj b/Mimir.Worker/Mimir.Worker.csproj
@@ -11,15 +11,16 @@
   <ItemGroup>
     <PackageReference Include="Lib9c" Version="1.19.0" />
     <PackageReference Include="Lib9c.Abstractions" Version="1.19.0" />
-    <PackageReference Include="Libplanet.RocksDBStore" Version="5.3.0-alpha.3" />
-    <PackageReference Include="Libplanet" Version="5.3.0-alpha.3" />
+    <PackageReference Include="Libplanet.RocksDBStore" Version="5.3.2-alpha.1" />
+    <PackageReference Include="Libplanet" Version="5.3.2-alpha.1" />
     <PackageReference Include="Microsoft.Extensions.Hosting" Version="8.0.0" />
     <PackageReference Include="Sentry" Version="4.12.1" />
     <PackageReference Include="Sentry.Serilog" Version="4.12.1" />
     <PackageReference Include="Serilog.AspNetCore" Version="8.0.1" />
     <PackageReference Include="Serilog.Formatting.Compact" Version="3.0.0" />
     <PackageReference Include="Serilog.Settings.Configuration" Version="8.0.1" />
     <PackageReference Include="System.IdentityModel.Tokens.Jwt" Version="7.3.1" />
+    <PackageReference Include="BitFaster.Caching" Version="2.5.2" />
   </ItemGroup>
 
   <ItemGroup>

diff --git a/Mimir/Mimir.csproj b/Mimir/Mimir.csproj
@@ -20,7 +20,7 @@
       <IncludeAssets>runtime; build; native; contentfiles; analyzers; buildtransitive</IncludeAssets>
     </PackageReference>
     <PackageReference Include="Lib9c" Version="1.19.0" />
-    <PackageReference Include="Libplanet" Version="5.3.0-alpha.3" />
+    <PackageReference Include="Libplanet" Version="5.3.2-alpha.1" />
     <PackageReference Include="Microsoft.AspNetCore.Authentication.JwtBearer" Version="8.0.7" />
     <PackageReference Include="Microsoft.IdentityModel.Tokens" Version="7.3.1" />
     <PackageReference Include="Sentry" Version="4.12.1" />