Create Custom Channel

// POST /api/search-products
export default async function handler(req, res) {
  const { platform, searchEntry, after } = req.body;

  // Verify access token
  if (platform.accessToken !== process.env.ACCESS_TOKEN) {
    return res.status(403).json({ error: "Access denied" });
  }

  // Your custom product catalog (suppliers, 3PL inventory, etc.)
  const allProducts = [
    {
      image: "https://via.placeholder.com/300x300/FF0000/FFFFFF?text=PIPE",
      title: "Hooli XYZ Compression Device",
      productId: "hooli001",
      variantId: "white",
      price: "299.99",
      availableForSale: true,
      inventory: 150,
      inventoryTracked: true,
      productLink: "https://hooli-supply.com/products/xyz-compression",
      cursor: "eyJpZCI6Imhvb2xpMDAxIn0="
    },
    {
      image: "https://via.placeholder.com/300x300/008080/FFFFFF?text=STORAGE",
      title: "Electronics Storage Box",
      productId: "storage001", 
      variantId: "crypto-box",
      price: "2000.00",
      availableForSale: true,
      inventory: 8,
      inventoryTracked: true,
      productLink: "https://demo-supplier.com/products/crypto-device",
      cursor: "eyJpZCI6InNldGVjMDAxIn0="
    },
    {
      image: "https://via.placeholder.com/300x300/4B0082/FFFFFF?text=HACK", 
      title: "Wireless Mouse - Blue",
      productId: "phreaks001",
      variantId: "blue-box",
      price: "500.00",
      availableForSale: true,
      inventory: 12,
      inventoryTracked: true,
      productLink: "https://demo-store.com/products/wireless-mouse",
      cursor: "eyJpZCI6Im1vdXNlMDAxIn0="
    }
  ];

  let filteredProducts = allProducts;

  // Filter by search term if provided
  if (searchEntry) {
    filteredProducts = allProducts.filter(product =>
      product.title.toLowerCase().includes(searchEntry.toLowerCase())
    );
  }

  // Simple pagination
  let startIndex = 0;
  if (after) {
    const decodedCursor = JSON.parse(Buffer.from(after, 'base64').toString());
    startIndex = allProducts.findIndex(p => p.productId === decodedCursor.id) + 1;
  }

  const paginatedProducts = filteredProducts.slice(startIndex, startIndex + 10);
  const hasNextPage = startIndex + 10 < filteredProducts.length;
  const endCursor = paginatedProducts.length > 0 
    ? paginatedProducts[paginatedProducts.length - 1].cursor 
    : null;

  return res.status(200).json({
    products: paginatedProducts,
    pageInfo: {
      hasNextPage,
      endCursor
    }
  });
}

// POST /api/get-product
export default async function handler(req, res) {
  const { platform, productId, variantId } = req.body;

  // Verify access token
  if (platform.accessToken !== process.env.ACCESS_TOKEN) {
    return res.status(403).json({ error: "Access denied" });
  }

  // Your product catalog
  const products = {
    "hooli001": {
      white: {
        image: "https://via.placeholder.com/300x300/FF0000/FFFFFF?text=PIPE",
        title: "Hooli XYZ Compression Device - White",
        productId: "hooli001",
        variantId: "white", 
        price: "299.99",
        availableForSale: true,
        inventory: 150,
        inventoryTracked: true,
        productLink: "https://hooli-supply.com/products/xyz-compression"
      }
    },
    "storage001": {
      "crypto-box": {
        image: "https://via.placeholder.com/300x300/008080/FFFFFF?text=STORAGE",
        title: "Electronics Storage Box - Crypto Box",
        productId: "storage001",
        variantId: "crypto-box",
        price: "2000.00",
        availableForSale: true,
        inventory: 8,
        inventoryTracked: true,
        productLink: "https://demo-supplier.com/products/crypto-device"
      }
    }
  };

  const product = products[productId]?.[variantId || 'default'];
  
  if (!product) {
    return res.status(404).json({ error: "Product not found" });
  }

  return res.status(200).json({ product });
}

// POST /api/create-purchase
export default async function handler(req, res) {
  const { platform, cartItems, shipping, notes } = req.body;

  // Verify access token
  if (platform.accessToken !== process.env.ACCESS_TOKEN) {
    return res.status(403).json({ error: "Access denied" });
  }

  try {
    // Generate unique purchase ID (in real app, use proper ID generation)
    const purchaseId = `PO-${Date.now()}`;
    const orderNumber = `#${purchaseId}`;

    // Calculate total price
    const totalPrice = cartItems.reduce((sum, item) => {
      return sum + (parseFloat(item.price) * item.quantity);
    }, 0).toFixed(2);

    // In a real implementation, you would:
    // 1. Create the purchase in your fulfillment system
    // 2. Send order to your supplier/3PL
    // 3. Update inventory levels
    // 4. Generate invoices/receipts

    // For demo purposes, let's simulate different responses based on products
    const hasCryptoEquipment = cartItems.some(item => item.variantId?.includes('crypto') || item.variantId?.includes('setec'));
    
    if (hasCryptoEquipment) {
      // Special handling for crypto/security equipment
      return res.status(200).json({
        purchaseId,
        orderNumber,
        totalPrice,
        invoiceUrl: `https://demo-supplier.com/invoices/${purchaseId}`,
        lineItems: cartItems.map(item => ({
          id: `line_${Date.now()}_${Math.random()}`,
          title: item.name || `Product ${item.variantId}`,
          quantity: item.quantity,
          variantId: item.variantId
        })),
        status: "pending_security_clearance" // Crypto equipment needs clearance
      });
    }

    // Regular purchase flow
    const processedLineItems = cartItems.map(item => ({
      id: `line_${Date.now()}_${Math.random()}`,
      title: item.name || `Product ${item.variantId}`,
      quantity: item.quantity,
      variantId: item.variantId
    }));

    // Simulate email notification to supplier
    console.log(`📧 Purchase Order Created: ${orderNumber}`);
    console.log(`📦 Items:`, processedLineItems);
    console.log(`🚚 Ship to: ${shipping?.firstName} ${shipping?.lastName}`);
    console.log(`💰 Total: $${totalPrice}`);

    return res.status(200).json({
      purchaseId,
      orderNumber,
      totalPrice,
      invoiceUrl: `https://your-fulfillment-portal.com/invoices/${purchaseId}`,
      lineItems: processedLineItems,
      status: "processing"
    });

  } catch (error) {
    console.error('Purchase creation failed:', error);
    return res.status(500).json({
      error: "Purchase creation failed",
      details: error.message
    });
  }
}

// POST /api/create-webhook
export default async function handler(req, res) {
  const { platform, endpoint, events } = req.body;

  // Verify access token
  if (platform.accessToken !== process.env.ACCESS_TOKEN) {
    return res.status(403).json({ error: "Access denied" });
  }

  try {
    const webhooks = [];

    // Map Openship events to your system's events
    const eventMapping = {
      "TRACKING_CREATED": "fulfillment.shipped",
      "ORDER_CANCELLED": "purchase.cancelled",
      "ORDER_CHARGEBACKED": "purchase.disputed"
    };

    for (const event of events) {
      const internalEvent = eventMapping[event] || event;
      
      // In a real implementation, you would register these webhooks 
      // with your fulfillment system/3PL API
      const webhookId = `webhook_${Date.now()}_${Math.random().toString(36).substr(2, 9)}`;
      
      console.log(`🔗 Registering webhook: ${internalEvent} -> ${endpoint}`);
      
      // Simulate webhook registration
      webhooks.push({
        id: webhookId,
        endpoint: {
          callbackUrl: endpoint
        },
        events: [internalEvent],
        active: true,
        created_at: new Date().toISOString()
      });
    }

    return res.status(200).json({ webhooks });

  } catch (error) {
    console.error('Webhook creation failed:', error);
    return res.status(500).json({
      error: "Webhook creation failed",
      details: error.message
    });
  }
}

// POST /api/webhook/tracking-created
export default async function handler(req, res) {
  const { event, headers } = req.body;

  // Verify webhook authenticity (implement your own verification)
  if (!verifyWebhookSignature(headers)) {
    return res.status(403).json({ error: "Invalid signature" });
  }

  // Transform your fulfillment event to Openship format
  const fulfillment = {
    id: event.fulfillment_id,
    orderId: event.order_id,
    status: "success",
    trackingCompany: event.shipping_carrier,
    trackingNumber: event.tracking_number,
    trackingUrl: event.tracking_url,
    purchaseId: event.purchase_id,
    lineItems: event.shipped_items.map(item => ({
      id: item.line_item_id,
      title: item.product_name,
      quantity: item.quantity_shipped,
      variantId: item.variant_id,
      productId: item.product_id
    })),
    createdAt: event.shipped_at,
    updatedAt: event.updated_at
  };

  return res.status(200).json({ fulfillment, type: "fulfillment_created" });
}

function verifyWebhookSignature(headers) {
  // Implement your webhook signature verification here
  // This could be HMAC, JWT, or other verification method
  return true; // Simplified for demo
}