1- import { TBufferedTransport , TCompactProtocol , Thrift } from 'thrift'
21import * as zlib from 'zlib'
32import AuthTokens from '../../types/AuthTokens'
43import DeviceId from '../../types/DeviceId'
54import MqttMessage from '../MqttMessage'
6- import { MqttConnectFlag , MqttMessageFlag } from '../MqttTypes'
7- import { MessageType } from './MessageTypes'
5+ import { MqttConnectFlag } from '../MqttTypes'
86import * as Payloads from '../payloads'
7+ import { MessageType } from './MessageTypes'
98
109const USER_AGENT =
1110 'Facebook plugin / LIBFB-JS / [FBAN/Orca-Android;FBAV/148.0.0.5.83;FBPN/com.facebook.orca;FBLC/en_US;FBBV/26040814]'
@@ -18,20 +17,16 @@ export const encodeConnectMessage = async (
1817 deviceId : DeviceId
1918) : Promise < MqttMessage > => {
2019 const payload = new Payloads . Connect ( deviceId , tokens , USER_AGENT )
21-
22- const message = new MqttMessage ( )
2320 const flags =
24- MqttConnectFlag . User |
25- MqttConnectFlag . Pass |
26- MqttConnectFlag . Clr |
27- MqttConnectFlag . QoS1
28- message . writeString ( 'MQTToT' )
29- message . writeU8 ( 3 )
30- message . writeU8 ( flags )
31- message . writeU16 ( 60 ) // KEEP ALIVE
32- message . writeRaw ( zlib . deflateSync ( await Payloads . encodePayload ( payload ) ) )
33- message . flags = 0
34- message . type = FacebookMessageType . Connect
35-
36- return message
21+ MqttConnectFlag . User |
22+ MqttConnectFlag . Pass |
23+ MqttConnectFlag . Clr |
24+ MqttConnectFlag . QoS1
25+ return new MqttMessage ( MessageType . Connect )
26+ . setFlags ( MqttConnectFlag . QoS0 )
27+ . writeString ( 'MQTToT' )
28+ . writeU8 ( 3 )
29+ . writeU8 ( flags )
30+ . writeU16 ( 60 ) // KEEP ALIVE
31+ . writeRaw ( zlib . deflateSync ( await Payloads . encodePayload ( payload ) ) )
3732}
0 commit comments