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 }