Function replaceFileReferences

packages/cli/src/controller/publish-controller.ts:100–131

(
  projectDir: string,
  input: T,
  authToken?: string,
  ipfs?: IPFSHTTPClientLite
)

/* Recursively finds all FileReferences in an object and replaces the files with IPFS references */
async function replaceFileReferences<T extends Record<string, any>>(
  projectDir: string,
  input: T,
  authToken?: string,
  ipfs?: IPFSHTTPClientLite
): Promise<T> {
  if (Array.isArray(input)) {
    return (await Promise.all(
      input.map((val) => replaceFileReferences(projectDir, val, authToken, ipfs))
    )) as unknown as T;
  } else if (typeof input === 'object' && input !== null) {
    if (input instanceof Map) {
      input = mapToObject(input) as T;
    }
    if (isFileReference(input)) {
      const filePath = path.resolve(projectDir, input.file);
      const content = fs.readFileSync(path.resolve(projectDir, input.file));
      input.file = await uploadFile({content: content.toString(), path: filePath}, authToken, ipfs).then(
        (cid) => `ipfs://${cid}`
      );
    }
    const keys = Object.keys(input).filter((key) => key !== '_deployment') as unknown as (keyof T)[];
    await Promise.all(
      keys.map(async (key) => {
        // this is the loop
        input[key] = await replaceFileReferences(projectDir, input[key], authToken, ipfs);
      })
    );
  }

  return input;
}

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