asb_cloud_front/src/pages/TelemetryView/ActiveMessagesOnline.jsx

import {useState, useEffect} from 'react'
import {Table} from "antd";
import moment from 'moment'

import LoaderPortal from '../../components/LoaderPortal'
import {invokeWebApiWrapperAsync} from '../../components/factory'

import {Subscribe} from '../../services/signalr'
import {MessageService} from '../../services/api'
import '../../styles/message.css'

// Словарь категорий для строк таблицы
const categoryDictionary = {
  1: {title: 'Важное'},
  2: {title: 'Предупреждение'},
  3: {title: 'Информация'},
}

// Конфигурация таблицы
const columns = [
  {
    title: 'Дата',
    dataIndex: 'date',
    render: (item) => moment(item).format('DD MMM YYYY, HH:mm:ss'),
    sorter: (a, b) => new Date(b.date) - new Date(a.date),
    sortDirections: ['descend', 'ascend'],
  }, {
    title: 'Глубина',
    key: 'wellDepth',
    dataIndex: 'wellDepth',
    render: depth => <span>Глубина {depth.toFixed(2)} м.</span>,
  }, {
    title: 'Категория',
    dataIndex: 'categoryId',
    render: (_, item) => categoryDictionary[item.categoryId]?.title,
    style: (_, item) => categoryDictionary[item.categoryId]?.style,
    sorter: (a, b) => a.categoryId - b.categoryId,
    sortDirections: ['descend', 'ascend'],
  }, {
    title: 'Сообщение',
    dataIndex: 'message',
    onFilter: (value, record) => record.name.indexOf(value) === 0,
  }, {
    title: 'Пользователь',
    dataIndex: 'user',
  },
];

export default function ActiveMessagesOnline({idWell}) {
  const [messages, setMessages] = useState([])
  const [loader, setLoader] = useState(false)

  const handleReceiveMessages = (messages) => {
    if (messages) {
      setMessages(messages.items.splice(0, 4))
    }
  }

  useEffect(() => {    
    invokeWebApiWrapperAsync(
    async () => {
        const messages = await MessageService.getMessages(idWell, 0, 4)
        handleReceiveMessages(messages)
      },
      setLoader,
      `Не удалось загрузить сообщения по скважине "${idWell}"`,
    )
    return Subscribe('hubs/telemetry','ReceiveMessages', `well_${idWell}`, handleReceiveMessages)
  }, [idWell])

  return (<LoaderPortal show={loader}>
    <Table
      showHeader={false}
      columns={columns}
      dataSource={messages}
      rowClassName={(record) => `event_message_${record.categoryId} event_message`}
      className={'message_table'}
      size={'small'}
      pagination={false}
      rowKey={(record) => record.id}
    />
  </LoaderPortal>)
}