middleware.js

const axios = require('axios');
const url = "http://localhost:9999/otto"
/**
 * 获取本地服务响应
 * @param {string} path 本地服务路由
 * @param {number} timeout 超时时间
 * @example
 */
async function accessLocalService(path, timeout) {
  try {
    const response = await Promise.race([
      axios.get(url + path),
      new Promise((_, reject) =>
        setTimeout(() => reject(new Error('Request timeout')), timeout)
      )
    ]);
    return response.data;
  } catch (error) {
    console.error('Error fetching response:', error);
    throw error;
  }
}


// 获取发送者ID
function getSenderID() {
  console.log(process.argv);
  const arg = process.argv[1];
  return arg
}

// 推送消息
function push(imType, groupCode, userID, title, content) {
  return accessLocalService(`/push?imtype=${imType}&groupcode=${groupCode}&userid=${userID}&title=${title}&content=${content}`, 5000,);
}

// 获取机器人名称
function name() {
  return accessLocalService(`/name`, 5000);
}

// 获取机器id
function machineId() {
  return accessLocalService(`/machineId`, 5000);
}

// 获取机器人版本
function version() {
  return accessLocalService(`/version`, 5000);
}

// 获取数据库数据
function get(key) {
  return accessLocalService(`/get?key=${key}`, 5000);
}

// 设置数据库数据
function set(key, value) {
  return accessLocalService(`/set?key=${key}&value=${value}`, 5000);
}

// 删除数据库数据
function del(key) {
  return accessLocalService(`/del?key=${key}`, 5000);
}

// 获取指定数据库指定的key值
function bucketGet(bucket, key) {
  return accessLocalService(`/bucketGet?bucket=${bucket}&key=${key}`, 5000);
}

// 设置指定数据库指定的key值
function bucketSet(bucket, key, value) {
  return accessLocalService(`/bucketSet?bucket=${bucket}&key=${key}&value=${value}`, 5000);
}

// 删除指定数据库指定key的值
function bucketDel(bucket, key) {
  return accessLocalService(`/bucketDel?bucket=${bucket}&key=${key}`, 5000);
}

// 获取指定数据库所有值为value的keys
function bucketKeys(bucket, value) {
  keys = accessLocalService(`/bucketKeys?bucket=${bucket}&value=${value}`, 5000);
  return keys.split(",");
}

// 获取指定数据桶内所有的key集合
function bucketAllKeys(bucket) {
  keys = accessLocalService(`/bucketAllKeys?bucket=${bucket}`, 5000);
  return keys.split(",");
}

// 通知管理员
function notifyMasters(content, imtypes) {
  return accessLocalService(`/notifyMasters?content=${content}&imtypes=${imtypes}`, 5000);
}

// 当前系统咖啡码激活状态
function coffee() {
  return accessLocalService(`/coffee`, 5000);
}

// 京东、淘宝、拼多多转链推广
function spread(msg) {
  return accessLocalService(`/spread?msg=${msg}`, 5000);
}

class Sender {
  constructor(senderID) {
    // 发送者ID,格式：in64时间戳,
    this.senderID = senderID;

    // 获取发送者渠道
    this.getImtype = function () {
      accessLocalService(`/getImtype?senderid=${senderID}`, 5000);
    }

    // 获取当前用户id
    this.getUserID = function () {
      return accessLocalService(`/getUserID?senderid=${senderID}`, 5000);
    }

    // 获取当前用户名
    this.getUserName = function () {
      return accessLocalService(`/getUserName?senderid=${senderID}`, 5000);
    }

    // 获取用户头像url
    this.getUserAvatarUrl = function () {
      return accessLocalService(`/getUserAvatarUrl?senderid=${senderID}`, 5000);
    }

    // 获取当前群组id
    this.getGroupID = function () {
      return accessLocalService(`/getGroupID?senderid=${senderID}`, 5000);
    }

    // 获取当前群组名称
    this.getGroupName = function () {
      return accessLocalService(`/getGroupName?senderid=${senderID}`, 5000);
    }

    // 是否管理员
    this.isAdmin = function () {
      return "true" == accessLocalService(`/isAdmin?senderid=${senderID}`, 5000);
    }

    // 获取消息
    this.getMessage = function () {
      return accessLocalService(`/getMessage?senderid=${senderID}`, 5000);
    }

    // 获取消息ID
    this.getMessageID = function () {
      return accessLocalService(`/getMessageID?senderid=${senderID}`, 5000);
    }

    // 撤回消息
    this.recallMessage = function (messageid) {
      accessLocalService(`/recallMessage?senderid=${senderID}&id=${messageid}`, 5000);
    }


    // 获取匹配的文本参数
    this.param = function (index) {
      return accessLocalService(`/param?senderid=${senderID}&index=${index}`, 5000);
    }

    // 回复文本消息
    this.reply = function (text) {
      accessLocalService(`/sendText?senderid=${senderID}&text=${text}`, 5000);
    }

    // 回复图片消息
    this.replyImage = function (imageUrl) {
      accessLocalService(`/sendImage?senderid=${senderID}&imageurl=${imageUrl}`, 5000);
    }

    // 回复语音消息
    this.replyVoice = function (voiceUrl) {
      accessLocalService(`/sendVoice?senderid=${senderID}&voiceurl=${voiceUrl}`, 5000);
    }

    // 回复视频消息
    this.replyVideo = function (videoUrl) {
      accessLocalService(`/sendVideo?senderid=${senderID}&videourl=${videoUrl}`, 5000);
    }

    //等待用户输入
    this.listen = function (timeout) {
      accessLocalService(`/listen?senderid=${senderID}&timeout=${timeout}`, timeout);
    }

    //等待支付
    this.waitPay = function (exitcode,timeout) {
      accessLocalService(`/waitPay?senderid=${senderID}&exitcode=${exitcode}&timeout=${timeout}`, timeout);
    }

    //是否处于等待支付状态
    this.atWaitPay = function () {
      return "true" == accessLocalService(`/atWaitPay`, 5000);
    }

    //邀请入群
    this.groupInviteIn = function (friend,group) {
      accessLocalService(`/groupInviteIn?senderid=${senderID}&friend=${friend}&group=${group}`, 5000);
    }

    //踢群
    this.groupKick = function (userid) {
      accessLocalService(`/groupKick?senderid=${senderID}&userid=${userid}`, 5000);
    }

    //禁言
    this.groupBan = function (userid,timeout) {
      accessLocalService(`/groupBan?senderid=${senderID}&userid=${userid}&timeout=${timeout}`, 5000);
    }

    //解除禁言
    this.groupUnban = function (userid) {
      accessLocalService(`/groupUnban?senderid=${senderID}&userid=${userid}`, 5000);
    }

    //全员禁言
    this.groupWholeBan=function(){
      accessLocalService(`/groupWholeBan?senderid=${senderID}`, 5000);
    }

    //解除全员禁言
    this.groupWholeUnban=function(){
      accessLocalService(`/groupWholeUnban?senderid=${senderID}`, 5000);
    }

    //发送群公告
    this.groupNoticeSend=function(notice){
      accessLocalService(`/groupNoticeSend?senderid=${senderID}&notice=${notice}`, 5000);
    }

    //获取当前处理流程的插件名
    this.getPluginName = function () {
      return accessLocalService(`/getPluginName?senderid=${senderID}`, 5000);
    }

    //获取当前处理流程的插件版本
    this.getPluginVersion = function () {
      return accessLocalService(`/getPluginVersion?senderid=${senderID}`, 5000);
    }
    
  };
}

module.exports = {
  Sender,
  getSenderID: getSenderID,
  push: push,
  name: name,
  machineId: machineId,
  version: version,
  get: get,
  set: set,
  del: del,
  bucketGet: bucketGet,
  bucketSet: bucketSet,
  bucketDel: bucketDel,
  bucketKeys: bucketKeys,
  bucketAllKeys: bucketAllKeys,
  notifyMasters: notifyMasters,
  coffee: coffee,
  spread: spread,
}