CrewAI

import os
from scalekit import ScalekitClient
from dotenv import find_dotenv, load_dotenv

load_dotenv(find_dotenv())

scalekit_client = ScalekitClient(
    env_url=os.environ["SCALEKIT_ENVIRONMENT_URL"],
    client_id=os.environ["SCALEKIT_CLIENT_ID"],
    client_secret=os.environ["SCALEKIT_CLIENT_SECRET"],
)
actions = scalekit_client.actions

1
# Connect the user's Gmail account, and wait until it's ACTIVE before calling tools
2
connection_name = "gmail"
3
identifier = "user_123"  # your app's unique user ID
4

5
response = actions.get_or_create_connected_account(
6
    connection_name=connection_name, identifier=identifier
7
)
8
if response.connected_account.status != "ACTIVE":
9
    link = actions.get_authorization_link(
10
        connection_name=connection_name, identifier=identifier
11
    )
12
    print("Authorize Gmail:", link.link)
13
    input("Press Enter after authorizing...")
14
    # Fetch the account again to pick up the new status
15
    response = actions.get_or_create_connected_account(
16
        connection_name=connection_name, identifier=identifier
17
    )
18

19
if response.connected_account.status != "ACTIVE":
20
    raise RuntimeError(
21
        f"Gmail is {response.connected_account.status}, not ACTIVE. Authorize it and run again."
22
    )

1
from crewai import Agent, Crew, LLM, Task
2
from crewai_tools import MCPServerAdapter
3
from datetime import timedelta
4

5
# Retrieve config_id by listing Virtual MCP servers filtered by name
6
list_response = actions.mcp.list_configs(filter_name="gmail-user-tools")
7
mcp_server_url = list_response.configs[0].mcp_server_url
8
mcp_id = list_response.configs[0].id
9

10
token_response = actions.mcp.create_session_token(
11
    mcp_config_id=mcp_id,
12
    identifier="user_123",
13
    expiry=timedelta(hours=1),
14
)
15

16
with MCPServerAdapter({
17
    "url": mcp_server_url,
18
    "headers": {"Authorization": f"Bearer {token_response.token}"},
19
    "transport": "streamable-http",
20
}) as tools:
21
    agent = Agent(
22
        role="Email Assistant",
23
        goal="Fetch and summarize the user's unread emails",
24
        backstory="You are a helpful assistant with access to the user's Gmail inbox.",
25
        tools=tools,
26
        llm=LLM(
27
            model=os.getenv("LLM_MODEL", "gpt-4o"),
28
            base_url=os.getenv("OPENAI_BASE_URL"),
29
            api_key=os.getenv("OPENAI_API_KEY"),
30
        ),
31
        verbose=True,
32
    )
33

34
    task = Task(
35
        description="Fetch the last 5 unread emails and provide a brief summary of each.",
36
        expected_output="A list of 5 unread emails with subject, sender, and a one-sentence summary.",
37
        agent=agent,
38
    )
39

40
    result = Crew(agents=[agent], tasks=[task]).kickoff()
41
    print(result)