@gaoding/hlg-logger-v2/lib/sender.js

const url = require('url');
const zlib = require('zlib');
const request = require('sync-request');
const dgram = require('dgram');

module.exports = {
    sendToServer(serverAddr, dataObj) {
        const urlObj = url.parse(serverAddr);
        const dataJson = JSON.stringify(dataObj);
        const dataCompressed = zlib.gzipSync(dataJson);
        const dataStr = dataCompressed.toString('base64');

        if (urlObj.protocol === 'udp:') {
            return this._sendToUdpServer(urlObj, dataStr);
        } else {
            return this._sendToHttpServer(urlObj, dataStr);
        }
    },
    _sendToUdpServer(urlObj, dataStr) {
        const client = this._getUdpClient(urlObj);
        const bufferObj = Buffer.from(dataStr);

        client.send(bufferObj, 0, bufferObj.length, urlObj.port, urlObj.hostname);

        return {
            server: urlObj.href,
            status: 0,
            body: '',
        };
    },
    _getUdpClient() {
        if (this._udpClient) {
            return this._udpClient;
        }

        this._udpClient = dgram.createSocket('udp4');

        this._udpClient.on('close', () => {
                this._udpClient = null;
                this._udpClient.removeAllListeners();
            })
            .on('error', (err) => {
                this._udpClient.close();
            });

        return this._udpClient;
    },
    _sendToHttpServer(urlObj, dataStr) {
        const formData = new request.FormData();
        formData.append('data_list', dataStr);
        const response = request('POST', urlObj.href, {
            form: formData,
            gzip: false,
            timeout: 10000,
            try: true,
            retryDelay: 200,
            maxRetries: 3,
        });
        return {
            server: urlObj.href,
            status: response.statusCode,
            body: response.body.toString()
        };
    }
};