Uploaded

Dockerfile

@@ -0,0 +1,20 @@
+# Use an official lightweight Node.js image
+FROM node:18-alpine
+
+# Set the working directory inside the container
+WORKDIR /app
+
+# Copy package.json and package-lock.json to leverage Docker cache
+COPY package*.json ./
+
+# Install production dependencies
+RUN npm install --production
+
+# Copy the rest of your application code
+COPY . .
+
+# Expose the port the app runs on
+EXPOSE 3001
+
+# The command to run your application
+CMD ["node", "server.js"]

google-credentials.json

@@ -0,0 +1,13 @@
+{
+  "type": "service_account",
+  "project_id": "staff-sheet-chatbot",
+  "private_key_id": "450ad00226e86e8b79be3fa7f55099cfb005ca4c",
+  "private_key": "-----BEGIN PRIVATE KEY-----\nMIIEvQIBADANBgkqhkiG9w0BAQEFAASCBKcwggSjAgEAAoIBAQDgKOvVq3WkZZ5G\n8qxXLWwTUnLgvfEgodOXtFF1aO+Cb8VbB1AR43ksrKaTVE3M2mtoN+jaaQ72KTwH\nn+rIyJUDITaw9GBthmzjLIquECj7haa3h1BRBjiZY1FMTysdIg3HK8GQDjbNf5UE\nEwS3NOp6EvNp8gTVejF1c819KZ/RCDQPlNWC+Ol8eet9GIiEHzgsqv0YRHNdqwV6\nrV7oTxOZ3F7s6J7a6bVkQkP51M/l5rv6xObVaikkk+XcUrFY77FjkzvbuyKEYRoq\neHJ1FTs02GplhUhoy/zIxNAvAZF3fMhk1kXNUlgPcS20LwHi2ybt+joFMYaUjzBl\nCBS9b/S5AgMBAAECggEABmS8Z0WC7zuzwj/JMRpbTwjGvIjGYCElfRn4SdJCpJSG\nC0Tf4Ia9rcvF24Vny6w+LISNuG8PLW+7JdeGlY/9ChAQNIdf2bfgErGySektlhD3\nkpwCKzFze1KFHtlSODxAqtnhZTe2kfFt4WYeeBBDENTKCw9LWoBn+TrilUuS4p4c\n3JpGnSuI1MWyzMkggGMC3GyLzQhUrhfKk8GNrW76Mpc91WiHyy9xv9tvk4ipMVpc\n0yNzyzLe7UniJY0MsUKw759YtfWgkhr4mO8/4SNWo/tyI1Qgy+SGIJpWR77KTkvj\nVHvd9ynMQdx4JZXI0s0RzlmJ6MbADJFA8ZKzM2uuwQKBgQD1tUHUSU1rN9V2PVl8\noAW5uSKTkHBtB7hlsvhmc3oEUhkx+hfJcYnvut9vivZPQmAN9vSizL5jWE8a9kWq\nAdGOOObMDP3i3/y+/hyBfPcvQnItbUpIGIizFeLhpB2Dv8eyWHkQsdA3oqkGMh/V\nAU7KxQn5jIlSkGfz05c3CrWgoQKBgQDpjJn8RKPboNeZpYM6HGK65A2AA685QjI3\nNbJgpTlcK5e0CE1DJnCXkd+I8RRLSyY9gfGfiEE0rI5G4naWGx0m2xCkFPM0PkDb\ngu9CkxWewEv+wVge9Dh3QKsZFup7v2sut6pr/MKtQndrU6Q6MCPQ0ipjJVVWCjTL\nIEN2c/wlGQKBgCarMgMAzkhTbyq+mPi+DmieNEzY7HicQG7w7ZriDY/kg8aTv26a\nicTKuiNJ0V3D6m4IMZP1ePkVis2JeIk65Ann9pqiaMptyc8dGsteKWCsql9v1cLm\n6YyVozEzrNlxMzJkLhlsgoJe/Q7WkJ/rJsVOoTU+4tW1mEaNRD0LWG5BAoGBANQc\nR0nvCSaSSN2Zjbo8R4rXTk+CiSSmszajRRMzXAoS6V+v3oPrKHzwFiWoVjcf1GYu\nW0T5mcb+JOXKDcu8alh8wvtSr6M2Gu+CVkyPiyY4HY0NCjxqr9HW4M4Tmviy2+R9\nGIGk+SYkZJMMTu4uBIlGJwsOwBc5g8Mr1TmCk3EZAoGAQtPF5LD4yYAzFrbwYtzZ\nyThMMa0Fp35TLTTYXoZ2GIyUAJTLbW0SSvT5kglvNxz72iTikCJCJ8YRZ5qe69w3\nnzWO3vwPMKdDuBMkbHF1J6j6yesosidEOhRH5pg29z6AlmzgfUV/c2JVzhkb28aB\nuZS3oPNqlNcMv81appq53/Y=\n-----END PRIVATE KEY-----\n",
+  "client_email": "sheet-reader-bot@staff-sheet-chatbot.iam.gserviceaccount.com",
+  "client_id": "108371730199027670321",
+  "auth_uri": "https://accounts.google.com/o/oauth2/auth",
+  "token_uri": "https://oauth2.googleapis.com/token",
+  "auth_provider_x509_cert_url": "https://www.googleapis.com/oauth2/v1/certs",
+  "client_x509_cert_url": "https://www.googleapis.com/robot/v1/metadata/x509/sheet-reader-bot%40staff-sheet-chatbot.iam.gserviceaccount.com",
+  "universe_domain": "googleapis.com"
+}

package.json

@@ -0,0 +1,18 @@
+{
+  "name": "chatbot-backend",
+  "version": "1.0.0",
+  "main": "index.js",
+  "scripts": {
+    "test": "echo \"Error: no test specified\" && exit 1"
+  },
+  "keywords": [],
+  "author": "",
+  "license": "ISC",
+  "description": "",
+  "dependencies": {
+    "@google/generative-ai": "^0.24.1",
+    "dotenv": "^17.2.1",
+    "express": "^5.1.0",
+    "googleapis": "^154.0.0"
+  }
+}

server.js

@@ -0,0 +1,171 @@
+const express = require('express');
+const { google } = require('googleapis');
+const { GoogleGenerativeAI } = require('@google/generative-ai');
+const cors = require('cors');
+require('dotenv').config();
+
+const app = express();
+app.use(express.json());
+
+const frontendUrl = process.env.FRONTEND_URL || 'http://localhost:5173';
+app.use(cors({ origin: frontendUrl }));
+
+const PORT = process.env.PORT || 3001;
+
+const genAI = new GoogleGenerativeAI(process.env.GEMINI_API_KEY);
+const model = genAI.getGenerativeModel({ model: "gemini-1.5-flash" });
+
+let processedStaffCache = null;
+let rawSheetCache = null;
+const CACHE_DURATION_MS = 300000;
+
+const isValidName = (name) => name && name.trim() !== '' && name.trim() !== '-';
+
+function getGoogleAuth() {
+    if (process.env.GOOGLE_CREDENTIALS_JSON) {
+        const credentials = JSON.parse(process.env.GOOGLE_CREDENTIALS_JSON);
+        return new google.auth.GoogleAuth({
+            credentials,
+            scopes: ['https://www.googleapis.com/auth/spreadsheets.readonly'],
+        });
+    }
+    return new google.auth.GoogleAuth({
+        keyFile: 'google-credentials.json',
+        scopes: ['https://www.googleapis.com/auth/spreadsheets.readonly'],
+    });
+}
+
+async function updateSheetCache() {
+    try {
+        console.log('Refreshing spreadsheet data cache...');
+        const auth = getGoogleAuth();
+        const sheets = google.sheets({ version: 'v4', auth });
+        const response = await sheets.spreadsheets.values.get({
+            spreadsheetId: process.env.GOOGLE_SHEET_ID,
+            range: 'Sheet1!A:H',
+        });
+        const rows = response.data.values;
+        if (!rows || rows.length === 0) {
+            console.log('No data found in spreadsheet.');
+            return;
+        }
+
+        rawSheetCache = rows;
+        const headers = rows[0];
+        const dataRows = rows.slice(1);
+        let currentLocation = '';
+        const allStaff = [];
+
+        dataRows.forEach((row, rowIndex) => {
+            const rowData = {};
+            headers.forEach((header, index) => rowData[header] = row[index] || '');
+
+            if (isValidName(rowData.Location)) {
+                currentLocation = rowData.Location;
+            }
+            rowData.Location = currentLocation;
+            
+            const baseId = `r${rowIndex}`;
+            
+            if (isValidName(rowData.Provider)) {
+                allStaff.push({ ...rowData, id: `${baseId}-p`, role: 'Provider' });
+            }
+            if (isValidName(rowData['Team Leads/Manager'])) {
+                allStaff.push({ ...rowData, id: `${baseId}-tl`, role: 'Team Lead / Manager', Extension: rowData['Ext/Phone#'] });
+            }
+            if (isValidName(rowData.MA)) {
+                allStaff.push({ ...rowData, id: `${baseId}-ma`, role: 'Medical Assistant', Extension: rowData.Extension });
+            }
+            if (isValidName(rowData.VA)) {
+                allStaff.push({ ...rowData, id: `${baseId}-va`, role: 'Virtual Assistant', Extension: rowData.Ext });
+            }
+            if (isValidName(rowData['Ext/Phone#']) && /^[a-zA-Z]+-\s*\d+$/.test(rowData['Ext/Phone#'])) {
+                const [name, ext] = rowData['Ext/Phone#'].split('-');
+                allStaff.push({ ...rowData, id: `${baseId}-other`, role: 'Other Staff', OtherStaffName: name.trim(), Extension: ext.trim() });
+            }
+        });
+        
+        processedStaffCache = allStaff;
+        console.log('Cache updated. Processed records:', processedStaffCache.length, 'Raw rows:', rawSheetCache.length);
+    } catch (error) {
+        console.error('Error refreshing spreadsheet cache:', error.message);
+    }
+}
+
+const delay = (ms) => new Promise(resolve => setTimeout(resolve, ms));
+
+async function generateWithRetry(model, prompt, maxRetries = 3) {
+    let attempt = 0;
+    while (attempt < maxRetries) {
+        try {
+            return await model.generateContentStream(prompt);
+        } catch (error) {
+            if (error.status === 503 && attempt < maxRetries - 1) {
+                const delayTime = Math.pow(2, attempt) * 1000 + Math.random() * 1000;
+                console.log(`Attempt ${attempt + 1} failed. Retrying in ${Math.round(delayTime / 1000)}s...`);
+                await delay(delayTime);
+                attempt++;
+            } else {
+                throw error;
+            }
+        }
+    }
+}
+
+app.get('/api/data', (req, res) => {
+    if (!processedStaffCache) {
+        return res.status(503).json({ message: 'Data is being fetched.' });
+    }
+    res.json(processedStaffCache);
+});
+
+app.get('/api/raw-data', (req, res) => {
+    if (!rawSheetCache) {
+        return res.status(503).json({ message: 'Data is being fetched.' });
+    }
+    res.json(rawSheetCache);
+});
+
+app.get('/api/ask-luis', async (req, res) => {
+    const { question } = req.query;
+    if (!question || !processedStaffCache) {
+        return res.status(400).send('Bad request.');
+    }
+    res.setHeader('Content-Type', 'text/event-stream');
+    res.setHeader('Cache-Control', 'no-cache');
+    res.setHeader('Connection', 'keep-alive');
+    res.flushHeaders();
+    const prompt = `
+      You are "Luis", an AI data analyst for the Hillside Medical Group staff directory.
+      Your primary function is to answer questions about staff based ONLY on the JSON data provided.
+      **Core Instructions:**
+      1.  **Data Schema:** Each object in the JSON array represents ONE person. Their role is in the 'role' key.
+      2.  **Name Keys:** Use the correct key for the person's name based on their role: 'Provider' for Providers, 'Team Leads/Manager' for Managers, 'MA' for Medical Assistants, 'VA' for Virtual Assistants, and 'OtherStaffName' for Other Staff.
+      3.  **Structured Output:** For lists of people, ALWAYS use a Markdown table.
+      4.  **Ambiguity:** If a question is unclear, ask for the specific clinic location.
+      **Directory Data:**
+      ${JSON.stringify(processedStaffCache)}
+      **User's Question:**
+      "${question}"
+    `;
+    try {
+        const result = await generateWithRetry(model, prompt);
+        for await (const chunk of result.stream) {
+            if (chunk.text()) {
+                res.write(`data: ${JSON.stringify({ chunk: chunk.text() })}\n\n`);
+            }
+        }
+    } catch (error) {
+        const errorMessage = error.status === 503 ? "The service is busy. Please try again." : "I'm having trouble connecting.";
+        res.write(`data: ${JSON.stringify({ error: errorMessage })}\n\n`);
+    } finally {
+        res.write('data: [DONE]\n\n');
+        res.end();
+    }
+});
+
+app.listen(PORT, () => {
+    console.log(`Backend server is running on port ${PORT}`);
+    updateSheetCache();
+    setInterval(updateSheetCache, CACHE_DURATION_MS);
+});