feat: do not use sequence number as record start time

resolve #202

src/blrec/hls/operators/segment_dumper.py

@@ -1,5 +1,4 @@
 import io
-from datetime import datetime, timedelta, timezone
 from pathlib import PurePath
 from typing import Callable, Optional, Tuple, Union
 
@@ -10,7 +9,6 @@
 
 from blrec.utils.ffprobe import ffprobe
 
-from ..helpler import sequence_number_of
 from .segment_fetcher import InitSectionData, SegmentData
 
 __all__ = ('SegmentDumper',)
@@ -29,7 +27,6 @@ def _reset(self) -> None:
         self._path: str = ''
         self._file: Optional[io.BufferedWriter] = None
         self._filesize: int = 0
-        self._record_start_time: Optional[int] = None
 
     @property
     def path(self) -> str:
@@ -39,10 +36,6 @@ def path(self) -> str:
     def filesize(self) -> int:
         return self._filesize
 
-    @property
-    def record_start_time(self) -> Optional[int]:
-        return self._record_start_time
-
     @property
     def file_opened(self) -> Observable[Tuple[str, int]]:
         return self._file_opened
@@ -57,8 +50,7 @@ def __call__(
         return self._dump(source)
 
     def _open_file(self) -> None:
-        assert self._record_start_time is not None
-        path, timestamp = self._path_provider(self._record_start_time)
+        path, timestamp = self._path_provider()
         self._path = str(PurePath(path).with_suffix('.m4s'))
         self._file = open(self._path, 'wb')  # type: ignore
         logger.debug(f'Opened file: {self._path}')
@@ -80,13 +72,6 @@ def _write_data(self, item: Union[InitSectionData, SegmentData]) -> Tuple[int, i
     def _update_filesize(self, size: int) -> None:
         self._filesize += size
 
-    def _set_record_start_time(self, item: Union[InitSectionData, SegmentData]) -> None:
-        seq = sequence_number_of(item.segment.uri)
-        dt = datetime.utcfromtimestamp(seq)
-        tz = timezone(timedelta(hours=8))
-        ts = dt.replace(year=datetime.today().year, tzinfo=tz).timestamp()
-        self._record_start_time = int(ts)
-
     def _must_split_file(
         self, prev_init_item: Optional[InitSectionData], curr_init_item: InitSectionData
     ) -> bool:
@@ -159,7 +144,6 @@ def on_next(item: Union[InitSectionData, SegmentData]) -> None:
                 if split_file:
                     self._close_file()
                     self._reset()
-                    self._set_record_start_time(item)
                     self._open_file()
 
                 try: