Documentation

pip install epist

import os
import time
from epist import Epist

# Initialize the client
# Ensure EPIST_API_KEY is set in your environment or passed explicitly
client = Epist(api_key="YOUR_API_KEY")

def main():
    # --- 1. Upload a Local File ---
    print("\n[1] Uploading 'interview.mp3'...")
    try:
        # Uploads are synchronous but processing is asynchronous
        upload_res = client.upload_file("interview.mp3")
        task_id = upload_res["id"]
        print(f"Upload successful. Task ID: {task_id}")
    except Exception as e:
        print(f"Upload failed: {e}")
        return

    # --- 2. Poll for Completion ---
    # We must wait for the audio to be processed before we can search it.
    print(f"\n[2] Polling status for task: {task_id}")
    while True:
        status_res = client.get_status(task_id)
        status = status_res.get("status")
        print(f"Status: {status}")
        
        if status == "completed":
            print("Processing complete!")
            break
        elif status == "failed":
            print(f"Task failed: {status_res.get('error')}")
            return
        
        time.sleep(2)

    # --- 3. Semantic Search ---
    # Now that the file is indexed, we can ask questions about it.
    query = "What was discussed about the roadmap?"
    print(f"\n[3] Searching knowledge base for: '{query}'")
    
    search_res = client.search(query=query, limit=3)
    
    for idx, item in enumerate(search_res, 1):
        print(f"\nResult {idx}:")
        print(f"Text: {item.get('text', '')[:150]}...")
        print(f"Score: {item.get('score')}")

if __name__ == "__main__":
    main()

npm install epist

const { Epist } = require('epist');

// Initialize the client
const client = new Epist({ 
    apiKey: "YOUR_API_KEY",
    baseUrl: "https://epist-api-staging-920152096400.us-central1.run.app/api/v1"
});

async function main() {
    // --- 1. Transcribe from URL ---
    const audioUrl = "https://storage.googleapis.com/cloud-samples-data/speech/brooklyn_bridge.flac";
    console.log(`\n[1] Transcribing URL: ${audioUrl}`);

    try {
        const urlRes = await client.transcribeUrl(audioUrl, true);
        const taskId = urlRes.id;
        console.log(`Task started. ID: ${taskId}`);

        // --- 2. Poll Status ---
        await pollStatus(client, taskId);

        // --- 3. Search ---
        const query = "How old is the bridge?";
        console.log(`\n[3] Searching for: '${query}'`);
        const searchRes = await client.search(query, 1);
        
        searchRes.forEach(result => {
             console.log(`\nAnswer: ${result.text}`);
        });

    } catch (error) {
        console.error("Error:", error.message);
    }
}

async function pollStatus(client, id) {
    while (true) {
        const res = await client.getStatus(id);
        const status = res.status;
        console.log(`Status: ${status}`);
        
        if (status === 'completed' || status === 'failed') break;
        await new Promise(r => setTimeout(r, 2000));
    }
}

main();