lex-microsoft_teams

Microsoft Teams integration for LegionIO. Connects to Microsoft Teams via Graph API and Bot Framework for chat, channel, and bot communication.

gem install lex-microsoft_teams

• acquire_token — OAuth2 client credentials token for Graph API
• acquire_bot_token — OAuth2 token for Bot Framework
• authorize_url — Build Authorization Code + PKCE authorize URL for delegated consent
• exchange_code — Exchange authorization code for delegated access/refresh tokens
• refresh_delegated_token — Refresh a delegated token using a refresh token
• request_device_code — Start Device Code flow (headless fallback)
• poll_device_code — Poll for Device Code completion (RFC 8628 compliant)

• list_joined_teams — List teams the user has joined
• get_team — Get team details
• list_team_members — List members of a team

• list_chats — List 1:1 and group chats
• get_chat — Get chat details
• create_chat — Create a new chat
• list_chat_members — List chat participants
• add_chat_member — Add a member to a chat

• list_chat_messages — List messages in a chat
• get_chat_message — Get a specific message
• send_chat_message — Send a message to a chat
• reply_to_chat_message — Reply to a message
• list_message_replies — List replies to a message

• list_channels — List channels in a team
• get_channel — Get channel details
• create_channel — Create a new channel
• update_channel — Update channel properties
• delete_channel — Delete a channel
• list_channel_members — List channel members

• list_channel_messages — List messages in a channel
• get_channel_message — Get a specific channel message
• send_channel_message — Send a message to a channel
• reply_to_channel_message — Reply to a channel message
• list_channel_message_replies — List replies to a channel message

• list_meetings — List online meetings for a user
• get_meeting — Get meeting details
• create_meeting — Create an online meeting
• update_meeting — Update meeting properties
• delete_meeting — Delete a meeting
• get_meeting_by_join_url — Find a meeting by its join URL
• list_attendance_reports — List attendance reports for a meeting
• get_attendance_report — Get a specific attendance report with attendee records

• list_transcripts — List available transcripts for a meeting
• get_transcript — Get transcript metadata
• get_transcript_content — Get transcript content (VTT default, DOCX optional via format: param)

• get_presence — Get the availability and activity status for a user

• list_subscriptions — List active subscriptions
• get_subscription — Get subscription details
• create_subscription — Create a change notification subscription
• renew_subscription — Extend subscription expiration
• delete_subscription — Delete a subscription
• subscribe_to_chat_messages — Subscribe to chat message events
• subscribe_to_channel_messages — Subscribe to channel message events

• extract_local_messages — Extract messages from the Teams 2.x LevelDB local storage without Graph API credentials
• local_cache_available? — Check whether the local Teams cache exists on disk
• local_cache_stats — Get message count and date range stats from the local cache without extracting

• ingest_cache — Ingest messages from the local Teams cache into lex-memory as episodic traces; returns { stored:, skipped:, latest_time: }

• build_card — Build an Adaptive Card payload
• text_block — Create a TextBlock element
• fact_set — Create a FactSet element
• action_open_url — Create an OpenUrl action
• action_submit — Create a Submit action
• message_attachment — Wrap a card as a message attachment

• send_activity — Send an activity to a conversation
• reply_to_activity — Reply to an existing activity
• send_text — Send a simple text message via bot
• send_card — Send an Adaptive Card via bot
• create_conversation — Create a new bot conversation
• get_conversation_members — List conversation members

• handle_message — LLM-powered response loop for direct 1:1 bot chats (polls Graph API, replies via Graph or Bot Framework)
• observe_message — Conversation observer that extracts tasks, context, and relationship data from subscribed human chats (disabled by default, compliance-gated)

Actors:

• DirectChatPoller — Polls bot DM chats every 5s, publishes to AMQP
• ObservedChatPoller — Polls subscribed conversations every 30s (disabled by default)
• MessageProcessor — AMQP subscription actor, routes messages by mode to handle_message or observe_message

Helpers:

• SessionManager — Multi-turn LLM session lifecycle with lex-memory persistence
• PromptResolver — Layered system prompt resolution (settings default -> mode -> per-conversation)
• HighWaterMark — Per-chat message deduplication via legion-cache
• TokenCache — In-memory OAuth token cache with pre-expiry refresh (app + delegated slots)
• SubscriptionRegistry — Conversation observation subscriptions (in-memory + lex-memory)
• BrowserAuth — Delegated OAuth orchestrator (PKCE, headless detection, browser launch)
• CallbackServer — Ephemeral TCP server for OAuth redirect callback

Opt-in browser-based OAuth for delegated Microsoft Graph permissions (e.g., meeting transcripts).

Authorization Code + PKCE (primary): Opens the user's browser for Entra ID login, captures the callback on an ephemeral local port, exchanges the code with PKCE verification.

Device Code (fallback): Automatically selected in headless/SSH environments (no DISPLAY/WAYLAND_DISPLAY). Displays a URL and code for the user to enter on any device.

# Via CLI
# legion auth teams --tenant-id TENANT --client-id CLIENT

# Via code
auth = Legion::Extensions::MicrosoftTeams::Helpers::BrowserAuth.new(
  tenant_id: 'your-tenant-id',
  client_id: 'your-client-id'
)
result = auth.authenticate  # returns token hash with access_token, refresh_token, expires_in

Tokens are stored in Vault (legionio/microsoft_teams/delegated_token) and silently refreshed before expiry.

The Client class includes all runner modules (Auth, Teams, Chats, Messages, Channels, ChannelMessages, Subscriptions, AdaptiveCards, Bot, Presence, Meetings, Transcripts, LocalCache, CacheIngest).

client = Legion::Extensions::MicrosoftTeams::Client.new(
  tenant_id:     'your-tenant-id',
  client_id:     'your-app-id',
  client_secret: 'your-client-secret'
)
client.authenticate!

# Graph API
client.list_chats
client.send_chat_message(chat_id: 'chat-id', content: 'Hello!')

# Bot Framework
client.send_text(
  service_url: 'https://smba.trafficmanager.net/teams/',
  conversation_id: 'conv-id',
  text: 'Hello from bot'
)

# Local cache (no credentials needed)
client.local_cache_available?
client.extract_local_messages(since: Time.now - 86_400)

• Ruby >= 3.4
• LegionIO framework
• Microsoft Entra ID application with appropriate Graph API permissions

MIT