handles.js

/**
 * 获取时间戳
 * @returns {string} - timestamp
 */
const handleTimeStap = () => {
  return new Date().getTime();
};

/**
 * 生成随机字符串
 * @returns {string} - nonce
 *
 */
const handleBase64 = () => {
  const nonce = btoa(
    new Uint8Array(21).reduce(
      (data) => data + String.fromCharCode(Math.floor(Math.random() * 256)),
      ""
    )
  );
  return nonce.substring(0, 21);
};

/**
 * 全局异常处理
 * @param {Koa.ParameterizedContext} ctx
 * @param {Koa.Next} next
 */
const handleErrors = async (ctx, next) => {
  try {
    await next();
  } catch (err) {
    console.error("Error:", err.message);
    ctx.status
      ? (ctx.body = `${ctx.status} - ${ctx.message}`)
      : (ctx.body = "500 - Internal Server Error");
  }
};

/**
 * 清除上下文消息
 * @param {Object} params
 * @param {String} sessionid
 */
const handleNewSession = async (params, sessionid) => {
  await fetch("https://www.coze.com/api/conversation/break_message", {
    method: "POST",
    headers: {
      "Content-Type": "application/json",
      Cookie: `sessionid=${sessionid}`,
      "User-Agent":
        "Mozilla/5.0 (Macintosh; Intel Mac OS X 10_15_7) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/122.0.0.0 Safari/537.36",
    },
    body: JSON.stringify(params),
    credentials: "include",
  });
  await fetch("https://www.coze.com/api/conversation/create_section", {
    method: "POST",
    headers: {
      "Content-Type": "application/json",
      Cookie: `sessionid=${sessionid}`,
      "User-Agent":
        "Mozilla/5.0 (Macintosh; Intel Mac OS X 10_15_7) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/122.0.0.0 Safari/537.36",
    },
    body: JSON.stringify({
      conversation_id: params.conversation_id,
      scene: params.scene,
    }),
    credentials: "include",
  });
};

/**
 * 初始化请求参数
 * @param {Object} params
 */
const initParams = async (params) => {
  params.bot_id = "7337496580645339154";
  params.conversation_id =
    "7337495393033765890_7337496580645339154_2_" + handleTimeStap();
  params.local_message_id = handleBase64();
  params.query = "";
  params.bot_version = "1709039055567";
  params.chat_history = [];
  params.insert_history_message_list = [];
  params.stream = true;
  params.scene = 2;
  params.content_type = "text";
  params.extra = {};
};

export {
  handleTimeStap,
  handleBase64,
  handleNewSession,
  handleErrors,
  initParams,
};