feature: core 文件操作 uploadFileAndSend.js to #31

src/core/uploadFileAndSend.js

@@ -0,0 +1,57 @@
+const { errCodeMap } = require('../util/errCode');
+const axios = require('axios').default;
+let URL;
+if (!process.browser) {
+    ({ URL } = require('url'));
+} else {
+    URL = window.URL;
+}
+const errorHandler = require('../util/errorHandler');
+const FormData = require('form-data');
+
+
+/**
+ * @description 上传文件至服务器并发送，返回文件 id
+ * @param {string}  baseUrl    mirai-api-http server 的地址
+ * @param {string}  sessionKey 会话标识
+ * @param {string}  type       "friend" 或 "group"，目前仅支持 group
+ * @param {string}  path       上传目录
+ * @param {Buffer}  file       文件二进制数据
+ * @returns {string} 文件 id
+ */
+module.exports = async ({ baseUrl, sessionKey, type, path, file }) => {
+    try {
+        // 拼接 url
+        const targetUrl = new URL('/uploadFileAndSend', baseUrl).toString();
+
+        // 构造 fromdata
+        const form = new FormData();
+        form.append('sessionKey', sessionKey);
+        form.append('type', type);
+        form.append('path', path);
+        form.append('file', file);
+
+        // 请求
+        const responseData = await axios.post(targetUrl, form, {
+            // formdata.getHeaders 将会指定 content-type，同时给定随
+            // 机生成的 boundary，即分隔符，用以分隔多个表单项而不会造成混乱
+            headers: form.getHeaders(),
+        });
+
+        try {
+            var {
+                data: { msg: message, code, id }
+            } = responseData;
+        } catch (error) {
+            throw new Error('core.uploadFileAndSend 请求返回格式出错，请检查 mirai-console');
+        }
+
+        // 抛出 mirai 的异常，到 catch 中处理后再抛出
+        if (code in errCodeMap) {
+            throw new Error(message);
+        }
+        return id;
+    } catch (error) {
+        errorHandler(error);
+    }
+};