jan/openreplay
1
0
Fork 0
Code Issues Pull requests Projects Releases Packages Wiki Activity Actions

feat(assist): project's cache fix

Browse source
This commit is contained in:
Alexander 2025-05-13 17:01:25 +02:00
parent 27f3ec5585
commit 33e2e8efb9
1 changed files with 5 additions and 4 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

9
backend/pkg/projects/cache.go
View file

@ -1,6 +1,7 @@
package projects package projects
import ( import (
"context"
"encoding/json" "encoding/json"
"fmt" "fmt"
"time" "time"
@ -40,10 +41,10 @@ func (c *cacheImpl) Set(project *Project) error {
if err != nil { if err != nil {
return err return err
} }
if _, err = c.db.Redis.Set(fmt.Sprintf("project:id:%d", project.ProjectID), projectBytes, time.Minute*10).Result(); err != nil { if _, err = c.db.Redis.Set(context.Background(), fmt.Sprintf("project:id:%d", project.ProjectID), projectBytes, time.Minute*10).Result(); err != nil {
return err return err
} }
if _, err = c.db.Redis.Set(fmt.Sprintf("project:key:%s", project.ProjectKey), projectBytes, time.Minute*10).Result(); err != nil { if _, err = c.db.Redis.Set(context.Background(), fmt.Sprintf("project:key:%s", project.ProjectKey), projectBytes, time.Minute*10).Result(); err != nil {
return err return err
} }
c.metrics.RecordRedisRequestDuration(float64(time.Now().Sub(start).Milliseconds()), "set", "project") c.metrics.RecordRedisRequestDuration(float64(time.Now().Sub(start).Milliseconds()), "set", "project")
@ -56,7 +57,7 @@ func (c *cacheImpl) GetByID(projectID uint32) (*Project, error) {
return nil, ErrDisabledCache return nil, ErrDisabledCache
} }
start := time.Now() start := time.Now()
result, err := c.db.Redis.Get(fmt.Sprintf("project:id:%d", projectID)).Result() result, err := c.db.Redis.Get(context.Background(), fmt.Sprintf("project:id:%d", projectID)).Result()
if err != nil { if err != nil {
return nil, err return nil, err
} }
@ -74,7 +75,7 @@ func (c *cacheImpl) GetByKey(projectKey string) (*Project, error) {
return nil, ErrDisabledCache return nil, ErrDisabledCache
} }
start := time.Now() start := time.Now()
result, err := c.db.Redis.Get(fmt.Sprintf("project:key:%s", projectKey)).Result() result, err := c.db.Redis.Get(context.Background(), fmt.Sprintf("project:key:%s", projectKey)).Result()
if err != nil { if err != nil {
return nil, err return nil, err
} }