mirror of
https://github.com/dograh-hq/dograh.git
synced 2026-06-07 07:55:16 +02:00
20 lines
678 B
Python
20 lines
678 B
Python
|
from api.services.campaign.source_sync import CampaignSourceSyncService
|
||
|
|
from api.services.campaign.sources.csv import CSVSyncService
|
||
|
|
from api.services.campaign.sources.google_sheets import GoogleSheetsSyncService
|
||
|
|
|
||
|
|
|
||
|
|
def get_sync_service(source_type: str) -> CampaignSourceSyncService:
|
||
|
|
"""Returns appropriate sync service based on source type"""
|
||
|
|
|
||
|
|
services = {
|
||
|
|
"google-sheet": GoogleSheetsSyncService,
|
||
|
|
"csv": CSVSyncService,
|
||
|
|
# Add more as needed: "hubspot": HubSpotSyncService,
|
||
|
|
}
|
||
|
|
|
||
|
|
service_class = services.get(source_type)
|
||
|
|
if not service_class:
|
||
|
|
raise ValueError(f"Unknown source type: {source_type}")
|
||
|
|
|
||
|
|
return service_class()
|