chore: check if the parent resource for the policy exists (#48)

* feat: support policy data source

* chore: support CRUD policy resource

* chore: support config sql review rules

* chore: update docs

* chore: update version

* chore: update docs

* chore: update docs

* chore: update docs

* chore: optimize

* chore: update

* chore: update version

* chore: add tests

* chore: update access control policy & sql review policy

* chore: check if the parent resource for the policy exists

* chore: hide policy

Author: ecmadao

VERSION

@@ -1 +1 @@
-0.0.7-alpha.7
+0.0.7

api/client.go

@@ -59,4 +59,12 @@ type Client interface {
 	UpsertPolicy(ctx context.Context, find *PolicyFindMessage, patch *PolicyPatchMessage) (*PolicyMessage, error)
 	// DeletePolicy deletes the policy.
 	DeletePolicy(ctx context.Context, find *PolicyFindMessage) error
+
+	// Database
+	// GetDatabase gets the database by environment resource id, instance resource id and the database name.
+	GetDatabase(ctx context.Context, find *DatabaseFindMessage) (*DatabaseMessage, error)
+
+	// Project
+	// GetProject gets the project by resource id.
+	GetProject(ctx context.Context, projectID string) (*PorjectMessage, error)
 }

api/database.go

@@ -0,0 +1,15 @@
+package api
+
+// DatabaseFindMessage is the API message for finding database.
+type DatabaseFindMessage struct {
+	EnvironmentID string
+	InstanceID    string
+	DatabaseName  string
+}
+
+// DatabaseMessage is the API message for database.
+type DatabaseMessage struct {
+	Name          string `json:"name"`
+	Project       string `json:"project"`
+	SchemaVersion string `json:"schemaVersion"`
+}

api/project.go

@@ -0,0 +1,15 @@
+package api
+
+// PorjectMessage is the API message for project.
+type PorjectMessage struct {
+	Name           string `json:"name"`
+	Title          string `json:"title"`
+	Key            string `json:"key"`
+	Workflow       string `json:"workflow"`
+	Visibility     string `json:"visibility"`
+	TenantMode     string `json:"tenantMode"`
+	DBNameTemplate string `json:"dbNameTemplate"`
+	SchemaVersion  string `json:"schemaVersion"`
+	SchemaChange   string `json:"schemaChange"`
+	LGTMCheck      string `json:"lgtmCheck"`
+}

client/database.go

@@ -0,0 +1,31 @@
+package client
+
+import (
+	"context"
+	"encoding/json"
+	"fmt"
+	"net/http"
+
+	"github.com/bytebase/terraform-provider-bytebase/api"
+)
+
+// GetDatabase gets the database by environment resource id, instance resource id and the database name.
+func (c *client) GetDatabase(ctx context.Context, find *api.DatabaseFindMessage) (*api.DatabaseMessage, error) {
+	req, err := http.NewRequestWithContext(ctx, "GET", fmt.Sprintf("%s/%s/environments/%s/instances/%s/databases/%s", c.url, c.version, find.EnvironmentID, find.InstanceID, find.DatabaseName), nil)
+	if err != nil {
+		return nil, err
+	}
+
+	body, err := c.doRequest(req)
+	if err != nil {
+		return nil, err
+	}
+
+	var res api.DatabaseMessage
+	err = json.Unmarshal(body, &res)
+	if err != nil {
+		return nil, err
+	}
+
+	return &res, nil
+}

client/project.go

@@ -0,0 +1,31 @@
+package client
+
+import (
+	"context"
+	"encoding/json"
+	"fmt"
+	"net/http"
+
+	"github.com/bytebase/terraform-provider-bytebase/api"
+)
+
+// GetProject gets the project by resource id.
+func (c *client) GetProject(ctx context.Context, projectID string) (*api.PorjectMessage, error) {
+	req, err := http.NewRequestWithContext(ctx, "GET", fmt.Sprintf("%s/%s/projects/%s", c.url, c.version, projectID), nil)
+	if err != nil {
+		return nil, err
+	}
+
+	body, err := c.doRequest(req)
+	if err != nil {
+		return nil, err
+	}
+
+	var res api.PorjectMessage
+	err = json.Unmarshal(body, &res)
+	if err != nil {
+		return nil, err
+	}
+
+	return &res, nil
+}