o t|_||_t||_d|jd|_d|jd|_dS)Nzoutput/z.mdzsummary/)r crew_instance input_datargenerate_input_hash input_hash output_file summary_file)selfr r/home/azureuser/microlearn/backend/user_journey_with_openai/agentic_workflow/src/user_journey_service/services/summary_creation_service.py__init__s  zSummaryCreationService.__init__cCstd||j\}}|r<||j\}}|r%||}dd|dS|||j\}}||}dd|dS||j\}}|rQ||}dd|dS|||j\}}||}dd|dS)NzInside def run function...successzFetch existing result.)statusmessageoutputzExecution completed.)print_fetch_existing_resultr isStructured_restructure_output_structuredcreate_summary_structured_restructure_output_ondemandcreate_summary_ondemand)rexistsresultrrrrruns&        zSummaryCreationService.runcCs&td|jj|jjdkrdSdS)NzInside journey type : zStructured LearningTF)rr journey)rrrrr0s z#SummaryCreationService.isStructuredcCsj|j}t|jddd }|}Wdn1swY||d<|jj|jd}|j|ddS)Nrutf-8encodingcontentr inputs) r dictopenr readr structured_crewrkickoffrr)fr&crewrrrr6s  z0SummaryCreationService.create_summary_structuredcCsrtd|j}t|jddd }|}Wdn1s wY||d<|jj|jd}|j |ddS)Nz#Inside on demand journey function..r"r#r$r&r'r() rr r*r+r r,r ondemand_crewrr.r/rrrr@s  z.SummaryCreationService.create_summary_ondemandcCstdtj|r>tdt|d}|}td|tdt|Wdd|fS1s5wYd|fSdS)NzInside fetch result functionzInside if conditionr"zThe fetched result is : The type of result is : T)F)rospathrr+r,type)r file_pathfilerrrrrJs   z-SummaryCreationService._fetch_existing_resultrreturnc Csz(tdtdt|tdt|td|}tddd|DWSty@}z t|iWYd}~Sd}~ww)Nz"Inside restructure output functionr3zResult content: z##\s*([\w\s]+?)\s*-\s*(\d+)%z match foundcSsi|] \}}|t|qSr)stripint).0skillpercentrrr _szISummaryCreationService._restructure_output_structured..)rr7reprrefindall Exception)rrmatcheserrrrVs z5SummaryCreationService._restructure_output_structuredmd_textcCsz|}tt}d}i}|D]}|}|dr$|dd}q|dkr_d|vr>td|}|r=d|di}qd|vr^td |}|r^|r^|d|d <|||i}q|d krt d |} | r| \} } | | d } ||| qd|vr||rtd|} | r| d||dd<q|dvrt d|}|r|||dqt |S)Nz## z Skill Gapsz **Skill:**z\*\*Skill:\*\*\s*(.+)r>z - Reason:z- Reason:\s*(.+)reasonzRecommended Modulesz&\d+\.\s+\*\*(.+?)\*\* \(Stage: (.+?)\)) module_titlestagez- Why Relevant:z- Why Relevant:\s*(.+) why_relevant>Applied SkillsCore foundationBusiness ContextPersonalization Reasonsz-\s*(.+)) r; splitlinesrlist startswithrBsearchgroupappendmatchgroupsr*)rrGlinesdatacurrent_section temp_skillliner>rJ module_matchrKrLmodulerN bullet_matchrrrrcsN        z3SummaryCreationService._restructure_output_ondemandN) __name__ __module__ __qualname__rr rrrrstrr*rrrrrrr s    r)fastapir collectionsrr5rB utils.hashingruser_journey_service.crewr1user_journey_service.processors.summary_generatorrsummary_generatorrrrrrs