move redis config over to config file
This commit is contained in:
@@ -14,7 +14,11 @@
|
||||
"server_config": {
|
||||
"port": 8080,
|
||||
"base_url": "https://profile.example.com",
|
||||
"session_store": "redis"
|
||||
"session_store": "redis",
|
||||
"redis_config": {
|
||||
"redis_url": "redis://localhost:6379/0",
|
||||
"prefix": ""
|
||||
}
|
||||
},
|
||||
"email_config": {
|
||||
"username": "noreply",
|
||||
|
||||
@@ -21,10 +21,16 @@ type StyleConfig struct {
|
||||
LogoPath string `json:"logo_path"`
|
||||
}
|
||||
|
||||
type RedisConfig struct {
|
||||
RedisURL string `json:"redis_url"`
|
||||
Prefix string `json:"prefix"`
|
||||
}
|
||||
|
||||
type WebserverConfig struct {
|
||||
Port int `json:"port"`
|
||||
BaseURL string `json:"base_url"`
|
||||
SessionStore string `json:"session_store"`
|
||||
RedisConfigInfo RedisConfig `json:"redis_config"`
|
||||
}
|
||||
|
||||
type EmailConfig struct {
|
||||
|
||||
+1
-1
@@ -232,7 +232,7 @@ func main() {
|
||||
if serverConfig.WebserverConfig.SessionStore == "in_memory" {
|
||||
sessionManager.SetStoreType(session.InMemory)
|
||||
} else if serverConfig.WebserverConfig.SessionStore == "redis" {
|
||||
sessionManager.SetStoreType(session.Redis)
|
||||
sessionManager.SetStoreType(session.Redis, serverConfig.WebserverConfig.RedisConfigInfo.RedisURL, serverConfig.WebserverConfig.RedisConfigInfo.Prefix)
|
||||
} else {
|
||||
logging.Warnf("'%s' is an unknown session store type defaulting to in memory", serverConfig.WebserverConfig.SessionStore)
|
||||
sessionManager.SetStoreType(session.InMemory)
|
||||
|
||||
@@ -33,7 +33,7 @@ func GetSessionManager() *SessionManager {
|
||||
return instance
|
||||
}
|
||||
|
||||
func (manager *SessionManager) SetStoreType(storeType StoreType) {
|
||||
func (manager *SessionManager) SetStoreType(storeType StoreType, params ...any) {
|
||||
logging.Infof("Changing session manager store type")
|
||||
switch storeType {
|
||||
case InMemory:
|
||||
@@ -47,7 +47,9 @@ func (manager *SessionManager) SetStoreType(storeType StoreType) {
|
||||
}
|
||||
case Redis:
|
||||
{
|
||||
manager.store = store.NewRedisStore[*SessionData]()
|
||||
url, _ := params[0].(string)
|
||||
prefix, _ := params[1].(string)
|
||||
manager.store = store.NewRedisStore[*SessionData](url, prefix)
|
||||
break
|
||||
}
|
||||
}
|
||||
|
||||
@@ -19,12 +19,9 @@ func (m *RedisStore[Value]) RedisHash(value_to_hash string) string {
|
||||
return m.prefix + HashKey(value_to_hash)
|
||||
}
|
||||
|
||||
func NewRedisStore[Value any]() *RedisStore[Value] {
|
||||
func NewRedisStore[Value any](redis_server string, prefix string) *RedisStore[Value] {
|
||||
logging.Debug("Creating new redis session store")
|
||||
|
||||
// this will be replaced with a URL that can be parsed in the config file
|
||||
redis_server := "redis://localhost:6379/0"
|
||||
|
||||
opts, err := redis.ParseURL(redis_server)
|
||||
if err != nil {
|
||||
logging.Errorf("Failed to parse redis url %s", err.Error())
|
||||
@@ -42,7 +39,7 @@ func NewRedisStore[Value any]() *RedisStore[Value] {
|
||||
store := &RedisStore[Value]{
|
||||
client: rdb,
|
||||
ctx: ctx,
|
||||
prefix: "random_string_1",
|
||||
prefix: prefix,
|
||||
}
|
||||
return store
|
||||
}
|
||||
|
||||
Reference in New Issue
Block a user