From 5a95e7e4f2b9854c7645c3a597d227db5b3e8fc6 Mon Sep 17 00:00:00 2001
From: =?UTF-8?q?Karolis=20Gudi=C5=A1kis?= <karolisgud@gmail.com>
Date: Wed, 24 Jan 2024 15:01:11 +0200
Subject: [PATCH] Dont store . in prefix

---
 dozer-ingestion/mysql/src/binlog.rs    | 10 ++++++----
 dozer-ingestion/mysql/src/connector.rs |  2 +-
 2 files changed, 7 insertions(+), 5 deletions(-)

diff --git a/dozer-ingestion/mysql/src/binlog.rs b/dozer-ingestion/mysql/src/binlog.rs
index 029a6cf91f..a81a6a6fff 100644
--- a/dozer-ingestion/mysql/src/binlog.rs
+++ b/dozer-ingestion/mysql/src/binlog.rs
@@ -76,7 +76,7 @@ pub async fn get_master_binlog_position(
     })?;
 
     Ok((
-        format!("{prefix}."),
+        prefix.to_string(),
         BinlogPosition {
             binlog_id,
             position,
@@ -140,8 +140,10 @@ impl BinlogIngestor<'_, '_, '_> {
     }
 
     async fn open_binlog(&mut self) -> Result<(), MySQLConnectorError> {
-        let filename_formatted =
-            format!("{}{:0>6}", self.binlog_prefix, self.next_position.binlog_id);
+        let filename_formatted = format!(
+            "{}.{:0>6}",
+            self.binlog_prefix, self.next_position.binlog_id
+        );
         let filename = filename_formatted.as_bytes();
         let binlog_stream = self
             .connect()
@@ -249,7 +251,7 @@ impl BinlogIngestor<'_, '_, '_> {
                             seq_no: 0,
                         };
 
-                        self.binlog_prefix = format!("{prefix}.");
+                        self.binlog_prefix = prefix.to_string();
                         self.open_binlog().await?;
                     }
 
diff --git a/dozer-ingestion/mysql/src/connector.rs b/dozer-ingestion/mysql/src/connector.rs
index 5dc077fe78..818df5bc6c 100644
--- a/dozer-ingestion/mysql/src/connector.rs
+++ b/dozer-ingestion/mysql/src/connector.rs
@@ -281,7 +281,7 @@ impl MySQLConnector {
                     return Err(MySQLConnectorError::MultipleBinlogsWithSameSuffix);
                 }
 
-                prefix = Some(binlog_id[..(binlog_id.len() - 6)].to_string());
+                prefix = Some(binlog_id[..(binlog_id.len() - 7)].to_string());
             }
         }