chore: merge ReceiptMessage and readReceiptMessage into one

pull/2963/head
Audric Ackermann 2 years ago
parent df3a188074
commit 0fbb0cc852

@ -36,7 +36,6 @@ import { OpenGroupRequestCommonType } from '../session/apis/open_group_api/openg
import { OpenGroupUtils } from '../session/apis/open_group_api/utils';
import { getOpenGroupV2FromConversationId } from '../session/apis/open_group_api/utils/OpenGroupUtils';
import { ExpirationTimerUpdateMessage } from '../session/messages/outgoing/controlMessage/ExpirationTimerUpdateMessage';
import { ReadReceiptMessage } from '../session/messages/outgoing/controlMessage/receipt/ReadReceiptMessage';
import { TypingMessage } from '../session/messages/outgoing/controlMessage/TypingMessage';
import { GroupInvitationMessage } from '../session/messages/outgoing/visibleMessage/GroupInvitationMessage';
import { OpenGroupVisibleMessage } from '../session/messages/outgoing/visibleMessage/OpenGroupVisibleMessage';
@ -112,6 +111,7 @@ import {
READ_MESSAGE_STATE,
} from './conversationAttributes';
import { ReadReceiptMessage } from '../session/messages/outgoing/controlMessage/receipt/ReadReceiptMessage';
import { PreConditionFailed } from '../session/utils/errors';
import { LibSessionUtil } from '../session/utils/libsession/libsession_utils';
import { SessionUtilUserProfile } from '../session/utils/libsession/libsession_utils_user_profile';

@ -1,8 +1,28 @@
import { ContentMessage } from '../..';
import { SignalService } from '../../../../../protobuf';
import { ReceiptMessage } from './ReceiptMessage';
import { MessageParams } from '../../Message';
export class ReadReceiptMessage extends ReceiptMessage {
public getReceiptType(): SignalService.ReceiptMessage.Type {
return SignalService.ReceiptMessage.Type.READ;
interface ReadReceiptMessageParams extends MessageParams {
timestamps: Array<number>;
}
export class ReadReceiptMessage extends ContentMessage {
public readonly timestamps: Array<number>;
constructor({ timestamp, identifier, timestamps }: ReadReceiptMessageParams) {
super({ timestamp, identifier });
this.timestamps = timestamps;
}
public contentProto(): SignalService.Content {
return new SignalService.Content({
receiptMessage: this.receiptProto(),
});
}
protected receiptProto(): SignalService.ReceiptMessage {
return new SignalService.ReceiptMessage({
type: SignalService.ReceiptMessage.Type.READ,
timestamp: this.timestamps,
});
}
}

@ -1,30 +0,0 @@
import { SignalService } from '../../../../../protobuf';
import { MessageParams } from '../../Message';
import { ContentMessage } from '../..';
interface ReceiptMessageParams extends MessageParams {
timestamps: Array<number>;
}
export abstract class ReceiptMessage extends ContentMessage {
public readonly timestamps: Array<number>;
constructor({ timestamp, identifier, timestamps }: ReceiptMessageParams) {
super({ timestamp, identifier });
this.timestamps = timestamps;
}
public abstract getReceiptType(): SignalService.ReceiptMessage.Type;
public contentProto(): SignalService.Content {
return new SignalService.Content({
receiptMessage: this.receiptProto(),
});
}
protected receiptProto(): SignalService.ReceiptMessage {
return new SignalService.ReceiptMessage({
type: this.getReceiptType(),
timestamp: this.timestamps,
});
}
}
Loading…
Cancel
Save