Bee Chat & Messaging Architecture

Messaging Core:
  Backend:
    - WebSocket for real-time
    - Redis for message queue
    - PostgreSQL for history.

  Features:
    - 1:1 chat with Bee
    - Group conversations (Swarm Chat)
    - Message threading and reactions
    - Email notifications
    - In-app alerts
    - File attachments.

Enterprise Features:
  Third-Party Integration:
    - Slack connector
    - Microsoft Teams
    - Discord
    - Custom webhooks.

  Advanced Waggles:
    - Data-type specific alerts
    - Custom waggle creation
    - ML-powered routing
    - Cross-platform sync.

System Waggles:
  - report_complete: "Your report is ready!"
  - data_anomaly: "Unusual pattern detected"
  - security_alert: "Suspicious access attempt"
  - performance_warning: "Processing slowdown"

Data Waggles:
  - threshold_breach: "Sales exceeded target"
  - pattern_match: "Similar to previous issue"
  - compliance_violation: "PII detected in logs"
  - insight_discovery: "New trend identified"

Collaboration Waggles:
  - mention_alert: "@user mentioned you"
  - task_assigned: "New task from @manager"
  - approval_needed: "Report awaits approval"
  - team_update: "Project milestone reached"

class WaggleConfig:
    """Configuration for custom Waggles"""
    
    def __init__(self, name: str, waggle_type: str):
        self.name = name
        self.type = waggle_type
        self.conditions = []
        self.actions = []
        self.recipients = []
    
    def when(self, condition: Dict[str, Any]):
        """Define trigger conditions"""
        self.conditions.append(condition)
        return self
    
    def notify(self, recipients: List[str]):
        """Define who gets notified"""
        self.recipients.extend(recipients)
        return self
    
    def via(self, channels: List[str]):
        """Define notification channels"""
        self.channels = channels
        return self

# Example: Custom Sales Waggle
sales_waggle = WaggleConfig("high_value_sale", "data_waggle")
    .when({"field": "sale_amount", "operator": ">", "value": 10000})
    .notify(["sales_manager", "ceo"])
    .via(["email", "slack", "in_app"])

Local Waggles:
  Purpose: "Process data without cloud dependency"
  
  Installation:
    - Download waggle package
    - Configure data connections
    - Set notification preferences
    - Deploy to local Worker Bee.
  
  Benefits:
    - No data leaves premises
    - Customizable logic
    - Fast processing
    - Compliance friendly.

Security Layers:
  Authentication:
    Primary: WebAuthn/Passkeys (strongly recommended)
    Fallback: TOTP + Password
    Session: Secure, httpOnly cookies
  
  Authorization:
    - Message-level permissions
    - Channel-based access
    - Time-limited shares
    - Audit trail.
  
  Encryption:
    - E2E for sensitive chats
    - TLS for transport
    - At-rest encryption
    - Key rotation.

Trust Levels:
  Fully Trusted (WebAuthn):
    - Full access to all features
    - Can view sensitive data
    - Extended session timeout
    - Offline access.
  
  Partially Trusted (TOTP):
    - Limited sensitive data access
    - Shorter session timeout
    - No offline access
    - Additional verification for critical ops.
  
  Untrusted (Password only):
    - Basic access only
    - Frequent re-authentication
    - No sensitive operations
    - Limited API access.

class SlackConnector:
    """Slack integration for STING"""
    
    async def setup_workspace(self, workspace_id: str):
        """Initial workspace setup"""
        # OAuth flow
        # Channel mapping
        # User synchronization
        # Permission mapping
    
    async def forward_waggle(self, waggle: Waggle, channel: str):
        """Forward Waggle to Slack channel"""
        slack_message = self.transform_waggle(waggle)
        await self.slack_client.post_message(channel, slack_message)
    
    async def handle_slash_command(self, command: str, args: List[str]):
        """Handle Slack slash commands"""
        if command == "/sting-report":
            return await self.generate_report(args)
        elif command == "/sting-query":
            return await self.query_honey_jar(args)

Teams Connector:
  Features:
    - Adaptive cards for rich content
    - Bot framework integration
    - Channel synchronization
    - File sharing support.
  
  Commands:
    - "@sting help" - Get assistance
    - "@sting report [type]" - Generate report
    - "@sting status" - Check system status
    - "@sting query [data]" - Query Honey Jars

POST /api/v1/waggles
{
  "name": "inventory_low",
  "type": "data_waggle",
  "conditions": {
    "field": "inventory_count",
    "operator": "<",
    "value": 100
  },
  "actions": [
    {
      "type": "notify",
      "channels": ["email", "slack"],
      "recipients": ["inventory_manager"]
    },
    {
      "type": "create_task",
      "assignee": "purchasing_team",
      "title": "Reorder inventory"
    }
  ]
}

POST /api/v1/swarms/{swarm_id}/messages
{
  "content": "Check out this insight from the sales data",
  "attachments": [
    {
      "type": "honey_jar_query",
      "jar_id": "sales_2024",
      "query": "top_customers_by_revenue"
    }
  ],
  "mentions": ["@sales_team", "@ceo"]
}

POST /api/v1/integrations/slack
{
  "workspace_id": "T1234567",
  "channel_mappings": {
    "sales_waggles": "#sales-alerts",
    "security_waggles": "#security",
    "general": "#sting-notifications"
  },
  "waggle_forwarding": {
    "enabled": true,
    "filter": {
      "priority": ["high", "critical"],
      "types": ["security_alert", "compliance_violation"]
    }
  }
}

WebAuthn Enforcement:
  Recommended For:
    - Admin users
    - Users with Honey Jar access
    - Financial data handlers
    - Healthcare workers.
  
  Benefits:
    - Phishing resistant
    - No passwords to steal
    - Biometric convenience
    - Hardware security.