用 JavaScript 开发 Slack ChatGPT 机器人（含全部源码，免费托管，手把手教程）

1// 引入 AirCode.io 的依赖，其中包括数据库及文件存储的方法
2const aircode = require('aircode');
3
4// 引入 axios，用来发起 http request
5const axios = require('axios');
6
7// 引入 OpenAI 的 SDK
8const openai = require("openai");
9
10// 引入 Slack 的 SDK，相关文档 https://slack.dev/node-slack-sdk/
11const { WebClient } = require('@slack/web-api');
12
13// 从环境变量中获取 Slack 机器人的 Token
14const slackBotToken = process.env.SlackBotToken;
15if (!slackBotToken) return { error: '请根据教程配置 Slack 机器人的 Token。' };
16const slackClient = new WebClient(slackBotToken);
17
18// 从环境变量中获取 OpenAI 的 Secret
19const OpenAISecret = process.env.OpenAISecret;
20let chatGPT = null;
21if (OpenAISecret) {
22  const configuration = new openai.Configuration({ apiKey: OpenAISecret });
23  const client = new openai.OpenAIApi(configuration);
24
25  // 与 ChatGTP 聊天的方法，传入字符串即可
26  chatGPT = async (content) => {
27    return await client.createChatCompletion({
28      // 使用当前 OpenAI 开放的最新 3.5 模型，如果后续 4 发布，则修改此处参数即可
29      // OpenAI models 参数列表 https://platform.openai.com/docs/models
30      model: 'gpt-3.5-turbo',
31      // 让 ChatGPT 充当的角色为 assistant
32      messages: [{ role: 'assistant', content }],
33    });
34  };
35}
36
37// Slack ChatGPT 机器人的入口函数
38module.exports = async function(params, context) {
39
40  // 所有调用当前函数的参数都可以直接从 params 中获取
41  // 用来做 Slack 事件 Request 校验，要求有 challenge 参数时需直接返回
42  if (params.challenge) return { challenge: params.challenge };
43  
44  // Slack 机器人每条用户消息都会有 client_msg_id
45  const msgId = params.event.client_msg_id;
46
47  // 可以使用数据库极其简单地写入数据到数据表中
48  // 实例化一个名字叫做 contents 的表
49  const contentsTable = aircode.db.table('contents');
50  
51  // 搜索 contents 表中是否有 msgId 与当前这次一致的
52  const contentObj = await contentsTable.where({ msgId }).findOne();
53
54  // 如果 contentObj 有值，则代表这条 event 出现过
55  // 由于 ChatGPT 返回时间较长，这种情况可能是 Slack 的重试，直接 return 掉，防止重复调用
56  // 当当前环境为 DEBUG 环境时，这条不生效，方便调试
57  if (contentObj && context.trigger !== 'DEBUG') return;
58  
59  // 获取用户发送给机器人的信息内容，去掉 at 字符部分
60  const message = params.event.text.replace(/<@.*?>\s*/,'');
61
62  // 获取发送消息的人信息
63  const senderId = params.event.user;
64
65  // 返回给用户的消息
66  let replyContent = '';
67
68  // 判断是否有其他类型文件（如：图片），目前 ChatGPT 仅支持文本内容
69  if (!params.event.files) {
70
71    // 默认将用户发送的内容回复给用户，仅是一个直接返回对话的机器人
72    replyContent = message;    
73
74    // 将消息体信息储存到数据库中，以备后续查询历史或做上下文支持使用
75    await contentsTable.save({ msgId, senderId, message });
76
77    // 如果配置了 OpenAI Key 则让 ChatGPT 回复
78    if (OpenAISecret) {
79      
80      // 将用户具体消息发送给 ChatGPT
81			try {
82	      const result = await chatGPT(content);
83
84				// 将获取到的 ChatGPT 回复给用户
85	      replyContent = `${result.data.choices[0].message.content.trim()}`;
86			} catch (err) {
87				err = err.toJSON();
88				if (err.status === 401) return {
89					error: 'OpenAI ChatGPT 返回 401 错误，应该是你配置错了 OpenAI 平台的 Secret Token，请重新配置。' };
90				if (err.status === 429) return {
91					error: 'OpenAI ChatGPT 的 API 返回 429 错误，可能是你的额度已耗尽，你需要去 OpenAI 付费充值你的 API 配额。付费购买的 ChatGPT Plus 仅是网页版，API 需要另外充值。' };
92				return err.message;
93			}      
94    }
95
96  } else {
97    replyContent = '不好意思，暂时不支持其他类型的文件。';
98  }
99  
100  // 将处理后的消息通过 Slack 机器人发送给用户
101  await slackClient.chat.postMessage({
102    channel: params.event.channel,
103    text: `<@${senderId}> ${replyContent}`,
104    thread_ts: params.event.ts,
105    reply_broadcast: true,
106  });
107
108  // 整个函数调用结束，需要有返回
109  return null;
110};
111