Rietveld Code Review Tool
Help | Bug tracker | Discussion group | Source code

Delta Between Two Patch Sets: lib/downloader.js

Issue 29859565: Issue 6741 - Use ES2015 classes in lib/downloader.js (Closed) Base URL: https://hg.adblockplus.org/adblockpluscore/
Left Patch Set: Insert blank line before jsdocs for _timer Created Aug. 21, 2018, 7:13 p.m.
Right Patch Set: Address PS7 comments Created Aug. 27, 2018, 4:16 p.m.
Left:
Right:
Use n/p to move between diff chunks; N/P to move between comments.
Jump to:
Left: Side by side diff | Download
Right: Side by side diff | Download
« no previous file with change/comment | « no previous file | no next file » | no next file with change/comment »
Toggle Intra-line Diffs ('i') | Expand Comments ('e') | Collapse Comments ('c') | Show Comments Hide Comments ('s')
LEFTRIGHT
1 /* 1 /*
2 * This file is part of Adblock Plus <https://adblockplus.org/>, 2 * This file is part of Adblock Plus <https://adblockplus.org/>,
3 * Copyright (C) 2006-present eyeo GmbH 3 * Copyright (C) 2006-present eyeo GmbH
4 * 4 *
5 * Adblock Plus is free software: you can redistribute it and/or modify 5 * Adblock Plus is free software: you can redistribute it and/or modify
6 * it under the terms of the GNU General Public License version 3 as 6 * it under the terms of the GNU General Public License version 3 as
7 * published by the Free Software Foundation. 7 * published by the Free Software Foundation.
8 * 8 *
9 * Adblock Plus is distributed in the hope that it will be useful, 9 * Adblock Plus is distributed in the hope that it will be useful,
10 * but WITHOUT ANY WARRANTY; without even the implied warranty of 10 * but WITHOUT ANY WARRANTY; without even the implied warranty of
(...skipping 14 matching lines...) Expand all
25 25
26 const MILLIS_IN_SECOND = exports.MILLIS_IN_SECOND = 1000; 26 const MILLIS_IN_SECOND = exports.MILLIS_IN_SECOND = 1000;
27 const MILLIS_IN_MINUTE = exports.MILLIS_IN_MINUTE = 60 * MILLIS_IN_SECOND; 27 const MILLIS_IN_MINUTE = exports.MILLIS_IN_MINUTE = 60 * MILLIS_IN_SECOND;
28 const MILLIS_IN_HOUR = exports.MILLIS_IN_HOUR = 60 * MILLIS_IN_MINUTE; 28 const MILLIS_IN_HOUR = exports.MILLIS_IN_HOUR = 60 * MILLIS_IN_MINUTE;
29 const MILLIS_IN_DAY = exports.MILLIS_IN_DAY = 24 * MILLIS_IN_HOUR; 29 const MILLIS_IN_DAY = exports.MILLIS_IN_DAY = 24 * MILLIS_IN_HOUR;
30 30
31 class Downloader 31 class Downloader
32 { 32 {
33 /** 33 /**
34 * Creates a new downloader instance. 34 * Creates a new downloader instance.
35 * @param {Function} dataSource 35 * @param {function} dataSource
Manish Jethani 2018/08/22 06:13:34 Another JSDoc convention that I think that we shou
Jon Sonesen 2018/08/22 18:18:51 Done.
36 * Function that will yield downloadable objects on each check 36 * Function that will yield downloadable objects on each check
37 * @param {number} initialDelay 37 * @param {number} initialDelay
38 * Number of milliseconds to wait before the first check 38 * Number of milliseconds to wait before the first check
39 * @param {number} checkInterval 39 * @param {number} checkInterval
40 * Interval between the checks 40 * Interval between the checks
41 */ 41 */
42 constructor(dataSource, initialDelay, checkInterval) 42 constructor(dataSource, initialDelay, checkInterval)
43 { 43 {
44 /** 44 /**
45 * Maximal time interval that the checks can be left out until the soft 45 * Maximal time interval that the checks can be left out until the soft
(...skipping 16 matching lines...) Expand all
62 this.maxExpirationInterval = 14 * MILLIS_IN_DAY; 62 this.maxExpirationInterval = 14 * MILLIS_IN_DAY;
63 63
64 /** 64 /**
65 * Maximal number of redirects before the download is considered as failed. 65 * Maximal number of redirects before the download is considered as failed.
66 * @type {number} 66 * @type {number}
67 */ 67 */
68 this.maxRedirects = 5; 68 this.maxRedirects = 5;
69 69
70 /** 70 /**
71 * Called whenever expiration intervals for an object need to be adapted. 71 * Called whenever expiration intervals for an object need to be adapted.
72 * @type {Function} 72 * @type {function?}
73 */ 73 */
74 this.onExpirationChange = null; 74 this.onExpirationChange = null;
75 75
76 /** 76 /**
77 * Callback to be triggered whenever a download starts. 77 * Callback to be triggered whenever a download starts.
78 * @type {Function} 78 * @type {function?}
79 */ 79 */
80 this.onDownloadStarted = null; 80 this.onDownloadStarted = null;
81 81
82 /** 82 /**
83 * Callback to be triggered whenever a download finishes successfully. The 83 * Callback to be triggered whenever a download finishes successfully. The
84 * callback can return an error code to indicate that the data is wrong. 84 * callback can return an error code to indicate that the data is wrong.
85 * @type {Function} 85 * @type {function?}
86 */ 86 */
87 this.onDownloadSuccess = null; 87 this.onDownloadSuccess = null;
88 88
89 /** 89 /**
90 * Callback to be triggered whenever a download fails. 90 * Callback to be triggered whenever a download fails.
91 * @type {Function} 91 * @type {function?}
92 */ 92 */
93 this.onDownloadError = null; 93 this.onDownloadError = null;
94 94
95 /** 95 /**
96 * Function that will yield downloadable objects on each check. 96 * Function that will yield downloadable objects on each check.
97 * @type {Function} 97 * @type {function}
98 */ 98 */
99 this.dataSource = dataSource; 99 this.dataSource = dataSource;
100 100
101 /** 101 /**
102 * Timer triggering the downloads. 102 * Timer triggering the downloads.
103 * @type {nsITimer} 103 * @type {nsITimer}
104 */ 104 */
105 this._timer = Cc["@mozilla.org/timer;1"].createInstance(Ci.nsITimer); 105 this._timer = Cc["@mozilla.org/timer;1"].createInstance(Ci.nsITimer);
106 this._timer.initWithCallback(() => 106 this._timer.initWithCallback(() =>
107 { 107 {
(...skipping 59 matching lines...) Expand 10 before | Expand all | Expand 10 after
167 * Stops the periodic checks. 167 * Stops the periodic checks.
168 */ 168 */
169 cancel() 169 cancel()
170 { 170 {
171 this._timer.cancel(); 171 this._timer.cancel();
172 } 172 }
173 173
174 /** 174 /**
175 * Checks whether an address is currently being downloaded. 175 * Checks whether an address is currently being downloaded.
176 * @param {string} url 176 * @param {string} url
177 * @return {boolean} 177 * @returns {boolean}
178 */ 178 */
179 isDownloading(url) 179 isDownloading(url)
180 { 180 {
181 return this._downloading.has(url); 181 return this._downloading.has(url);
182 } 182 }
183 183
184 /** 184 /**
185 * Starts downloading for an object. 185 * Starts downloading for an object.
186 * @param {Downloadable} downloadable 186 * @param {Downloadable} downloadable
187 */ 187 */
188 download(downloadable) 188 download(downloadable)
189 { 189 {
190 // Make sure to detach download from the current execution context 190 // Make sure to detach download from the current execution context
191 Utils.runAsync(this._download.bind(this, downloadable, 0)); 191 Utils.runAsync(this._download.bind(this, downloadable, 0));
192 } 192 }
193 193
194 /** 194 /**
195 * Generates the real download URL for an object by appending various 195 * Generates the real download URL for an object by appending various
196 * parameters. 196 * parameters.
197 * @param {Downloadable} downloadable 197 * @param {Downloadable} downloadable
198 * @return {string} 198 * @returns {string}
199 */ 199 */
200 getDownloadUrl(downloadable) 200 getDownloadUrl(downloadable)
201 { 201 {
202 const {addonName, addonVersion, application, applicationVersion, 202 const {addonName, addonVersion, application, applicationVersion,
203 platform, platformVersion} = require("info"); 203 platform, platformVersion} = require("info");
204 let url = downloadable.redirectURL || downloadable.url; 204 let url = downloadable.redirectURL || downloadable.url;
205 if (url.includes("?")) 205 if (url.includes("?"))
206 url += "&"; 206 url += "&";
207 else 207 else
208 url += "?"; 208 url += "?";
(...skipping 127 matching lines...) Expand 10 before | Expand all | Expand 10 after
336 336
337 this._downloading.add(downloadable.url); 337 this._downloading.add(downloadable.url);
338 if (this.onDownloadStarted) 338 if (this.onDownloadStarted)
339 this.onDownloadStarted(downloadable); 339 this.onDownloadStarted(downloadable);
340 } 340 }
341 341
342 /** 342 /**
343 * Produces a soft and a hard expiration interval for a given supplied 343 * Produces a soft and a hard expiration interval for a given supplied
344 * expiration interval. 344 * expiration interval.
345 * @param {number} interval 345 * @param {number} interval
346 * @return {Array} soft and hard expiration interval 346 * @returns {Array.<number>} soft and hard expiration interval
347 */ 347 */
348 processExpirationInterval(interval) 348 processExpirationInterval(interval)
349 { 349 {
350 interval = Math.min(Math.max(interval, 0), this.maxExpirationInterval); 350 interval = Math.min(Math.max(interval, 0), this.maxExpirationInterval);
351 let soft = Math.round(interval * (Math.random() * 0.4 + 0.8)); 351 let soft = Math.round(interval * (Math.random() * 0.4 + 0.8));
352 let hard = interval * 2; 352 let hard = interval * 2;
353 let now = Date.now(); 353 let now = Date.now();
354 return [now + soft, now + hard]; 354 return [now + soft, now + hard];
355 } 355 }
356 } 356 }
357
357 exports.Downloader = Downloader; 358 exports.Downloader = Downloader;
358 359
359 class Downloadable 360 class Downloadable
360 { 361 {
361 /** 362 /**
362 * An object that can be downloaded by the downloadable 363 * Creates an object that can be downloaded by the downloader.
Manish Jethani 2018/08/22 06:13:35 I think this should be "Creates an object that can
Jon Sonesen 2018/08/22 18:18:51 Done.
363 * @param {string} url URL that has to be requested for the object 364 * @param {string} url URL that has to be requested for the object
364 */ 365 */
365 constructor(url) 366 constructor(url)
366 { 367 {
368 /**
369 * URL that the download was redirected to if any.
370 * @type {string?}
371 */
372 this.redirectURL = null;
373
374 /**
375 * Time of last download error or 0 if the last download was successful.
376 * @type {number}
377 */
378 this.lastError = 0;
379
380 /**
381 * Time of last check whether the object needs downloading.
382 * @type {number}
383 */
384 this.lastCheck = 0;
385
386 /**
387 * Object version corresponding to the last successful download.
388 * @type {number}
389 */
390 this.lastVersion = 0;
391
392 /**
393 * Soft expiration interval; will increase if no checks are performed for a
394 * while.
395 * @type {number}
396 */
397 this.softExpiration = 0;
398
399 /**
400 * Hard expiration interval; this is fixed.
401 * @type {number}
402 */
403 this.hardExpiration = 0;
404
405 /**
406 * Number indicating how often the object was downloaded.
407 * @type {number}
408 */
409 this.downloadCount = 0;
410
367 /** 411 /**
368 * URL that has to be requested for the object. 412 * URL that has to be requested for the object.
369 * @type {string} 413 * @type {string}
370 */ 414 */
371 this.url = null;
Manish Jethani 2018/08/22 06:13:35 Let's also just assign `this.url` directly at the
Jon Sonesen 2018/08/22 18:18:51 Done.
372
373 /**
374 * URL that the download was redirected to if any.
375 * @type {string}
376 */
377 this.redirectURL = null;
378
379 /**
380 * Time of last download error or 0 if the last download was successful.
381 * @type {number}
382 */
383 this.lastError = 0;
384
385 /**
386 * Time of last check whether the object needs downloading.
387 * @type {number}
388 */
389 this.lastCheck = 0;
390
391 /**
392 * Object version corresponding to the last successful download.
393 * @type {number}
394 */
395 this.lastVersion = 0;
396
397 /**
398 * Soft expiration interval; will increase if no checks are performed for a
399 * while.
400 * @type {number}
401 */
402 this.softExpiration = 0;
403
404 /**
405 * Hard expiration interval; this is fixed.
406 * @type {number}
407 */
408 this.hardExpiration = 0;
409
410 /**
411 * Number indicating how often the object was downloaded.
412 * @type {number}
413 */
414 this.downloadCount = 0;
415 this.url = url; 415 this.url = url;
416 } 416 }
417 } 417 }
418
418 exports.Downloadable = Downloadable; 419 exports.Downloadable = Downloadable;
LEFTRIGHT
« no previous file | no next file » | Toggle Intra-line Diffs ('i') | Expand Comments ('e') | Collapse Comments ('c') | Toggle Comments ('s')

Powered by Google App Engine
This is Rietveld