From 4f8c4358f80b52f62f3a0cce928aa3b104aeb874 Mon Sep 17 00:00:00 2001
From: Alexander Zavorotynskiy <alexander@openreplay.com>
Date: Tue, 7 Jun 2022 13:30:48 +0200
Subject: [PATCH] fix(backend/storage): fixed panic in storage service

---
 backend/internal/sink/assetscache/assets.go | 1 +
 backend/internal/storage/storage.go         | 5 +++++
 2 files changed, 6 insertions(+)

diff --git a/backend/internal/sink/assetscache/assets.go b/backend/internal/sink/assetscache/assets.go
index 97d3eddb9..1996819de 100644
--- a/backend/internal/sink/assetscache/assets.go
+++ b/backend/internal/sink/assetscache/assets.go
@@ -26,6 +26,7 @@ func (e *AssetsCache) ParseAssets(sessID uint64, msg messages.Message) messages.
 	switch m := msg.(type) {
 	case *messages.SetNodeAttributeURLBased:
 		if m.Name == "src" || m.Name == "href" {
+			log.Printf("accet for session: %d", sessID)
 			return &messages.SetNodeAttribute{
 				ID:    m.ID,
 				Name:  m.Name,
diff --git a/backend/internal/storage/storage.go b/backend/internal/storage/storage.go
index b48448117..8001279eb 100644
--- a/backend/internal/storage/storage.go
+++ b/backend/internal/storage/storage.go
@@ -40,12 +40,17 @@ func New(cfg *config.Config, s3 *storage.S3, metrics *monitoring.Metrics) (*Stor
 	if err != nil {
 		log.Printf("can't create session_size metric: %s", err)
 	}
+	archivingTime, err := metrics.RegisterHistogram("archiving_duration")
+	if err != nil {
+		log.Printf("can't create archiving_duration metric: %s", err)
+	}
 	return &Storage{
 		cfg:           cfg,
 		s3:            s3,
 		startBytes:    make([]byte, cfg.FileSplitSize),
 		totalSessions: totalSessions,
 		sessionSize:   sessionSize,
+		archivingTime: archivingTime,
 	}, nil
 }