Function migrateSubgraphAdapter

packages/cli/src/commands/migrate.ts:52–132

(
  workingDir: string,
  args: MigrateSubgraphInputs,
  logger: Logger
)

});

async function migrateSubgraphAdapter(
  workingDir: string,
  args: MigrateSubgraphInputs,
  logger: Logger
): Promise<z.infer<typeof migrateSubgraphOutputs>> {
  const gitMatch = extractGitInfo(args.input);

  const parsedSubqlPath = path.parse(path.resolve(workingDir, args.output));
  // We don't need to check output directory is existing or not
  const subqlDir = parsedSubqlPath.ext === '' ? args.output : parsedSubqlPath.dir;
  let subgraphDir: string;
  let tempSubgraphDir: string | undefined;
  if (gitMatch) {
    tempSubgraphDir = await makeTempDir();
    const {branch, link} = gitMatch;
    // clone the subdirectory project
    if (args.gitSubDirectory) {
      subgraphDir = path.join(tempSubgraphDir, args.gitSubDirectory);
      await git(tempSubgraphDir).init().addRemote('origin', link);
      await git(tempSubgraphDir).raw('sparse-checkout', 'set', args.gitSubDirectory);
      assert(branch, 'Branch is required for git subdirectory');
      await git(tempSubgraphDir).raw('pull', 'origin', branch);
    } else {
      subgraphDir = tempSubgraphDir;
      await git().clone(link, subgraphDir, branch ? ['-b', branch, '--single-branch'] : ['--single-branch']);
    }
    logger.info(
      `* Pull subgraph project from git: ${link}, branch: ${branch ?? 'default branch'}${
        args.gitSubDirectory ? `, subdirectory:${args.gitSubDirectory}` : '.'
      }`
    );
  } else {
    // will return false if directory not exist
    if (lstatSync(path.resolve(workingDir, args.input), {throwIfNoEntry: false})?.isDirectory()) {
      if (args.gitSubDirectory) {
        logger.warn(`Git sub directory only works with git path, not local directories.`);
      }
      subgraphDir = args.input;
    } else {
      throw new Error(`Subgraph project should be a git ssh/link or file directory`);
    }
  }

  const subgraphManifestPath = path.join(subgraphDir, DEFAULT_SUBGRAPH_MANIFEST);
  const subgraphSchemaPath = path.join(subgraphDir, DEFAULT_SUBGRAPH_SCHEMA);
  const subqlManifestPath = path.join(subqlDir, DEFAULT_SUBQL_MANIFEST);
  const subqlSchemaPath = path.join(subqlDir, DEFAULT_SUBQL_SCHEMA);

  try {
    const subgraphManifest = readSubgraphManifest(subgraphManifestPath, subgraphDir);
    improveProjectInfo(subgraphDir, subgraphManifest);
    subgraphValidation(subgraphManifest);
    const chainInfo = await extractNetworkFromManifest(subgraphManifest);
    await prepareProject(chainInfo, subqlDir);
    await migrateAbis(subgraphManifest, subgraphDir, subqlDir);
    await migrateManifest(chainInfo, subgraphManifest, subqlManifestPath);
    // render package.json
    await preparePackage(subqlDir, {