pip install ekacare

curl --request POST \
  --url https://api.eka.care/notification/v1/connect/webhook/subscriptions \
  --header 'Authorization: Bearer <auth_token>' \
  --header 'Content-Type: application/json' \
  --data '{
    "event_names": [
      "v2rx.completed"
    ],
    "endpoint": "your-endpoint-url",
    "signing_key": "supersecretkey",
    "protocol": "https"
  }'

from ekacare import EkaCareClient

# Initialize the client
client = EkaCareClient(
    client_id="your_client_id",
    client_secret="your_client_secret"
)

# Login to get tokens
token_response = client.auth.login()
access_token = token_response["access_token"]
refresh_token = token_response["refresh_token"]

# Set access token manually if needed
client.set_access_token(access_token)

# Refresh token when needed
refreshed_tokens = client.auth.refresh_token(refresh_token)
new_access_token = refreshed_tokens["access_token"]

# Prepare files and metadata
audio_files = [
    "path/to/audio_file1.mp3",
    "path/to/audio_file2.mp3"
]
# Optional fields transaction_id, extra_data, action
transaction_id = "unique_transaction_id"  
extra_data = {
    "mode": "dictation",
    "model_type": "lite"
}
action = "ekascribe-v2"

# Upload files
responses = client.v2rx.upload(
    file_paths=audio_files, 
    txn_id=transaction_id, 
    action=action, 
    extra_data=extra_data,
    output_format = {
        "input_language": ["en-IN"],
        "output_template": [
            {
                "template_id": "clinical_notes_template",
                "codification_needed": True
            }]
    }
)

# Process responses
for response in responses:
    # Handle response data as needed
    print(response)

{
  "event": "v2rx.completed",
  "data": {
    "transaction_id": "unique_transaction_id",
    "status": "completed",
    "session_id": "unique_transaction_id"
  },
  "timestamp": "2023-07-20T10:30:00Z"
}

import base64

# Get the session ID from the webhook callback
session_id = "unique_transaction_id"  # This comes from the webhook payload which equals to transaction_id of Step 3: Upload Audio files 

# Fetch session status and results
action = "ekascribe-v2"
session_data = client.v2rx.get_session_status(session_id, action)


#{
#  "data": {
#    "output": [
#      {
#        "template_id": "clinical_notes_template",
#        "value": "<base 64 encoded value>",
#        "name": "Clinical Notes Template",
#        "status": "success",
#        "errors": [],
#        "warnings": []
#      }
#    ]
#  }
#}

# Extract and decode the Template value
for template_data in session_status.get("data", {}).get("output", []):
    template_id, template_value = template_data.get("template_id"), template_data.get("value")
    decoded_bytes = base64.b64decode(template_value)
    template_json = decoded_bytes.decode('utf-8')
    print(template_json)

from ekacare import EkaCareClient
import base64
import time

def ekascribe_integration_example():
    try:
        # Initialize the client
        client = EkaCareClient(
            client_id="your_client_id",
            client_secret="your_client_secret"
        )
        
        # Authenticate
        authenticate_client(client)
        
        # Upload audio files
        transaction_id = "unique_transaction_id"
        upload_audio_files(client, transaction_id)
        
        # NOTE: At this point, wait for the webhook callback
        # This would typically be handled by your web server
        
        # Once webhook is received, fetch results
        # The session_id would come from the webhook payload
        session_id = transaction_id         # "session_id_from_webhook"
        get_transcription_results(client, session_id)
        
    except Exception as e:
        print(f"Error: {str(e)}")

def authenticate_client(client):
    token_response = client.auth.login()
    client.set_access_token(token_response["access_token"])

def upload_audio_files(client, transaction_id):
    audio_files = [
        "path/to/audio1.mp3",
        "path/to/audio2.mp3"
    ]
    
    extra_data = {
        "mode": "dictation",
        "model_type": "lite"
    }

    action = "ekascribe-v2"

    
    
    responses = client.v2rx.upload(
    file_paths=audio_files, 
    txn_id=transaction_id, 
    action=action, 
    extra_data=extra_data,
    output_format = {
        "input_language": ["en-IN"],
        "output_template": [
            {
                "template_id": "clinical_notes_template",
                "codification_needed": True
            }]
    }
)
    
    return responses

def get_transcription_results(client, session_id):
    action = "ekascribe-v2"
    session_status = client.v2rx.get_session_status(session_id, action)
    
    if "data" in session_status and "output" in session_status["data"] and "fhir" in session_status["data"]["output"]:
        encoded_fhir = session_status["data"]["output"]["fhir"]
        decoded_bytes = base64.b64decode(encoded_fhir)
        fhir_json = decoded_bytes.decode('utf-8')
        return fhir_json
    else:
        # Handle non-completed status
        return None

if __name__ == "__main__":
    ekascribe_integration_example()