Zj(ASrSSKJr SSKrSSKrSSKrSSKrSSKrSSKrSSK r SSK r SSK r SSK r SSK r SSKrSSKrSSKrSSKJr SSKJrJr SSKJr SSKJr \"\5R55R6r\R:R=S5=(d S R?5r \!"\R:R=S 5=(d S 5r"\"\R:R=S 5=(d \S - \ - S- 5r#\"\R:R=S5=(d \RH"5S- S- 5r%\"\R:R=S5=(d \%S- S- S- \ - 5r&\&S- r'\&S- r(\&S- r)\&RUSSS9 \'RUSSS9 \(RUSSS9 \S- S- r+\+S- S- r,\+S- S - r-\+S!- S"- S#- S$- r.\S%- r/\ R`"5r1\ Rd"5r3\ R"5r4S&r5S'r6S&r7S(r8\&S)- r9SSS*S0S+S_S,S!_S-\:"\.5_S.\:"\/5_S/S0_S1S2_S3S4_S5S6_S7S&_S8S9_S:S;_SS?_S@S_SASB_SCSD_S*SESBSSSSF/SGQSH.SSISJSKSLS9SM.SSN/SOSPS9SQSR.SSSTSSSSUSVSW/SX.SNSYSNSSZS[SVSW/S\./S]. r;SS^jrSSajr?SSbjr@SScjrASSdjrB\R"Se\R5rESSfjrFSSgjrGSShjrHSSijrI"SjSk5rJ"SlSm5rK"SnSo5rL\J"5rM\K"5rN\L"5rOSSpjrPSSqjrQSSSrjjrRSSsjrSSStjrTSSujrU1SvkrVSw/SxQ4Sy/SzQ4S{/S|Q4S}/S~Q4S/SQ4SSS/4S/SQ4S/SQ4S/SQ4S/SQ4S/SQ4/ rW/SQrXSrYSrZSr[SSSSSSSSSSSSS. r\Sr]Sr^Sr_Sr`SSjraSSjrbSSjrcSSjrdSSjreSSjrfSSjrgSrhSriSrjSrk"SS\5rlSrm\nS:Xa\m"5 gg)aNW AL Scanner Radio Intelligence - Incident Intelligence Phase 1. Monitor-only service. Watches configured recording folders, waits for completed files, identifies source/channel metadata, archives audio, transcribes locally with whisper.cpp when installed, and marks likely duplicate Lauderdale paging repeater copies, provides operator audio playback and transcript correction, and stores correction vocabulary. It does NOT publish, create incidents, or modify Incident Command in Phase 3. ) annotationsN)datetime)BaseHTTPRequestHandlerThreadingHTTPServer)Path)urlparse NWALS_TENANTz nw-al-scannerNWALS_RADIO_PORT9021NWALS_RADIO_CONFIGtenantszradio_intelligence.json LOCALAPPDATAz.localshareNWALS_RADIO_DATA_DIRNWALScannerPlatformdataradio_intelligenceaudio transcriptszradio_intelligence.sqlite3Tparentsexist_oktoolsradio_transcriptionwhisperzwhisper-cli.exemodelszggml-base.en.binfaster_whispervenvScriptsz python.exezfaster_whisper_transcribe.py?g?g333333?zdeepgram_api_key.txtFenabledbackendpythonhelpermodeldistil-large-v3 compute_type int8_float16devicecuda beam_sizepatience cpu_threadsfallback_modelsmall.enfallback_devicecpufallback_compute_typeint8 vad_filterlanguageeninitial_promptzPublic safety radio traffic in northwest Alabama. Fire, EMS, dispatch, street names, road names, unit numbers and local place names.nova-2-phonecall@) wreckinjuries LauderdaleFlorenceColbertKillen Tuscumbia SheffieldMuscleShoalsHeltonMarsHill)r!r%r7 smart_format punctuate mip_opt_out keyword_booststatic_keywords )r!lookback_hoursmax_gap_seconds cross_source_fast_window_secondssame_type_window_seconds min_wordsvoxZ(\?zLauderdale Paging Repeat)r! watcher_idswindow_secondssimilarity_thresholdrV group_labelsdrtrunkzSDRTrunk Callsz#%USERPROFILE%\\SDRTrunk\\recordings.mp3.wav)idnameadapterr!path extensionszLauderdale VOX RecordingszC:\\VOX Recorder\\RecordingsLauderdale County VOX)rarbrcr!rd source_namere) r! monitor_onlyingest_existing_on_first_run archive_audio transcriptiondeepgramincident_groupingduplicate_detectionwatcherscUR5H[up#X ;aX0U'M[U[5(dM'[URU5[5(dMM[ XU5 M] U$N)items isinstancedictget deep_defaults)dstsrckeyvals 0/mnt/data/v087_work/radio_intelligence_server.pyrvrvsTIIK >H T " "z#''#,'E'E #(C (  Jc[R5(dL[RRSSS9 [R [ R "[SS9S-SS9 [ R"[RSS95n[U[5 U$![a1 [ R"[ R "[55nNLf=f) NTrindent utf-8encoding utf-8-sig) CONFIG_PATHexistsparentmkdir write_textjsondumpsDEFAULT_CONFIGloads read_text Exceptionrv)cfgs r{ load_configrs        =tzz.CdJU\]5jj.. .DE#~& J 5jjN345s''B 8CCc[RRSSS9 [RS5nUR [ R "USS9S-SS9 UR[5 g) NTrz .json.tmpr~rrrr)rrr with_suffixrrrreplace)rtmps r{ save_configrsWTD9  ! !+ .CNN4::c!,t3gNFKK r|c[[RR[RR U555R 5$rq)rosrd expandvars expanduserresolve)texts r{ expand_pathrs4 ""277#5#5d#;< = E E GGr|cURSUS35R5Vs1sHoDSiM nnX%;aURSUSUSU35 ggs snf)NzPRAGMA table_info()z ALTER TABLE z ADD COLUMN  )executefetchall)contablerbddlrcolss r{_ensure_columnrsf++(:5'&CDMMO POQaDOD P  l5'dV1SEBC QsAc[R"[SS9n[RUlUR S5 UR S5 UR S5 [ USSS5 [ USS S 5 [ USS S5 [ USS S 5 [ USSS5 [ USSS5 [ USSS5 [ USSS 5 [ USSS5 [ USSS 5 [ USSS5 [ USSS5 [ USSS 5 [ USSS5 [ USSS 5 [ USSS5 [ USSS 5 UR S5 UR S5 UR S5 UR S5 UR S 5 UR S!5 UR5 U$)"N timeoutzPRAGMA journal_mode=WALzCREATE TABLE IF NOT EXISTS files_seen ( fingerprint TEXT PRIMARY KEY, original_path TEXT NOT NULL, size_bytes INTEGER NOT NULL, mtime REAL NOT NULL, first_seen REAL NOT NULL, disposition TEXT NOT NULL )aCREATE TABLE IF NOT EXISTS transmissions ( id INTEGER PRIMARY KEY AUTOINCREMENT, fingerprint TEXT UNIQUE NOT NULL, timestamp_epoch REAL NOT NULL, timestamp_text TEXT NOT NULL, adapter TEXT NOT NULL, watcher_id TEXT NOT NULL, watcher_name TEXT NOT NULL, source_name TEXT NOT NULL, system_name TEXT, site_name TEXT, alias_name TEXT, target_id TEXT, original_path TEXT NOT NULL, archive_path TEXT, filename TEXT NOT NULL, extension TEXT NOT NULL, size_bytes INTEGER NOT NULL, ingested_at REAL NOT NULL, status TEXT NOT NULL DEFAULT 'MONITOR_ONLY' ) transmissions transcriptTEXTtranscript_statuszTEXT DEFAULT 'PENDING'transcript_errortranscribed_atREALtranscript_backendduplicate_groupduplicate_of_idINTEGERduplicate_similaritycorrected_transcript corrected_at corrected_bydeepgram_transcriptdeepgram_statusdeepgram_errordeepgram_transcribed_atdeepgram_modeldeepgram_confidencea4CREATE TABLE IF NOT EXISTS transcript_corrections ( id INTEGER PRIMARY KEY AUTOINCREMENT, transmission_id INTEGER NOT NULL, raw_transcript TEXT, corrected_transcript TEXT NOT NULL, corrected_at REAL NOT NULL, corrected_by TEXT NOT NULL DEFAULT 'operator' )aCREATE TABLE IF NOT EXISTS vocabulary_phrases ( phrase TEXT PRIMARY KEY, first_seen REAL NOT NULL, last_seen REAL NOT NULL, use_count INTEGER NOT NULL DEFAULT 1, source TEXT NOT NULL DEFAULT 'operator_correction' )zCREATE TABLE IF NOT EXISTS incident_handoffs (candidate_id TEXT PRIMARY KEY, sent_at REAL NOT NULL, incident_url TEXT NOT NULL, payload_json TEXT NOT NULL)zfCREATE INDEX IF NOT EXISTS idx_transmissions_transcript_status ON transmissions(transcript_status, id)zgCREATE INDEX IF NOT EXISTS idx_transmissions_watcher_time ON transmissions(watcher_id, timestamp_epoch)zbCREATE INDEX IF NOT EXISTS idx_transmissions_deepgram_status ON transmissions(deepgram_status, id))sqlite3connectDB_PATHRow row_factoryrrcommit)rs r{dbrs //'2 .CkkCOKK)*KK  KK  *3v>3)<>VW3);VD3)96B3)=vF3):FC3):IF3)?H3)?H3@3@3)>G3):GKK  KK  KKnoKKxyKKyzKKtuJJL Jr|cUR5SURSUR3RSSS9n[R "U5R 5$)N|rr)errors)rst_size st_mtime_nsencodehashlibsha1 hexdigest)rdstatraws r{ fingerprintrsS \\^ Adll^1T-=-=,> ? F FwW` F aC <<  & & ((r|zI^(?P\d{8})_(?P