diff --git a/cmd/init.go b/cmd/init.go index 6cd650b..9220421 100644 --- a/cmd/init.go +++ b/cmd/init.go @@ -47,13 +47,17 @@ func loadConfig(configFilePath string, k *koanf.Koanf) error { return nil } -func connectDb(dsn string) error { +func connectDbs(dsn string) error { var err error db, err = pgxpool.Connect(context.Background(), dsn) if err != nil { return err } + rClient = asynq.RedisClientOpt{ + Addr: conf.Db.Redis, + } + return nil } diff --git a/cmd/main.go b/cmd/main.go index 849ea62..13be23c 100644 --- a/cmd/main.go +++ b/cmd/main.go @@ -35,7 +35,7 @@ func init() { log.Fatal().Err(err).Msg("failed to load sql file") } - if err := connectDb(conf.Db.Postgres); err != nil { + if err := connectDbs(conf.Db.Postgres); err != nil { log.Fatal().Err(err).Msg("failed to connect to postgres") } diff --git a/config.toml b/config.toml index 1a57d7d..816ac92 100644 --- a/config.toml +++ b/config.toml @@ -8,5 +8,5 @@ rpc = "http://127.0.0.1:8545" [syncers] cache = "@every 20s" -ussd = "@every 1m" -token = "@every 10s" \ No newline at end of file +ussd = "@every 30" +token = "@every 1m" \ No newline at end of file