r4sas/webogram-i2p
1
0
Fork 0
Code Issues Releases Wiki Activity

Fixed authorizer bad network handling

Browse Source 
Closes #415
This commit is contained in:
Igor Zhukov 2014-08-05 14:56:45 +01:00
parent 2f12621a01
commit 98da2bbea4
2 changed files with 12 additions and 11 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

22
app/js/lib/mtproto.js
View File

@ -199,15 +199,16 @@ angular.module('izhukov.mtproto', ['izhukov.utils'])
return $http.post('http://' + MtpDcConfigurator.chooseServer(dcID) + '/apiw1', resultArray, { return $http.post('http://' + MtpDcConfigurator.chooseServer(dcID) + '/apiw1', resultArray, {
responseType: 'arraybuffer', responseType: 'arraybuffer',
transformRequest: null, transformRequest: null
transformResponse: function (responseBuffer) { }).then(
if (!responseBuffer || !responseBuffer.byteLength) { function (result) {
if (!result.data || !result.data.byteLength) {
return $q.reject({code: 406, type: 'NETWORK_BAD_RESPONSE'}); return $q.reject({code: 406, type: 'NETWORK_BAD_RESPONSE'});
} }
try { try {
var deserializer = new TLDeserialization(responseBuffer, {mtproto: true}); var deserializer = new TLDeserialization(result.data, {mtproto: true});
var auth_key_id = deserializer.fetchLong('auth_key_id'); var auth_key_id = deserializer.fetchLong('auth_key_id');
var msg_id = deserializer.fetchLong('msg_id'); var msg_id = deserializer.fetchLong('msg_id');
var msg_len = deserializer.fetchInt('msg_len'); var msg_len = deserializer.fetchInt('msg_len');
@ -219,13 +220,14 @@ angular.module('izhukov.mtproto', ['izhukov.utils'])
rng_seed_time(); rng_seed_time();
return deserializer; return deserializer;
},
function (error) {
if (!error.message && !error.type) {
error = {code: 406, type: 'NETWORK_BAD_REQUEST'};
}
return $q.reject(error);
} }
})['catch'](function (error) { );
if (!error.message && !error.type) {
error = {code: 406, type: 'NETWORK_BAD_REQUEST'};
}
return $q.reject(error);
});
}; };
function mtpSendReqPQ (auth) { function mtpSendReqPQ (auth) {

1
app/js/services.js
View File

@ -1994,7 +1994,6 @@ angular.module('myApp.services', [])
delete pendingByMessageID[message.id]; delete pendingByMessageID[message.id];
} }
// console.log(11, randomID, pendingMessage);
if (!pendingMessage) { if (!pendingMessage) {
$rootScope.$broadcast('history_append', {peerID: peerID, messageID: message.id}); $rootScope.$broadcast('history_append', {peerID: peerID, messageID: message.id});
} }