const express = require('express');
const app = express();
app.use(express.json());

app.post('/webhooks/agni', (req, res) => {
  const { event, org_id, data } = req.body;

  if (event === 'call.completed') {
    console.log(`Call ${data.call_session_id} completed`);
    console.log(`Duration: ${data.duration_sec}s, Status: ${data.status}`);
    console.log(`Summary: ${data.summary}`);
    console.log(`Sentiment: ${data.post_call_analysis?.sentiment}`);
    console.log(`Disposition: ${data.post_call_analysis?.disposition}`);
    console.log(`Transcripts: ${data.transcripts?.length} messages`);

    // Store in your database
    // Update CRM with call outcome
    // Trigger follow-up workflows based on disposition
  }

  res.status(200).json({ received: true });
});

app.listen(3000);

from flask import Flask, request, jsonify

app = Flask(__name__)

@app.route('/webhooks/agni', methods=['POST'])
def handle_webhook():
    payload = request.json
    event = payload.get('event')
    data = payload.get('data', {})

    if event == 'call.completed':
        print(f"Call {data['call_session_id']} completed")
        print(f"Duration: {data['duration_sec']}s, Status: {data['status']}")
        print(f"Summary: {data.get('summary')}")

        analysis = data.get('post_call_analysis', {})
        print(f"Sentiment: {analysis.get('sentiment')}")
        print(f"Disposition: {analysis.get('disposition')}")
        print(f"Goals met: {analysis.get('goals_met')}")

        transcripts = data.get('transcripts', [])
        print(f"Transcript entries: {len(transcripts)}")

        # Store in database, update CRM, trigger workflows

    return jsonify({'received': True}), 200

if __name__ == '__main__':
    app.run(port=3000)