npm install @prosody/sdk

pnpm add @prosody/sdk

yarn add @prosody/sdk

pip install prosody-sdk

import { Prosody } from '@prosody/sdk';

const client = new Prosody({
  apiKey: process.env.PROSODY_API_KEY,
});

from prosody import Prosody

client = Prosody(api_key=os.environ["PROSODY_API_KEY"])

const result = await client.analyze({
  audio: audioBuffer,
  vertical: 'contact_center',
  features: ['emotion', 'prosody', 'prediction'],
});

console.log(result.emotion);        // "frustrated"
console.log(result.valence);        // -0.6
console.log(result.escalationRisk); // "high"
console.log(result.predictedCsat);  // 2.3

result = client.analyze(
    audio=audio_bytes,
    vertical="contact_center",
    features=["emotion", "prosody", "prediction"],
)

print(result.emotion)          # "frustrated"
print(result.valence)          # -0.6
print(result.escalation_risk)  # "high"
print(result.predicted_csat)   # 2.3

const stream = client.stream({
  vertical: 'contact_center',
  sessionId: 'call-12345',
});

stream.on('emotion', (data) => {
  console.log(`Emotion: ${data.emotion} (${data.confidence})`);
});

stream.on('prediction', (data) => {
  console.log(`Escalation risk: ${data.escalationRisk}`);
  console.log(`Predicted CSAT: ${data.predictedCsat}`);
});

// Send audio chunks as they arrive
mediaRecorder.ondataavailable = (e) => {
  stream.send(e.data);
};

// End the session
stream.end();

async with client.stream(
    vertical="contact_center",
    session_id="call-12345",
) as stream:
    async for chunk in audio_source:
        await stream.send(chunk)
        
        result = await stream.receive()
        if result:
            print(f"Emotion: {result.emotion}")
            print(f"Escalation risk: {result.escalation_risk}")