AiReviewPR/src/utils.ts

import http from "http";
import https from "https";

export function split_message(files: string): string[] {
  files = files || "";
  let n = files.includes('\n') || files.includes('\r');
  files = files.trim()
  let res: string[] = [];
  if (files) {
    if (n) {
      res = files.split(/[\r\n]/);
    } else {
      res = files.split(",")
    }
  }
  return res.map(str => str.trim()).filter(item => item !== null && item !== undefined && item !== "")
}

export function doesAnyPatternMatch(patterns: Array<string>, str: string) {
  // 遍历正则表达式数组
  return patterns.some(pattern => {
    // 创建正则表达式对象，匹配模式
    const regex = new RegExp(pattern);
    // 测试字符串是否与正则表达式匹配
    return regex.test(str);
  });
}

/**
 * post data
 * @param url url
 * @param body post data
 * @param header post header
 * @param json is json res
 */
export async function post({url, body, header, json}: any): Promise<string> {
  return new Promise((resolve, reject) => {
    json = typeof json === "boolean" ? json : true;
    const data = typeof body === "string" ? body : JSON.stringify(body);
    let url_ = new URL(url);
    header = header || {};
    header['Content-Type'] = header['Content-Type'] || 'application/json';
    header['Content-Length'] = Buffer.byteLength(data)
    const options = {
      hostname: url_.hostname, // 确保去掉协议部分
      path: url_.pathname + (url_.search || ''),
      method: 'POST',
      headers: header
    };

    // noinspection DuplicatedCode
    const req = (url_.protocol === "http" ? http : https).request(options, (res) => {
      let responseBody = '';

      res.on('data', (chunk) => {
        responseBody += chunk;
      });

      res.on('end', () => {
        try {
          if (json) {
            resolve(JSON.parse(responseBody));
          } else {
            resolve(responseBody);
          }
        } catch (error) {
          reject(new Error('Failed to parse JSON response'));
        }
      });
    });

    req.on('error', (error) => {
      reject(new Error(`Request failed: ${error.message}`));
    });

    req.write(data);
    req.end();
  });
}