You cannot select more than 25 topics
Topics must start with a letter or number, can include dashes ('-') and can be up to 35 characters long.
143 lines
3.2 KiB
TypeScript
143 lines
3.2 KiB
TypeScript
import * as dns from 'dns';
|
|
import { clearTimeout, setTimeout } from 'timers';
|
|
|
|
import { MongoRuntimeError } from '../error';
|
|
import { TypedEventEmitter } from '../mongo_types';
|
|
import { HostAddress, matchesParentDomain } from '../utils';
|
|
|
|
/**
|
|
* @internal
|
|
* @category Event
|
|
*/
|
|
export class SrvPollingEvent {
|
|
srvRecords: dns.SrvRecord[];
|
|
constructor(srvRecords: dns.SrvRecord[]) {
|
|
this.srvRecords = srvRecords;
|
|
}
|
|
|
|
hostnames(): Set<string> {
|
|
return new Set(this.srvRecords.map(r => HostAddress.fromSrvRecord(r).toString()));
|
|
}
|
|
}
|
|
|
|
/** @internal */
|
|
export interface SrvPollerOptions {
|
|
srvServiceName: string;
|
|
srvMaxHosts: number;
|
|
srvHost: string;
|
|
heartbeatFrequencyMS: number;
|
|
}
|
|
|
|
/** @internal */
|
|
export type SrvPollerEvents = {
|
|
srvRecordDiscovery(event: SrvPollingEvent): void;
|
|
};
|
|
|
|
/** @internal */
|
|
export class SrvPoller extends TypedEventEmitter<SrvPollerEvents> {
|
|
srvHost: string;
|
|
rescanSrvIntervalMS: number;
|
|
heartbeatFrequencyMS: number;
|
|
haMode: boolean;
|
|
generation: number;
|
|
srvMaxHosts: number;
|
|
srvServiceName: string;
|
|
_timeout?: NodeJS.Timeout;
|
|
|
|
/** @event */
|
|
static readonly SRV_RECORD_DISCOVERY = 'srvRecordDiscovery' as const;
|
|
|
|
constructor(options: SrvPollerOptions) {
|
|
super();
|
|
|
|
if (!options || !options.srvHost) {
|
|
throw new MongoRuntimeError('Options for SrvPoller must exist and include srvHost');
|
|
}
|
|
|
|
this.srvHost = options.srvHost;
|
|
this.srvMaxHosts = options.srvMaxHosts ?? 0;
|
|
this.srvServiceName = options.srvServiceName ?? 'mongodb';
|
|
this.rescanSrvIntervalMS = 60000;
|
|
this.heartbeatFrequencyMS = options.heartbeatFrequencyMS ?? 10000;
|
|
|
|
this.haMode = false;
|
|
this.generation = 0;
|
|
|
|
this._timeout = undefined;
|
|
}
|
|
|
|
get srvAddress(): string {
|
|
return `_${this.srvServiceName}._tcp.${this.srvHost}`;
|
|
}
|
|
|
|
get intervalMS(): number {
|
|
return this.haMode ? this.heartbeatFrequencyMS : this.rescanSrvIntervalMS;
|
|
}
|
|
|
|
start(): void {
|
|
if (!this._timeout) {
|
|
this.schedule();
|
|
}
|
|
}
|
|
|
|
stop(): void {
|
|
if (this._timeout) {
|
|
clearTimeout(this._timeout);
|
|
this.generation += 1;
|
|
this._timeout = undefined;
|
|
}
|
|
}
|
|
|
|
// TODO(NODE-4994): implement new logging logic for SrvPoller failures
|
|
schedule(): void {
|
|
if (this._timeout) {
|
|
clearTimeout(this._timeout);
|
|
}
|
|
|
|
this._timeout = setTimeout(() => {
|
|
this._poll().catch(() => null);
|
|
}, this.intervalMS);
|
|
}
|
|
|
|
success(srvRecords: dns.SrvRecord[]): void {
|
|
this.haMode = false;
|
|
this.schedule();
|
|
this.emit(SrvPoller.SRV_RECORD_DISCOVERY, new SrvPollingEvent(srvRecords));
|
|
}
|
|
|
|
failure(): void {
|
|
this.haMode = true;
|
|
this.schedule();
|
|
}
|
|
|
|
async _poll(): Promise<void> {
|
|
const generation = this.generation;
|
|
let srvRecords;
|
|
|
|
try {
|
|
srvRecords = await dns.promises.resolveSrv(this.srvAddress);
|
|
} catch (dnsError) {
|
|
this.failure();
|
|
return;
|
|
}
|
|
|
|
if (generation !== this.generation) {
|
|
return;
|
|
}
|
|
|
|
const finalAddresses: dns.SrvRecord[] = [];
|
|
for (const record of srvRecords) {
|
|
if (matchesParentDomain(record.name, this.srvHost)) {
|
|
finalAddresses.push(record);
|
|
}
|
|
}
|
|
|
|
if (!finalAddresses.length) {
|
|
this.failure();
|
|
return;
|
|
}
|
|
|
|
this.success(finalAddresses);
|
|
}
|
|
}
|