3&}hr+bddlZddlZddlmZmZmZmZmZddlm Z ddl m Z ddl m Z ddlmZddlmZddlmZdd lmZddlZddlZddlZddlZdd lmZmZdd lmZm Z dd l!m!Z!dd l"m#Z#ddl$m%Z%m&Z&m'Z'ddl(m)Z)ede*Z+e+jYdddgdZ-e+jYddgdZ.e+jYddgdZ/e+jYddgdZ0dZ1dZ2eZ3e+jYddgdZ4e+jYd dgd!Z5y)"N) Blueprintrequestjsonify send_file current_app)get_llm)get_tts)get_stt)BlobServiceClient) Proctoring)BytesIO)DeepFace) BaseModelValidationError)OptionalList)datetime)timezone)AnalysisRequestAnalysisResponseHeadPose) fraudCheckroutes/GETPOST)methodsctdddS)NzEngine is runningsuccess)messagestatus)r#/var/www/html/test/engine/routes.pyindexr%s & r#z/api/llmctj} tj}|stddidfSd|vrtddidfSd|vr |dr|dnd}|d}t |}|j |}t |dtd |iS#t$r2}t |dtd t|d d d fcYd}~Sd}~wwxYw)z LLM (Language Learning Model) API endpoint Purpose: Generates text responses using specified LLM engine Input: JSON with required 'prompt' field and optional 'engine' field Returns: Generated text response or error message errorNo JSON data providedpromptz Missing required field: 'prompt'engineopenaillmresponsezAn error occurred: failedr'r!N) timerget_jsonrr generate_text get_duration Exceptionstr)startdatar+r* llm_engineresultes r$llm_apir=s  IIKE!0  4 ; $,t#3XhHhV_ ))&1UE" F+,, UE"*3q6(3    s)$BBA B C!'CCCz/api/ttsc tj}d} tj stddidfSgd}t fd|Ds!tdddj |idfS j d xsd } j d d j}tjj d d} d}|d|}d|d}tjdd t|}|j }|d k(rEt|d5} |jd| j!|j#dddd|d||d} t%|dt| S#1swY*xYw#t&$r=} |r4tj(j+|rtj,|| d} ~ wwxYw#t&$re} t%|d|r4tj(j+|rtj,|tt/| dddfcYd} ~ Sd} ~ wwxYw)an Text-to-Speech (TTS) API endpoint Purpose: Converts text to speech audio and handles storage Input: JSON with required fields: - text: Text to convert to speech - name: Filename for the audio - engine: TTS engine to use - storage: Storage type (local/azure) Returns: Audio file location (local path or Azure URL) Nr'r(r))textnamer+voicec3&K|]}|v yw)Nr").0kr9s r$ ztts_api..Zs6196szMissing required fields: z, r+ elevenlabsstoragelocalDEPLOYMENT_ENVunknownr@_z./temp/questions_audios/.mp3z./temp/questions_audiosT)exist_okwbrr)r!filename local_path environmentttsr/r0r1)r2rr3ralljoingetlowerrconfigosmakedirsr text_to_speechopenseekwritereadr5r6pathexistsremover7) r8rPrequired_fieldsr+rG deploy_env file_name tts_engineaudio_iofr.r<r9s @r$tts_apirhEs3 IIKEJ9!G%<=>C C=6o664TYY5O4PQ (#3|((9g.446!''++,G6-F #1E=(F =FF G8G  GG IAH;5I;Iz/api/sttctj} tj}|stddidfS|j d}|j ddj }|rt jj|stddidfS t|}|j|}t|dtd |d S#t$r2}t|dtd t|d d dfcYd}~Sd}~wwxYw#t$r2}t|dtdt|d d dfcYd}~Sd}~wwxYw)a/ Speech-to-Text (STT) API endpoint Purpose: Converts audio file at given path to text using specified STT engine Input: JSON with fields: - file_path: Path to the audio file on server - engine: STT engine to use (default: whisper) Returns: JSON with transcribed text r'zNo JSON body providedr) file_pathr+whisperzInvalid or missing file_pathsttr)r! transcriptzFailed to transcribe audio: r/r0r1NzUnexpected error: )r2rr3rrUrVrXr_isfiler transcribe_audior5r6r7)r8r9rjr+ stt_enginermr<s r$stt_apirqs] IIKE#!G%<=>C CHH[) (I.446y 9G%CDEsJ J  J#44Y?J  &#(     &7Ax@"   UE")#a&2    sM$DA D5C D'D DD DD E 'EE E cZtj|z }td|d|dd|S)a  Utility function to measure and log execution time Purpose: Calculates and prints the duration of API calls Parameters: - start: Start time of the function - fnName: Name of the function being timed Returns: Duration in seconds z Function z took z.2fz seconds)r2print)r8fnNamedurations r$r5r5s2yy{U"H IfXVHS> :; Or#c tjd}tjd}tjd}d|d|d}t j |}|j |}|jd|j||d }d tjd d |d |} | |fS#t$r} tdt| d} ~ wwxYw)a Azure Blob Storage upload handler Purpose: Uploads audio files to Azure Blob Storage Parameters: - audio_io: BytesIO object containing audio data - name: Base name for the blob file Returns: Tuple of (blob_url, blob_name) Required Environment Variables: - AZURE_STORAGE_CONNECTION_STRING - AZURE_CONTAINER_NAME - AZURE_STORAGE_ACCOUNT AZURE_STORAGE_CONNECTION_STRINGAZURE_CONTAINER_NAMEz %Y%m%d-%H%M%Sztts/-rLrT)r@r9 overwritezhttps://AZURE_STORAGE_ACCOUNTz.blob.core.windows.net/rzAzure upload failed: N) rXgetenvr2strftimer from_connection_stringget_container_clientr\ upload_blobr6r7) rfr@connection_stringcontainer_name timestamp blob_nameblob_service_clientcontainer_client blob_clientblob_urlr<s r$upload_to_azurers:II&GH#9:MM/2 4&)D1 0FFGXY.CCNS  a&223 bii(?@AAXYgXhhijsitu"" :/Ax899:sB4B77 CCCz/api/proctor/analyzectd tditj} tj|j}tjtj|tjtj}| t!d t$j'|}|drt)di|dnd}d} t+j,|d gd d }t/|t0r+t3|d kDr|d d }t$j5|}d} |r5t$j;|j<|j>|j@} tCjDtGdjI} tK|d|d||g| } | jM} | | d<t | S#t$r(}t d|j ddfcYd}~Sd}~wwxYw#t"$rt ddidfcYSwxYw#t7j8YxYw#t"$r7}t7j8t dtO|ddfcYd}~Sd}~wwxYw)Nzcalling analyze endpointzInvalid request format)r'detailsr)zDecoded image is Noner'zInvalid base64 image head_poseemotionFopencv)img_pathactionsenforce_detectiondetector_backendrz Not detectedz Asia/Kolkata face_detected people_count)rrrdominant_emotionflagsrhead_orientation_readablezInternal server errorr1r")(rsrrjsonrrerrorsbase64 b64decodeimagecv2imdecodenp frombufferuint8 IMREAD_COLOR ValueErrorr6 proctoring analyzeFramerranalyze isinstancelistlen fuseEmotions traceback print_excdescribeHeadPoseyawpitchrollrnowr isoformatrdictr7) requestDatar< imageDataframe visionResults headPoseDatadominantEmotionanalysisemotionsheadOrientationReadableistTimer.payloads r$rrsH $%X%5 5 ?$$[%6%67  R]]9bhh?AQAQR =45 5  -S"//6 AN{A[x=- "<=ae  "''" "'!) H (D)c(ma.?#A;y1","9"9("C#1 &0&A&A  ""!!' # ,,x78BBD#'8&~6",  --//F+,wi X!9ahhjQRTWWWX ?!7893>>?$ "    !6 S!8SVLMsRRSsgF9A2G-,H'AH BH'9 G*G%G*%G*-HH H$!H'' I'0,I"I'"I'z/api/proctor/verify_identityc6 tj}|jd}|jd}tj||}t |S#t $r6}tjt dt|idfcYd}~Sd}~wwxYw)Nid_imageselfier'r1) rr3rUr match_facesrr6rrr7)r9 id_image_b64 selfie_b64r;r<s r$verify_identityr6s /!xx + XXh' '' jAv /Q()3../sAA B"+B BB)6r2rXflaskrrrrr services.llmr services.ttsr services.sttr azure.storage.blobr services.proctorr ior deepfacerrrnumpyrrpydanticrrtypingrrrpytzrservices.proctor.models.modelsrrrservices.proctor.fraud_checkr__name__rrouter%r=rhrqr5rrrrr"r#r$rs< EE 0'**/!VV3 8X &cE6?+,j6(+","Jj6(+F,FPj6(+.,.` ':T L $vh7<S8<S|,vh? /@ /r#