实现gitlab PR自动流程处理机器人

提交PR -> 群里发通知+@对方 -> PR通过 -> 私聊发送通知 -> 合并PR

const atReg = /@[^\s]+/g

// 获取单条note中@的列表
function getNoteAtList ( note ) {
  return ( note.match( atReg ) || [] )
    .map( at => at.slice( 1 ) ); //去除前面的@符号
}

// 过滤@列表，只留下真实存在的gitlab用户, privateToken为gitlab openapi需要的鉴权token
async function filterAtList ( atList = [], privateToken ) {
  const distinctList = [ ...new Set( atList ) ]; // 去重
  const result = await Promise.all( distinctList.map( username => getGitlabUser( username, privateToken ) ) );
  return result.filter( Boolean ); // 去除空值
}

// 根据username在查找User信息
async function getGitlabUser ( userName, privateToken ) {
  const users = await getUser( {
    userName,
    privateToken,
  } )

  if ( !users || !users.length )
  {
    return null;
  }
  const target = users[ 0 ];
  return {
    username: userName,
    name: target.name,
    id: target.id,
  };
};

async function getUser ( params ) {
  const { userName, privateToken } = params;
  const request = await getGitlabRequest( privateToken ); // 基于axios进行的封装，设置了baseURL及鉴权header
  try
  {
    const result = await request.get( `/users`, {
      params: {
        username: userName,
      }
    } );

    return result.data || [];
  } catch ( e )
  {
    console.error( 'get_gitlab_user_info', e );
    return [];
  }
}

const atText = atList.map( at => `@${ at.name }` );
const textMsgConfig = {
  open_chat_id, // 群id
  msg_type: 'text',
  content: {
    text: atText,
  }
}
await request.post( '/send/message/', textMsgConfig ); // 在群里发送通知

// 此PR所有的评论
const discussions = await getPrDiscussions( {
  pid,
  mrId,
  privateToken
} );

const lgtmList = getLgtmList( discussions, author ) || []; // 回复了LGTM的评论列表
// 如果还没有到阈值则不回复消息
if ( lgtmList.length < lgtmThreshold )
{
  return;
}

// 文本消息
const nameList = lgtmList.map( note => note.author.name );
const lgtmSummary = `${ nameList.slice(0,3).join( '、' ) }${ nameList.length > 3 ? `等${nameList.length}人` : '' }对你的PR回复了LGTM， 你可以Merge此PR了`;
const textMsgConfig = {
  email, // PR作者的邮箱
  msg_type: 'text',
  content: {
    text: lgtmSummary,
  }
}
await request.post( '/send/message/', textMsgConfig ); // 发送私聊通知

// 筛选出非PR作者写的note， discussion 与 note是一对多的关系
function getNonAuthorNotes ( discus, authorId ) {
  return ( discus.notes || [] ).filter( note =>
    `${ note.author.id }` !== `${ authorId }` && // 非作者的PR
    !note.system && // 不是系统发的
    !note.resolved // 没有resolve
  );
}

// 获取回复了LGTM的评论列表
function getLgtmList ( discussions, author ) {
  const distinctMap = {}; // 去重，同一个人的多次lgtm只算一次

  // 获取所有非作者的评论
  const noteList = discussions.reduce( ( noteList, discus ) => noteList.concat( getNonAuthorNotes( discus, author.id ) ), [] );

  return noteList
    .filter( note => note.body.trim().toUpperCase() === 'LGTM' ) // 过滤出评论了LGTM的
    .filter( note => { // 去重
      const { id } = note.author;
      if ( !distinctMap[ id ] )
      {
        distinctMap[ id ] = 1;
        return true;
      }
      return false;
    } )
}

// 发送支持交互的消息
const interacriveMsgConfig = {
  // ... 其他相关配置
  method: "post",
  url: 'xxx', // 中转后端api
  parameter: {
    pid,
    mrId,
    privateToken,
    squash, // 是否squash commit
    removeSource, // 是否删除源分支
  },
}

// 发送交互类型消息
await request.post( '/send/message/', {
  email,
  msg_type: 'interactive',
  content: {
    card: interacriveMsgConfig,
  },
} );

// 合并PR
module.exports = async function ( params, context ) {
  const {
    pid,
    mrId,
    privateToken,
    squash,
    removeSource,
  } = params;

  const gitlabRequest = await getGitlabRequest( privateToken );

  let msg = '';
  let status = 200;
  try
  {
    // 发送PUT请求
    const result = await gitlabRequest.put( `/projects/${ pid }/merge_requests/${ mrId }/merge`, {
      id: pid,
      merge_request_iid: mrId,
      squash,
      should_remove_source_branch: removeSource
    } );
    console.log( 'SUCCESS merge pr, result => ', result );
    msg = `【 SUCCESS 】: PR is merged!`;
  } catch ( error )
  {
    console.error( 'FAIL merge pr, error => ', error.response );
    ( { status, statusText } = error.response );
    msg = `【 FAILED 】: ${ statusText }, ${ errorMap[ status ] }`;
  }

  console.log( 'merge pr ,final function return => ', { status, msg } );
  context.status( status ); // 设置响应状态码
  return { status, msg };
}