获取错误:uncaughtException:当对多部分/表单数据使用request和multiparty时，sourc

Question

我正试图将数据从节点应用程序发送到第三方HTTP端点。

我使用多方模块解析来自客户端的请求对象上的数据，并通过请求模块发送数据。我得到错误

错误：uncaughtException：source.on不是函数

var request = require('request');
const multiparty = require('multiparty');
function addAttachment(req, res) {
let form = new multiparty.Form();
let parsedFile = {};
const formData = {};
form.parse(req, function(err, fields, files){
Object.keys(fields).forEach(function(name) {
formData[name] = fields[name][0];
});
Object.keys(files).forEach(function(name) {
logger.debug(name);
parsedFile[name] = files[name][0];
});
formData.uploadFile = parsedFile.uploadFile;
logger.debug('formData ', formData);
reqOptions.url = imageURL;
reqOptions.formData = formData;
logger.debug('REQ_OPTIONS ', reqOptions);
request.post(reqOptions, function (err, response, body) {
if (err) {
logger.warn(req, ' Error sending attachment', err);
res.status(400);
res.json({ "msg": "Error sending attachment" });
} else {
res.status(201);
logger.debug('BODY ', body);
res.send(body);
}
});
});
}

reqOptionsobj包含头、url、auth-obj，然后我们将表单数据添加到其中。

当我记录表单数据时，它看起来是正确的格式

{
"meta": {
"prop1": "xxxxxx",
"prop2": "xxxxxxxxxxxxx",
"uploadFile": {
"fieldName": "uploadFile",
"originalFilename": "test.PNG",
"path": "/tmp/W1IppPiK04JpkPrnZWEhzkmV.PNG",
"headers": {
"content-disposition": "form-data; name="uploadFile"; filename="test.PNG"",
"content-type": "image/png"
},
"size": 42786
}
}

}

Answer 1

这个错误可能是错误消息完全具有误导性的最好例子之一。因此对这个问题进行RCA是非常令人沮丧的

ERROR: uncaught Exception: source.on is not a function

实际上这里没有任何函数。在我的案例中，我花了几个小时挠头，最后发现它是另一个JSON下的JSON，导致了这个错误：

let subJson = 
{
field1: "value1",
field2: "value2"
}
let myJson = 
{
field1: "value1",
field2: "value2",
field3: subJson
}
createFormData(myJson);

就是这样！当您使用myJson作为参数调用createFormData时，您将看到异常source.on is not a function！我们一直在想这个函数在哪里？

解决方案为JSON.stringify

field3: JSON.stringify(subJson)

将解决此问题。

javascript！

Answer 2

因此，经过一番努力，我能够将表单数据发布到外部API。我决定将我使用的节点模块更改为connect-multiparty。Connect将解析请求标头并解码后表单数据，从而允许您访问reqobj E.G中的数据。req.body现在已添加属性，req.files已上载文件。

const multipart = require('connect-multiparty');
const multipartMiddleware = multipart();

然后将multipartMiddleware添加到路由中。

app.post('/api/addAttachment' multipartMiddleware, MyController.addAttachment);

然后，在我的控制器文件中，我将代码更改为使用connect-multipart。

const fs = require('fs');
var request = require('request');  
function addAttachment(req, res) {
const TMP = '/tmp';
let formData = {};
Object.keys(req.body).forEach((propName) =>{
if (typeof propName === 'string') {
logger.debug(propName, ' is a string');
formData[propName] = req.body[propName];
} else {
logger.debug(propName, ' is not a string')
}
});
//The files get added to the tmp folder on the files system,
//So we create a stream to read from tmp folder, 
//at the end end we need to delete the file
formData['uploadFile'] = fs.createReadStream(req.files.uploadFile.path);
logger.debug('FORM DATA ', formData, 'n');
reqOptions.url = imageUrl;
reqOptions.headers = {'Content-Type': 'multipart/form-data','Accept': 'application/json'};
reqOptions.formData = formData;
logger.debug('REQ_OPTIONS ', reqOptions, 'n');
request.post(reqOptions, function (err, response, body) {
if (err) {
removeFiles(TMP);
logger.warn(req, ' Error sending attachment', err);
res.status(400);
res.json({"msg": "Error sending attachment"});
} else {
removeFiles(TMP);
res.status(201);
logger.debug('BODY ', body);
res.send(body);
}
});
}