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

feat(canvas): removed unnecessary log

Browse source
This commit is contained in:
Alexander 2025-02-17 15:21:37 +01:00
parent adb359b3bf
commit f1614b6626
2 changed files with 6 additions and 3 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

5
backend/cmd/canvas-handler/main.go
View file

@ -4,6 +4,7 @@ import (
"context" "context"
"os" "os"
"os/signal" "os/signal"
"strings"
"syscall" "syscall"
"time" "time"
@ -58,7 +59,9 @@ func main() {
if isSessionEnd(data) { if isSessionEnd(data) {
if err := srv.PackSessionCanvases(sessCtx, sessID); err != nil { if err := srv.PackSessionCanvases(sessCtx, sessID); err != nil {
log.Error(sessCtx, "can't pack session's canvases: %s", err) if !strings.Contains(err.Error(), "no such file or directory") {
log.Error(sessCtx, "can't pack session's canvases: %s", err)
}
} }
} else { } else {
if err := srv.SaveCanvasToDisk(sessCtx, sessID, data); err != nil { if err := srv.SaveCanvasToDisk(sessCtx, sessID, data); err != nil {

4
backend/internal/canvas-handler/service.go
View file

@ -80,7 +80,7 @@ func (v *ImageStorage) SaveCanvasToDisk(ctx context.Context, sessID uint64, data
func (v *ImageStorage) writeToDisk(payload interface{}) { func (v *ImageStorage) writeToDisk(payload interface{}) {
task := payload.(*saveTask) task := payload.(*saveTask)
path := fmt.Sprintf("%s/%d/", v.basePath, task.sessionID) path := fmt.Sprintf("%s%d/", v.basePath, task.sessionID)
// Ensure the directory exists // Ensure the directory exists
if err := os.MkdirAll(path, 0755); err != nil { if err := os.MkdirAll(path, 0755); err != nil {
@ -102,7 +102,7 @@ func (v *ImageStorage) writeToDisk(payload interface{}) {
} }
func (v *ImageStorage) PackSessionCanvases(ctx context.Context, sessID uint64) error { func (v *ImageStorage) PackSessionCanvases(ctx context.Context, sessID uint64) error {
path := fmt.Sprintf("%s/%d/", v.basePath, sessID) path := fmt.Sprintf("%s%d/", v.basePath, sessID)
// Check that the directory exists // Check that the directory exists
files, err := os.ReadDir(path) files, err := os.ReadDir(path)