feat: curio: alertManager (#11926)

* add alert task * maxbalance config, storage alert * docs gen * improve storage alert * fix empty alert
filecoin-project · May 8, 2024 · 22ccaf9 · 22ccaf9
1 parent 33876bf
commit 22ccaf9
Show file tree

Hide file tree

Showing 14 changed files with 1,104 additions and 365 deletions.
diff --git a/Dockerfile.curio b/Dockerfile.curio
@@ -33,8 +33,6 @@ RUN set -eux; \
 COPY ./ /opt/curio
 WORKDIR /opt/curio
 
-#RUN scripts/docker-git-state-check.sh
-
 ### make configurable filecoin-ffi build
 ARG FFI_BUILD_FROM_SOURCE=0
 ENV FFI_BUILD_FROM_SOURCE=${FFI_BUILD_FROM_SOURCE}

diff --git a/cmd/curio/deps/deps.go b/cmd/curio/deps/deps.go
@@ -207,7 +207,7 @@ func (deps *Deps) PopulateRemainingDeps(ctx context.Context, cctx *cli.Context,
 		}
 	}
 
-	if deps.Cfg == nil {
+	if deps.DB == nil {
 		deps.DB, err = MakeDB(cctx)
 		if err != nil {
 			return err

diff --git a/cmd/curio/guidedsetup/guidedsetup.go b/cmd/curio/guidedsetup/guidedsetup.go
@@ -250,7 +250,7 @@ func complete(d *MigrationData) {
 
 func completeInit(d *MigrationData) {
 	stepCompleted(d, d.T("New Miner initialization complete."))
-	d.say(plain, "Try the web interface with %s for further guided improvements.", "--layers=gui")
+	d.say(plain, "Try the web interface with %s for further guided improvements.", code.Render("curio run --layers=gui"))
 }
 
 func configToDB(d *MigrationData) {

diff --git a/cmd/curio/internal/translations/catalog.go b/cmd/curio/internal/translations/catalog.go
diff --git a/cmd/curio/internal/translations/locales/en/out.gotext.json b/cmd/curio/internal/translations/locales/en/out.gotext.json
@@ -187,6 +187,44 @@
             ],
             "fuzzy": true
         },
+        {
+            "id": "Unmigratable sectors found. Do you want to continue?",
+            "message": "Unmigratable sectors found. Do you want to continue?",
+            "translation": "Unmigratable sectors found. Do you want to continue?",
+            "translatorComment": "Copied from source.",
+            "fuzzy": true
+        },
+        {
+            "id": "Yes, continue",
+            "message": "Yes, continue",
+            "translation": "Yes, continue",
+            "translatorComment": "Copied from source.",
+            "fuzzy": true
+        },
+        {
+            "id": "No, abort",
+            "message": "No, abort",
+            "translation": "No, abort",
+            "translatorComment": "Copied from source.",
+            "fuzzy": true
+        },
+        {
+            "id": "Aborting migration.",
+            "message": "Aborting migration.",
+            "translation": "Aborting migration.",
+            "translatorComment": "Copied from source.",
+            "placeholders": [
+                {
+                    "id": "Error",
+                    "string": "%[1]v",
+                    "type": "string",
+                    "underlyingType": "string",
+                    "argNum": 1,
+                    "expr": "err.Error()"
+                }
+            ],
+            "fuzzy": true
+        },
         {
             "id": "Error saving config to layer: {Error}. Aborting Migration",
             "message": "Error saving config to layer: {Error}. Aborting Migration",
@@ -602,13 +640,6 @@
             "translatorComment": "Copied from source.",
             "fuzzy": true
         },
-        {
-            "id": "Aborting migration.",
-            "message": "Aborting migration.",
-            "translation": "Aborting migration.",
-            "translatorComment": "Copied from source.",
-            "fuzzy": true
-        },
         {
             "id": "Sectors verified. {I} sector locations found.",
             "message": "Sectors verified. {I} sector locations found.",
@@ -1552,6 +1583,23 @@
             ],
             "fuzzy": true
         },
+        {
+            "id": "Migrating metadata for {NSectors} sectors.",
+            "message": "Migrating metadata for {NSectors} sectors.",
+            "translation": "Migrating metadata for {NSectors} sectors.",
+            "translatorComment": "Copied from source.",
+            "placeholders": [
+                {
+                    "id": "NSectors",
+                    "string": "%[1]d",
+                    "type": "int",
+                    "underlyingType": "int",
+                    "argNum": 1,
+                    "expr": "nSectors"
+                }
+            ],
+            "fuzzy": true
+        },
         {
             "id": "Configuration 'base' was updated to include this miner's address ({MinerAddress}) and its wallet setup.",
             "message": "Configuration 'base' was updated to include this miner's address ({MinerAddress}) and its wallet setup.",

diff --git a/cmd/curio/internal/translations/locales/ko/messages.gotext.json b/cmd/curio/internal/translations/locales/ko/messages.gotext.json
@@ -1101,6 +1101,30 @@
             "translation": "'base' 설정이 이 lotus-miner의 config.toml과 유사하게 만들어졌습니다.",
             "message": "Configuration 'base' was created to resemble this lotus-miner's config.toml .",
             "placeholder": null
+        },
+        {
+            "id": "Unmigratable sectors found. Do you want to continue?",
+            "translation": "이동할 수 없는 섹터가 발견되었습니다. 계속하시겠습니까?",
+            "message": "Unmigratable sectors found. Do you want to continue?",
+            "placeholder": null
+        },
+        {
+            "id": "Yes, continue",
+            "translation": "예, 계속",
+            "message": "Yes, continue",
+            "placeholder": null
+        },
+        {
+            "id": "No, abort",
+            "translation": "아니오, 중단",
+            "message": "No, abort",
+            "placeholder": null
+        },
+        {
+            "id": "Migrating metadata for {NSectors} sectors.",
+            "translation": "{NSectors} 섹터의 메타데이터를 이동 중입니다.",
+            "message": "Migrating metadata for {NSectors} sectors.",
+            "placeholder": null
         }
     ]
 }
diff --git a/cmd/curio/internal/translations/locales/zh/messages.gotext.json b/cmd/curio/internal/translations/locales/zh/messages.gotext.json
@@ -1071,6 +1071,30 @@
       "translation": "'base'配置已创建，以类似于这个lotus-miner的config.toml。",
       "message": "Configuration 'base' was created to resemble this lotus-miner's config.toml .",
       "placeholder": null
+    },
+    {
+      "id": "Unmigratable sectors found. Do you want to continue?",
+      "translation": "发现无法迁移的扇区。您想要继续吗？",
+      "message": "Unmigratable sectors found. Do you want to continue?",
+      "placeholder": null
+    },
+    {
+      "id": "Yes, continue",
+      "translation": "是的，继续",
+      "message": "Yes, continue",
+      "placeholder": null
+    },
+    {
+      "id": "No, abort",
+      "translation": "不，中止",
+      "message": "No, abort",
+      "placeholder": null
+    },
+    {
+      "id": "Migrating metadata for {NSectors} sectors.",
+      "translation": "正在迁移{NSectors}个扇区的元数据。",
+      "message": "Migrating metadata for {NSectors} sectors.",
+      "placeholder": null
     }
   ]
 }
diff --git a/cmd/curio/tasks/tasks.go b/cmd/curio/tasks/tasks.go
@@ -16,6 +16,7 @@ import (
 
 	"github.com/filecoin-project/lotus/cmd/curio/deps"
 	curio "github.com/filecoin-project/lotus/curiosrc"
+	"github.com/filecoin-project/lotus/curiosrc/alertmanager"
 	"github.com/filecoin-project/lotus/curiosrc/chainsched"
 	"github.com/filecoin-project/lotus/curiosrc/ffi"
 	"github.com/filecoin-project/lotus/curiosrc/gc"
@@ -144,6 +145,9 @@ func StartTasks(ctx context.Context, dependencies *deps.Deps) (*harmonytask.Task
 		activeTasks = append(activeTasks, storageEndpointGcTask)
 	}
 
+	amTask := alertmanager.NewAlertTask(full, db, cfg.Alerting)
+	activeTasks = append(activeTasks, amTask)
+
 	if needProofParams {
 		for spt := range dependencies.ProofTypes {
 			if err := modules.GetParams(true)(spt); err != nil {