forked from mirrors/gecko-dev
dcccd900a3
This simple cache is generally applicable to protocols that need to fetch an HPKE key over TLS that doesn't change and would benefit from caching. Subsequent patches will use this for the DAPTelemetrySender. Differential Revision: https://phabricator.services.mozilla.com/D193696
42 lines
1.2 KiB
JavaScript
42 lines
1.2 KiB
JavaScript
/* This Source Code Form is subject to the terms of the Mozilla Public
|
|
* License, v. 2.0. If a copy of the MPL was not distributed with this file,
|
|
* You can obtain one at http://mozilla.org/MPL/2.0/. */
|
|
|
|
let knownConfigs = new Map();
|
|
|
|
export class HPKEConfigManager {
|
|
static async get(aURL, aOptions = {}) {
|
|
try {
|
|
let config = await this.#getInternal(aURL, aOptions);
|
|
return new Uint8Array(config);
|
|
} catch (ex) {
|
|
console.error(ex);
|
|
return null;
|
|
}
|
|
}
|
|
|
|
static async #getInternal(aURL, aOptions = {}) {
|
|
let { maxAge = -1 } = aOptions;
|
|
let knownConfig = knownConfigs.get(aURL);
|
|
if (
|
|
knownConfig &&
|
|
(maxAge < 0 || Date.now() - knownConfig.fetchDate < maxAge)
|
|
) {
|
|
return knownConfig.config;
|
|
}
|
|
return this.fetchAndStore(aURL, aOptions);
|
|
}
|
|
|
|
static async fetchAndStore(aURL, aOptions = {}) {
|
|
let fetchDate = Date.now();
|
|
let resp = await fetch(aURL);
|
|
if (!resp?.ok) {
|
|
throw new Error(
|
|
`Fetching HPKE config from ${aURL} failed with error ${resp.status}`
|
|
);
|
|
}
|
|
let config = await resp.blob().then(b => b.arrayBuffer());
|
|
knownConfigs.set(aURL, { config, fetchDate });
|
|
return config;
|
|
}
|
|
}
|