Data Sources Integration Guide

const express = require('express');
const app = express();

app.use(express.json());

// Your API endpoint that Chatplugify will call
app.post('/api/items', async (req, res) => {
  try {
    const { after, limit } = req.body;
    
    // Get items from your database
    const items = await getItemsFromDatabase(after, limit);
    
    // Check if there are more items
    const hasMore = await checkIfMoreItems(items[items.length - 1]?.id);
    
    // Format response according to Chatplugify requirements
    const response = {
      items: items.map(item => ({
        id: item.id,
        title: item.title,
        description: item.description,
        category: item.category,
        type: item.type,
        price: item.price.toString(),
        url: item.url,
        image: item.image,
        metadata: {
          brand: item.brand,
          rating: item.rating,
          inStock: item.stock > 0,
          // Add any other relevant metadata
        }
      })),
      hasMore: hasMore,
      nextCursor: items.length > 0 ? items[items.length - 1].id : null
    };
    
    res.json(response);
  } catch (error) {
    res.status(500).json({ error: 'Internal server error' });
  }
});

async function getItemsFromDatabase(after, limit) {
  // Your database query logic here
  // Example with SQL:
  let query = 'SELECT * FROM products';
  let params = [];
  
  if (after) {
    query += ' WHERE id > ?';
    params.push(after);
  }
  
  query += ' ORDER BY id LIMIT ?';
  params.push(limit);
  
  return await db.query(query, params);
}

app.listen(3000, () => {
  console.log('API server running on port 3000');
});

from flask import Flask, request, jsonify
import sqlite3

app = Flask(__name__)

@app.route('/api/items', methods=['POST'])
def get_items():
    try:
        data = request.get_json()
        after = data.get('after')
        limit = data.get('limit', 100)
        
        # Get items from your database
        items = get_items_from_database(after, limit)
        
        # Check if there are more items
        has_more = check_if_more_items(items[-1]['id'] if items else None)
        
        # Format response according to Chatplugify requirements
        response = {
            "items": [
                {
                    "id": item['id'],
                    "title": item['title'],
                    "description": item['description'],
                    "category": item['category'],
                    "type": item['type'],
                    "price": str(item['price']),
                    "url": item['url'],
                    "image": item['image'],
                    "metadata": {
                        "brand": item.get('brand'),
                        "rating": item.get('rating'),
                        "inStock": item.get('stock', 0) > 0,
                        # Add any other relevant metadata
                    }
                }
                for item in items
            ],
            "hasMore": has_more,
            "nextCursor": items[-1]['id'] if items else None
        }
        
        return jsonify(response)
    
    except Exception as e:
        return jsonify({"error": "Internal server error"}), 500

def get_items_from_database(after, limit):
    conn = sqlite3.connect('products.db')
    cursor = conn.cursor()
    
    if after:
        cursor.execute("""
            SELECT * FROM products 
            WHERE id > ? 
            ORDER BY id 
            LIMIT ?
        """, (after, limit))
    else:
        cursor.execute("""
            SELECT * FROM products 
            ORDER BY id 
            LIMIT ?
        """, (limit,))
    
    items = cursor.fetchall()
    conn.close()
    
    return [dict(zip([col[0] for col in cursor.description], item)) for item in items]

if __name__ == '__main__':
    app.run(debug=True, port=3000)