로그 제거
This commit is contained in:
@ -55,8 +55,6 @@ func (p *provider_redis) New(input *Authorization) (string, error) {
|
||||
}
|
||||
pk := storagekey_to_publickey(sk)
|
||||
|
||||
logger.Println("session provider new :", sk, pk)
|
||||
|
||||
return string(pk), err
|
||||
}
|
||||
|
||||
@ -69,7 +67,6 @@ func (p *provider_redis) Delete(account primitive.ObjectID) error {
|
||||
}
|
||||
|
||||
for _, sk := range sks {
|
||||
logger.Println("session provider delete :", sk)
|
||||
p.redisClient.Del(p.ctx, sk).Result()
|
||||
p.redisClient.Publish(p.ctx, p.deleteChannel, sk).Result()
|
||||
}
|
||||
@ -94,15 +91,12 @@ func (p *provider_redis) Query(pk string) (Authorization, error) {
|
||||
return Authorization{}, err
|
||||
}
|
||||
|
||||
logger.Println("session provider query :", pk, auth)
|
||||
|
||||
return auth, nil
|
||||
}
|
||||
|
||||
func (p *provider_redis) Touch(pk string) (bool, error) {
|
||||
sk := publickey_to_storagekey(publickey(pk))
|
||||
ok, err := p.redisClient.Expire(p.ctx, string(sk), p.ttl).Result()
|
||||
logger.Println("session provider touch :", pk)
|
||||
|
||||
if err == redis.Nil {
|
||||
// 이미 만료됨
|
||||
@ -112,7 +106,6 @@ func (p *provider_redis) Touch(pk string) (bool, error) {
|
||||
logger.Println("session consumer touch :", pk, err)
|
||||
return false, err
|
||||
}
|
||||
logger.Println("session consumer touch :", pk)
|
||||
|
||||
return ok, nil
|
||||
}
|
||||
@ -288,10 +281,8 @@ func (c *consumer_redis) Touch(pk string) (Authorization, error) {
|
||||
c.add_internal(sk, si)
|
||||
}
|
||||
|
||||
logger.Println("session consumer touch(ok) :", pk)
|
||||
return *si.Authorization, nil
|
||||
}
|
||||
|
||||
logger.Println("session consumer touch(!ok) :", pk)
|
||||
return Authorization{}, nil
|
||||
}
|
||||
|
||||
Reference in New Issue
Block a user