Method executeLinkFlow

packages/cli/src/postgres/link/Link.ts:236–270

(
    apiKey: string | undefined,
    databaseId: string | undefined,
    baseDir: string,
  )

  }

  private async executeLinkFlow(
    apiKey: string | undefined,
    databaseId: string | undefined,
    baseDir: string,
  ): Promise<LinkResult> {
    const client = await resolveApiClient(apiKey)

    let workspaceId: string | null = null
    let projectId: string | null = null

    if (!databaseId) {
      const resolved = await resolveDatabase(client)
      databaseId = resolved.databaseId
      workspaceId = resolved.workspaceId
      projectId = resolved.projectId
    } else {
      workspaceId = apiKey ? extractWorkspaceIdFromToken(apiKey) : null
      projectId = await resolveProjectForDatabase(client, databaseId)
    }

    const connection = await createDevConnection(client, databaseId)
    const localFilesResult = writeLocalFiles(baseDir, connection)
    const hasModels = getModelNames(baseDir).length > 0
    const environmentId = databaseId.replace(/^db_/, '')

    return {
      workspaceId: workspaceId ?? 'unknown',
      projectId: projectId ?? 'unknown',
      environmentId,
      databaseId,
      connectionString: connection.connectionString,
      localFilesResult,
      hasModels,
    }
  }

  private static formatError(err: unknown): HelpError {
    if (err instanceof LinkApiError) {