import {
  regSocketEventListener,
  getGlobalState,
  getCachedUserInfo,
  getServiceWorkerRegistration,
} from '@capital/common';
import { Translate } from './translate';
import { hasSilent } from './silent';

export function initNotify() {
  if (Notification.permission === 'default') {
    Notification.requestPermission();
  }

  regSocketEventListener({
    eventName: 'chat.message.add',
    eventFn: (message) => {
      const converseId = message.converseId;
      const currentUserId = getGlobalState()?.user.info._id;

      if (hasSilent(converseId)) {
        // 免打扰
        return;
      }

      if (currentUserId !== message.author) {
        // 创建通知

        // TODO: 需要增加所在群组
        if (Notification.permission === 'granted') {
          Promise.all([getCachedUserInfo(message.author)]).then(
            ([userInfo]) => {
              const nickname = userInfo?.nickname ?? '';
              const icon = userInfo?.avatar ?? undefined;
              const content = message.content;

              const registration: ServiceWorkerRegistration | null =
                getServiceWorkerRegistration();

              const title = `${Translate.from} ${nickname}`;
              const options: NotificationOptions = {
                body: content,
                icon,
                tag: 'tailchat-message',
                renotify: true,
              };
              if (registration && registration.showNotification) {
                registration.showNotification(title, options);
              } else {
                // fallback
                new Notification(title, options);
              }
            }
          );
        }
      }
    },
  });
}