Medical Consensus

const response = await fetch('https://api.sully.ai/alpha/consensus', {
  method: 'POST',
  headers: {
    'Authorization': `Bearer ${process.env.SULLY_API_KEY}`,
    'Content-Type': 'application/json'
  },
  body: JSON.stringify({
    query: "What are the differential diagnoses for a 45-year-old patient presenting with chest pain, shortness of breath, and elevated troponin levels?"
  })
});

const { data } = await response.json();
console.log('Consensus ID:', data.id);
console.log('Status:', data.status); // "pending"

import os
import requests

url = "https://api.sully.ai/alpha/consensus"
headers = {
    "Authorization": f"Bearer {os.environ['SULLY_API_KEY']}",
    "Content-Type": "application/json"
}
payload = {
    "query": "What are the differential diagnoses for a 45-year-old patient presenting with chest pain, shortness of breath, and elevated troponin levels?"
}

response = requests.post(url, headers=headers, json=payload)
data = response.json()["data"]

print(f"Consensus ID: {data['id']}")
print(f"Status: {data['status']}")  # "pending"

curl -X POST "https://api.sully.ai/alpha/consensus" \
  -H "Authorization: Bearer ${SULLY_API_KEY}" \
  -H "Content-Type: application/json" \
  -d '{
    "query": "What are the differential diagnoses for a 45-year-old patient presenting with chest pain, shortness of breath, and elevated troponin levels?"
  }'

async function waitForConsensus(consensusId: string): Promise<string> {
  const headers = {
    'Authorization': `Bearer ${process.env.SULLY_API_KEY}`
  };

  while (true) {
    const response = await fetch(
      `https://api.sully.ai/alpha/consensus/${consensusId}`,
      { headers }
    );
    const { data } = await response.json();

    if (data.status === 'completed') {
      return data.result.consensus_response;
    }

    if (data.status === 'failed') {
      throw new Error(data.result?.error || 'Consensus processing failed');
    }

    // Wait 5 seconds before polling again
    await new Promise(resolve => setTimeout(resolve, 5000));
  }
}

// Usage
const consensusId = 'consensus_abc123def456';
const result = await waitForConsensus(consensusId);
console.log('Medical Consensus:', result);

import os
import time
import requests

def wait_for_consensus(consensus_id: str) -> str:
    headers = {
        "Authorization": f"Bearer {os.environ['SULLY_API_KEY']}"
    }
    url = f"https://api.sully.ai/alpha/consensus/{consensus_id}"

    while True:
        response = requests.get(url, headers=headers)
        data = response.json()["data"]

        if data["status"] == "completed":
            return data["result"]["consensus_response"]

        if data["status"] == "failed":
            error = data.get("result", {}).get("error", "Consensus processing failed")
            raise Exception(error)

        # Wait 5 seconds before polling again
        time.sleep(5)

# Usage
consensus_id = "consensus_abc123def456"
result = wait_for_consensus(consensus_id)
print(f"Medical Consensus: {result}")

# Poll until complete
CONSENSUS_ID="consensus_abc123def456"

while true; do
  RESPONSE=$(curl -s "https://api.sully.ai/alpha/consensus/${CONSENSUS_ID}" \
    -H "Authorization: Bearer ${SULLY_API_KEY}")

  STATUS=$(echo "${RESPONSE}" | jq -r '.data.status')

  if [ "${STATUS}" = "completed" ]; then
    echo "${RESPONSE}" | jq -r '.data.result.consensus_response'
    break
  elif [ "${STATUS}" = "failed" ]; then
    echo "Error: $(echo ${RESPONSE} | jq -r '.data.result.error')"
    exit 1
  fi

  echo "Status: ${STATUS}, waiting..."
  sleep 5
done

async function createConsensusWithRetry(query: string): Promise<string> {
  const response = await fetch('https://api.sully.ai/alpha/consensus', {
    method: 'POST',
    headers: {
      'Authorization': `Bearer ${process.env.SULLY_API_KEY}`,
      'Content-Type': 'application/json'
    },
    body: JSON.stringify({ query })
  });

  if (response.status === 429) {
    throw new Error('Rate limit exceeded. Please wait 24 hours or contact support.');
  }

  if (!response.ok) {
    throw new Error(`Request failed: ${response.status}`);
  }

  const { data } = await response.json();
  return data.id;
}

import os
import requests

def create_consensus_with_retry(query: str) -> str:
    response = requests.post(
        "https://api.sully.ai/alpha/consensus",
        headers={
            "Authorization": f"Bearer {os.environ['SULLY_API_KEY']}",
            "Content-Type": "application/json"
        },
        json={"query": query}
    )

    if response.status_code == 429:
        raise Exception("Rate limit exceeded. Please wait 24 hours or contact support.")

    response.raise_for_status()
    return response.json()["data"]["id"]