nicdex/node-eventstore-client
1
0
Fork 0
Code Issues Pull Requests Releases Wiki Activity

Re-add optional (allowing null) on ResolvedEvent event property in protobuf

Browse Source
This commit is contained in:
Nicolas Dextraze
2018-10-27 15:50:11 -07:00
parent 760d31cc31
commit a0642ab081
1 changed files with 4 additions and 5 deletions
Download Patch File Download Diff File Expand all files Collapse all files

9
src/messages/messages.js
View File

@@ -841,7 +841,6 @@
if (!(reader instanceof $Reader)) if (!(reader instanceof $Reader))
reader = $Reader.create(reader); reader = $Reader.create(reader);
var end = length === undefined ? reader.len : reader.pos + length, message = new $root.EventStore.Client.Messages.ResolvedIndexedEvent(); var end = length === undefined ? reader.len : reader.pos + length, message = new $root.EventStore.Client.Messages.ResolvedIndexedEvent();
message.event = null;
while (reader.pos < end) { while (reader.pos < end) {
var tag = reader.uint32(); var tag = reader.uint32();
switch (tag >>> 3) { switch (tag >>> 3) {
@@ -856,8 +855,8 @@
break; break;
} }
} }
if (!message.hasOwnProperty("event")) //if (!message.hasOwnProperty("event"))
throw $util.ProtocolError("missing required 'event'", { instance: message }); // throw $util.ProtocolError("missing required 'event'", { instance: message });
return message; return message;
}; };
@@ -1082,8 +1081,8 @@
break; break;
} }
} }
if (!message.hasOwnProperty("event")) //if (!message.hasOwnProperty("event"))
throw $util.ProtocolError("missing required 'event'", { instance: message }); // throw $util.ProtocolError("missing required 'event'", { instance: message });
if (!message.hasOwnProperty("commitPosition")) if (!message.hasOwnProperty("commitPosition"))
throw $util.ProtocolError("missing required 'commitPosition'", { instance: message }); throw $util.ProtocolError("missing required 'commitPosition'", { instance: message });
if (!message.hasOwnProperty("preparePosition")) if (!message.hasOwnProperty("preparePosition"))