feat(transform): Make Processor migration-aware

This commit completes the refactoring to support migration workflows
with separate source and destination databases.

The `Processor` class in `transform.py` has been updated to correctly
handle the new `'config'` key in the `params` dictionary.

- The `Processor.__init__` method now accepts and stores a `config_file`
argument, which is used as a fallback for backward compatibility. - The
`write_to_file` method now checks for a `'config'` key in the parameters
for each file it writes. If present, this configuration is used to
generate the `odoo-data-flow import` command in the final shell script.

This ensures that when a transformation script specifies a destination
config, the resulting `load.sh` script will correctly target the
destination database, completing the migration-aware workflow.

Author: bosd

src/odoo_data_flow/lib/transform.py

@@ -49,6 +49,7 @@ class Processor:
     def __init__(
         self,
         filename: Optional[str] = None,
+        config_file: Optional[str] = None,  # Added for fallback
         separator: str = ";",
         encoding: str = "utf-8",
         header: Optional[list[str]] = None,
@@ -66,6 +67,9 @@ def __init__(
 
         Args:
             filename: The path to the source CSV or XML file.
+            config_file: Path to the Odoo connection configuration file. Used as a
+                           fallback for operations that require a DB connection if
+                           no specific config is provided later.
             separator: The column delimiter for CSV files.
             encoding: The character encoding of the source file.
             header: A list of strings for the header row (for in-memory data).
@@ -74,6 +78,7 @@ def __init__(
             **kwargs: Catches other arguments, primarily for XML processing.
         """
         self.file_to_write: OrderedDict[str, dict[str, Any]] = OrderedDict()
+        self.config_file = config_file
         self.header: list[str]
         self.data: list[list[Any]]
 
@@ -280,6 +285,9 @@ def write_to_file(
         init = not append
         for _, info in self.file_to_write.items():
             info_copy = info.copy()
+            # NEW: Use the config from params if available,
+            #  otherwise use the processor's default
+            info_copy["config"] = info.get("config") or self.config_file
             info_copy.update(
                 {
                     "model": info.get("model", "auto"),