Function uploadFiles

packages/cli/src/controller/publish-controller.ts:135–176

(
  contents: {path: string; content: string}[],
  authToken?: string,
  isMultichain?: boolean,
  ipfs?: IPFSHTTPClientLite
)

const fileMap = new Map<string | fs.ReadStream, Promise<string>>();

export async function uploadFiles(
  contents: {path: string; content: string}[],
  authToken?: string,
  isMultichain?: boolean,
  ipfs?: IPFSHTTPClientLite
): Promise<Map<string, string>> {
  const fileCidMap: Map<string, string> = new Map();

  if (ipfs) {
    try {
      const results = await ipfs.addAll(contents, {wrapWithDirectory: isMultichain});

      for (const result of results) {
        fileCidMap.set(result.path, result.cid.toString());
      }
    } catch (e) {
      throw new Error(`Publish project to provided IPFS gateway failed`, {cause: e});
    }
  }

  const ipfsWrite = new IPFSHTTPClientLite({
    url: IPFS_WRITE_ENDPOINT,
    headers: authToken ? {Authorization: `Bearer ${authToken}`} : undefined,
  });

  try {
    const results = await ipfsWrite.addAll(contents, {pin: true, cidVersion: 0, wrapWithDirectory: isMultichain});
    for (const result of results) {
      fileCidMap.set(result.path, result.cid);

      await ipfsWrite.pinRemoteAdd(result.cid, {service: PIN_SERVICE}).catch((e) => {
        console.warn(
          `Failed to pin file ${result.path}. There might be problems with this file being accessible later. ${e}`
        );
      });
    }
  } catch (e) {
    throw new Error(`Publish project files to IPFS failed`, {cause: e});
  }

  return fileCidMap;
}

export async function uploadFile(
  contents: {path: string; content: string},