add callback manager , model app

README.md

@@ -5,7 +5,7 @@ colorFrom: gray
 colorTo: pink
 sdk: gradio
 sdk_version: 5.19.0
-app_file: app.py
+app_file: callbackmanager.py
 pinned: false
 license: mit
 short_description: Provides guardrails and discharge summaries with compliance

callbackmanager.py

@@ -0,0 +1,188 @@
+import gradio as gr
+from meldrx import MeldRxAPI  
+import json
+
+# CallbackManager class to handle OAuth callbacks
+class CallbackManager:
+    def __init__(self, client_id: str, redirect_uri: str, workspace_id: str, client_secret: str = None):
+        """
+        Initialize the CallbackManager with MeldRx API credentials.
+
+        Args:
+            client_id (str): The client ID from MeldRx Developer Portal.
+            redirect_uri (str): The redirect URI for the Gradio app (e.g., Space URL + /callback).
+            workspace_id (str): The workspace slug/ID.
+            client_secret (str, optional): The client secret (for confidential clients).
+        """
+        self.api = MeldRxAPI(client_id, redirect_uri, workspace_id, client_secret)
+        self.auth_code = None
+        self.access_token = None
+
+    def get_auth_url(self) -> str:
+        """Generate and return the SMART on FHIR authorization URL."""
+        return self.api.get_authorization_url()
+
+    def set_auth_code(self, code: str) -> str:
+        """Set the authorization code and attempt to get an access token."""
+        self.auth_code = code
+        if self.api.authenticate_with_code(code):
+            self.access_token = self.api.access_token
+            return f"Authentication successful! Access Token: {self.access_token[:10]}... (truncated)"
+        return "Authentication failed. Please check the code."
+
+    def get_patient_data(self) -> str:
+        """Retrieve patient data using the access token."""
+        if not self.access_token:
+            return "Not authenticated. Please provide a valid authorization code first."
+        patients = self.api.get_patients()
+        if patients is not None:
+            return json.dumps(patients, indent=2) if patients else "No patient data returned."
+        return "Failed to retrieve patient data."
+
+# Discharge form display function
+def display_form(
+    first_name, last_name, middle_initial, dob, age, sex, address, city, state, zip_code,
+    doctor_first_name, doctor_last_name, doctor_middle_initial, hospital_name, doctor_address,
+    doctor_city, doctor_state, doctor_zip,
+    admission_date, referral_source, admission_method, discharge_date, discharge_reason, date_of_death,
+    diagnosis, procedures, medications, preparer_name, preparer_job_title
+):
+    form = f"""
+    **Patient Discharge Form**
+    
+    **Patient Details:**
+    - Name: {first_name} {middle_initial} {last_name}
+    - Date of Birth: {dob}, Age: {age}, Sex: {sex}
+    - Address: {address}, {city}, {state}, {zip_code}
+    
+    **Primary Healthcare Professional Details:**
+    - Name: {doctor_first_name} {doctor_middle_initial} {doctor_last_name}
+    - Hospital/Clinic: {hospital_name}
+    - Address: {doctor_address}, {doctor_city}, {doctor_state}, {doctor_zip}
+    
+    **Admission and Discharge Details:**
+    - Date of Admission: {admission_date}
+    - Source of Referral: {referral_source}
+    - Method of Admission: {admission_method}
+    - Date of Discharge: {discharge_date}
+    - Discharge Reason: {discharge_reason}
+    - Date of Death (if applicable): {date_of_death}
+    
+    **Diagnosis & Procedures:**
+    - Diagnosis: {diagnosis}
+    - Procedures: {procedures}
+    
+    **Medication Details:**
+    - Medications on Discharge: {medications}
+    
+    **Prepared By:**
+    - Name: {preparer_name}, Job Title: {preparer_job_title}
+    """
+    return form
+
+# Initialize CallbackManager with your credentials
+CALLBACK_MANAGER = CallbackManager(
+    client_id="your_client_id",  # Replace with actual client ID
+    redirect_uri="https://multitransformer-discharge-guard.hf.space/callback",
+    workspace_id="your_workspace_id",  # Replace with actual workspace ID
+    client_secret=None  # Replace with actual secret if using a confidential client
+)
+
+# Gradio interface
+with gr.Blocks() as demo:
+    gr.Markdown("# Patient Discharge Form with MeldRx Integration")
+
+    # Authentication Section
+    with gr.Tab("Authenticate with MeldRx"):
+        gr.Markdown("## SMART on FHIR Authentication")
+        auth_url_output = gr.Textbox(label="Authorization URL", value=CALLBACK_MANAGER.get_auth_url(), interactive=False)
+        gr.Markdown("Copy the URL above, open it in a browser, log in, and paste the 'code' from the redirect URL below.")
+        auth_code_input = gr.Textbox(label="Authorization Code")
+        auth_submit = gr.Button("Submit Code")
+        auth_result = gr.Textbox(label="Authentication Result")
+        patient_data_button = gr.Button("Fetch Patient Data")
+        patient_data_output = gr.Textbox(label="Patient Data")
+
+        auth_submit.click(
+            fn=CALLBACK_MANAGER.set_auth_code,
+            inputs=auth_code_input,
+            outputs=auth_result
+        )
+        patient_data_button.click(
+            fn=CALLBACK_MANAGER.get_patient_data,
+            inputs=None,
+            outputs=patient_data_output
+        )
+
+    # Discharge Form Section
+    with gr.Tab("Discharge Form"):
+        gr.Markdown("## Patient Details")
+        with gr.Row():
+            first_name = gr.Textbox(label="First Name")
+            last_name = gr.Textbox(label="Last Name")
+            middle_initial = gr.Textbox(label="Middle Initial")
+        
+        with gr.Row():
+            dob = gr.Textbox(label="Date of Birth")
+            age = gr.Textbox(label="Age")
+            sex = gr.Textbox(label="Sex")
+        
+        address = gr.Textbox(label="Address")
+        with gr.Row():
+            city = gr.Textbox(label="City")
+            state = gr.Textbox(label="State")
+            zip_code = gr.Textbox(label="Zip Code")
+        
+        gr.Markdown("## Primary Healthcare Professional Details")
+        with gr.Row():
+            doctor_first_name = gr.Textbox(label="Doctor's First Name")
+            doctor_last_name = gr.Textbox(label="Doctor's Last Name")
+            doctor_middle_initial = gr.Textbox(label="Middle Initial")
+        
+        hospital_name = gr.Textbox(label="Hospital/Clinic Name")
+        doctor_address = gr.Textbox(label="Address")
+        with gr.Row():
+            doctor_city = gr.Textbox(label="City")
+            doctor_state = gr.Textbox(label="State")
+            doctor_zip = gr.Textbox(label="Zip Code")
+        
+        gr.Markdown("## Admission and Discharge Details")
+        with gr.Row():
+            admission_date = gr.Textbox(label="Date of Admission")
+            referral_source = gr.Textbox(label="Source of Referral")
+        
+        admission_method = gr.Textbox(label="Method of Admission")
+        with gr.Row():
+            discharge_date = gr.Textbox(label="Date of Discharge")
+            discharge_reason = gr.Radio(["Treated", "Transferred", "Discharge Against Advice", "Patient Died"], label="Discharge Reason")
+        
+        date_of_death = gr.Textbox(label="Date of Death (if applicable)")
+        
+        gr.Markdown("## Diagnosis & Procedures")
+        diagnosis = gr.Textbox(label="Diagnosis")
+        procedures = gr.Textbox(label="Operation & Procedures")
+        
+        gr.Markdown("## Medication Details")
+        medications = gr.Textbox(label="Medication on Discharge")
+        
+        gr.Markdown("## Prepared By")
+        with gr.Row():
+            preparer_name = gr.Textbox(label="Name")
+            preparer_job_title = gr.Textbox(label="Job Title")
+        
+        submit = gr.Button("Generate Form")
+        output = gr.Markdown()
+        
+        submit.click(
+            display_form,
+            inputs=[
+                first_name, last_name, middle_initial, dob, age, sex, address, city, state, zip_code,
+                doctor_first_name, doctor_last_name, doctor_middle_initial, hospital_name, doctor_address,
+                doctor_city, doctor_state, doctor_zip,
+                admission_date, referral_source, admission_method, discharge_date, discharge_reason, date_of_death,
+                diagnosis, procedures, medications, preparer_name, preparer_job_title
+            ],
+            outputs=output
+        )
+
+demo.launch()

commandr.py

@@ -0,0 +1,20 @@
+from huggingface_hub import InferenceClient
+
+client = InferenceClient(api_key="YOUR_HF_TOKEN")
+
+messages = [
+	{ "role": "user", "content": "you are a senior expert medical health practitioner known for their abilities to decide on clinical discharge . you will recieve a clinical case study for a fictional patient. you should respond with the following model { \"response\" : { \"discharge\" : True/False } } if the patient should be discharged or not. produce only your final answer:\n\nPatient Name: Patient 2  \nGender: Female  \nAge: 72 years  \n\n### Presentation and Diagnosis:  \nThe patient presented to the emergency department in October 2024 with complaints of progressive shortness of breath, fatigue, and bilateral lower extremity edema persisting for three weeks. Initial evaluation revealed tachycardia, hypoxia (SpO2 88% on room air), and elevated blood pressure (168/94 mmHg). Laboratory findings demonstrated elevated brain natriuretic peptide (BNP) at 1,200 pg/mL, creatinine of 2.1 mg/dL (baseline 1.0 mg/dL), and a troponin I of 0.08 ng/mL. Chest X-ray showed bilateral pleural effusions and pulmonary congestion. An echocardiogram revealed a left ventricular ejection fraction (LVEF) of 25%, severe mitral regurgitation, and elevated pulmonary artery pressure (55 mmHg). Electrocardiogram (ECG) indicated sinus rhythm with left bundle branch block. The patient was diagnosed with acute decompensated heart failure (ADHF) secondary to ischemic cardiomyopathy, with concurrent stage IIIb chronic kidney disease (CKD) identified based on estimated glomerular filtration rate (eGFR) of 35 mL/min/1.73m². Coronary angiography performed subsequently confirmed triple-vessel coronary artery disease (CAD) with no immediate indication for revascularization due to high procedural risk.\n\n### Hospital Course:  \nThe patient was admitted to the cardiac care unit (CCU) and initiated on intravenous furosemide (40 mg IV twice daily) and supplemental oxygen via nasal cannula. Nitroglycerin infusion was started for preload reduction but was discontinued after 24 hours due to hypotension (systolic BP dropping to 85 mmHg). She was transitioned to oral guideline-directed medical therapy (GDMT), including carvedilol (3.125 mg twice daily), sacubitril/valsartan (24/26 mg twice daily), and spironolactone (25 mg daily), with doses titrated cautiously due to renal impairment and borderline blood pressure. Despite initial improvement in dyspnea and reduction in edema, the patient developed worsening renal function (creatinine peaked at 2.8 mg/dL, eGFR 25 mL/min/1.73m²) by hospital day 5, prompting a temporary hold on diuretics and angiotensin receptor-neprilysin inhibitor (ARNI) therapy. Nephrology was consulted, and ultrafiltration was initiated for volume overload management, achieving a net fluid removal of 4 liters over 72 hours. \n\nBy hospital day 10, the patient stabilized hemodynamically (BP 110/70 mmHg, SpO2 94% on 2L oxygen), but attempts to wean oxygen supplementation resulted in recurrent hypoxia. Repeat echocardiography showed persistent LVEF of 25% with no improvement in mitral regurgitation. A multidisciplinary team discussion concluded that the patient’s advanced heart failure, compounded by CKD and frailty (Clinical Frailty Scale score of 6), precluded discharge to home. She was deemed high-risk for outpatient management due to recurrent decompensation risk, frequent monitoring needs, and inability to tolerate optimal GDMT dosing. A trial of inotropic support with dobutamine (2.5 mcg/kg/min) was initiated on hospital day 14 to improve cardiac output, with partial symptomatic relief but no significant change in LVEF or renal function. \n\nOn hospital day 20, the patient developed a hospital-acquired pneumonia, confirmed by chest X-ray (right lower lobe consolidation) and sputum culture positive for *Klebsiella pneumoniae*. She was started on piperacillin-tazobactam (adjusted for renal function), but her respiratory status deteriorated, requiring escalation to high-flow nasal cannula (HFNC) at 40 L/min with FiO2 of 60%. Infectious disease and pulmonology consultations recommended a 10-day antibiotic course and supportive care, but the patient’s frailty and poor cardiac reserve limited recovery. By hospital day 30, she remained oxygen-dependent, with persistent volume overload and worsening renal function (creatinine 3.2 mg/dL, eGFR 20 mL/min/1.73m²), necessitating ongoing ultrafiltration and inotropic support.\n\n### Current Status:  \nAs of February 28, 2025, the patient remains hospitalized in a step-down unit, unable to be discharged due to chronic dependence on inotropic therapy (dobutamine 2.5 mcg/kg/min) and supplemental oxygen (HFNC at 30 L/min, FiO2 50%). Her advanced heart failure, compounded by recurrent infections, severe CKD, and poor functional status, renders her ineligible for home care or transfer to a lower-acuity facility. Palliative care has been engaged to discuss goals of care, but the patient and family have declined hospice transition, opting for continued aggressive management. She experiences intermittent dyspnea at rest, fatigue, and fluctuating mental status (likely due to hypoperfusion and medication effects), requiring constant nursing supervision. Long-term plans include evaluation for potential left ventricular assist device (LVAD) candidacy, though her comorbidities and frailty pose significant barriers." },
+#	{ "role": "assistant", "content": "{\n    \"response\": {\n        \"discharge\": false\n    }\n}" }
+]
+
+stream = client.chat.completions.create(
+    model="CohereForAI/c4ai-command-r-plus-08-2024", 
+	messages=messages, 
+	temperature=0.4,
+	max_tokens=1280,
+	top_p=0.7,
+	stream=True
+)
+
+for chunk in stream:
+    print(chunk.choices[0].delta.content)

hospital.py

@@ -0,0 +1,120 @@
+import gradio as gr
+
+def display_form(
+    first_name, last_name, middle_initial, dob, age, sex, address, city, state, zip_code,
+    doctor_first_name, doctor_last_name, doctor_middle_initial, hospital_name, doctor_address,
+    doctor_city, doctor_state, doctor_zip,
+    admission_date, referral_source, admission_method, discharge_date, discharge_reason, date_of_death,
+    diagnosis, procedures, medications, preparer_name, preparer_job_title
+):
+    form = f"""
+    **Patient Discharge Form**
+    
+    **Patient Details:**
+    - Name: {first_name} {middle_initial} {last_name}
+    - Date of Birth: {dob}, Age: {age}, Sex: {sex}
+    - Address: {address}, {city}, {state}, {zip_code}
+    
+    **Primary Healthcare Professional Details:**
+    - Name: {doctor_first_name} {doctor_middle_initial} {doctor_last_name}
+    - Hospital/Clinic: {hospital_name}
+    - Address: {doctor_address}, {doctor_city}, {doctor_state}, {doctor_zip}
+    
+    **Admission and Discharge Details:**
+    - Date of Admission: {admission_date}
+    - Source of Referral: {referral_source}
+    - Method of Admission: {admission_method}
+    - Date of Discharge: {discharge_date}
+    - Discharge Reason: {discharge_reason}
+    - Date of Death (if applicable): {date_of_death}
+    
+    **Diagnosis & Procedures:**
+    - Diagnosis: {diagnosis}
+    - Procedures: {procedures}
+    
+    **Medication Details:**
+    - Medications on Discharge: {medications}
+    
+    **Prepared By:**
+    - Name: {preparer_name}, Job Title: {preparer_job_title}
+    """
+    return form
+
+with gr.Blocks() as demo:
+    gr.Markdown("# Patient Discharge Form")
+    
+    with gr.Row():
+        first_name = gr.Textbox(label="First Name")
+        last_name = gr.Textbox(label="Last Name")
+        middle_initial = gr.Textbox(label="Middle Initial")
+    
+    with gr.Row():
+        dob = gr.Textbox(label="Date of Birth")
+        age = gr.Textbox(label="Age")
+        sex = gr.Textbox(label="Sex")
+    
+    address = gr.Textbox(label="Address")
+    
+    with gr.Row():
+        city = gr.Textbox(label="City")
+        state = gr.Textbox(label="State")
+        zip_code = gr.Textbox(label="Zip Code")
+    
+    gr.Markdown("## Primary Healthcare Professional Details")
+    
+    with gr.Row():
+        doctor_first_name = gr.Textbox(label="Doctor's First Name")
+        doctor_last_name = gr.Textbox(label="Doctor's Last Name")
+        doctor_middle_initial = gr.Textbox(label="Middle Initial")
+    
+    hospital_name = gr.Textbox(label="Hospital/Clinic Name")
+    doctor_address = gr.Textbox(label="Address")
+    
+    with gr.Row():
+        doctor_city = gr.Textbox(label="City")
+        doctor_state = gr.Textbox(label="State")
+        doctor_zip = gr.Textbox(label="Zip Code")
+    
+    gr.Markdown("## Admission and Discharge Details")
+    
+    with gr.Row():
+        admission_date = gr.Textbox(label="Date of Admission")
+        referral_source = gr.Textbox(label="Source of Referral")
+    
+    admission_method = gr.Textbox(label="Method of Admission")
+    
+    with gr.Row():
+        discharge_date = gr.Textbox(label="Date of Discharge")
+        discharge_reason = gr.Radio(["Treated", "Transferred", "Discharge Against Advice", "Patient Died"], label="Discharge Reason")
+    
+    date_of_death = gr.Textbox(label="Date of Death (if applicable)")
+    
+    gr.Markdown("## Diagnosis & Procedures")
+    diagnosis = gr.Textbox(label="Diagnosis")
+    procedures = gr.Textbox(label="Operation & Procedures")
+    
+    gr.Markdown("## Medication Details")
+    medications = gr.Textbox(label="Medication on Discharge")
+    
+    gr.Markdown("## Prepared By")
+    
+    with gr.Row():
+        preparer_name = gr.Textbox(label="Name")
+        preparer_job_title = gr.Textbox(label="Job Title")
+    
+    submit = gr.Button("Generate Form")
+    output = gr.Markdown()
+    
+    submit.click(
+        display_form,
+        inputs=[
+            first_name, last_name, middle_initial, dob, age, sex, address, city, state, zip_code,
+            doctor_first_name, doctor_last_name, doctor_middle_initial, hospital_name, doctor_address,
+            doctor_city, doctor_state, doctor_zip,
+            admission_date, referral_source, admission_method, discharge_date, discharge_reason, date_of_death,
+            diagnosis, procedures, medications, preparer_name, preparer_job_title
+        ],
+        outputs=output
+    )
+
+demo.launch()

interfacehospital.py

@@ -0,0 +1,63 @@
+import gradio as gr
+
+def display_discharge_form(
+    patient_first, patient_last, patient_middle, dob, age, sex, address, city, state, zip_code,
+    doctor_first, doctor_last, doctor_middle, hospital, doctor_address, doctor_city, doctor_state, doctor_zip,
+    admission_date, referral_source, admission_method, discharge_date, discharge_reason, death_date,
+    diagnosis, procedures, medications, preparer_name, job_title, signature
+):
+    
+    form = f"""
+    **Patient Details:**
+    - **Name:** {patient_first} {patient_middle} {patient_last}
+    - **Date of Birth:** {dob}, **Age:** {age}, **Sex:** {sex}
+    - **Address:** {address}, {city}, {state} {zip_code}
+
+    **Primary Healthcare Professional Details:**
+    - **Name:** {doctor_first} {doctor_middle} {doctor_last}
+    - **Hospital/Clinic:** {hospital}
+    - **Address:** {doctor_address}, {doctor_city}, {doctor_state} {doctor_zip}
+    
+    **Admission and Discharge Details:**
+    - **Date of Admission:** {admission_date}
+    - **Source of Referral:** {referral_source}
+    - **Method of Admission:** {admission_method}
+    - **Date of Discharge:** {discharge_date}
+    - **Discharge Reason:** {discharge_reason}
+    - **Date of Death:** {death_date if discharge_reason == 'Patient Died' else 'N/A'}
+
+    **Diagnosis & Procedures:**
+    - **Diagnosis:** {diagnosis}
+    - **Operations & Procedures:** {procedures}
+
+    **Medication Details:**
+    - **Medication on Discharge:** {medications}
+
+    **Prepared By:**
+    - **Name:** {preparer_name}, **Job Title:** {job_title}
+    - **Signature:** {signature}
+    """
+    return form
+
+discharge_interface = gr.Interface(
+    fn=display_discharge_form,
+    inputs=[
+        gr.Textbox(label="Patient First Name"), gr.Textbox(label="Patient Last Name"), gr.Textbox(label="Patient Middle Initial"),
+        gr.Textbox(label="Date of Birth"), gr.Textbox(label="Age"), gr.Textbox(label="Sex"),
+        gr.Textbox(label="Address"), gr.Textbox(label="City"), gr.Textbox(label="State"), gr.Textbox(label="Zip Code"),
+        gr.Textbox(label="Doctor First Name"), gr.Textbox(label="Doctor Last Name"), gr.Textbox(label="Doctor Middle Initial"),
+        gr.Textbox(label="Hospital/Clinic Name"), gr.Textbox(label="Doctor Address"),
+        gr.Textbox(label="Doctor City"), gr.Textbox(label="Doctor State"), gr.Textbox(label="Doctor Zip Code"),
+        gr.Textbox(label="Date of Admission"), gr.Textbox(label="Source of Referral"), gr.Textbox(label="Method of Admission"),
+        gr.Textbox(label="Date of Discharge"), gr.Radio(["Treated", "Transferred", "Discharge Against Advice", "Patient Died"], label="Discharge Reason"),
+        gr.Textbox(label="Date of Death (if applicable)"),
+        gr.Textbox(label="Diagnosis"), gr.Textbox(label="Operations & Procedures"),
+        gr.Textbox(label="Medication on Discharge"),
+        gr.Textbox(label="Prepared By (Name)"), gr.Textbox(label="Job Title"), gr.Textbox(label="Signature"),
+    ],
+    outputs=gr.Markdown(),
+    title="Patient Discharge Form",
+    description="Fill in the required fields to generate a complete patient discharge summary."
+)
+
+discharge_interface.launch()

llamaprompt.py

@@ -0,0 +1,22 @@
+from huggingface_hub import InferenceClient
+
+client = InferenceClient(api_key="YOUR_HF_TOKEN")
+
+messages = [
+	{ "role": "user", "content": "" },
+	{ "role": "assistant", "content": "you are a senior expert medical health practitioner known for their abilities to produce discharge papers. you will recieve patient information and treatment cursus. Produce a complete discharge summary based on the information provided. produce complete discharge summary." },
+	{ "role": "user", "content": "Patient Name: Patient 1\nGender: Male\nAge: 65 years\n\nPresentation and Diagnosis:\nThe patient was diagnosed with acute myeloid leukemia (AML) in January 2020 based on leukocytosis, thrombocytopenia and anemia. Bone marrow aspiration revealed a hypercellular bone marrow with 50% blasts. The patient was further assessed using flow cytometry and cytogenetics, and molecular panel testing showed aberrations in ASXL1, CEBPA, JAK2, and RUNX1. AML with adverse risk was diagnosed according to genetic risk stratification.\n\nHospital Course:\nAfter one course of induction treatment with the IA regimen, the patient achieved complete remission with low minimal residual disease. Genetic analyses showed negative gene mutations, and the patient received consolidation therapies with the IA regimen and high-dose Ara-c (HiDAC) regimen. However, remission duration only lasted for 11 months, and in November 2020, relapsed BM morphology was detected, indicating relapsed AML with concurrent molecular aberration recurrence. The patient underwent several treatment regimens, including venetoclax combined with azacitidine and chidamide with venetoclax and azacitidine regimen. He achieved complete remission after one course of the chidamide combined regimen.\n\nOutcome:\nThe patient passed away due to disease progression three months after the completion of therapy." },
+#	{ "role": "assistant", "content": "**DISCHARGE SUMMARY**\n\n**Patient Name:** Patient 1\n**Gender:** Male\n**Age:** 65 years\n**Medical Record Number:** [Insert MRN]\n**Date of Admission:** [Insert Date]\n**Date of Discharge:** [Insert Date]\n**Discharge Diagnosis:**\n1. Acute Myeloid Leukemia (AML) with adverse risk\n2. Relapsed AML with molecular aberration recurrence\n\n**History of Present Illness:**\nThe patient was initially diagnosed with Acute Myeloid Leukemia (AML) in January 2020, characterized by leukocytosis, thrombocytopenia, and anemia. Bone marrow aspiration revealed a hypercellular bone marrow with 50% blasts. Further genetic and molecular testing identified aberrations in ASXL1, CEBPA, JAK2, and RUNX1, categorizing the AML as high risk.\n\n**Treatment Course:**\n- The patient underwent induction therapy with the IA regimen, achieving complete remission with minimal residual disease.\n- Consolidation therapies included the IA regimen and high-dose Ara-c (HiDAC) regimen.\n- Despite initial remission, the patient relapsed 11 months later, with detection of relapsed BM morphology and concurrent molecular aberration recurrence.\n- Subsequent treatments included venetoclax combined with azacitidine and a regimen of chidamide with venetoclax and azacitidine, with the latter resulting in complete remission.\n\n**Outcome:**\nUnfortunately, the patient's disease progressed, and he passed away three months after completing the last therapy regimen.\n\n**Discharge Condition:**\nThe patient was discharged in a terminal condition due to disease progression.\n\n**Medications at Discharge:**\n[Insert list of medications the patient was on at the time of discharge, including dosages and frequencies]\n\n**Follow-Up Care:**\nGiven the patient's demise, follow-up care was not applicable. However, the family was counseled regarding the disease progression and the options for bereavement support.\n\n**Instructions to Patient/Family:**\nAt the time of discharge, the patient and family were informed about the terminal nature of the disease and the focus was shifted to palliative care. They were provided with information on hospice care services and bereavement counseling.\n\n**Condition at Time of Discharge:**\nThe patient's condition at discharge was terminal, with evidence of disease progression despite aggressive treatment.\n\n**Certification:**\nI, [Your Name], hereby certify that the information contained in this discharge summary is accurate and complete to the best of my knowledge. I can be reached at [Your Contact Information] for any further questions or clarifications.\n\n**Signature:** [Your Signature]\n**Date:** [Current Date]\n**Title:** Senior Expert Medical Health Practitioner" }
+]
+
+stream = client.chat.completions.create(
+    model="meta-llama/Llama-3.3-70B-Instruct", 
+	messages=messages, 
+	temperature=0.4,
+	max_tokens=3584,
+	top_p=0.7,
+	stream=True
+)
+
+for chunk in stream:
+    print(chunk.choices[0].delta.content)

meldrx.py

@@ -0,0 +1,361 @@
+import requests
+import json
+from typing import Optional, Dict, Any
+
+class MeldRxAPI:
+    """
+    A Python class to interact with the MeldRx API, including the MIPS API.
+    Provides methods to authenticate, retrieve/update patients, create virtual workspaces,
+    and interact with encounter data.
+    """
+
+    def __init__(self, client_id: str, client_secret: str, workspace_id: str):
+        """
+        Initialize the MeldRxAPI class with client credentials and workspace ID.
+
+        Args:
+            client_id (str): The client ID (App ID) obtained from MeldRx Developer Portal.
+            client_secret (str): The client secret for authentication.
+            workspace_id (str): The workspace slug/ID to interact with.
+        """
+        self.base_url = "https://app.meldrx.com"
+        self.api_base_url = f"{self.base_url}/api"
+        self.fhir_base_url = f"{self.api_base_url}/fhir/{workspace_id}"
+        self.mips_base_url = f"{self.base_url}/mms-api"  # MIPS API base URL
+        self.token_url = f"{self.base_url}/connect/token"
+        self.client_id = client_id
+        self.client_secret = client_secret
+        self.workspace_id = workspace_id
+        self.access_token = None
+        self.session = requests.Session()
+
+    def authenticate(self) -> bool:
+        """
+        Authenticate with the MeldRx API to obtain an access token.
+
+        Returns:
+            bool: True if authentication is successful, False otherwise.
+        """
+        payload = {
+            "grant_type": "client_credentials",
+            "client_id": self.client_id,
+            "client_secret": self.client_secret
+        }
+        headers = {"Content-Type": "application/x-www-form-urlencoded"}
+
+        try:
+            response = self.session.post(self.token_url, data=payload, headers=headers)
+            response.raise_for_status()
+            token_data = response.json()
+            self.access_token = token_data.get("access_token")
+            if not self.access_token:
+                raise ValueError("No access token received from the server.")
+            return True
+        except requests.RequestException as e:
+            print(f"Authentication failed: {e}")
+            return False
+        except ValueError as e:
+            print(f"Authentication error: {e}")
+            return False
+
+    def _get_headers(self) -> Dict[str, str]:
+        """
+        Generate headers with the Bearer token for authenticated requests.
+
+        Returns:
+            Dict[str, str]: Headers dictionary with Authorization token if available.
+        """
+        headers = {"Content-Type": "application/json"}
+        if self.access_token:
+            headers["Authorization"] = f"Bearer {self.access_token}"
+        return headers
+
+    def get_patients(self) -> Optional[Dict[str, Any]]:
+        """
+        Retrieve a list of patients from the specified workspace (FHIR API).
+
+        Returns:
+            Optional[Dict[str, Any]]: Patient data as a dictionary if successful, None otherwise.
+        """
+        url = f"{self.fhir_base_url}/Patient"
+
+        if not self.access_token and not self.authenticate():
+            print("Cannot proceed without authentication.")
+            return None
+
+        try:
+            response = self.session.get(url, headers=self._get_headers())
+            response.raise_for_status()
+            return response.json() if response.text else {}
+        except requests.RequestException as e:
+            print(f"Failed to retrieve patients: {e}")
+            return None
+        
+    def get_authorization_url(self, scope: str = "patient/*.read openid profile", state: str = "random_state") -> str:
+            """
+            Generate the SMART on FHIR authorization URL for patient login.
+
+            Args:
+                scope (str): The requested scopes (default: patient/*.read openid profile).
+                state (str): A random state string for security (default: random_state).
+
+            Returns:
+                str: The authorization URL to open in a browser.
+            """
+            params = {
+                "response_type": "code",
+                "client_id": self.client_id,
+                "redirect_uri": self.redirect_uri,
+                "scope": scope,
+                "state": state,
+                "aud": self.fhir_base_url
+            }
+            query_string = "&".join(f"{k}={v}" for k, v in params.items())
+            return f"{self.authorize_url}?{query_string}"
+
+    def authenticate_with_code(self, auth_code: str) -> bool:
+        """
+        Exchange an authorization code for an access token.
+
+        Args:
+            auth_code (str): The authorization code from the redirect URI.
+
+        Returns:
+            bool: True if authentication is successful, False otherwise.
+        """
+        payload = {
+            "grant_type": "authorization_code",
+            "code": auth_code,
+            "redirect_uri": self.redirect_uri,
+            "client_id": self.client_id
+        }
+        if self.client_secret:
+            payload["client_secret"] = self.client_secret
+        headers = {"Content-Type": "application/x-www-form-urlencoded"}
+
+        try:
+            response = self.session.post(self.token_url, data=payload, headers=headers)
+            response.raise_for_status()
+            token_data = response.json()
+            self.access_token = token_data.get("access_token")
+            if not self.access_token:
+                raise ValueError("No access token received from the server.")
+            return True
+        except requests.RequestException as e:
+            print(f"Authentication failed: {e}")
+            return False
+        except ValueError as e:
+            print(f"Authentication error: {e}")
+            return False
+    def create_virtual_workspace(self, snapshot: str = "patient-prefetch",
+                               patient_id: str = "AutoPopulatedIfNotManuallySet",
+                               hook: str = "patient-view") -> bool:
+        """
+        Create a virtual workspace in the specified workspace (FHIR API).
+
+        Args:
+            snapshot (str): The snapshot type (default: "patient-prefetch").
+            patient_id (str): The patient ID (default: "AutoPopulatedIfNotManuallySet").
+            hook (str): The hook type (default: "patient-view").
+
+        Returns:
+            bool: True if the virtual workspace is created successfully, False otherwise.
+        """
+        url = f"{self.fhir_base_url}/$virtual-workspace"
+
+        if not self.access_token and not self.authenticate():
+            print("Cannot proceed without authentication.")
+            return False
+
+        payload = {"snapshot": snapshot, "patientId": patient_id, "hook": hook}
+
+        try:
+            response = self.session.post(url, data=json.dumps(payload), headers=self._get_headers())
+            response.raise_for_status()
+            return True
+        except requests.RequestException as e:
+            print(f"Failed to create virtual workspace: {e}")
+            return False
+
+    def get_mips_patients(self) -> Optional[Dict[str, Any]]:
+        """
+        Retrieve a list of patients from the MIPS API.
+
+        Returns:
+            Optional[Dict[str, Any]]: Patient data as a dictionary if successful, None otherwise.
+        """
+        url = f"{self.mips_base_url}/Patient"
+
+        if not self.access_token and not self.authenticate():
+            print("Cannot proceed without authentication.")
+            return None
+
+        try:
+            response = self.session.get(url, headers=self._get_headers())
+            response.raise_for_status()
+            return response.json() if response.text else {}
+        except requests.RequestException as e:
+            print(f"Failed to retrieve MIPS patients: {e}")
+            return None
+
+    def get_mips_patient_by_id(self, patient_id: str) -> Optional[Dict[str, Any]]:
+        """
+        Retrieve patient information by ID from the MIPS API.
+
+        Args:
+            patient_id (str): The ID of the patient to retrieve.
+
+        Returns:
+            Optional[Dict[str, Any]]: Patient data as a dictionary if successful, None otherwise.
+        """
+        url = f"{self.mips_base_url}/Patient/{patient_id}"
+
+        if not self.access_token and not self.authenticate():
+            print("Cannot proceed without authentication.")
+            return None
+
+        try:
+            response = self.session.get(url, headers=self._get_headers())
+            response.raise_for_status()
+            return response.json() if response.text else {}
+        except requests.RequestException as e:
+            print(f"Failed to retrieve patient {patient_id}: {e}")
+            return None
+
+    def get_mips_encounters(self, patient_id: str = None) -> Optional[Dict[str, Any]]:
+        """
+        Retrieve encounters from the MIPS API, optionally filtered by patient ID.
+
+        Args:
+            patient_id (str, optional): The ID of the patient to filter encounters by.
+
+        Returns:
+            Optional[Dict[str, Any]]: Encounter data as a dictionary if successful, None otherwise.
+        """
+        url = f"{self.mips_base_url}/Encounter"
+        if patient_id:
+            url += f"?patient={patient_id}"
+
+        if not self.access_token and not self.authenticate():
+            print("Cannot proceed without authentication.")
+            return None
+
+        try:
+            response = self.session.get(url, headers=self._get_headers())
+            response.raise_for_status()
+            return response.json() if response.text else {}
+        except requests.RequestException as e:
+            print(f"Failed to retrieve encounters: {e}")
+            return None
+
+    def update_fhir_patient(self, patient_id: str, patient_data: Dict[str, Any]) -> bool:
+        """
+        Update patient data in the FHIR API using a PUT request.
+
+        Args:
+            patient_id (str): The ID of the patient to update.
+            patient_data (Dict[str, Any]): The updated patient data in FHIR JSON format.
+
+        Returns:
+            bool: True if the patient is updated successfully, False otherwise.
+        """
+        url = f"{self.fhir_base_url}/Patient/{patient_id}"
+
+        if not self.access_token and not self.authenticate():
+            print("Cannot proceed without authentication.")
+            return False
+
+        try:
+            response = self.session.put(url, data=json.dumps(patient_data), headers=self._get_headers())
+            response.raise_for_status()
+            return True
+        except requests.RequestException as e:
+            print(f"Failed to update FHIR patient {patient_id}: {e}")
+            return False
+
+    def update_mips_patient(self, patient_id: str, patient_data: Dict[str, Any]) -> bool:
+        """
+        Update patient data in the MIPS API using a PUT request.
+
+        Args:
+            patient_id (str): The ID of the patient to update.
+            patient_data (Dict[str, Any]): The updated patient data in FHIR JSON format.
+
+        Returns:
+            bool: True if the patient is updated successfully, False otherwise.
+        """
+        url = f"{self.mips_base_url}/Patient/{patient_id}"
+
+        if not self.access_token and not self.authenticate():
+            print("Cannot proceed without authentication.")
+            return False
+
+        try:
+            response = self.session.put(url, data=json.dumps(patient_data), headers=self._get_headers())
+            response.raise_for_status()
+            return True
+        except requests.RequestException as e:
+            print(f"Failed to update MIPS patient {patient_id}: {e}")
+            return False
+
+    def close(self):
+        """Close the session to free up resources."""
+        self.session.close()
+
+    def __enter__(self):
+        """Support for context manager entry."""
+        return self
+
+    def __exit__(self, exc_type, exc_val, exc_tb):
+        """Support for context manager exit, ensuring session is closed."""
+        self.close()
+
+
+# # Example usage with patient update functionality
+# if __name__ == "__main__":
+#     # Replace these with your actual credentials and workspace ID
+#     CLIENT_ID = "your_client_id"
+#     CLIENT_SECRET = "your_client_secret"
+#     WORKSPACE_ID = "your_workspace_id"
+#     PATIENT_ID = "example_patient_id"  # Replace with an actual patient ID
+
+#     with MeldRxAPI(client_id=CLIENT_ID, client_secret=CLIENT_SECRET, workspace_id=WORKSPACE_ID) as meldrx:
+#         # Authenticate
+#         if meldrx.authenticate():
+#             print("Authentication successful!")
+
+#             # Retrieve specific patient information from MIPS API
+#             patient_info = meldrx.get_mips_patient_by_id(PATIENT_ID)
+#             if patient_info is not None:
+#                 print(f"Original Patient {PATIENT_ID} Info:", json.dumps(patient_info, indent=2))
+
+#             # Example patient data to update (FHIR Patient resource format)
+#             updated_patient_data = {
+#                 "resourceType": "Patient",
+#                 "id": PATIENT_ID,
+#                 "name": [{
+#                     "family": "Doe",
+#                     "given": ["John", "Updated"]
+#                 }],
+#                 "gender": "male",
+#                 "birthDate": "1980-01-01"
+#             }
+
+#             # Update patient in FHIR API
+#             if meldrx.update_fhir_patient(PATIENT_ID, updated_patient_data):
+#                 print(f"Successfully updated patient {PATIENT_ID} in FHIR API")
+#                 updated_info = meldrx.get_mips_patient_by_id(PATIENT_ID)
+#                 if updated_info:
+#                     print(f"Updated Patient {PATIENT_ID} Info (FHIR):", json.dumps(updated_info, indent=2))
+
+#             # Update patient in MIPS API
+#             if meldrx.update_mips_patient(PATIENT_ID, updated_patient_data):
+#                 print(f"Successfully updated patient {PATIENT_ID} in MIPS API")
+#                 updated_info = meldrx.get_mips_patient_by_id(PATIENT_ID)
+#                 if updated_info:
+#                     print(f"Updated Patient {PATIENT_ID} Info (MIPS):", json.dumps(updated_info, indent=2))
+
+#             # Retrieve encounters for the patient from MIPS API
+#             encounters = meldrx.get_mips_encounters(patient_id=PATIENT_ID)
+#             if encounters is not None:
+#                 print(f"Encounters for Patient {PATIENT_ID}:", json.dumps(encounters, indent=2))

meldrxtester.py

@@ -0,0 +1,106 @@
+import requests
+import json
+from typing import Optional, Dict, Any
+from meldrx import MeldRxAPI
+
+# Testing class
+class MeldRxAPITest:
+    """A class to test the functionality of the MeldRxAPI class."""
+
+    def __init__(self):
+        # Placeholder variables (replace with real values for live testing)
+        self.client_id = "04bdc9f9a23d488a868b93d594ee5a4a"
+        self.client_secret = "test_client_secret"
+        self.workspace_id = "09ed4f76-b5ac-42bf-92d5-496933203dbe"
+        self.test_patient_id = "05f7c0c2-ebee-44db-ab71-2113e7a70acb"
+        self.api = MeldRxAPI(self.client_id, self.client_secret, self.workspace_id)
+
+    def test_authenticate(self):
+        """Test the authentication method."""
+        print("\n=== Testing Authentication ===")
+        result = self.api.authenticate()
+        print(f"Authentication Result: {result}")
+        if result:
+            print(f"Access Token: {self.api.access_token[:10]}... (truncated for brevity)")
+        else:
+            print("Authentication failed. Subsequent tests may not work as expected.")
+
+    def test_get_patients(self):
+        """Test retrieving patients from the FHIR API."""
+        print("\n=== Testing Get Patients (FHIR) ===")
+        patients = self.api.get_patients()
+        if patients is not None:
+            print("Patients Retrieved Successfully:")
+            print(json.dumps(patients, indent=2) if patients else "No data returned (expected per docs)")
+        else:
+            print("Failed to retrieve patients.")
+
+    def test_create_virtual_workspace(self):
+        """Test creating a virtual workspace."""
+        print("\n=== Testing Create Virtual Workspace ===")
+        success = self.api.create_virtual_workspace(
+            snapshot="patient-prefetch",
+            patient_id=self.test_patient_id,
+            hook="patient-view"
+        )
+        print(f"Virtual Workspace Creation Result: {success}")
+        if success:
+            print("Virtual workspace created successfully (no response body expected).")
+        else:
+            print("Failed to create virtual workspace.")
+
+    def test_get_mips_patients(self):
+        """Test retrieving patients from the MIPS API."""
+        print("\n=== Testing Get MIPS Patients ===")
+        patients = self.api.get_mips_patients()
+        if patients is not None:
+            print("MIPS Patients Retrieved Successfully:")
+            print(json.dumps(patients, indent=2) if patients else "No data returned")
+        else:
+            print("Failed to retrieve MIPS patients.")
+
+    def test_get_mips_patient_by_id(self):
+        """Test retrieving a specific patient by ID from the MIPS API."""
+        print("\n=== Testing Get MIPS Patient by ID ===")
+        patient = self.api.get_mips_patient_by_id(self.test_patient_id)
+        if patient is not None:
+            print(f"Patient {self.test_patient_id} Retrieved Successfully:")
+            print(json.dumps(patient, indent=2) if patient else "No data returned")
+        else:
+            print(f"Failed to retrieve patient {self.test_patient_id}.")
+
+    def test_get_mips_encounters(self):
+        """Test retrieving encounters from the MIPS API (with and without patient filter)."""
+        print("\n=== Testing Get MIPS Encounters (All) ===")
+        encounters = self.api.get_mips_encounters()
+        if encounters is not None:
+            print("All Encounters Retrieved Successfully:")
+            print(json.dumps(encounters, indent=2) if encounters else "No data returned")
+        else:
+            print("Failed to retrieve all encounters.")
+
+        print("\n=== Testing Get MIPS Encounters (Filtered by Patient) ===")
+        encounters_filtered = self.api.get_mips_encounters(self.test_patient_id)
+        if encounters_filtered is not None:
+            print(f"Encounters for Patient {self.test_patient_id} Retrieved Successfully:")
+            print(json.dumps(encounters_filtered, indent=2) if encounters_filtered else "No data returned")
+        else:
+            print(f"Failed to retrieve encounters for patient {self.test_patient_id}.")
+
+    def run_all_tests(self):
+        """Run all test methods in sequence."""
+        print("Starting MeldRx API Tests...\n")
+        self.test_authenticate()
+        self.test_get_patients()
+        self.test_create_virtual_workspace()
+        self.test_get_mips_patients()
+        self.test_get_mips_patient_by_id()
+        self.test_get_mips_encounters()
+        print("\nAll tests completed.")
+        self.api.close()
+
+
+# Run the tests
+if __name__ == "__main__":
+    tester = MeldRxAPITest()
+    tester.run_all_tests()

meldrxtester2.py

@@ -0,0 +1,140 @@
+import requests
+import json
+from typing import Optional, Dict, Any
+from meldrx import MeldRxAPI  # Assuming meldrx.py contains the updated MeldRxAPI with SMART on FHIR
+
+class MeldRxAPITest:
+    """A class to test the functionality of the MeldRxAPI class with SMART on FHIR and Gradio callback."""
+
+    def __init__(self):
+        # Placeholder variables (replace with real values for live testing)
+        self.client_id = "04bdc9f9a23d488a868b93d594ee5a4a"  # Replace with your actual client ID
+        self.redirect_uri = "https://multitransformer-discharge-guard.hf.space/callback"  # Gradio Space callback URL
+        self.workspace_id = "09ed4f76-b5ac-42bf-92d5-496933203dbe"  # Replace with your workspace ID
+        self.test_patient_id = "05f7c0c2-ebee-44db-ab71-2113e7a70acb"  # Replace with a valid patient ID
+        self.client_secret = None  # Optional; set if using a confidential client
+        self.api = MeldRxAPI(self.client_id, self.redirect_uri, self.workspace_id, self.client_secret)
+        self.auth_code = None
+        self.access_token = None
+
+    def _print_section(self, title: str):
+        """Helper method to print section headers."""
+        print(f"\n{'=' * 10} {title} {'=' * 10}")
+
+    def test_get_auth_url(self):
+        """Test generating the SMART on FHIR authorization URL."""
+        self._print_section("Testing Get Authorization URL")
+        auth_url = self.api.get_authorization_url()
+        print(f"Generated Authorization URL:\n{auth_url}")
+        print("Action: Open this URL in a browser, log in, and copy the 'code' from the redirect URL.")
+
+    def test_authenticate_with_code(self):
+        """Test authentication using an authorization code (simulating Gradio callback)."""
+        self._print_section("Testing Authenticate with Code")
+        self.auth_code = input("Enter the authorization code from the redirect URL (or press Enter to skip): ").strip()
+        if not self.auth_code:
+            print("No code provided. Skipping authentication test.")
+            return
+        result = self.api.authenticate_with_code(self.auth_code)
+        print(f"Authentication Result: {result}")
+        if result:
+            self.access_token = self.api.access_token
+            print(f"Access Token: {self.access_token[:10]}... (truncated for brevity)")
+        else:
+            print("Authentication failed. Subsequent tests may not work as expected.")
+
+    def test_get_patients(self):
+        """Test retrieving patients from the FHIR API."""
+        self._print_section("Testing Get Patients (FHIR)")
+        if not self.access_token:
+            print("Not authenticated. Run test_authenticate_with_code first.")
+            return
+        patients = self.api.get_patients()
+        if patients is not None:
+            print("Patients Retrieved Successfully:")
+            print(json.dumps(patients, indent=2) if patients else "No data returned (expected per docs)")
+        else:
+            print("Failed to retrieve patients.")
+
+    def test_create_virtual_workspace(self):
+        """Test creating a virtual workspace."""
+        self._print_section("Testing Create Virtual Workspace")
+        if not self.access_token:
+            print("Not authenticated. Run test_authenticate_with_code first.")
+            return
+        success = self.api.create_virtual_workspace(
+            snapshot="patient-prefetch",
+            patient_id=self.test_patient_id,
+            hook="patient-view"
+        )
+        print(f"Virtual Workspace Creation Result: {success}")
+        if success:
+            print("Virtual workspace created successfully (no response body expected).")
+        else:
+            print("Failed to create virtual workspace.")
+
+    def test_get_mips_patients(self):
+        """Test retrieving patients from the MIPS API."""
+        self._print_section("Testing Get MIPS Patients")
+        if not self.access_token:
+            print("Not authenticated. Run test_authenticate_with_code first.")
+            return
+        patients = self.api.get_mips_patients()
+        if patients is not None:
+            print("MIPS Patients Retrieved Successfully:")
+            print(json.dumps(patients, indent=2) if patients else "No data returned")
+        else:
+            print("Failed to retrieve MIPS patients.")
+
+    def test_get_mips_patient_by_id(self):
+        """Test retrieving a specific patient by ID from the MIPS API."""
+        self._print_section("Testing Get MIPS Patient by ID")
+        if not self.access_token:
+            print("Not authenticated. Run test_authenticate_with_code first.")
+            return
+        patient = self.api.get_mips_patient_by_id(self.test_patient_id)
+        if patient is not None:
+            print(f"Patient {self.test_patient_id} Retrieved Successfully:")
+            print(json.dumps(patient, indent=2) if patient else "No data returned")
+        else:
+            print(f"Failed to retrieve patient {self.test_patient_id}.")
+
+    def test_get_mips_encounters(self):
+        """Test retrieving encounters from the MIPS API (with and without patient filter)."""
+        self._print_section("Testing Get MIPS Encounters (All)")
+        if not self.access_token:
+            print("Not authenticated. Run test_authenticate_with_code first.")
+            return
+        encounters = self.api.get_mips_encounters()
+        if encounters is not None:
+            print("All Encounters Retrieved Successfully:")
+            print(json.dumps(encounters, indent=2) if encounters else "No data returned")
+        else:
+            print("Failed to retrieve all encounters.")
+
+        self._print_section("Testing Get MIPS Encounters (Filtered by Patient)")
+        encounters_filtered = self.api.get_mips_encounters(self.test_patient_id)
+        if encounters_filtered is not None:
+            print(f"Encounters for Patient {self.test_patient_id} Retrieved Successfully:")
+            print(json.dumps(encounters_filtered, indent=2) if encounters_filtered else "No data returned")
+        else:
+            print(f"Failed to retrieve encounters for patient {self.test_patient_id}.")
+
+    def run_all_tests(self):
+        """Run all test methods in sequence."""
+        print("Starting MeldRx API Tests with Gradio Callback Simulation...\n")
+        self.test_get_auth_url()
+        self.test_authenticate_with_code()
+        self.test_get_patients()
+        self.test_create_virtual_workspace()
+        self.test_get_mips_patients()
+        self.test_get_mips_patient_by_id()
+        self.test_get_mips_encounters()
+        print("\nAll tests completed.")
+        self.api.close()
+
+
+# Run the tests
+if __name__ == "__main__":
+    tester = MeldRxAPITest()
+    tester.run_all_tests()

qwenprompt.py

@@ -0,0 +1,22 @@
+from huggingface_hub import InferenceClient
+
+client = InferenceClient(api_key="YOUR_HF_TOKEN")
+
+messages = [
+	{ "role": "user", "content": "" },
+	{ "role": "assistant", "content": "you are a senior expert medical health practitioner known for their abilities to produce discharge papers. you will recieve patient information and treatment cursus. Produce a complete discharge summary based on the information provided. produce complete discharge summary." },
+	{ "role": "user", "content": "Patient Name: Patient 1\nGender: Male\nAge: 65 years\n\nPresentation and Diagnosis:\nThe patient was diagnosed with acute myeloid leukemia (AML) in January 2020 based on leukocytosis, thrombocytopenia and anemia. Bone marrow aspiration revealed a hypercellular bone marrow with 50% blasts. The patient was further assessed using flow cytometry and cytogenetics, and molecular panel testing showed aberrations in ASXL1, CEBPA, JAK2, and RUNX1. AML with adverse risk was diagnosed according to genetic risk stratification.\n\nHospital Course:\nAfter one course of induction treatment with the IA regimen, the patient achieved complete remission with low minimal residual disease. Genetic analyses showed negative gene mutations, and the patient received consolidation therapies with the IA regimen and high-dose Ara-c (HiDAC) regimen. However, remission duration only lasted for 11 months, and in November 2020, relapsed BM morphology was detected, indicating relapsed AML with concurrent molecular aberration recurrence. The patient underwent several treatment regimens, including venetoclax combined with azacitidine and chidamide with venetoclax and azacitidine regimen. He achieved complete remission after one course of the chidamide combined regimen.\n\nOutcome:\nThe patient passed away due to disease progression three months after the completion of therapy." },
+#	{ "role": "assistant", "content": "### Discharge Summary\n\n**Patient Name:** Patient 1  \n**Gender:** Male  \n**Age:** 65 years  \n**Date of Admission:** January 2020  \n**Date of Discharge:** April 2021  \n**Attending Physician:** Dr. [Attending Physician's Name]  \n**Discharge Diagnosis:** Acute Myeloid Leukemia (AML) with Adverse Risk\n\n#### Presentation and Diagnosis:\nThe patient, a 65-year-old male, was diagnosed with acute myeloid leukemia (AML) in January 2020. The initial presentation included leukocytosis, thrombocytopenia, and anemia. A bone marrow aspiration revealed a hypercellular bone marrow with 50% blasts. Further evaluation using flow cytometry, cytogenetics, and molecular panel testing identified aberrations in ASXL1, CEBPA, JAK2, and RUNX1. Based on these findings, the patient was diagnosed with AML with adverse risk according to genetic risk stratification.\n\n#### Hospital Course:\n- **Initial Treatment:**\n  - The patient underwent one course of induction treatment with the IA (idarubicin and cytarabine) regimen.\n  - After the induction treatment, the patient achieved complete remission with low minimal residual disease (MRD). Genetic analyses confirmed the absence of gene mutations.\n  - The patient then received consolidation therapies, including additional courses of the IA regimen and a high-dose Ara-C (HiDAC) regimen.\n\n- **Relapse:**\n  - Despite the initial success, the patient's remission lasted only 11 months. In November 2020, a bone marrow biopsy revealed relapsed AML with concurrent molecular aberration recurrence.\n  - The patient was subsequently treated with several regimens, including venetoclax combined with azacitidine and a chidamide with venetoclax and azacitidine regimen.\n  - After one course of the chidamide combined regimen, the patient achieved complete remission again.\n\n- **Disease Progression:**\n  - Despite achieving remission, the patient's condition began to deteriorate three months after the completion of therapy.\n  - The patient developed progressive disease, and despite supportive care and palliative measures, he passed away due to disease progression.\n\n#### Outcome:\nThe patient passed away on [Date of Death] due to disease progression and complications associated with relapsed AML. The family was provided with appropriate bereavement support and counseling.\n\n#### Discharge Instructions:\n- **Follow-Up:**\n  - The patient's family was advised to follow up with the oncology team for any further questions or support.\n  - The family was also provided with resources for grief counseling and support groups.\n\n- **Medications:**\n  - The patient was not discharged on any medications due to the terminal nature of his condition.\n\n- **Diet and Activity:**\n  - The patient was on a regular diet and was encouraged to maintain a comfortable level of activity as tolerated.\n\n- **Advance Directives:**\n  - The patient had previously completed an advance directive, and his wishes were respected throughout his care.\n\n#### Summary:\nPatient 1, a 65-year-old male with AML with adverse risk, underwent multiple treatment regimens, including induction and consolidation therapies, and achieved remission twice. However, the disease ultimately progressed, leading to his passing. The family was provided with comprehensive support and resources to navigate this difficult time.\n\n**Signed:**\nDr. [Attending Physician's Name]  \n[Contact Information]  \n[Date]" }
+]
+
+stream = client.chat.completions.create(
+    model="Qwen/Qwen2.5-72B-Instruct", 
+	messages=messages, 
+	temperature=0.6,
+	max_tokens=4096,
+	top_p=0.7,
+	stream=True
+)
+
+for chunk in stream:
+    print(chunk.choices[0].delta.content)

requirements.txt

@@ -0,0 +1 @@
+openai

test_meldrx.py

@@ -0,0 +1,160 @@
+import unittest
+from unittest.mock import patch, Mock
+import json
+from io import StringIO
+from contextlib import redirect_stdout
+from meldrx import MeldRxAPI  # Import the class from meldrx.py
+
+class TestMeldRxAPI(unittest.TestCase):
+    def setUp(self):
+        """Set up test fixtures before each test."""
+        self.client_id = "test_client_id"
+        self.client_secret = "test_client_secret"
+        self.workspace_id = "test_workspace_id"
+        self.patient_id = "test_patient_id"
+        self.api = MeldRxAPI(self.client_id, self.client_secret, self.workspace_id)
+
+    def tearDown(self):
+        """Clean up after each test."""
+        self.api.close()
+
+    @patch('meldrx.requests.Session.post')
+    def test_authenticate_success(self, mock_post):
+        """Test successful authentication."""
+        mock_response = Mock()
+        mock_response.status_code = 200
+        mock_response.json.return_value = {"access_token": "test_token"}
+        mock_post.return_value = mock_response
+
+        result = self.api.authenticate()
+        self.assertTrue(result)
+        self.assertEqual(self.api.access_token, "test_token")
+
+    @patch('meldrx.requests.Session.post')
+    def test_authenticate_failure(self, mock_post):
+        """Test authentication failure."""
+        mock_response = Mock()
+        mock_response.status_code = 401
+        mock_response.raise_for_status.side_effect = requests.exceptions.HTTPError("Unauthorized")
+        mock_post.return_value = mock_response
+
+        with redirect_stdout(StringIO()) as output:
+            result = self.api.authenticate()
+        self.assertFalse(result)
+        self.assertIsNone(self.api.access_token)
+        self.assertIn("Authentication failed: Unauthorized", output.getvalue())
+
+    @patch('meldrx.requests.Session.get')
+    @patch('meldrx.MeldRxAPI.authenticate', return_value=True)
+    def test_get_patients_success(self, mock_auth, mock_get):
+        """Test successful retrieval of patients from FHIR API."""
+        mock_response = Mock()
+        mock_response.status_code = 200
+        mock_response.text = json.dumps({"resourceType": "Bundle", "entry": [{"resource": {"id": self.patient_id}}]})
+        mock_response.json.return_value = json.loads(mock_response.text)
+        mock_get.return_value = mock_response
+
+        result = self.api.get_patients()
+        self.assertIsNotNone(result)
+        self.assertEqual(result["entry"][0]["resource"]["id"], self.patient_id)
+
+    @patch('meldrx.requests.Session.get')
+    @patch('meldrx.MeldRxAPI.authenticate', return_value=False)
+    def test_get_patients_auth_failure(self, mock_auth, mock_get):
+        """Test patient retrieval fails due to authentication."""
+        with redirect_stdout(StringIO()) as output:
+            result = self.api.get_patients()
+        self.assertIsNone(result)
+        mock_get.assert_not_called()
+        self.assertIn("Cannot proceed without authentication", output.getvalue())
+
+    @patch('meldrx.requests.Session.post')
+    @patch('meldrx.MeldRxAPI.authenticate', return_value=True)
+    def test_create_virtual_workspace_success(self, mock_auth, mock_post):
+        """Test successful creation of a virtual workspace."""
+        mock_response = Mock()
+        mock_response.status_code = 201
+        mock_post.return_value = mock_response
+
+        result = self.api.create_virtual_workspace()
+        self.assertTrue(result)
+
+    @patch('meldrx.requests.Session.get')
+    @patch('meldrx.MeldRxAPI.authenticate', return_value=True)
+    def test_get_mips_patients_success(self, mock_auth, mock_get):
+        """Test successful retrieval of patients from MIPS API."""
+        mock_response = Mock()
+        mock_response.status_code = 200
+        mock_response.text = json.dumps({"resourceType": "Bundle", "entry": [{"resource": {"id": self.patient_id}}]})
+        mock_response.json.return_value = json.loads(mock_response.text)
+        mock_get.return_value = mock_response
+
+        result = self.api.get_mips_patients()
+        self.assertIsNotNone(result)
+        self.assertEqual(result["entry"][0]["resource"]["id"], self.patient_id)
+
+    @patch('meldrx.requests.Session.get')
+    @patch('meldrx.MeldRxAPI.authenticate', return_value=True)
+    def test_get_mips_patient_by_id_success(self, mock_auth, mock_get):
+        """Test successful retrieval of a patient by ID from MIPS API."""
+        mock_response = Mock()
+        mock_response.status_code = 200
+        mock_response.text = json.dumps({"resourceType": "Patient", "id": self.patient_id})
+        mock_response.json.return_value = json.loads(mock_response.text)
+        mock_get.return_value = mock_response
+
+        result = self.api.get_mips_patient_by_id(self.patient_id)
+        self.assertIsNotNone(result)
+        self.assertEqual(result["id"], self.patient_id)
+
+    @patch('meldrx.requests.Session.get')
+    @patch('meldrx.MeldRxAPI.authenticate', return_value=True)
+    def test_get_mips_encounters_success(self, mock_auth, mock_get):
+        """Test successful retrieval of encounters from MIPS API."""
+        mock_response = Mock()
+        mock_response.status_code = 200
+        mock_response.text = json.dumps({"resourceType": "Bundle", "entry": [{"resource": {"id": "enc1"}}]})
+        mock_response.json.return_value = json.loads(mock_response.text)
+        mock_get.return_value = mock_response
+
+        result = self.api.get_mips_encounters(self.patient_id)
+        self.assertIsNotNone(result)
+        self.assertEqual(result["entry"][0]["resource"]["id"], "enc1")
+
+    @patch('meldrx.requests.Session.put')
+    @patch('meldrx.MeldRxAPI.authenticate', return_value=True)
+    def test_update_fhir_patient_success(self, mock_auth, mock_put):
+        """Test successful update of patient data in FHIR API."""
+        mock_response = Mock()
+        mock_response.status_code = 200
+        mock_put.return_value = mock_response
+
+        patient_data = {"resourceType": "Patient", "id": self.patient_id, "name": [{"family": "Doe"}]}
+        result = self.api.update_fhir_patient(self.patient_id, patient_data)
+        self.assertTrue(result)
+
+    @patch('meldrx.requests.Session.put')
+    @patch('meldrx.MeldRxAPI.authenticate', return_value=True)
+    def test_update_mips_patient_success(self, mock_auth, mock_put):
+        """Test successful update of patient data in MIPS API."""
+        mock_response = Mock()
+        mock_response.status_code = 200
+        mock_put.return_value = mock_response
+
+        patient_data = {"resourceType": "Patient", "id": self.patient_id, "name": [{"family": "Doe"}]}
+        result = self.api.update_mips_patient(self.patient_id, patient_data)
+        self.assertTrue(result)
+
+    @patch('meldrx.requests.Session.put')
+    @patch('meldrx.MeldRxAPI.authenticate', return_value=False)
+    def test_update_fhir_patient_auth_failure(self, mock_auth, mock_put):
+        """Test patient update fails due to authentication in FHIR API."""
+        patient_data = {"resourceType": "Patient", "id": self.patient_id}
+        with redirect_stdout(StringIO()) as output:
+            result = self.api.update_fhir_patient(self.patient_id, patient_data)
+        self.assertFalse(result)
+        mock_put.assert_not_called()
+        self.assertIn("Cannot proceed without authentication", output.getvalue())
+
+if __name__ == "__main__":
+    unittest.main(verbosity=2)  # Increased verbosity for detailed output

wound.py

@@ -0,0 +1,84 @@
+import gradio as gr
+
+def submit_form(
+    patient_name, dob, ssn, goal_met, goal_reason,
+    discharge_date, wound1_location, wound1_status, wound1_measure_date, wound1_length, wound1_width, wound1_depth,
+    wound2_location, wound2_status, wound2_measure_date, wound2_length, wound2_width, wound2_depth,
+    provider_name, provider_phone, info_date
+):
+    result = f"""
+    Patient Information:
+    Name: {patient_name}
+    DOB: {dob}
+    SSN: {ssn}
+    
+    Physician's Goal Met: {'Yes' if goal_met else 'No'}
+    Reason (if no): {goal_reason}
+    
+    Discharge Date: {discharge_date}
+    
+    Wound #1:
+    Location: {wound1_location}
+    Status: {', '.join(wound1_status)}
+    Measurement Date: {wound1_measure_date}
+    Length: {wound1_length} cm, Width: {wound1_width} cm, Depth: {wound1_depth} cm
+    
+    Wound #2:
+    Location: {wound2_location}
+    Status: {', '.join(wound2_status)}
+    Measurement Date: {wound2_measure_date}
+    Length: {wound2_length} cm, Width: {wound2_width} cm, Depth: {wound2_depth} cm
+    
+    Provider Information:
+    Name: {provider_name}
+    Phone: {provider_phone}
+    Information Date: {info_date}
+    """
+    return result
+
+with gr.Blocks() as app:
+    gr.Markdown("### Discharge Form")
+    with gr.Row():
+        patient_name = gr.Textbox(label="Patient's Name (Last, First, MI)")
+        dob = gr.Textbox(label="Date of Birth (MM/DD/YYYY)")
+        ssn = gr.Textbox(label="Social Security Number (XXX-XX-XXXX)")
+    
+    goal_met = gr.Checkbox(label="Was the Physician’s Goal Met?")
+    goal_reason = gr.Textbox(label="If No, Explain Why")
+    discharge_date = gr.Textbox(label="Therapy Discharge Date (MM/DD/YYYY)")
+    
+    gr.Markdown("### Wound #1")
+    with gr.Row():
+        wound1_location = gr.Textbox(label="Wound Location")
+    wound1_status = gr.CheckboxGroup(["Adequate granulation", "Patient in hospital", "Wound unresponsive", "Pain", "Wound healed", "Delayed primary closure", "Patient non-compliant", "Patient expired", "Wound sutured closed", "Tunnel dimensions decreased or closed", "Undermining improved or resolved", "4 months of treatment completed", "Other"], label="Wound Status")
+    wound1_measure_date = gr.Textbox(label="Final Measurement Date (MM/DD/YYYY)")
+    with gr.Row():
+        wound1_length = gr.Number(label="Length (cm)")
+        wound1_width = gr.Number(label="Width (cm)")
+        wound1_depth = gr.Number(label="Depth (cm)")
+    
+    gr.Markdown("### Wound #2 (if applicable)")
+    with gr.Row():
+        wound2_location = gr.Textbox(label="Wound Location")
+    wound2_status = gr.CheckboxGroup(["Adequate granulation", "Patient in hospital", "Wound unresponsive", "Pain", "Wound healed", "Delayed primary closure", "Patient non-compliant", "Patient expired", "Wound sutured closed", "Tunnel dimensions decreased or closed", "Undermining improved or resolved", "4 months of treatment completed", "Other"], label="Wound Status")
+    wound2_measure_date = gr.Textbox(label="Final Measurement Date (MM/DD/YYYY)")
+    with gr.Row():
+        wound2_length = gr.Number(label="Length (cm)")
+        wound2_width = gr.Number(label="Width (cm)")
+        wound2_depth = gr.Number(label="Depth (cm)")
+    
+    gr.Markdown("### Provider Information")
+    provider_name = gr.Textbox(label="Print Name, Title, Employer")
+    provider_phone = gr.Textbox(label="Phone Number")
+    info_date = gr.Textbox(label="Information Date (MM/DD/YYYY)")
+    
+    submit = gr.Button("Submit")
+    output = gr.Textbox(label="Form Output", interactive=False)
+    submit.click(submit_form, inputs=[
+        patient_name, dob, ssn, goal_met, goal_reason,
+        discharge_date, wound1_location, wound1_status, wound1_measure_date, wound1_length, wound1_width, wound1_depth,
+        wound2_location, wound2_status, wound2_measure_date, wound2_length, wound2_width, wound2_depth,
+        provider_name, provider_phone, info_date
+    ], outputs=output)
+    
+app.launch()