Drop fix-s3-oplog command related to unsupported ClickHouse feature s…

…end_metadata (#41)

ch_backup/ch_backup.py

@@ -27,7 +27,6 @@
     TerminatingSignal,
 )
 from ch_backup.logic.access import AccessBackup
-from ch_backup.logic.cloud_storage_utils import fix_s3_oplog
 from ch_backup.logic.database import DatabaseBackup
 from ch_backup.logic.table import TableBackup
 from ch_backup.logic.udf import UDFBackup
@@ -299,32 +298,6 @@ def restore(
                 keep_going=keep_going,
             )
 
-    # pylint: disable=too-many-nested-blocks,too-many-branches
-    def fix_s3_oplog(
-        self,
-        source_cluster_id: str = None,
-        shard: str = None,
-        cloud_storage_source_bucket: str = None,
-        cloud_storage_source_path: str = None,
-        dryrun: bool = False,
-    ) -> None:
-        """
-        Fix S3 operations log.
-        """
-        if not self._context.config.get("cloud_storage"):
-            return
-
-        fix_s3_oplog(
-            self._context.config["cloud_storage"],
-            source_cluster_id
-            if source_cluster_id
-            else self._context.config["restore_from"]["cid"],
-            shard if shard else self._context.config["restore_from"]["shard_name"],
-            cloud_storage_source_bucket,
-            cloud_storage_source_path,
-            dryrun,
-        )
-
     def delete(
         self, backup_name: str, purge_partial: bool
     ) -> Tuple[Optional[str], Optional[str]]:

ch_backup/cli.py

@@ -703,39 +703,6 @@ def restore_command(
     )
 
 
-@command(name="fix-s3-oplog")
-@option(
-    "--cloud-storage-source-bucket",
-    type=str,
-    help="Source bucket name to restore cloud storage data.",
-)
-@option(
-    "--cloud-storage-source-path",
-    type=str,
-    help="Source path to restore cloud storage data.",
-)
-@option("--source-cluster-id", type=str, help="Source cluster ID.")
-@option("--shard", type=str, default="shard1", help="Shard name.")
-@option("--dryrun", is_flag=True, default=False, help="Do not perform any actions.")
-def fix_s3_oplog_command(
-    _ctx: Context,
-    ch_backup: ClickhouseBackup,
-    cloud_storage_source_bucket: str = None,
-    cloud_storage_source_path: str = None,
-    source_cluster_id: str = None,
-    shard: str = "shard1",
-    dryrun: bool = False,
-) -> None:
-    """Fix S3 operations log."""
-    ch_backup.fix_s3_oplog(
-        source_cluster_id,
-        shard,
-        cloud_storage_source_bucket,
-        cloud_storage_source_path,
-        dryrun,
-    )
-
-
 @command(name="restore-access-control")  # type: ignore
 @argument("name", metavar="BACKUP")
 def restore_access_control_command(