Dart json.encode 未按照 Firebase Function 的需要进行编码

Question

我已经研究这个问题一段时间了，我似乎无法弄清楚问题到底是什么。在 Dart(2( 中，json.encode()似乎没有给我我想要的结果。

我正在传递一个看起来像这样的Map<String, dynamic>：

_data = <String, dynamic>{
'uid': newProfileCreationModel.accountID,
'displayName': newProfileCreationModel.profileName,
'greeting': newProfileCreationModel.profileBody ?? '',
'avatarSrc': newProfileCreationModel.avatarSrc,
'heroSrc': newProfileCreationModel.heroSrc,
'accountType': newProfileCreationModel.accountType,
'cityID': newProfileCreationModel.cityID,
'cityName': newProfileCreationModel.cityName,
'country': newProfileCreationModel.countryCode,
'state': newProfileCreationModel.stateAbv,
};

并使用它来将其转换为 JSON

final String _jsonData = json.encode(_data);

然后我通过以下方式将其发送到谷歌云功能。

final Uri _uri = Uri.parse(functionUrl);
final String _jsonData = json.encode(_data);
final String _userToken = await AuthenticationService.getUserToken();
HttpClient client = new HttpClient();
HttpClientRequest request = await client.postUrl(_uri);
request.headers.set('Authorization', 'Bearer ' + _userToken);
request.headers.set('Content-Type', 'application/json; charset=utf-8');
print('Encoded: ' + _jsonData);
request.write(_jsonData);
HttpClientResponse response = await request.close();
if(response.statusCode != HttpStatus.OK){ ...

我打印编码字符串的行将其输出到控制台：

05-04 18:52:57.902 26146-26200/com.app.name I/flutter: Encoded: {"uid":'123456789',"displayName":"James","greeting":"My Greetings!","avatarSrc":"http://cdn.free.com/someImage.jpg","heroSrc":"http://cdn.free.com/someImage.jpg","accountType":"per","cityID":1,"cityName":"Eugene","country":"US","state":"OR"}

但是，request.write(_jsonData)失败并显示以下 Firebase 控制台日志错误请求正文缺少数据

在Firebase 控制台日志。

Request body is missing data.  { 
uid: '123456789',
displayName: 'James',
greeting: 'My Greetings!',
avatarSrc: 'http://cdn.free.com/someImage.jpg',
heroSrc: 'http://cdn.free.com/someImage.jpg',   accountType: 'per',   
cityID: 1,
cityName: 'Eugene',   
country: 'US',
state: 'OR' 
}

Invalid request IncomingMessage {
_readableState: 
ReadableState {
objectMode: false,
highWaterMark: 16384,
buffer: BufferList { head: null, tail: null, length: 0 },
length: 0,
pipes: null,
pipesCount: 0,
flowing: true,
ended: true,
endEmitted: true,
reading: false,
sync: false,
needReadable: false,
emittedReadable: false,
readableListening: false,
resumeScheduled: false,
defaultEncoding: 'utf8',
ranOut: false,
awaitDrain: 0,
readingMore: false,
decoder: null,
encoding: null },
readable: false,
domain: null,
_events: {},
_eventsCount: 0,
_maxListeners: undefined,
socket: 
Socket {
connecting: false,
_hadError: false,
_handle: 
TCP {
bytesRead: 13285,
_externalStream: {},
fd: 14,
reading: true,
owner: [Circular],
onread: [Function: onread],
onconnection: null,
writeQueueSize: 0,
_consumed: true },
_parent: null,
_host: null,

有趣的是，数据正在通过，就像Firebase控制台日志中清楚地显示的那样，但是它不会将其识别为正文。

原始数据方法

当我尝试通过request.write()发送原始 JSON 对象时

request.write({'hello':'universe'});

我在Firebase控制台中遇到了完全不同的错误。

SyntaxError: Unexpected token h in JSON at position 1
at Object.parse (native)
at parse (/var/tmp/worker/node_modules/body-parser/lib/types/json.js:84:17)
at /var/tmp/worker/node_modules/body-parser/lib/read.js:102:18
at IncomingMessage.onEnd (/var/tmp/worker/node_modules/raw-body/index.js:149:7)
at IncomingMessage.g (events.js:292:16)
at emitNone (events.js:86:13)
at IncomingMessage.emit (events.js:185:7)
at endReadableNT (_stream_readable.js:974:12)
at _combinedTickCallback (internal/process/next_tick.js:80:11)
at process._tickDomainCallback (internal/process/next_tick.js:128:9)

在火碱端，我正在使用一个使用可调用的函数，这是记录火碱控制台日志的地方

export const finalizeProfile = functions.https.onCall((data, context) => { 
//CODE 
});

有人能够发现我可能做错了什么吗？

Answer 1

解决方案隐藏在众目睽睽之下。该问题与缺少字段有关。对于Firebase Cloud Functions，错误消息body is missing data中提到的内容"body"字面意思是它需要一个名为data的键，其中包含您正在传递的数据对象。

谷歌文档对此并不十分清楚，因为它们缺少一个示例 https://firebase.google.com/docs/functions/callable-reference#request_body

这就是数据必须发送到functions.https.onCall()的方式，请注意数据字段与不包括以下内容的原始问题相比：

{
"data":{ 
"uid":"123456789",
"displayName":"James",
"greeting":"My Greeting!",
"avatarSrc":"http://cdn.free.com/someImage.jpg",
"heroSrc":"http://cdn.free.com/someImage.jpg",
"accountType":"per",
"cityID":1,
"cityName":"Eugene",
"country":"OR",
"state":"AL"
}
}

现在工作的结果代码如下所示：

// Helper function to format any map to be used for Firebase
Map prepMapForFirebaseJSON(Map<String, dynamic> mapData){
Map<String, Map<String, dynamic>> _fireJson = {
'data' : mapData
};
return _fireJson;
}
// Process HTTP request
final Uri _uri = Uri.parse(functionUrl);
final String _jsonData = json.encode(prepMapForFirebaseJSON(mapData));
final String _userToken = await AuthenticationService.getUserToken();
HttpClient client = new HttpClient();
HttpClientRequest request = await client.postUrl(_uri);
request.headers.set('Authorization', 'Bearer ' + _userToken);
request.headers.set('Content-Type', 'application/json; charset=utf-8');
request.write(_jsonData);
request.close();

Answer 2

我认为缺少关闭请求：

request.write(_jsonData);
var response = await request.close();