O\i9hdZddlZddlZddlmZddlmZmZmZm Z m Z ddl m Z GddZ dS)a Settings Service Layer This module manages application settings persistence and MongoDB connection configuration. Settings are stored in app_config.yaml and can be updated through the UI. Key principles: - Explicit user control: No automatic reconnections or background operations - Safe persistence: Settings are validated before saving - Clear error handling: All errors are surfaced to the UI N)Path)DictAnyOptionalTupleList) MongoClientc8eZdZdZd"defdZdeeeffdZdeeeffdZ d#d ed ed e d e de e e eff d Z d#d ed ed e d e de e e eff dZdefdZdefdZd$dZdeeeffdZdedeeeffdZ d%dedeedeedede de e e eff dZde fdZde de e e effdZdedeeeeffdZded eeeefde e e effd!ZdS)&SettingsServicez Service for managing application settings and MongoDB configuration. This service handles: - Loading and saving settings to app_config.yaml - Testing MongoDB connections - Validating configuration values config/app_config.yaml config_pathc`t||_||_dS)z~ Initialize settings service. Args: config_path: Path to YAML configuration file N)rr _load_configconfig)selfr s 5/var/www/html/IGF-ODF-V3/services/settings_service.py__init__zSettingsService.__init__s+ ,,'')) returnc|jstd|jt|jd5}t j|cdddS#1swxYwYdS)zs Load configuration from YAML file. Returns: Configuration dictionary zConfiguration file not found: rN)r existsFileNotFoundErroropenyaml safe_load)rfs rrzSettingsService._load_config(s&&(( Y#$WTEU$W$WXX X $"C ( ( %A>!$$ % % % % % % % % % % % % % % % % % %sA''A+.A+c|jdi}|dd}tj|d}|||dd|dd|d dd S) ad Get current MongoDB settings. Returns: Dictionary with MongoDB configuration: - uri: Connection URI (from environment or default) - database: Database name - connection_timeout: Connection timeout in ms - server_selection_timeout: Server selection timeout in ms mongodburi_env MONGO_URIzpmongodb://AdminUser:WnE0TjGIafVJutreZL7cTIoWNWU52YyxLVgwCUqIGCGg3YUT@18.184.249.241:27017/?authMechanism=DEFAULTdatabaseIGF_WORKconnection_timeoutserver_selection_timeout)urir r"r$r&rgetosgetenv)r mongo_configr r's rget_mongodb_settingsz$SettingsService.get_mongodb_settings5s{y"55 ""9k::i"TUU$((Z@@"."2"23G"N"N(4(8(89SUY(Z(Z    rr%r'r"r$r&cd} t|||}|jd||}| ||dSdS#t $r2}dt |fcYd}~||SSd}~wwxYw#||wwxYw)a Test MongoDB connection with provided settings. Args: uri: MongoDB connection URI database: Database name connection_timeout: Connection timeout in milliseconds server_selection_timeout: Server selection timeout in milliseconds Returns: Tuple of (success: bool, error_message: Optional[str]) N)serverSelectionTimeoutMSconnectTimeoutMSpingTNF)r admincommandlist_collection_namesclose Exceptionstr)rr'r"r$r&clientdbes rtest_connectionzSettingsService.test_connectionNs&  )A!3F L  ( ( (!B  $ $ & & &       ! ! !#a&&=      !   s0AA'' B#1BB#B&B##B&&B?c |r|sdS|r|sdS|dkrdS|dkrdS|}|ds|dsdS||jd d <t||jd d <t||jd d < t |jd d5}t j|j|ddddddn #1swxYwYnC#t$rdd|jdfcYSt$r}ddt|fcYd}~Sd}~wwxYw|jd  dd}|tj |<dS#t$r} ddt| fcYd} ~ Sd} ~ wwxYw)aG Save MongoDB settings to configuration file and environment. This method: 1. Validates the settings 2. Updates app_config.yaml 3. Updates the environment variable for the current session Args: uri: MongoDB connection URI database: Database name connection_timeout: Connection timeout in milliseconds server_selection_timeout: Server selection timeout in milliseconds Returns: Tuple of (success: bool, error_message: Optional[str]) )FzMongoDB URI cannot be empty)FzDatabase name cannot be emptyi)Fz*Connection timeout must be at least 1000ms)Fz0Server selection timeout must be at least 1000msz mongodb://zmongodb+srv://)Fz8>>#3#3 >==!D( KJJ'$. QPP99;;L**<88 ]AXAXYiAjAj ]\\2:1A1ADK ": .;>?Q;R;RDK "#7 8ADE]A^A^DK "#= > P$*C'BBBmaIdk1RWgkllllmmmmmmmmmmmmmmm" p p poDDTooooooo P P POc*ooOOOOOOOOO Pk),00KHHG".BJw : ? ? ?>c!ff>>> > > > > > > ?sF"F"F"F">F"AF"D-6D! D-!D%%D-(D%)D-,F"-E-F" E-E("E-#F"(E--3F"" G ,G?G G c`|jdiddS)zg Get the configured database name. Returns: Database name rr"r#rr)rs rget_database_namez!SettingsService.get_database_names*{y"--11*jIIIrc|jdidd}tj|dS)zw Get the MongoDB connection URI from environment. Returns: Connection URI rr r!zmongodb://localhost:27017r()rr s rget_connection_uriz"SettingsService.get_connection_uris<+//)R0044Y LLy"=>>>rNc8||_dS)z Reload configuration from file. This is useful after settings have been saved to ensure the service has the latest configuration. N)rrrSs r reload_configzSettingsService.reload_configs'')) rc8|jdiS)z Get all collection configurations. Returns: Dictionary of collection configurations collectionsrRrSs rget_all_collectionsz#SettingsService.get_all_collectionss{}b111rcollection_namecd|jdi}||iS)z Get configuration for a specific collection. Args: collection_name: Name of the collection Returns: Collection configuration dictionary rZrR)rr\rZs rget_collection_configz%SettingsService.get_collection_configs-koomR88 333rT business_keysalternative_keysmatching_strategyenabledc d|jvr i|jd<||jdvri|jd|<||jd|d<||jd|d<||jd|d<||jd|d< t|jdd5}tj|j|d d d d d d n #1swxYwYnB#t $rd d |jfcYSt $r}d dt|fcYd }~Sd }~wwxYwdS#t $r}d dt|fcYd }~Sd }~wwxYw)a Update collection configuration. Args: collection_name: Name of the collection business_keys: List of business key field names alternative_keys: List of alternative key field names matching_strategy: Matching strategy (primary_only, primary_or_alternative, alternative_only) enabled: Whether collection is enabled Returns: Tuple of (success: bool, error_message: Optional[str]) rZrbr_r`rar>r?r@FTrBNrFrGr2z$Failed to update collection config: rrr rrKrLr7r8) rr\r_r`rarbrrOr;s rupdate_collection_configz(SettingsService.update_collection_configs* JDK/ 0-/ M*dk-&@@ A>@ M*?;FMDK & 7 BKXDK & 7 HN^DK & 78J KO`DK & 78K L P$*C'BBBmaIdk1RWgkllllmmmmmmmmmmmmmmm" W W WVDDTVVVVVV P P POc*ooOOOOOOOOO P: J J JIQIII I I I I I I Js~B D C$C CCCCCDD1D3 D<DDDDD E)E<EEc|jdidd} t|S#ttf$rYdSwxYw)zz Get the record limit for data loading. Returns: Record limit (default 5000) uidefault_record_limitr%)rr)rJ ValueError TypeError)rlimits rget_record_limitz SettingsService.get_record_limitsb b))--.DdKK u:: I&   44 sAAArkc |dkrdS|dkrdSd|jvr i|jd<||jdd< t|jdd 5}tj|j|d d d d d d n #1swxYwYnB#t $rd d|jfcYSt $r}d dt|fcYd }~Sd }~wwxYwdS#t $r}d dt|fcYd }~Sd }~wwxYw)z Update the record limit for data loading. Args: limit: New record limit Returns: Tuple of (success: bool, error_message: Optional[str]) d)Fz!Record limit must be at least 100i)Fz"Record limit cannot exceed 100,000rgrhr>r?r@FTrBNrFrGr2zFailed to update record limit: rd)rrkrrOr;s rupdate_record_limitz#SettingsService.update_record_limit,s Es{ BAAv~ CBB4;& '$& D!8=DK 4 5 P$*C'BBBmaIdk1RWgkllllmmmmmmmmmmmmmmm" W W WVDDTVVVVVV P P POc*ooOOOOOOOOO P: E E EDCFFDDD D D D D D D EsCC#CB A8, B8A<<B?A<BCCC C%B>8C9C>CC C0C+%C0+C0c|jdi}||i}|dgS)a Get foreign key relationships for a collection. Args: collection_name: Name of the collection Returns: List of foreign key definitions, each with: - field: Field name in this collection - references_collection: Target collection name - references_field: Field name in target collection rZ foreign_keysrR)rr\rZcollection_configs rget_foreign_keysz SettingsService.get_foreign_keysPsCkoomR88 'OOOR@@ $$^R888rrqct d|jvr i|jd<||jdvri|jd|<|D]/}d|vs|dsdSd|vs|dsdSd|vs|dsdS0||jd|d< t|jd d 5}tj|j|d d d dddn #1swxYwYnB#t $rd d|jfcYSt $r}d dt|fcYd}~Sd}~wwxYwdS#t $r}d dt|fcYd}~Sd}~wwxYw)a* Update foreign key relationships for a collection. Args: collection_name: Name of the collection foreign_keys: List of foreign key definitions Returns: Tuple of (success: bool, error_message: Optional[str]) rZfield)Fz)Foreign key must have a 'field' specifiedreferences_collection)Fz9Foreign key must have a 'references_collection' specifiedreferences_field)Fz4Foreign key must have a 'references_field' specifiedrqr>r?r@FTrBNrFrGr2zFailed to update foreign keys: rd)rr\rqfkrrOr;s rupdate_foreign_keysz#SettingsService.update_foreign_keysasZ EDK/ 0-/ M*dk-&@@ A>@ M*?;# Y Y"$NBwKNMMM*"4^B?V*.E tXc]" # .E.E.E.E.E.Err )r}r*rpathlibrtypingrrrrrpymongor r rrrrs   33333333333333{E{E{E{E{E{E{E{E{E{Er