Revert "Moving cli to scripts folder (#1196)"

This reverts commit c947e48d99.

.github/workflows/api-ee.yaml

@@ -10,6 +10,7 @@ on:
     branches:
       - dev
       - api-*
+      - v1.11.0-patch
     paths:
       - "ee/api/**"
       - "api/**"

.github/workflows/api.yaml

@@ -10,6 +10,7 @@ on:
     branches:
       - dev
       - api-*
+      - v1.11.0-patch
     paths:
       - "api/**"
       - "!api/.gitignore"

.github/workflows/crons-ee.yaml

@@ -10,6 +10,7 @@ on:
     branches:
       - dev
       - api-*
+      - v1.11.0-patch
     paths:
       - "ee/api/**"
       - "api/**"

api/chalicelib/core/health.py

@@ -14,9 +14,9 @@ def app_connection_string(name, port, path):
 
 
 HEALTH_ENDPOINTS = {
-    "alerts": app_connection_string("alerts-openreplay", 8888, "metrics"),
+    "alerts": app_connection_string("alerts-openreplay", 8888, "health"),
     "assets": app_connection_string("assets-openreplay", 8888, "metrics"),
-    "assist": app_connection_string("assist-openreplay", 8888, "metrics"),
+    "assist": app_connection_string("assist-openreplay", 8888, "health"),
     "chalice": app_connection_string("chalice-openreplay", 8888, "metrics"),
     "db": app_connection_string("db-openreplay", 8888, "metrics"),
     "ender": app_connection_string("ender-openreplay", 8888, "metrics"),

api/chalicelib/core/jobs.py

@@ -1,6 +1,6 @@
 from chalicelib.utils import pg_client, helper
 from chalicelib.utils.TimeUTC import TimeUTC
-from chalicelib.core import sessions, sessions_mobs
+from chalicelib.core import sessions_mobs, sessions_devtool
 
 
 class Actions:
@@ -17,11 +17,9 @@ class JobStatus:
 def get(job_id):
     with pg_client.PostgresClient() as cur:
         query = cur.mogrify(
-            """\
-            SELECT
-                *
-            FROM public.jobs
-            WHERE job_id = %(job_id)s;""",
+            """SELECT *
+               FROM public.jobs
+               WHERE job_id = %(job_id)s;""",
             {"job_id": job_id}
         )
         cur.execute(query=query)
@@ -37,11 +35,9 @@ def get(job_id):
 def get_all(project_id):
     with pg_client.PostgresClient() as cur:
         query = cur.mogrify(
-            """\
-            SELECT
-                *
-            FROM public.jobs
-            WHERE project_id = %(project_id)s;""",
+            """SELECT *
+               FROM public.jobs
+               WHERE project_id = %(project_id)s;""",
             {"project_id": project_id}
         )
         cur.execute(query=query)
@@ -51,23 +47,19 @@ def get_all(project_id):
     return helper.list_to_camel_case(data)
 
 
-def create(project_id, data):
+def create(project_id, user_id):
     with pg_client.PostgresClient() as cur:
-        job = {
-            "status": "scheduled",
-            "project_id": project_id,
-            **data
-        }
+        job = {"status": "scheduled",
+               "project_id": project_id,
+               "action": Actions.DELETE_USER_DATA,
+               "reference_id": user_id,
+               "description": f"Delete user sessions of userId = {user_id}",
+               "start_at": TimeUTC.to_human_readable(TimeUTC.midnight(1))}
 
-        query = cur.mogrify("""\
-            INSERT INTO public.jobs(
-                project_id, description, status, action,
-                reference_id, start_at
-            )
-            VALUES (
-                %(project_id)s, %(description)s, %(status)s, %(action)s,
-                %(reference_id)s, %(start_at)s
-            ) RETURNING *;""", job)
+        query = cur.mogrify(
+            """INSERT INTO public.jobs(project_id, description, status, action,reference_id, start_at)
+               VALUES (%(project_id)s, %(description)s, %(status)s, %(action)s,%(reference_id)s, %(start_at)s)
+               RETURNING *;""", job)
 
         cur.execute(query=query)
 
@@ -90,14 +82,13 @@ def update(job_id, job):
             **job
         }
 
-        query = cur.mogrify("""\
-            UPDATE public.jobs
-            SET
-                updated_at = timezone('utc'::text, now()),
-                status = %(status)s,
-                errors = %(errors)s
-            WHERE
-                job_id = %(job_id)s RETURNING *;""", job_data)
+        query = cur.mogrify(
+            """UPDATE public.jobs
+               SET updated_at = timezone('utc'::text, now()),
+                   status = %(status)s,
+                   errors = %(errors)s
+               WHERE job_id = %(job_id)s
+               RETURNING *;""", job_data)
 
         cur.execute(query=query)
 
@@ -113,61 +104,64 @@ def format_datetime(r):
     r["start_at"] = TimeUTC.datetime_to_timestamp(r["start_at"])
 
 
+def __get_session_ids_by_user_ids(project_id, user_ids):
+    with pg_client.PostgresClient() as cur:
+        query = cur.mogrify(
+            """SELECT session_id 
+               FROM public.sessions
+               WHERE project_id = %(project_id)s 
+                    AND user_id IN %(userId)s
+               LIMIT 1000;""",
+            {"project_id": project_id, "userId": tuple(user_ids)})
+        cur.execute(query=query)
+        ids = cur.fetchall()
+    return [s["session_id"] for s in ids]
+
+
+def __delete_sessions_by_session_ids(session_ids):
+    with pg_client.PostgresClient(unlimited_query=True) as cur:
+        query = cur.mogrify(
+            """DELETE FROM public.sessions
+               WHERE session_id IN %(session_ids)s""",
+            {"session_ids": tuple(session_ids)}
+        )
+        cur.execute(query=query)
+
+
 def get_scheduled_jobs():
     with pg_client.PostgresClient() as cur:
         query = cur.mogrify(
-            """\
-            SELECT * FROM public.jobs
-            WHERE status = %(status)s AND start_at <= (now() at time zone 'utc');""",
-            {"status": JobStatus.SCHEDULED}
-        )
+            """SELECT * 
+               FROM public.jobs
+               WHERE status = %(status)s 
+                    AND start_at <= (now() at time zone 'utc');""",
+            {"status": JobStatus.SCHEDULED})
         cur.execute(query=query)
         data = cur.fetchall()
-        for record in data:
-            format_datetime(record)
-
     return helper.list_to_camel_case(data)
 
 
 def execute_jobs():
     jobs = get_scheduled_jobs()
-    if len(jobs) == 0:
-        # No jobs to execute
-        return
-
     for job in jobs:
-        print(f"job can be executed {job['id']}")
+        print(f"Executing jobId:{job['jobId']}")
         try:
             if job["action"] == Actions.DELETE_USER_DATA:
-                session_ids = sessions.get_session_ids_by_user_ids(
-                    project_id=job["projectId"], user_ids=job["referenceId"]
-                )
-
-                sessions.delete_sessions_by_session_ids(session_ids)
-                sessions_mobs.delete_mobs(session_ids=session_ids, project_id=job["projectId"])
+                session_ids = __get_session_ids_by_user_ids(project_id=job["projectId"],
+                                                            user_ids=[job["referenceId"]])
+                if len(session_ids) > 0:
+                    print(f"Deleting {len(session_ids)} sessions")
+                    __delete_sessions_by_session_ids(session_ids)
+                    sessions_mobs.delete_mobs(session_ids=session_ids, project_id=job["projectId"])
+                    sessions_devtool.delete_mobs(session_ids=session_ids, project_id=job["projectId"])
             else:
-                raise Exception(f"The action {job['action']} not supported.")
+                raise Exception(f"The action '{job['action']}' not supported.")
 
             job["status"] = JobStatus.COMPLETED
-            print(f"job completed {job['id']}")
+            print(f"Job completed {job['jobId']}")
         except Exception as e:
             job["status"] = JobStatus.FAILED
-            job["error"] = str(e)
-            print(f"job failed {job['id']}")
+            job["errors"] = str(e)
+            print(f"Job failed {job['jobId']}")
 
-        update(job["job_id"], job)
-
-
-def group_user_ids_by_project_id(jobs, now):
-    project_id_user_ids = {}
-    for job in jobs:
-        if job["startAt"] > now:
-            continue
-
-        project_id = job["projectId"]
-        if project_id not in project_id_user_ids:
-            project_id_user_ids[project_id] = []
-
-        project_id_user_ids[project_id].append(job)
-
-    return project_id_user_ids
+        update(job["jobId"], job)

api/chalicelib/core/sessions.py

@@ -1065,47 +1065,6 @@ def get_session_user(project_id, user_id):
     return helper.dict_to_camel_case(data)
 
 
-def get_session_ids_by_user_ids(project_id, user_ids):
-    with pg_client.PostgresClient() as cur:
-        query = cur.mogrify(
-            """\
-            SELECT session_id FROM public.sessions
-            WHERE
-                project_id = %(project_id)s AND user_id IN %(userId)s;""",
-            {"project_id": project_id, "userId": tuple(user_ids)}
-        )
-        ids = cur.execute(query=query)
-    return ids
-
-
-def delete_sessions_by_session_ids(session_ids):
-    with pg_client.PostgresClient(unlimited_query=True) as cur:
-        query = cur.mogrify(
-            """\
-            DELETE FROM public.sessions
-            WHERE
-                session_id IN %(session_ids)s;""",
-            {"session_ids": tuple(session_ids)}
-        )
-        cur.execute(query=query)
-
-    return True
-
-
-def delete_sessions_by_user_ids(project_id, user_ids):
-    with pg_client.PostgresClient(unlimited_query=True) as cur:
-        query = cur.mogrify(
-            """\
-            DELETE FROM public.sessions
-            WHERE
-                project_id = %(project_id)s AND user_id IN %(userId)s;""",
-            {"project_id": project_id, "userId": tuple(user_ids)}
-        )
-        cur.execute(query=query)
-
-    return True
-
-
 def count_all():
     with pg_client.PostgresClient(unlimited_query=True) as cur:
         cur.execute(query="SELECT COUNT(session_id) AS count FROM public.sessions")

api/chalicelib/core/sessions_devtool.py

@@ -24,3 +24,9 @@ def get_urls(session_id, project_id, check_existence: bool = True):
             ExpiresIn=config("PRESIGNED_URL_EXPIRATION", cast=int, default=900)
         ))
     return results
+
+
+def delete_mobs(project_id, session_ids):
+    for session_id in session_ids:
+        for k in __get_devtools_keys(project_id=project_id, session_id=session_id):
+            s3.schedule_for_deletion(config("sessions_bucket"), k)

api/chalicelib/core/sessions_mobs.py

@@ -57,5 +57,6 @@ def get_ios(session_id):
 
 def delete_mobs(project_id, session_ids):
     for session_id in session_ids:
-        for k in __get_mob_keys(project_id=project_id, session_id=session_id):
+        for k in __get_mob_keys(project_id=project_id, session_id=session_id) \
+                 + __get_mob_keys_deprecated(session_id=session_id):
             s3.schedule_for_deletion(config("sessions_bucket"), k)

api/chalicelib/core/sessions_replay.py

@@ -69,9 +69,11 @@ def get_by_id2_pg(project_id, session_id, context: schemas.CurrentContext, full_
                                       if e['source'] == "js_exception"][:500]
                     data['userEvents'] = events.get_customs_by_session_id(project_id=project_id,
                                                                           session_id=session_id)
-                    data['domURL'] = sessions_mobs.get_urls(session_id=session_id, project_id=project_id)
-                    data['mobsUrl'] = sessions_mobs.get_urls_depercated(session_id=session_id)
-                    data['devtoolsURL'] = sessions_devtool.get_urls(session_id=session_id, project_id=project_id)
+                    data['domURL'] = sessions_mobs.get_urls(session_id=session_id, project_id=project_id,
+                                                            check_existence=False)
+                    data['mobsUrl'] = sessions_mobs.get_urls_depercated(session_id=session_id, check_existence=False)
+                    data['devtoolsURL'] = sessions_devtool.get_urls(session_id=session_id, project_id=project_id,
+                                                                    check_existence=False)
                     data['resources'] = resources.get_by_session_id(session_id=session_id, project_id=project_id,
                                                                     start_ts=data["startTs"], duration=data["duration"])
 
@@ -126,9 +128,11 @@ def get_replay(project_id, session_id, context: schemas.CurrentContext, full_dat
                 if data["platform"] == 'ios':
                     data['mobsUrl'] = sessions_mobs.get_ios(session_id=session_id)
                 else:
-                    data['domURL'] = sessions_mobs.get_urls(session_id=session_id, project_id=project_id)
-                    data['mobsUrl'] = sessions_mobs.get_urls_depercated(session_id=session_id)
-                    data['devtoolsURL'] = sessions_devtool.get_urls(session_id=session_id, project_id=project_id)
+                    data['domURL'] = sessions_mobs.get_urls(session_id=session_id, project_id=project_id,
+                                                            check_existence=False)
+                    data['mobsUrl'] = sessions_mobs.get_urls_depercated(session_id=session_id, check_existence=False)
+                    data['devtoolsURL'] = sessions_devtool.get_urls(session_id=session_id, project_id=project_id,
+                                                                    check_existence=False)
 
                 data['metadata'] = __group_metadata(project_metadata=data.pop("projectMetadata"), session=data)
                 data['live'] = live and assist.is_live(project_id=project_id, session_id=session_id,

api/chalicelib/utils/s3.py

@@ -110,11 +110,14 @@ def rename(source_bucket, source_key, target_bucket, target_key):
 
 
 def schedule_for_deletion(bucket, key):
+    if not exists(bucket, key):
+        return False
     s3 = __get_s3_resource()
     s3_object = s3.Object(bucket, key)
     s3_object.copy_from(CopySource={'Bucket': bucket, 'Key': key},
-                        Expires=datetime.now() + timedelta(days=7),
+                        Expires=datetime.utcnow() + timedelta(days=config("SCH_DELETE_DAYS", cast=int, default=30)),
                         MetadataDirective='REPLACE')
+    return True
 
 
 def generate_file_key(project_id, key):

api/env.default

@@ -53,4 +53,5 @@ PRESIGNED_URL_EXPIRATION=3600
 ASSIST_JWT_EXPIRATION=144000
 ASSIST_JWT_SECRET=
 PYTHONUNBUFFERED=1
-REDIS_STRING=redis://redis-master.db.svc.cluster.local:6379
+REDIS_STRING=redis://redis-master.db.svc.cluster.local:6379
+SCH_DELETE_DAYS=30

api/routers/crons/core_dynamic_crons.py

@@ -1,5 +1,4 @@
 from apscheduler.triggers.cron import CronTrigger
-from apscheduler.triggers.interval import IntervalTrigger
 
 from chalicelib.core import telemetry
 from chalicelib.core import weekly_report, jobs
@@ -20,7 +19,7 @@ async def telemetry_cron() -> None:
 cron_jobs = [
     {"func": telemetry_cron, "trigger": CronTrigger(day_of_week="*"),
      "misfire_grace_time": 60 * 60, "max_instances": 1},
-    {"func": run_scheduled_jobs, "trigger": IntervalTrigger(minutes=1),
+    {"func": run_scheduled_jobs, "trigger": CronTrigger(day_of_week="*", hour=0, minute=15),
      "misfire_grace_time": 20, "max_instances": 1},
     {"func": weekly_report2, "trigger": CronTrigger(day_of_week="mon", hour=5),
      "misfire_grace_time": 60 * 60, "max_instances": 1}

api/routers/subs/v1_api.py

@@ -2,7 +2,6 @@ from fastapi import Depends, Body
 
 import schemas
 from chalicelib.core import sessions, events, jobs, projects
-from chalicelib.utils.TimeUTC import TimeUTC
 from or_dependencies import OR_context
 from routers.base import get_routers
 
@@ -15,7 +14,7 @@ async def get_user_sessions(projectKey: str, userId: str, start_date: int = None
     if projectId is None:
         return {"errors": ["invalid projectKey"]}
     return {
-        'data': sessions.get_user_sessions(
+        "data": sessions.get_user_sessions(
             project_id=projectId,
             user_id=userId,
             start_date=start_date,
@@ -30,7 +29,7 @@ async def get_session_events(projectKey: str, sessionId: int):
     if projectId is None:
         return {"errors": ["invalid projectKey"]}
     return {
-        'data': events.get_by_session_id(
+        "data": events.get_by_session_id(
             project_id=projectId,
             session_id=sessionId
         )
@@ -43,7 +42,7 @@ async def get_user_details(projectKey: str, userId: str):
     if projectId is None:
         return {"errors": ["invalid projectKey"]}
     return {
-        'data': sessions.get_session_user(
+        "data": sessions.get_session_user(
             project_id=projectId,
             user_id=userId
         )
@@ -55,14 +54,8 @@ async def schedule_to_delete_user_data(projectKey: str, userId: str):
     projectId = projects.get_internal_project_id(projectKey)
     if projectId is None:
         return {"errors": ["invalid projectKey"]}
-    data = {"action": "delete_user_data",
-            "reference_id": userId,
-            "description": f"Delete user sessions of userId = {userId}",
-            "start_at": TimeUTC.to_human_readable(TimeUTC.midnight(1))}
-    record = jobs.create(project_id=projectId, data=data)
-    return {
-        'data': record
-    }
+    record = jobs.create(project_id=projectId, user_id=userId)
+    return {"data": record}
 
 
 @app_apikey.get('/v1/{projectKey}/jobs', tags=["api"])
@@ -70,16 +63,12 @@ async def get_jobs(projectKey: str):
     projectId = projects.get_internal_project_id(projectKey)
     if projectId is None:
         return {"errors": ["invalid projectKey"]}
-    return {
-        'data': jobs.get_all(project_id=projectId)
-    }
+    return {"data": jobs.get_all(project_id=projectId)}
 
 
 @app_apikey.get('/v1/{projectKey}/jobs/{jobId}', tags=["api"])
 async def get_job(projectKey: str, jobId: int):
-    return {
-        'data': jobs.get(job_id=jobId)
-    }
+    return {"data": jobs.get(job_id=jobId)}
 
 
 @app_apikey.delete('/v1/{projectKey}/jobs/{jobId}', tags=["api"])
@@ -93,9 +82,7 @@ async def cancel_job(projectKey: str, jobId: int):
         return {"errors": ["The request job has already been canceled/completed."]}
 
     job["status"] = "cancelled"
-    return {
-        'data': jobs.update(job_id=jobId, job=job)
-    }
+    return {"data": jobs.update(job_id=jobId, job=job)}
 
 
 @app_apikey.get('/v1/projects', tags=["api"])
@@ -104,15 +91,13 @@ async def get_projects(context: schemas.CurrentContext = Depends(OR_context)):
     for record in records:
         del record['projectId']
 
-    return {
-        'data': records
-    }
+    return {"data": records}
 
 
 @app_apikey.get('/v1/projects/{projectKey}', tags=["api"])
 async def get_project(projectKey: str, context: schemas.CurrentContext = Depends(OR_context)):
     return {
-        'data': projects.get_project_by_key(tenant_id=context.tenant_id, project_key=projectKey)
+        "data": projects.get_project_by_key(tenant_id=context.tenant_id, project_key=projectKey)
     }
 
 
@@ -125,5 +110,5 @@ async def create_project(data: schemas.CreateProjectSchema = Body(...),
         data=data,
         skip_authorization=True
     )
-    del record['data']['projectId']
+    del record["data"]['projectId']
     return record

backend/Dockerfile

@@ -84,7 +84,8 @@ ENV TZ=UTC \
     CH_PASSWORD="" \
     CH_DATABASE="default" \
     # Max file size to process, default to 100MB
-    MAX_FILE_SIZE=100000000
+    MAX_FILE_SIZE=100000000 \
+    USE_ENCRYPTION=false
 
 
 RUN if [ "$SERVICE_NAME" = "http" ]; then \

backend/internal/storage/storage.go

@@ -33,10 +33,28 @@ func (t FileType) String() string {
 }
 
 type Task struct {
-	id   string
-	doms *bytes.Buffer
-	dome *bytes.Buffer
-	dev  *bytes.Buffer
+	id     string
+	key    string
+	domRaw []byte
+	devRaw []byte
+	doms   *bytes.Buffer
+	dome   *bytes.Buffer
+	dev    *bytes.Buffer
+}
+
+func (t *Task) SetMob(mob []byte, tp FileType) {
+	if tp == DOM {
+		t.domRaw = mob
+	} else {
+		t.devRaw = mob
+	}
+}
+
+func (t *Task) Mob(tp FileType) []byte {
+	if tp == DOM {
+		return t.domRaw
+	}
+	return t.devRaw
 }
 
 type Storage struct {
@@ -75,7 +93,8 @@ func (s *Storage) Upload(msg *messages.SessionEnd) (err error) {
 	filePath := s.cfg.FSDir + "/" + sessionID
 	// Prepare sessions
 	newTask := &Task{
-		id: sessionID,
+		id:  sessionID,
+		key: msg.EncryptionKey,
 	}
 	wg := &sync.WaitGroup{}
 	wg.Add(2)
@@ -108,6 +127,9 @@ func (s *Storage) Upload(msg *messages.SessionEnd) (err error) {
 }
 
 func (s *Storage) openSession(filePath string, tp FileType) ([]byte, error) {
+	if tp == DEV {
+		filePath += "devtools"
+	}
 	// Check file size before download into memory
 	info, err := os.Stat(filePath)
 	if err == nil && info.Size() > s.cfg.MaxFileSize {
@@ -142,51 +164,87 @@ func (s *Storage) sortSessionMessages(raw []byte) ([]byte, error) {
 }
 
 func (s *Storage) prepareSession(path string, tp FileType, task *Task) error {
-	// Open mob file
-	if tp == DEV {
-		path += "devtools"
-	}
+	// Open session file
 	startRead := time.Now()
 	mob, err := s.openSession(path, tp)
 	if err != nil {
 		return err
 	}
-	metrics.RecordSessionSize(float64(len(mob)), tp.String())
 	metrics.RecordSessionReadDuration(float64(time.Now().Sub(startRead).Milliseconds()), tp.String())
+	metrics.RecordSessionSize(float64(len(mob)), tp.String())
 
-	// Encode and compress session
-	if tp == DEV {
-		start := time.Now()
-		task.dev = s.compressSession(mob)
-		metrics.RecordSessionCompressDuration(float64(time.Now().Sub(start).Milliseconds()), tp.String())
-	} else {
-		if len(mob) <= s.cfg.FileSplitSize {
-			start := time.Now()
-			task.doms = s.compressSession(mob)
-			metrics.RecordSessionCompressDuration(float64(time.Now().Sub(start).Milliseconds()), tp.String())
-			return nil
-		}
-		wg := &sync.WaitGroup{}
-		wg.Add(2)
-		var firstPart, secondPart int64
-		go func() {
-			start := time.Now()
-			task.doms = s.compressSession(mob[:s.cfg.FileSplitSize])
-			firstPart = time.Now().Sub(start).Milliseconds()
-			wg.Done()
-		}()
-		go func() {
-			start := time.Now()
-			task.dome = s.compressSession(mob[s.cfg.FileSplitSize:])
-			secondPart = time.Now().Sub(start).Milliseconds()
-			wg.Done()
-		}()
-		wg.Wait()
-		metrics.RecordSessionCompressDuration(float64(firstPart+secondPart), tp.String())
-	}
+	// Put opened session file into task struct
+	task.SetMob(mob, tp)
+
+	// Encrypt and compress session
+	s.packSession(task, tp)
 	return nil
 }
 
+func (s *Storage) packSession(task *Task, tp FileType) {
+	// Prepare mob file
+	mob := task.Mob(tp)
+
+	if tp == DEV || len(mob) <= s.cfg.FileSplitSize {
+		// Encryption
+		start := time.Now()
+		data := s.encryptSession(mob, task.key)
+		metrics.RecordSessionEncryptionDuration(float64(time.Now().Sub(start).Milliseconds()), tp.String())
+		// Compression
+		start = time.Now()
+		result := s.compressSession(data)
+		metrics.RecordSessionCompressDuration(float64(time.Now().Sub(start).Milliseconds()), tp.String())
+
+		if tp == DOM {
+			task.doms = result
+		} else {
+			task.dev = result
+		}
+		return
+	}
+
+	// Prepare two workers
+	wg := &sync.WaitGroup{}
+	wg.Add(2)
+	var firstPart, secondPart, firstEncrypt, secondEncrypt int64
+
+	// DomStart part
+	go func() {
+		// Encryption
+		start := time.Now()
+		data := s.encryptSession(mob[:s.cfg.FileSplitSize], task.key)
+		firstEncrypt = time.Since(start).Milliseconds()
+
+		// Compression
+		start = time.Now()
+		task.doms = s.compressSession(data)
+		firstPart = time.Since(start).Milliseconds()
+
+		// Finish task
+		wg.Done()
+	}()
+	// DomEnd part
+	go func() {
+		// Encryption
+		start := time.Now()
+		data := s.encryptSession(mob[s.cfg.FileSplitSize:], task.key)
+		secondEncrypt = time.Since(start).Milliseconds()
+
+		// Compression
+		start = time.Now()
+		task.dome = s.compressSession(data)
+		secondPart = time.Since(start).Milliseconds()
+
+		// Finish task
+		wg.Done()
+	}()
+	wg.Wait()
+
+	// Record metrics
+	metrics.RecordSessionEncryptionDuration(float64(firstEncrypt+secondEncrypt), tp.String())
+	metrics.RecordSessionCompressDuration(float64(firstPart+secondPart), tp.String())
+}
+
 func (s *Storage) encryptSession(data []byte, encryptionKey string) []byte {
 	var encryptedData []byte
 	var err error

backend/pkg/metrics/storage/metrics.go

@@ -85,18 +85,18 @@ func RecordSessionSortDuration(durMillis float64, fileType string) {
 	storageSessionSortDuration.WithLabelValues(fileType).Observe(durMillis / 1000.0)
 }
 
-var storageSessionEncodeDuration = prometheus.NewHistogramVec(
+var storageSessionEncryptionDuration = prometheus.NewHistogramVec(
 	prometheus.HistogramOpts{
 		Namespace: "storage",
-		Name:      "encode_duration_seconds",
+		Name:      "encryption_duration_seconds",
 		Help:      "A histogram displaying the duration of encoding for each session in seconds.",
 		Buckets:   common.DefaultDurationBuckets,
 	},
 	[]string{"file_type"},
 )
 
-func RecordSessionEncodeDuration(durMillis float64, fileType string) {
-	storageSessionEncodeDuration.WithLabelValues(fileType).Observe(durMillis / 1000.0)
+func RecordSessionEncryptionDuration(durMillis float64, fileType string) {
+	storageSessionEncryptionDuration.WithLabelValues(fileType).Observe(durMillis / 1000.0)
 }
 
 var storageSessionCompressDuration = prometheus.NewHistogramVec(
@@ -133,7 +133,7 @@ func List() []prometheus.Collector {
 		storageTotalSessions,
 		storageSessionReadDuration,
 		storageSessionSortDuration,
-		storageSessionEncodeDuration,
+		storageSessionEncryptionDuration,
 		storageSessionCompressDuration,
 		storageSessionUploadDuration,
 	}

ee/api/chalicelib/core/assist_records.py

@@ -41,9 +41,13 @@ def save_record(project_id, data: schemas_ee.AssistRecordSavePayloadSchema, cont
 def search_records(project_id, data: schemas_ee.AssistRecordSearchPayloadSchema, context: schemas_ee.CurrentContext):
     conditions = ["projects.tenant_id=%(tenant_id)s",
                   "projects.deleted_at ISNULL",
-                  "assist_records.created_at>=%(startDate)s",
-                  "assist_records.created_at<=%(endDate)s",
+                  "projects.project_id=%(project_id)s",
                   "assist_records.deleted_at ISNULL"]
+    if data.startDate:
+        conditions.append("assist_records.created_at>=%(startDate)s")
+    if data.endDate:
+        conditions.append("assist_records.created_at<=%(endDate)s")
+
     params = {"tenant_id": context.tenant_id, "project_id": project_id,
               "startDate": data.startDate, "endDate": data.endDate,
               "p_start": (data.page - 1) * data.limit, "p_limit": data.limit,

ee/api/chalicelib/core/health.py

@@ -15,9 +15,9 @@ def app_connection_string(name, port, path):
 
 
 HEALTH_ENDPOINTS = {
-    "alerts": app_connection_string("alerts-openreplay", 8888, "metrics"),
+    "alerts": app_connection_string("alerts-openreplay", 8888, "health"),
     "assets": app_connection_string("assets-openreplay", 8888, "metrics"),
-    "assist": app_connection_string("assist-openreplay", 8888, "metrics"),
+    "assist": app_connection_string("assist-openreplay", 8888, "health"),
     "chalice": app_connection_string("chalice-openreplay", 8888, "metrics"),
     "db": app_connection_string("db-openreplay", 8888, "metrics"),
     "ender": app_connection_string("ender-openreplay", 8888, "metrics"),

ee/api/chalicelib/core/sessions_devtool.py

@@ -31,3 +31,9 @@ def get_urls(session_id, project_id, context: schemas_ee.CurrentContext, check_e
             ExpiresIn=config("PRESIGNED_URL_EXPIRATION", cast=int, default=900)
         ))
     return results
+
+
+def delete_mobs(project_id, session_ids):
+    for session_id in session_ids:
+        for k in __get_devtools_keys(project_id=project_id, session_id=session_id):
+            s3.schedule_for_deletion(config("sessions_bucket"), k)

ee/api/chalicelib/core/sessions_exp.py

@@ -1396,47 +1396,6 @@ def get_session_user(project_id, user_id):
     return helper.dict_to_camel_case(data)
 
 
-def get_session_ids_by_user_ids(project_id, user_ids):
-    with pg_client.PostgresClient() as cur:
-        query = cur.mogrify(
-            """\
-            SELECT session_id FROM public.sessions
-            WHERE
-                project_id = %(project_id)s AND user_id IN %(userId)s;""",
-            {"project_id": project_id, "userId": tuple(user_ids)}
-        )
-        ids = cur.execute(query=query)
-    return ids
-
-
-def delete_sessions_by_session_ids(session_ids):
-    with pg_client.PostgresClient(unlimited_query=True) as cur:
-        query = cur.mogrify(
-            """\
-            DELETE FROM public.sessions
-            WHERE
-                session_id IN %(session_ids)s;""",
-            {"session_ids": tuple(session_ids)}
-        )
-        cur.execute(query=query)
-
-    return True
-
-
-def delete_sessions_by_user_ids(project_id, user_ids):
-    with pg_client.PostgresClient(unlimited_query=True) as cur:
-        query = cur.mogrify(
-            """\
-            DELETE FROM public.sessions
-            WHERE
-                project_id = %(project_id)s AND user_id IN %(userId)s;""",
-            {"project_id": project_id, "userId": tuple(user_ids)}
-        )
-        cur.execute(query=query)
-
-    return True
-
-
 def count_all():
     with ch_client.ClickHouseClient() as cur:
         row = cur.execute(query=f"SELECT COUNT(session_id) AS count FROM {exp_ch_helper.get_main_sessions_table()}")

ee/api/chalicelib/core/sessions_replay.py

@@ -72,10 +72,11 @@ def get_by_id2_pg(project_id, session_id, context: schemas_ee.CurrentContext, fu
                                       if e['source'] == "js_exception"][:500]
                     data['userEvents'] = events.get_customs_by_session_id(project_id=project_id,
                                                                           session_id=session_id)
-                    data['domURL'] = sessions_mobs.get_urls(session_id=session_id, project_id=project_id)
-                    data['mobsUrl'] = sessions_mobs.get_urls_depercated(session_id=session_id)
+                    data['domURL'] = sessions_mobs.get_urls(session_id=session_id, project_id=project_id,
+                                                            check_existence=False)
+                    data['mobsUrl'] = sessions_mobs.get_urls_depercated(session_id=session_id, check_existence=False)
                     data['devtoolsURL'] = sessions_devtool.get_urls(session_id=session_id, project_id=project_id,
-                                                                    context=context)
+                                                                    context=context, check_existence=False)
                     data['resources'] = resources.get_by_session_id(session_id=session_id, project_id=project_id,
                                                                     start_ts=data["startTs"], duration=data["duration"])
 
@@ -132,10 +133,11 @@ def get_replay(project_id, session_id, context: schemas.CurrentContext, full_dat
                 if data["platform"] == 'ios':
                     data['mobsUrl'] = sessions_mobs.get_ios(session_id=session_id)
                 else:
-                    data['domURL'] = sessions_mobs.get_urls(session_id=session_id, project_id=project_id)
-                    data['mobsUrl'] = sessions_mobs.get_urls_depercated(session_id=session_id)
+                    data['domURL'] = sessions_mobs.get_urls(session_id=session_id, project_id=project_id,
+                                                            check_existence=False)
+                    data['mobsUrl'] = sessions_mobs.get_urls_depercated(session_id=session_id, check_existence=False)
                     data['devtoolsURL'] = sessions_devtool.get_urls(session_id=session_id, project_id=project_id,
-                                                                    context=context)
+                                                                    context=context, check_existence=False)
 
                 data['metadata'] = __group_metadata(project_metadata=data.pop("projectMetadata"), session=data)
                 data['live'] = live and assist.is_live(project_id=project_id, session_id=session_id,

ee/api/env.default

@@ -73,4 +73,5 @@ PRESIGNED_URL_EXPIRATION=3600
 ASSIST_JWT_EXPIRATION=144000
 ASSIST_JWT_SECRET=
 KAFKA_SERVERS=kafka.db.svc.cluster.local:9092
-KAFKA_USE_SSL=false
+KAFKA_USE_SSL=false
+SCH_DELETE_DAYS=30

ee/api/requirements-crons.txt

@@ -7,7 +7,7 @@ elasticsearch==8.6.2
 jira==3.5.0
 
 
-
+python-decouple==3.8
 apscheduler==3.10.1
 
 clickhouse-driver==0.2.5

ee/api/routers/crons/core_dynamic_crons.py

@@ -1,5 +1,4 @@
 from apscheduler.triggers.cron import CronTrigger
-from apscheduler.triggers.interval import IntervalTrigger
 from decouple import config
 
 from chalicelib.core import jobs
@@ -29,13 +28,14 @@ cron_jobs = [
     {"func": unlock_cron, "trigger": CronTrigger(day="*")},
 ]
 
-SINGLE_CRONS = [{"func": telemetry_cron, "trigger": CronTrigger(day_of_week="*"),
-                 "misfire_grace_time": 60 * 60, "max_instances": 1},
-                {"func": run_scheduled_jobs, "trigger": IntervalTrigger(minutes=60),
-                 "misfire_grace_time": 20, "max_instances": 1},
-                {"func": weekly_report, "trigger": CronTrigger(day_of_week="mon", hour=5),
-                 "misfire_grace_time": 60 * 60, "max_instances": 1}
-                ]
+SINGLE_CRONS = [
+    {"func": telemetry_cron, "trigger": CronTrigger(day_of_week="*"),
+     "misfire_grace_time": 60 * 60, "max_instances": 1},
+    {"func": run_scheduled_jobs, "trigger": CronTrigger(day_of_week="*", hour=0, minute=15),
+     "misfire_grace_time": 20, "max_instances": 1},
+    {"func": weekly_report, "trigger": CronTrigger(day_of_week="mon", hour=5),
+     "misfire_grace_time": 60 * 60, "max_instances": 1}
+]
 
 if config("LOCAL_CRONS", default=False, cast=bool):
     cron_jobs += SINGLE_CRONS

ee/api/schemas_ee.py

@@ -137,8 +137,8 @@ class AssistRecordSavePayloadSchema(AssistRecordPayloadSchema):
 
 class AssistRecordSearchPayloadSchema(schemas._PaginatedSchema):
     limit: int = Field(default=200, gt=0)
-    startDate: int = Field(default=TimeUTC.now(-7))
-    endDate: int = Field(default=TimeUTC.now(1))
+    startDate: Optional[int] = Field(default=None)
+    endDate: Optional[int] = Field(default=None)
     user_id: Optional[int] = Field(default=None)
     query: Optional[str] = Field(default=None)
     order: Literal["asc", "desc"] = Field(default="desc")

frontend/.env.sample

@@ -22,5 +22,5 @@ MINIO_ACCESS_KEY = ''
 MINIO_SECRET_KEY = ''
 
 # APP and TRACKER VERSIONS
-VERSION = '1.11.0'
-TRACKER_VERSION = '6.0.0'
+VERSION = 1.11.13
+TRACKER_VERSION = '6.0.1'

frontend/app/api_middleware.js

@@ -13,9 +13,9 @@ export default () => (next) => (action) => {
 
   return call(client)
     .then(async (response) => {
-      if (response.status === 403) {
-        next({ type: FETCH_ACCOUNT.FAILURE });
-      }
+      // if (response.status === 403) {
+      //   next({ type: FETCH_ACCOUNT.FAILURE });
+      // }
       if (!response.ok) {
         const text = await response.text();
         return Promise.reject(text);
@@ -34,6 +34,10 @@ export default () => (next) => (action) => {
       }
     })
     .catch(async (e) => {
+      if (e.response?.status === 403) {
+        next({ type: FETCH_ACCOUNT.FAILURE });
+      }
+
       const data = await e.response?.json();
       logger.error('Error during API request. ', e);
       return next({ type: FAILURE, errors: data ? parseError(data.errors) : [] });

frontend/app/components/Assist/components/AssistTabs/AssistTabs.tsx

@@ -1,37 +1,29 @@
 import { useModal } from 'App/components/Modal';
-import React, { useState } from 'react';
+import React from 'react';
 import SessionList from '../SessionList';
-import stl from './assistTabs.module.css'
+import stl from './assistTabs.module.css';
 
 interface Props {
-  userId: any,
-  userNumericHash: any,
+  userId: any;
 }
 
 const AssistTabs = (props: Props) => {
-  const [showMenu, setShowMenu] = useState(false)
   const { showModal } = useModal();
 
   return (
     <div className="relative mr-4">
       <div className="flex items-center">
         {props.userId && (
-          <>
-            <div
-              className={stl.btnLink}
-              onClick={() => showModal(<SessionList userId={props.userId} />, { right: true, width: 700 })}
-            >
-              Active Sessions
-            </div>
-          </>
+          <div
+            className={stl.btnLink}
+            onClick={() =>
+              showModal(<SessionList userId={props.userId} />, { right: true, width: 700 })
+            }
+          >
+            Active Sessions
+          </div>
         )}
       </div>
-      {/* <SlideModal
-        title={ <div>{props.userId}'s <span className="color-gray-medium">Live Sessions</span> </div> }
-        isDisplayed={ showMenu }
-        content={ showMenu && <SessionList /> }
-        onClose={ () => setShowMenu(false) }
-      /> */}
     </div>
   );
 };

frontend/app/components/Assist/components/SessionList/SessionList.tsx

@@ -46,7 +46,7 @@ function SessionList(props: Props) {
                 >
                     <div className="p-4">
                         {props.list.map((session: any) => (
-                            <div className="mb-6">
+                            <div className="mb-6" key={session.sessionId}>
                                 {session.pageTitle && session.pageTitle !== '' && (
                                     <div className="flex items-center mb-2">
                                         <Label size="small" className="p-1">
@@ -55,7 +55,7 @@ function SessionList(props: Props) {
                                         <span className="ml-2 font-medium">{session.pageTitle}</span>
                                     </div>
                                 )}
-                                <SessionItem compact={true} onClick={() => hideModal()} key={session.sessionId} session={session} />
+                                <SessionItem compact={true} onClick={hideModal} session={session} />
                             </div>
                         ))}
                     </div>

frontend/app/components/Session/IOSPlayer/Performance.js

@@ -44,7 +44,7 @@ export default observer(({ player }) => {
 	      <Performance 
 					performanceChartTime={ current ? current.tmie : 0 }
 				  performanceChartData={ player.lists[PERFORMANCE].list }
-				  avaliability={ player.lists[PERFORMANCE].availability }
+				  availability={ player.lists[PERFORMANCE].availability }
 				  hiddenScreenMarker={ false }
 				  player={ player }
 				/>

frontend/app/components/Session/Layout/ToolPanel/Performance.tsx

@@ -220,12 +220,12 @@ export default class Performance extends React.PureComponent {
   render() {
     const { 
       performanceChartTime,
-      avaliability = {},
+      availability = {},
       hiddenScreenMarker = true,
     } = this.props;
-    const { fps, cpu, heap, nodes, memory, battery } = avaliability;
-    const avaliableCount = [ fps, cpu, heap, nodes, memory, battery ].reduce((c, av) => av ? c + 1 : c, 0);
-    const height = avaliableCount === 0 ? "0" : `${100 / avaliableCount}%`;
+    const { fps, cpu, heap, nodes, memory, battery } = availability;
+    const availableCount = [ fps, cpu, heap, nodes, memory, battery ].reduce((c, av) => av ? c + 1 : c, 0);
+    const height = availableCount === 0 ? "0" : `${100 / availableCount}%`;
 
     return (
       <>

frontend/app/components/Session/LivePlayer.tsx

@@ -71,12 +71,13 @@ function LivePlayer({
 
     return () => {
       if (!location.pathname.includes('multiview') || !location.pathname.includes(usedSession.sessionId)) {
+        console.debug('unmount', usedSession.sessionId)
         playerInst?.clean?.();
         // @ts-ignore default empty
         setContextValue(defaultContextValue)
       }
     }
-  }, [location.pathname]);
+  }, [location.pathname, usedSession.sessionId]);
 
   // LAYOUT (TODO: local layout state - useContext or something..)
   useEffect(() => {

frontend/app/components/Session/Player/LivePlayer/LivePlayerBlockHeader.tsx

@@ -46,7 +46,7 @@ function LivePlayerBlockHeader(props: any) {
     history.push(withSiteId(ASSIST_ROUTE, siteId));
   };
 
-  const { userId, userNumericHash, metadata, isCallActive, agentIds } = session;
+  const { userId, metadata, isCallActive, agentIds } = session;
   let _metaList = Object.keys(metadata)
     .filter((i) => metaList.includes(i))
     .map((key) => {
@@ -87,7 +87,7 @@ function LivePlayerBlockHeader(props: any) {
           </div>
         )}
         <UserCard className="" width={width} height={height} />
-        <AssistTabs userId={userId} userNumericHash={userNumericHash} />
+        <AssistTabs userId={userId} />
 
         <div className={cn('ml-auto flex items-center h-full', { hidden: closedLive })}>
           {_metaList.length > 0 && (

frontend/app/components/Session/WebPlayer.tsx

@@ -13,6 +13,7 @@ import PlayerContent from './Player/ReplayPlayer/PlayerContent';
 import { IPlayerContext, PlayerContext, defaultContextValue } from './playerContext';
 import { observer } from 'mobx-react-lite';
 import { Note } from "App/services/NotesService";
+import { useParams } from 'react-router-dom'
 
 const TABS = {
   EVENTS: 'User Steps',
@@ -35,6 +36,7 @@ function WebPlayer(props: any) {
   // @ts-ignore
   const [contextValue, setContextValue] = useState<IPlayerContext>(defaultContextValue);
   let playerInst: IPlayerContext['player'];
+  const params: { sessionId: string } = useParams()
 
   useEffect(() => {
     if (!session.sessionId || contextValue.player !== undefined) return;
@@ -91,13 +93,14 @@ function WebPlayer(props: any) {
   // LAYOUT (TODO: local layout state - useContext or something..)
   useEffect(
     () => () => {
+      console.debug('cleaning up player after', params.sessionId)
       toggleFullscreen(false);
       closeBottomBlock();
       playerInst?.clean();
       // @ts-ignore
       setContextValue(defaultContextValue);
     },
-    []
+    [params.sessionId]
   );
 
   const onNoteClose = () => {

frontend/app/components/Session_/Performance/Performance.tsx

@@ -187,7 +187,7 @@ function Performance({
     performanceChartData,
     connType,
     connBandwidth,
-    performanceAvaliability: avaliability,
+    performanceAvailability: availability,
   } = store.get();
 
   React.useState(() => {
@@ -212,9 +212,9 @@ function Performance({
     }
   };
 
-  const { fps, cpu, heap, nodes } = avaliability;
-  const avaliableCount = [fps, cpu, heap, nodes].reduce((c, av) => (av ? c + 1 : c), 0);
-  const height = avaliableCount === 0 ? '0' : `${100 / avaliableCount}%`;
+  const { fps, cpu, heap, nodes } = availability;
+  const availableCount = [fps, cpu, heap, nodes].reduce((c, av) => (av ? c + 1 : c), 0);
+  const height = availableCount === 0 ? '0' : `${100 / availableCount}%`;
 
   return (
     <BottomBlock>

frontend/app/components/shared/SessionItem/SessionItem.tsx

@@ -55,6 +55,7 @@ interface Props {
   compact?: boolean;
   isDisabled?: boolean;
   isAdd?: boolean;
+  ignoreAssist?: boolean;
 }
 
 function SessionItem(props: RouteComponentProps & Props) {
@@ -70,6 +71,7 @@ function SessionItem(props: RouteComponentProps & Props) {
     lastPlayedSessionId,
     onClick = null,
     compact = false,
+    ignoreAssist = false,
   } = props;
 
   const {
@@ -99,9 +101,10 @@ function SessionItem(props: RouteComponentProps & Props) {
   const hasUserId = userId || userAnonymousId;
   const isSessions = isRoute(SESSIONS_ROUTE, location.pathname);
   const isAssist =
-    isRoute(ASSIST_ROUTE, location.pathname) ||
-    isRoute(ASSIST_LIVE_SESSION, location.pathname) ||
-    location.pathname.includes('multiview');
+    !ignoreAssist &&
+    (isRoute(ASSIST_ROUTE, location.pathname) ||
+      isRoute(ASSIST_LIVE_SESSION, location.pathname) ||
+      location.pathname.includes('multiview'));
   const isLastPlayed = lastPlayedSessionId === sessionId;
 
   const _metaList = Object.keys(metadata)

frontend/app/components/shared/SessionSearch/SessionSearch.tsx

@@ -21,11 +21,11 @@ interface Props {
   updateFilter: typeof updateFilter;
 }
 function SessionSearch(props: Props) {
-  const { appliedFilter, saveRequestPayloads = false, metaLoading } = props;
+  const { appliedFilter, saveRequestPayloads = false, metaLoading = false } = props;
   const hasEvents = appliedFilter.filters.filter((i: any) => i.isEvent).size > 0;
   const hasFilters = appliedFilter.filters.filter((i: any) => !i.isEvent).size > 0;
 
-  useSessionSearchQueryHandler({ appliedFilter, applyFilter: props.updateFilter });
+  useSessionSearchQueryHandler({ appliedFilter, applyFilter: props.updateFilter, loading: metaLoading });
 
   useEffect(() => {
     debounceFetch = debounce(() => props.fetchSessions(), 500);
@@ -89,11 +89,9 @@ function SessionSearch(props: Props) {
           <div className="border-t px-5 py-1 flex items-center -mx-2">
             <div>
               <FilterSelection filter={undefined} onFilterClick={onAddFilter}>
-                {/* <IconButton primaryText label="ADD STEP" icon="plus" /> */}
                 <Button
                   variant="text-primary"
                   className="mr-2"
-                  // onClick={() => setshowModal(true)}
                   icon="plus"
                 >
                   ADD STEP

frontend/app/components/shared/UserSessionsModal/UserSessionsModal.tsx

@@ -70,7 +70,7 @@ function UserSessionsModal(props: Props) {
                     <Loader loading={loading}>
                         {data.sessions.map((session: any) => (
                             <div className="border-b last:border-none" key={session.sessionId}>
-                                <SessionItem key={session.sessionId} session={session} compact={true} onClick={hideModal} />
+                                <SessionItem key={session.sessionId} session={session} compact={true} onClick={hideModal} ignoreAssist={true} />
                             </div>
                         ))}
                     </Loader>

frontend/app/hooks/useSessionSearchQueryHandler.ts

@@ -5,29 +5,34 @@ import { createUrlQuery, getFiltersFromQuery } from 'App/utils/search';
 interface Props {
   appliedFilter: any;
   applyFilter: any;
+  loading: boolean;
 }
 
 const useSessionSearchQueryHandler = (props: Props) => {
-  const { appliedFilter, applyFilter } = props;
+  const { appliedFilter, applyFilter, loading } = props;
   const history = useHistory();
 
   useEffect(() => {
     const applyFilterFromQuery = () => {
-      const filter = getFiltersFromQuery(history.location.search, appliedFilter);
-      applyFilter(filter, true, false);
+      if (!loading) {
+        const filter = getFiltersFromQuery(history.location.search, appliedFilter);
+        applyFilter(filter, true, false);
+      }
     };
 
     applyFilterFromQuery();
-  }, []);
+  }, [loading]);
 
   useEffect(() => {
     const generateUrlQuery = () => {
-      const search: any = createUrlQuery(appliedFilter);
-      history.replace({ search });
+      if (!loading) {
+        const search: any = createUrlQuery(appliedFilter);
+        history.replace({ search });
+      }
     };
 
     generateUrlQuery();
-  }, [appliedFilter]);
+  }, [appliedFilter, loading]);
 
   return null;
 };

frontend/app/player/common/ListWalker.ts

@@ -105,11 +105,11 @@ export default class ListWalker<T extends Timed> {
 			: null
 	}
 
-	/*
-		Returns last message with the time <= t.
-		Assumed that the current message is already handled so
-		if pointer doesn't cahnge <null> is returned.
-	*/
+	/**
+	 * @returns last message with the time <= t.
+	 * Assumed that the current message is already handled so
+	 * if pointer doesn't cahnge <null> is returned.
+	 */
 	moveGetLast(t: number, index?: number): T | null {
 		let key: string = "time"; //TODO
 		let val = t;
@@ -130,7 +130,13 @@ export default class ListWalker<T extends Timed> {
 		return changed ? this.list[ this.p - 1 ] : null;
 	}
 
-	async moveWait(t: number, callback: (msg: T) => Promise<any> | undefined): Promise<void> {
+	/**
+	 * Moves over the messages starting from the current+1 to the last one with the time <= t
+	 * applying callback on each of them
+	 * @param t - max message time to move to; will move & apply callback while msg.time <= t
+	 * @param callback - a callback to apply on each message passing by while moving
+	 */
+	moveApply(t: number, callback: (msg: T) => void): void {
 		// Applying only in increment order for now
 		if (t < this.timeNow) {
 			this.reset();
@@ -138,8 +144,7 @@ export default class ListWalker<T extends Timed> {
 
 		const list = this.list
 		while (list[this.p] && list[this.p].time <= t) {
-			const maybePromise = callback(this.list[ this.p++ ]);
-			if (maybePromise) { await maybePromise }
+			callback(this.list[ this.p++ ])
 		}
 	}
 

frontend/app/player/common/SimpleStore.ts

@@ -1,6 +1,5 @@
 import { Store } from './types'
 
-// (not a type)
 export default class SimpleSore<G, S=G> implements Store<G, S> {
   constructor(private state: G){}
   get(): G {

frontend/app/player/web/MessageManager.ts

@@ -52,7 +52,7 @@ export interface State extends ScreenState, ListsState {
   connBandwidth?: number,
   location?: string,
   performanceChartTime?: number,
-  performanceAvaliability?: PerformanceTrackManager['avaliability']
+  performanceAvailability?: PerformanceTrackManager['availability']
 
   domContentLoadedTime?:  { time: number, value: number },
   domBuildingTime?: number,
@@ -191,7 +191,7 @@ export default class MessageManager {
   private onFileReadSuccess = () => {
     const stateToUpdate : Partial<State>= {
       performanceChartData: this.performanceTrackManager.chartData,
-      performanceAvaliability: this.performanceTrackManager.avaliability,
+      performanceAvailability: this.performanceTrackManager.availability,
       ...this.lists.getFullListsState(),
     }
     if (this.activityManager) {
@@ -214,7 +214,7 @@ export default class MessageManager {
   async loadMessages(isClickmap: boolean = false) {
     this.setMessagesLoading(true)
     // TODO: reusable decryptor instance
-    const createNewParser = (shouldDecrypt = true, file) => {
+    const createNewParser = (shouldDecrypt = true, file?: string) => {
       const decrypt = shouldDecrypt && this.session.fileKey
         ? (b: Uint8Array) => decryptSessionBytes(b, this.session.fileKey)
         : (b: Uint8Array) => Promise.resolve(b)
@@ -228,7 +228,7 @@ export default class MessageManager {
         }
         const sorted = msgs.sort((m1, m2) => {
           // @ts-ignore
-          if (m1.time === m2.time) return m1._index - m2._index
+          if (!m1.time || !m2.time || m1.time === m2.time) return m1._index - m2._index
           return m1.time - m2.time
         })
 
@@ -250,34 +250,60 @@ export default class MessageManager {
 
     this.waitingForFiles = true
 
+    // TODO: refactor this stuff; split everything to async/await
+
     const loadMethod = this.session.domURL && this.session.domURL.length > 0
       ? { url: this.session.domURL, parser: () => createNewParser(true, 'dom') }
       : { url: this.session.mobsUrl, parser: () => createNewParser(false, 'dom')}
 
-    loadFiles(loadMethod.url, loadMethod.parser())
-      // EFS fallback
-      .catch((e) =>
-        requestEFSDom(this.session.sessionId)
-          .then(createNewParser(false, 'domEFS'))
+    const parser = loadMethod.parser()
+
+    /**
+     * We load first dom mobfile before the rest
+     * to speed up time to replay
+     * but as a tradeoff we have to have some copy-paste
+     * for the devtools file
+     * */
+    loadFiles([loadMethod.url[0]], parser)
+      .then(() => {
+        const domPromise = loadMethod.url.length > 1
+          ? loadFiles([loadMethod.url[1]], parser, true)
+          : Promise.resolve()
+          const devtoolsPromise = !isClickmap
+            ? this.loadDevtools(createNewParser)
+            : Promise.resolve()
+        return Promise.all([domPromise, devtoolsPromise])
+      })
+      /**
+       * EFS fallback for unprocessed sessions (which are live)
+       * */
+      .catch(() => {
+          requestEFSDom(this.session.sessionId)
+            .then(createNewParser(false, 'domEFS'))
+            .catch(this.onFileReadFailed)
+          if (!isClickmap) {
+            this.loadDevtools(createNewParser)
+          }
+        }
       )
       .then(this.onFileReadSuccess)
-      .catch(this.onFileReadFailed)
       .finally(this.onFileReadFinally);
+  }
 
-    // load devtools (TODO: start after the first DOM file download)
-    if (isClickmap) return;
+  loadDevtools(createNewParser: (shouldDecrypt: boolean, file: string) => (b: Uint8Array) => Promise<void>) {
     this.state.update({ devtoolsLoading: true })
-    loadFiles(this.session.devtoolsURL, createNewParser(true, 'devtools'))
-    // EFS fallback
-    .catch(() =>
-      requestEFSDevtools(this.session.sessionId)
-        .then(createNewParser(false, 'devtoolsEFS'))
-    )
-    .then(() => {
-      this.state.update(this.lists.getFullListsState()) // TODO: also in case of dynamic update through assist
-    })
-    .catch(e => logger.error("Can not download the devtools file", e))
-    .finally(() => this.state.update({ devtoolsLoading: false }))
+    return loadFiles(this.session.devtoolsURL, createNewParser(true, 'devtools'))
+      // EFS fallback
+      .catch(() =>
+        requestEFSDevtools(this.session.sessionId)
+          .then(createNewParser(false, 'devtoolsEFS'))
+      )
+      // TODO: also in case of dynamic update through assist
+      .then(() => {
+        this.state.update({ ...this.lists.getFullListsState() })
+      })
+      .catch(e => logger.error("Can not download the devtools file", e))
+      .finally(() => this.state.update({ devtoolsLoading: false }))
   }
 
   resetMessageManagers() {

frontend/app/player/web/WebLivePlayer.ts

@@ -90,7 +90,7 @@ export default class WebLivePlayer extends WebPlayer {
   clean = () => {
     this.incomingMessages.length = 0
     this.assistManager.clean()
-    this.screen.clean()
+    this.screen?.clean?.()
     // @ts-ignore
     this.screen = undefined;
     super.clean()

frontend/app/player/web/managers/DOM/DOMManager.ts

@@ -9,40 +9,35 @@ import FocusManager from './FocusManager';
 import SelectionManager from './SelectionManager';
 import type { StyleElement } from './VirtualDOM';
 import {
-  PostponedStyleSheet,
+  OnloadStyleSheet,
   VDocument,
   VElement,
+  VHTMLElement,
   VNode,
   VShadowRoot,
-  VStyleElement,
   VText,
+  OnloadVRoot,
 } from './VirtualDOM';
 import { deleteRule, insertRule } from './safeCSSRules';
 
-type HTMLElementWithValue = HTMLInputElement | HTMLTextAreaElement | HTMLSelectElement;
 
-const IGNORED_ATTRS = [ "autocomplete" ];
-const ATTR_NAME_REGEXP = /([^\t\n\f \/>"'=]+)/; // regexp costs ~
-
-
-// TODO: filter out non-relevant  prefixes
-// function replaceCSSPrefixes(css: string) {
-//   return css
-//     .replace(/\-ms\-/g, "")
-//     .replace(/\-webkit\-/g, "")
-//     .replace(/\-moz\-/g, "")
-//     .replace(/\-webkit\-/g, "")
-// }
+function isStyleVElement(vElem: VElement): vElem is VElement & { node: StyleElement } {
+  return vElem.tagName.toLowerCase() === "style"
+}
 
+const IGNORED_ATTRS = [ "autocomplete" ]
+const ATTR_NAME_REGEXP = /([^\t\n\f \/>"'=]+)/
 
 export default class DOMManager extends ListWalker<Message> {
   private readonly vTexts: Map<number, VText> = new Map() // map vs object here?
   private readonly vElements: Map<number, VElement> = new Map()
-  private readonly vRoots: Map<number, VShadowRoot | VDocument> = new Map()
-  private styleSheets: Map<number, CSSStyleSheet> = new Map()
-  private ppStyleSheets: Map<number, PostponedStyleSheet> = new Map()
-  private stringDict: Record<number,string> = {}
-  private attrsBacktrack: Message[] = []
+  private readonly olVRoots: Map<number, OnloadVRoot> = new Map()
+  /** Constructed StyleSheets https://developer.mozilla.org/en-US/docs/Web/API/Document/adoptedStyleSheets
+   * as well as <style> tag owned StyleSheets
+   */
+  private olStyleSheets: Map<number, OnloadStyleSheet> = new Map()
+  /** @depreacted since tracker 4.0.2 Mapping by nodeID */
+  private olStyleSheetsDeprecated: Map<number, OnloadStyleSheet> = new Map()
 
   private upperBodyId: number = -1;
   private nodeScrollManagers: Map<number, ListWalker<SetNodeScroll>> = new Map()
@@ -53,6 +48,7 @@ export default class DOMManager extends ListWalker<Message> {
   constructor(
     private readonly screen: Screen,
     private readonly isMobile: boolean,
+    private stringDict: Record<number,string>,
     public readonly time: number,
     setCssLoading: ConstructorParameters<typeof StylesManager>[1],
   ) {
@@ -61,6 +57,10 @@ export default class DOMManager extends ListWalker<Message> {
     this.stylesManager = new StylesManager(screen, setCssLoading)
   }
 
+  setStringDict(stringDict: Record<number,string>) {
+    this.stringDict = stringDict
+  }
+
   append(m: Message): void {
     if (m.tp === MType.SetNodeScroll) {
       let scrollManager = this.nodeScrollManagers.get(m.id)
@@ -91,21 +91,20 @@ export default class DOMManager extends ListWalker<Message> {
     super.append(m)
   }
 
-  private removeBodyScroll(id: number, vn: VElement): void {
+  private removeBodyScroll(id: number, vElem: VElement): void {
     if (this.isMobile && this.upperBodyId === id) { // Need more type safety!
-      (vn.node as HTMLBodyElement).style.overflow = "hidden"
+      (vElem.node as HTMLBodyElement).style.overflow = "hidden"
     }
   }
 
-  // May be make it as a message on message add?
-  private removeAutocomplete(node: Element): boolean {
-    const tag = node.tagName
+  private removeAutocomplete(vElem: VElement): boolean {
+    const tag = vElem.tagName
     if ([ "FORM", "TEXTAREA", "SELECT" ].includes(tag)) {
-      node.setAttribute("autocomplete", "off");
+      vElem.setAttribute("autocomplete", "off");
       return true;
     }
     if (tag === "INPUT") {
-      node.setAttribute("autocomplete", "new-password");
+      vElem.setAttribute("autocomplete", "new-password");
       return true;
     }
     return false;
@@ -117,22 +116,24 @@ export default class DOMManager extends ListWalker<Message> {
       logger.error("Insert error. Node not found", id);
       return;
     }
-    const parent = this.vElements.get(parentID) || this.vRoots.get(parentID)
+    const parent = this.vElements.get(parentID) || this.olVRoots.get(parentID)
     if (!parent) {
-      logger.error("Insert error. Parent node not found", parentID, this.vElements, this.vRoots);
+      logger.error("Insert error. Parent vNode not found", parentID, this.vElements, this.olVRoots);
       return;
     }
 
-    const pNode = parent.node
-    if ((pNode instanceof HTMLStyleElement) &&  // TODO: correct ordering OR filter in tracker
-        pNode.sheet &&
-        pNode.sheet.cssRules &&
-        pNode.sheet.cssRules.length > 0 &&
-        pNode.innerText &&
-        pNode.innerText.trim().length === 0
-    ) {
-      logger.log("Trying to insert child to a style tag with virtual rules: ", parent, child);
-      return;
+    if (parent instanceof VElement && isStyleVElement(parent)) {
+      // TODO: if this ever happens? ; Maybe do not send empty TextNodes in tracker
+      const styleNode = parent.node
+      if (styleNode.sheet &&
+        styleNode.sheet.cssRules &&
+        styleNode.sheet.cssRules.length > 0 &&
+        styleNode.textContent &&
+        styleNode.textContent.trim().length === 0
+      ) {
+        logger.log("Trying to insert child to a style tag with virtual rules: ", parent, child);
+        return;
+      }
     }
 
     parent.insertChildAt(child, index)
@@ -143,25 +144,27 @@ export default class DOMManager extends ListWalker<Message> {
     const vn = this.vElements.get(msg.id)
     if (!vn) { logger.error("SetNodeAttribute: Node not found", msg); return }
 
-    if (vn.node.tagName === "INPUT" && name === "name") {
-      // Otherwise binds local autocomplete values (maybe should ignore on the tracker level)
+    if (vn.tagName === "INPUT" && name === "name") {
+      // Otherwise binds local autocomplete values (maybe should ignore on the tracker level?)
       return
     }
-    if (name === "href" && vn.node.tagName === "LINK") {
+    if (name === "href" && vn.tagName === "LINK") {
       // @ts-ignore  ?global ENV type   // It've been done on backend (remove after testing in saas)
       // if (value.startsWith(window.env.ASSETS_HOST || window.location.origin + '/assets')) {
       //   value = value.replace("?", "%3F");
       // }
       if (!value.startsWith("http")) {
+        /* blob:... value can happen here for some reason.
+         * which will result in that link being unable to load and having 4sec timeout in the below function.
+         */
         return
       }
-      // blob:... value can happen here for some reason.
-      // which will result in that link being unable to load and having 4sec timeout in the below function.
 
-      // TODO: check if node actually exists on the page, not just in memory
+      // TODOTODO: check if node actually exists on the page, not just in memory
       this.stylesManager.setStyleHandlers(vn.node as HTMLLinkElement, value);
     }
-    if (vn.node.namespaceURI === 'http://www.w3.org/2000/svg' && value.startsWith("url(")) {
+    if (vn.isSVG && value.startsWith("url(")) {
+      /* SVG shape ID-s for masks etc. Sometimes referred with the full-page url, which we don't have in replay */
       value = "url(#" + (value.split("#")[1] ||")")
     }
     vn.setAttribute(name, value)
@@ -169,12 +172,9 @@ export default class DOMManager extends ListWalker<Message> {
   }
 
   private applyMessage = (msg: Message): Promise<any> | undefined => {
-    let vn: VNode | undefined
-    let doc: Document | null
-    let styleSheet: CSSStyleSheet | PostponedStyleSheet | undefined
     switch (msg.tp) {
-      case MType.CreateDocument:
-        doc = this.screen.document;
+      case MType.CreateDocument: {
+        const doc = this.screen.document;
         if (!doc) {
           logger.error("No root iframe document found", msg, this.screen)
           return;
@@ -185,84 +185,71 @@ export default class DOMManager extends ListWalker<Message> {
         const fRoot = doc.documentElement;
         fRoot.innerText = '';
 
-        vn = new VElement(fRoot)
+        const vHTMLElement = new VHTMLElement(fRoot)
         this.vElements.clear()
-        this.vElements.set(0, vn)
-        const vDoc = new VDocument(doc)
-        vDoc.insertChildAt(vn, 0)
-        this.vRoots.clear()
-        this.vRoots.set(0, vDoc) // watchout: id==0 for both Document and documentElement
+        this.vElements.set(0, vHTMLElement)
+        const vDoc = OnloadVRoot.fromDocumentNode(doc)
+        vDoc.insertChildAt(vHTMLElement, 0)
+        this.olVRoots.clear()
+        this.olVRoots.set(0, vDoc) // watchout: id==0 for both Document and documentElement
         // this is done for the AdoptedCSS logic
-        // todo: start from 0-node (sync logic with tracker)
+        // Maybetodo: start Document as 0-node in tracker
         this.vTexts.clear()
         this.stylesManager.reset()
-        this.stringDict = {}
         return
-      case MType.CreateTextNode:
-        vn = new VText()
-        this.vTexts.set(msg.id, vn)
+      }
+      case MType.CreateTextNode: {
+        const vText = new VText()
+        this.vTexts.set(msg.id, vText)
         this.insertNode(msg)
         return
-      case MType.CreateElementNode:
-        let element: Element
-        if (msg.svg) {
-          element = document.createElementNS('http://www.w3.org/2000/svg', msg.tag)
-        } else {
-          element = document.createElement(msg.tag)
+      }
+      case MType.CreateElementNode: {
+        const vElem = new VElement(msg.tag, msg.svg)
+        if (['STYLE', 'style', 'LINK'].includes(msg.tag)) {
+          vElem.prioritized = true
         }
-        if (msg.tag === "STYLE" || msg.tag === "style") {
-          vn = new VStyleElement(element as StyleElement)
-        } else {
-          vn = new VElement(element)
-        }
-        this.vElements.set(msg.id, vn)
+        this.vElements.set(msg.id, vElem)
         this.insertNode(msg)
-        this.removeBodyScroll(msg.id, vn)
-        this.removeAutocomplete(element)
-        if (['STYLE', 'style', 'LINK'].includes(msg.tag)) { // Styles in priority
-          vn.enforceInsertion()
-        }
+        this.removeBodyScroll(msg.id, vElem)
+        this.removeAutocomplete(vElem)
         return
+      }
       case MType.MoveNode:
-        this.insertNode(msg);
+        this.insertNode(msg)
         return
-      case MType.RemoveNode:
-        vn = this.vElements.get(msg.id) || this.vTexts.get(msg.id)
-        if (!vn) { logger.error("RemoveNode: Node not found", msg); return }
-        if (!vn.parentNode) { logger.error("RemoveNode: Parent node not found", msg); return }
-        vn.parentNode.removeChild(vn)
+      case MType.RemoveNode: {
+        const vChild = this.vElements.get(msg.id) || this.vTexts.get(msg.id)
+        if (!vChild) { logger.error("RemoveNode: Node not found", msg); return }
+        if (!vChild.parentNode) { logger.error("RemoveNode: Parent node not found", msg); return }
+        vChild.parentNode.removeChild(vChild)
         this.vElements.delete(msg.id)
         this.vTexts.delete(msg.id)
         return
+      }
       case MType.SetNodeAttribute:
-        if (msg.name === 'href') this.attrsBacktrack.push(msg)
-        else this.setNodeAttribute(msg)
-        return
-      case MType.StringDict:
-        this.stringDict[msg.key] = msg.value
+        this.setNodeAttribute(msg)
         return
       case MType.SetNodeAttributeDict:
-        this.stringDict[msg.nameKey] === undefined && logger.error("No dictionary key for msg 'name': ", msg)
-        this.stringDict[msg.valueKey] === undefined && logger.error("No dictionary key for msg 'value': ", msg)
+        this.stringDict[msg.nameKey] === undefined && logger.error("No dictionary key for msg 'name': ", msg, this.stringDict)
+        this.stringDict[msg.valueKey] === undefined && logger.error("No dictionary key for msg 'value': ", msg, this.stringDict)
         if (this.stringDict[msg.nameKey] === undefined || this.stringDict[msg.valueKey] === undefined ) { return }
-        if (this.stringDict[msg.nameKey] === 'href') this.attrsBacktrack.push(msg)
-        else {
-          this.setNodeAttribute({
-            id: msg.id,
-            name: this.stringDict[msg.nameKey],
-            value: this.stringDict[msg.valueKey],
-          })
-        }
+        this.setNodeAttribute({
+          id: msg.id,
+          name: this.stringDict[msg.nameKey],
+          value: this.stringDict[msg.valueKey],
+        })
         return
-      case MType.RemoveNodeAttribute:
-          vn = this.vElements.get(msg.id)
-          if (!vn) { logger.error("RemoveNodeAttribute: Node not found", msg); return }
-          vn.removeAttribute(msg.name)
+      case MType.RemoveNodeAttribute: {
+        const vElem = this.vElements.get(msg.id)
+        if (!vElem) { logger.error("RemoveNodeAttribute: Node not found", msg); return }
+        vElem.removeAttribute(msg.name)
         return
-      case MType.SetInputValue:
-        vn = this.vElements.get(msg.id)
-        if (!vn) { logger.error("SetInoputValue: Node not found", msg); return }
-        const nodeWithValue = vn.node
+      }
+      case MType.SetInputValue: {
+        const vElem = this.vElements.get(msg.id)
+        if (!vElem) { logger.error("SetInoputValue: Node not found", msg); return }
+        const nodeWithValue = vElem.node
         if (!(nodeWithValue instanceof HTMLInputElement
             || nodeWithValue instanceof HTMLTextAreaElement
             || nodeWithValue instanceof HTMLSelectElement)
@@ -271,222 +258,183 @@ export default class DOMManager extends ListWalker<Message> {
           return
         }
         const val = msg.mask > 0 ? '*'.repeat(msg.mask) : msg.value
-        doc = this.screen.document
+        const doc = this.screen.document
         if (doc && nodeWithValue === doc.activeElement) {
           // For the case of Remote Control
           nodeWithValue.onblur = () => { nodeWithValue.value = val }
           return
         }
-        nodeWithValue.value = val
+        nodeWithValue.value = val // Maybe make special VInputValueElement type for lazy value update
         return
-      case MType.SetInputChecked:
-        vn = this.vElements.get(msg.id)
-        if (!vn) { logger.error("SetInputChecked: Node not found", msg); return }
-        (vn.node as HTMLInputElement).checked = msg.checked
+      }
+      case MType.SetInputChecked: {
+        const vElem = this.vElements.get(msg.id)
+        if (!vElem) { logger.error("SetInputChecked: Node not found", msg); return }
+        (vElem.node as HTMLInputElement).checked = msg.checked // Maybe make special VCheckableElement type for lazy checking
         return
+      }
       case MType.SetNodeData:
-      case MType.SetCssData: // mbtodo: remove  css transitions when timeflow is not natural (on jumps)
-        vn = this.vTexts.get(msg.id)
-        if (!vn) { logger.error("SetCssData: Node not found", msg); return }
-        vn.setData(msg.data)
-        if (msg.tp === MType.SetCssData) { // Styles in priority  (do we need inlines as well?)
-          vn.applyChanges()
-        }
+      case MType.SetCssData: {
+        const vText = this.vTexts.get(msg.id)
+        if (!vText) { logger.error("SetNodeData/SetCssData: Node not found", msg); return }
+        vText.setData(msg.data)
         return
+      }
 
-      // @deprecated since 4.0.2 in favor of adopted_ss_insert/delete_rule + add_owner as being common case for StyleSheets
-      case MType.CssInsertRule:
-        vn = this.vElements.get(msg.id)
-        if (!vn) { logger.error("CssInsertRule: Node not found", msg); return }
-        if (!(vn instanceof VStyleElement)) {
-          logger.warn("Non-style node in CSS rules message (or sheet is null)", msg, vn);
-          return
+      /** @deprecated 
+       * since 4.0.2 in favor of AdoptedSsInsertRule/DeleteRule + AdoptedSsAddOwner as a common case for StyleSheets
+       */
+      case MType.CssInsertRule: {
+        let styleSheet = this.olStyleSheetsDeprecated.get(msg.id)
+        if (!styleSheet) {
+          const vElem = this.vElements.get(msg.id)
+          if (!vElem) { logger.error("CssInsertRule: Node not found", msg); return }
+          if (!isStyleVElement(vElem)) { logger.error("CssInsertRule: Non-style element", msg); return }
+          styleSheet = OnloadStyleSheet.fromStyleElement(vElem.node)
+          this.olStyleSheetsDeprecated.set(msg.id, styleSheet)
         }
-        vn.onStyleSheet(sheet => insertRule(sheet, msg))
+        styleSheet.insertRule(msg.rule, msg.index)
         return
-      case MType.CssDeleteRule:
-        vn = this.vElements.get(msg.id)
-        if (!vn) { logger.error("CssDeleteRule: Node not found", msg); return }
-        if (!(vn instanceof VStyleElement)) {
-          logger.warn("Non-style node in CSS rules message (or sheet is null)", msg, vn);
-          return
-        }
-        vn.onStyleSheet(sheet => deleteRule(sheet, msg))
+      }
+      case MType.CssDeleteRule: {
+        const styleSheet = this.olStyleSheetsDeprecated.get(msg.id)
+        if (!styleSheet) { logger.error("CssDeleteRule: StyleSheet was not created", msg); return }
+        styleSheet.deleteRule(msg.index)
         return
-      // end @deprecated
-
-      case MType.CreateIFrameDocument:
-        vn = this.vElements.get(msg.frameID)
-        if (!vn) { logger.error("CreateIFrameDocument: Node not found", msg); return }
-        vn.enforceInsertion()
-        const host = vn.node
-        if (host instanceof HTMLIFrameElement) {
-          const doc = host.contentDocument
-          if (!doc) {
-            logger.warn("No default iframe doc", msg, host)
-            return
-          }
-
-          const vDoc = new VDocument(doc)
-          this.vRoots.set(msg.id, vDoc)
-          return;
-        } else if (host instanceof Element) { // shadow DOM
-          try {
-            const shadowRoot = host.attachShadow({ mode: 'open' })
-            vn = new VShadowRoot(shadowRoot)
-            this.vRoots.set(msg.id, vn)
-          } catch(e) {
-            logger.warn("Can not attach shadow dom", e, msg)
-          }
-        } else {
-          logger.warn("Context message host is not Element", msg)
-        }
+      }
+      /* end @deprecated */
+      case MType.CreateIFrameDocument: {
+        const vElem = this.vElements.get(msg.frameID)
+        if (!vElem) { logger.error("CreateIFrameDocument: Node not found", msg); return }
+        const vRoot = OnloadVRoot.fromVElement(vElem)
+        vRoot.catch(e => logger.warn(e, msg))
+        this.olVRoots.set(msg.id, vRoot)
         return
-      case MType.AdoptedSsInsertRule:
-        styleSheet = this.styleSheets.get(msg.sheetID) || this.ppStyleSheets.get(msg.sheetID)
+      }
+      case MType.AdoptedSsInsertRule: {
+        const styleSheet = this.olStyleSheets.get(msg.sheetID)
         if (!styleSheet) {
           logger.warn("No stylesheet was created for ", msg)
           return
         }
         insertRule(styleSheet, msg)
         return
-      case MType.AdoptedSsDeleteRule:
-        styleSheet = this.styleSheets.get(msg.sheetID) || this.ppStyleSheets.get(msg.sheetID)
+      }
+      case MType.AdoptedSsDeleteRule: {
+        const styleSheet = this.olStyleSheets.get(msg.sheetID)
         if (!styleSheet) {
           logger.warn("No stylesheet was created for ", msg)
           return
         }
         deleteRule(styleSheet, msg)
         return
-
-      case MType.AdoptedSsReplace:
-        styleSheet = this.styleSheets.get(msg.sheetID)
+      }
+      case MType.AdoptedSsReplace: {
+        const styleSheet = this.olStyleSheets.get(msg.sheetID)
         if (!styleSheet) {
           logger.warn("No stylesheet was created for ", msg)
           return
         }
-        // @ts-ignore
+        // @ts-ignore (configure ts with recent WebaAPI)
         styleSheet.replaceSync(msg.text)
         return
-      case MType.AdoptedSsAddOwner:
-        vn = this.vRoots.get(msg.id)
-        if (!vn) {
-          // non-constructed case
-          vn = this.vElements.get(msg.id)
-          if (!vn) { logger.error("AdoptedSsAddOwner: Node not found", msg); return }
-          if (!(vn instanceof VStyleElement)) { logger.error("Non-style owner", msg); return }
-          this.ppStyleSheets.set(msg.sheetID, new PostponedStyleSheet(vn.node))
-          return
-        }
-        styleSheet = this.styleSheets.get(msg.sheetID)
-        if (!styleSheet) {
-          let context: typeof globalThis
-          const rootNode = vn.node
-          if (rootNode.nodeType === Node.DOCUMENT_NODE) {
-            context = (rootNode as Document).defaultView
-          } else {
-            context = (rootNode as ShadowRoot).ownerDocument.defaultView
-          }
-          styleSheet = new context.CSSStyleSheet()
-          this.styleSheets.set(msg.sheetID, styleSheet)
-        }
-        //@ts-ignore
-        vn.node.adoptedStyleSheets = [...vn.node.adoptedStyleSheets, styleSheet]
-        return
-      case MType.AdoptedSsRemoveOwner:
-        styleSheet = this.styleSheets.get(msg.sheetID)
-        if (!styleSheet) {
-          logger.warn("No stylesheet was created for ", msg)
-          return
-        }
-        vn = this.vRoots.get(msg.id)
-        if (!vn) { logger.error("AdoptedSsRemoveOwner: Node not found", msg); return }
-        //@ts-ignore
-        vn.node.adoptedStyleSheets = [...vn.node.adoptedStyleSheets].filter(s => s !== styleSheet)
-        return
-      case MType.LoadFontFace:
-        vn = this.vRoots.get(msg.parentID)
-        if (!vn) { logger.error("LoadFontFace: Node not found", msg); return }
-        if (vn instanceof VShadowRoot) { logger.error(`Node ${vn} expected to be a Document`, msg); return }
-        let descr: Object
-        try {
-          descr = JSON.parse(msg.descriptors)
-          descr = typeof descr === 'object' ? descr : undefined
-        } catch {
-          logger.warn("Can't parse font-face descriptors: ", msg)
-        }
-        const ff = new FontFace(msg.family, msg.source, descr)
-        vn.node.fonts.add(ff)
-        return ff.load()
-    }
-  }
-
-  applyBacktrack(msg: Message) {
-    // @ts-ignore
-    const target = this.vElements.get(msg.id)
-    if (!target) {
-      return
-    }
-
-    switch (msg.tp) {
-      case MType.SetNodeAttribute: {
-        this.setNodeAttribute(msg)
-        return
       }
-      case MType.SetNodeAttributeDict: {
-        this.stringDict[msg.nameKey] === undefined && logger.error("No dictionary key for msg 'name': ", msg)
-        this.stringDict[msg.valueKey] === undefined && logger.error("No dictionary key for msg 'value': ", msg)
-        if (this.stringDict[msg.nameKey] === undefined || this.stringDict[msg.valueKey] === undefined) {
+      case MType.AdoptedSsAddOwner: {
+        const vRoot = this.olVRoots.get(msg.id)
+        if (!vRoot) {
+          /* <style> tag case */
+          const vElem = this.vElements.get(msg.id)
+          if (!vElem) { logger.error("AdoptedSsAddOwner: Node not found", msg); return }
+          if (!isStyleVElement(vElem)) { logger.error("Non-style owner", msg); return }
+          this.olStyleSheets.set(msg.sheetID, OnloadStyleSheet.fromStyleElement(vElem.node))
           return
         }
-        this.setNodeAttribute({
-          id: msg.id,
-          name: this.stringDict[msg.nameKey],
-          value: this.stringDict[msg.valueKey],
+        /* Constructed StyleSheet case */
+        let olStyleSheet = this.olStyleSheets.get(msg.sheetID)
+        if (!olStyleSheet) {
+          olStyleSheet = OnloadStyleSheet.fromVRootContext(vRoot)
+          this.olStyleSheets.set(msg.sheetID, olStyleSheet)
+        }
+        olStyleSheet.whenReady(styleSheet => {
+          vRoot.onNode(node => {
+            // @ts-ignore
+            node.adoptedStyleSheets = [...node.adoptedStyleSheets, styleSheet]
+          })
         })
-        return;
+        return
+      }
+      case MType.AdoptedSsRemoveOwner: {
+        const olStyleSheet = this.olStyleSheets.get(msg.sheetID)
+        if (!olStyleSheet) {
+          logger.warn("AdoptedSsRemoveOwner: No stylesheet was created for ", msg)
+          return
+        }
+        const vRoot = this.olVRoots.get(msg.id)
+        if (!vRoot) { logger.error("AdoptedSsRemoveOwner: Owner node not found", msg); return }
+        olStyleSheet.whenReady(styleSheet => {
+          vRoot.onNode(node => {
+            // @ts-ignore
+            node.adoptedStyleSheets = [...vRoot.node.adoptedStyleSheets].filter(s => s !== styleSheet)
+          })
+        })
+        return
+      }
+      case MType.LoadFontFace: {
+        const vRoot = this.olVRoots.get(msg.parentID)
+        if (!vRoot) { logger.error("LoadFontFace: Node not found", msg); return }
+        vRoot.whenReady(vNode => {
+          if (vNode instanceof VShadowRoot) { logger.error(`Node ${vNode} expected to be a Document`, msg); return }
+          let descr: Object | undefined
+          try {
+            descr = JSON.parse(msg.descriptors)
+            descr = typeof descr === 'object' ? descr : undefined
+          } catch {
+            logger.warn("Can't parse font-face descriptors: ", msg)
+          }
+          const ff = new FontFace(msg.family, msg.source, descr)
+          vNode.node.fonts.add(ff)
+          ff.load() // TODOTODO: wait for this one in StylesManager in a common way with styles
+        })
+        return
       }
     }
   }
 
+  /**
+   * Moves and applies all the messages from the current (or from the beginning, if t < current.time) 
+   * to the one with msg.time >= `t`
+   * 
+   * This function autoresets pointer if necessary (better name?)
+   * 
+   * @returns Promise that fulfulls when necessary changes get applied 
+   *   (the async part exists mostly due to styles loading)
+   */
   async moveReady(t: number): Promise<void> {
-    // MBTODO (back jump optimisation):
-    //    - store intemediate virtual dom state
-    //    - cancel previous moveReady tasks (is it possible?) if new timestamp is less
-    // This function autoresets pointer if necessary (better name?)
+    this.moveApply(t, this.applyMessage)
 
-    /**
-     * Basically just skipping all set attribute with attrs being "href" if user is 'jumping'
-     * to the other point of replay to save time on NOT downloading any resources before the dom tree changes
-     * are applied, so it won't try to download and then cancel when node is created in msg N and removed in msg N+2
-     * which produces weird bug when asset is cached (10-25ms delay)
-     * */
-    // http://0.0.0.0:3333/5/session/8452905874437457
-    // 70 iframe, 8 create element - STYLE tag
-    await this.moveWait(t, this.applyMessage)
-
-    this.attrsBacktrack.forEach(msg => {
-      this.applyBacktrack(msg)
-    })
-    this.attrsBacktrack = []
-
-    this.vRoots.forEach(rt => rt.applyChanges()) // MBTODO (optimisation): affected set
+    this.olVRoots.forEach(rt => rt.applyChanges())
     // Thinkabout (read): css preload
     // What if we go back before it is ready? We'll have two handlres?
     return this.stylesManager.moveReady(t).then(() => {
-      // Apply focus
+      /* Waiting for styles to be applied first */
+      /* Applying focus */
       this.focusManager.move(t)
+      /* Applying text selections */
       this.selectionManager.move(t)
-      // Apply all scrolls after the styles got applied
+      /* Applying all scrolls */
       this.nodeScrollManagers.forEach(manager => {
         const msg = manager.moveGetLast(t)
         if (msg) {
-          let vNode: VNode
-          if (vNode = this.vElements.get(msg.id)) {
-            vNode.node.scrollLeft = msg.x
-            vNode.node.scrollTop = msg.y
-          } else if ((vNode = this.vRoots.get(msg.id)) && vNode instanceof VDocument){
-            vNode.node.defaultView?.scrollTo(msg.x, msg.y)
+          let scrollVHost: VElement | OnloadVRoot | undefined
+          if (scrollVHost = this.vElements.get(msg.id)) {
+            scrollVHost.node.scrollLeft = msg.x
+            scrollVHost.node.scrollTop = msg.y
+          } else if ((scrollVHost = this.olVRoots.get(msg.id))) {
+            scrollVHost.whenReady(vNode => {
+              if (vNode instanceof VDocument) {
+                vNode.node.defaultView?.scrollTo(msg.x, msg.y)
+              }
+            })
           }
         }
       })

frontend/app/player/web/managers/DOM/VirtualDOM.ts

@@ -1,69 +1,119 @@
-type VChild = VElement | VText
-
-export type VNode = VDocument | VShadowRoot | VElement | VText
-
 import { insertRule, deleteRule } from './safeCSSRules';
 
-abstract class VParent {
-	abstract node: Node | null
+
+type Callback<T> = (o: T) => void
+
+/**
+ * Virtual Node base class.
+ * Implements common abstract methods and lazy node creation logic.
+ * 
+ * @privateRemarks
+ * Would be better to export type-only, but didn't find a nice way to do that.
+ */
+export abstract class VNode<T extends Node = Node> {
+	protected abstract createNode(): T
+	private _node: T | null
+	/**
+	 * JS DOM Node getter with lazy node creation
+	 * 
+	 * @returns underneath JS DOM Node
+	 * @remarks should not be called unless the real node is required since creation might be expensive
+	 * 	It is better to use `onNode` callback applicator unless in the `applyChanges` implementation
+	 */
+	get node(): T {
+		if (!this._node) {
+			const node = this._node = this.createNode()
+			this.nodeCallbacks.forEach(cb => cb(node))
+			this.nodeCallbacks = []
+		}
+		return this._node
+	}
+	private nodeCallbacks: Callback<T>[] = []
+	/**
+	 * Lazy Node callback applicator
+	 *
+	 * @param callback - Callback that fires on existing JS DOM Node instantly if it exists
+	 * or whenever it gets created. Call sequence is concerned.
+	 */
+	onNode(callback: Callback<T>) {
+		if (this._node) {
+			callback(this._node)
+			return
+		}
+		this.nodeCallbacks.push(callback)
+	}
+	/**
+	 * Abstract method, should be implemented by the actual classes
+	 * It is supposed to apply virtual changes into the actual DOM
+	 */
+	public abstract applyChanges(): void
+}
+
+
+type VChild = VElement | VText
+abstract class VParent<T extends Node = Node> extends VNode<T>{
 	protected children: VChild[] = []
-	private insertedChildren: Set<VChild> = new Set()
+	private childrenToMount: Set<VChild> = new Set()
 
 	insertChildAt(child: VChild, index: number) {
 		if (child.parentNode) {
 			child.parentNode.removeChild(child)
 		}
 		this.children.splice(index, 0, child)
-		this.insertedChildren.add(child)
+		this.childrenToMount.add(child)
 		child.parentNode = this
 	}
 
 	removeChild(child: VChild) {
 		this.children = this.children.filter(ch => ch !== child)
-		this.insertedChildren.delete(child)
+		this.childrenToMount.delete(child)
 		child.parentNode = null
 	}
 
-	applyChanges() {
-		const node = this.node
-		if (!node) {
-			// log err
-			console.error("No node found", this)
-			return
-		}
-		// inserting
+	protected mountChildren(shouldInsert?: (child: VChild) => boolean) {
+		let nextMounted: VChild | null = null
 		for (let i = this.children.length-1; i >= 0; i--) {
 			const child = this.children[i]
-			child.applyChanges()
-			if (this.insertedChildren.has(child)) {
-				const nextVSibling = this.children[i+1]
-				node.insertBefore(child.node, nextVSibling ? nextVSibling.node : null)
+			if (this.childrenToMount.has(child) &&
+				(!shouldInsert || shouldInsert(child)) // is there a better way of not-knowing about subclass logic on prioritized insertion?
+			) {
+				this.node.insertBefore(child.node, nextMounted ? nextMounted.node : null)
+				this.childrenToMount.delete(child)
+			}
+			if (!this.childrenToMount.has(child)) {
+				nextMounted = child
 			}
 		}
-		this.insertedChildren.clear()
-		// removing
+	}
+
+	applyChanges() {
+		/* Building a sub-trees first (in-memory for non-mounted children) */
+		this.children.forEach(child => child.applyChanges())
+		/* Inserting */
+		this.mountChildren()
+		if (this.childrenToMount.size !== 0) {
+			console.error("VParent: Something went wrong with children insertion")
+		}
+		/* Removing in-between */
+		const node = this.node
 		const realChildren = node.childNodes
 		for(let j = 0; j < this.children.length; j++) {
 			while (realChildren[j] !== this.children[j].node) {
 				node.removeChild(realChildren[j])
 			}
 		}
-		// removing rest
+		/* Removing tail */
 		while(realChildren.length > this.children.length) {
-			node.removeChild(node.lastChild)
+			node.removeChild(node.lastChild as Node) /* realChildren.length > this.children.length >= 0 so it is not null */
 		}
 	}
 }
 
-export class VDocument extends VParent {
-	constructor(public readonly node: Document) { super() }
+export class VDocument extends VParent<Document> {
+	constructor(protected readonly createNode: () => Document) { super() }
 	applyChanges() {
 		if (this.children.length > 1) {
-			// log err
-		}
-		if (!this.node) {
-			// iframe not mounted yet
-			return
+			console.error("VDocument expected to have a single child.", this)
 		}
 		const child = this.children[0]
 		if (!child) { return }
@@ -75,14 +125,22 @@ export class VDocument extends VParent {
 	}
 }
 
-export class VShadowRoot extends VParent {
-	constructor(public readonly node: ShadowRoot) { super() }
+export class VShadowRoot extends VParent<ShadowRoot> {
+	constructor(protected readonly createNode: () => ShadowRoot) { super() }
 }
 
-export class VElement extends VParent {
-	parentNode: VParent | null = null
+export type VRoot = VDocument | VShadowRoot
+
+export class VElement extends VParent<Element> {
+	parentNode: VParent | null = null /** Should be modified only by he parent itself */
 	private newAttributes: Map<string, string | false> = new Map()
-	constructor(public readonly node: Element) { super() }
+
+	constructor(readonly tagName: string, readonly isSVG = false) { super() }
+	protected createNode() {
+		return this.isSVG
+			? document.createElementNS('http://www.w3.org/2000/svg', this.tagName)
+			: document.createElement(this.tagName)
+	}
 	setAttribute(name: string, value: string) {
 		this.newAttributes.set(name, value)
 	}
@@ -90,18 +148,7 @@ export class VElement extends VParent {
 		this.newAttributes.set(name, false)
 	}
 
-	// mbtodo: priority insertion instead.
-	// rn this is for styles that should be inserted as prior, 
-	// otherwise it will show visual styling lag if there is a transition CSS property)
-	enforceInsertion() {
-		let vNode: VElement = this
-		while (vNode.parentNode instanceof VElement) {
-			vNode = vNode.parentNode
-		}
-		(vNode.parentNode || vNode).applyChanges()
-	}
-
-	applyChanges() {
+	private applyAttributeChanges() { // "changes" -> "updates" ?
 		this.newAttributes.forEach((value, key) => {
 			if (value === false) {
 				this.node.removeAttribute(key)
@@ -114,88 +161,57 @@ export class VElement extends VParent {
 			}
 		})
 		this.newAttributes.clear()
+	}
+
+	applyChanges() {
+		this.prioritized && this.applyPrioritizedChanges()
+		this.applyAttributeChanges()
 		super.applyChanges()
 	}
-}
 
-
-type StyleSheetCallback = (s: CSSStyleSheet) => void
-export type StyleElement = HTMLStyleElement | SVGStyleElement
-
-// @deprecated TODO: remove in favor of PostponedStyleSheet
-export class VStyleElement extends VElement {
-	private loaded = false
-	private stylesheetCallbacks: StyleSheetCallback[] = []
-	constructor(public readonly node: StyleElement) { 
-		super(node)  // Is it compiled correctly or with 2 node assignments?
-		node.onload = () => {
-		  const sheet = node.sheet
-		  if (sheet) {
-		    this.stylesheetCallbacks.forEach(cb => cb(sheet))
-		    this.stylesheetCallbacks = []
-		  } else {
-		    // console.warn("Style onload: sheet is null") ?
-				// sometimes logs sheet ton of errors for some reason
-		  }
-		  this.loaded = true
-		}
-	}
-
-	onStyleSheet(cb: StyleSheetCallback) {
-		if (this.loaded) {
-			if (!this.node.sheet) {
-				console.warn("Style tag is loaded, but sheet is null")
-				return
+	/** Insertion Prioritization
+	 * Made for styles that should be inserted as prior, 
+	 * otherwise it will show visual styling lag if there is a transition CSS property)
+	 */
+	prioritized = false
+	insertChildAt(child: VChild, index: number) {
+		super.insertChildAt(child, index)
+		/* Bubble prioritization */
+		if (child instanceof VElement && child.prioritized) {
+			let parent: VParent | null = this
+			while (parent instanceof VElement && !parent.prioritized) {
+				parent.prioritized = true
+				parent = parent.parentNode
 			}
-			cb(this.node.sheet)
-		} else {
-		  this.stylesheetCallbacks.push(cb)
 		}
 	}
-}
-
-
-export class PostponedStyleSheet {
-	private loaded = false
-	private stylesheetCallbacks: StyleSheetCallback[] = []
-
-	constructor(private readonly node: StyleElement) {
-		node.onload = () => {
-		  const sheet = node.sheet
-		  if (sheet) {
-		    this.stylesheetCallbacks.forEach(cb => cb(sheet))
-		    this.stylesheetCallbacks = []
-		  } else {
-		    console.warn("Style node onload: sheet is null")
-		  }
-		  this.loaded = true
-		}
-	}
-
-	private applyCallback(cb: StyleSheetCallback) {
-		if (this.loaded) {
-			if (!this.node.sheet) {
-				console.warn("Style tag is loaded, but sheet is null")
-				return
+	private applyPrioritizedChanges() {
+		this.children.forEach(child => {
+			if (child instanceof VText) {
+				child.applyChanges()
+			} else if (child.prioritized) {
+				/* Update prioritized VElement-s */
+				child.applyPrioritizedChanges()
+				child.applyAttributeChanges()
 			}
-			cb(this.node.sheet)
-		} else {
-		  this.stylesheetCallbacks.push(cb)
-		}
-	}
-
-	insertRule(rule: string, index: number) {
-		this.applyCallback(s => insertRule(s, { rule, index }))
-	}
-
-	deleteRule(index: number) {
-		this.applyCallback(s => deleteRule(s, { index }))
+		})
+		this.mountChildren(child => child instanceof VText || child.prioritized)
 	}
 }
 
-export class VText {
+export class VHTMLElement extends VElement {
+	constructor(node: HTMLElement) {
+		super("HTML", false)
+		this.createNode = () => node
+	}
+}
+
+export class VText extends VNode<Text> {
 	parentNode: VParent | null = null
-	constructor(public readonly node: Text = new Text()) {}
+	protected createNode() {
+		return new Text()
+	}
+
 	private data: string = ""
 	private changed: boolean = false
 	setData(data: string) {
@@ -210,3 +226,112 @@ export class VText {
 	}
 }
 
+class PromiseQueue<T> {
+	constructor(private promise: Promise<T>) {}
+	/**
+	 * Call sequence is concerned.
+	 */
+	// Doing this with callbacks list instead might be more efficient (but more wordy). TODO: research
+	whenReady(cb: Callback<T>) {
+		this.promise = this.promise.then(vRoot => {
+			cb(vRoot)
+			return vRoot
+		})
+	}
+	catch(cb: Parameters<Promise<T>['catch']>[0]) {
+		this.promise.catch(cb)
+	}
+}
+
+/**
+ * VRoot wrapper that allows to defer all the API calls till the moment
+ * when VNode CAN be created (for example, on <iframe> mount&load)
+ */
+export class OnloadVRoot extends PromiseQueue<VRoot> {
+	static fromDocumentNode(doc: Document): OnloadVRoot {
+		return new OnloadVRoot(Promise.resolve(new VDocument(() => doc)))
+	}
+	static fromVElement(vElem: VElement): OnloadVRoot {
+		return new OnloadVRoot(new Promise((resolve, reject) => {
+			vElem.onNode(host => {
+				if (host instanceof HTMLIFrameElement) {
+					/* IFrame case: creating Document */
+					const doc = host.contentDocument
+					if (doc) {
+						resolve(new VDocument(() => doc))
+					} else {
+						host.addEventListener('load', () => {
+							const doc = host.contentDocument
+							if (doc) {
+								resolve(new VDocument(() => doc))
+							} else {
+								reject("No default Document found on iframe load") // Send `host` for logging as well
+							}
+						})
+					}
+				} else {
+				/* ShadowDom case */
+					try {
+						const shadowRoot = host.attachShadow({ mode: 'open' })
+						resolve(new VShadowRoot(() => shadowRoot))
+					} catch(e) {
+						reject(e) // "Can not attach shadow dom"
+					}
+				}
+			})
+		}))
+	}
+	onNode(cb: Callback<Document | ShadowRoot>) {
+		this.whenReady(vRoot => vRoot.onNode(cb))
+	}
+	applyChanges() {
+		this.whenReady(vRoot => vRoot.applyChanges())
+	}
+	insertChildAt(...args: Parameters<VParent['insertChildAt']>) {
+		this.whenReady(vRoot => vRoot.insertChildAt(...args))
+	}
+}
+
+export type StyleElement = HTMLStyleElement | SVGStyleElement
+
+/**
+ * CSSStyleSheet wrapper that collects all the insertRule/deleteRule calls 
+ * and then applies them when the sheet is ready
+ */
+export class OnloadStyleSheet extends PromiseQueue<CSSStyleSheet> {
+	static fromStyleElement(node: StyleElement) {
+		return new OnloadStyleSheet(new Promise((resolve, reject) => {
+			node.addEventListener("load", () => {
+				const sheet = node.sheet
+				if (sheet) {
+					resolve(sheet)
+				} else {
+					reject("Style node onload: sheet is null")
+				}
+			})
+		}))
+	}
+	static fromVRootContext(vRoot: OnloadVRoot) {
+		return new OnloadStyleSheet(new Promise((resolve, reject) => 
+			vRoot.onNode(node => {
+				let context: typeof globalThis | null
+				if (node instanceof Document || node.nodeName === '#document') {
+					context = node.defaultView
+				} else {
+					context = node.ownerDocument.defaultView
+				}
+				if (!context) { reject("Root node default view not found"); return }
+				/* a StyleSheet from another Window context won't work */
+				resolve(new context.CSSStyleSheet())
+			})
+		))
+	}
+
+	insertRule(rule: string, index: number) {
+		this.whenReady(s => insertRule(s, { rule, index }))
+	}
+
+	deleteRule(index: number) {
+		this.whenReady(s => deleteRule(s, { index }))
+	}
+}

frontend/app/player/web/managers/DOM/safeCSSRules.ts

@@ -1,14 +1,15 @@
 import logger from 'App/logger';
 
-export type { PostponedStyleSheet } from './VirtualDOM'
-
-export function insertRule(sheet: CSSStyleSheet | PostponedStyleSheet, msg: { rule: string, index: number }) {
+export function insertRule(
+  sheet: { insertRule: (rule: string, index: number) => void },
+  msg: { rule: string, index: number }
+) {
   try {
     sheet.insertRule(msg.rule, msg.index)
   } catch (e) {
     logger.warn(e, msg)
     try {
-      sheet.insertRule(msg.rule, 0)
+      sheet.insertRule(msg.rule, 0) // TODO: index renumeration in case of subsequent rule deletion
       logger.warn("Inserting rule into 0-index", e, msg)
     } catch (e) {
       logger.warn("Cannot insert rule.", e, msg)
@@ -16,7 +17,10 @@ export function insertRule(sheet: CSSStyleSheet | PostponedStyleSheet, msg: { ru
   }
 }
 
-export function deleteRule(sheet: CSSStyleSheet | PostponedStyleSheet, msg: { index: number }) {
+export function deleteRule(
+  sheet: { deleteRule: (index: number) => void },
+  msg: { index: number }
+) {
   try {
     sheet.deleteRule(msg.index)
   } catch (e) {

frontend/app/player/web/managers/PagesManager.ts

@@ -1,13 +1,21 @@
-import type Screen from '../Screen/Screen';
-import type { Message } from '../messages';
+import logger from 'App/logger';
 
-import { MType } from '../messages';
+import type Screen from '../Screen/Screen';
+import type { Message, StringDict } from '../messages';
+
+import { MType} from '../messages';
 import ListWalker from '../../common/ListWalker';
 import DOMManager from './DOM/DOMManager'; 
 
 
 export default class PagesManager extends ListWalker<DOMManager> {
 	private currentPage: DOMManager | null = null
+	/**
+	 * String Dictionary in tracker may be desync with CreateDocument (why???) 
+	 * e.g. some StringDictionary and other messages before any 'CreateDocument' one
+	 * TODO: understand why and fix
+	 */
+	private currentStringDict: Record<number, string> = {}
 
 	constructor(
 		private screen: Screen,
@@ -19,11 +27,19 @@ export default class PagesManager extends ListWalker<DOMManager> {
 		Assumed that messages added in a correct time sequence.
 	*/
 	appendMessage(m: Message): void {
+		if (m.tp === MType.StringDict) {
+			if (this.currentStringDict[m.key] !== undefined) {
+				this.currentStringDict = {} /* refresh stringDict */
+				this.last?.setStringDict(this.currentStringDict)
+			}
+			this.currentStringDict[m.key] = m.value
+			return
+		}
 		if (m.tp === MType.CreateDocument) {
-			super.append(new DOMManager(this.screen, this.isMobile, m.time, this.setCssLoading))
+			super.append(new DOMManager(this.screen, this.isMobile, this.currentStringDict, m.time, this.setCssLoading))
 		}
 		if (this.last === null) {
-			// Log wrong
+			logger.warn("DOMMessage before any document created, skipping:", m)
 			return;
 		}
 		this.last.append(m)

frontend/app/player/web/managers/PerformanceTrackManager.ts

@@ -15,9 +15,9 @@ export default class PerformanceTrackManager extends ListWalker<PerformanceTrack
 	private chart: Array<PerformanceChartPoint> = [];
 	private isHidden: boolean = false;
 	private timeCorrection: number = 0;
-	private heapAvaliable: boolean = false;
-	private fpsAvaliable: boolean = false;
-	private cpuAvaliable: boolean = false;
+	private heapAvailable: boolean = false;
+	private fpsAvailable: boolean = false;
+	private cpuAvailable: boolean = false;
 	private prevTime: number | null = null;
 	private prevNodesCount: number = 0;
 
@@ -29,7 +29,7 @@ export default class PerformanceTrackManager extends ListWalker<PerformanceTrack
 			let timePassed = msg.time - this.prevTime + this.timeCorrection;
 
 			if (timePassed > 0 && msg.frames >= 0) {
-				if (msg.frames > 0) { this.fpsAvaliable = true; }
+				if (msg.frames > 0) { this.fpsAvailable = true; }
 				fps = msg.frames*1e3/timePassed; // Multiply by 1e3 as time in ms;
 				fps = Math.min(fps,60); // What if 120?  TODO: alert if more than 60
 				if (this.chart.length === 1) {
@@ -38,7 +38,7 @@ export default class PerformanceTrackManager extends ListWalker<PerformanceTrack
 			}
 
 			if (timePassed > 0 && msg.ticks >= 0) {
-				this.cpuAvaliable = true;
+				this.cpuAvailable = true;
 				let tickRate = msg.ticks * 30 / timePassed;
 				if (tickRate > 1) {
 					tickRate = 1;
@@ -53,7 +53,7 @@ export default class PerformanceTrackManager extends ListWalker<PerformanceTrack
 		this.prevTime = msg.time;
 		this.timeCorrection = 0
 
-		this.heapAvaliable = this.heapAvaliable || msg.usedJSHeapSize > 0;
+		this.heapAvailable = this.heapAvailable || msg.usedJSHeapSize > 0;
 		this.chart.push({
 			usedHeap: msg.usedJSHeapSize,
 			totalHeap: msg.totalJSHeapSize,
@@ -109,11 +109,11 @@ export default class PerformanceTrackManager extends ListWalker<PerformanceTrack
 		return this.chart;
 	}
 
-	get avaliability(): { cpu: boolean, fps: boolean, heap: boolean, nodes: boolean } {
+	get availability(): { cpu: boolean, fps: boolean, heap: boolean, nodes: boolean } {
 		return {
-			cpu: this.cpuAvaliable,
-			fps: this.fpsAvaliable,
-			heap: this.heapAvaliable,
+			cpu: this.cpuAvailable,
+			fps: this.fpsAvailable,
+			heap: this.heapAvailable,
 			nodes: true,
 		}
 	}

frontend/app/player/web/messages/rewriter/rewriteMessage.ts

@@ -15,6 +15,18 @@ import { MType } from '../raw.gen'
 import { resolveURL, resolveCSS } from './urlResolve'
 import { HOVER_CLASSNAME, FOCUS_CLASSNAME } from './constants'
 
+/* maybetodo:  filter out non-relevant  prefixes in CSS-rules. 
+   They might cause an error in console, but not sure if it breaks the replay.
+   (research required)
+*/
+// function replaceCSSPrefixes(css: string) {
+//   return css
+//     .replace(/\-ms\-/g, "")
+//     .replace(/\-webkit\-/g, "")
+//     .replace(/\-moz\-/g, "")
+//     .replace(/\-webkit\-/g, "")
+// }
+
 const HOVER_SELECTOR = `.${HOVER_CLASSNAME}`
 const FOCUS_SELECTOR = `.${FOCUS_CLASSNAME}`
 export function replaceCSSPseudoclasses(cssText: string): string {

frontend/app/player/web/network/loadFiles.ts

@@ -8,15 +8,16 @@ export const NO_URLS = 'No-urls-provided'
 export async function loadFiles(
   urls: string[],
   onData: (data: Uint8Array) => void,
-): Promise<any> {
+  canSkip: boolean = false,
+): Promise<void> {
   if (!urls.length) {
     throw NO_URLS
   }
   try {
     for (let url of urls) {
       const response = await window.fetch(url)
-      const data = await processAPIStreamResponse(response, url !== url[0])
-      onData(data)
+      const data = await processAPIStreamResponse(response, urls.length > 1 ? url !== urls[0] : canSkip)
+      await onData(data)
     }
   } catch(e) {
     if (e === ALLOWED_404) {

frontend/app/utils/search.ts

@@ -1,7 +1,7 @@
 import { getFilterKeyTypeByKey, setQueryParamKeyFromFilterkey } from 'Types/filter/filterType';
-import Period, { LAST_24_HOURS, LAST_7_DAYS, LAST_30_DAYS, CUSTOM_RANGE } from 'Types/app/period';
+import Period, { CUSTOM_RANGE } from 'Types/app/period';
 import Filter from 'Types/filter/filter';
-import { filtersMap } from 'App/types/filter/newFilter';
+import { filtersMap } from 'Types/filter/newFilter';
 
 export const createUrlQuery = (filter: any) => {
   const query = [];
@@ -83,13 +83,13 @@ const getFiltersFromEntries = (entires: any) => {
       filter.operator = operator;
       if (filter.icon === "filters/metadata") {
         filter.source = filter.type;
-        filter.type = 'METADATA';
+        filter.type = 'MULTIPLE';
       } else {
         filter.source = sourceArr && sourceArr.length > 0 ? sourceArr : null;
         filter.sourceOperator = !!sourceOperator ? decodeURI(sourceOperator) : null;
       }
       
-      if (!filter.filters || filter.filters.size === 0) {
+      if (!filter.filters || filter.filters.size === 0) { // TODO support subfilters in url
         filters.push(filter);
       }
     });

frontend/build.sh

@@ -20,7 +20,9 @@ check_prereq() {
 chart=frontend
 [[ $1 == ee ]] && ee=true
 [[ $PATCH -eq 1 ]] && {
-  image_tag="$(grep -ER ^.ppVersion ../scripts/helmcharts/openreplay/charts/$chart | xargs | awk '{print $2}'  | awk -F. -v OFS=. '{$NF += 1 ; print}')"
+  __app_version="$(grep -ER ^.ppVersion ../scripts/helmcharts/openreplay/charts/${chart} | xargs | awk '{print $2}'  | awk -F. -v OFS=. '{$NF += 1 ; print}' | cut -d 'v' -f2)"
+  sed -i "s/^VERSION = .*/VERSION = $__app_version/g" .env.sample
+  image_tag="v${__app_version}"
   [[ $ee == "true" ]] && { 
     image_tag="${image_tag}-ee"
   }
@@ -30,8 +32,9 @@ update_helm_release() {
   # Update the chart version
   sed -i "s#^version.*#version: $HELM_TAG# g" ../scripts/helmcharts/openreplay/charts/$chart/Chart.yaml
   # Update image tags
-  sed -i "s#ppVersion.*#ppVersion: \"$image_tag\"#g" ../scripts/helmcharts/openreplay/charts/$chart/Chart.yaml
+  sed -i "s#ppVersion.*#ppVersion: \"v${__app_version}\"#g" ../scripts/helmcharts/openreplay/charts/$chart/Chart.yaml
   # Commit the changes
+  git add .env.sample
   git add ../scripts/helmcharts/openreplay/charts/$chart/Chart.yaml
   git commit -m "chore(helm): Updating $chart image release"
 }

scripts/helmcharts/databases/charts/clickhouse/values.yaml

@@ -84,4 +84,4 @@ nodeSelector: {}
 tolerations: []
 
 affinity: {}
-storageSize: 100G
+storageSize: 100Gi

scripts/helmcharts/openreplay-cli

@@ -5,10 +5,6 @@ OR_DIR="/var/lib/openreplay"
 APP_NS="${APP_NS:-app}"
 DB_NS="${DB_NS:-db}"
 OR_REPO="https://github.com/openreplay/openreplay"
-# To run kubeconfig run
-# `KUBECONFIG=/path/to/file openreplay -s`
-export KUBECONFIG=${KUBECONFIG:-"/etc/rancher/k3s/k3s.yaml"}
-tmp_dir=$(mktemp -d)
 # For example HELM_OPTIONS="--set dbMigrationUpstreamBranch=dev"
 #HELM_OPTIONS=""
 # If you want to install the dev version. It can be any branch or tag.
@@ -79,6 +75,14 @@ function log () {
   exit 100
 }
 
+# To run kubeconfig run
+# `KUBECONFIG=/path/to/file openreplay -s`
+[[ -f /etc/rancher/k3s/k3s.yaml ]] && k3s_path="/etc/rancher/k3s/k3s.yaml"
+[[ -f "${HOME}/.kube/config" ]] && local_kube_config_path="${HOME}/.kube/config"
+export KUBECONFIG=${KUBECONFIG:-$k3s_path:$local_kube_config_path}
+[[ -z $KUBECONFIG ]] && log err "No kubeconfig file found. Exiting"
+tmp_dir=$(mktemp -d)
+
 function install_packages() {
 
   [[ -e "$OR_DIR/eget" ]] || {
@@ -117,11 +121,11 @@ cat <<"EOF"
 EOF
 echo -e ${NC}
 
-log info '
+log info "
   Usage: openreplay [ -h | --help ]
                     [ -s | --status ]
                     [ -i | --install DOMAIN_NAME ]
-                    [ -u | --upgrade ]
+                    [ -u | --upgrade (fetch lastest patches for installed release. ${BWHITE}RELEASE_UPGRADE=1 openreplay -u${GREEN} to upgrade release.)]
                     [ -U | --deprecated-upgrade /path/to/old_vars.yaml]
                     [ -r | --restart ]
                     [ -R | --Reload ]
@@ -133,7 +137,7 @@ log info '
                    db ender frontend heuristics 
                    http integrations nginx-controller 
                    peers sink sourcemapreader storage 
-    '
+    "
   return
 }
 
@@ -186,6 +190,12 @@ function or_helm_upgrade() {
 
 function upgrade_old() {
   old_vars_path="$1"
+  [[ -f $old_vars_path ]] || log err "No configuration file ${BWHITE}$old_vars_path${RED}.
+          If you're updating from version older than ${BWHITE}v1.10.0${RED}, for example ${BWHITE}v1.9.0${RED}:
+            ${BWHITE}openreplay --deprecated-upgrade ~/openreplay_v1.9.0/scripts/helmcharts/vars.yaml${RED}.
+          If you're having a custom installation,
+            ${BWHITE}openreplay --deprecated-upgrade /path/to/vars.yaml${RED}.
+          "
   or_version=$(busybox awk '/fromVersion/{print $2}' < "${old_vars_path}")
   sudo cp "${old_vars_path}" ${OR_DIR}/vars.yaml.backup."${or_version//\"}"_"$(date +%Y%m%d-%H%M%S)" || log err "Not able to copy old vars.yaml"
   sudo cp "${old_vars_path}" ${OR_DIR}/vars.yaml || log err "Not able to copy old vars.yaml"
@@ -266,14 +276,24 @@ function upgrade() {
   # 3. How to update package. Because openreplay -u will be done from old update script
   # 4. Update from Version
   exists git || log err "Git not found. Please install"
+  [[ -f ${OR_DIR}/vars.yaml ]] || log err "No configuration file ${BWHITE}${OR_DIR}/vars.yaml${RED}.
+        If you're updating from version older than ${BWHITE}v1.10.0${RED}, for example ${BWHITE}v1.9.0${RED}:
+          ${BWHITE}openreplay --deprecated-upgrade ~/openreplay_v1.9.0/scripts/helmcharts/vars.yaml${RED}.
+        If you're having a custom installation,
+          ${BWHITE}openreplay --deprecated-upgrade /path/to/vars.yaml${RED}.
+        "
   or_version=$(busybox awk '/fromVersion/{print $2}' < "${OR_DIR}/vars.yaml") || {
     log err "${BWHITE}${OR_DIR}/vars.yaml${RED} not found. 
         Please do ${BWHITE}openreplay --deprecated-upgrade /path/to/vars.yaml${RED}
       "
   }
 
+  # Unless its upgrade release, always checkout same tag.
+  [[ $RELEASE_UPGRADE -eq 1 ]] || OR_VERSION=$or_version
+
+  time_now=$(date +%m-%d-%Y-%I%M%S)
   # Creating backup dir of current installation
-  [[ -d "$OR_DIR/openreplay" ]] && sudo cp -rfb "$OR_DIR/openreplay" "$OR_DIR/openreplay_${or_version//\"}" && sudo rm -rf ${OR_DIR}/openreplay
+  [[ -d "$OR_DIR/openreplay" ]] && sudo mv "$OR_DIR/openreplay" "$OR_DIR/openreplay_${or_version//\"}_${time_now}"
 
   clone_repo
   err_cd openreplay/scripts/helmcharts
@@ -345,7 +365,11 @@ do
       exit 0
       ;;
     -u | --upgrade)
-      log title "Upgrading OpenReplay"
+      if [[ $RELEASE_UPGRADE -eq 1 ]]; then
+        log title "Upgrading OpenReplay to Latest Release"
+      else
+        log title "Applying Latest OpenReplay Patches"
+      fi
       upgrade
       clean_tmp_dir
       exit 0
@@ -391,7 +415,7 @@ do
         clean_tmp_dir
         exit 100
       }
-      if /var/lib/openreplay/busybox md5sum -c "${tmp_dir}/var.yaml.md5"; then
+      if /var/lib/openreplay/busybox md5sum -c "${tmp_dir}/var.yaml.md5" &> /dev/null; then
         log info "No change detected in ${BWHITE}${OR_DIR}/vars.yaml${GREEN}. Not reloading"
       else
         reload

scripts/helmcharts/openreplay/charts/alerts/templates/deployment.yaml

@@ -48,7 +48,7 @@ spec:
             - name: pg_host
               value: '{{ .Values.global.postgresql.postgresqlHost }}'
             - name: pg_port
-              value: "5432"
+              value: '{{ .Values.global.postgresql.postgresqlPort }}' 
             - name: pg_dbname
               value: "{{ .Values.global.postgresql.postgresqlDatabase }}"
             - name: ch_host

scripts/helmcharts/openreplay/charts/assets/templates/deployment.yaml

@@ -43,6 +43,14 @@ spec:
           {{- .Values.healthCheck | toYaml | nindent 10}}
           {{- end}}
           env:
+            {{- range $key, $val := .Values.env }}
+            - name: {{ $key }}
+              value: '{{ $val }}'
+            {{- end}}
+            {{- range $key, $val := .Values.global.env }}
+            - name: {{ $key }}
+              value: '{{ $val }}'
+            {{- end }}
             - name: AWS_ACCESS_KEY_ID
               {{- if .Values.global.s3.existingSecret }}
               valueFrom:
@@ -94,14 +102,6 @@ spec:
               value: '{{ .Values.global.s3.endpoint }}/{{.Values.global.s3.assetsBucket}}'
             {{- end }}
             {{- include "openreplay.env.redis_string" .Values.global.redis | nindent 12 }}
-            {{- range $key, $val := .Values.global.env }}
-            - name: {{ $key }}
-              value: '{{ $val }}'
-            {{- end }}
-            {{- range $key, $val := .Values.env }}
-            - name: {{ $key }}
-              value: '{{ $val }}'
-            {{- end}}
           ports:
             {{- range $key, $val := .Values.service.ports }}
             - name: {{ $key }}

scripts/helmcharts/openreplay/charts/chalice/Chart.yaml

@@ -15,10 +15,10 @@ type: application
 # This is the chart version. This version number should be incremented each time you make changes
 # to the chart and its templates, including the app version.
 # Versions are expected to follow Semantic Versioning (https://semver.org/)
-version: 0.1.7
+version: 0.1.12
 
 # This is the version number of the application being deployed. This version number should be
 # incremented each time you make changes to the application. Versions are not expected to
 # follow Semantic Versioning. They should reflect the version the application is using.
 # It is recommended to use it with quotes.
-AppVersion: "v1.11.7"
+AppVersion: "v1.11.12"

scripts/helmcharts/openreplay/charts/chalice/templates/deployment.yaml

@@ -43,10 +43,9 @@ spec:
           {{- .Values.healthCheck | toYaml | nindent 10}}
           {{- end}}
           env:
+            {{- include "openreplay.env.redis_string" .Values.global.redis | nindent 12 }}
             - name: KAFKA_SERVERS
               value: "{{ .Values.global.kafka.kafkaHost }}"
-            - name: REDIS_STRING
-              value: "{{ .Values.global.redis.redisHost }}"
             - name: ch_username
               value: "{{ .Values.global.clickhouse.username }}"
             - name: ch_password
@@ -114,6 +113,8 @@ spec:
               value: '{{ .Values.global.s3.region }}'
             - name: sessions_region
               value: '{{ .Values.global.s3.region }}' 
+            - name: ASSIST_RECORDS_BUCKET
+              value: {{ .Values.global.s3.assistRecordsBucket }}
             - name: sessions_bucket
               value: {{ .Values.global.s3.recordingsBucket }}
             - name: sourcemaps_bucket

scripts/helmcharts/openreplay/charts/db/templates/deployment.yaml

@@ -44,7 +44,7 @@ spec:
           {{- end}}
           env:
             - name: CH_USERNAME
-              value: '{{ .Values.global.clickhouse.userame }}'
+              value: '{{ .Values.global.clickhouse.username }}'
             - name: CH_PASSWORD
               value: '{{ .Values.global.clickhouse.password }}'
             - name: CLICKHOUSE_STRING

scripts/helmcharts/openreplay/charts/ender/Chart.yaml

@@ -15,10 +15,10 @@ type: application
 # This is the chart version. This version number should be incremented each time you make changes
 # to the chart and its templates, including the app version.
 # Versions are expected to follow Semantic Versioning (https://semver.org/)
-version: 0.1.1
+version: 0.1.2
 
 # This is the version number of the application being deployed. This version number should be
 # incremented each time you make changes to the application. Versions are not expected to
 # follow Semantic Versioning. They should reflect the version the application is using.
 # It is recommended to use it with quotes.
-AppVersion: "v1.11.1"
+AppVersion: "v1.11.2"

scripts/helmcharts/openreplay/charts/frontend/Chart.yaml

@@ -15,10 +15,10 @@ type: application
 # This is the chart version. This version number should be incremented each time you make changes
 # to the chart and its templates, including the app version.
 # Versions are expected to follow Semantic Versioning (frontends://semver.org/)
-version: 0.1.7
+version: 0.1.14
 
 # This is the version number of the application being deployed. This version number should be
 # incremented each time you make changes to the application. Versions are not expected to
 # follow Semantic Versioning. They should reflect the version the application is using.
 # It is recommended to use it with quotes.
-AppVersion: "v1.11.6"
+AppVersion: "v1.11.13"

scripts/helmcharts/openreplay/charts/http/templates/deployment.yaml

@@ -43,6 +43,14 @@ spec:
           {{- .Values.healthCheck | toYaml | nindent 10}}
           {{- end}}
           env:
+            {{- range $key, $val := .Values.env }}
+            - name: {{ $key }}
+              value: '{{ $val }}'
+            {{- end}}
+            {{- range $key, $val := .Values.global.env }}
+            - name: {{ $key }}
+              value: '{{ $val }}'
+            {{- end }}
             - name: AWS_ACCESS_KEY_ID
               {{- if .Values.global.s3.existingSecret }}
               valueFrom:
@@ -101,14 +109,6 @@ spec:
               value: '{{ .Values.global.s3.endpoint }}/{{.Values.global.s3.assetsBucket}}'
             {{- end }}
             {{- include "openreplay.env.redis_string" .Values.global.redis | nindent 12 }}
-            {{- range $key, $val := .Values.global.env }}
-            - name: {{ $key }}
-              value: '{{ $val }}'
-            {{- end }}
-            {{- range $key, $val := .Values.env }}
-            - name: {{ $key }}
-              value: '{{ $val }}'
-            {{- end}}
           ports:
             {{- range $key, $val := .Values.service.ports }}
             - name: {{ $key }}

scripts/helmcharts/openreplay/charts/sink/templates/deployment.yaml

@@ -43,6 +43,14 @@ spec:
           {{- .Values.healthCheck | toYaml | nindent 10}}
           {{- end}}
           env:
+            {{- range $key, $val := .Values.env }}
+            - name: {{ $key }}
+              value: '{{ $val }}'
+            {{- end}}
+            {{- range $key, $val := .Values.global.env }}
+            - name: {{ $key }}
+              value: '{{ $val }}'
+            {{- end }}
             - name: LICENSE_KEY
               value: '{{ .Values.global.enterpriseEditionLicense }}'
             - name: KAFKA_SERVERS
@@ -70,14 +78,6 @@ spec:
               value: '{{ .Values.global.s3.endpoint }}/{{.Values.global.s3.assetsBucket}}'
             {{- end }}
             {{- include "openreplay.env.redis_string" .Values.global.redis | nindent 12 }}
-            {{- range $key, $val := .Values.global.env }}
-            - name: {{ $key }}
-              value: '{{ $val }}'
-            {{- end }}
-            {{- range $key, $val := .Values.env }}
-            - name: {{ $key }}
-              value: '{{ $val }}'
-            {{- end}}
           ports:
             {{- range $key, $val := .Values.service.ports }}
             - name: {{ $key }}

scripts/helmcharts/openreplay/charts/sourcemapreader/templates/deployment.yaml

@@ -43,6 +43,14 @@ spec:
           {{- .Values.healthCheck | toYaml | nindent 10}}
           {{- end}}
           env:
+            {{- range $key, $val := .Values.env }}
+            - name: {{ $key }}
+              value: '{{ $val }}'
+            {{- end}}
+            {{- range $key, $val := .Values.global.env }}
+            - name: {{ $key }}
+              value: '{{ $val }}'
+            {{- end }}
             - name: AWS_ACCESS_KEY_ID
               value: {{ .Values.global.s3.accessKey }}
             - name: AWS_SECRET_ACCESS_KEY
@@ -51,8 +59,7 @@ spec:
               value: '{{ .Values.global.s3.region }}'
             - name: LICENSE_KEY
               value: '{{ .Values.global.enterpriseEditionLicense }}'
-            - name: REDIS_STRING
-              value: '{{ .Values.global.redis.redisHost }}:{{ .Values.global.redis.redisPort }}'
+            {{- include "openreplay.env.redis_string" .Values.global.redis | nindent 12 }}
             - name: KAFKA_SERVERS
               value: '{{ .Values.global.kafka.kafkaHost }}:{{ .Values.global.kafka.kafkaPort }}'
             - name: KAFKA_USE_SSL
@@ -79,14 +86,6 @@ spec:
               # S3 compatible storage
               value: '{{ .Values.global.s3.endpoint }}/{{.Values.global.s3.assetsBucket}}'
             {{- end }}
-            {{- range $key, $val := .Values.global.env }}
-            - name: {{ $key }}
-              value: '{{ $val }}'
-            {{- end }}
-            {{- range $key, $val := .Values.env }}
-            - name: {{ $key }}
-              value: '{{ $val }}'
-            {{- end}}
           ports:
             {{- range $key, $val := .Values.service.ports }}
             - name: {{ $key }}

scripts/helmcharts/openreplay/charts/storage/Chart.yaml

@@ -15,10 +15,10 @@ type: application
 # This is the chart version. This version number should be incremented each time you make changes
 # to the chart and its templates, including the app version.
 # Versions are expected to follow Semantic Versioning (https://semver.org/)
-version: 0.1.1
+version: 0.1.2
 
 # This is the version number of the application being deployed. This version number should be
 # incremented each time you make changes to the application. Versions are not expected to
 # follow Semantic Versioning. They should reflect the version the application is using.
 # It is recommended to use it with quotes.
-AppVersion: "v1.11.1"
+AppVersion: "v1.11.2"

scripts/helmcharts/openreplay/templates/_helpers.tpl

@@ -65,6 +65,7 @@ Create the name of the service account to use
 Create the environment configuration for REDIS_STRING
 */}}
 {{- define "openreplay.env.redis_string" -}}
+{{- if .enabled }}
 {{- $scheme := (eq (.tls | default dict).enabled true) | ternary "rediss" "redis" -}}
 {{- $auth := "" -}}
 {{- if or .existingSecret .redisPassword -}}
@@ -83,6 +84,7 @@ Create the environment configuration for REDIS_STRING
 - name: REDIS_STRING
   value: '{{ $scheme }}://{{ $auth }}{{ .redisHost }}:{{ .redisPort }}'
 {{- end }}
+{{- end }}
 
 {{/*
 Create the volume mount config for redis TLS certificates

scripts/helmcharts/vars.yaml

@@ -50,7 +50,7 @@ kafka: &kafka
     #   value: "3000000"
 
 redis: &redis
-  # enabled: false
+  enabled: true
   redisHost: "redis-master.db.svc.cluster.local"
   redisPort: "6379"
 
@@ -117,6 +117,7 @@ global:
     assetsBucket: "sessions-assets"
     recordingsBucket: "mobs"
     sourcemapsBucket: "sourcemaps"
+    assistRecordsBucket: "records"
     vaultBucket: "vault-data"
     # This is only for enterpriseEdition
     quickwitBucket: "quickwit"