file-mode-api: uri make connectors pass the relative path of the file in the source rather the file to use the uri

Author: aldogonzalez8

airbyte_cdk/sources/file_based/file_based_stream_reader.py

@@ -178,21 +178,16 @@ def upload(
 
     def _get_file_transfer_paths(
         self,
-        file: RemoteFile,
-        local_directory: str,
-        parse_file_path_from_uri: Optional[Callable[[str], str]] = None,
+        source_file_relative_path: str,
+        local_directory: str
     ) -> MutableMapping[str, Any]:
         preserve_directory_structure = self.preserve_directory_structure()
-        if not parse_file_path_from_uri:
-            file_path = file.uri
-        else:
-            file_path = parse_file_path_from_uri(file.uri)
 
-        file_name = path.basename(file_path)
-        file_folder = path.dirname(file_path)
+        file_name = path.basename(source_file_relative_path)
+        file_folder = path.dirname(source_file_relative_path)
         if preserve_directory_structure:
             # Remove left slashes from source path format to make relative path for writing locally
-            file_relative_path = file_path.lstrip("/")
+            file_relative_path = source_file_relative_path.lstrip("/")
         else:
             file_relative_path = file_name
         local_file_path = path.join(local_directory, file_relative_path)
@@ -203,7 +198,6 @@ def _get_file_transfer_paths(
             self.FILE_RELATIVE_PATH: file_relative_path,
             self.LOCAL_FILE_PATH: local_file_path,
             self.FILE_NAME: file_name,
-            self.FILE_FOLDER: file_folder,
-            self.SOURCE_FILE_URI: file.uri,
+            self.FILE_FOLDER: file_folder
         }
         return file_paths

unit_tests/sources/file_based/test_file_based_stream_reader.py

@@ -384,7 +384,7 @@ def test_globs_and_prefixes_from_globs(
 
 
 @pytest.mark.parametrize(
-    "config, source_file, expected_file_relative_path, expected_local_file_path",
+    "config, source_file_path, expected_file_relative_path, expected_local_file_path",
     [
         pytest.param(
             {
@@ -430,23 +430,21 @@ def test_globs_and_prefixes_from_globs(
 )
 def test_preserve_sub_directories_scenarios(
     config: Mapping[str, Any],
-    source_file: str,
+    source_file_path: str,
     expected_file_relative_path: str,
     expected_local_file_path: str,
 ) -> None:
-    remote_file = RemoteFile(
-        uri=source_file,
-        last_modified=datetime(2025, 1, 9, 11, 27, 20),
-        mime_type=None,
-    )
+    """
+    Test scenarios when preserve_directory_structure is True or False, the flag indicates whether we need to
+    use a relative path to upload the file or simply place it in the root.
+    """
     reader = TestStreamReader()
     reader.config = TestSpec(**config)
-    file_paths = reader._get_file_transfer_paths(remote_file, "/tmp/transfer-files/")
+    file_paths = reader._get_file_transfer_paths(source_file_path, "/tmp/transfer-files/")
 
     assert (
         file_paths[AbstractFileBasedStreamReader.FILE_RELATIVE_PATH] == expected_file_relative_path
     )
     assert file_paths[AbstractFileBasedStreamReader.LOCAL_FILE_PATH] == expected_local_file_path
-    assert file_paths[AbstractFileBasedStreamReader.SOURCE_FILE_URI] == source_file
-    assert file_paths[AbstractFileBasedStreamReader.FILE_NAME] == path.basename(source_file)
-    assert file_paths[AbstractFileBasedStreamReader.FILE_FOLDER] == path.dirname(source_file)
+    assert file_paths[AbstractFileBasedStreamReader.FILE_NAME] == path.basename(source_file_path)
+    assert file_paths[AbstractFileBasedStreamReader.FILE_FOLDER] == path.dirname(source_file_path)