Outlook

import asyncio

from charter.auth import EnvTokenProvider
from charter.packs import outlook

credentials = EnvTokenProvider("MICROSOFT_ACCESS_TOKEN")
outlook.configure(credentials)


async def main():
    unread = await outlook.messages_list.ainvoke(folder_id="inbox", filter="isRead eq false")


asyncio.run(main())

from charter.auth import EnvTokenProvider
from charter.packs import outlook

credentials = EnvTokenProvider("MICROSOFT_ACCESS_TOKEN")
outlook.configure(credentials)

from charter.auth import OAuth2Client
from charter.packs import outlook

credentials = OAuth2Client(
    MICROSOFT,
    client_id=os.environ["MICROSOFT_CLIENT_ID"],
    client_secret=os.environ["MICROSOFT_CLIENT_SECRET"],
    refresh_token=os.environ["MICROSOFT_REFRESH_TOKEN"],
)
outlook.configure(credentials)

from functools import partial

from charter.auth import OAuth2Client, SubjectProvider, TokenGrant, use_subject
from charter.packs import outlook

# Yours to write: a user id in, that user's credential out.
async def for_user(user_id: str) -> OAuth2Client:
    async def stored_grant() -> TokenGrant:  # read again whenever the token is due
        row = await db.grants.get(user_id, "microsoft")
        return TokenGrant(
            access_token=row.access_token,
            refresh_token=row.refresh_token,
            expires_at=row.expires_at,
        )

    return OAuth2Client(
        MICROSOFT,
        client_id=os.environ["MICROSOFT_CLIENT_ID"],
        client_secret=os.environ["MICROSOFT_CLIENT_SECRET"],
        refresh_token=stored_grant,
        on_refresh=partial(save_to_db, user_id),
    )

credentials = SubjectProvider(for_user)
outlook.configure(credentials)

# Per request: whose grant the tools use.
with use_subject(request.user_id):
    ...  # your agent runs here