Function onMessage

packages/ui-default/components/message/worker.ts:32–63

(message: any)

}

function onMessage(message: any) {
  broadcastMsg({ type: 'message', payload: message });
  let acked = false;
  let payload = message;
  ack[message.mdoc._id] = () => { acked = true; };
  ack[`${message.mdoc._id}-i18n`] = (v) => { payload = v; };
  if (message.mdoc.flag & FLAG_I18N) broadcastMsg({ type: 'i18n', payload: message });
  setTimeout(() => {
    delete ack[message.mdoc._id];
    delete ack[`${message.mdoc._id}-i18n`];
    if (acked) return;
    if (message.mdoc.flag & FLAG_INFO) return;
    if (Notification?.permission !== 'granted') {
      console.log('Notification permission denied');
      return;
    }
    console.log('Sending as system notification');
    // eslint-disable-next-line no-new
    new Notification(
      payload.udoc._id === 1 ? payload.mdoc.content.split('\n')[0] : payload.udoc.uname || 'Hydro Notification',
      payload.udoc._id === 1 ? {
        tag: `notification-${payload.mdoc._id}`,
        icon: payload.mdoc.avatar || '/android-chrome-192x192.png',
        body: payload.mdoc.content.split('\n').slice(1).join('\n'),
      } : {
        tag: `message-${payload.mdoc._id}`,
        icon: payload.udoc.avatarUrl || '/android-chrome-192x192.png',
        body: payload.mdoc.content,
      },
    );
  }, 3000);
}

function initConn(path: string, port: MessagePort, cookie: any) {
  ports.add(port);