| """Shared indexer singletons, locks, and 3GPP working-group/meeting-folder helpers. |
| |
| Extracted from v0's app.py so that both the REST endpoints (used by the web |
| dashboard) and the MCP indexing server share the same indexer instances and |
| locks, preventing an indexing job started from one surface from racing with |
| one started from the other. |
| """ |
| import re |
| import threading |
|
|
| from classes import TDocIndexer, Spec3GPPIndexer, SpecETSIIndexer |
|
|
| meetings_mapping = { |
| "SA": [ |
| "TSG_SA", |
| "WG1_Serv", |
| "WG2_Arch", |
| "WG3_Security", |
| "WG4_CODEC", |
| "WG5_TM", |
| "WG6_MissionCritical" |
| ], |
| "CT": [ |
| "TSG_CT", |
| "WG1_mm-cc-sm_ex-CN1", |
| "WG2_capability_ex-T2", |
| "WG3_interworking_ex-CN3", |
| "WG4_protocollars_ex-CN4", |
| "WG5_osa_ex-CN5", |
| "WG6_Smartcard_Ex-T3" |
| ], |
| "RAN": [ |
| "TSG_RAN", |
| "WG1_RL1", |
| "WG2_RL2", |
| "WG3_Iu", |
| "WG4_Radio", |
| "WG5_Test_ex-T1", |
| "WG6_legacyRAN" |
| ] |
| } |
|
|
|
|
| def get_folder_name(working_group: str): |
| if working_group.endswith("P"): |
| if working_group.startswith("S"): |
| return ("SA", 0) |
| if working_group.startswith("C"): |
| return ("CT", 0) |
| if working_group.startswith("R"): |
| return ("RAN", 0) |
| m = re.match(r"([A-Z]+)(\d+)", working_group) |
| if m: |
| code, num = m.groups() |
| return (code, int(num)) |
| else: |
| raise ValueError("Unattended format") |
|
|
|
|
| _tdoc_indexer = None |
| _spec_3gpp_indexer = None |
| _spec_etsi_indexer = None |
| _init_locks = { |
| "tdoc": threading.Lock(), |
| "3gpp": threading.Lock(), |
| "etsi": threading.Lock(), |
| } |
| indexing_locks = { |
| "tdoc": threading.Lock(), |
| "3gpp": threading.Lock(), |
| "etsi": threading.Lock(), |
| } |
|
|
|
|
| def get_tdoc_indexer(): |
| global _tdoc_indexer |
| if _tdoc_indexer is None: |
| with _init_locks["tdoc"]: |
| if _tdoc_indexer is None: |
| _tdoc_indexer = TDocIndexer() |
| return _tdoc_indexer |
|
|
|
|
| def get_spec_3gpp_indexer(): |
| global _spec_3gpp_indexer |
| if _spec_3gpp_indexer is None: |
| with _init_locks["3gpp"]: |
| if _spec_3gpp_indexer is None: |
| _spec_3gpp_indexer = Spec3GPPIndexer() |
| return _spec_3gpp_indexer |
|
|
|
|
| def get_spec_etsi_indexer(): |
| global _spec_etsi_indexer |
| if _spec_etsi_indexer is None: |
| with _init_locks["etsi"]: |
| if _spec_etsi_indexer is None: |
| _spec_etsi_indexer = SpecETSIIndexer() |
| return _spec_etsi_indexer |
|
|
