mirror of
https://github.com/EvolutionAPI/evolution-api.git
synced 2025-07-13 15:14:49 -06:00
commit
ed5ff089c5
@ -213,3 +213,10 @@ AUTHENTICATION_API_KEY=429683C4C977415CAAFCCE10F7D57E11
|
||||
# If you leave this option as true, the instances will be exposed in the fetch instances endpoint.
|
||||
AUTHENTICATION_EXPOSE_IN_FETCH_INSTANCES=true
|
||||
LANGUAGE=en
|
||||
|
||||
# Define a global proxy to be used if the instance does not have one
|
||||
# PROXY_HOST=
|
||||
# PROXY_PORT=80
|
||||
# PROXY_PROTOCOL=http
|
||||
# PROXY_USERNAME=
|
||||
# PROXY_PASSWORD=
|
@ -21,6 +21,9 @@ export class CacheService {
|
||||
}
|
||||
|
||||
public async hGet(key: string, field: string) {
|
||||
if (!this.cache) {
|
||||
return null;
|
||||
}
|
||||
try {
|
||||
const data = await this.cache.hGet(key, field);
|
||||
|
||||
@ -43,6 +46,9 @@ export class CacheService {
|
||||
}
|
||||
|
||||
public async hSet(key: string, field: string, value: any) {
|
||||
if (!this.cache) {
|
||||
return;
|
||||
}
|
||||
try {
|
||||
const json = JSON.stringify(value, BufferJSON.replacer);
|
||||
|
||||
@ -67,6 +73,9 @@ export class CacheService {
|
||||
}
|
||||
|
||||
async hDelete(key: string, field: string) {
|
||||
if (!this.cache) {
|
||||
return false;
|
||||
}
|
||||
try {
|
||||
await this.cache.hDelete(key, field);
|
||||
return true;
|
||||
|
@ -338,18 +338,31 @@ export class ChannelStartupService {
|
||||
}
|
||||
|
||||
public async loadProxy() {
|
||||
this.localProxy.enabled = false;
|
||||
|
||||
if (process.env.PROXY_HOST) {
|
||||
this.localProxy.enabled = true;
|
||||
this.localProxy.host = process.env.PROXY_HOST;
|
||||
this.localProxy.port = process.env.PROXY_PORT || '80';
|
||||
this.localProxy.protocol = process.env.PROXY_PROTOCOL || 'http';
|
||||
this.localProxy.username = process.env.PROXY_USERNAME;
|
||||
this.localProxy.password = process.env.PROXY_PASSWORD;
|
||||
}
|
||||
|
||||
const data = await this.prismaRepository.proxy.findUnique({
|
||||
where: {
|
||||
instanceId: this.instanceId,
|
||||
},
|
||||
});
|
||||
|
||||
this.localProxy.enabled = data?.enabled;
|
||||
this.localProxy.host = data?.host;
|
||||
this.localProxy.port = data?.port;
|
||||
this.localProxy.protocol = data?.protocol;
|
||||
this.localProxy.username = data?.username;
|
||||
this.localProxy.password = data?.password;
|
||||
if (data?.enabled) {
|
||||
this.localProxy.enabled = true;
|
||||
this.localProxy.host = data?.host;
|
||||
this.localProxy.port = data?.port;
|
||||
this.localProxy.protocol = data?.protocol;
|
||||
this.localProxy.username = data?.username;
|
||||
this.localProxy.password = data?.password;
|
||||
}
|
||||
}
|
||||
|
||||
public async setProxy(data: ProxyDto) {
|
||||
|
Loading…
Reference in New Issue
Block a user