Function computePlan

dev/local/env-sync/plan.ts:480–809

(repoRoot: string, serviceFilter?: Set<string>)

  );
  return new Map(groupedResults.flat());
}

function resolveSecretStoreSource(
  secretName: string,
  envLocal: Map<string, string>,
  localSecretSources: Map<string, { sourceKey: string; value: string }>
): { sourceKey: string; value: string } | undefined {
  const baseKey = secretName.replace(/_(PROD|DEV)$/, '');
  const exactLocalSource = localSecretSources.get(secretName);
  if (exactLocalSource) {
    return exactLocalSource;
  }

  const exactEnvLocalValue = envLocal.get(secretName);
  if (exactEnvLocalValue) {
    return { sourceKey: secretName, value: exactEnvLocalValue };
  }

  const baseEnvLocalValue = envLocal.get(baseKey);
  if (baseEnvLocalValue) {
    return { sourceKey: baseKey, value: baseEnvLocalValue };
  }

  return localSecretSources.get(baseKey);
}

function collectLocalSecretSources(
  repoRoot: string,
  workerDirs: string[],
  envLocal: Map<string, string>,
  lanIp: string | undefined,
  dirUsesLanIp: Map<string, boolean>
): Map<string, { sourceKey: string; value: string }> {
  const sources = new Map<string, { sourceKey: string; value: string }>();

  for (const workerDir of workerDirs) {
    const devVarsPath = path.join(repoRoot, workerDir, '.dev.vars');
    const localVars = readEnvFile(devVarsPath);
    for (const [key, value] of localVars) {
      if (value) {
        sources.set(key, {
          sourceKey: `${workerDir}/.dev.vars:${key}`,
          value,
        });
      }
    }

    const examplePath = path.join(repoRoot, workerDir, '.dev.vars.example');
    const serviceUsesLanIp = dirUsesLanIp.get(workerDir) ?? false;
    if (fs.existsSync(examplePath)) {
      const entries = parseExampleFile(fs.readFileSync(examplePath, 'utf-8'));
      for (const entry of entries) {
        if (entry.annotation.type === 'exec') {
          continue;
        }
        const { value } = resolveAnnotatedValue(
          entry.key,
          entry,