--- name: integrations-b4bb44e69a4d description: "External data sources, connectors, and custom data streams" emoji: "🔗" --- # Integrations - Complete API Reference Manage external data sources, add custom connectors, and plug in new data streams for trading bots. --- ## Chat Commands ### List Data Sources ``` /integrations List all data sources /integrations status Show source health /integrations sources Available source types ``` ### Manage Sources ``` /integrations enable fedwatch Enable CME FedWatch /integrations disable 538 Disable FiveThirtyEight /integrations add webhook "my-signals" Add custom webhook source /integrations add rest "my-api" Add REST API source /integrations remove Remove data source ``` ### Configure Sources ``` /integrations config fedwatch View source config /integrations set fedwatch interval 60 Set refresh interval /integrations set fedwatch key Set API key /integrations test Test source connection ``` ### View Data ``` /integrations data fedwatch Latest data from source /integrations history --hours 24 Historical data /integrations subscribe Real-time updates ``` --- ## TypeScript API Reference ### Create Integrations Manager ```typescript import { createIntegrationsManager } from 'clodds/integrations'; const integrations = createIntegrationsManager({ // Storage storage: 'sqlite', dbPath: './integrations.db', // Default refresh interval defaultIntervalMs: 60000, // Retry settings maxRetries: 3, retryDelayMs: 5000, }); ``` ### Built-in Data Sources ```typescript // Enable built-in sources await integrations.enable('fedwatch'); // CME FedWatch await integrations.enable('538'); // FiveThirtyEight await integrations.enable('silver'); // Silver Bulletin await integrations.enable('rcp'); // RealClearPolitics await integrations.enable('odds-api'); // The Odds API await integrations.enable('polymarket'); // Polymarket prices await integrations.enable('kalshi'); // Kalshi prices await integrations.enable('binance'); // Binance spot prices await integrations.enable('crypto'); // Multi-exchange crypto ``` ### Add Custom Webhook Source ```typescript // Add webhook to receive custom signals const source = await integrations.addWebhook({ name: 'my-signals', description: 'Custom trading signals', // Webhook config path: '/webhooks/my-signals', secret: process.env.WEBHOOK_SECRET, // Data schema (optional validation) schema: { type: 'object', properties: { signal: { type: 'string', enum: ['BUY', 'SELL', 'HOLD'] }, symbol: { type: 'string' }, confidence: { type: 'number', min: 0, max: 1 }, }, required: ['signal', 'symbol'], }, // Transform incoming data transform: (payload) => ({ signal: payload.signal, symbol: payload.symbol, confidence: payload.confidence || 0.5, timestamp: Date.now(), }), }); console.log(`Webhook URL: ${source.url}`); // POST to: https://your-domain.com/webhooks/my-signals ``` ### Add Custom REST Source ```typescript // Add REST API data source const source = await integrations.addRest({ name: 'my-api', description: 'Custom price API', // API config url: 'https://api.example.com/prices', method: 'GET', headers: { 'Authorization': `Bearer ${process.env.MY_API_KEY}`, }, // Polling interval intervalMs: 30000, // Transform response transform: (response) => ({ price: response.data.price, volume: response.data.volume, timestamp: Date.now(), }), }); ``` ### Add WebSocket Source ```typescript // Add WebSocket data source const source = await integrations.addWebSocket({ name: 'live-prices', description: 'Real-time price feed', // WebSocket config url: 'wss://stream.example.com/prices', // Message handlers onMessage: (data) => ({ type: 'price', symbol: data.s, price: parseFloat(data.p), timestamp: data.t, }), // Subscription message subscribe: { method: 'SUBSCRIBE', params: ['btcusdt@trade'], }, // Reconnect settings reconnect: true, reconnectIntervalMs: 5000, }); ``` ### Subscribe to Data ```typescript // Subscribe to real-time updates integrations.subscribe('my-signals', (data) => { console.log(`Signal: ${data.signal} ${data.symbol}`); console.log(`Confidence: ${data.confidence}`); if (data.signal === 'BUY' && data.confidence > 0.8) { // Execute trade logic } }); // Subscribe to multiple sources integrations.subscribeAll(['fedwatch', 'crypto', 'my-signals'], (source, data) => { console.log(`[${source}] ${JSON.stringify(data)}`); }); ``` ### Get Latest Data ```typescript // Get current data from source const fedData = await integrations.getData('fedwatch'); console.log('Fed Rate Probabilities:'); for (const meeting of fedData.meetings) { console.log(`${meeting.date}: ${meeting.probabilities}`); } // Get with freshness check const data = await integrations.getData('crypto', { maxAgeMs: 60000, // Refetch if older than 60s }); ``` ### Check Status ```typescript // Get source status const status = await integrations.getStatus('my-api'); console.log(`Status: ${status.status}`); // 'healthy' | 'degraded' | 'error' console.log(`Last fetch: ${status.lastFetch}`); console.log(`Last error: ${status.lastError}`); console.log(`Fetch count: ${status.fetchCount}`); console.log(`Error count: ${status.errorCount}`); // Get all statuses const all = await integrations.getAllStatuses(); ``` --- ## Built-in Data Sources | Source | Type | Data | Refresh | |--------|------|------|---------| | **fedwatch** | REST | Fed rate probabilities | 5 min | | **538** | REST | Election forecasts | 1 hour | | **silver** | REST | Silver Bulletin forecasts | 1 hour | | **rcp** | REST | Polling averages | 15 min | | **odds-api** | REST | Sports betting odds | 1 min | | **polymarket** | WebSocket | Market prices | Real-time | | **kalshi** | WebSocket | Market prices | Real-time | | **binance** | WebSocket | Crypto prices | Real-time | --- ## Custom Source Types | Type | Best For | Latency | |------|----------|---------| | **webhook** | External signals pushed to you | Instant | | **rest** | APIs you poll periodically | Seconds | | **websocket** | Real-time streaming data | Milliseconds | --- ## Using Data in Bots ```typescript import { createTradingBot } from 'clodds/trading'; import { createIntegrationsManager } from 'clodds/integrations'; const integrations = createIntegrationsManager(); const bot = createTradingBot(); // Use custom signals in bot strategy integrations.subscribe('my-signals', async (signal) => { if (signal.signal === 'BUY' && signal.confidence > 0.9) { await bot.execute({ platform: 'polymarket', market: signal.symbol, side: 'YES', size: 100 * signal.confidence, }); } }); // Use Fed data for macro bets integrations.subscribe('fedwatch', async (data) => { const cutProb = data.meetings[0].probabilities['25bp_cut']; if (cutProb > 0.8) { // High probability of rate cut await bot.execute({ platform: 'kalshi', market: 'fed-rate-cut', side: 'YES', size: 500, }); } }); ``` --- ## Environment Variables ```bash # Built-in sources CME_FEDWATCH_API_KEY=your-key FIVETHIRTYEIGHT_API_KEY=your-key ODDS_API_KEY=your-key # Custom sources MY_SIGNALS_WEBHOOK_SECRET=your-secret MY_API_KEY=your-key ``` --- ## Best Practices 1. **Validate incoming data** — Use schemas for webhooks 2. **Set appropriate intervals** — Don't poll too frequently 3. **Handle errors gracefully** — Sources will fail sometimes 4. **Monitor freshness** — Alert on stale data 5. **Transform consistently** — Normalize data formats 6. **Use WebSocket for latency** — When milliseconds matter --- Source attribution: alsk1992 Original project: https://github.com/alsk1992/CloddsBot/blob/c930628c47a4a745f497e29035a3b64622f97cc7/src/skills/bundled/integrations/SKILL.md License: MIT License information: https://opensource.org/license/mit Original upstream instructions; downloaded from Mega AI Hub. ## Upstream license notice MIT License Copyright (c) 2026 alsk1992 Permission is hereby granted, free of charge, to any person obtaining a copy of this software and associated documentation files (the "Software"), to deal in the Software without restriction, including without limitation the rights to use, copy, modify, merge, publish, distribute, sublicense, and/or sell copies of the Software, and to permit persons to whom the Software is furnished to do so, subject to the following conditions: The above copyright notice and this permission notice shall be included in all copies or substantial portions of the Software. THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS OR IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF MERCHANTABILITY, FITNESS FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT. IN NO EVENT SHALL THE AUTHORS OR COPYRIGHT HOLDERS BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER LIABILITY, WHETHER IN AN ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING FROM, OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN THE SOFTWARE. # Mega AI Hub resource metadata Creator / publisher: alsk1992 Original project: https://github.com/alsk1992/CloddsBot/blob/c930628c47a4a745f497e29035a3b64622f97cc7/src/skills/bundled/integrations/SKILL.md Attribution basis: Source repository record Fields of work: Development & Engineering, Product Management Roles: Backend Developer, Data Engineer, Growth Product Manager, ML / AI Engineer, Product Manager Specialties: API, Database Tools: Clodds, SQLite Country applicability: Country not specified Classification basis: Source catalog labels Instruction SHA-256: 8290d321e7d2ece54ba73d1112d5ec625e630a58b3e74136a92283e8e2e6b58c