File Explorer

1"use strict";2Object.defineProperty(exports, "__esModule", { value: true });3exports.HostEntry = void 0;4const types_1 = require("@aws-sdk/types");5const HostAddressEntryCollection_1 = require("./HostAddressEntryCollection");6class HostEntry {7    aaaaRecords;8    aRecords;9    failedAaaaRecords;10    failedARecords;11    nextTimestampToUpdateMs;12    constructor(nextTimestampToProcessMs) {13        this.aaaaRecords = new HostAddressEntryCollection_1.HostAddressEntryCollection();14        this.aRecords = new HostAddressEntryCollection_1.HostAddressEntryCollection();15        this.failedAaaaRecords = new HostAddressEntryCollection_1.HostAddressEntryCollection();16        this.failedARecords = new HostAddressEntryCollection_1.HostAddressEntryCollection();17        this.nextTimestampToUpdateMs = nextTimestampToProcessMs;18    }19    updateRecords(addresses, expirationTtlMs) {20        this.nextTimestampToUpdateMs = expirationTtlMs;21        const addressesToAppend = [];22        for (const freshAddress of addresses) {23            const hostAddressEntry = this.findAddress(freshAddress);24            if (hostAddressEntry !== undefined) {25                hostAddressEntry.expirationTtlMs = expirationTtlMs;26                continue;27            }28            addressesToAppend.push(freshAddress);29        }30        for (const addressToAppend of addressesToAppend) {31            const hostAddressEntry = this.findAddress(addressToAppend);32            if (hostAddressEntry !== undefined) {33                continue;34            }35            const successRecords = this.getGoodRecords(addressToAppend);36            successRecords.append(Object.assign(addressToAppend, {37                expirationTtlMs,38            }));39        }40    }41    processRecords() {42        this.processRecordsAddressType(this.aRecords, this.failedARecords);43        this.processRecordsAddressType(this.aaaaRecords, this.failedAaaaRecords);44    }45    failAddressInRecords(address) {46        const successRecords = this.getGoodRecords(address);47        const failedRecords = this.getFailedRecords(address);48        const recordsToRemove = [];49        for (const hostAddressEntry of successRecords) {50            if (hostAddressEntry.address === address.address) {51                recordsToRemove.push(hostAddressEntry);52                failedRecords.append(hostAddressEntry);53            }54        }55        for (const recordToRemove of recordsToRemove) {56            successRecords.remove(recordToRemove);57        }58    }59    findAddress(address) {60        const successRecords = this.getGoodRecords(address);61        for (const hostAddressEntry of successRecords) {62            if (address.address === hostAddressEntry.address) {63                return hostAddressEntry;64            }65        }66        const failedRecords = this.getFailedRecords(address);67        for (const hostAddressEntry of failedRecords) {68            if (address.address === hostAddressEntry.address) {69                return hostAddressEntry;70            }71        }72        return undefined;73    }74    processRecordsAddressType(successRecords, failedRecords) {75        const successRecordsToRemove = [];76        let successIndex = 0;77        for (const hostAddressEntry of successRecords) {78            if (successIndex === successRecords.length - 1) {79                break;80            }81            if (Date.now() >= hostAddressEntry.expirationTtlMs) {82                successRecordsToRemove.push(hostAddressEntry);83            }84            successIndex++;85        }86        for (const recordToRemove of successRecordsToRemove) {87            successRecords.remove(recordToRemove);88        }89        const failedRecordsToRemove = [];90        let failedIndex = 0;91        for (const hostAddressEntry of failedRecords) {92            if (failedIndex === failedRecords.length - 1) {93                break;94            }95            if (Date.now() >= hostAddressEntry.expirationTtlMs) {96                failedRecordsToRemove.push(hostAddressEntry);97            }98            failedIndex++;99        }100        for (const recordToRemove of failedRecordsToRemove) {101            failedRecords.remove(recordToRemove);102        }103        if (successRecords.length === 0) {104            let hostAddressEntryToPromote = undefined;105            for (const hostAddressEntry of failedRecords) {106                if (Date.now() >= hostAddressEntry.expirationTtlMs) {107                    continue;108                }109                hostAddressEntryToPromote = hostAddressEntry;110                break;111            }112            if (hostAddressEntryToPromote !== undefined) {113                failedRecords.remove(hostAddressEntryToPromote);114                successRecords.append(hostAddressEntryToPromote);115            }116        }117    }118    getGoodRecords(address) {119        return address.addressType === types_1.HostAddressType.AAAA ? this.aaaaRecords : this.aRecords;120    }121    getFailedRecords(address) {122        return address.addressType === types_1.HostAddressType.AAAA ? this.failedAaaaRecords : this.failedARecords;123    }124}125exports.HostEntry = HostEntry;126