send.js

import { request as _request } from 'node:https';
import { getLogger } from '@sitespeed.io/log';
const log = getLogger('sitespeedio.plugin.matrix');

function send(
  host,
  data,
  message,
  room,
  accessToken,
  retries = 3,
  backoff = 5000,
  transactionId = null
) {
  if (transactionId === null) {
    transactionId = `ssio-${Date.now()}`
  }
  const retryCodes = new Set([408, 429, 500, 503]);
  return new Promise((resolve, reject) => {
    const request = _request(
      {
        host,
        port: 443,
        path: `/_matrix/client/v3/rooms/${room}/send/m.room.message/${transactionId}`,
        headers: {
          'Authorization': `Bearer ${accessToken}`,
          'Content-Type': 'application/json',
          'Content-Length': Buffer.byteLength(JSON.stringify(data), 'utf8')
        },
        method: 'PUT'
      },
      res => {
        const { statusCode, statusMessage } = res;
        if (statusCode < 200 || statusCode > 299) {
          if (retries > 0 && retryCodes.has(statusCode)) {
            setTimeout(() => {
              return send(
                host,
                data,
                message,
                room,
                accessToken,
                retries - 1,
                backoff * 2,
                transactionId
              );
            }, backoff);
          } else {
            log.error(
              `Got error from Matrix. Error Code: ${statusCode} Message: ${statusMessage}`
            );
            reject(new Error(`Status Code: ${statusCode}`));
          }
        } else {
          const data = [];
          res.on('data', chunk => {
            data.push(chunk);
          });
          res.on('end', () => {
            resolve(JSON.parse(Buffer.concat(data).toString()));
          });
        }
      }
    );
    request.write(JSON.stringify(data));
    request.end();
  });
}

export default async function sendMatrix(host, room, accessToken, message) {
  const data = {
    msgtype: 'm.notice',
    body: '',
    format: 'org.matrix.custom.html',
    formatted_body: message
  };
  return send(host, data, message, room, accessToken);
}