ADDED:Calander Intregrated

Author: RaheesAhmed

.gitignore

@@ -3,4 +3,9 @@
 local.js
 app.js
 send_email.js
-assistant.json
+assistant.json
+auth.jsons
+calendar_auth.json
+auth.json
+clinetAuth.json
+googleAuth.json

README.MD

@@ -80,3 +80,5 @@ Example error response:
 }
 
 ```
+
+Google Calander:https://console.cloud.google.com/

calander.js

@@ -0,0 +1,110 @@
+import { google } from "googleapis";
+import fs from "fs";
+import path from "path";
+
+//const KEYFILEPATH = "auth.json";
+const CALENDAR_ID = "primary";
+
+const serviceAccountCredentials = JSON.parse(
+  fs.readFileSync(path.join("auth.json"), "utf8")
+);
+
+// Google Calendar API client setup
+const auth = new google.auth.JWT(
+  serviceAccountCredentials.client_email,
+  null,
+  serviceAccountCredentials.private_key,
+  [
+    "https://www.googleapis.com/auth/calendar",
+    "https://www.googleapis.com/auth/calendar.events",
+    "https://www.googleapis.com/auth/admin.directory.resource.calendar",
+    "https://www.googleapis.com/auth/cloud-platform",
+  ],
+  "gil@smartrise.org",
+  "111370419970452146902"
+);
+const calendar = google.calendar({ version: "v3", auth });
+console.log("Auth setup complete, proceeding with API calls...");
+// Function to check calendar availability
+export async function checkDateTimeAvailability(dateTimeToCheck) {
+  const startDateTime = new Date(dateTimeToCheck);
+  const endDateTime = new Date(startDateTime.getTime() + 60 * 60000); // Check 1 hour range
+
+  const res = await calendar.freebusy.query({
+    requestBody: {
+      timeMin: startDateTime.toISOString(),
+      timeMax: endDateTime.toISOString(),
+      items: [{ id: CALENDAR_ID }],
+    },
+  });
+
+  const isAvailable = res.data.calendars[CALENDAR_ID].busy.length === 0;
+  console.log(
+    `Checking availability for: ${startDateTime.toISOString()} to ${endDateTime.toISOString()}`
+  );
+  console.log(`Availability: ${isAvailable ? "Available" : "Not available"}`);
+  return isAvailable;
+}
+
+// // Function to create a calendar event
+async function createAppointment(dateTimeToCheck, summary, description, email) {
+  if (await checkDateTimeAvailability(dateTimeToCheck)) {
+    const event = {
+      summary,
+      description,
+      start: {
+        dateTime: dateTimeToCheck,
+        timeZone: "America/New_York",
+      },
+      end: {
+        dateTime: new Date(
+          new Date(dateTimeToCheck).getTime() + 3600000
+        ).toISOString(), // Adds one hour to the start time
+        timeZone: "America/New_York",
+      },
+      attendees: [{ email: email }],
+    };
+
+    try {
+      const { data } = await calendar.events.insert({
+        calendarId: CALENDAR_ID,
+        resource: event,
+      });
+
+      return data.htmlLink; // Return the link to the created calendar event
+    } catch (error) {
+      console.error("Error booking appointment:", error);
+      throw error;
+    }
+  } else {
+    console.log(
+      "Time slot not available, looking for the next available slot..."
+    );
+    // Find the next available time slot, add an hour and try again:
+    const nextAttempt = new Date(new Date(dateTimeToCheck).getTime() + 3600000);
+    return createAppointment(
+      nextAttempt.toISOString(),
+      summary,
+      description,
+      email
+    );
+  }
+}
+
+// // Example usage of booking an appointment
+export async function setupMeeting(dateTime, summary, description, email) {
+  try {
+    const bookingLink = await createAppointment(
+      dateTime,
+      summary,
+      description,
+
+      email
+    );
+    console.log(
+      `Meeting successfully scheduled, you can join using this link: ${bookingLink}`
+    );
+  } catch (error) {
+    console.error("Failed to schedule the meeting:", error);
+  }
+}

checkDateTimeAvailability.json

@@ -0,0 +1,18 @@
+{
+  "type": "function",
+  "function":{
+    "name": "checkDateTimeAvailability",
+    "description": "Checks if the specified date and time are available in the calendar.",
+    "parameters": {
+      "type": "object",
+      "properties": {
+        "dateTimeToCheck": {
+          "type": "string",
+          "format": "date-time",
+          "description": "The date and time to check availability for, in ISO 8601 format."
+        }
+      },
+      "required": ["dateTimeToCheck"]
+    }
+  }
+}

createAppointment.json

@@ -0,0 +1,35 @@
+{
+  "type": "function",
+  "function":{
+    "name": "createAppointment",
+    "description": "Creates an appointment in the calendar if the time slot is available.",
+    "parameters": {
+      "type": "object",
+      "properties": {
+        "dateTimeToCheck": {
+          "type": "string",
+          "format": "date-time",
+          "description": "The starting date and time of the appointment in ISO 8601 format."
+        },
+        "summary": {
+          "type": "string",
+          "description": "A brief summary or title for the appointment."
+        },
+        "description": {
+          "type": "string",
+          "description": "A detailed description of the appointment."
+        },
+        "location": {
+          "type": "string",
+          "description": "The location of the appointment, can be a physical address or a virtual location."
+        },
+        "email": {
+          "type": "string",
+          "format": "email",
+          "description": "The email address of the attendee to be added to the appointment."
+        }
+      },
+      "required": ["dateTimeToCheck", "summary", "description", "location", "email"]
+    }
+  }
+}

index.js

@@ -5,6 +5,7 @@ import { promises as fsPromises } from "fs";
 import OpenAI from "openai";
 import dotenv from "dotenv";
 import { sendTestWebhook } from "./get_webhook.js";
+import { checkDateTimeAvailability } from "./calander.js";
 
 // Load environment variables from .env file
 dotenv.config();
@@ -13,7 +14,7 @@ dotenv.config();
 const openai = new OpenAI({ apiKey: process.env.OPENAI_API_KEY });
 
 const app = express();
-const port = 3000;
+const port = 5000;
 
 // Middleware to parse JSON bodies
 app.use(bodyParser.json());
@@ -80,6 +81,7 @@ function extractUserDetailsFromQuestion(question) {
 
   return userDetails;
 }
+
 // Async function to  get existing assistant
 async function getOrCreateAssistant() {
   const assistantFilePath = "./assistant.json";
@@ -149,8 +151,30 @@ async function chatWithAssistant(question, userDetails) {
       // Prepare the tool outputs
       const toolOutputs = [];
       for (const toolCall of toolCalls) {
+        if (toolCall.function.name === "checkDateTimeAvailability") {
+          const output = await checkDateTimeAvailability(userDetails);
+          toolOutputs.push({
+            tool_call_id: toolCall.id,
+            output: output,
+          });
+        }
+
+        if (toolCall.function.name === "createAppointment") {
+          const output = await createAppointment(
+            userDetails.date + " " + userDetails.time,
+            "Appointment",
+            "Meeting with the user",
+            userDetails.email
+          );
+          toolOutputs.push({
+            tool_call_id: toolCall.id,
+            output: output,
+          });
+        }
+
         if (toolCall.function.name === "sendTestWebhook") {
-          const output = await sendTestWebhook(userDetails);
+          const meetingLink = await createAppointment(userDetails);
+          const output = await sendTestWebhook(meetingLink);
           toolOutputs.push({
             tool_call_id: toolCall.id,
             output: output,