import {api, util} from "simplex-chat"
import {T, CEvt} from "@simplex-chat/types"
import {Config} from "./config.js"
import {GrokMessage, GrokApiClient} from "./grok.js"
import {CardManager, ConversationState} from "./cards.js"
import {
  queueMessage, grokInvitingMessage, grokActivatedMessage, teamAddedMessage,
  teamAlreadyInvitedMessage, teamLockedMessage, noTeamMembersMessage,
  grokUnavailableMessage, grokErrorMessage, grokNoHistoryMessage,
} from "./messages.js"
import {profileMutex, log, logError} from "./util.js"

// True for any non-terminal status — invited but not yet accepted, through
// connected. Used to decide whether a contact is already in the group so we
// don't trigger a re-invite (the SimpleX API resends the invitation for a
// member in GSMemInvited).
function isInGroup(m: T.GroupMember): boolean {
  switch (m.memberStatus) {
    case T.GroupMemberStatus.Rejected:
    case T.GroupMemberStatus.Removed:
    case T.GroupMemberStatus.Left:
    case T.GroupMemberStatus.Deleted:
    case T.GroupMemberStatus.Unknown:
      return false
    default:
      return true
  }
}

export class SupportBot {
  // Card manager
  cards: CardManager

  // Grok group mapping: memberId → mainGroupId (for pending joins)
  private pendingGrokJoins = new Map<string, number>()
  // Buffered invitations that arrived before pendingGrokJoins was set (race condition)
  private bufferedGrokInvitations = new Map<string, CEvt.ReceivedGroupInvitation>()
  // mainGroupId → grokLocalGroupId
  private grokGroupMap = new Map<number, number>()
  // grokLocalGroupId → mainGroupId
  private reverseGrokMap = new Map<number, number>()
  // mainGroupId → resolve fn for grok join
  private grokJoinResolvers = new Map<number, () => void>()
  // mainGroupIds where Grok connectedToGroupMember fired
  private grokFullyConnected = new Set<number>()
  // Suppress per-message Grok responses while activateGrok sends the initial combined response
  private grokInitialResponsePending = new Set<number>()

  // Pending DMs for team group members (contactId → message)
  private pendingTeamDMs = new Map<number, string>()
  // Contacts that already received the team DM (dedup)
  private sentTeamDMs = new Set<number>()

  // Tracked fire-and-forget operations (for testing)
  private _pendingOps: Promise<void>[] = []

  // Bot's business address link
  businessAddress: string | null = null

  private commandsSynced = false

  constructor(
    private chat: api.ChatApi,
    private grokApi: GrokApiClient | null,
    private config: Config,
    private mainUserId: number,
    private grokUserId: number | null,
    private desiredCommands: T.ChatBotCommand[],
  ) {
    this.cards = new CardManager(chat, config, mainUserId, config.cardFlushSeconds * 1000)
  }

  private get grokEnabled(): boolean {
    return this.grokApi !== null
  }

  // Wait for all fire-and-forget operations to settle (for testing)
  async flush(): Promise<void> {
    while (this._pendingOps.length > 0) {
      const ops = this._pendingOps.splice(0)
      await Promise.allSettled(ops)
    }
  }

  private fireAndForget(op: Promise<void>): void {
    const tracked = op.catch(err => logError("async operation error", err))
    this._pendingOps.push(tracked)
    tracked.finally(() => {
      const idx = this._pendingOps.indexOf(tracked)
      if (idx >= 0) this._pendingOps.splice(idx, 1)
    })
  }

  // --- Profile-switching helpers ---

  private async withMainProfile<R>(fn: () => Promise<R>): Promise<R> {
    return profileMutex.runExclusive(async () => {
      await this.chat.apiSetActiveUser(this.mainUserId)
      await this.syncCommands()
      return fn()
    })
  }

  // Push the bot's command list into the main profile if the DB's
  // preferences.commands doesn't already match. Passing the profile's own
  // current displayName back keeps core's updateUserProfile on the fast
  // path (src/Simplex/Chat/Store/Profiles.hs:311) — no rename.
  private async syncCommands(): Promise<void> {
    if (this.commandsSynced) return
    const user = await this.chat.apiGetActiveUser()
    if (!user) return
    const current = JSON.stringify(user.profile.preferences?.commands ?? [])
    const desired = JSON.stringify(this.desiredCommands)
    if (current === desired) {
      this.commandsSynced = true
      return
    }
    const profile = util.fromLocalProfile(user.profile)
    await this.chat.apiUpdateProfile(user.userId, {
      ...profile,
      preferences: {...(profile.preferences ?? {}), commands: this.desiredCommands},
    })
    log(`Bot commands updated (displayName preserved: "${profile.displayName}")`)
    this.commandsSynced = true
  }

  private async withGrokProfile<R>(fn: () => Promise<R>): Promise<R> {
    if (this.grokUserId === null) throw new Error("Grok is disabled (no GROK_API_KEY)")
    const grokUserId = this.grokUserId
    return profileMutex.runExclusive(async () => {
      await this.chat.apiSetActiveUser(grokUserId)
      return fn()
    })
  }

  // --- Main profile event handlers ---

  async onBusinessRequest(evt: CEvt.AcceptingBusinessRequest): Promise<void> {
    const groupId = evt.groupInfo.groupId
    try {
      const profile = evt.groupInfo.groupProfile
      await this.withMainProfile(() =>
        this.chat.apiUpdateGroupProfile(groupId, {
          displayName: profile.displayName,
          fullName: profile.fullName,
          groupPreferences: {
            ...profile.groupPreferences,
            files: {enable: T.GroupFeatureEnabled.On},
            history: {enable: T.GroupFeatureEnabled.On},
          },
        })
      )
      // file uploads + history enabled
    } catch (err) {
      logError(`Failed to update business group ${groupId} preferences`, err)
    }
  }

  async onNewChatItems(evt: CEvt.NewChatItems): Promise<void> {
    // Only process events for main profile
    if (evt.user.userId !== this.mainUserId) return
    for (const ci of evt.chatItems) {
      try {
        await this.processMainChatItem(ci)
      } catch (err) {
        logError("Error processing chat item", err)
      }
    }
  }

  async onChatItemUpdated(evt: CEvt.ChatItemUpdated): Promise<void> {
    if (evt.user.userId !== this.mainUserId) return
    const {chatInfo} = evt.chatItem
    if (chatInfo.type !== "group") return
    const groupInfo = chatInfo.groupInfo
    if (!groupInfo.businessChat) return
    this.cards.scheduleUpdate(groupInfo.groupId)
  }

  async onChatItemReaction(evt: CEvt.ChatItemReaction): Promise<void> {
    if (evt.user.userId !== this.mainUserId) return
    if (!evt.added) return
    const chatInfo = evt.reaction.chatInfo
    if (chatInfo.type !== "group") return
    const groupInfo = chatInfo.groupInfo
    if (!groupInfo.businessChat) return
    this.cards.scheduleUpdate(groupInfo.groupId)
  }

  async onLeftMember(evt: CEvt.LeftMember): Promise<void> {
    if (evt.user.userId !== this.mainUserId) return
    const groupId = evt.groupInfo.groupId
    const member = evt.member
    const bc = evt.groupInfo.businessChat
    if (!bc) return

    if (member.memberId === bc.customerId) {
      log(`Customer left group ${groupId}`)
      this.cleanupGrokMaps(groupId)
      try { await this.cards.clearCustomData(groupId) } catch {}
      return
    }

    if (this.config.grokContactId !== null && member.memberContactId === this.config.grokContactId) {
      log(`Grok left group ${groupId}`)
      this.cleanupGrokMaps(groupId)
      return
    }

    if (this.config.teamMembers.some(tm => tm.id === member.memberContactId)) {
      log(`Team member left group ${groupId}`)
    }
  }

  async onJoinedGroupMember(evt: CEvt.JoinedGroupMember): Promise<void> {
    if (evt.user.userId !== this.mainUserId) return
    if (evt.groupInfo.groupId === this.config.teamGroup.id) {
      await this.sendTeamMemberDM(evt.member)
    }
  }

  async onMemberConnected(evt: CEvt.ConnectedToGroupMember): Promise<void> {
    if (evt.user.userId !== this.mainUserId) return
    const groupId = evt.groupInfo.groupId

    // Team group → send DM (if not already sent by onJoinedGroupMember)
    if (groupId === this.config.teamGroup.id) {
      await this.sendTeamMemberDM(evt.member, evt.memberContact)
      return
    }

    // Customer group → promote to Owner (unless customer or Grok). Idempotent per plan §11.
    const bc = evt.groupInfo.businessChat
    if (bc) {
      const isCustomer = evt.member.memberId === bc.customerId
      const isGrok = this.config.grokContactId !== null
        && evt.member.memberContactId === this.config.grokContactId
      if (!isCustomer && !isGrok) {
        try {
          await this.withMainProfile(() =>
            this.chat.apiSetMembersRole(groupId, [evt.member.groupMemberId], T.GroupMemberRole.Owner)
          )
          log(`Promoted member ${evt.member.groupMemberId} to Owner in group ${groupId}`)
        } catch (err) {
          logError(`Failed to promote member in group ${groupId}`, err)
        }
      }
    }
  }

  async onMemberContactReceivedInv(evt: CEvt.NewMemberContactReceivedInv): Promise<void> {
    if (evt.user.userId !== this.mainUserId) return
    const {contact, groupInfo, member} = evt
    if (groupInfo.groupId === this.config.teamGroup.id) {
      if (this.sentTeamDMs.has(contact.contactId)) return
      log(`DM contact from team group member: ${contact.contactId}:${member.memberProfile.displayName}`)
      const name = member.memberProfile.displayName
      const formatted = name.includes(" ") ? `'${name}'` : name
      const msg = `Added you to be able to invite you to customer chats later, keep this contact. Your contact ID is ${contact.contactId}:${formatted}`
      // Try sending immediately — contact may already be usable
      try {
        await this.withMainProfile(() =>
          this.chat.apiSendTextMessage([T.ChatType.Direct, contact.contactId], msg)
        )
        this.sentTeamDMs.add(contact.contactId)
        log(`Sent DM to team member ${contact.contactId}:${name}`)
      } catch {
        // Not ready yet — queue for contactConnected / contactSndReady
        this.pendingTeamDMs.set(contact.contactId, msg)
        log(`Queued DM for team member ${contact.contactId}:${name}`)
      }
    }
  }

  async onContactConnected(evt: CEvt.ContactConnected): Promise<void> {
    if (evt.user.userId !== this.mainUserId) return
    await this.deliverPendingDM(evt.contact.contactId)
  }

  async onContactSndReady(evt: CEvt.ContactSndReady): Promise<void> {
    if (evt.user.userId !== this.mainUserId) return
    await this.deliverPendingDM(evt.contact.contactId)
  }

  private async deliverPendingDM(contactId: number): Promise<void> {
    if (this.sentTeamDMs.has(contactId)) {
      this.pendingTeamDMs.delete(contactId)
      return
    }
    const pendingMsg = this.pendingTeamDMs.get(contactId)
    if (pendingMsg === undefined) return
    this.pendingTeamDMs.delete(contactId)
    try {
      await this.withMainProfile(() =>
        this.chat.apiSendTextMessage([T.ChatType.Direct, contactId], pendingMsg)
      )
      this.sentTeamDMs.add(contactId)
      log(`Sent DM to team member ${contactId}`)
    } catch (err) {
      logError(`Failed to send DM to team member ${contactId}`, err)
    }
  }

  // --- Grok profile event handlers ---

  async onGrokGroupInvitation(evt: CEvt.ReceivedGroupInvitation): Promise<void> {
    if (evt.user.userId !== this.grokUserId) return
    const memberId = evt.groupInfo.membership.memberId
    const mainGroupId = this.pendingGrokJoins.get(memberId)
    if (mainGroupId === undefined) {
      // Buffer: invitation may arrive before pendingGrokJoins is set (race with apiAddMember)
      this.bufferedGrokInvitations.set(memberId, evt)
      return
    }
    this.pendingGrokJoins.delete(memberId)
    this.bufferedGrokInvitations.delete(memberId)
    await this.processGrokInvitation(evt, mainGroupId)
  }

  private async processGrokInvitation(evt: CEvt.ReceivedGroupInvitation, mainGroupId: number): Promise<void> {
    log(`Grok joining group: mainGroupId=${mainGroupId}, grokGroupId=${evt.groupInfo.groupId}`)
    try {
      await this.withGrokProfile(() => this.chat.apiJoinGroup(evt.groupInfo.groupId))
    } catch (err) {
      logError(`Grok failed to join group ${evt.groupInfo.groupId}`, err)
      return
    }
    this.grokGroupMap.set(mainGroupId, evt.groupInfo.groupId)
    this.reverseGrokMap.set(evt.groupInfo.groupId, mainGroupId)
  }

  async onGrokMemberConnected(evt: CEvt.ConnectedToGroupMember): Promise<void> {
    if (evt.user.userId !== this.grokUserId) return
    const grokGroupId = evt.groupInfo.groupId
    const mainGroupId = this.reverseGrokMap.get(grokGroupId)
    if (mainGroupId === undefined) return
    this.grokFullyConnected.add(mainGroupId)
    const resolver = this.grokJoinResolvers.get(mainGroupId)
    if (resolver) {
      this.grokJoinResolvers.delete(mainGroupId)
      log(`Grok fully connected: mainGroupId=${mainGroupId}, grokGroupId=${grokGroupId}`)
      resolver()
    }
  }

  async onGrokNewChatItems(evt: CEvt.NewChatItems): Promise<void> {
    if (evt.user.userId !== this.grokUserId) return
    // When multiple customer messages arrive in one batch, only respond to the
    // last per group — earlier messages are included in its history context.
    const lastPerGroup = new Map<number, T.AChatItem>()
    for (const ci of evt.chatItems) {
      const {chatInfo, chatItem} = ci
      if (chatInfo.type !== "group") continue
      if (chatItem.chatDir.type !== "groupRcv") continue
      if (!util.ciContentText(chatItem)?.trim()) continue
      if (util.ciBotCommand(chatItem)) continue
      const bc = chatInfo.groupInfo.businessChat
      if (!bc) continue
      if (chatItem.chatDir.groupMember.memberId !== bc.customerId) continue
      lastPerGroup.set(chatInfo.groupInfo.groupId, ci)
    }
    // Groups are independent — avoid serializing one group's xAI latency across the others.
    await Promise.allSettled(
      [...lastPerGroup.values()].map((ci) => this.processGrokChatItem(ci)),
    )
  }

  // --- Main profile message routing ---

  private async processMainChatItem(ci: T.AChatItem): Promise<void> {
    const {chatInfo, chatItem} = ci

    // 1. Direct text message → reply with business address
    if (chatInfo.type === "direct" && chatItem.chatDir.type === "directRcv"
      && (chatItem.content as any).type === "rcvMsgContent") {
      if (this.businessAddress) {
        const contactId = chatInfo.contact.contactId
        try {
          await this.withMainProfile(() =>
            this.chat.apiSendTextMessage(
              [T.ChatType.Direct, contactId],
              `Please use my business address to ask questions: ${this.businessAddress}`,
            )
          )
        } catch (err) {
          logError(`Failed to reply to direct message from contact ${contactId}`, err)
        }
      }
      return
    }

    if (chatInfo.type !== "group") return
    const groupInfo = chatInfo.groupInfo
    const groupId = groupInfo.groupId

    // 2. Team group → handle /join
    if (groupId === this.config.teamGroup.id) {
      await this.processTeamGroupMessage(chatItem)
      return
    }

    // 3. Skip non-business groups
    if (!groupInfo.businessChat) return

    // 4. Skip own messages
    if (chatItem.chatDir.type === "groupSnd") return
    if (chatItem.chatDir.type !== "groupRcv") return

    const sender = chatItem.chatDir.groupMember
    const bc = groupInfo.businessChat
    const isCustomer = sender.memberId === bc.customerId

    // 6. Non-customer message → one-way gate check + card update
    if (!isCustomer) {
      const isTeam = this.config.teamMembers.some(tm => tm.id === sender.memberContactId)

      if (isTeam && util.ciContentText(chatItem)?.trim()) {
        // One-way gate: first team text → transition to TEAM + remove Grok
        const data = await this.cards.getRawCustomData(groupId)
        if (data?.state !== "TEAM") {
          await this.cards.mergeCustomData(groupId, {state: "TEAM"})
          const {grokMember} = await this.cards.getGroupComposition(groupId)
          if (grokMember) {
            log(`One-way gate: team message in group ${groupId}, removing Grok`)
            try {
              await this.withMainProfile(() =>
                this.chat.apiRemoveMembers(groupId, [grokMember.groupMemberId])
              )
            } catch {
              // may have already left
            }
            this.cleanupGrokMaps(groupId)
          }
        }
      }
      // Schedule card update for any non-customer message (team or Grok)
      this.cards.scheduleUpdate(groupId)
      return
    }

    // 8. Customer message → derive state and dispatch
    const state = await this.cards.deriveState(groupId)
    const rawCmd = util.ciBotCommand(chatItem)
    // When Grok is disabled, ignore /grok so it behaves like an unknown command
    const cmd = rawCmd?.keyword === "grok" && !this.grokEnabled ? null : rawCmd
    const text = util.ciContentText(chatItem)?.trim() || null

    switch (state) {
      case "WELCOME":
        if (cmd?.keyword === "grok") {
          // WELCOME → GROK (skip queue msg). Write state optimistically so the
          // card renders with GROK icon/label; activateGrok will revert via
          // setStateOnFail if activation fails.
          // Fire-and-forget: activateGrok awaits future events (waitForGrokJoin)
          // which would deadlock the sequential event loop if awaited here.
          await this.cards.mergeCustomData(groupId, {state: "GROK"})
          await this.cards.createCard(groupId, groupInfo)
          this.fireAndForget(this.activateGrok(groupId, {sendQueueOnFail: true, setStateOnFail: "QUEUE"}))
          return
        }
        if (cmd?.keyword === "team") {
          // activateTeam writes state=TEAM-PENDING before the add loop
          await this.activateTeam(groupId)
          await this.cards.createCard(groupId, groupInfo)
          return
        }
        // First regular message → QUEUE
        if (text) {
          await this.cards.mergeCustomData(groupId, {state: "QUEUE"})
          await this.sendToGroup(groupId, queueMessage(this.config.timezone, this.grokEnabled))
          await this.cards.createCard(groupId, groupInfo)
        }
        break

      case "QUEUE":
        if (cmd?.keyword === "grok") {
          // Write state optimistically; activateGrok reverts to QUEUE on failure
          await this.cards.mergeCustomData(groupId, {state: "GROK"})
          this.fireAndForget(this.activateGrok(groupId, {setStateOnFail: "QUEUE"}))
        } else if (cmd?.keyword === "team") {
          await this.activateTeam(groupId)
        }
        this.cards.scheduleUpdate(groupId)
        break

      case "GROK":
        if (cmd?.keyword === "team") {
          await this.activateTeam(groupId)
        } else if (cmd?.keyword === "grok") {
          // Already in grok mode — ignore
        } else if (text) {
          // Customer text → Grok responds (handled by Grok profile's onGrokNewChatItems)
          // Just schedule card update for the customer message
        }
        this.cards.scheduleUpdate(groupId)
        break

      case "TEAM-PENDING":
        if (cmd?.keyword === "grok") {
          // Invite Grok if not present; state stays TEAM-PENDING
          const {grokMember} = await this.cards.getGroupComposition(groupId)
          if (!grokMember) {
            this.fireAndForget(this.activateGrok(groupId))
          }
          // else: already present, ignore
        } else if (cmd?.keyword === "team") {
          // activateTeam handles "already invited" reply (team still present)
          // or silent re-add (team has all left)
          await this.activateTeam(groupId)
        }
        this.cards.scheduleUpdate(groupId)
        break

      case "TEAM":
        if (cmd?.keyword === "grok") {
          await this.sendToGroup(groupId, teamLockedMessage)
        } else if (cmd?.keyword === "team") {
          // Team still present → "already invited"; team all left → silent re-add
          await this.activateTeam(groupId)
        }
        this.cards.scheduleUpdate(groupId)
        break
    }
  }

  // --- Grok profile message processing ---

  private async processGrokChatItem(ci: T.AChatItem): Promise<void> {
    if (!this.grokApi) return
    const grokApi = this.grokApi
    const {chatInfo, chatItem} = ci
    if (chatInfo.type !== "group") return
    const groupInfo = chatInfo.groupInfo
    const grokGroupId = groupInfo.groupId

    // Skip while activateGrok is sending the initial combined response
    const mainGroupId = this.reverseGrokMap.get(grokGroupId)
    if (mainGroupId !== undefined && this.grokInitialResponsePending.has(mainGroupId)) return

    // Only process received text messages from customer
    if (chatItem.chatDir.type !== "groupRcv") return
    const text = util.ciContentText(chatItem)?.trim()
    if (!text) return // ignore non-text

    // Ignore bot commands
    if (util.ciBotCommand(chatItem)) return

    // Only respond in business groups (survives restart without in-memory maps)
    const bc = groupInfo.businessChat
    if (!bc) return

    // Only respond to customer messages, not bot or team messages
    if (chatItem.chatDir.groupMember.memberId !== bc.customerId) return

    // Read history from Grok's own view
    try {
      const chat = await this.withGrokProfile(() =>
        this.chat.apiGetChat(T.ChatType.Group, grokGroupId, 100)
      )
      const history: GrokMessage[] = []
      for (const histCi of chat.chatItems) {
        const histText = util.ciContentText(histCi)?.trim()
        if (!histText) continue
        if (histCi.chatDir.type === "groupSnd") {
          history.push({role: "assistant", content: histText})
        } else if (histCi.chatDir.type === "groupRcv"
          && histCi.chatDir.groupMember.memberId === bc.customerId
          && !util.ciBotCommand(histCi)) {
          history.push({role: "user", content: histText})
        }
      }

      // Don't include the current message in history — it's the userMessage
      if (history.length > 0 && history[history.length - 1].role === "user"
        && history[history.length - 1].content === text) {
        history.pop()
      }

      // Call Grok API (outside mutex)
      const response = await grokApi.chat(history, text)

      // Send response via Grok profile
      await this.withGrokProfile(() =>
        this.chat.apiSendTextMessage([T.ChatType.Group, grokGroupId], response)
      )
    } catch (err) {
      logError(`Grok per-message error for grokGroup ${grokGroupId}`, err)
      try {
        await this.withGrokProfile(() =>
          this.chat.apiSendTextMessage([T.ChatType.Group, grokGroupId], grokErrorMessage)
        )
      } catch {}
    }

    // Card update scheduled by main profile seeing the groupRcv events
  }

  // --- Grok activation ---

  private async activateGrok(
    groupId: number,
    opts: {sendQueueOnFail?: boolean; setStateOnFail?: ConversationState} = {},
  ): Promise<void> {
    if (!this.grokApi) return
    const grokApi = this.grokApi
    const revertStateOnFail = async () => {
      if (!opts.setStateOnFail) return
      const current = await this.cards.getRawCustomData(groupId)
      if (current?.state !== "GROK") return
      await this.cards.mergeCustomData(groupId, {state: opts.setStateOnFail})
    }
    if (this.config.grokContactId === null) {
      await revertStateOnFail()
      await this.sendToGroup(groupId, grokUnavailableMessage)
      if (opts.sendQueueOnFail) await this.sendToGroup(groupId, queueMessage(this.config.timezone, this.grokEnabled))
      this.cards.scheduleUpdate(groupId)
      return
    }

    // Pre-check: silent return if Grok is already in the group in any
    // non-terminal status. The apiAddMember/groupDuplicateMember catch below
    // handles Connected/etc. but the SimpleX API resends the invitation for
    // GSMemInvited (no error thrown), so without this check a /grok issued
    // while a previous activation is still pending would re-trigger the invite.
    const grokMembers = await this.withMainProfile(() => this.chat.apiListMembers(groupId))
    if (grokMembers.some(m => m.memberContactId === this.config.grokContactId && isInGroup(m))) {
      return
    }

    // Gate MUST be up before apiAddMember / pendingGrokJoins / reverseGrokMap —
    // any later and onGrokNewChatItems can fire a duplicate per-message reply.
    this.grokInitialResponsePending.add(groupId)
    try {
      await this.sendToGroup(groupId, grokInvitingMessage)

      let member: T.GroupMember
      try {
        member = await this.withMainProfile(() =>
          this.chat.apiAddMember(groupId, this.config.grokContactId!, T.GroupMemberRole.Member)
        )
      } catch (err: unknown) {
        const chatErr = err as {chatError?: {errorType?: {type?: string}}}
        if (chatErr?.chatError?.errorType?.type === "groupDuplicateMember") {
          // Grok already in group (e.g. customer sent /grok again before join completed) —
          // the in-flight activation will handle the outcome, just return silently
          return
        }
        logError(`Failed to invite Grok to group ${groupId}`, err)
        await revertStateOnFail()
        await this.sendToGroup(groupId, grokUnavailableMessage)
        if (opts.sendQueueOnFail) await this.sendToGroup(groupId, queueMessage(this.config.timezone, this.grokEnabled))
        this.cards.scheduleUpdate(groupId)
        return
      }

      this.pendingGrokJoins.set(member.memberId, groupId)

      // Drain buffered invitation that arrived during the apiAddMember await
      const buffered = this.bufferedGrokInvitations.get(member.memberId)
      if (buffered) {
        this.bufferedGrokInvitations.delete(member.memberId)
        this.pendingGrokJoins.delete(member.memberId)
        await this.processGrokInvitation(buffered, groupId)
      }

      const joined = await this.waitForGrokJoin(groupId, 120_000)
      if (!joined) {
        this.pendingGrokJoins.delete(member.memberId)
        try {
          await this.withMainProfile(() =>
            this.chat.apiRemoveMembers(groupId, [member.groupMemberId])
          )
        } catch {}
        this.cleanupGrokMaps(groupId)
        await revertStateOnFail()
        await this.sendToGroup(groupId, grokUnavailableMessage)
        if (opts.sendQueueOnFail) await this.sendToGroup(groupId, queueMessage(this.config.timezone, this.grokEnabled))
        this.cards.scheduleUpdate(groupId)
        return
      }

      await this.sendToGroup(groupId, grokActivatedMessage)

      // Grok joined — send initial response based on customer's accumulated messages
      try {
        const grokLocalGId = this.grokGroupMap.get(groupId)
        if (grokLocalGId === undefined) {
          await this.sendToGroup(groupId, grokUnavailableMessage)
          return
        }

        // Read history from Grok's own view — only customer messages.
        // The previous `grokBc && ...` short-circuit let bot and team
        // messages through when Grok's view had no businessChat; require
        // grokBc.customerId to be present and match strictly.
        const chat = await this.withGrokProfile(() =>
          this.chat.apiGetChat(T.ChatType.Group, grokLocalGId, 100)
        )
        const grokBc = chat.chatInfo.type === "group" ? chat.chatInfo.groupInfo.businessChat : null
        const customerMessages: string[] = []
        for (const ci of chat.chatItems) {
          if (ci.chatDir.type !== "groupRcv") continue
          if (!grokBc || ci.chatDir.groupMember.memberId !== grokBc.customerId) continue
          const t = util.ciContentText(ci)?.trim()
          if (t && !util.ciBotCommand(ci)) customerMessages.push(t)
        }

        if (customerMessages.length === 0) {
          await this.withGrokProfile(() =>
            this.chat.apiSendTextMessage([T.ChatType.Group, grokLocalGId], grokNoHistoryMessage)
          )
          return
        }

        const initialMsg = customerMessages.join("\n")
        const response = await grokApi.chat([], initialMsg)

        await this.withGrokProfile(() =>
          this.chat.apiSendTextMessage([T.ChatType.Group, grokLocalGId], response)
        )
      } catch (err) {
        logError(`Grok initial response failed for group ${groupId}`, err)
        await this.sendToGroup(groupId, grokUnavailableMessage)
      }
    } finally {
      this.grokInitialResponsePending.delete(groupId)
    }
  }

  // --- Team activation ---

  private async activateTeam(groupId: number): Promise<void> {
    if (this.config.teamMembers.length === 0) {
      await this.sendToGroup(groupId, noTeamMembersMessage(this.grokEnabled))
      return
    }

    const data = await this.cards.getRawCustomData(groupId)
    const alreadyActivated = data?.state === "TEAM-PENDING" || data?.state === "TEAM"
    if (alreadyActivated) {
      const {teamMembers} = await this.cards.getGroupComposition(groupId)
      if (teamMembers.length > 0) {
        await this.sendToGroup(groupId, teamAlreadyInvitedMessage)
        return
      }
      // Team previously activated but all team members have since left —
      // re-add silently (no teamAddedMessage). State stays TEAM-PENDING/TEAM.
      for (const tm of this.config.teamMembers) {
        try {
          await this.addOrFindTeamMember(groupId, tm.id)
        } catch (err) {
          logError(`Failed to add team member ${tm.id} to group ${groupId}`, err)
        }
      }
      return
    }

    // First activation — write state BEFORE add loop so concurrent customer
    // events observing mid-flight see TEAM-PENDING rather than stale state.
    await this.cards.mergeCustomData(groupId, {state: "TEAM-PENDING"})

    for (const tm of this.config.teamMembers) {
      try {
        await this.addOrFindTeamMember(groupId, tm.id)
      } catch (err) {
        logError(`Failed to add team member ${tm.id} to group ${groupId}`, err)
      }
    }

    const {grokMember} = await this.cards.getGroupComposition(groupId)
    await this.sendToGroup(groupId, teamAddedMessage(this.config.timezone, !!grokMember))
  }

  // --- Team group commands ---

  private async processTeamGroupMessage(chatItem: T.ChatItem): Promise<void> {
    if (chatItem.chatDir.type !== "groupRcv") return
    const senderContactId = chatItem.chatDir.groupMember.memberContactId
    if (!senderContactId) return

    const cmd = util.ciBotCommand(chatItem)
    if (cmd?.keyword !== "join") return

    const targetGroupId = Number.parseInt(cmd.params, 10)
    if (Number.isNaN(targetGroupId) || targetGroupId <= 0) {
      await this.sendToGroup(this.config.teamGroup.id, `Error: invalid group id "${cmd.params}"`)
      return
    }
    await this.handleJoinCommand(targetGroupId, senderContactId)
  }

  private async handleJoinCommand(targetGroupId: number, senderContactId: number): Promise<void> {
    // Validate target is a business group
    const groups = await this.withMainProfile(() =>
      this.chat.apiListGroups(this.mainUserId)
    )
    const targetGroup = groups.find(g => g.groupId === targetGroupId)
    if (!targetGroup?.businessChat) {
      await this.sendToGroup(this.config.teamGroup.id, `Error: group ${targetGroupId} is not a business chat`)
      return
    }

    try {
      const member = await this.addOrFindTeamMember(targetGroupId, senderContactId)
      if (member) {
        log(`Team member ${senderContactId} joined group ${targetGroupId} via /join`)
      }
    } catch (err) {
      logError(`/join failed for group ${targetGroupId}`, err)
      await this.sendToGroup(this.config.teamGroup.id, `Error joining group ${targetGroupId}`)
    }
  }

  // --- Helpers ---

  private async addOrFindTeamMember(groupId: number, teamContactId: number): Promise<T.GroupMember | null> {
    // Pre-check membership: skip apiAddMember entirely if the contact is in
    // the group in any non-terminal status. The SimpleX API resends the
    // invitation for a member in GSMemInvited, so calling apiAddMember on a
    // pending invitee would re-trigger an invite notification.
    const members = await this.withMainProfile(() => this.chat.apiListMembers(groupId))
    const existing = members.find(m => m.memberContactId === teamContactId && isInGroup(m))
    if (existing) return existing
    const member = await this.withMainProfile(() =>
      this.chat.apiAddMember(groupId, teamContactId, T.GroupMemberRole.Member)
    )
    try {
      await this.withMainProfile(() =>
        this.chat.apiSetMembersRole(groupId, [member.groupMemberId], T.GroupMemberRole.Owner)
      )
    } catch {
      // Not yet connected — will be promoted in onMemberConnected
    }
    return member
  }

  async sendToGroup(groupId: number, text: string): Promise<void> {
    try {
      await this.withMainProfile(() =>
        this.chat.apiSendTextMessage([T.ChatType.Group, groupId], text)
      )
    } catch (err) {
      logError(`Failed to send message to group ${groupId}`, err)
    }
  }

  private waitForGrokJoin(groupId: number, timeout: number): Promise<boolean> {
    if (this.grokFullyConnected.has(groupId)) return Promise.resolve(true)
    return new Promise<boolean>((resolve) => {
      const timer = setTimeout(() => {
        this.grokJoinResolvers.delete(groupId)
        resolve(false)
      }, timeout)
      this.grokJoinResolvers.set(groupId, () => {
        clearTimeout(timer)
        resolve(true)
      })
    })
  }

  private async sendTeamMemberDM(member: T.GroupMember, memberContact?: T.Contact): Promise<void> {
    const name = member.memberProfile.displayName
    const formatted = name.includes(" ") ? `'${name}'` : name

    let contactId = memberContact?.contactId ?? member.memberContactId
    if (!contactId) {
      // No DM contact yet — create one and send invitation with message
      try {
        const contact = await this.withMainProfile(() =>
          this.chat.apiCreateMemberContact(this.config.teamGroup.id, member.groupMemberId)
        )
        contactId = contact.contactId as number
        log(`Created DM contact ${contactId} for team member ${name}`)
      } catch (err) {
        logError(`Failed to create member contact for ${name}`, err)
        return
      }
      if (this.sentTeamDMs.has(contactId)) return
      const msg = `Added you to be able to invite you to customer chats later, keep this contact. Your contact ID is ${contactId}:${formatted}`
      try {
        await this.withMainProfile(() =>
          this.chat.apiSendMemberContactInvitation(contactId!, msg)
        )
        this.sentTeamDMs.add(contactId)
        this.pendingTeamDMs.delete(contactId)
        log(`Sent DM invitation to team member ${contactId}:${name}`)
      } catch {
        this.pendingTeamDMs.set(contactId, msg)
      }
      return
    }
    // Contact already exists — send via normal DM
    if (this.sentTeamDMs.has(contactId)) return
    const msg = `Added you to be able to invite you to customer chats later, keep this contact. Your contact ID is ${contactId}:${formatted}`
    try {
      await this.withMainProfile(() =>
        this.chat.apiSendTextMessage([T.ChatType.Direct, contactId], msg)
      )
      this.sentTeamDMs.add(contactId)
      this.pendingTeamDMs.delete(contactId)
      log(`Sent DM to team member ${contactId}:${name}`)
    } catch {
      this.pendingTeamDMs.set(contactId, msg)
    }
  }

  private cleanupGrokMaps(groupId: number): void {
    const grokLocalGId = this.grokGroupMap.get(groupId)
    this.grokFullyConnected.delete(groupId)
    this.grokInitialResponsePending.delete(groupId)
    if (grokLocalGId === undefined) return
    this.grokGroupMap.delete(groupId)
    this.reverseGrokMap.delete(grokLocalGId)
  }
}