interceptor.js
2.88 KB
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
angular.module('focaConfiguracion')
.factory("interceptorRequest", [ '$injector',
function($injector) {
function reintentarRequest(httpConfig) {
var $timeout = $injector.get('$timeout');
return $timeout(function() {
var $http = $injector.get('$http');
return $http(httpConfig.config);
}, 10000);
}
function updateDataSqlite(request) {
var sqliteService = $injector.get('focaSqliteService');
sqliteService.updateQuery(
request.config.url,
JSON.stringify(request.config.data),
request.config.method,
JSON.stringify(request.data));
}
function getDataSqlite(request) {
return new Promise(function(resolve) {
var sqliteService = $injector.get('focaSqliteService');
sqliteService.getQuery(
request.config.url,
JSON.stringify(request.config.data),
request.config.method,
respuesta);
function respuesta(config) {
if (config) {
var request = {
data: JSON.parse(config.response),
status: 200
};
resolve(request);
} else {
resolve(false);
}
}
});
}
function broadCastRed(status) {
var $rootScope = $injector.get('$rootScope');
$rootScope.$broadcast('estadoRed', status);
}
var request = {
responseError: async function(config) {
if (config.status === -1) {
broadCastRed(false);
var data = await getDataSqlite(config);
if (!data) {
return reintentarRequest(config);
} else {
config.data = data.data;
return config;
}
} else {
return config;
}
},
response: function(response) {
if (typeof response.data !== 'string') {
broadCastRed(true);
updateDataSqlite(response);
}
return response;
}
}
return request;
}
]).config(['$httpProvider', function($httpProvider) {
$httpProvider.interceptors.push('interceptorRequest');
}]);