fix: stop logging connection credentials
This commit is contained in:
29
internal/impl/connections.go
Normal file
29
internal/impl/connections.go
Normal file
@@ -0,0 +1,29 @@
|
|||||||
|
package impl
|
||||||
|
|
||||||
|
import (
|
||||||
|
"fmt"
|
||||||
|
|
||||||
|
"git.apinb.com/bsm-sdk/core/cache/redis"
|
||||||
|
"git.apinb.com/bsm-sdk/core/conf"
|
||||||
|
"git.apinb.com/bsm-sdk/core/database"
|
||||||
|
"git.apinb.com/bsm-sdk/core/vars"
|
||||||
|
"gorm.io/gorm"
|
||||||
|
)
|
||||||
|
|
||||||
|
func newDatabase(cfg *conf.DBConf) *gorm.DB {
|
||||||
|
if cfg == nil || len(cfg.Source) == 0 {
|
||||||
|
panic("database source is required")
|
||||||
|
}
|
||||||
|
db, err := database.NewDatabase(cfg.Driver, cfg.Source, nil)
|
||||||
|
if err != nil {
|
||||||
|
panic(fmt.Sprintf("database init failed: %v", err))
|
||||||
|
}
|
||||||
|
return db
|
||||||
|
}
|
||||||
|
|
||||||
|
func newRedisCache(dsn string) *redis.RedisClient {
|
||||||
|
if dsn == "" {
|
||||||
|
return nil
|
||||||
|
}
|
||||||
|
return redis.New(dsn, vars.ServiceKey)
|
||||||
|
}
|
||||||
@@ -5,7 +5,6 @@ import (
|
|||||||
|
|
||||||
"git.apinb.com/bsm-sdk/core/cache/redis"
|
"git.apinb.com/bsm-sdk/core/cache/redis"
|
||||||
"git.apinb.com/bsm-sdk/core/logger"
|
"git.apinb.com/bsm-sdk/core/logger"
|
||||||
"git.apinb.com/bsm-sdk/core/with"
|
|
||||||
"git.apinb.com/ops/logs/internal/config"
|
"git.apinb.com/ops/logs/internal/config"
|
||||||
"git.apinb.com/ops/logs/internal/models"
|
"git.apinb.com/ops/logs/internal/models"
|
||||||
"gorm.io/gorm"
|
"gorm.io/gorm"
|
||||||
@@ -17,8 +16,8 @@ var (
|
|||||||
)
|
)
|
||||||
|
|
||||||
func NewImpl() {
|
func NewImpl() {
|
||||||
RedisService = with.RedisCache(config.Spec.Cache)
|
RedisService = newRedisCache(config.Spec.Cache)
|
||||||
DBService = with.Databases(config.Spec.Databases, nil)
|
DBService = newDatabase(config.Spec.Databases)
|
||||||
logger.New(nil)
|
logger.New(nil)
|
||||||
|
|
||||||
if DBService != nil {
|
if DBService != nil {
|
||||||
|
|||||||
Reference in New Issue
Block a user