Sending Notifications

const https = require('https');

async function sendNotification(userId, message) {
  const appId = process.env.OMI_APP_ID;
  const appSecret = process.env.OMI_APP_SECRET;

  const url = new URL(`https://api.omi.me/v2/integrations/${appId}/notification`);
  url.searchParams.set('uid', userId);
  url.searchParams.set('message', message);

  const response = await fetch(url, {
    method: 'POST',
    headers: {
      'Authorization': `Bearer ${appSecret}`,
      'Content-Type': 'application/json'
    }
  });

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

  return response.json();
}

// Usage
sendNotification('user123', 'Your task is due in 1 hour!')
  .then(console.log)
  .catch(console.error);

from fastapi import FastAPI
from pydantic import BaseModel
from typing import List, Optional

app = FastAPI()

class TranscriptSegment(BaseModel):
    text: str
    speaker: str
    is_user: bool

class WebhookRequest(BaseModel):
    session_id: str
    segments: List[TranscriptSegment]

@app.post("/webhook")
def handle_transcript(data: WebhookRequest, uid: str, session_id: str):
    # Combine all segments into transcript
    transcript = " ".join([s.text for s in data.segments]).lower()

    # Detect trigger phrases
    if "what do you think" in transcript or "any advice" in transcript:
        return {
            "session_id": data.session_id,
            "notification": {
                "prompt": """You are a helpful mentor for {{user_name}}.
                Based on their goals ({{user_facts}}) and the current discussion ({{user_context}}),
                provide specific, actionable advice in under 100 words.""",
                "params": ["user_name", "user_facts", "user_context"]
            }
        }

    # No notification needed
    return {"session_id": data.session_id}