|
|
|
@ -1,6 +1,8 @@
|
|
|
|
|
const https = require("https");
|
|
|
|
|
const http = require("http");
|
|
|
|
|
const CacheableLookup = require("cacheable-lookup");
|
|
|
|
|
const { Settings } = require("./settings");
|
|
|
|
|
const { log } = require("../src/util");
|
|
|
|
|
|
|
|
|
|
class CacheableDnsHttpAgent {
|
|
|
|
|
|
|
|
|
@ -9,12 +11,30 @@ class CacheableDnsHttpAgent {
|
|
|
|
|
static httpAgentList = {};
|
|
|
|
|
static httpsAgentList = {};
|
|
|
|
|
|
|
|
|
|
static enable = false;
|
|
|
|
|
|
|
|
|
|
/**
|
|
|
|
|
* Register cacheable to global agents
|
|
|
|
|
* Register/Disable cacheable to global agents
|
|
|
|
|
*/
|
|
|
|
|
static registerGlobalAgent() {
|
|
|
|
|
this.cacheable.install(http.globalAgent);
|
|
|
|
|
this.cacheable.install(https.globalAgent);
|
|
|
|
|
static async update() {
|
|
|
|
|
log.debug("CacheableDnsHttpAgent", "update");
|
|
|
|
|
let isEnable = await Settings.get("dnsCache");
|
|
|
|
|
|
|
|
|
|
if (isEnable !== this.enable) {
|
|
|
|
|
log.debug("CacheableDnsHttpAgent", "value changed");
|
|
|
|
|
|
|
|
|
|
if (isEnable) {
|
|
|
|
|
log.debug("CacheableDnsHttpAgent", "enable");
|
|
|
|
|
this.cacheable.install(http.globalAgent);
|
|
|
|
|
this.cacheable.install(https.globalAgent);
|
|
|
|
|
} else {
|
|
|
|
|
log.debug("CacheableDnsHttpAgent", "disable");
|
|
|
|
|
this.cacheable.uninstall(http.globalAgent);
|
|
|
|
|
this.cacheable.uninstall(https.globalAgent);
|
|
|
|
|
}
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
this.enable = isEnable;
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
static install(agent) {
|
|
|
|
@ -26,6 +46,10 @@ class CacheableDnsHttpAgent {
|
|
|
|
|
* @return {https.Agent}
|
|
|
|
|
*/
|
|
|
|
|
static getHttpsAgent(agentOptions) {
|
|
|
|
|
if (!this.enable) {
|
|
|
|
|
return new https.Agent(agentOptions);
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
let key = JSON.stringify(agentOptions);
|
|
|
|
|
if (!(key in this.httpsAgentList)) {
|
|
|
|
|
this.httpsAgentList[key] = new https.Agent(agentOptions);
|
|
|
|
@ -39,6 +63,10 @@ class CacheableDnsHttpAgent {
|
|
|
|
|
* @return {https.Agents}
|
|
|
|
|
*/
|
|
|
|
|
static getHttpAgent(agentOptions) {
|
|
|
|
|
if (!this.enable) {
|
|
|
|
|
return new http.Agent(agentOptions);
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
let key = JSON.stringify(agentOptions);
|
|
|
|
|
if (!(key in this.httpAgentList)) {
|
|
|
|
|
this.httpAgentList[key] = new http.Agent(agentOptions);
|
|
|
|
|