feat: check project status at link time

api/beta.yaml

@@ -817,6 +817,31 @@ paths:
       security:
         - bearer: []
   /v1/projects/{ref}:
+    get:
+      operationId: v1-get-project
+      summary: Gets a specific project status that belongs to the authenticated user
+      parameters:
+        - name: ref
+          required: true
+          in: path
+          description: Project ref
+          schema:
+            minLength: 20
+            maxLength: 20
+            type: string
+      responses:
+        '200':
+          description: ''
+          content:
+            application/json:
+              schema:
+                $ref: '#/components/schemas/V1ProjectResponse'
+        '500':
+          description: Failed to retrieve project status
+      tags:
+        - Projects
+      security:
+        - bearer: []
     delete:
       operationId: v1-delete-a-project
       summary: Deletes the given project

internal/link/link.go

@@ -29,6 +29,11 @@ func Run(ctx context.Context, projectRef string, fsys afero.Fs, options ...func(
 		"api": utils.Config.Api,
 		"db":  utils.Config.Db,
 	})
+
+	if err := checkRemoteProjectStatus(ctx, projectRef); err != nil {
+		return err
+	}
+
 	// 1. Check service config
 	keys, err := tenant.GetApiKeys(ctx, projectRef)
 	if err != nil {
@@ -233,3 +238,20 @@ func updatePoolerConfig(config api.SupavisorConfigResponse) {
 		utils.Config.Db.Pooler.MaxClientConn = uint(*config.MaxClientConn)
 	}
 }
+
+func checkRemoteProjectStatus(ctx context.Context, projectRef string) error {
+	resp, err := utils.GetSupabase().V1GetProjectWithResponse(ctx, projectRef)
+	if err != nil {
+		return errors.Errorf("failed to retrieve remote project status: %w", err)
+	}
+	if resp.JSON200 == nil {
+		return errors.New("Unexpected error retrieving remote project status: " + string(resp.Body))
+	}
+	if resp.JSON200.Status == api.V1ProjectResponseStatusINACTIVE {
+		return errors.New(fmt.Sprintf("Project is paused. An admin must unpause it from the Supabase dashboard at %s", utils.Aqua(fmt.Sprintf("%s/project/%s", utils.GetSupabaseDashboardURL(), projectRef))))
+	}
+	if resp.JSON200.Status != api.V1ProjectResponseStatusACTIVEHEALTHY {
+		fmt.Fprintf(os.Stderr, "%s: Project status is %s instead of Active Healthy. Some operations might fail.\n", utils.Yellow("Warning"), resp.JSON200.Status)
+	}
+	return nil
+}

internal/link/link_test.go

@@ -48,6 +48,11 @@ func TestLinkCommand(t *testing.T) {
 		helper.MockMigrationHistory(conn)
 		// Flush pending mocks after test execution
 		defer gock.OffAll()
+		// Mock project status
+		gock.New(utils.DefaultApiHost).
+			Get("/v1/projects/" + project).
+			Reply(200).
+			JSON(api.V1ProjectResponse{Status: api.V1ProjectResponseStatusACTIVEHEALTHY})
 		gock.New(utils.DefaultApiHost).
 			Get("/v1/projects/" + project + "/api-keys").
 			Reply(200).
@@ -119,6 +124,11 @@ func TestLinkCommand(t *testing.T) {
 		fsys := afero.NewMemMapFs()
 		// Flush pending mocks after test execution
 		defer gock.OffAll()
+		// Mock project status
+		gock.New(utils.DefaultApiHost).
+			Get("/v1/projects/" + project).
+			Reply(200).
+			JSON(api.V1ProjectResponse{Status: api.V1ProjectResponseStatusACTIVEHEALTHY})
 		gock.New(utils.DefaultApiHost).
 			Get("/v1/projects/" + project + "/api-keys").
 			Reply(200).
@@ -159,6 +169,11 @@ func TestLinkCommand(t *testing.T) {
 		fsys := afero.NewReadOnlyFs(afero.NewMemMapFs())
 		// Flush pending mocks after test execution
 		defer gock.OffAll()
+		// Mock project status
+		gock.New(utils.DefaultApiHost).
+			Get("/v1/projects/" + project).
+			Reply(200).
+			JSON(api.V1ProjectResponse{Status: api.V1ProjectResponseStatusACTIVEHEALTHY})
 		gock.New(utils.DefaultApiHost).
 			Get("/v1/projects/" + project + "/api-keys").
 			Reply(200).
@@ -193,6 +208,22 @@ func TestLinkCommand(t *testing.T) {
 		assert.NoError(t, err)
 		assert.False(t, exists)
 	})
+	t.Run("throws error on project inactive", func(t *testing.T) {
+		// Setup in-memory fs
+		fsys := afero.NewReadOnlyFs(afero.NewMemMapFs())
+		// Flush pending mocks after test execution
+		defer gock.OffAll()
+		// Mock project status
+		gock.New(utils.DefaultApiHost).
+			Get("/v1/projects/" + project).
+			Reply(200).
+			JSON(api.V1ProjectResponse{Status: api.V1ProjectResponseStatusINACTIVE})
+		// Run test
+		err := Run(context.Background(), project, fsys)
+		// Check error
+		assert.ErrorContains(t, err, "Project is paused. An admin must unpause it from the Supabase dashboard")
+		assert.Empty(t, apitest.ListUnmatchedRequests())
+	})
 }
 
 func TestLinkPostgrest(t *testing.T) {