*Update dist
This commit is contained in:
parent
33f5d36aca
commit
122124c550
|
@ -1,5 +1,5 @@
|
||||||
import tldEnum from "@lumeweb/tld-enum";
|
import tldEnum from "@lumeweb/tld-enum";
|
||||||
import { AbstractResolverModule, DNS_RECORD_TYPE, isDomain, isIp, isPromise, normalizeDomain, resolverEmptyResponse, resolveSuccess, ensureUniqueRecords, getTld, } from "@lumeweb/libresolver";
|
import { AbstractResolverModule, DNS_RECORD_TYPE, isDomain, isIp, isPromise, normalizeDomain, resolverEmptyResponse, resolveSuccess, ensureUniqueRecords, getTld, resolverError, } from "@lumeweb/libresolver";
|
||||||
const HIP5_EXTENSIONS = ["eth", "_eth"];
|
const HIP5_EXTENSIONS = ["eth", "_eth"];
|
||||||
export default class Handshake extends AbstractResolverModule {
|
export default class Handshake extends AbstractResolverModule {
|
||||||
async buildBlacklist() {
|
async buildBlacklist() {
|
||||||
|
@ -31,11 +31,14 @@ export default class Handshake extends AbstractResolverModule {
|
||||||
return resolverEmptyResponse();
|
return resolverEmptyResponse();
|
||||||
}
|
}
|
||||||
const chainRecords = await this.query(tld, bypassCache);
|
const chainRecords = await this.query(tld, bypassCache);
|
||||||
if (!chainRecords) {
|
if (chainRecords.error) {
|
||||||
|
return resolverError(chainRecords.error);
|
||||||
|
}
|
||||||
|
if (!chainRecords.data?.records.length) {
|
||||||
return resolverEmptyResponse();
|
return resolverEmptyResponse();
|
||||||
}
|
}
|
||||||
let records = [];
|
let records = [];
|
||||||
for (const record of chainRecords) {
|
for (const record of chainRecords.data?.records) {
|
||||||
switch (record.type) {
|
switch (record.type) {
|
||||||
case "NS": {
|
case "NS": {
|
||||||
await this.processNs(domain, record, records, chainRecords, options, bypassCache);
|
await this.processNs(domain, record, records, chainRecords, options, bypassCache);
|
||||||
|
@ -161,10 +164,8 @@ export default class Handshake extends AbstractResolverModule {
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
async query(tld, bypassCache) {
|
async query(tld, bypassCache) {
|
||||||
const query = this.resolver.rpcNetwork.wisdomQuery("getnameresource", "handshakearn build", [tld], bypassCache);
|
let query = this.resolver.rpcNetwork.wisdomQuery("getnameresource", "handshake", [tld], bypassCache);
|
||||||
const resp = await query.result;
|
return (await query.result);
|
||||||
// @ts-ignore
|
|
||||||
return resp?.records || [];
|
|
||||||
}
|
}
|
||||||
async processTxt(record, records, options) {
|
async processTxt(record, records, options) {
|
||||||
const content = record.txt.slice().pop();
|
const content = record.txt.slice().pop();
|
||||||
|
|
Loading…
Reference in New Issue