sending of prestaking snapshot messages #112
Conversation
tokenomics/contract.go
Outdated
| @@ -229,6 +234,8 @@ const ( | |||
| totalCoinStatsCacheLockDuration = 1 * stdlibtime.Minute | |||
| ) | |||
|
|
|||
| var cfg Config | |||
There was a problem hiding this comment.
huh? use the one in repository. If u need it in miner, just add the topic as parameter to the function u call from miner to send the message
tokenomics/pre_staking.go
Outdated
|
|
||
| return multierror.Append( | ||
| sErr, | ||
| storage.Set(ctx, r.db, prestaking), |
There was a problem hiding this comment.
use a new context if u`re gonna rollback. Cuz most likely the reason message sending is gonna fail is cuz of exhausted retries => context expires
tokenomics/pre_staking.go
Outdated
| snapshot := &PreStakingSnapshot{ | ||
| PreStakingSummary: newPrestaking, | ||
| } | ||
| if existingAllocation != 0 && existingBonus != 0 { |
There was a problem hiding this comment.
no. zero values is a valid before state
tokenomics/pre_staking.go
Outdated
| log.Panic(errors.Wrapf(err, "failed to marshal %#v", newPrestaking)) | ||
|
|
||
| return &messagebroker.Message{ | ||
| Headers: map[string]string{"producer": "freezer"}, |
There was a problem hiding this comment.
move that into the func args. Its gonna be called with freezer-refrigerant or freezer-miner
tokenomics/pre_staking.go
Outdated
| return &messagebroker.Message{ | ||
| Headers: map[string]string{"producer": "freezer"}, | ||
| Key: newPrestaking.UserID, | ||
| Topic: cfg.MessageBroker.Topics[6].Name, |
There was a problem hiding this comment.
also, is [6] the last topic?
There was a problem hiding this comment.
Yes, on deployments repo I see 6 of them, last one is [5]
topics:
- name: freezer-refrigerant-health-check
- name: adoption-table
- name: mining-sessions-table
- name: balances-table
- name: available-daily-bonuses
- name: started-days-off
tokenomics/tokenomics.go
Outdated
| @@ -55,8 +56,6 @@ func New(ctx context.Context, _ context.CancelFunc) Repository { | |||
| } | |||
|
|
|||
| func StartProcessor(ctx context.Context, cancel context.CancelFunc) Processor { | |||
| var cfg Config | |||
There was a problem hiding this comment.
rollback changes in this file
No description provided.