消息告警弹层

{
  "id": "exp_weather_alert",
  "name": "天气告警",
  "version": "1.0.0",
  "entry": "./plugin.js",
  "permissions": ["platform:websocket", "platform:http"],
  "extensions": [
    {
      "id": "weather-popup",
      "point": "message.alert-popups"
    }
  ],
  "views": {
    "weather-card": { "entry": "./views/weather-card.js" }
  }
}

// plugin.ts
import {
  createViewState,
  definePlugin,
  definePluginView,
} from 'fh2-plugin-sdk'

interface WeatherCardContract {
  state: { alertId: string; title: string; detail: string }
  methods: {
    acknowledge(): void
    close(): void
  }
}
const weatherCard = definePluginView<WeatherCardContract>('weather-card')

export default definePlugin({
  async activate (ctx) {
    if (ctx.host.id !== 'message') return
    const state = createViewState<WeatherCardContract['state']>({
      alertId: '',
      title: '',
      detail: '',
    })
    let popup: {
      update(patch: { visible?: boolean }): Promise<void>
    } | undefined

    async function hide () {
      await popup?.update({ visible: false })
    }
    await weatherCard.handle(ctx, {
      state,
      methods: {
        async acknowledge () {
          // 处理回执由插件自己的后端接口完成
          const { alertId } = state.get()
          await ctx.apiCall(`/weather-alerts/${encodeURIComponent(alertId)}/ack`, {
            method: 'POST',
            body: { result: 'acknowledged' },
            idempotencyKey: `weather-ack-${alertId}`,
          })
          await hide()
        },
        close: hide,
      },
    })

    popup = await ctx.extensions.contribute('weather-popup', {
      visible: false,
      render: () => weatherCard.get(ctx),
    })
    const wsSubscription = await ctx.ws.onBizCode<{
      id: string
      title: string
      detail: string
    }>('weather_alert', async ({ data }) => {
      state.update(() => ({
        alertId: data.id,
        title: data.title,
        detail: data.detail,
      }))
      await popup?.update({ visible: true })
    })

    return {
      async dispose () {
        await hide()
        await wsSubscription.dispose()
      },
    }
  },
})