WhatsApp Bot Integration

export const getWhatsAppQR = async (): Promise<string> => {
    const qrResponse = await fetch(`${DEPLOY_URL}/${projectId}/qr`, {
        headers: { 'x-api-builderbot': builderBotApiKey },
    });

    const blob = await qrResponse.blob();
    return new Promise((resolve, reject) => {
        const reader = new FileReader();
        reader.onloadend = () => resolve(reader.result as string);
        reader.readAsDataURL(blob);
    });
};

export const persistStatus = (status: 'active' | 'disconnected') => {
    if (status === 'active') {
        localStorage.setItem(WHATSAPP_STATUS_KEY, 'active');
        if (!getPersistedConnectionTime()) {
            localStorage.setItem(
                WHATSAPP_CONNECTION_TIME_KEY,
                new Date().toISOString()
            );
        }
    } else {
        localStorage.removeItem(WHATSAPP_STATUS_KEY);
        localStorage.removeItem(WHATSAPP_CONNECTION_TIME_KEY);
    }
};

import { sendWhatsAppMessage } from './services/whatsappBotService';

const result = await sendWhatsAppMessage(
    '1234567890',              // Phone number
    'Hello! Your order is ready.',  // Message content
    'https://example.com/image.jpg' // Optional media URL
);

if (result.success) {
    console.log('Message sent successfully');
} else {
    console.error('Failed to send:', result.error);
}

import { sendWhatsAppGroupMessage } from './services/whatsappBotService';

const result = await sendWhatsAppGroupMessage(
    '[email protected]',    // Group ID
    'Special promotion today!',  // Message
    'https://example.com/promo.jpg' // Optional media
);

function logMessageHistory(clientSpreadsheet, eventName, projectId, data) {
    const messageId = data.id || 'N/A';
    const direction = eventName.replace('message.', ''); // 'incoming' or 'outgoing'
    const from = data.from || 'N/A';
    const to = data.to || 'N/A';
    const body = data.body || '';
    const mediaUrl = (data.media && data.media.url) || data.mediaUrl || '';

    historySheet.appendRow([
        new Date().toISOString(),
        messageId,
        direction,
        from,
        to,
        body.toString().substring(0, 5000),
        mediaUrl,
        JSON.stringify(data)
    ]);
}

function checkBotStatusManually() {
    const url = `https://app.builderbot.cloud/api/v1/manager/deploys/${PROJECT_ID}`;
    const options = {
        method: 'get',
        headers: { 'x-api-builderbot': BUILDERBOT_API_KEY },
        muteHttpExceptions: true
    };

    const response = UrlFetchApp.fetch(url, options);
    const responseCode = response.getResponseCode();

    let newStatus = 'inactive';
    if (responseCode === 200) {
        const data = JSON.parse(response.getContentText());
        const apiStatus = data.deploy && data.deploy.status;

        if (apiStatus === 'ACTIVE' || apiStatus === 'ONLINE') {
            newStatus = 'active';
        } else if (apiStatus === 'READY_TO_SCAN') {
            newStatus = 'pending_scan';
        }
    }

    updateBotStatus(clientSpreadsheet, PROJECT_ID, newStatus, details);
}

import { disconnectWhatsAppBot } from './services/whatsappBotService';

try {
    await disconnectWhatsAppBot();
    persistStatus('disconnected');
    console.log('Bot disconnected successfully');
} catch (error) {
    console.error('Failed to disconnect:', error);
}

import {
    fetchAndCacheWhatsAppBotData,
    getMetrics,
    getChatHistory
} from './services/whatsappBotMetricsService';

// Fetch latest data from Google Sheets
await fetchAndCacheWhatsAppBotData();

// Get metrics
const metrics = getMetrics();
console.log(metrics);
// {
//   distinctCustomers: 150,
//   totalMessages: 1247,
//   ordersMade: 45,
//   reservationsMade: 23
// }

// Get chat history
const chatHistory = getChatHistory();
// Returns up to 100 most recent chat sessions

const ordersMade = orders.filter(
    o => o.createdBy === CreatedBy.WHATSAPP_ASSISTANT
).length;

const reservationsMade = reservations.filter(
    r => r.createdBy === CreatedBy.WHATSAPP_ASSISTANT
).length;

export const logStatusChange = async (
    status: string,
    details: string
): Promise<void> => {
    const logEntry = {
        timestamp: new Date().toISOString(),
        eventName: 'status.change.frontend',
        projectId: projectId,
        from: 'Frontend Panel',
        details: details,
        rawPayload: JSON.stringify({ status, details }),
        unhandledStatus: '',
        botStatus: status
    };

    await addDoc(collection(db, 'WhastappAssistant_logs'), logEntry);
};