/*! * Webogram v0.5.7.1 - messaging web application for MTProto * https://github.com/zhukov/webogram * Copyright (C) 2014 Igor Zhukov * https://github.com/zhukov/webogram/blob/master/LICENSE */ angular.module('izhukov.mtproto', ['izhukov.utils']) .factory('MtpDcConfigurator', function () { var sslSubdomains = ['pluto', 'venus', 'aurora', 'vesta', 'flora'] var dcOptions = Config.Modes.test ? [ {id: 1, host: '149.154.175.10', port: 80}, {id: 2, host: '149.154.167.40', port: 80}, {id: 3, host: '149.154.175.117', port: 80} ] : [ {id: 1, host: '149.154.175.50', port: 80}, {id: 2, host: '149.154.167.51', port: 80}, {id: 3, host: '149.154.175.100', port: 80}, {id: 4, host: '149.154.167.91', port: 80}, {id: 5, host: '149.154.171.5', port: 80} ] var chosenServers = {} function chooseServer (dcID, upload) { if (chosenServers[dcID] === undefined) { var chosenServer = false, i, dcOption if (Config.Modes.ssl || !Config.Modes.http) { var subdomain = sslSubdomains[dcID - 1] + (upload ? '-1' : '') var path = Config.Modes.test ? 'apiw_test1' : 'apiw1' chosenServer = 'https://' + subdomain + '.web.telegram.org/' + path return chosenServer } for (i = 0; i < dcOptions.length; i++) { dcOption = dcOptions[i] if (dcOption.id == dcID) { chosenServer = 'http://' + dcOption.host + (dcOption.port != 80 ? ':' + dcOption.port : '') + '/apiw1' break } } chosenServers[dcID] = chosenServer } return chosenServers[dcID] } return { chooseServer: chooseServer } }) .factory('MtpRsaKeysManager', function () { /** * Server public key, obtained from here: https://core.telegram.org/api/obtaining_api_id * * -----BEGIN RSA PUBLIC KEY----- * MIIBCgKCAQEAwVACPi9w23mF3tBkdZz+zwrzKOaaQdr01vAbU4E1pvkfj4sqDsm6 * lyDONS789sVoD/xCS9Y0hkkC3gtL1tSfTlgCMOOul9lcixlEKzwKENj1Yz/s7daS * an9tqw3bfUV/nqgbhGX81v/+7RFAEd+RwFnK7a+XYl9sluzHRyVVaTTveB2GazTw * Efzk2DWgkBluml8OREmvfraX3bkHZJTKX4EQSjBbbdJ2ZXIsRrYOXfaA+xayEGB+ * 8hdlLmAjbCVfaigxX0CDqWeR1yFL9kwd9P0NsZRPsmoqVwMbMu7mStFai6aIhc3n * Slv8kg9qv1m6XHVQY3PnEw+QQtqSIXklHwIDAQAB * -----END RSA PUBLIC KEY----- */ var publisKeysHex = [{ modulus: 'c150023e2f70db7985ded064759cfecf0af328e69a41daf4d6f01b538135a6f91f8f8b2a0ec9ba9720ce352efcf6c5680ffc424bd634864902de0b4bd6d49f4e580230e3ae97d95c8b19442b3c0a10d8f5633fecedd6926a7f6dab0ddb7d457f9ea81b8465fcd6fffeed114011df91c059caedaf97625f6c96ecc74725556934ef781d866b34f011fce4d835a090196e9a5f0e4449af7eb697ddb9076494ca5f81104a305b6dd27665722c46b60e5df680fb16b210607ef217652e60236c255f6a28315f4083a96791d7214bf64c1df4fd0db1944fb26a2a57031b32eee64ad15a8ba68885cde74a5bfc920f6abf59ba5c75506373e7130f9042da922179251f', exponent: '010001' }] var publicKeysParsed = {} var prepared = false function prepareRsaKeys () { if (prepared) { return } for (var i = 0; i < publisKeysHex.length; i++) { var keyParsed = publisKeysHex[i] var RSAPublicKey = new TLSerialization() RSAPublicKey.storeBytes(bytesFromHex(keyParsed.modulus), 'n') RSAPublicKey.storeBytes(bytesFromHex(keyParsed.exponent), 'e') var buffer = RSAPublicKey.getBuffer() var fingerprintBytes = sha1BytesSync(buffer).slice(-8) fingerprintBytes.reverse() publicKeysParsed[bytesToHex(fingerprintBytes)] = { modulus: keyParsed.modulus, exponent: keyParsed.exponent } } prepared = true } function selectRsaKeyByFingerPrint (fingerprints) { prepareRsaKeys() var fingerprintHex, foundKey, i for (i = 0; i < fingerprints.length; i++) { fingerprintHex = bigStringInt(fingerprints[i]).toString(16) if (foundKey = publicKeysParsed[fingerprintHex]) { return angular.extend({fingerprint: fingerprints[i]}, foundKey) } } return false } return { prepare: prepareRsaKeys, select: selectRsaKeyByFingerPrint } }) .service('MtpSecureRandom', function ($window) { $($window).on('click keydown', rng_seed_time) return new SecureRandom() }) .factory('MtpTimeManager', function (Storage) { var lastMessageID = [0, 0] var timeOffset = 0 Storage.get('server_time_offset').then(function (to) { if (to) { timeOffset = to } }) function generateMessageID () { var timeTicks = tsNow(), timeSec = Math.floor(timeTicks / 1000) + timeOffset, timeMSec = timeTicks % 1000, random = nextRandomInt(0xFFFF) var messageID = [timeSec, (timeMSec << 21) | (random << 3) | 4] if (lastMessageID[0] > messageID[0] || lastMessageID[0] == messageID[0] && lastMessageID[1] >= messageID[1]) { messageID = [lastMessageID[0], lastMessageID[1] + 4] } lastMessageID = messageID // console.log('generated msg id', messageID, timeOffset) return longFromInts(messageID[0], messageID[1]) } function applyServerTime (serverTime, localTime) { var newTimeOffset = serverTime - Math.floor((localTime || tsNow()) / 1000) var changed = Math.abs(timeOffset - newTimeOffset) > 10 Storage.set({server_time_offset: newTimeOffset}) lastMessageID = [0, 0] timeOffset = newTimeOffset console.log(dT(), 'Apply server time', serverTime, localTime, newTimeOffset, changed) return changed } return { generateID: generateMessageID, applyServerTime: applyServerTime } }) .factory('MtpAuthorizer', function (MtpDcConfigurator, MtpRsaKeysManager, MtpSecureRandom, MtpTimeManager, CryptoWorker, $http, $q, $timeout) { var chromeMatches = navigator.userAgent.match(/Chrome\/(\d+(\.\d+)?)/) var chromeVersion = chromeMatches && parseFloat(chromeMatches[1]) || false var xhrSendBuffer = !('ArrayBufferView' in window) && (!chromeVersion || chromeVersion < 30) delete $http.defaults.headers.post['Content-Type'] delete $http.defaults.headers.common['Accept'] function mtpSendPlainRequest (dcID, requestBuffer) { var requestLength = requestBuffer.byteLength, requestArray = new Int32Array(requestBuffer) var header = new TLSerialization() header.storeLongP(0, 0, 'auth_key_id') // Auth key header.storeLong(MtpTimeManager.generateID(), 'msg_id') // Msg_id header.storeInt(requestLength, 'request_length') var headerBuffer = header.getBuffer(), headerArray = new Int32Array(headerBuffer) var headerLength = headerBuffer.byteLength var resultBuffer = new ArrayBuffer(headerLength + requestLength), resultArray = new Int32Array(resultBuffer) resultArray.set(headerArray) resultArray.set(requestArray, headerArray.length) var requestData = xhrSendBuffer ? resultBuffer : resultArray, requestPromise var url = MtpDcConfigurator.chooseServer(dcID) var baseError = {code: 406, type: 'NETWORK_BAD_RESPONSE', url: url} try { requestPromise = $http.post(url, requestData, { responseType: 'arraybuffer', transformRequest: null }) } catch (e) { requestPromise = $q.reject(angular.extend(baseError, {originalError: e})) } return requestPromise.then( function (result) { if (!result.data || !result.data.byteLength) { return $q.reject(baseError) } try { var deserializer = new TLDeserialization(result.data, {mtproto: true}) var auth_key_id = deserializer.fetchLong('auth_key_id') var msg_id = deserializer.fetchLong('msg_id') var msg_len = deserializer.fetchInt('msg_len') } catch (e) { return $q.reject(angular.extend(baseError, {originalError: e})) } return deserializer }, function (error) { if (!error.message && !error.type) { error = angular.extend(baseError, {originalError: error}) } return $q.reject(error) } ) } function mtpSendReqPQ (auth) { var deferred = auth.deferred var request = new TLSerialization({mtproto: true}) request.storeMethod('req_pq', {nonce: auth.nonce}) console.log(dT(), 'Send req_pq', bytesToHex(auth.nonce)) mtpSendPlainRequest(auth.dcID, request.getBuffer()).then(function (deserializer) { var response = deserializer.fetchObject('ResPQ') if (response._ != 'resPQ') { throw new Error('[MT] resPQ response invalid: ' + response._) } if (!bytesCmp(auth.nonce, response.nonce)) { throw new Error('[MT] resPQ nonce mismatch') } auth.serverNonce = response.server_nonce auth.pq = response.pq auth.fingerprints = response.server_public_key_fingerprints console.log(dT(), 'Got ResPQ', bytesToHex(auth.serverNonce), bytesToHex(auth.pq), auth.fingerprints) auth.publicKey = MtpRsaKeysManager.select(auth.fingerprints) if (!auth.publicKey) { throw new Error('[MT] No public key found') } console.log(dT(), 'PQ factorization start', auth.pq) CryptoWorker.factorize(auth.pq).then(function (pAndQ) { auth.p = pAndQ[0] auth.q = pAndQ[1] console.log(dT(), 'PQ factorization done', pAndQ[2]) mtpSendReqDhParams(auth) }, function (error) { console.log('Worker error', error, error.stack) deferred.reject(error) }) }, function (error) { console.error(dT(), 'req_pq error', error.message) deferred.reject(error) }) $timeout(function () { MtpRsaKeysManager.prepare() }) } function mtpSendReqDhParams (auth) { var deferred = auth.deferred auth.newNonce = new Array(32) MtpSecureRandom.nextBytes(auth.newNonce) var data = new TLSerialization({mtproto: true}) data.storeObject({ _: 'p_q_inner_data', pq: auth.pq, p: auth.p, q: auth.q, nonce: auth.nonce, server_nonce: auth.serverNonce, new_nonce: auth.newNonce }, 'P_Q_inner_data', 'DECRYPTED_DATA') var dataWithHash = sha1BytesSync(data.getBuffer()).concat(data.getBytes()) var request = new TLSerialization({mtproto: true}) request.storeMethod('req_DH_params', { nonce: auth.nonce, server_nonce: auth.serverNonce, p: auth.p, q: auth.q, public_key_fingerprint: auth.publicKey.fingerprint, encrypted_data: rsaEncrypt(auth.publicKey, dataWithHash) }) console.log(dT(), 'Send req_DH_params') mtpSendPlainRequest(auth.dcID, request.getBuffer()).then(function (deserializer) { var response = deserializer.fetchObject('Server_DH_Params', 'RESPONSE') if (response._ != 'server_DH_params_fail' && response._ != 'server_DH_params_ok') { deferred.reject(new Error('[MT] Server_DH_Params response invalid: ' + response._)) return false } if (!bytesCmp(auth.nonce, response.nonce)) { deferred.reject(new Error('[MT] Server_DH_Params nonce mismatch')) return false } if (!bytesCmp(auth.serverNonce, response.server_nonce)) { deferred.reject(new Error('[MT] Server_DH_Params server_nonce mismatch')) return false } if (response._ == 'server_DH_params_fail') { var newNonceHash = sha1BytesSync(auth.newNonce).slice(-16) if (!bytesCmp(newNonceHash, response.new_nonce_hash)) { deferred.reject(new Error('[MT] server_DH_params_fail new_nonce_hash mismatch')) return false } deferred.reject(new Error('[MT] server_DH_params_fail')) return false } try { mtpDecryptServerDhDataAnswer(auth, response.encrypted_answer) } catch (e) { deferred.reject(e) return false } mtpSendSetClientDhParams(auth) }, function (error) { deferred.reject(error) }) } function mtpDecryptServerDhDataAnswer (auth, encryptedAnswer) { auth.localTime = tsNow() auth.tmpAesKey = sha1BytesSync(auth.newNonce.concat(auth.serverNonce)).concat(sha1BytesSync(auth.serverNonce.concat(auth.newNonce)).slice(0, 12)) auth.tmpAesIv = sha1BytesSync(auth.serverNonce.concat(auth.newNonce)).slice(12).concat(sha1BytesSync([].concat(auth.newNonce, auth.newNonce)), auth.newNonce.slice(0, 4)) var answerWithHash = aesDecryptSync(encryptedAnswer, auth.tmpAesKey, auth.tmpAesIv) var hash = answerWithHash.slice(0, 20) var answerWithPadding = answerWithHash.slice(20) var buffer = bytesToArrayBuffer(answerWithPadding) var deserializer = new TLDeserialization(buffer, {mtproto: true}) var response = deserializer.fetchObject('Server_DH_inner_data') if (response._ != 'server_DH_inner_data') { throw new Error('[MT] server_DH_inner_data response invalid: ' + constructor) } if (!bytesCmp(auth.nonce, response.nonce)) { throw new Error('[MT] server_DH_inner_data nonce mismatch') } if (!bytesCmp(auth.serverNonce, response.server_nonce)) { throw new Error('[MT] server_DH_inner_data serverNonce mismatch') } console.log(dT(), 'Done decrypting answer') auth.g = response.g auth.dhPrime = response.dh_prime auth.gA = response.g_a auth.serverTime = response.server_time auth.retry = 0 mtpVerifyDhParams(auth.g, auth.dhPrime, auth.gA) var offset = deserializer.getOffset() if (!bytesCmp(hash, sha1BytesSync(answerWithPadding.slice(0, offset)))) { throw new Error('[MT] server_DH_inner_data SHA1-hash mismatch') } MtpTimeManager.applyServerTime(auth.serverTime, auth.localTime) } function mtpVerifyDhParams(g, dhPrime, gA) { console.log(dT(), 'Verifying DH params') var dhPrimeHex = bytesToHex(dhPrime); if (g != 3 || dhPrimeHex !== 'c71caeb9c6b1c9048e6c522f70f13f73980d40238e3e21c14934d037563d930f48198a0aa7c14058229493d22530f4dbfa336f6e0ac925139543aed44cce7c3720fd51f69458705ac68cd4fe6b6b13abdc9746512969328454f18faf8c595f642477fe96bb2a941d5bcd1d4ac8cc49880708fa9b378e3c4f3a9060bee67cf9a4a4a695811051907e162753b56b0f6b410dba74d8a84b2a14b3144e0ef1284754fd17ed950d5965b4b9dd46582db1178d169c6bc465b0d6ff9ca3928fef5b9ae4e418fc15e83ebea0f87fa9ff5eed70050ded2849f47bf959d956850ce929851f0d8115f635b105ee2e4e15d04b2454bf6f4fadf034b10403119cd8e3b92fcc5b') { // The verified value is from https://core.telegram.org/mtproto/security_guidelines throw new Error('[MT] DH params are not verified: unknown dhPrime') } console.log(dT(), 'dhPrime cmp OK') var gABigInt = new BigInteger(bytesToHex(gA), 16) var dhPrimeBigInt = new BigInteger(dhPrimeHex, 16) if (gABigInt.compareTo(BigInteger.ONE) <= 0) { throw new Error('[MT] DH params are not verified: gA <= 1') } if (gABigInt.compareTo(dhPrimeBigInt.subtract(BigInteger.ONE)) >= 0) { throw new Error('[MT] DH params are not verified: gA >= dhPrime - 1') } console.log(dT(), '1 < gA < dhPrime-1 OK') var two = new BigInteger(null) two.fromInt(2) var twoPow = two.pow(2048 - 64) if (gABigInt.compareTo(twoPow) < 0) { throw new Error('[MT] DH params are not verified: gA < 2^{2048-64}') } if (gABigInt.compareTo(dhPrimeBigInt.subtract(twoPow)) >= 0) { throw new Error('[MT] DH params are not verified: gA > dhPrime - 2^{2048-64}') } console.log(dT(), '2^{2048-64} < gA < dhPrime-2^{2048-64} OK') return true } function mtpSendSetClientDhParams (auth) { var deferred = auth.deferred var gBytes = bytesFromHex(auth.g.toString(16)) auth.b = new Array(256) MtpSecureRandom.nextBytes(auth.b) CryptoWorker.modPow(gBytes, auth.b, auth.dhPrime).then(function (gB) { var data = new TLSerialization({mtproto: true}) data.storeObject({ _: 'client_DH_inner_data', nonce: auth.nonce, server_nonce: auth.serverNonce, retry_id: [0, auth.retry++], g_b: gB }, 'Client_DH_Inner_Data') var dataWithHash = sha1BytesSync(data.getBuffer()).concat(data.getBytes()) var encryptedData = aesEncryptSync(dataWithHash, auth.tmpAesKey, auth.tmpAesIv) var request = new TLSerialization({mtproto: true}) request.storeMethod('set_client_DH_params', { nonce: auth.nonce, server_nonce: auth.serverNonce, encrypted_data: encryptedData }) console.log(dT(), 'Send set_client_DH_params') mtpSendPlainRequest(auth.dcID, request.getBuffer()).then(function (deserializer) { var response = deserializer.fetchObject('Set_client_DH_params_answer') if (response._ != 'dh_gen_ok' && response._ != 'dh_gen_retry' && response._ != 'dh_gen_fail') { deferred.reject(new Error('[MT] Set_client_DH_params_answer response invalid: ' + response._)) return false } if (!bytesCmp(auth.nonce, response.nonce)) { deferred.reject(new Error('[MT] Set_client_DH_params_answer nonce mismatch')) return false } if (!bytesCmp(auth.serverNonce, response.server_nonce)) { deferred.reject(new Error('[MT] Set_client_DH_params_answer server_nonce mismatch')) return false } CryptoWorker.modPow(auth.gA, auth.b, auth.dhPrime).then(function (authKey) { var authKeyHash = sha1BytesSync(authKey), authKeyAux = authKeyHash.slice(0, 8), authKeyID = authKeyHash.slice(-8) console.log(dT(), 'Got Set_client_DH_params_answer', response._) switch (response._) { case 'dh_gen_ok': var newNonceHash1 = sha1BytesSync(auth.newNonce.concat([1], authKeyAux)).slice(-16) if (!bytesCmp(newNonceHash1, response.new_nonce_hash1)) { deferred.reject(new Error('[MT] Set_client_DH_params_answer new_nonce_hash1 mismatch')) return false } var serverSalt = bytesXor(auth.newNonce.slice(0, 8), auth.serverNonce.slice(0, 8)) // console.log('Auth successfull!', authKeyID, authKey, serverSalt) auth.authKeyID = authKeyID auth.authKey = authKey auth.serverSalt = serverSalt deferred.resolve(auth) break case 'dh_gen_retry': var newNonceHash2 = sha1BytesSync(auth.newNonce.concat([2], authKeyAux)).slice(-16) if (!bytesCmp(newNonceHash2, response.new_nonce_hash2)) { deferred.reject(new Error('[MT] Set_client_DH_params_answer new_nonce_hash2 mismatch')) return false } return mtpSendSetClientDhParams(auth) case 'dh_gen_fail': var newNonceHash3 = sha1BytesSync(auth.newNonce.concat([3], authKeyAux)).slice(-16) if (!bytesCmp(newNonceHash3, response.new_nonce_hash3)) { deferred.reject(new Error('[MT] Set_client_DH_params_answer new_nonce_hash3 mismatch')) return false } deferred.reject(new Error('[MT] Set_client_DH_params_answer fail')) return false } }, function (error) { deferred.reject(error) }) }, function (error) { deferred.reject(error) }) }, function (error) { deferred.reject(error) }) } var cached = {} function mtpAuth (dcID) { if (cached[dcID] !== undefined) { return cached[dcID] } var nonce = [] for (var i = 0; i < 16; i++) { nonce.push(nextRandomInt(0xFF)) } if (!MtpDcConfigurator.chooseServer(dcID)) { return $q.reject(new Error('[MT] No server found for dc ' + dcID)) } var auth = { dcID: dcID, nonce: nonce, deferred: $q.defer() } $timeout(function () { mtpSendReqPQ(auth) }) cached[dcID] = auth.deferred.promise cached[dcID]['catch'](function () { delete cached[dcID] }) return cached[dcID] } return { auth: mtpAuth } }) .factory('MtpNetworkerFactory', function (MtpDcConfigurator, MtpTimeManager, MtpSecureRandom, Storage, CryptoWorker, AppRuntimeManager, $http, $q, $timeout, $interval, $rootScope) { var updatesProcessor var iii = 0, offline var offlineInited = false var akStopped = false var chromeMatches = navigator.userAgent.match(/Chrome\/(\d+(\.\d+)?)/) var chromeVersion = chromeMatches && parseFloat(chromeMatches[1]) || false var xhrSendBuffer = !('ArrayBufferView' in window) && (!chromeVersion || chromeVersion < 30) delete $http.defaults.headers.post['Content-Type'] delete $http.defaults.headers.common['Accept'] $rootScope.retryOnline = function () { $(document.body).trigger('online') } function MtpNetworker (dcID, authKey, serverSalt, options) { options = options || {} this.dcID = dcID this.iii = iii++ this.authKey = authKey this.authKeyUint8 = convertToUint8Array(authKey) this.authKeyBuffer = convertToArrayBuffer(authKey) this.authKeyID = sha1BytesSync(authKey).slice(-8) this.serverSalt = serverSalt this.upload = options.fileUpload || options.fileDownload || false this.updateSession() this.lastServerMessages = [] this.currentRequests = 0 this.checkConnectionPeriod = 0 this.sentMessages = {} this.clientMessages = [] this.pendingMessages = {} this.pendingAcks = [] this.pendingResends = [] this.connectionInited = false this.pendingTimeouts = [] this.longPollInt = $interval(this.checkLongPoll.bind(this), 10000) this.checkLongPoll() if (!offlineInited) { offlineInited = true $rootScope.offline = true $rootScope.offlineConnecting = true } if (Config.Navigator.mobile) { this.setupMobileSleep() } } MtpNetworker.prototype.updateSession = function () { this.seqNo = 0 this.prevSessionID = this.sessionID this.sessionID = new Array(8) MtpSecureRandom.nextBytes(this.sessionID) } MtpNetworker.prototype.setupMobileSleep = function () { var self = this $rootScope.$watch('idle.isIDLE', function (isIDLE) { if (isIDLE) { self.sleepAfter = tsNow() + 30000 } else { delete self.sleepAfter self.checkLongPoll() } }) $rootScope.$on('push_received', function () { // console.log(dT(), 'push recieved', self.sleepAfter) if (self.sleepAfter) { self.sleepAfter = tsNow() + 30000 self.checkLongPoll() } }) } MtpNetworker.prototype.updateSentMessage = function (sentMessageID) { var sentMessage = this.sentMessages[sentMessageID] if (!sentMessage) { return false } var self = this if (sentMessage.container) { var newInner = [] angular.forEach(sentMessage.inner, function (innerSentMessageID) { var innerSentMessage = self.updateSentMessage(innerSentMessageID) if (innerSentMessage) { newInner.push(innerSentMessage.msg_id) } }) sentMessage.inner = newInner } sentMessage.msg_id = MtpTimeManager.generateID() sentMessage.seq_no = this.generateSeqNo( sentMessage.notContentRelated || sentMessage.container ) this.sentMessages[sentMessage.msg_id] = sentMessage delete self.sentMessages[sentMessageID] return sentMessage } MtpNetworker.prototype.generateSeqNo = function (notContentRelated) { var seqNo = this.seqNo * 2 if (!notContentRelated) { seqNo++ this.seqNo++ } return seqNo } MtpNetworker.prototype.wrapMtpCall = function (method, params, options) { var serializer = new TLSerialization({mtproto: true}) serializer.storeMethod(method, params) var messageID = MtpTimeManager.generateID() var seqNo = this.generateSeqNo() var message = { msg_id: messageID, seq_no: seqNo, body: serializer.getBytes() } if (Config.Modes.debug) { console.log(dT(), 'MT call', method, params, messageID, seqNo) } return this.pushMessage(message, options) } MtpNetworker.prototype.wrapMtpMessage = function (object, options) { options = options || {} var serializer = new TLSerialization({mtproto: true}) serializer.storeObject(object, 'Object') var messageID = MtpTimeManager.generateID() var seqNo = this.generateSeqNo(options.notContentRelated) var message = { msg_id: messageID, seq_no: seqNo, body: serializer.getBytes() } if (Config.Modes.debug) { console.log(dT(), 'MT message', object, messageID, seqNo) } return this.pushMessage(message, options) } MtpNetworker.prototype.wrapApiCall = function (method, params, options) { var serializer = new TLSerialization(options) if (!this.connectionInited) { serializer.storeInt(0xda9b0d0d, 'invokeWithLayer') serializer.storeInt(Config.Schema.API.layer, 'layer') serializer.storeInt(0x69796de9, 'initConnection') serializer.storeInt(Config.App.id, 'api_id') serializer.storeString(navigator.userAgent || 'Unknown UserAgent', 'device_model') serializer.storeString(navigator.platform || 'Unknown Platform', 'system_version') serializer.storeString(Config.App.version, 'app_version') serializer.storeString(navigator.language || 'en', 'lang_code') } if (options.afterMessageID) { serializer.storeInt(0xcb9f372d, 'invokeAfterMsg') serializer.storeLong(options.afterMessageID, 'msg_id') } options.resultType = serializer.storeMethod(method, params) var messageID = MtpTimeManager.generateID() var seqNo = this.generateSeqNo() var message = { msg_id: messageID, seq_no: seqNo, body: serializer.getBytes(true), isAPI: true } if (Config.Modes.debug) { console.log(dT(), 'Api call', method, params, messageID, seqNo, options) } else { console.log(dT(), 'Api call', method) } return this.pushMessage(message, options) } MtpNetworker.prototype.checkLongPoll = function (force) { var isClean = this.cleanupSent() // console.log('Check lp', this.longPollPending, tsNow(), this.dcID, isClean) if (this.longPollPending && tsNow() < this.longPollPending || this.offline || akStopped) { return false } var self = this Storage.get('dc').then(function (baseDcID) { if (isClean && ( baseDcID != self.dcID || self.upload || self.sleepAfter && tsNow() > self.sleepAfter )) { // console.warn(dT(), 'Send long-poll for DC is delayed', self.dcID, self.sleepAfter) return } self.sendLongPoll() }) } MtpNetworker.prototype.sendLongPoll = function () { var maxWait = 25000 var self = this this.longPollPending = tsNow() + maxWait // console.log('Set lp', this.longPollPending, tsNow()) this.wrapMtpCall('http_wait', { max_delay: 500, wait_after: 150, max_wait: maxWait }, { noResponse: true, longPoll: true }).then(function () { delete self.longPollPending setZeroTimeout(self.checkLongPoll.bind(self)) }, function () { console.log('Long-poll failed') }) } MtpNetworker.prototype.pushMessage = function (message, options) { var deferred = $q.defer() this.sentMessages[message.msg_id] = angular.extend(message, options || {}, {deferred: deferred}) this.pendingMessages[message.msg_id] = 0 if (!options || !options.noShedule) { this.sheduleRequest() } if (angular.isObject(options)) { options.messageID = message.msg_id } return deferred.promise } MtpNetworker.prototype.pushResend = function (messageID, delay) { var value = delay ? tsNow() + delay : 0 var sentMessage = this.sentMessages[messageID] if (sentMessage.container) { for (var i = 0; i < sentMessage.inner.length; i++) { this.pendingMessages[sentMessage.inner[i]] = value } } else { this.pendingMessages[messageID] = value } // console.log('Resend due', messageID, this.pendingMessages) this.sheduleRequest(delay) } MtpNetworker.prototype.getMsgKeyIv = function (msgKey, isOut) { var authKey = this.authKeyUint8 var x = isOut ? 0 : 8 var sha1aText = new Uint8Array(48) var sha1bText = new Uint8Array(48) var sha1cText = new Uint8Array(48) var sha1dText = new Uint8Array(48) var promises = {} sha1aText.set(msgKey, 0) sha1aText.set(authKey.subarray(x, x + 32), 16) promises.sha1a = CryptoWorker.sha1Hash(sha1aText) sha1bText.set(authKey.subarray(x + 32, x + 48), 0) sha1bText.set(msgKey, 16) sha1bText.set(authKey.subarray(x + 48, x + 64), 32) promises.sha1b = CryptoWorker.sha1Hash(sha1bText) sha1cText.set(authKey.subarray(x + 64, x + 96), 0) sha1cText.set(msgKey, 32) promises.sha1c = CryptoWorker.sha1Hash(sha1cText) sha1dText.set(msgKey, 0) sha1dText.set(authKey.subarray(x + 96, x + 128), 16) promises.sha1d = CryptoWorker.sha1Hash(sha1dText) return $q.all(promises).then(function (result) { var aesKey = new Uint8Array(32) var aesIv = new Uint8Array(32) sha1a = new Uint8Array(result.sha1a), sha1b = new Uint8Array(result.sha1b), sha1c = new Uint8Array(result.sha1c), sha1d = new Uint8Array(result.sha1d) aesKey.set(sha1a.subarray(0, 8)) aesKey.set(sha1b.subarray(8, 20), 8) aesKey.set(sha1c.subarray(4, 16), 20) aesIv.set(sha1a.subarray(8, 20)) aesIv.set(sha1b.subarray(0, 8), 12) aesIv.set(sha1c.subarray(16, 20), 20) aesIv.set(sha1d.subarray(0, 8), 24) return [aesKey, aesIv] }) } MtpNetworker.prototype.checkConnection = function (event) { $rootScope.offlineConnecting = true console.log(dT(), 'Check connection', event) $timeout.cancel(this.checkConnectionPromise) var serializer = new TLSerialization({mtproto: true}) var pingID = [nextRandomInt(0xFFFFFFFF), nextRandomInt(0xFFFFFFFF)] serializer.storeMethod('ping', {ping_id: pingID}) var pingMessage = { msg_id: MtpTimeManager.generateID(), seq_no: this.generateSeqNo(true), body: serializer.getBytes() } var self = this this.sendEncryptedRequest(pingMessage, {timeout: 15000}).then(function (result) { delete $rootScope.offlineConnecting self.toggleOffline(false) }, function () { console.log(dT(), 'Delay ', self.checkConnectionPeriod * 1000) self.checkConnectionPromise = $timeout(self.checkConnection.bind(self), parseInt(self.checkConnectionPeriod * 1000)) self.checkConnectionPeriod = Math.min(60, self.checkConnectionPeriod * 1.5) $timeout(function () { delete $rootScope.offlineConnecting }, 1000) }) } MtpNetworker.prototype.toggleOffline = function (enabled) { // console.log('toggle ', enabled, this.dcID, this.iii) if (this.offline !== undefined && this.offline == enabled) { return false } this.offline = enabled $rootScope.offline = enabled $rootScope.offlineConnecting = false if (this.offline) { $timeout.cancel(this.nextReqPromise) delete this.nextReq if (this.checkConnectionPeriod < 1.5) { this.checkConnectionPeriod = 0 } this.checkConnectionPromise = $timeout(this.checkConnection.bind(this), parseInt(this.checkConnectionPeriod * 1000)) this.checkConnectionPeriod = Math.min(30, (1 + this.checkConnectionPeriod) * 1.5) this.onOnlineCb = this.checkConnection.bind(this) $(document.body).on('online focus', this.onOnlineCb) } else { delete this.longPollPending this.checkLongPoll() this.sheduleRequest() if (this.onOnlineCb) { $(document.body).off('online focus', this.onOnlineCb) } $timeout.cancel(this.checkConnectionPromise) } } MtpNetworker.prototype.performSheduledRequest = function () { // console.log(dT(), 'sheduled', this.dcID, this.iii) if (this.offline || akStopped) { console.log(dT(), 'Cancel sheduled') return false } delete this.nextReq if (this.pendingAcks.length) { var ackMsgIDs = [] for (var i = 0; i < this.pendingAcks.length; i++) { ackMsgIDs.push(this.pendingAcks[i]) } // console.log('acking messages', ackMsgIDs) this.wrapMtpMessage({_: 'msgs_ack', msg_ids: ackMsgIDs}, {notContentRelated: true, noShedule: true}) } if (this.pendingResends.length) { var resendMsgIDs = [] var resendOpts = {noShedule: true, notContentRelated: true} for (var i = 0; i < this.pendingResends.length; i++) { resendMsgIDs.push(this.pendingResends[i]) } // console.log('resendReq messages', resendMsgIDs) this.wrapMtpMessage({_: 'msg_resend_req', msg_ids: resendMsgIDs}, resendOpts) this.lastResendReq = {req_msg_id: resendOpts.messageID, resend_msg_ids: resendMsgIDs} } var messages = [], message var messagesByteLen = 0 var currentTime = tsNow() var hasApiCall = false var hasHttpWait = false var lengthOverflow = false var singlesCount = 0 var self = this angular.forEach(this.pendingMessages, function (value, messageID) { if (!value || value >= currentTime) { if (message = self.sentMessages[messageID]) { var messageByteLength = (message.body.byteLength || message.body.length) + 32 if (!message.notContentRelated && lengthOverflow) { return } if (!message.notContentRelated && messagesByteLen && messagesByteLen + messageByteLength > 655360) { // 640 Kb lengthOverflow = true return } if (message.singleInRequest) { singlesCount++ if (singlesCount > 1) { return } } messages.push(message) messagesByteLen += messageByteLength if (message.isAPI) { hasApiCall = true } else if (message.longPoll) { hasHttpWait = true } } else { // console.log(message, messageID) } delete self.pendingMessages[messageID] } }) if (hasApiCall && !hasHttpWait) { var serializer = new TLSerialization({mtproto: true}) serializer.storeMethod('http_wait', { max_delay: 500, wait_after: 150, max_wait: 3000 }) messages.push({ msg_id: MtpTimeManager.generateID(), seq_no: this.generateSeqNo(), body: serializer.getBytes() }) } if (!messages.length) { // console.log('no sheduled messages') return } var noResponseMsgs = [] if (messages.length > 1) { var container = new TLSerialization({mtproto: true, startMaxLength: messagesByteLen + 64}) container.storeInt(0x73f1f8dc, 'CONTAINER[id]') container.storeInt(messages.length, 'CONTAINER[count]') var onloads = [] var innerMessages = [] for (var i = 0; i < messages.length; i++) { container.storeLong(messages[i].msg_id, 'CONTAINER[' + i + '][msg_id]') innerMessages.push(messages[i].msg_id) container.storeInt(messages[i].seq_no, 'CONTAINER[' + i + '][seq_no]') container.storeInt(messages[i].body.length, 'CONTAINER[' + i + '][bytes]') container.storeRawBytes(messages[i].body, 'CONTAINER[' + i + '][body]') if (messages[i].noResponse) { noResponseMsgs.push(messages[i].msg_id) } } var containerSentMessage = { msg_id: MtpTimeManager.generateID(), seq_no: this.generateSeqNo(true), container: true, inner: innerMessages } message = angular.extend({body: container.getBytes(true)}, containerSentMessage) this.sentMessages[message.msg_id] = containerSentMessage if (Config.Modes.debug) { console.log(dT(), 'Container', innerMessages, message.msg_id, message.seq_no) } } else { if (message.noResponse) { noResponseMsgs.push(message.msg_id) } this.sentMessages[message.msg_id] = message } this.pendingAcks = [] this.sendEncryptedRequest(message).then(function (result) { self.toggleOffline(false) // console.log('parse for', message) self.parseResponse(result.data).then(function (response) { if (Config.Modes.debug) { console.log(dT(), 'Server response', self.dcID, response) } self.processMessage(response.response, response.messageID, response.sessionID) angular.forEach(noResponseMsgs, function (msgID) { if (self.sentMessages[msgID]) { var deferred = self.sentMessages[msgID].deferred delete self.sentMessages[msgID] deferred.resolve() } }) self.checkLongPoll() this.checkConnectionPeriod = Math.max(1.1, Math.sqrt(this.checkConnectionPeriod)) }) }, function (error) { console.log('Encrypted request failed', error) if (message.container) { angular.forEach(message.inner, function (msgID) { self.pendingMessages[msgID] = 0 }) delete self.sentMessages[message.msg_id] } else { self.pendingMessages[message.msg_id] = 0 } angular.forEach(noResponseMsgs, function (msgID) { if (self.sentMessages[msgID]) { var deferred = self.sentMessages[msgID].deferred delete self.sentMessages[msgID] delete self.pendingMessages[msgID] deferred.reject() } }) self.toggleOffline(true) }) if (lengthOverflow || singlesCount > 1) { this.sheduleRequest() } } MtpNetworker.prototype.getEncryptedMessage = function (bytes) { var self = this // console.log(dT(), 'Start encrypt', bytes.byteLength) return CryptoWorker.sha1Hash(bytes).then(function (bytesHash) { // console.log(dT(), 'after hash') var msgKey = new Uint8Array(bytesHash).subarray(4, 20) return self.getMsgKeyIv(msgKey, true).then(function (keyIv) { // console.log(dT(), 'after msg key iv') return CryptoWorker.aesEncrypt(bytes, keyIv[0], keyIv[1]).then(function (encryptedBytes) { // console.log(dT(), 'Finish encrypt') return { bytes: encryptedBytes, msgKey: msgKey } }) }) }) } MtpNetworker.prototype.getDecryptedMessage = function (msgKey, encryptedData) { // console.log(dT(), 'get decrypted start') return this.getMsgKeyIv(msgKey, false).then(function (keyIv) { // console.log(dT(), 'after msg key iv') return CryptoWorker.aesDecrypt(encryptedData, keyIv[0], keyIv[1]) }) } MtpNetworker.prototype.sendEncryptedRequest = function (message, options) { var self = this options = options || {} // console.log(dT(), 'Send encrypted'/*, message*/) // console.trace() var data = new TLSerialization({startMaxLength: message.body.length + 64}) data.storeIntBytes(this.serverSalt, 64, 'salt') data.storeIntBytes(this.sessionID, 64, 'session_id') data.storeLong(message.msg_id, 'message_id') data.storeInt(message.seq_no, 'seq_no') data.storeInt(message.body.length, 'message_data_length') data.storeRawBytes(message.body, 'message_data') return this.getEncryptedMessage(data.getBuffer()).then(function (encryptedResult) { // console.log(dT(), 'Got encrypted out message'/*, encryptedResult*/) var request = new TLSerialization({startMaxLength: encryptedResult.bytes.byteLength + 256}) request.storeIntBytes(self.authKeyID, 64, 'auth_key_id') request.storeIntBytes(encryptedResult.msgKey, 128, 'msg_key') request.storeRawBytes(encryptedResult.bytes, 'encrypted_data') var requestData = xhrSendBuffer ? request.getBuffer() : request.getArray() var requestPromise var url = MtpDcConfigurator.chooseServer(self.dcID, self.upload) var baseError = {code: 406, type: 'NETWORK_BAD_RESPONSE', url: url} try { options = angular.extend(options || {}, { responseType: 'arraybuffer', transformRequest: null }) requestPromise = $http.post(url, requestData, options) } catch (e) { requestPromise = $q.reject(e) } return requestPromise.then( function (result) { if (!result.data || !result.data.byteLength) { return $q.reject(baseError) } return result }, function (error) { if (!error.message && !error.type) { error = angular.extend(baseError, {type: 'NETWORK_BAD_REQUEST', originalError: error}) } return $q.reject(error) } ) }) } MtpNetworker.prototype.parseResponse = function (responseBuffer) { // console.log(dT(), 'Start parsing response') var self = this var deserializer = new TLDeserialization(responseBuffer) var authKeyID = deserializer.fetchIntBytes(64, false, 'auth_key_id') if (!bytesCmp(authKeyID, this.authKeyID)) { throw new Error('[MT] Invalid server auth_key_id: ' + bytesToHex(authKeyID)) } var msgKey = deserializer.fetchIntBytes(128, true, 'msg_key') var encryptedData = deserializer.fetchRawBytes(responseBuffer.byteLength - deserializer.getOffset(), true, 'encrypted_data') return this.getDecryptedMessage(msgKey, encryptedData).then(function (dataWithPadding) { // console.log(dT(), 'after decrypt') var deserializer = new TLDeserialization(dataWithPadding, {mtproto: true}) var salt = deserializer.fetchIntBytes(64, false, 'salt') var sessionID = deserializer.fetchIntBytes(64, false, 'session_id') var messageID = deserializer.fetchLong('message_id') if (!bytesCmp(sessionID, self.sessionID) && (!self.prevSessionID || !bytesCmp(sessionID, self.prevSessionID))) { console.warn('Sessions', sessionID, self.sessionID, self.prevSessionID) throw new Error('[MT] Invalid server session_id: ' + bytesToHex(sessionID)) } var seqNo = deserializer.fetchInt('seq_no') var offset = deserializer.getOffset() var totalLength = dataWithPadding.byteLength var messageBodyLength = deserializer.fetchInt('message_data[length]') if ((messageBodyLength % 4) || messageBodyLength > totalLength - offset) { throw new Error('[MT] Invalid body length: ' + messageBodyLength) } var messageBody = deserializer.fetchRawBytes(messageBodyLength, true, 'message_data') var offset = deserializer.getOffset() var paddingLength = totalLength - offset if (paddingLength < 0 || paddingLength > 15) { throw new Error('[MT] Invalid padding length: ' + paddingLength) } var hashData = convertToUint8Array(dataWithPadding).subarray(0, offset) return CryptoWorker.sha1Hash(hashData).then(function (dataHash) { if (!bytesCmp(msgKey, bytesFromArrayBuffer(dataHash).slice(-16))) { console.warn(msgKey, bytesFromArrayBuffer(dataHash)) throw new Error('[MT] server msgKey mismatch') } var buffer = bytesToArrayBuffer(messageBody) var deserializerOptions = { mtproto: true, override: { mt_message: function (result, field) { result.msg_id = this.fetchLong(field + '[msg_id]') result.seqno = this.fetchInt(field + '[seqno]') result.bytes = this.fetchInt(field + '[bytes]') var offset = this.getOffset() try { result.body = this.fetchObject('Object', field + '[body]') } catch (e) { console.error(dT(), 'parse error', e.message, e.stack) result.body = {_: 'parse_error', error: e} } if (this.offset != offset + result.bytes) { // console.warn(dT(), 'set offset', this.offset, offset, result.bytes) // console.log(dT(), result) this.offset = offset + result.bytes } // console.log(dT(), 'override message', result) }, mt_rpc_result: function (result, field) { result.req_msg_id = this.fetchLong(field + '[req_msg_id]') var sentMessage = self.sentMessages[result.req_msg_id] var type = sentMessage && sentMessage.resultType || 'Object' if (result.req_msg_id && !sentMessage) { // console.warn(dT(), 'Result for unknown message', result) return } result.result = this.fetchObject(type, field + '[result]') // console.log(dT(), 'override rpc_result', sentMessage, type, result) } } } var deserializer = new TLDeserialization(buffer, deserializerOptions) var response = deserializer.fetchObject('', 'INPUT') return { response: response, messageID: messageID, sessionID: sessionID, seqNo: seqNo } }) }) } MtpNetworker.prototype.applyServerSalt = function (newServerSalt) { var serverSalt = longToBytes(newServerSalt) var storeObj = {} storeObj['dc' + this.dcID + '_server_salt'] = bytesToHex(serverSalt) Storage.set(storeObj) this.serverSalt = serverSalt return true } MtpNetworker.prototype.sheduleRequest = function (delay) { if (this.offline) { this.checkConnection('forced shedule') } var nextReq = tsNow() + delay if (delay && this.nextReq && this.nextReq <= nextReq) { return false } // console.log(dT(), 'shedule req', delay) // console.trace() $timeout.cancel(this.nextReqPromise) if (delay > 0) { this.nextReqPromise = $timeout(this.performSheduledRequest.bind(this), delay || 0) } else { setZeroTimeout(this.performSheduledRequest.bind(this)) } this.nextReq = nextReq } MtpNetworker.prototype.ackMessage = function (msgID) { // console.log('ack message', msgID) this.pendingAcks.push(msgID) this.sheduleRequest(30000) } MtpNetworker.prototype.reqResendMessage = function (msgID) { console.log(dT(), 'Req resend', msgID) this.pendingResends.push(msgID) this.sheduleRequest(100) } MtpNetworker.prototype.cleanupSent = function () { var self = this var notEmpty = false // console.log('clean start', this.dcID/*, this.sentMessages*/) angular.forEach(this.sentMessages, function (message, msgID) { // console.log('clean iter', msgID, message) if (message.notContentRelated && self.pendingMessages[msgID] === undefined) { // console.log('clean notContentRelated', msgID) delete self.sentMessages[msgID] } else if (message.container) { for (var i = 0; i < message.inner.length; i++) { if (self.sentMessages[message.inner[i]] !== undefined) { // console.log('clean failed, found', msgID, message.inner[i], self.sentMessages[message.inner[i]].seq_no) notEmpty = true return } } // console.log('clean container', msgID) delete self.sentMessages[msgID] } else { notEmpty = true } }) return !notEmpty } MtpNetworker.prototype.processMessageAck = function (messageID) { var sentMessage = this.sentMessages[messageID] if (sentMessage && !sentMessage.acked) { delete sentMessage.body sentMessage.acked = true return true } return false } MtpNetworker.prototype.processError = function (rawError) { var matches = (rawError.error_message || '').match(/^([A-Z_0-9]+\b)(: (.+))?/) || [] rawError.error_code = uintToInt(rawError.error_code) return { code: !rawError.error_code || rawError.error_code <= 0 ? 500 : rawError.error_code, type: matches[1] || 'UNKNOWN', description: matches[3] || ('CODE#' + rawError.error_code + ' ' + rawError.error_message), originalError: rawError } } MtpNetworker.prototype.processMessage = function (message, messageID, sessionID) { var msgidInt = parseInt(messageID.toString(10).substr(0, -10), 10) if (msgidInt % 2) { console.warn('[MT] Server even message id: ', messageID, message) return } // console.log('process message', message, messageID, sessionID) switch (message._) { case 'msg_container': var len = message.messages.length for (var i = 0; i < len; i++) { this.processMessage(message.messages[i], message.messages[i].msg_id, sessionID) } break case 'bad_server_salt': console.log(dT(), 'Bad server salt', message) var sentMessage = this.sentMessages[message.bad_msg_id] if (!sentMessage || sentMessage.seq_no != message.bad_msg_seqno) { console.log(message.bad_msg_id, message.bad_msg_seqno) throw new Error('[MT] Bad server salt for invalid message') } this.applyServerSalt(message.new_server_salt) this.pushResend(message.bad_msg_id) this.ackMessage(messageID) break case 'bad_msg_notification': console.log(dT(), 'Bad msg notification', message) var sentMessage = this.sentMessages[message.bad_msg_id] if (!sentMessage || sentMessage.seq_no != message.bad_msg_seqno) { console.log(message.bad_msg_id, message.bad_msg_seqno) throw new Error('[MT] Bad msg notification for invalid message') } if (message.error_code == 16 || message.error_code == 17) { if (MtpTimeManager.applyServerTime( bigStringInt(messageID).shiftRight(32).toString(10) )) { console.log(dT(), 'Update session') this.updateSession() } var badMessage = this.updateSentMessage(message.bad_msg_id) this.pushResend(badMessage.msg_id) this.ackMessage(messageID) } break case 'message': if (this.lastServerMessages.indexOf(messageID) != -1) { // console.warn('[MT] Server same messageID: ', messageID) this.ackMessage(messageID) return } this.lastServerMessages.push(messageID) if (this.lastServerMessages.length > 100) { this.lastServerMessages.shift() } this.processMessage(message.body, message.msg_id, sessionID) break case 'new_session_created': this.ackMessage(messageID) this.processMessageAck(message.first_msg_id) this.applyServerSalt(message.server_salt) var self = this Storage.get('dc').then(function (baseDcID) { if (baseDcID == self.dcID && !self.upload && updatesProcessor) { updatesProcessor(message, true) } }) break case 'msgs_ack': for (var i = 0; i < message.msg_ids.length; i++) { this.processMessageAck(message.msg_ids[i]) } break case 'msg_detailed_info': if (!this.sentMessages[message.msg_id]) { this.ackMessage(message.answer_msg_id) break } case 'msg_new_detailed_info': // this.ackMessage(message.answer_msg_id) this.reqResendMessage(message.answer_msg_id) break case 'msgs_state_info': this.ackMessage(message.answer_msg_id) if (this.lastResendReq && this.lastResendReq.req_msg_id == message.req_msg_id && this.pendingResends.length) { var i, badMsgID, pos for (i = 0; i < this.lastResendReq.resend_msg_ids.length; i++) { badMsgID = this.lastResendReq.resend_msg_ids[i] pos = this.pendingResends.indexOf(badMsgID) if (pos != -1) { this.pendingResends.splice(pos, 1) } } } break case 'rpc_result': this.ackMessage(messageID) var sentMessageID = message.req_msg_id var sentMessage = this.sentMessages[sentMessageID] this.processMessageAck(sentMessageID) if (sentMessage) { var deferred = sentMessage.deferred if (message.result._ == 'rpc_error') { var error = this.processError(message.result) console.log(dT(), 'Rpc error', error) if (deferred) { deferred.reject(error) } } else { if (deferred) { if (Config.Modes.debug) { console.log(dT(), 'Rpc response', message.result) } else { var dRes = message.result._ if (!dRes) { if (message.result.length > 5) { dRes = '[..' + message.result.length + '..]' } else { dRes = message.result } } console.log(dT(), 'Rpc response', dRes) } sentMessage.deferred.resolve(message.result) } if (sentMessage.isAPI) { this.connectionInited = true } } delete this.sentMessages[sentMessageID] } break default: this.ackMessage(messageID) // console.log('Update', message) if (updatesProcessor) { updatesProcessor(message, true) } break } } function startAll () { if (akStopped) { akStopped = false updatesProcessor({_: 'new_session_created'}, true) } } function stopAll () { akStopped = true } return { getNetworker: function (dcID, authKey, serverSalt, options) { return new MtpNetworker(dcID, authKey, serverSalt, options) }, setUpdatesProcessor: function (callback) { updatesProcessor = callback }, stopAll: stopAll, startAll: startAll } })