https://github.com/matomo-org/matomo/blob/4.x-dev/offline-service-worker.js - Mouve

Site d'origine

Permalink
 
 
Cannot retrieve contributors at this time
var matomoAnalytics = {initialize: function (options) {
if ('object' !== typeof options) {
options = {};
}
var maxLimitQueue = options.queueLimit || 50;
var maxTimeLimit = options.timeLimit || (60 * 60 * 24); // in seconds...
// same as configured in in tracking_requests_require_authentication_when_custom_timestamp_newer_than
function getQueue()
{
return new Promise(function(resolve, reject) {
// do a thing, possibly async, then...
if (!indexedDB) {
reject(new Error('No support for IndexedDB'));
return;
}
var request = indexedDB.open("matomo", 1);
request.onerror = function() {
console.error("Error", request.error);
reject(new Error(request.error));
};
request.onupgradeneeded = function(event) {
console.log('onupgradeneeded')
var db = event.target.result;
if (!db.objectStoreNames.contains('requests')) {
db.createObjectStore('requests', {autoIncrement : true, keyPath: 'id'});
}
};
request.onsuccess = function(event) {
var db = event.target.result;
let transaction = db.transaction("requests", "readwrite");
let requests =transaction.objectStore("requests");
resolve(requests);
};
});
}
function syncQueue () {
// check something in indexdb
return getQueue().then(function (queue) {
queue.openCursor().onsuccess = function(event) {
var cursor = event.target.result;
if (cursor && navigator.onLine) {
cursor.continue();
var queueId = cursor.value.id;
var secondsQueuedAgo = ((Date.now() - cursor.value.created) / 1000);
secondsQueuedAgo = parseInt(secondsQueuedAgo, 10);
if (secondsQueuedAgo > maxTimeLimit) {
// too old
getQueue().then(function (queue) {
queue.delete(queueId);
});
return;
}
console.log("Cursor " + cursor.key);
var init = {
headers: cursor.value.headers,
method: cursor.value.method,
}
if (cursor.value.body) {
init.body = cursor.value.body;
}
if (cursor.value.url.includes('?')) {
cursor.value.url += '&cdo=' + secondsQueuedAgo;
} else if (init.body) {
// todo test if this actually works for bulk requests
init.body = init.body.replace('&idsite=', '&cdo=' + secondsQueuedAgo + '&idsite=');
}
fetch(cursor.value.url, init).then(function (response) {
console.log('server response', response);
if (response.status < 400) {
getQueue().then(function (queue) {
queue.delete(queueId);
});
}
}).catch(function (error) {
console.error('Send to Server failed:', error);
throw error
})
}
else {
console.log("No more entries!");
}
};
});
}
function limitQueueIfNeeded(queue)
{
var countRequest = queue.count();
countRequest.onsuccess = function(event) {
if (event.result > maxLimitQueue) {
// we delete only one at a time because of concurrency some other process might delete data too
queue.openCursor().onsuccess = function(event) {
var cursor = event.target.result;
if (cursor) {
queue.delete(cursor.value.id);
limitQueueIfNeeded(queue);
}
}
}
}
}
self.addEventListener('sync', function(event) {
if (event.tag === 'matomoSync') {
syncQueue();
}
});
self.addEventListener('fetch', function (event) {
let isOnline = navigator.onLine;
let isTrackingRequest = (event.request.url.includes('/matomo.php')
|| event.request.url.includes('/piwik.php'));
let isTrackerRequest = event.request.url.endsWith('/matomo.js')
|| event.request.url.endsWith('/piwik.js');
if (isTrackerRequest) {
if (isOnline) {
syncQueue();
}
caches.open('matomo').then(function(cache) {
return cache.match(event.request).then(function (response) {
return response || fetch(event.request).then(function(response) {
cache.put(event.request, response.clone());
return response;
});
});
})
} else if (isTrackingRequest && isOnline) {
syncQueue();
event.respondWith(fetch(event.request));
} else if (isTrackingRequest && !isOnline) {
var headers = {};
for (const [header, value] of event.request.headers) {
headers[header] = value;
}
let requestInfo = {
url: event.request.url,
referrer : event.request.referrer,
method : event.request.method,
referrerPolicy : event.request.referrerPolicy,
headers : headers,
created: Date.now()
};
event.request.text().then(function (postData) {
requestInfo.body = postData;
getQueue().then(function (queue) {
queue.add(requestInfo);
limitQueueIfNeeded(queue);
return queue;
});
});
}
});
}
};

level de log mis à 1

Récupération du document https://github.com/matomo-org/matomo/blob/4.x-dev/offline-service-worker.js.

Récupération de l'URL https://github.com/matomo-org/matomo/blob/4.x-dev/offline-service-worker.js...

Raccourcis

Commandes

Fermer