diff --git a/src/core/engines/gows/grpc/gows.ts b/src/core/engines/gows/grpc/gows.ts index 4941c0f0..bdbe7879 100644 --- a/src/core/engines/gows/grpc/gows.ts +++ b/src/core/engines/gows/grpc/gows.ts @@ -3901,6 +3901,145 @@ export namespace messages { return CheckPhonesResponse.deserialize(bytes); } } + export class RevokeMessageRequest extends pb_1.Message { + #one_of_decls: number[][] = []; + constructor(data?: any[] | { + session?: Session; + jid?: string; + sender?: string; + messageId?: string; + }) { + super(); + pb_1.Message.initialize(this, Array.isArray(data) ? data : [], 0, -1, [], this.#one_of_decls); + if (!Array.isArray(data) && typeof data == "object") { + if ("session" in data && data.session != undefined) { + this.session = data.session; + } + if ("jid" in data && data.jid != undefined) { + this.jid = data.jid; + } + if ("sender" in data && data.sender != undefined) { + this.sender = data.sender; + } + if ("messageId" in data && data.messageId != undefined) { + this.messageId = data.messageId; + } + } + } + get session() { + return pb_1.Message.getWrapperField(this, Session, 1) as Session; + } + set session(value: Session) { + pb_1.Message.setWrapperField(this, 1, value); + } + get has_session() { + return pb_1.Message.getField(this, 1) != null; + } + get jid() { + return pb_1.Message.getFieldWithDefault(this, 2, "") as string; + } + set jid(value: string) { + pb_1.Message.setField(this, 2, value); + } + get sender() { + return pb_1.Message.getFieldWithDefault(this, 3, "") as string; + } + set sender(value: string) { + pb_1.Message.setField(this, 3, value); + } + get messageId() { + return pb_1.Message.getFieldWithDefault(this, 4, "") as string; + } + set messageId(value: string) { + pb_1.Message.setField(this, 4, value); + } + static fromObject(data: { + session?: ReturnType; + jid?: string; + sender?: string; + messageId?: string; + }): RevokeMessageRequest { + const message = new RevokeMessageRequest({}); + if (data.session != null) { + message.session = Session.fromObject(data.session); + } + if (data.jid != null) { + message.jid = data.jid; + } + if (data.sender != null) { + message.sender = data.sender; + } + if (data.messageId != null) { + message.messageId = data.messageId; + } + return message; + } + toObject() { + const data: { + session?: ReturnType; + jid?: string; + sender?: string; + messageId?: string; + } = {}; + if (this.session != null) { + data.session = this.session.toObject(); + } + if (this.jid != null) { + data.jid = this.jid; + } + if (this.sender != null) { + data.sender = this.sender; + } + if (this.messageId != null) { + data.messageId = this.messageId; + } + return data; + } + serialize(): Uint8Array; + serialize(w: pb_1.BinaryWriter): void; + serialize(w?: pb_1.BinaryWriter): Uint8Array | void { + const writer = w || new pb_1.BinaryWriter(); + if (this.has_session) + writer.writeMessage(1, this.session, () => this.session.serialize(writer)); + if (this.jid.length) + writer.writeString(2, this.jid); + if (this.sender.length) + writer.writeString(3, this.sender); + if (this.messageId.length) + writer.writeString(4, this.messageId); + if (!w) + return writer.getResultBuffer(); + } + static deserialize(bytes: Uint8Array | pb_1.BinaryReader): RevokeMessageRequest { + const reader = bytes instanceof pb_1.BinaryReader ? bytes : new pb_1.BinaryReader(bytes), message = new RevokeMessageRequest(); + while (reader.nextField()) { + if (reader.isEndGroup()) + break; + switch (reader.getFieldNumber()) { + case 1: + reader.readMessage(message.session, () => message.session = Session.deserialize(reader)); + break; + case 2: + message.jid = reader.readString(); + break; + case 3: + message.sender = reader.readString(); + break; + case 4: + message.messageId = reader.readString(); + break; + default: reader.skipField(); + } + } + return message; + } + serializeBinary(): Uint8Array { + return this.serialize(); + } + static deserializeBinary(bytes: Uint8Array): RevokeMessageRequest { + return RevokeMessageRequest.deserialize(bytes); + } + } export class NewsletterListRequest extends pb_1.Message { #one_of_decls: number[][] = []; constructor(data?: any[] | { @@ -6841,24 +6980,6 @@ export namespace messages { responseSerialize: (message: JsonList) => Buffer.from(message.serialize()), responseDeserialize: (bytes: Buffer) => JsonList.deserialize(new Uint8Array(bytes)) }, - SendMessage: { - path: "/messages.MessageService/SendMessage", - requestStream: false, - responseStream: false, - requestSerialize: (message: MessageRequest) => Buffer.from(message.serialize()), - requestDeserialize: (bytes: Buffer) => MessageRequest.deserialize(new Uint8Array(bytes)), - responseSerialize: (message: MessageResponse) => Buffer.from(message.serialize()), - responseDeserialize: (bytes: Buffer) => MessageResponse.deserialize(new Uint8Array(bytes)) - }, - SendReaction: { - path: "/messages.MessageService/SendReaction", - requestStream: false, - responseStream: false, - requestSerialize: (message: MessageReaction) => Buffer.from(message.serialize()), - requestDeserialize: (bytes: Buffer) => MessageReaction.deserialize(new Uint8Array(bytes)), - responseSerialize: (message: MessageResponse) => Buffer.from(message.serialize()), - responseDeserialize: (bytes: Buffer) => MessageResponse.deserialize(new Uint8Array(bytes)) - }, GetProfilePicture: { path: "/messages.MessageService/GetProfilePicture", requestStream: false, @@ -6895,6 +7016,33 @@ export namespace messages { responseSerialize: (message: Empty) => Buffer.from(message.serialize()), responseDeserialize: (bytes: Buffer) => Empty.deserialize(new Uint8Array(bytes)) }, + CheckPhones: { + path: "/messages.MessageService/CheckPhones", + requestStream: false, + responseStream: false, + requestSerialize: (message: CheckPhonesRequest) => Buffer.from(message.serialize()), + requestDeserialize: (bytes: Buffer) => CheckPhonesRequest.deserialize(new Uint8Array(bytes)), + responseSerialize: (message: CheckPhonesResponse) => Buffer.from(message.serialize()), + responseDeserialize: (bytes: Buffer) => CheckPhonesResponse.deserialize(new Uint8Array(bytes)) + }, + SendMessage: { + path: "/messages.MessageService/SendMessage", + requestStream: false, + responseStream: false, + requestSerialize: (message: MessageRequest) => Buffer.from(message.serialize()), + requestDeserialize: (bytes: Buffer) => MessageRequest.deserialize(new Uint8Array(bytes)), + responseSerialize: (message: MessageResponse) => Buffer.from(message.serialize()), + responseDeserialize: (bytes: Buffer) => MessageResponse.deserialize(new Uint8Array(bytes)) + }, + SendReaction: { + path: "/messages.MessageService/SendReaction", + requestStream: false, + responseStream: false, + requestSerialize: (message: MessageReaction) => Buffer.from(message.serialize()), + requestDeserialize: (bytes: Buffer) => MessageReaction.deserialize(new Uint8Array(bytes)), + responseSerialize: (message: MessageResponse) => Buffer.from(message.serialize()), + responseDeserialize: (bytes: Buffer) => MessageResponse.deserialize(new Uint8Array(bytes)) + }, MarkRead: { path: "/messages.MessageService/MarkRead", requestStream: false, @@ -6904,14 +7052,14 @@ export namespace messages { responseSerialize: (message: Empty) => Buffer.from(message.serialize()), responseDeserialize: (bytes: Buffer) => Empty.deserialize(new Uint8Array(bytes)) }, - CheckPhones: { - path: "/messages.MessageService/CheckPhones", + RevokeMessage: { + path: "/messages.MessageService/RevokeMessage", requestStream: false, responseStream: false, - requestSerialize: (message: CheckPhonesRequest) => Buffer.from(message.serialize()), - requestDeserialize: (bytes: Buffer) => CheckPhonesRequest.deserialize(new Uint8Array(bytes)), - responseSerialize: (message: CheckPhonesResponse) => Buffer.from(message.serialize()), - responseDeserialize: (bytes: Buffer) => CheckPhonesResponse.deserialize(new Uint8Array(bytes)) + requestSerialize: (message: RevokeMessageRequest) => Buffer.from(message.serialize()), + requestDeserialize: (bytes: Buffer) => RevokeMessageRequest.deserialize(new Uint8Array(bytes)), + responseSerialize: (message: MessageResponse) => Buffer.from(message.serialize()), + responseDeserialize: (bytes: Buffer) => MessageResponse.deserialize(new Uint8Array(bytes)) }, GetSubscribedNewsletters: { path: "/messages.MessageService/GetSubscribedNewsletters", @@ -7064,14 +7212,15 @@ export namespace messages { abstract SetGroupLocked(call: grpc_1.ServerUnaryCall, callback: grpc_1.sendUnaryData): void; abstract SetGroupAnnounce(call: grpc_1.ServerUnaryCall, callback: grpc_1.sendUnaryData): void; abstract UpdateGroupParticipants(call: grpc_1.ServerUnaryCall, callback: grpc_1.sendUnaryData): void; - abstract SendMessage(call: grpc_1.ServerUnaryCall, callback: grpc_1.sendUnaryData): void; - abstract SendReaction(call: grpc_1.ServerUnaryCall, callback: grpc_1.sendUnaryData): void; abstract GetProfilePicture(call: grpc_1.ServerUnaryCall, callback: grpc_1.sendUnaryData): void; abstract SendPresence(call: grpc_1.ServerUnaryCall, callback: grpc_1.sendUnaryData): void; abstract SendChatPresence(call: grpc_1.ServerUnaryCall, callback: grpc_1.sendUnaryData): void; abstract SubscribePresence(call: grpc_1.ServerUnaryCall, callback: grpc_1.sendUnaryData): void; - abstract MarkRead(call: grpc_1.ServerUnaryCall, callback: grpc_1.sendUnaryData): void; abstract CheckPhones(call: grpc_1.ServerUnaryCall, callback: grpc_1.sendUnaryData): void; + abstract SendMessage(call: grpc_1.ServerUnaryCall, callback: grpc_1.sendUnaryData): void; + abstract SendReaction(call: grpc_1.ServerUnaryCall, callback: grpc_1.sendUnaryData): void; + abstract MarkRead(call: grpc_1.ServerUnaryCall, callback: grpc_1.sendUnaryData): void; + abstract RevokeMessage(call: grpc_1.ServerUnaryCall, callback: grpc_1.sendUnaryData): void; abstract GetSubscribedNewsletters(call: grpc_1.ServerUnaryCall, callback: grpc_1.sendUnaryData): void; abstract GetNewsletterInfo(call: grpc_1.ServerUnaryCall, callback: grpc_1.sendUnaryData): void; abstract GetNewsletterMessagesByInvite(call: grpc_1.ServerUnaryCall, callback: grpc_1.sendUnaryData): void; @@ -7160,12 +7309,6 @@ export namespace messages { UpdateGroupParticipants: GrpcUnaryServiceInterface = (message: UpdateParticipantsRequest, metadata: grpc_1.Metadata | grpc_1.CallOptions | grpc_1.requestCallback, options?: grpc_1.CallOptions | grpc_1.requestCallback, callback?: grpc_1.requestCallback): grpc_1.ClientUnaryCall => { return super.UpdateGroupParticipants(message, metadata, options, callback); }; - SendMessage: GrpcUnaryServiceInterface = (message: MessageRequest, metadata: grpc_1.Metadata | grpc_1.CallOptions | grpc_1.requestCallback, options?: grpc_1.CallOptions | grpc_1.requestCallback, callback?: grpc_1.requestCallback): grpc_1.ClientUnaryCall => { - return super.SendMessage(message, metadata, options, callback); - }; - SendReaction: GrpcUnaryServiceInterface = (message: MessageReaction, metadata: grpc_1.Metadata | grpc_1.CallOptions | grpc_1.requestCallback, options?: grpc_1.CallOptions | grpc_1.requestCallback, callback?: grpc_1.requestCallback): grpc_1.ClientUnaryCall => { - return super.SendReaction(message, metadata, options, callback); - }; GetProfilePicture: GrpcUnaryServiceInterface = (message: ProfilePictureRequest, metadata: grpc_1.Metadata | grpc_1.CallOptions | grpc_1.requestCallback, options?: grpc_1.CallOptions | grpc_1.requestCallback, callback?: grpc_1.requestCallback): grpc_1.ClientUnaryCall => { return super.GetProfilePicture(message, metadata, options, callback); }; @@ -7178,11 +7321,20 @@ export namespace messages { SubscribePresence: GrpcUnaryServiceInterface = (message: SubscribePresenceRequest, metadata: grpc_1.Metadata | grpc_1.CallOptions | grpc_1.requestCallback, options?: grpc_1.CallOptions | grpc_1.requestCallback, callback?: grpc_1.requestCallback): grpc_1.ClientUnaryCall => { return super.SubscribePresence(message, metadata, options, callback); }; + CheckPhones: GrpcUnaryServiceInterface = (message: CheckPhonesRequest, metadata: grpc_1.Metadata | grpc_1.CallOptions | grpc_1.requestCallback, options?: grpc_1.CallOptions | grpc_1.requestCallback, callback?: grpc_1.requestCallback): grpc_1.ClientUnaryCall => { + return super.CheckPhones(message, metadata, options, callback); + }; + SendMessage: GrpcUnaryServiceInterface = (message: MessageRequest, metadata: grpc_1.Metadata | grpc_1.CallOptions | grpc_1.requestCallback, options?: grpc_1.CallOptions | grpc_1.requestCallback, callback?: grpc_1.requestCallback): grpc_1.ClientUnaryCall => { + return super.SendMessage(message, metadata, options, callback); + }; + SendReaction: GrpcUnaryServiceInterface = (message: MessageReaction, metadata: grpc_1.Metadata | grpc_1.CallOptions | grpc_1.requestCallback, options?: grpc_1.CallOptions | grpc_1.requestCallback, callback?: grpc_1.requestCallback): grpc_1.ClientUnaryCall => { + return super.SendReaction(message, metadata, options, callback); + }; MarkRead: GrpcUnaryServiceInterface = (message: MarkReadRequest, metadata: grpc_1.Metadata | grpc_1.CallOptions | grpc_1.requestCallback, options?: grpc_1.CallOptions | grpc_1.requestCallback, callback?: grpc_1.requestCallback): grpc_1.ClientUnaryCall => { return super.MarkRead(message, metadata, options, callback); }; - CheckPhones: GrpcUnaryServiceInterface = (message: CheckPhonesRequest, metadata: grpc_1.Metadata | grpc_1.CallOptions | grpc_1.requestCallback, options?: grpc_1.CallOptions | grpc_1.requestCallback, callback?: grpc_1.requestCallback): grpc_1.ClientUnaryCall => { - return super.CheckPhones(message, metadata, options, callback); + RevokeMessage: GrpcUnaryServiceInterface = (message: RevokeMessageRequest, metadata: grpc_1.Metadata | grpc_1.CallOptions | grpc_1.requestCallback, options?: grpc_1.CallOptions | grpc_1.requestCallback, callback?: grpc_1.requestCallback): grpc_1.ClientUnaryCall => { + return super.RevokeMessage(message, metadata, options, callback); }; GetSubscribedNewsletters: GrpcUnaryServiceInterface = (message: NewsletterListRequest, metadata: grpc_1.Metadata | grpc_1.CallOptions | grpc_1.requestCallback, options?: grpc_1.CallOptions | grpc_1.requestCallback, callback?: grpc_1.requestCallback): grpc_1.ClientUnaryCall => { return super.GetSubscribedNewsletters(message, metadata, options, callback); diff --git a/src/core/engines/gows/grpc/gows_grpc_pb.js b/src/core/engines/gows/grpc/gows_grpc_pb.js index 3b3ad5ec..fce36e6b 100644 --- a/src/core/engines/gows/grpc/gows_grpc_pb.js +++ b/src/core/engines/gows/grpc/gows_grpc_pb.js @@ -433,6 +433,17 @@ function deserialize_messages_ProfileStatusRequest(buffer_arg) { return gows_pb.ProfileStatusRequest.deserializeBinary(new Uint8Array(buffer_arg)); } +function serialize_messages_RevokeMessageRequest(arg) { + if (!(arg instanceof gows_pb.RevokeMessageRequest)) { + throw new Error('Expected argument of type messages.RevokeMessageRequest'); + } + return Buffer.from(arg.serializeBinary()); +} + +function deserialize_messages_RevokeMessageRequest(buffer_arg) { + return gows_pb.RevokeMessageRequest.deserializeBinary(new Uint8Array(buffer_arg)); +} + function serialize_messages_SearchNewslettersByTextRequest(arg) { if (!(arg instanceof gows_pb.SearchNewslettersByTextRequest)) { throw new Error('Expected argument of type messages.SearchNewslettersByTextRequest'); @@ -819,29 +830,7 @@ updateGroupParticipants: { // // Actions // -sendMessage: { - path: '/messages.MessageService/SendMessage', - requestStream: false, - responseStream: false, - requestType: gows_pb.MessageRequest, - responseType: gows_pb.MessageResponse, - requestSerialize: serialize_messages_MessageRequest, - requestDeserialize: deserialize_messages_MessageRequest, - responseSerialize: serialize_messages_MessageResponse, - responseDeserialize: deserialize_messages_MessageResponse, - }, - sendReaction: { - path: '/messages.MessageService/SendReaction', - requestStream: false, - responseStream: false, - requestType: gows_pb.MessageReaction, - responseType: gows_pb.MessageResponse, - requestSerialize: serialize_messages_MessageReaction, - requestDeserialize: deserialize_messages_MessageReaction, - responseSerialize: serialize_messages_MessageResponse, - responseDeserialize: deserialize_messages_MessageResponse, - }, - getProfilePicture: { +getProfilePicture: { path: '/messages.MessageService/GetProfilePicture', requestStream: false, responseStream: false, @@ -885,6 +874,42 @@ sendMessage: { responseSerialize: serialize_messages_Empty, responseDeserialize: deserialize_messages_Empty, }, + checkPhones: { + path: '/messages.MessageService/CheckPhones', + requestStream: false, + responseStream: false, + requestType: gows_pb.CheckPhonesRequest, + responseType: gows_pb.CheckPhonesResponse, + requestSerialize: serialize_messages_CheckPhonesRequest, + requestDeserialize: deserialize_messages_CheckPhonesRequest, + responseSerialize: serialize_messages_CheckPhonesResponse, + responseDeserialize: deserialize_messages_CheckPhonesResponse, + }, + // +// Message +// +sendMessage: { + path: '/messages.MessageService/SendMessage', + requestStream: false, + responseStream: false, + requestType: gows_pb.MessageRequest, + responseType: gows_pb.MessageResponse, + requestSerialize: serialize_messages_MessageRequest, + requestDeserialize: deserialize_messages_MessageRequest, + responseSerialize: serialize_messages_MessageResponse, + responseDeserialize: deserialize_messages_MessageResponse, + }, + sendReaction: { + path: '/messages.MessageService/SendReaction', + requestStream: false, + responseStream: false, + requestType: gows_pb.MessageReaction, + responseType: gows_pb.MessageResponse, + requestSerialize: serialize_messages_MessageReaction, + requestDeserialize: deserialize_messages_MessageReaction, + responseSerialize: serialize_messages_MessageResponse, + responseDeserialize: deserialize_messages_MessageResponse, + }, markRead: { path: '/messages.MessageService/MarkRead', requestStream: false, @@ -896,16 +921,16 @@ sendMessage: { responseSerialize: serialize_messages_Empty, responseDeserialize: deserialize_messages_Empty, }, - checkPhones: { - path: '/messages.MessageService/CheckPhones', + revokeMessage: { + path: '/messages.MessageService/RevokeMessage', requestStream: false, responseStream: false, - requestType: gows_pb.CheckPhonesRequest, - responseType: gows_pb.CheckPhonesResponse, - requestSerialize: serialize_messages_CheckPhonesRequest, - requestDeserialize: deserialize_messages_CheckPhonesRequest, - responseSerialize: serialize_messages_CheckPhonesResponse, - responseDeserialize: deserialize_messages_CheckPhonesResponse, + requestType: gows_pb.RevokeMessageRequest, + responseType: gows_pb.MessageResponse, + requestSerialize: serialize_messages_RevokeMessageRequest, + requestDeserialize: deserialize_messages_RevokeMessageRequest, + responseSerialize: serialize_messages_MessageResponse, + responseDeserialize: deserialize_messages_MessageResponse, }, // // Newsletters diff --git a/src/core/engines/gows/grpc/gows_pb.js b/src/core/engines/gows/grpc/gows_pb.js index 3dcfb6f5..e0a1245d 100644 --- a/src/core/engines/gows/grpc/gows_pb.js +++ b/src/core/engines/gows/grpc/gows_pb.js @@ -74,6 +74,7 @@ goog.exportSymbol('proto.messages.ProfilePictureRequest', null, global); goog.exportSymbol('proto.messages.ProfilePictureResponse', null, global); goog.exportSymbol('proto.messages.ProfileStatusRequest', null, global); goog.exportSymbol('proto.messages.ReceiptType', null, global); +goog.exportSymbol('proto.messages.RevokeMessageRequest', null, global); goog.exportSymbol('proto.messages.SearchNewslettersByTextRequest', null, global); goog.exportSymbol('proto.messages.SearchNewslettersByViewRequest', null, global); goog.exportSymbol('proto.messages.SearchPage', null, global); @@ -910,6 +911,27 @@ if (goog.DEBUG && !COMPILED) { */ proto.messages.CheckPhonesResponse.displayName = 'proto.messages.CheckPhonesResponse'; } +/** + * Generated by JsPbCodeGenerator. + * @param {Array=} opt_data Optional initial data array, typically from a + * server response, or constructed directly in Javascript. The array is used + * in place and becomes part of the constructed object. It is not cloned. + * If no data is provided, the constructed object will be empty, but still + * valid. + * @extends {jspb.Message} + * @constructor + */ +proto.messages.RevokeMessageRequest = function(opt_data) { + jspb.Message.initialize(this, opt_data, 0, -1, null, null); +}; +goog.inherits(proto.messages.RevokeMessageRequest, jspb.Message); +if (goog.DEBUG && !COMPILED) { + /** + * @public + * @override + */ + proto.messages.RevokeMessageRequest.displayName = 'proto.messages.RevokeMessageRequest'; +} /** * Generated by JsPbCodeGenerator. * @param {Array=} opt_data Optional initial data array, typically from a @@ -8789,6 +8811,247 @@ proto.messages.CheckPhonesResponse.prototype.clearInfosList = function() { +if (jspb.Message.GENERATE_TO_OBJECT) { +/** + * Creates an object representation of this proto. + * Field names that are reserved in JavaScript and will be renamed to pb_name. + * Optional fields that are not set will be set to undefined. + * To access a reserved field use, foo.pb_, eg, foo.pb_default. + * For the list of reserved names please see: + * net/proto2/compiler/js/internal/generator.cc#kKeyword. + * @param {boolean=} opt_includeInstance Deprecated. whether to include the + * JSPB instance for transitional soy proto support: + * http://goto/soy-param-migration + * @return {!Object} + */ +proto.messages.RevokeMessageRequest.prototype.toObject = function(opt_includeInstance) { + return proto.messages.RevokeMessageRequest.toObject(opt_includeInstance, this); +}; + + +/** + * Static version of the {@see toObject} method. + * @param {boolean|undefined} includeInstance Deprecated. Whether to include + * the JSPB instance for transitional soy proto support: + * http://goto/soy-param-migration + * @param {!proto.messages.RevokeMessageRequest} msg The msg instance to transform. + * @return {!Object} + * @suppress {unusedLocalVariables} f is only used for nested messages + */ +proto.messages.RevokeMessageRequest.toObject = function(includeInstance, msg) { + var f, obj = { + session: (f = msg.getSession()) && proto.messages.Session.toObject(includeInstance, f), + jid: jspb.Message.getFieldWithDefault(msg, 2, ""), + sender: jspb.Message.getFieldWithDefault(msg, 3, ""), + messageid: jspb.Message.getFieldWithDefault(msg, 4, "") + }; + + if (includeInstance) { + obj.$jspbMessageInstance = msg; + } + return obj; +}; +} + + +/** + * Deserializes binary data (in protobuf wire format). + * @param {jspb.ByteSource} bytes The bytes to deserialize. + * @return {!proto.messages.RevokeMessageRequest} + */ +proto.messages.RevokeMessageRequest.deserializeBinary = function(bytes) { + var reader = new jspb.BinaryReader(bytes); + var msg = new proto.messages.RevokeMessageRequest; + return proto.messages.RevokeMessageRequest.deserializeBinaryFromReader(msg, reader); +}; + + +/** + * Deserializes binary data (in protobuf wire format) from the + * given reader into the given message object. + * @param {!proto.messages.RevokeMessageRequest} msg The message object to deserialize into. + * @param {!jspb.BinaryReader} reader The BinaryReader to use. + * @return {!proto.messages.RevokeMessageRequest} + */ +proto.messages.RevokeMessageRequest.deserializeBinaryFromReader = function(msg, reader) { + while (reader.nextField()) { + if (reader.isEndGroup()) { + break; + } + var field = reader.getFieldNumber(); + switch (field) { + case 1: + var value = new proto.messages.Session; + reader.readMessage(value,proto.messages.Session.deserializeBinaryFromReader); + msg.setSession(value); + break; + case 2: + var value = /** @type {string} */ (reader.readString()); + msg.setJid(value); + break; + case 3: + var value = /** @type {string} */ (reader.readString()); + msg.setSender(value); + break; + case 4: + var value = /** @type {string} */ (reader.readString()); + msg.setMessageid(value); + break; + default: + reader.skipField(); + break; + } + } + return msg; +}; + + +/** + * Serializes the message to binary data (in protobuf wire format). + * @return {!Uint8Array} + */ +proto.messages.RevokeMessageRequest.prototype.serializeBinary = function() { + var writer = new jspb.BinaryWriter(); + proto.messages.RevokeMessageRequest.serializeBinaryToWriter(this, writer); + return writer.getResultBuffer(); +}; + + +/** + * Serializes the given message to binary data (in protobuf wire + * format), writing to the given BinaryWriter. + * @param {!proto.messages.RevokeMessageRequest} message + * @param {!jspb.BinaryWriter} writer + * @suppress {unusedLocalVariables} f is only used for nested messages + */ +proto.messages.RevokeMessageRequest.serializeBinaryToWriter = function(message, writer) { + var f = undefined; + f = message.getSession(); + if (f != null) { + writer.writeMessage( + 1, + f, + proto.messages.Session.serializeBinaryToWriter + ); + } + f = message.getJid(); + if (f.length > 0) { + writer.writeString( + 2, + f + ); + } + f = message.getSender(); + if (f.length > 0) { + writer.writeString( + 3, + f + ); + } + f = message.getMessageid(); + if (f.length > 0) { + writer.writeString( + 4, + f + ); + } +}; + + +/** + * optional Session session = 1; + * @return {?proto.messages.Session} + */ +proto.messages.RevokeMessageRequest.prototype.getSession = function() { + return /** @type{?proto.messages.Session} */ ( + jspb.Message.getWrapperField(this, proto.messages.Session, 1)); +}; + + +/** + * @param {?proto.messages.Session|undefined} value + * @return {!proto.messages.RevokeMessageRequest} returns this +*/ +proto.messages.RevokeMessageRequest.prototype.setSession = function(value) { + return jspb.Message.setWrapperField(this, 1, value); +}; + + +/** + * Clears the message field making it undefined. + * @return {!proto.messages.RevokeMessageRequest} returns this + */ +proto.messages.RevokeMessageRequest.prototype.clearSession = function() { + return this.setSession(undefined); +}; + + +/** + * Returns whether this field is set. + * @return {boolean} + */ +proto.messages.RevokeMessageRequest.prototype.hasSession = function() { + return jspb.Message.getField(this, 1) != null; +}; + + +/** + * optional string jid = 2; + * @return {string} + */ +proto.messages.RevokeMessageRequest.prototype.getJid = function() { + return /** @type {string} */ (jspb.Message.getFieldWithDefault(this, 2, "")); +}; + + +/** + * @param {string} value + * @return {!proto.messages.RevokeMessageRequest} returns this + */ +proto.messages.RevokeMessageRequest.prototype.setJid = function(value) { + return jspb.Message.setProto3StringField(this, 2, value); +}; + + +/** + * optional string sender = 3; + * @return {string} + */ +proto.messages.RevokeMessageRequest.prototype.getSender = function() { + return /** @type {string} */ (jspb.Message.getFieldWithDefault(this, 3, "")); +}; + + +/** + * @param {string} value + * @return {!proto.messages.RevokeMessageRequest} returns this + */ +proto.messages.RevokeMessageRequest.prototype.setSender = function(value) { + return jspb.Message.setProto3StringField(this, 3, value); +}; + + +/** + * optional string messageId = 4; + * @return {string} + */ +proto.messages.RevokeMessageRequest.prototype.getMessageid = function() { + return /** @type {string} */ (jspb.Message.getFieldWithDefault(this, 4, "")); +}; + + +/** + * @param {string} value + * @return {!proto.messages.RevokeMessageRequest} returns this + */ +proto.messages.RevokeMessageRequest.prototype.setMessageid = function(value) { + return jspb.Message.setProto3StringField(this, 4, value); +}; + + + + + if (jspb.Message.GENERATE_TO_OBJECT) { /** * Creates an object representation of this proto. diff --git a/src/core/engines/gows/session.gows.core.ts b/src/core/engines/gows/session.gows.core.ts index d1a71c52..b277562b 100644 --- a/src/core/engines/gows/session.gows.core.ts +++ b/src/core/engines/gows/session.gows.core.ts @@ -538,6 +538,20 @@ export class WhatsappSessionGoWSCore extends WhatsappSession { return this.messageResponse(jid, data); } + public async deleteMessage(chatId: string, messageId: string) { + const jid = toJID(this.ensureSuffix(chatId)); + const key = parseMessageIdSerialized(messageId); + const message = new messages.RevokeMessageRequest({ + session: this.session, + jid: jid, + sender: key.participant || '', + messageId: key.id, + }); + const response = await promisify(this.client.RevokeMessage)(message); + const data = response.toObject(); + return this.messageResponse(jid, data); + } + protected checkStatusRequest(request: StatusRequest) { if (request.contacts && request.contacts?.length > 0) { const msg =