feat: Minimum block rewards to send notifications

Flexpool is now finding more blocks than ever. There are tons of notifications
all day long. This commit adds a new pool setting `min-block-reward` to send
notifications for blocks reaching this minimum threshold, so we can focus on
big blocks.

Signed-off-by: Julien Riou <julien@riou.xyz>

.gitignore

@@ -1,3 +1,4 @@
+etc
 bin
 flexassistant.yaml
 flexassistant.db

README.md

@@ -73,6 +73,7 @@ Reference:
 * `pools` (optional): list of pools
     * `coin`: coin of the pool (ex: `eth`, `xch`)
     * `enable-blocks` (optional): enable block notifications for this pool (disabled by default)
+    * `min-block-reward` (optional): send notifications when block reward has reached this minimum threshold in crypto currency unit (ETH, XCH, etc)
 * `miners` (optional): list of miners and/or farmers
     * `address`: address of the miner or the farmer registered on the API
     * `enable-balance` (optional): enable balance notifications (disabled by default)

VERSION

@@ -1 +1 @@
-1.4
+1.5

config.go

@@ -19,8 +19,9 @@ type Config struct {
 
 // PoolConfig to store Pool configuration
 type PoolConfig struct {
-	Coin         string `yaml:"coin"`
-	EnableBlocks bool   `yaml:"enable-blocks"`
+	Coin           string  `yaml:"coin"`
+	EnableBlocks   bool    `yaml:"enable-blocks"`
+	MinBlockReward float64 `yaml:"min-block-reward"`
 }
 
 // MinerConfig to store Miner configuration

flexassistant.yaml.example

@@ -14,8 +14,10 @@ miners:
 pools:
   - coin: eth
     enable-blocks: true
+    min-block-reward: 10
   - coin: xch
     enable-blocks: true
+    min-block-reward: 1.79
 telegram:
   chat-id: 000000000
   channel-name: MyTelegramChannel

main.go

@@ -263,7 +263,11 @@ func main() {
 							log.Warnf("Cannot update pool: %v", trx.Error)
 							continue
 						}
-						if notify {
+						convertedReward, err := ConvertCurrency(pool.Coin, block.Reward)
+						if err != nil {
+							log.Warnf("Reward for block %d cannot be converted: %v", block.Number, err)
+						}
+						if notify && convertedReward >= configuredPool.MinBlockReward {
 							err = notifier.NotifyBlock(*pool, *block)
 							if err != nil {
 								log.Warnf("Cannot send notification: %v", err)