Function updateDataSourcesV1_0_0

packages/node-core/src/utils/project.ts:121–159

(
  _dataSources: (DS | CDS)[],
  reader: Reader,
  root: string,
  isCustomDs: IsCustomDs<DS, CDS>
)

}

export async function updateDataSourcesV1_0_0<DS extends BaseDataSource, CDS extends DS & BaseCustomDataSource>(
  _dataSources: (DS | CDS)[],
  reader: Reader,
  root: string,
  isCustomDs: IsCustomDs<DS, CDS>
): Promise<(DS | CDS)[]> {
  // force convert to updated ds
  return Promise.all(
    _dataSources.map(async (dataSource) => {
      dataSource.startBlock = dataSource.startBlock ?? 1;
      const entryScript = await loadDataSourceScript(reader, dataSource.mapping.file);
      if (isAssetsDs(dataSource) && dataSource.assets) {
        for (const [, asset] of dataSource.assets.entries()) {
          // Only need to resolve path for local file
          if (reader instanceof LocalReader) {
            asset.file = path.resolve(root, asset.file);
          } else {
            asset.file = await fetchAndSaveFile(reader, root, asset.file, '');
          }
        }
      }
      const file = await updateDataSourcesEntry(reader, dataSource.mapping.file, root, entryScript);
      if (isCustomDs(dataSource)) {
        if (dataSource.processor) {
          dataSource.processor.file = await updateProcessor(reader, root, dataSource.processor.file);
        }
        return {
          ...dataSource,
          mapping: {...dataSource.mapping, file},
        };
      } else {
        return {
          ...dataSource,
          mapping: {...dataSource.mapping, file},
        };
      }
    })
  );
}

export async function updateDataSourcesEntry(
  reader: Reader,