utils.py

from datetime import timedelta
from datetime import datetime
import os.path
import logging  
from google.auth.transport.requests import Request
from google.oauth2.credentials import Credentials
from google_auth_oauthlib.flow import InstalledAppFlow
from googleapiclient.discovery import build
from googleapiclient.errors import HttpError
import smtplib
from email.mime.multipart import MIMEMultipart
from email.mime.text import MIMEText
import pandas as pd
from langchain.prompts import PromptTemplate
from langchain.chains import LLMChain
from langchain_groq import ChatGroq
from langchain.agents import tool
from dotenv import load_dotenv
from schema import bookSlot,deleteSlot,reschedule_event,listevent,checkevent
load_dotenv()
API_KEY= os.environ["API_KEY"]
# Configure logging
logging.basicConfig(level=logging.DEBUG, format='%(asctime)s - %(levelname)s - %(message)s')

llm = ChatGroq(
    model="llama3-8b-8192",
    temperature=0,
    max_tokens=None,
    timeout=None,
    max_retries=2,
    api_key=API_KEY
)
SCOPES = ["https://www.googleapis.com/auth/calendar"]

EMAIL_SENDER = "[email protected]"  
EMAIL_PASSWORD = "wlxf poqr wgsh qvqs" 

def get_service():
    """Create and return the Google Calendar API service."""
    print('this function is called.')
    logging.debug("Initializing Google Calendar API service")
    creds = None
    if os.path.exists("token.json"):
        creds = Credentials.from_authorized_user_file("token.json", SCOPES)
    if not creds or not creds.valid:
        if creds and creds.expired and creds.refresh_token:
            creds.refresh(Request())
        else:
            flow = InstalledAppFlow.from_client_secrets_file("credentials.json", SCOPES)
            creds = flow.run_local_server(port=0)
        with open("token.json", "w") as token:
            token.write(creds.to_json())

    return build("calendar", "v3", credentials=creds)

def send_email(to_email, subject, body):
    """Send an email notification to the participants."""
    try:
        msg = MIMEMultipart()
        msg['From'] = EMAIL_SENDER
        msg['To'] = to_email
        msg['Subject'] = subject
        msg.attach(MIMEText(body, 'plain'))

        server = smtplib.SMTP('smtp.gmail.com', 587)
        server.starttls()
        server.login(EMAIL_SENDER, EMAIL_PASSWORD) 
        text = msg.as_string()
        server.sendmail(EMAIL_SENDER, to_email, text)
        server.quit()

        print(f"Email sent to {to_email}")
    except Exception as e:
        print(f"Failed to send email: {e}")


# def is_valid_booking_time(start_time):
#     # Convert string to datetime object
#     start_time_dt = datetime.strptime(start_time, "%Y-%m-%dT%H:%M:%S%z")
    
#     # Ensure the booking is within the next 7 days
#     today = datetime.now(start_time_dt.tzinfo)
#     if start_time_dt < today or start_time_dt > (today + timedelta(days=7)):
#         return False, "You can only book appointments within the next 7 days."
    
#     # Ensure the booking is on a weekday and within 10 AM to 7 PM
#     if start_time_dt.weekday() >= 5:  # 0 = Monday, 6 = Sunday
#         return False, "Appointments can only be booked Monday to Friday."
    
#     if not (10 <= start_time_dt.hour < 19):  # Ensure the time is between 10 AM to 7 PM
#         return False, "Appointments can only be scheduled between 10 AM and 7 PM."

#     return True, None

def is_valid_booking_time(start_time):
    # Convert string to datetime object
    logging.debug(start_time)
    start_time_dt = datetime.strptime(start_time, "%Y-%m-%dT%H:%M:%S%z")
    logging.debug(start_time_dt)
    # Get today's date at midnight for date comparison
    today = datetime.now(start_time_dt.tzinfo).replace(
        hour=0, minute=0, second=0, microsecond=0
    )
    
    # Get the end of the 7th day
    seven_days_later = (today + timedelta(days=7)).replace(
        hour=23, minute=59, second=59
    )
    
    # Check if the date falls within the 7-day window
    if start_time_dt.date() < today.date() or start_time_dt.date() > seven_days_later.date():
        return False, "You can only book appointments within the next 7 days."
    
    # Ensure the booking is on a weekday and within 10 AM to 7 PM
    if start_time_dt.weekday() >= 5:  # 0 = Monday, 6 = Sunday
        return False, "Appointments can only be booked Monday to Friday."
    
    if not (10 <= start_time_dt.hour < 19):  # Ensure the time is between 10 AM to 7 PM
        return False, "Appointments can only be scheduled between 10 AM and 7 PM."

    return True, None
import pytz
from datetime import datetime, timedelta
@tool("check-event", args_schema=checkevent, return_direct=True)
def check_slots(date):
    """
    This function is to check available slot for a given date, excluding times when events are booked.
    It only returns valid slots that fall on weekdays (Mon-Fri) between 10 AM to 7 PM.

    Args:
        date (str): The date for which to check availability. Can be 'today', 'tomorrow', or a date string.

    Returns:
        str: Formatted string of available 1-hour slots or a message if no slots are available.
    """
    logging.debug("Entered into check-slots tool")
    
    # Handle relative dates with proper timezone
    ist_tz = pytz.timezone('Asia/Kolkata')
    today = datetime.now(ist_tz)
    
    if date.lower() == 'today':
        date = today.strftime('%Y-%m-%d')
    elif date.lower() == 'tomorrow':
        tomorrow = today + timedelta(days=1)
        date = tomorrow.strftime('%Y-%m-%d')
    else:
        try:
            # Try to parse the provided date string
            parsed_date = datetime.strptime(date, '%Y-%m-%d')
            date = parsed_date.strftime('%Y-%m-%d')
        except ValueError:
            return "❌ Invalid date format. Please use 'today', 'tomorrow', or format 'YYYY-MM-DD'"

    # Define the start and end time for the day
    start_time = f"{date}T10:00:00+05:30"  # Start at 10 AM
    end_time = f"{date}T19:00:00+05:30"    # End at 7 PM
    service = get_service()
    
    # Check if the date is valid (weekday, and within 10 AM to 7 PM)
    valid, message = is_valid_booking_time(start_time)
    if not valid:
        formatted_output = "❌ **Invalid Date Selection**\n\n"
        formatted_output += f"{message}\n"
        formatted_output += "\nAppointments can only be scheduled:\n"
        formatted_output += "📅 Monday to Friday\n"
        formatted_output += "🕒 Between 10 AM and 7 PM\n"
        formatted_output += "📆 Within the next 7 days"
        return formatted_output

    # For today's date, filter out past hours
    current_time = None
    if date == today.strftime('%Y-%m-%d'):
        current_time = today
        if current_time.hour >= 19:  # If it's past 7 PM
            return "❌ No more slots available for today. Please check tomorrow's availability."

    # Query for events between start and end time
    events_result = service.events().list(
        calendarId='primary',
        timeMin=start_time,
        timeMax=end_time,
        singleEvents=True,
        orderBy='startTime'
    ).execute()

    events = events_result.get('items', [])

    # Define the working hours with timezone
    work_start = datetime.fromisoformat(f"{date}T10:00:00+05:30").replace(tzinfo=ist_tz)
    if current_time and current_time.hour >= 10:
        # If it's today and after 10 AM, start from the next hour
        work_start = current_time.replace(minute=0, second=0, microsecond=0) + timedelta(hours=1)
    work_end = datetime.fromisoformat(f"{date}T19:00:00+05:30").replace(tzinfo=ist_tz)
    
    available_slots = []
    current_slot = work_start

    # Add all available slots
    while current_slot + timedelta(hours=1) <= work_end:
        slot_end = current_slot + timedelta(hours=1)
        is_available = True

        # Check if slot conflicts with any existing event
        for event in events:
            event_start = datetime.fromisoformat(event['start']['dateTime'])
            event_end = datetime.fromisoformat(event['end']['dateTime'])
            
            if (current_slot < event_end and slot_end > event_start):
                is_available = False
                break

        if is_available:
            available_slots.append((current_slot, slot_end))
        current_slot += timedelta(hours=1)

    # Return available slots in a properly formatted string
    if available_slots:
        formatted_output = f"📅 **Available Slots for {date}:**\n\n"
        for slot in available_slots:
            start_time = slot[0].strftime('%I:%M %p')
            end_time = slot[1].strftime('%I:%M %p')
            formatted_output += f"🕒 {start_time} - {end_time}\n"
        
        formatted_output += "\n✨ Each slot is for a 1-hour appointment."
        formatted_output += "\n\n💡 To book an appointment, please specify your preferred time slot."
        
        return formatted_output
    else:
        return "😔 I'm sorry, but there are no available slots for the requested date. Would you like to check another date?"# def check_slots(date):
#     """
#     This function is to check available slot for a given date, excluding times when events are booked.
#     It only returns valid slots that fall on weekdays (Mon-Fri) between 10 AM to 7 PM.

#     Args:
#         date (str): The date for which to check availability (e.g., '2024-09-17').

#     Returns:
#         str: Formatted string of available 1-hour slots or a message if no slots are available.
#     """
#     logging.debug("Entered into check-slots tool")
#     # Define the start and end time for the day
#     start_time = f"{date}T10:00:00+05:30"  # Start at 10 AM
#     end_time = f"{date}T19:00:00+05:30"    # End at 7 PM
#     service = get_service()
    
#     # Check if the date is valid (weekday, and within 10 AM to 7 PM)
#     valid, message = is_valid_booking_time(start_time)
#     if not valid:
#         return message

#     # Query for events between start and end time
#     events_result = service.events().list(
#         calendarId='primary',
#         timeMin=start_time,
#         timeMax=end_time,
#         singleEvents=True,
#         orderBy='startTime'
#     ).execute()

#     events = events_result.get('items', [])

#     # Define the working hours (10 AM to 7 PM)
#     work_start = datetime.fromisoformat(f"{date}T10:00:00+05:30")
#     work_end = datetime.fromisoformat(f"{date}T19:00:00+05:30")
#     available_slots = []

#     # Add all the slots starting from work_start until work_end
#     current_time = work_start

#     for event in events:
#         event_start = datetime.fromisoformat(event['start']['dateTime'])
#         event_end = datetime.fromisoformat(event['end']['dateTime'])

#         # Find all available 1-hour slots between current_time and the event start
#         while current_time + timedelta(hours=1) <= event_start:
#             slot_start = current_time
#             slot_end = current_time + timedelta(hours=1)
            
#             # Ensure the slot is a valid booking time
#             valid, message = is_valid_booking_time(slot_start.isoformat())
#             if valid:
#                 available_slots.append((slot_start, slot_end))
#             current_time += timedelta(hours=1)

#         # Move current_time to the end of the event
#         current_time = max(current_time, event_end)

#     # Add slots from the last event to the end of the working day
#     while current_time + timedelta(hours=1) <= work_end:
#         slot_start = current_time
#         slot_end = current_time + timedelta(hours=1)
        
#         # Ensure the slot is a valid booking time
#         valid, message = is_valid_booking_time(slot_start.isoformat())
#         if valid:
#             available_slots.append((slot_start, slot_end))
#         current_time += timedelta(hours=1)

#     # Return available slots in a properly formatted string
#     if available_slots:
#         formatted_output = f"📅 **Available Slots for {date}:\n**\n\n"
#         for slot in available_slots:
#             start_time = slot[0].strftime('%I:%M %p')
#             end_time = slot[1].strftime('%I:%M %p')
#             formatted_output += f"\n🕒 {start_time} - {end_time}\n"
        
#         formatted_output += "\n✨ Each slot is for a 1-hour appointment."
#         formatted_output += "\n\n💡 To book an appointment, please specify your preferred time slot."
        
#         return formatted_output
#     else:
#         return "😔 I'm sorry, but there are no available slots for the requested date. Would you like to check another date?"
    

def check_slot_availability(start_time, end_time):
    # Define the Asia/Kolkata timezone
    kolkata_tz = pytz.timezone('Asia/Kolkata')
    
    # Parse and localize the start_time and end_time into Asia/Kolkata timezone
    start_time_dt = datetime.strptime(start_time, "%Y-%m-%dT%H:%M:%S%z")
    end_time_dt = datetime.strptime(end_time, "%Y-%m-%dT%H:%M:%S%z")
    
    # Ensure the times are correctly converted to ISO format without adding "Z"
    time_min = start_time_dt.isoformat()  # Already includes the timezone info
    time_max = end_time_dt.isoformat()  # Already includes the timezone info
    service=get_service()
    # Fetch events within the given time range in Asia/Kolkata timezone
    events_result = service.events().list(
        calendarId="primary",
        timeMin=time_min,
        timeMax=time_max,
        singleEvents=True,
        orderBy="startTime"
    ).execute()
    
    events = events_result.get("items", [])
    return len(events) == 0  # Returns True if the slot is free

def find_event_by_time(start_time):
    """
    Finds an event by its start time in the user's Google Calendar.
    
    Args:
        start_time (str): The start time of the event in ISO format (e.g., '2024-09-17T14:30:00+05:30').

    Returns:
        dict or None: The event details if found, otherwise None.
    """
    try:
        print(f"Searching for event starting at {start_time}")
        service=get_service()
        # Calculate the end time (assuming 1-hour event window)
        start_time_dt = datetime.fromisoformat(start_time)
        end_time_dt = start_time_dt + timedelta(hours=1)
        end_time = end_time_dt.isoformat()
        
        # Query Google Calendar API for events in this time window
        events_result = service.events().list(
            calendarId="primary",
            timeMin=start_time,
            timeMax=end_time,
            singleEvents=True,
            orderBy="startTime",
        ).execute()

        events = events_result.get("items", [])
        print(f"Events found: {events}")

        # Return the first event that matches the time exactly
        for event in events:
            event_start = event['start'].get('dateTime')
            if event_start == start_time:
                print(f"Matching event found: {event['summary']} at {event_start}")
                return event
        
        print(f"No event found starting at {start_time}")
        return None

    except HttpError as error:
        print(f"An error occurred: {error}")
        return None
    except Exception as e:
        print(f"Unexpected error: {e}")
        return None

    


@tool("list_event", args_schema=listevent, return_direct=True)
def list_upcoming_events(target_date):
    """
    Lists the upcoming events on the user's calendar for a specific date.

    Args:
    target_date (str): The date to filter events on, in 'YYYY-MM-DD' format.

    Returns:
    string: Summary of the events
    """
    service=get_service()
    logging.debug("Entered into list events tools")
    # Parse the target date to create timeMin and timeMax bounds
     # Convert the target date string to a datetime object
    target_date_obj = datetime.strptime(target_date, "%Y-%m-%d")

    # Set timeMin to the beginning of the day and timeMax to the end of the day
    time_min = target_date_obj.isoformat() + "Z"  # Beginning of the day in UTC
    time_max = (target_date_obj + timedelta(days=1)).isoformat() + "Z"  # End of the day in UTC

    print(f"Getting events for {target_date}")

    try:
        events_result = (
            service.events()
            .list(
                calendarId="primary",
                timeMin=time_min,
                timeMax=time_max,
                singleEvents=True,
                orderBy="startTime",
            )
            .execute()
        )
        events = events_result.get("items", [])
        
        if not events:
            print(f"No events found for {target_date}.")
        else:
            for event in events:
                start = event["start"].get("dateTime", event["start"].get("date"))
                result=start, event["summary"]
                return result
    except HttpError as error:
        print(f"An error occurred: {error}")

@tool("book-slot-tool", args_schema=bookSlot, return_direct=True)
def book_slot(start_time, end_time, summary):
    """
    This functions is to boos a appointment/slot for user by creating an event on the calendar.
    
    Args:
        start_time (str): The start time of the slot (e.g., '2024-09-16T14:00:00+05:30').
        end_time (str): The end time of the slot (e.g., '2024-09-16T15:00:00+05:30').
        summary (str): Summary or title of the event.
    
    Returns:
        str: Confirmation message if the event is created or an error message if booking fails.
    """
    service = get_service()
    logging.debug("Entered into book slot tools")
    is_valid, error_message = is_valid_booking_time(start_time)
    
    if not is_valid:
        # Return the error message with proper formatting
        formatted_output = "❌ **Invalid Booking Time**\n\n"
        formatted_output += f"{error_message}\n"
        formatted_output += "\nAppointments can only be scheduled:\n"
        formatted_output += "📅 Monday to Friday\n"
        formatted_output += "🕒 Between 10 AM and 7 PM\n"
        formatted_output += "📆 Within the next 7 days\n"
        return formatted_output
    if not check_slot_availability(start_time, end_time):
        formatted_output = "❌ **Slot Unavailable**\n\n"
        formatted_output += "\nThe requested slot is not available.\n"
        formatted_output += "\nPlease choose another time."
        return formatted_output

    # Create the event object
    event = {
        'summary': summary,
        'start': {
            'dateTime': start_time,  # ISO 8601 format
            'timeZone': 'Asia/Kolkata',  # Use appropriate timezone
        },
        'end': {
            'dateTime': end_time,
            'timeZone': 'Asia/Kolkata',
        },
    }

    try:
        # Insert the event into the primary calendar
        event_result = service.events().insert(calendarId='primary', body=event).execute()
        formatted_output = "✅ **Event Created Successfully!**\n\n"
        formatted_output += f"\n📌 **Summary:** {summary}\n"
        formatted_output += f"\n🕒 **Start Time:** {start_time}\n"
        formatted_output += f"\n🕒 **End Time:** {end_time}\n\n"
        formatted_output += "\n📅 The event has been added to your primary calendar."
        return formatted_output
    except HttpError as error:
        return f"❌ **An error occurred:** {error}\n\nPlease try again or contact support if the issue persists."

@tool("delete-slot-tool", args_schema=deleteSlot, return_direct=True)
def delete_event(start_time):
    """
    Deletes an event by start time on the user's calendar.
    
    Args:
        start_time (str): The start time of the event (e.g., '2024-09-20T15:30:00+05:30').
    
    Returns:
        str: Confirmation message if the event is deleted.
    """
    service = get_service()
    logging.debug("Entered into delete events tools")
    event = find_event_by_time(start_time)
    
    if event:
        try:
            service.events().delete(calendarId='primary', eventId=event['id']).execute()
            formatted_output = "\n🗑️ **Event Deleted Successfully!**\n\n"
            formatted_output += f"\n📌 **Summary:** {event['summary']}\n"
            formatted_output += f"\n🕒 **Start Time:** {event['start']['dateTime']}\n\n"
            formatted_output += "\nThe event has been removed from your primary calendar."
            return formatted_output
        except HttpError as error:
            return f"❌ **An error occurred:** {error}\n\nPlease try again or contact support if the issue persists."
    else:
        formatted_output = "❓ **No Event Found**\n\n"
        formatted_output += f"🕒 **\nRequested Start Time:** {start_time}\n\n"
        formatted_output += "\nNo event was found for the specified time. Please check the time and try again."
        return formatted_output


@tool("reschedule-event-tool", args_schema=reschedule_event, return_direct=True)
def reschedule_event(start_time, new_start_time, new_end_time):
    """
    Reschedules an existing event by providing new start and end times.
    
    Args:
        start_time (str): The start time of the existing event (e.g., '2024-09-18T14:00:00+05:30').
        new_start_time (str): The new start time of the event (e.g., '2024-09-18T12:00:00+05:30').
        new_end_time (str): The new end time of the event (e.g., '2024-09-18T14:00:00+05:30').
    
    Returns:
        str: Confirmation message if the event is rescheduled or an error message if rescheduling fails.
    """
    service = get_service()
    logging.debug("Entered into reshedule events tools")
    if not is_valid_booking_time(start_time):
        formatted_output = "❌ **Invalid Booking Time**\n\n"
        formatted_output += "\nAppointments can only be scheduled:\n"
        formatted_output += "\n📅 Monday to Friday\n"
        formatted_output += "\n🕒 Between 10 AM and 7 PM\n"
        formatted_output += "\n📆 Within the next 7 days\n"
        return formatted_output

    if not check_slot_availability(new_start_time, new_end_time):
        formatted_output = "❌ **Slot Unavailable**\n\n"
        formatted_output += "\nThe requested slot is not available.\n"
        formatted_output += "\nPlease choose another time."
        return formatted_output

    try:
        event = find_event_by_time(start_time)
        
        if not event:
            formatted_output = "❓ **No Event Found**\n\n"
            formatted_output += f"\n🕒 **Requested Start Time:** {start_time}\n\n"
            formatted_output += "\nNo event was found for the specified time. Please check the time and try again."
            return formatted_output
        
        event['start']['dateTime'] = new_start_time
        event['end']['dateTime'] = new_end_time
        
        updated_event = service.events().update(calendarId='primary', eventId=event['id'], body=event).execute()
        
        formatted_output = "✅ **Event Rescheduled Successfully!**\n\n"
        formatted_output += f"\n🔄 **Original Start Time:** {start_time}\n"
        formatted_output += f"\n🆕 **New Start Time:** {new_start_time}\n"
        formatted_output += f"\n🆕 **New End Time:** {new_end_time}\n\n"
        formatted_output += "\nYour appointment has been updated in the calendar."
        return formatted_output

    except HttpError as error:
        return f"❌ **An error occurred:** {error}\n\nPlease try again or contact support if the issue persists."