mirror of
https://github.com/grassrootseconomics/cic-custodial.git
synced 2024-11-25 07:16:46 +01:00
Mohammed Sohail
4d13a14dc2
Squashed commit of the following: commit05e1396121Author: Mohammed Sohail <sohailsameja@gmail.com> Date: Wed Feb 15 10:03:44 2023 +0300 feat: add status types to dispatcher commit397cd78ca9Author: Mohammed Sohail <sohailsameja@gmail.com> Date: Wed Feb 15 09:39:31 2023 +0300 deps: bump -> cic-celo-sdk commitf2ba079232Author: Mohammed Sohail <sohailsameja@gmail.com> Date: Sun Feb 12 16:53:53 2023 +0300 snapshot: 12-ebening commit4f7909e4eeAuthor: Mohammed Sohail <sohailsameja@gmail.com> Date: Sun Feb 12 12:50:43 2023 +0300 xnapshot: 12-02 commit773474cad9Author: Mohammed Sohail <sohailsameja@gmail.com> Date: Thu Feb 9 14:23:37 2023 +0300 update: deps initializers commit8a0880fcfcAuthor: Mohammed Sohail <sohailsameja@gmail.com> Date: Thu Feb 9 10:42:15 2023 +0300 wip: refactor taskers commit8676450122Author: Mohammed Sohail <sohailsameja@gmail.com> Date: Fri Feb 3 12:29:27 2023 +0300 refactor: decouple sql queries, remove transfer * add inline docs * removed transfer taks in prep for re-write commitb4c09cd11aAuthor: Mohammed Sohail <sohailsameja@gmail.com> Date: Thu Feb 2 12:29:43 2023 +0000 refactor: cmd/service/* and api
83 lines
2.5 KiB
Go
83 lines
2.5 KiB
Go
package main
|
|
|
|
import (
|
|
"github.com/grassrootseconomics/cic-custodial/internal/tasker"
|
|
"github.com/grassrootseconomics/cic-custodial/internal/tasker/task"
|
|
"github.com/grassrootseconomics/cic-custodial/pkg/redis"
|
|
"github.com/hibiken/asynq"
|
|
)
|
|
|
|
// Load tasker handlers, injecting any necessary handler dependencies from the system container.
|
|
func initTasker(custodialContainer *custodial, redisPool *redis.RedisPool) *tasker.TaskerServer {
|
|
lo.Debug("Bootstrapping tasker")
|
|
js, err := initJetStream()
|
|
if err != nil {
|
|
lo.Fatal("filters: critical error loading jetstream", "error", err)
|
|
}
|
|
|
|
taskerServerOpts := tasker.TaskerServerOpts{
|
|
Concurrency: ko.MustInt("asynq.worker_count"),
|
|
Logg: lo,
|
|
LogLevel: asynq.ErrorLevel,
|
|
RedisPool: redisPool,
|
|
SystemContainer: custodialContainer.systemContainer,
|
|
TaskerClient: custodialContainer.taskerClient,
|
|
}
|
|
|
|
if debugFlag {
|
|
taskerServerOpts.LogLevel = asynq.DebugLevel
|
|
}
|
|
|
|
taskerServer := tasker.NewTaskerServer(taskerServerOpts)
|
|
|
|
taskerServer.RegisterHandlers(tasker.PrepareAccountTask, task.PrepareAccount(
|
|
custodialContainer.noncestore,
|
|
custodialContainer.taskerClient,
|
|
js,
|
|
))
|
|
taskerServer.RegisterHandlers(tasker.RegisterAccountOnChain, task.RegisterAccountOnChainProcessor(
|
|
custodialContainer.celoProvider,
|
|
custodialContainer.lockProvider,
|
|
custodialContainer.noncestore,
|
|
custodialContainer.pgStore,
|
|
custodialContainer.systemContainer,
|
|
custodialContainer.taskerClient,
|
|
js,
|
|
))
|
|
taskerServer.RegisterHandlers(tasker.GiftGasTask, task.GiftGasProcessor(
|
|
custodialContainer.celoProvider,
|
|
custodialContainer.lockProvider,
|
|
custodialContainer.noncestore,
|
|
custodialContainer.pgStore,
|
|
custodialContainer.systemContainer,
|
|
custodialContainer.taskerClient,
|
|
js,
|
|
))
|
|
taskerServer.RegisterHandlers(tasker.GiftTokenTask, task.GiftTokenProcessor(
|
|
custodialContainer.celoProvider,
|
|
custodialContainer.lockProvider,
|
|
custodialContainer.noncestore,
|
|
custodialContainer.pgStore,
|
|
custodialContainer.systemContainer,
|
|
custodialContainer.taskerClient,
|
|
js,
|
|
))
|
|
taskerServer.RegisterHandlers(tasker.SignTransferTask, task.SignTransfer(
|
|
custodialContainer.celoProvider,
|
|
custodialContainer.keystore,
|
|
custodialContainer.lockProvider,
|
|
custodialContainer.noncestore,
|
|
custodialContainer.pgStore,
|
|
custodialContainer.systemContainer,
|
|
custodialContainer.taskerClient,
|
|
js,
|
|
))
|
|
taskerServer.RegisterHandlers(tasker.TxDispatchTask, task.TxDispatch(
|
|
custodialContainer.celoProvider,
|
|
custodialContainer.pgStore,
|
|
js,
|
|
))
|
|
|
|
return taskerServer
|
|
}
|