webnative/lib/data-root.js

import * as check from "./fs/types/check.js";
import * as debug from "./common/debug.js";
import * as did from "./did/index.js";
import * as dns from "./dns/index.js";
import * as ucan from "./ucan/index.js";
import { api } from "./common/index.js";
import { setup } from "./setup/internal.js";
/**
 * CID representing an empty string. We use to to speed up DNS propagation
 * However, we treat that as a null value in the code
 */
const EMPTY_CID = 'Qmc5m94Gu7z62RC8waSKkZUrCCBJPyHbkpmGzEePxy2oXJ';
/**
 * Get the CID of a user's data root.
 * First check Fission server, then check DNS
 *
 * @param username The username of the user that we want to get the data root of.
 */
export async function lookup(username) {
    const maybeRoot = await lookupOnFisson(username);
    if (maybeRoot === EMPTY_CID)
        return null;
    if (maybeRoot !== null)
        return maybeRoot;
    try {
        const cid = await dns.lookupDnsLink(username + '.files.' + setup.endpoints.user);
        return cid === EMPTY_CID ? null : cid;
    }
    catch (err) {
        console.error(err);
        throw new Error('Could not locate user root in dns');
    }
}
/**
 * Get the CID of a user's data root from the Fission server.
 *
 * @param username The username of the user that we want to get the data root of.
 */
export async function lookupOnFisson(username) {
    try {
        const resp = await fetch(`${setup.endpoints.api}/user/data/${username}`, { cache: 'reload' } // don't use cache
        );
        const cid = await resp.json();
        if (!check.isCID(cid)) {
            throw new Error("Did not receive a CID");
        }
        return cid;
    }
    catch (err) {
        debug.log('Could not locate user root on Fission server: ', err.toString());
        return null;
    }
}
/**
 * Update a user's data root.
 *
 * @param cid The CID of the data root.
 * @param proof The proof to use in the UCAN sent to the API.
 */
export async function update(cid, proof) {
    const apiEndpoint = setup.endpoints.api;
    // Debug
    debug.log("🌊 Updating your DNSLink:", cid);
    // Make API call
    return await fetchWithRetry(`${apiEndpoint}/user/data/${cid}`, {
        headers: async () => {
            const jwt = ucan.encode(await ucan.build({
                audience: await api.did(),
                issuer: await did.ucan(),
                potency: "APPEND",
                proof,
                // TODO: Waiting on API change.
                //       Should be `username.fission.name/*`
                resource: ucan.decode(proof).payload.rsc
            }));
            return { 'authorization': `Bearer ${jwt}` };
        },
        retries: 100,
        retryDelay: 5000,
        retryOn: [502, 503, 504],
    }, {
        method: 'PATCH'
    }).then((response) => {
        if (response.status < 300)
            debug.log("🪴 DNSLink updated:", cid);
        else
            debug.log("🔥 Failed to update DNSLink for:", cid);
        return { success: response.status < 300 };
    }).catch(err => {
        debug.log("🔥 Failed to update DNSLink for:", cid);
        console.error(err);
        return { success: false };
    });
}
async function fetchWithRetry(url, retryOptions, fetchOptions, retry = 0) {
    const headers = await retryOptions.headers();
    const response = await fetch(url, {
        ...fetchOptions,
        headers: { ...fetchOptions.headers, ...headers }
    });
    if (retryOptions.retryOn.includes(response.status)) {
        if (retry < retryOptions.retries) {
            return await new Promise((resolve, reject) => setTimeout(() => fetchWithRetry(url, retryOptions, fetchOptions, retry + 1).then(resolve, reject), retryOptions.retryDelay));
        }
        else {
            throw new Error("Too many retries for fetch");
        }
    }
    return response;
}
//# sourceMappingURL=data-root.js.map