Function load

src/dataconnect/load.ts:84–135

(
  projectId: string,
  config: Config,
  sourceDirectory: string,
)

 * loads schemas and connectors from  {sourceDirectory}/dataconnect.yaml
 */
export async function load(
  projectId: string,
  config: Config,
  sourceDirectory: string,
): Promise<ServiceInfo> {
  // TODO: better error handling when config read fails
  const resolvedDir = config.path(sourceDirectory);
  const dataConnectYaml = await readDataConnectYaml(resolvedDir);
  const serviceName = `projects/${projectId}/locations/${dataConnectYaml.location}/services/${dataConnectYaml.serviceId}`;
  const schemaYamls = dataConnectYaml.schema ? [dataConnectYaml.schema] : dataConnectYaml.schemas;
  const schemas = await Promise.all(
    schemaYamls!.map(async (yaml) => {
      const schemaDir = path.join(resolvedDir, yaml.source);
      const schemaGQLs = await readGQLFiles(schemaDir);
      return {
        name: `${serviceName}/schemas/${yaml.id || MAIN_SCHEMA_ID}`,
        datasources: [toDatasource(projectId, dataConnectYaml.location, yaml.datasource)],
        source: {
          files: schemaGQLs,
        },
      };
    }),
  );
  const connectorInfo = await Promise.all(
    dataConnectYaml.connectorDirs.map(async (dir) => {
      const connectorDir = path.join(resolvedDir, dir);
      const connectorYaml = await readConnectorYaml(connectorDir);
      const connectorGqls = await readGQLFiles(connectorDir);
      const clientCache = inferClientCache(connectorYaml);

      return {
        directory: connectorDir,
        connectorYaml,
        connector: {
          name: `${serviceName}/connectors/${connectorYaml.connectorId}`,
          source: {
            files: connectorGqls,
          },
          client_cache: clientCache,
        },
      };
    }),
  );

  return {
    serviceName,
    sourceDirectory: resolvedDir,
    schemas: schemas,
    dataConnectYaml,
    connectorInfo,
  };
}

export function readFirebaseJson(config?: Config): DataConnectMultiple {
  if (!config?.has("dataconnect")) {