Meridian SDK

import os
from meridian_sdk import MeridianAPI

# Load from environment
api_key = os.getenv("MERIDIAN_API_KEY")

# Initialize client
async with MeridianAPI(api_key=api_key) as client:
    # Make authenticated requests
    response = await client.search("your query")

client = MeridianAPI(
    api_key="kt_...",
    base_url="https://dashboard.trymeridian.dev",
    timeout=60.0,
    max_retries=3
)

from meridian_sdk import MeridianAPI, SearchFilters, SearchOptions

async with MeridianAPI(api_key=api_key) as client:
    # Simple search
    response = await client.search("project Apollo status")

    for result in response.results:
        print(f"Title: {result.title}")
        print(f"Snippet: {result.snippet}")
        print(f"Relevance: {result.relevance_score:.2%}")
        print(f"Source: {result.source_type}\n")

    # Advanced search with filters
    filters = SearchFilters(
        sources=["google_drive", "sharepoint"],
        file_types=["PDF", "DOCUMENT"],
        date_range=(30, 0),  # Past 30 days
        entities=["Stellar Dynamics", "Q4"]
    )

    options = SearchOptions(
        max_results=20,
        include_sources=True,
        use_entity_filtering=True
    )

    response = await client.search(
        query="Q4 financial reports",
        filters=filters,
        options=options
    )

    print(f"Found {len(response.results)} results from {response.sources_count} sources")

# Get email summaries about a specific topic
response = await client.search_summaries(
    query="Deloitte project communications",
    summary_type="EMAIL_SUMMARIES",
    date_range=(7, 0),  # Past week
    use_semantic_search=True
)

for summary in response.summaries:
    print(f"📧 {summary.generated_at}")
    print(f"   {summary.summary_text}")
    print(f"   References {len(summary.referenced_ids)} emails\n")

# First search for relevant documents
search_response = await client.search("API documentation")

# Get full context for the first result
if search_response.results:
    content_id = search_response.results[0].content_id
    context = await client.get_context(content_id, max_chars=50000)

    print(f"Title: {context.title}")
    print(f"Size: {context.size_chars:,} characters")
    print(f"\n{context.full_text}")

# Get monthly usage
usage = await client.get_usage(period="month")

print(f"Total requests: {usage.total_requests}")
print(f"Total cost: ${usage.total_cost:.4f}")
print(f"Current tier: {usage.current_tier}")

# Daily breakdown
for day in usage.daily_breakdown:
    print(f"{day.date}: {day.requests} requests, ${day.cost:.4f}")

# Check rate limits
limits = await client.get_limits()

print(f"Daily limit: {limits.remaining_day}/{limits.requests_per_day}")
print(f"Per minute: {limits.remaining_minute}/{limits.requests_per_minute}")

# Check before making requests
if limits.remaining_minute > 0:
    response = await client.search("query")
else:
    print("Rate limit reached, waiting...")

sources = await client.list_sources()
print(f"Connected sources: {sources.total_connected}")

for source in sources.sources:
    status = "✅" if source.is_connected else "❌"
    print(f"{status} {source.name} ({source.type})")

health = await client.health_check()

print(f"API Status: {health.status}")
print(f"Version: {health.version}")

for service_name, service in health.services.items():
    print(f"  {service_name}: {service.status}")

from meridian_sdk import (
    MeridianAPI,
    AuthenticationError,
    RateLimitError,
    ValidationError,
    ServerError
)

async with MeridianAPI(api_key=api_key) as client:
    try:
        response = await client.search("test query")
    except AuthenticationError:
        print("Invalid API key")
    except RateLimitError as e:
        print(f"Rate limit exceeded. Retry after {e.retry_after}s")
    except ValidationError as e:
        print(f"Validation error: {e.message}")
    except ServerError as e:
        print(f"Server error: {e.status_code}")