Newsletter Summarizer

1
import os
2
from datetime import datetime, timedelta
3
4
from composio_crewai import App, ComposioToolSet
5
from crewai import Agent, Crew, Process, Task
6
from dotenv import load_dotenv
7
from langchain_openai import ChatOpenAI
8
9
# Load environment variables
10
load_dotenv()
11
12
# Initialize the language model
13
llm = ChatOpenAI(model="gpt-4o")
14
15
# Set up Composio tools
16
composio_toolset = ComposioToolSet()
17
18
# Get Gmail tools
19
gmail_tools = composio_toolset.get_tools(apps=[App.GMAIL])
20
21
# Get today's date and the date from 7 days ago
22
today = datetime.today().strftime("%Y/%m/%d")
23
week_ago = (datetime.today() - timedelta(days=7)).strftime("%Y/%m/%d")
24
25
# Define the Email Fetcher Agent
26
email_fetcher = Agent(
27
    role="Email Fetcher",
28
    goal="Fetch all newsletter emails",
29
    backstory="""You are an Email Fetcher specialized in finding newsletter emails.
30
    Your job is to identify and retrieve recent newsletter emails from the user's inbox.""",
31
    verbose=True,
32
    tools=gmail_tools,
33
    llm=llm
34
)
35
36
# Define the Email Summarizer Agent
37
summarizer = Agent(
38
    role="Newsletter Summarizer",
39
    goal="Create concise summaries of newsletter content",
40
    backstory="""You are a Newsletter Summarizer who excels at distilling information.
41
    You can read newsletter emails and create brief, informative summaries of their main points.""",
42
    verbose=True,
43
    llm=llm
44
)
45
46
# Define the Email Sender Agent
47
email_sender = Agent(
48
    role="Email Sender",
49
    goal="Send email with newsletter summaries",
50
    backstory="""You are an Email Sender who specializes in composing and sending emails.
51
    You take summaries and convert them into well-formatted emails before sending them to recipients.""",
52
    verbose=True,
53
    tools=gmail_tools,
54
    llm=llm
55
)
56
57
# Define tasks for each agent
58
fetch_task = Task(
59
    description=f"""Search for newsletter emails in the inbox from {week_ago} to {today}.
60
    Return a list of emails with their subjects, senders, and content.""",
61
    expected_output="A list of newsletter emails with their content",
62
    agent=email_fetcher
63
)
64
65
summarize_task = Task(
66
    description="""Create a concise summary of each newsletter email.
67
    Identify the key points, announcements, and insights from each newsletter.
68
    Format your summaries neatly with bullet points.""",
69
    expected_output="Summarized content from all newsletters",
70
    agent=summarizer,
71
    context=[fetch_task]
72
)
73
74
send_task = Task(
75
    description="""Compose an email with the newsletter summaries.
76
    Send it to youremail@example.com with the subject 'Weekly Newsletter Digest'.
77
    Format the email in a reader-friendly way with headings for each newsletter.""",
78
    expected_output="Confirmation that the email was sent",
79
    agent=email_sender,
80
    context=[summarize_task]
81
)
82
83
# Create and run the crew
84
crew = Crew(
85
    agents=[email_fetcher, summarizer, email_sender],
86
    tasks=[fetch_task, summarize_task, send_task],
87
    verbose=2,
88
    process=Process.sequential
89
)
90
91
# Execute the workflow
92
result = crew.kickoff()
93
print(f"Result: {result}")