@stoplight/graphite/resolver.js

"use strict";
Object.defineProperty(exports, "__esModule", { value: true });
const json_ref_resolver_1 = require("@stoplight/json-ref-resolver");
const yaml_1 = require("@stoplight/yaml");
const node_fetch_1 = require("node-fetch");
const nodes_1 = require("./graph/nodes");
exports.createResolver = (uriCache, getNodeByUri) => {
    const httpReader = {
        async resolve(uri) {
            const res = await node_fetch_1.default(String(uri));
            if (res.status >= 400) {
                throw new Error(res.statusText);
            }
            return res.text();
        },
    };
    const fileReader = {
        resolve: async (uri) => {
            const path = decodeURI(uri.valueOf());
            const referredNode = getNodeByUri(path);
            if (!referredNode) {
                throw new Error(`Target $ref not found: ${String(uri)}`);
            }
            if (referredNode.category === nodes_1.NodeCategory.Virtual) {
                throw new Error(`Resolving virtual nodes is not supported. Node Id = ${referredNode.id}`);
            }
            return referredNode.category === nodes_1.NodeCategory.Source ? referredNode.data.raw : referredNode.data.parsed;
        },
    };
    return new json_ref_resolver_1.Resolver({
        uriCache,
        resolvers: {
            http: httpReader,
            https: httpReader,
            file: fileReader,
        },
        parseResolveResult: async (opts) => {
            const referredNode = getNodeByUri(opts.targetAuthority.toString());
            if (referredNode && referredNode.category !== nodes_1.NodeCategory.Virtual) {
                opts.result = referredNode.data.parsed;
            }
            else if (typeof opts.result === 'string') {
                try {
                    opts.result = yaml_1.parse(opts.result);
                }
                catch (e) {
                }
            }
            return opts;
        },
    });
};
class ResolveCache extends json_ref_resolver_1.Cache {
    set(key, value) {
        if (key.indexOf('http') === 0) {
            super.set(key, value);
        }
    }
}
exports.ResolveCache = ResolveCache;
//# sourceMappingURL=resolver.js.map