Book a Demo!
CoCalc Logo Icon
StoreFeaturesDocsShareSupportNewsAboutPoliciesSign UpSign In
jajbshjahavahh
GitHub Repository: jajbshjahavahh/Gojo-Satoru
 Path: blob/master/node_modules/@adiwajshing/baileys/lib/Utils/decode-wa-message.js
2593 views
1
"use strict";

2
Object.defineProperty(exports, "__esModule", { value: true });

3
exports.decodeMessageStanza = void 0;

4
const boom_1 = require("@hapi/boom");

5
const WAProto_1 = require("../../WAProto");

6
const WABinary_1 = require("../WABinary");

7
const generics_1 = require("./generics");

8
const signal_1 = require("./signal");

9
const NO_MESSAGE_FOUND_ERROR_TEXT = 'No message found';

10
const decodeMessageStanza = (stanza, auth) => {

11
    let msgType;

12
    let chatId;

13
    let author;

14
    const msgId = stanza.attrs.id;

15
    const from = stanza.attrs.from;

16
    const participant = stanza.attrs.participant;

17
    const recipient = stanza.attrs.recipient;

18
    const isMe = (jid) => WABinary_1.areJidsSameUser(jid, auth.creds.me.id);

19
    if (WABinary_1.isJidUser(from)) {

20
        if (recipient) {

21
            if (!isMe(from)) {

22
                throw new boom_1.Boom('');

23
            }

24
            chatId = recipient;

25
        }

26
        else {

27
            chatId = from;

28
        }

29
        msgType = 'chat';

30
        author = from;

31
    }

32
    else if (WABinary_1.isJidGroup(from)) {

33
        if (!participant) {

34
            throw new boom_1.Boom('No participant in group message');

35
        }

36
        msgType = 'group';

37
        author = participant;

38
        chatId = from;

39
    }

40
    else if (WABinary_1.isJidBroadcast(from)) {

41
        if (!participant) {

42
            throw new boom_1.Boom('No participant in group message');

43
        }

44
        const isParticipantMe = isMe(participant);

45
        if (WABinary_1.isJidStatusBroadcast(from)) {

46
            msgType = isParticipantMe ? 'direct_peer_status' : 'other_status';

47
        }

48
        else {

49
            msgType = isParticipantMe ? 'peer_broadcast' : 'other_broadcast';

50
        }

51
        chatId = from;

52
        author = participant;

53
    }

54
    const sender = msgType === 'chat' ? author : chatId;

55
    const fromMe = isMe(stanza.attrs.participant || stanza.attrs.from);

56
    const pushname = stanza.attrs.notify;

57
    const key = {

58
        remoteJid: chatId,

59
        fromMe,

60
        id: msgId,

61
        participant

62
    };

63
    const fullMessage = {

64
        key,

65
        messageTimestamp: +stanza.attrs.t,

66
        pushName: pushname

67
    };

68
    if (key.fromMe) {

69
        fullMessage.status = WAProto_1.proto.WebMessageInfo.WebMessageInfoStatus.SERVER_ACK;

70
    }

71
    return {

72
        fullMessage,

73
        decryptionTask: (async () => {

74
            var _a;

75
            let decryptables = 0;

76
            if (Array.isArray(stanza.content)) {

77
                for (const { tag, attrs, content } of stanza.content) {

78
                    if (tag !== 'enc') {

79
                        continue;

80
                    }

81
                    if (!(content instanceof Uint8Array)) {

82
                        continue;

83
                    }

84
                    decryptables += 1;

85
                    let msgBuffer;

86
                    try {

87
                        const e2eType = attrs.type;

88
                        switch (e2eType) {

89
                            case 'skmsg':

90
                                msgBuffer = await signal_1.decryptGroupSignalProto(sender, author, content, auth);

91
                                break;

92
                            case 'pkmsg':

93
                            case 'msg':

94
                                const user = WABinary_1.isJidUser(sender) ? sender : author;

95
                                msgBuffer = await signal_1.decryptSignalProto(user, e2eType, content, auth);

96
                                break;

97
                        }

98
                        let msg = WAProto_1.proto.Message.decode(generics_1.unpadRandomMax16(msgBuffer));

99
                        msg = ((_a = msg.deviceSentMessage) === null || _a === void 0 ? void 0 : _a.message) || msg;

100
                        if (msg.senderKeyDistributionMessage) {

101
                            await signal_1.processSenderKeyMessage(author, msg.senderKeyDistributionMessage, auth);

102
                        }

103
                        if (fullMessage.message) {

104
                            Object.assign(fullMessage.message, msg);

105
                        }

106
                        else {

107
                            fullMessage.message = msg;

108
                        }

109
                    }

110
                    catch (error) {

111
                        fullMessage.messageStubType = WAProto_1.proto.WebMessageInfo.WebMessageInfoStubType.CIPHERTEXT;

112
                        fullMessage.messageStubParameters = [error.message];

113
                    }

114
                }

115
            }

116
            // if nothing was found to decrypt

117
            if (!decryptables) {

118
                fullMessage.messageStubType = WAProto_1.proto.WebMessageInfo.WebMessageInfoStubType.CIPHERTEXT;

119
                fullMessage.messageStubParameters = [NO_MESSAGE_FOUND_ERROR_TEXT];

120
            }

121
        })()

122
    };

123
};

124
exports.decodeMessageStanza = decodeMessageStanza;

125


126