import type { ImManagerChannelApi } from '#/api/im/manager/channel'

import { acceptHMRUpdate, defineStore } from 'pinia'

import { getSimpleChannelList } from '#/api/im/manager/channel'

import { ImConversationType } from '../../utils/constants'
import { getDb } from '../../utils/db'
import { useConversationStore } from './conversationStore'

/**
 * IM 频道 Store
 *
 * 负责：缓存当前用户能看到的频道精简列表（含 id / code / name / avatar），
 * 供会话列表 / 卡片渲染时反查频道名称 + 头像，避免显示「频道 1」这种占位
 */
export const useChannelStore = defineStore('imChannelStore', {
  state: () => ({
    channels: [] as ImManagerChannelApi.Channel[],
    loaded: false
  }),

  getters: {
    getChannel(state): (id: number) => ImManagerChannelApi.Channel | undefined {
      return (id: number) => state.channels.find((c) => c.id === id)
    }
  },

  actions: {
    // ==================== 本地缓存 ====================

    /** 从 IndexedDB 恢复频道列表 */
    async loadChannelList(): Promise<boolean> {
      try {
        const cached = await getDb().getAll<ImManagerChannelApi.Channel>('channels')
        if (!cached || cached.length === 0) {
          return false
        }
        this.channels = cached
        return true
      } catch (error) {
        console.warn('[IM channelStore] 本地频道缓存读取失败', error)
        return false
      }
    },

    /** 保存频道列表 */
    saveChannelList(): void {
      void getDb()
        .transaction(['channels'], 'readwrite', async (tx) => {
          const db = getDb()
          await db.clearStore('channels', tx)
          for (const channel of this.channels) {
            await db.put('channels', channel, tx)
          }
        })
        .catch((error) => console.warn('[IM channelStore] 本地频道缓存写入失败', error))
    },

    // ==================== 远端拉取 ====================

    /** 拉取启用的频道精简列表；成功后回填会话列表已有的频道 name / avatar，覆盖 IDB 旧占位 */
    async fetchChannelList(force = false) {
      if (this.loaded && !force) {
        return
      }
      try {
        this.channels = (await getSimpleChannelList()) || []
        this.loaded = true
        this.syncChannelConversationMetadata()
        this.saveChannelList()
      } catch (error) {
        console.warn('[IM channelStore] fetchChannelList 失败', error)
      }
    },

    /** 用最新的频道信息覆盖已有 CHANNEL 会话的 name / avatar */
    syncChannelConversationMetadata() {
      const conversationStore = useConversationStore()
      const indexed = new Map(this.channels.map((c) => [c.id, c]))
      conversationStore.conversations.forEach((conversation) => {
        if (conversation.type !== ImConversationType.CHANNEL) {
          return
        }
        const channel = indexed.get(conversation.targetId)
        if (!channel) {
          return
        }
        conversationStore.updateConversation(ImConversationType.CHANNEL, conversation.targetId, {
          name: channel.name,
          avatar: channel.avatar
        })
      })
    },

    /** 清空频道内存 */
    clear() {
      this.channels = []
      this.loaded = false
    }
  }
})

if (import.meta.hot) {
  import.meta.hot.accept(acceptHMRUpdate(useChannelStore, import.meta.hot))
}

export const useChannelStoreWithOut = () => useChannelStore()