@effectai/effect-js/dist/services/ipfs.js

"use strict";
Object.defineProperty(exports, "__esModule", { value: true });
exports.IpfsService = exports.IpfsContentFormat = void 0;
var IpfsContentFormat;
(function (IpfsContentFormat) {
    IpfsContentFormat["FormData"] = "formdata";
    IpfsContentFormat["ArrayBuffer"] = "arraybuffer";
    IpfsContentFormat["Blob"] = "blob";
    IpfsContentFormat["Text"] = "text";
    IpfsContentFormat["JSON"] = "json";
})(IpfsContentFormat || (exports.IpfsContentFormat = IpfsContentFormat = {}));
class IpfsService {
    constructor(client) {
        this.client = client;
        this.upload = async (obj) => {
            try {
                let blob = new Blob([JSON.stringify(obj)], { type: 'application/json' });
                const formData = new FormData();
                formData.append('file', blob);
                if (blob.size > 1024 * 1024 * 10) {
                    throw new Error('File too large, max file size is: 10MB');
                }
                else {
                    const requestOptions = {
                        method: 'POST',
                        body: formData,
                    };
                    const response = await this.client.fetchProvider.fetch(`${this.client.config.ipfsEndpoint}/api/v0/add?pin=true`, requestOptions);
                    if (!response.ok) {
                        const errorText = await response.text();
                        throw new Error(`Error in IPFS upload: ${errorText}`);
                    }
                    else {
                        const json = await response.json();
                        return json.Hash;
                    }
                }
            }
            catch (error) {
                throw new Error(error);
            }
        };
        /**
         * Get IPFS Content in JSON, without caching, to be in getIpfsContent.
         * @param {string} hash - hash of the IPFS content you want to fetch
         * @param {IpfsContentFormat} format - format of the content you are fetching,
         * @returns content of the ipfs hash in your preferred format
         */
        this.fetch = async (hash, ipfsContentForm = IpfsContentFormat.JSON) => {
            try {
                let data;
                data = await this.client.fetchProvider.fetch(`${this.client.config.ipfsEndpoint}/ipfs/${hash}`);
                // Return the IPFS content in the format you want
                switch (ipfsContentForm) {
                    case IpfsContentFormat.FormData:
                        return data.formData();
                    case IpfsContentFormat.ArrayBuffer:
                        return data.arrayBuffer();
                    case IpfsContentFormat.Blob:
                        return data.blob();
                    case IpfsContentFormat.Text:
                        return data.text();
                    case IpfsContentFormat.JSON:
                        return await data.json();
                    default:
                        return data;
                }
            }
            catch (error) {
                console.error(error);
            }
        };
    }
}
exports.IpfsService = IpfsService;
//# sourceMappingURL=ipfs.js.map