fix(phase4): edge functions now broadcast via Render bot /internal/broadcast

Edge functions (seller-products, live, group-buy) now call the Render bot's
/internal/broadcast endpoint instead of the Supabase telegram edge function.
This uses the bot's TELEGRAM_BOT_TOKEN (which never leaves Render) to send
actual Telegram messages to subscribers.

Auth: X-Internal-Key header (BOT_INTERNAL_KEY env var on both sides).

supabase/functions/group-buy/index.ts

@@ -106,16 +106,20 @@ async function handleCreate(userId: string, body: Record<string, unknown>): Prom
   const freshRows = await refreshed.json();
   const freshGroupBuy = freshRows?.[0] || created[0];
 
-  // Phase 4: Auto-broadcast to Telegram (fire-and-forget)
-  fetch(`${SUPABASE_URL}/functions/v1/telegram`, {
+  // Phase 4: Auto-broadcast to Telegram via the Render bot (fire-and-forget)
+  const BOT_RENDER_URL = Deno.env.get('BOT_RENDER_URL') || 'https://eesha-shop-buying-and-selling.onrender.com';
+  const BOT_INTERNAL_KEY = Deno.env.get('BOT_INTERNAL_KEY') || 'CellexInternal2024';
+  fetch(`${BOT_RENDER_URL}/internal/broadcast`, {
     method: 'POST',
-    headers: { ...adminHeaders, 'X-Internal-Call': 'cellex-internal', 'Content-Type': 'application/json' },
+    headers: {
+      'Content-Type': 'application/json',
+      'X-Internal-Key': BOT_INTERNAL_KEY,
+    },
     body: JSON.stringify({
-      op: 'broadcast',
-      broadcastType: 'group_buy',
-      entityId: groupBuyId,
+      broadcast_type: 'group_buy',
+      entity_id: groupBuyId,
       message: `🛍️ <b>New group buy!</b>\n${escapeHtml(product.name)} — $${Number(product.price).toFixed(2)}\nGet ${discountPct}% off when ${targetCount} friends join.\n\nJoin: https://eeshaai-cellex-web.hf.space/group-buy.html?id=${groupBuyId}`,
-      imageUrl: product.image_url || undefined,
+      image_url: product.image_url || undefined,
     }),
   }).catch(() => {});
 

supabase/functions/live/index.ts

@@ -186,14 +186,18 @@ async function handleStart(userId: string, body: Record<string, unknown>): Promi
   // System message
   await postSystemMessage(session.id, `🔴 Live now: ${title}`);
 
-  // Phase 4: Auto-broadcast to Telegram (fire-and-forget)
-  fetch(`${SUPABASE_URL}/functions/v1/telegram`, {
+  // Phase 4: Auto-broadcast to Telegram via the Render bot (fire-and-forget)
+  const BOT_RENDER_URL = Deno.env.get('BOT_RENDER_URL') || 'https://eesha-shop-buying-and-selling.onrender.com';
+  const BOT_INTERNAL_KEY = Deno.env.get('BOT_INTERNAL_KEY') || 'CellexInternal2024';
+  fetch(`${BOT_RENDER_URL}/internal/broadcast`, {
     method: 'POST',
-    headers: { ...adminHeaders, 'X-Internal-Call': 'cellex-internal', 'Content-Type': 'application/json' },
+    headers: {
+      'Content-Type': 'application/json',
+      'X-Internal-Key': BOT_INTERNAL_KEY,
+    },
     body: JSON.stringify({
-      op: 'broadcast',
-      broadcastType: 'live_start',
-      entityId: session.id,
+      broadcast_type: 'live_start',
+      entity_id: session.id,
       message: `🔴 <b>LIVE NOW:</b> ${escapeHtml(title)}\n${(body.description as string) || ''}\n\nWatch: https://eeshaai-cellex-web.hf.space/live-watch.html?id=${session.id}`,
     }),
   }).catch(() => {});

supabase/functions/seller-products/index.ts

@@ -84,21 +84,26 @@ async function handleCreate(sellerId: string, body: Record<string, unknown>): Pr
   if (!resp.ok) return errorResponse(created?.message || 'Failed to create product', 500);
   const product = created?.[0];
 
-  // Phase 4: Auto-broadcast to Telegram (fire-and-forget)
+  // Phase 4: Auto-broadcast to Telegram via the Render bot (fire-and-forget)
   broadcastToTelegram('new_product', String(product.id),
-    `🆕 <b>New product:</b> ${escapeHtml(name)}\n💵 $${Number(price).toFixed(2)}\n📦 ${payload.category}\n\n${SUPABASE_URL ? 'https://eeshaai-cellex-web.hf.space/Eesha buying folder/product.html?id=' + product.id : ''}`,
+    `🆕 <b>New product:</b> ${escapeHtml(name)}\n💵 $${Number(price).toFixed(2)}\n📦 ${payload.category}\n\nhttps://eeshaai-cellex-web.hf.space/Eesha buying folder/product.html?id=${product.id}`,
     payload.image_url as string | undefined
   ).catch(() => {});
 
   return jsonResponse({ success: true, product });
 }
 
-// Helper: broadcast to Telegram via the telegram edge function (fire-and-forget)
+// Helper: broadcast to Telegram via the Render bot's /internal/broadcast endpoint
 async function broadcastToTelegram(broadcastType: string, entityId: string, message: string, imageUrl?: string): Promise<void> {
-  await fetch(`${SUPABASE_URL}/functions/v1/telegram`, {
+  const BOT_RENDER_URL = Deno.env.get('BOT_RENDER_URL') || 'https://eesha-shop-buying-and-selling.onrender.com';
+  const BOT_INTERNAL_KEY = Deno.env.get('BOT_INTERNAL_KEY') || 'CellexInternal2024';
+  await fetch(`${BOT_RENDER_URL}/internal/broadcast`, {
     method: 'POST',
-    headers: { ...adminHeaders, 'X-Internal-Call': 'cellex-internal', 'Content-Type': 'application/json' },
-    body: JSON.stringify({ op: 'broadcast', broadcastType, entityId, message, imageUrl }),
+    headers: {
+      'Content-Type': 'application/json',
+      'X-Internal-Key': BOT_INTERNAL_KEY,
+    },
+    body: JSON.stringify({ broadcast_type: broadcastType, entity_id: entityId, message, image_url: imageUrl }),
   }).catch(() => {});
 }