Integrate Project into Your App

curl -X POST 'https://app.triform.ai/api/in/31460071-17aa-43e8-a0e6-fb22984c0bdc/26420f15-2143-443f-bca9-45c5b0720784' \  --header 'Authorization: 88ffe8398f972837ccc6e0a6cd31c5c92689040c' \  --header 'Content-Type: application/json' \  --data '{"sources": ["https://newsapi.org/v2/top-headlines?country=us", "https://api.example.com/tech-news"]}'

import requestsimport osAPI_KEY = os.environ.get('TRIFORM_API_KEY')ENDPOINT = 'https://app.triform.ai/api/in/31460071-17aa-43e8-a0e6-fb22984c0bdc/26420f15-2143-443f-bca9-45c5b0720784'headers = {    'Authorization': API_KEY,    'Content-Type': 'application/json'}payload = {    'sources': [        'https://newsapi.org/v2/top-headlines?country=us',        'https://api.example.com/tech-news'    ]}response = requests.post(ENDPOINT, json=payload, headers=headers)if response.status_code == 200:    result = response.json()    print('Success:', result)else:    print('Error:', response.status_code, response.text)

const axios = require('axios');const API_KEY = process.env.TRIFORM_API_KEY;const ENDPOINT = 'https://app.triform.ai/api/in/31460071-17aa-43e8-a0e6-fb22984c0bdc/26420f15-2143-443f-bca9-45c5b0720784';const headers = {  'Authorization': API_KEY,  'Content-Type': 'application/json'};const payload = {  sources: [    'https://newsapi.org/v2/top-headlines?country=us',    'https://api.example.com/tech-news'  ]};axios.post(ENDPOINT, payload, { headers })  .then(response => {    console.log('Success:', response.data);  })  .catch(error => {    console.error('Error:', error.response?.status, error.response?.data);  });

const callTriformAPI = async () => {  const API_KEY = process.env.REACT_APP_TRIFORM_API_KEY;  const ENDPOINT = 'https://app.triform.ai/api/in/31460071-17aa-43e8-a0e6-fb22984c0bdc/26420f15-2143-443f-bca9-45c5b0720784';    try {    const response = await fetch(ENDPOINT, {      method: 'POST',      headers: {        'Authorization': API_KEY,        'Content-Type': 'application/json'      },      body: JSON.stringify({        sources: [          'https://newsapi.org/v2/top-headlines?country=us',          'https://api.example.com/tech-news'        ]      })    });        if (!response.ok) {      throw new Error(`HTTP error! status: ${response.status}`);    }        const data = await response.json();    console.log('Success:', data);    return data;  } catch (error) {    console.error('Error:', error);  }};

{  "execution_id": "exec_abc123",  "status": "completed",  "output": {    "digest": "Top stories today include...",    "article_count": 42,    "topics": ["technology", "politics", "science"]  },  "execution_time_ms": 3420,  "timestamp": "2025-10-01T10:30:00Z"}

{  "error": {    "code": "invalid_input",    "message": "Field 'sources' is required",    "details": {      "field": "sources",      "expected_type": "array"    }  },  "request_id": "req_xyz789"}

def call_triform_api(payload):    response = requests.post(ENDPOINT, json=payload, headers=headers)        if response.status_code == 200:        data = response.json()        return {            'success': True,            'data': data['output'],            'execution_id': data['execution_id']        }    elif response.status_code == 400:        error = response.json()['error']        return {            'success': False,            'error': error['message'],            'code': error['code']        }    elif response.status_code == 429:        # Rate limit exceeded        return {            'success': False,            'error': 'Rate limit exceeded. Try again later.'        }    elif response.status_code >= 500:        # Server error        return {            'success': False,            'error': 'Triform service temporarily unavailable'        }    else:        return {            'success': False,            'error': f'Unexpected error: {response.status_code}'        }

import timefrom typing import Optionaldef call_with_retry(payload, max_retries=3):    for attempt in range(max_retries):        try:            response = requests.post(                ENDPOINT,                json=payload,                headers=headers,                timeout=30            )                        if response.status_code == 200:                return response.json()            elif response.status_code == 429:                # Rate limited, wait and retry                wait_time = 2 ** attempt  # 1s, 2s, 4s                time.sleep(wait_time)                continue            elif response.status_code >= 500:                # Server error, retry                wait_time = 2 ** attempt                time.sleep(wait_time)                continue            else:                # Client error, don't retry                raise Exception(f"API error: {response.text}")                        except requests.exceptions.Timeout:            if attempt < max_retries - 1:                time.sleep(2 ** attempt)                continue            raise        except requests.exceptions.RequestException as e:            if attempt < max_retries - 1:                time.sleep(2 ** attempt)                continue            raise        raise Exception(f"Failed after {max_retries} attempts")

# Set reasonable timeout (connect timeout, read timeout)response = requests.post(    ENDPOINT,    json=payload,    headers=headers,    timeout=(5, 30)  # 5s to connect, 30s to read)

# Flask appfrom flask import Flask, render_template, request, jsonifyapp = Flask(__name__)@app.route('/dashboard')def dashboard():    return render_template('dashboard.html')@app.route('/api/refresh-news', methods=['POST'])def refresh_news():    sources = request.json.get('sources', [])        result = call_triform_api({        'sources': sources    })        if result['success']:        return jsonify({            'digest': result['data']['digest'],            'article_count': result['data']['article_count']        })    else:        return jsonify({'error': result['error']}), 400

# Daily cron jobimport scheduleimport timedef fetch_daily_news():    print("Fetching daily news digest...")        payload = {        'sources': [            'https://newsapi.org/v2/top-headlines?country=us',            'https://api.example.com/tech-news'        ]    }        result = call_with_retry(payload)        # Save to database or send email    save_to_database(result['output']['digest'])    send_email_digest(result['output']['digest'])        print("Daily news digest completed")# Schedule for 6 AM dailyschedule.every().day.at("06:00").do(fetch_daily_news)while True:    schedule.run_pending()    time.sleep(60)

# Process incoming webhooksfrom fastapi import FastAPI, BackgroundTasksapp = FastAPI()@app.post('/webhook/new-content')async def handle_new_content(data: dict, background_tasks: BackgroundTasks):    # Trigger Triform processing in background    background_tasks.add_task(process_with_triform, data)    return {'status': 'processing'}def process_with_triform(data):    result = call_triform_api({        'content': data['content'],        'metadata': data['metadata']    })        # Store results    store_results(result)

import logginglogger = logging.getLogger(__name__)def call_triform_api_with_logging(payload):    start_time = time.time()        try:        response = requests.post(ENDPOINT, json=payload, headers=headers)        elapsed = time.time() - start_time                logger.info(f"Triform API call completed in {elapsed:.2f}s, status: {response.status_code}")                return response.json()    except Exception as e:        elapsed = time.time() - start_time        logger.error(f"Triform API call failed after {elapsed:.2f}s: {str(e)}")        raise

from functools import lru_cacheimport hashlibimport json# Simple in-memory cachecache = {}CACHE_TTL = 3600  # 1 hourdef get_cache_key(payload):    return hashlib.md5(json.dumps(payload, sort_keys=True).encode()).hexdigest()def call_triform_cached(payload):    cache_key = get_cache_key(payload)        # Check cache    if cache_key in cache:        cached_data, timestamp = cache[cache_key]        if time.time() - timestamp < CACHE_TTL:            logger.info("Returning cached result")            return cached_data        # Call API    result = call_triform_api(payload)        # Store in cache    cache[cache_key] = (result, time.time())        return result