5925c2fe84
Protocol and handling is all analogous to contact sync: Multiple GroupDetails structs are packed into a single attachment blob and parsed on our end. We don't display the synced groups in the conversation list until a new message is sent to one of them. // FREEBIE
52 lines
1.7 KiB
JavaScript
52 lines
1.7 KiB
JavaScript
/*
|
|
* vim: ts=4:sw=4:expandtab
|
|
*/
|
|
|
|
function ProtoParser(arrayBuffer, protobuf) {
|
|
this.protobuf = protobuf;
|
|
this.buffer = new dcodeIO.ByteBuffer();
|
|
this.buffer.append(arrayBuffer);
|
|
this.buffer.offset = 0;
|
|
this.buffer.limit = arrayBuffer.byteLength;
|
|
}
|
|
ProtoParser.prototype = {
|
|
constructor: ProtoParser,
|
|
next: function() {
|
|
try {
|
|
if (this.buffer.limit === this.buffer.offset) {
|
|
return undefined; // eof
|
|
}
|
|
var len = this.buffer.readVarint32();
|
|
var nextBuffer = this.buffer.slice(
|
|
this.buffer.offset, this.buffer.offset+len
|
|
).toArrayBuffer();
|
|
// TODO: de-dupe ByteBuffer.js includes in libaxo/libts
|
|
// then remove this toArrayBuffer call.
|
|
|
|
var proto = this.protobuf.decode(nextBuffer);
|
|
this.buffer.skip(len);
|
|
|
|
if (proto.avatar) {
|
|
var attachmentLen = proto.avatar.length;
|
|
proto.avatar.data = this.buffer.slice(
|
|
this.buffer.offset, this.buffer.offset + attachmentLen
|
|
).toArrayBuffer();
|
|
this.buffer.skip(attachmentLen);
|
|
}
|
|
|
|
return proto;
|
|
} catch(e) {
|
|
console.log(e);
|
|
}
|
|
}
|
|
};
|
|
var GroupBuffer = function(arrayBuffer) {
|
|
ProtoParser.call(this, arrayBuffer, textsecure.protobuf.GroupDetails);
|
|
};
|
|
GroupBuffer.prototype = Object.create(ProtoParser.prototype);
|
|
GroupBuffer.prototype.constructor = GroupBuffer;
|
|
var ContactBuffer = function(arrayBuffer) {
|
|
ProtoParser.call(this, arrayBuffer, textsecure.protobuf.ContactDetails);
|
|
};
|
|
ContactBuffer.prototype = Object.create(ProtoParser.prototype);
|
|
ContactBuffer.prototype.constructor = ContactBuffer;
|