Store to worker (#40)

* store -> worker * temp
planetarium · May 7, 2024 · 949f085 · 949f085
1 parent 4f57dae
commit 949f085
Show file tree

Hide file tree

Showing 38 changed files with 88 additions and 88 deletions.
diff --git a/.github/workflows/docker.yaml b/.github/workflows/docker.yaml
@@ -11,8 +11,8 @@ jobs:
         docker:
           - repo: planetariumhq/mimir
             dockerfile: Dockerfile
-          - repo: planetariumhq/mimir-store
-            dockerfile: Dockerfile.Store
+          - repo: planetariumhq/mimir-worker
+            dockerfile: Dockerfile.Worker
     steps:
       -
         name: Checkout

diff --git a/.vscode/launch.json b/.vscode/launch.json
@@ -12,14 +12,14 @@
       "preLaunchTask": "build-backend"
     },
     {
-      "name": "Debug Mimir.Store",
+      "name": "Debug Mimir.Worker",
       "type": "coreclr",
       "request": "launch",
-      "program": "${workspaceFolder}/Mimir.Store/bin/Debug/net8.0/Mimir.Store.dll",
-      "cwd": "${workspaceFolder}/Mimir.Store",
+      "program": "${workspaceFolder}/Mimir.Worker/bin/Debug/net8.0/Mimir.Worker.dll",
+      "cwd": "${workspaceFolder}/Mimir.Worker",
       "stopAtEntry": false,
       "console": "internalConsole",
-      "preLaunchTask": "build-store",
+      "preLaunchTask": "build-worker",
       "env": {
         "STORE_CONFIG_FILE": "appsettings.local.json"
       }

diff --git a/.vscode/tasks.json b/.vscode/tasks.json
@@ -38,38 +38,38 @@
             "problemMatcher": "$msCompile"
         },
         {
-            "label": "build-store",
+            "label": "build-worker",
             "command": "dotnet",
             "type": "process",
             "args": [
                 "build",
-                "${workspaceFolder}/Mimir.Store/Mimir.Store.csproj",
+                "${workspaceFolder}/Mimir.Worker/Mimir.Worker.csproj",
                 "/property:GenerateFullPaths=true",
                 "/consoleloggerparameters:NoSummary"
             ],
             "problemMatcher": "$msCompile"
         },
         {
-            "label": "publish-store",
+            "label": "publish-worker",
             "command": "dotnet",
             "type": "process",
             "args": [
                 "publish",
-                "${workspaceFolder}/Mimir.Store/Mimir.Store.csproj",
+                "${workspaceFolder}/Mimir.Worker/Mimir.Worker.csproj",
                 "/property:GenerateFullPaths=true",
                 "/consoleloggerparameters:NoSummary"
             ],
             "problemMatcher": "$msCompile"
         },
         {
-            "label": "watch-store",
+            "label": "watch-worker",
             "command": "dotnet",
             "type": "process",
             "args": [
                 "watch",
                 "run",
                 "--project",
-                "${workspaceFolder}/Mimir.Store/Mimir.Store.csproj"
+                "${workspaceFolder}/Mimir.Worker/Mimir.Worker.csproj"
             ],
             "problemMatcher": "$msCompile"
         }

diff --git a/Dockerfile.Store → Dockerfile.Worker b/Dockerfile.Store → Dockerfile.Worker
@@ -6,21 +6,21 @@ WORKDIR /app
 # Copy everything else and build
 COPY . ./
 RUN dotnet tool restore
-RUN dotnet graphql generate Mimir.Store
+RUN dotnet graphql generate Mimir.Worker
 RUN <<EOF
 #!/bin/bash
 echo "TARGETPLATFROM=$TARGETPLATFORM"
 echo "BUILDPLATFORM=$BUILDPLATFORM"
 if [[ "$TARGETPLATFORM" = "linux/amd64" ]]
 then
-  dotnet publish Mimir.Store/Mimir.Store.csproj \
+  dotnet publish Mimir.Worker/Mimir.Worker.csproj \
     -c Release \
     -r linux-x64 \
     -o out \
     --self-contained
 elif [[ "$TARGETPLATFORM" = "linux/arm64" ]]
 then
-  dotnet publish Mimir.Store/Mimir.Store.csproj \
+  dotnet publish Mimir.Worker/Mimir.Worker.csproj \
     -c Release \
     -r linux-arm64 \
     -o out \
@@ -43,4 +43,4 @@ RUN apt-get update \
         libc6-dev jq curl \
      && rm -rf /var/lib/apt/lists/*
 
-ENTRYPOINT ["dotnet", "Mimir.Store.dll"]
+ENTRYPOINT ["dotnet", "Mimir.Worker.dll"]
diff --git a/Mimir.Store/.graphqlrc.json → Mimir.Worker/.graphqlrc.json b/Mimir.Store/.graphqlrc.json → Mimir.Worker/.graphqlrc.json
diff --git a/Mimir.Store/BlockPoller.cs → Mimir.Worker/BlockPoller.cs b/Mimir.Store/BlockPoller.cs → Mimir.Worker/BlockPoller.cs
@@ -2,20 +2,20 @@
 using HeadlessGQL;
 using Libplanet.Crypto;
 using Libplanet.Types.Tx;
-using Mimir.Store.Models;
-using Mimir.Store.Scrapper;
-using Mimir.Store.Services;
+using Mimir.Worker.Models;
+using Mimir.Worker.Scrapper;
+using Mimir.Worker.Services;
 
-namespace Mimir.Store;
+namespace Mimir.Worker;
 
-public class BlockPoller(IStateService stateService, HeadlessGQLClient headlessGqlClient, MongoDbStore mongoDbStore)
+public class BlockPoller(IStateService stateService, HeadlessGQLClient headlessGqlClient, MongoDbWorker mongoDbWorker)
 {
     public async Task RunAsync(CancellationToken cancellationToken)
     {
         var stateGetter = new StateGetter(stateService);
         while (!cancellationToken.IsCancellationRequested)
         {
-            var syncedBlockIndex = await mongoDbStore.GetLatestBlockIndex();
+            var syncedBlockIndex = await mongoDbWorker.GetLatestBlockIndex();
             var currentBlockIndex = await stateService.GetLatestIndex();
             var processBlockIndex = syncedBlockIndex + 1;
 
@@ -31,7 +31,7 @@ public async Task RunAsync(CancellationToken cancellationToken)
             {
                 Serilog.Log.Error("Failed to get arena txs. errors:\n" +
                                   string.Join("\n", rawArenaTxsResp.Errors.Select(x => "- " + x.Message)));
-                await mongoDbStore.UpdateLatestBlockIndex(syncedBlockIndex + 1);
+                await mongoDbWorker.UpdateLatestBlockIndex(syncedBlockIndex + 1);
                 continue;
             }
 
@@ -56,13 +56,13 @@ public async Task RunAsync(CancellationToken cancellationToken)
                     var myArenaData = await stateGetter.GetArenaData(roundData, myAvatarAddress);
                     var enemyArenaData = await stateGetter.GetArenaData(roundData, enemyAvatarAddress);
 
-                    await mongoDbStore.BulkUpsertAvatarDataAsync(new List<AvatarData> { myAvatarData, enemyAvatarData });
-                    await mongoDbStore.BulkUpsertArenaDataAsync(new List<ArenaData> { myArenaData, enemyArenaData });
+                    await mongoDbWorker.BulkUpsertAvatarDataAsync(new List<AvatarData> { myAvatarData, enemyAvatarData });
+                    await mongoDbWorker.BulkUpsertArenaDataAsync(new List<ArenaData> { myArenaData, enemyArenaData });
                 }
             }
             finally
             {
-                await mongoDbStore.UpdateLatestBlockIndex(syncedBlockIndex + 1);
+                await mongoDbWorker.UpdateLatestBlockIndex(syncedBlockIndex + 1);
             }
         }
     }

diff --git a/Mimir.Store/Configuration.cs → Mimir.Worker/Configuration.cs b/Mimir.Store/Configuration.cs → Mimir.Worker/Configuration.cs
@@ -1,4 +1,4 @@
-namespace Mimir.Store;
+namespace Mimir.Worker;
 
 public class Configuration
 {

diff --git a/...ore/Events/ArenaDataCollectedEventArgs.cs → ...ker/Events/ArenaDataCollectedEventArgs.cs b/...ore/Events/ArenaDataCollectedEventArgs.cs → ...ker/Events/ArenaDataCollectedEventArgs.cs
@@ -1,6 +1,6 @@
-using Mimir.Store.Models;
+using Mimir.Worker.Models;
 
-namespace Mimir.Store.Events;
+namespace Mimir.Worker.Events;
 
 public class ArenaDataCollectedEventArgs : EventArgs
 {

diff --git a/Mimir.Store/Initializer.cs → Mimir.Worker/Initializer.cs b/Mimir.Store/Initializer.cs → Mimir.Worker/Initializer.cs
@@ -1,12 +1,12 @@
 using HeadlessGQL;
-using Mimir.Store.Scrapper;
-using Mimir.Store.Services;
+using Mimir.Worker.Scrapper;
+using Mimir.Worker.Services;
 
-namespace Mimir.Store;
+namespace Mimir.Worker;
 
 public class Initializer : BackgroundService
 {
-    private readonly MongoDbStore _store;
+    private readonly MongoDbWorker _worker;
     private readonly ArenaScrapper _scrapper;
     private readonly ILogger<Initializer> _logger;
     private readonly HeadlessGQLClient _headlessGqlClient;
@@ -17,13 +17,13 @@ public Initializer(
         ILogger<ArenaScrapper> scrapperLogger,
         HeadlessGQLClient headlessGqlClient,
         IStateService stateService,
-        MongoDbStore store)
+        MongoDbWorker worker)
     {
         _logger = logger;
         _stateService = stateService;
-        _store = store;
+        _worker = worker;
         _headlessGqlClient = headlessGqlClient;
-        _scrapper = new ArenaScrapper(scrapperLogger, _stateService, _store);
+        _scrapper = new ArenaScrapper(scrapperLogger, _stateService, _worker);
     }
 
     protected override async Task ExecuteAsync(CancellationToken stoppingToken)
@@ -35,7 +35,7 @@ protected override async Task ExecuteAsync(CancellationToken stoppingToken)
         var totalElapsedMinutes = DateTime.UtcNow.Subtract(started).Minutes;
         _logger.LogInformation($"Finished Initializer background service. Elapsed {totalElapsedMinutes} minutes.");
 
-        var poller = new BlockPoller(_stateService, _headlessGqlClient, _store);
+        var poller = new BlockPoller(_stateService, _headlessGqlClient, _worker);
         await poller.RunAsync(stoppingToken);
     }
 }
diff --git a/...re/NineChroniclesUtilBackend.Store.csproj → Mimir.Worker/Mimir.Worker.csproj b/...re/NineChroniclesUtilBackend.Store.csproj → Mimir.Worker/Mimir.Worker.csproj
@@ -4,7 +4,7 @@
     <TargetFramework>net8.0</TargetFramework>
     <Nullable>enable</Nullable>
     <ImplicitUsings>enable</ImplicitUsings>
-    <UserSecretsId>dotnet-Mimir.Store-bccda56f-4d38-484b-ab03-ebb26065c837</UserSecretsId>
+    <UserSecretsId>dotnet-Mimir.Worker-bccda56f-4d38-484b-ab03-ebb26065c837</UserSecretsId>
   </PropertyGroup>
 
   <ItemGroup>

diff --git a/Mimir.Store/Models/BlockResponse.cs → Mimir.Worker/Models/BlockResponse.cs b/Mimir.Store/Models/BlockResponse.cs → Mimir.Worker/Models/BlockResponse.cs
@@ -1,4 +1,4 @@
-namespace Mimir.Store.Models;
+namespace Mimir.Worker.Models;
 
 public class BlockResponse
 {

diff --git a/Mimir.Store/Models/ScrapperResult.cs → Mimir.Worker/Models/ScrapperResult.cs b/Mimir.Store/Models/ScrapperResult.cs → Mimir.Worker/Models/ScrapperResult.cs
@@ -1,6 +1,6 @@
 using Libplanet.Crypto;
 
-namespace Mimir.Store.Models;
+namespace Mimir.Worker.Models;
 
 public class ScrapperResult
 {

diff --git a/Mimir.Store/Models/State/ArenaData.cs → Mimir.Worker/Models/State/ArenaData.cs b/Mimir.Store/Models/State/ArenaData.cs → Mimir.Worker/Models/State/ArenaData.cs
@@ -2,7 +2,7 @@
 using Nekoyume.TableData;
 using Libplanet.Crypto;
 
-namespace Mimir.Store.Models;
+namespace Mimir.Worker.Models;
 
 public class ArenaData : BaseData
 {

diff --git a/Mimir.Store/Models/State/AvataData.cs → Mimir.Worker/Models/State/AvataData.cs b/Mimir.Store/Models/State/AvataData.cs → Mimir.Worker/Models/State/AvataData.cs
@@ -1,6 +1,6 @@
 using Nekoyume.Model.State;
 
-namespace Mimir.Store.Models;
+namespace Mimir.Worker.Models;
 
 public class AvatarData : BaseData
 {

diff --git a/Mimir.Store/Models/State/BaseData.cs → Mimir.Worker/Models/State/BaseData.cs b/Mimir.Store/Models/State/BaseData.cs → Mimir.Worker/Models/State/BaseData.cs
@@ -1,7 +1,7 @@
 using Newtonsoft.Json;
-using Mimir.Store.Util;
+using Mimir.Worker.Util;
 
-namespace Mimir.Store.Models;
+namespace Mimir.Worker.Models;
 
 public class BaseData
 {

diff --git a/Mimir.Store/Models/StateResponse.cs → Mimir.Worker/Models/StateResponse.cs b/Mimir.Store/Models/StateResponse.cs → Mimir.Worker/Models/StateResponse.cs
@@ -1,4 +1,4 @@
-namespace Mimir.Store.Models;
+namespace Mimir.Worker.Models;
 
 public class StateResponse
 {

diff --git a/Mimir.Store/Models/StoreResult.cs → Mimir.Worker/Models/StoreResult.cs b/Mimir.Store/Models/StoreResult.cs → Mimir.Worker/Models/StoreResult.cs
@@ -1,8 +1,8 @@
 using Libplanet.Crypto;
 
-namespace Mimir.Store.Models;
+namespace Mimir.Worker.Models;
 
-public class StoreResult
+public class WorkerResult
 {
     public DateTime StartTime { get; set; }
     public int TotalElapsedMinutes { get; set; }

diff --git a/Mimir.Store/Program.cs → Mimir.Worker/Program.cs b/Mimir.Store/Program.cs → Mimir.Worker/Program.cs
@@ -2,8 +2,8 @@
 using System.Net.Http.Headers;
 using System.Text;
 using Microsoft.IdentityModel.Tokens;
-using Mimir.Store;
-using Mimir.Store.Services;
+using Mimir.Worker;
+using Mimir.Worker.Services;
 using Microsoft.Extensions.Options;
 
 var builder = Host.CreateApplicationBuilder(args);
@@ -40,8 +40,8 @@
 builder.Services.AddSingleton(serviceProvider =>
 {
     var config = serviceProvider.GetRequiredService<IOptions<Configuration>>().Value;
-    var logger = serviceProvider.GetRequiredService<ILogger<MongoDbStore>>();
-    return new MongoDbStore(logger, config.MongoDbConnectionString, config.DatabaseName);
+    var logger = serviceProvider.GetRequiredService<ILogger<MongoDbWorker>>();
+    return new MongoDbWorker(logger, config.MongoDbConnectionString, config.DatabaseName);
 });
 builder.Services.AddHostedService<Initializer>();
 

diff --git a/Mimir.Store/Properties/launchSettings.json → Mimir.Worker/Properties/launchSettings.json b/Mimir.Store/Properties/launchSettings.json → Mimir.Worker/Properties/launchSettings.json
@@ -1,7 +1,7 @@
 {
-  "$schema": "http://json.schemastore.org/launchsettings.json",
+  "$schema": "http://json.schemaworker.org/launchsettings.json",
   "profiles": {
-    "Mimir.Store": {
+    "Mimir.Worker": {
       "commandName": "Project",
       "dotnetRunMessages": true,
       "environmentVariables": {

diff --git a/Mimir.Store/Queries.graphql → Mimir.Worker/Queries.graphql b/Mimir.Store/Queries.graphql → Mimir.Worker/Queries.graphql
diff --git a/Mimir.Store/Scrapper/ArenaScrapper.cs → Mimir.Worker/Scrapper/ArenaScrapper.cs b/Mimir.Store/Scrapper/ArenaScrapper.cs → Mimir.Worker/Scrapper/ArenaScrapper.cs
@@ -1,17 +1,17 @@
-using Mimir.Store.Events;
-using Mimir.Store.Services;
-using Mimir.Store.Models;
+using Mimir.Worker.Events;
+using Mimir.Worker.Services;
+using Mimir.Worker.Models;
 using Nekoyume.TableData;
 using Libplanet.Crypto;
 
-namespace Mimir.Store.Scrapper;
+namespace Mimir.Worker.Scrapper;
 
-public class ArenaScrapper(ILogger<ArenaScrapper> logger, IStateService service, MongoDbStore store)
+public class ArenaScrapper(ILogger<ArenaScrapper> logger, IStateService service, MongoDbWorker worker)
 {
     private readonly ILogger<ArenaScrapper> _logger = logger;
 
     private readonly IStateService _stateService = service;
-    private readonly MongoDbStore _store = store;
+    private readonly MongoDbWorker _worker = worker;
 
     public async Task ExecuteAsync(CancellationToken cancellationToken)
     {
@@ -24,17 +24,17 @@ public async Task ExecuteAsync(CancellationToken cancellationToken)
         const int maxBufferSize = 10;
         async Task FlushBufferAsync()
         {
-            await _store.BulkUpsertArenaDataAsync(buffer.Select(x => x.Arena).ToList());
-            await _store.BulkUpsertAvatarDataAsync(buffer.Select(x => x.Avatar).ToList());
+            await _worker.BulkUpsertArenaDataAsync(buffer.Select(x => x.Arena).ToList());
+            await _worker.BulkUpsertAvatarDataAsync(buffer.Select(x => x.Avatar).ToList());
             foreach (var pair in buffer)
             {
-                await _store.LinkAvatarWithArenaAsync(pair.AvatarAddress);
+                await _worker.LinkAvatarWithArenaAsync(pair.AvatarAddress);
             }
 
             buffer.Clear();
         }
 
-        await _store.UpdateLatestBlockIndex(latestBlockIndex);
+        await _worker.UpdateLatestBlockIndex(latestBlockIndex);
 
         foreach (var avatarAddress in arenaParticipants.AvatarAddresses)
         {

diff --git a/Mimir.Store/Scrapper/StateGetter.cs → Mimir.Worker/Scrapper/StateGetter.cs b/Mimir.Store/Scrapper/StateGetter.cs → Mimir.Worker/Scrapper/StateGetter.cs
@@ -1,4 +1,4 @@
-using Mimir.Store.Services;
+using Mimir.Worker.Services;
 using Libplanet.Crypto;
 using Bencodex.Types;
 using Nekoyume.TableData;
@@ -8,9 +8,9 @@
 using Nekoyume.Model.Item;
 using Nekoyume.Model.State;
 using Nekoyume.Model.Arena;
-using Mimir.Store.Models;
+using Mimir.Worker.Models;
 
-namespace Mimir.Store.Scrapper;
+namespace Mimir.Worker.Scrapper;
 
 public class StateGetter
 {

diff --git a/Mimir.Store/Services/HeadlessStateService.cs → ...r.Worker/Services/HeadlessStateService.cs b/Mimir.Store/Services/HeadlessStateService.cs → ...r.Worker/Services/HeadlessStateService.cs
@@ -6,7 +6,7 @@
 using Libplanet.Types.Blocks;
 using StrawberryShake;
 
-namespace Mimir.Store.Services;
+namespace Mimir.Worker.Services;
 
 public class HeadlessStateService(IHeadlessGQLClient client) : IStateService
 {

diff --git a/Mimir.Store/Services/IStateService.cs → Mimir.Worker/Services/IStateService.cs b/Mimir.Store/Services/IStateService.cs → Mimir.Worker/Services/IStateService.cs
@@ -2,7 +2,7 @@
 using Bencodex.Types;
 using Libplanet.Crypto;
 
-namespace Mimir.Store.Services;
+namespace Mimir.Worker.Services;
 
 public interface IStateService
 {