Merge pull request #65 from scotho3/tscott/potenda-skip-unmatched-src

feat: Add skip_unmatched_source option

Author: BeArchiTek

docs/docs/reference/config.mdx

@@ -17,12 +17,13 @@ Describes the overall synchronization    configuration.
 
 | Property | Type | Description | Mandatory |
 | -------- | ---- | ----------- | --------- |
-| name | string | Unique identifier for the sync instance. | Yes |
-| store | SyncStore | Configuration for the optional storage mechanism. | No |
-| source | SyncAdapter | Configuration for the source adapter. | Yes |
-| destination | SyncAdapter | Configuration for the destination adapter. | Yes |
-| order | List of strings | Specifies the order in which objects should be synchronized. | Yes |
-| schema_mapping | List of SchemaMappingModel | Defines how data is mapped from source to destination. | Yes |
+| `name` | string | Unique identifier for the sync instance. | Yes |
+| `store` | SyncStore | Configuration for the optional storage mechanism. | No |
+| `source` | SyncAdapter | Configuration for the source adapter. | Yes |
+| `destination` | SyncAdapter | Configuration for the destination adapter. | Yes |
+| `order` | List of strings | Specifies the order in which objects should be synchronized. | Yes |
+| `schema_mapping` | List of SchemaMappingModel | Defines how data is mapped from source to destination. | Yes |
+| `skip_unmatched_source` | boolean | If set to `true`, Source records will not be compared if they do not exist in the Destination | No |
 
 ### Sync store
 

infrahub_sync/__init__.py

@@ -55,6 +55,7 @@ class SyncConfig(pydantic.BaseModel):
     destination: SyncAdapter
     order: list[str] = pydantic.Field(default_factory=list)
     schema_mapping: list[SchemaMappingModel] = []
+    skip_unmatched_source: bool = pydantic.Field(default=False)
 
 
 class SyncInstance(SyncConfig):

infrahub_sync/potenda/__init__.py

@@ -37,7 +37,11 @@ def __init__(
         self.progress_bar = None
         self.show_progress = show_progress
         enable_console_logging(verbosity=1)
-        self.flags = DiffSyncFlags.SKIP_UNMATCHED_DST
+        self.flags = (
+            DiffSyncFlags.SKIP_UNMATCHED_BOTH
+            if self.config.skip_unmatched_destination
+            else DiffSyncFlags.SKIP_UNMATCHED_DST
+        )
 
     def _print_callback(self, stage: str, elements_processed: int, total_models: int):
         """Callback for DiffSync using tqdm"""