Skip to content
New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Bigquery dataset iam #3608

Merged
merged 10 commits into from
Jun 8, 2020
Merged
Show file tree
Hide file tree
Changes from all commits
Commits
File filter

Filter by extension

Filter by extension

Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
1 change: 1 addition & 0 deletions products/bigquery/api.yaml
Original file line number Diff line number Diff line change
Expand Up @@ -383,6 +383,7 @@ objects:
A-Z), numbers (0-9), or underscores (_). The maximum length
is 1,024 characters.
required: true

- !ruby/object:Api::Resource
name: 'Job'
kind: 'bigquery#job'
Expand Down
Original file line number Diff line number Diff line change
@@ -0,0 +1,62 @@
package google

import (
"fmt"
"testing"

"github.com/hashicorp/terraform-plugin-sdk/helper/resource"
)

func TestAccBigqueryDatasetIamMember_basic(t *testing.T) {
t.Parallel()

datasetID := fmt.Sprintf("tf_test_%s", randString(t, 10))
saID := fmt.Sprintf("tf-test-%s", randString(t, 10))

expected := map[string]interface{}{
"role": "roles/viewer",
"userByEmail": fmt.Sprintf("%s@%s.iam.gserviceaccount.com", saID, getTestProjectFromEnv()),
}

vcrTest(t, resource.TestCase{
PreCheck: func() { testAccPreCheck(t) },
Providers: testAccProviders,
Steps: []resource.TestStep{
{
Config: testAccBigqueryDatasetIamMember_basic(datasetID, saID),
Check: testAccCheckBigQueryDatasetAccessPresent(t, "google_bigquery_dataset.dataset", expected),
},
{
// Destroy step instead of CheckDestroy so we can check the access is removed without deleting the dataset
Config: testAccBigqueryDatasetIamMember_destroy(datasetID, "dataset"),
Check: testAccCheckBigQueryDatasetAccessAbsent(t, "google_bigquery_dataset.dataset", expected),
},
},
})
}

func testAccBigqueryDatasetIamMember_destroy(datasetID, rs string) string {
return fmt.Sprintf(`
resource "google_bigquery_dataset" "%s" {
dataset_id = "%s"
}
`, rs, datasetID)
}

func testAccBigqueryDatasetIamMember_basic(datasetID, saID string) string {
return fmt.Sprintf(`
resource "google_bigquery_dataset_iam_member" "access" {
dataset_id = google_bigquery_dataset.dataset.dataset_id
role = "roles/viewer"
member = "serviceAccount:${google_service_account.bqviewer.email}"
}

resource "google_bigquery_dataset" "dataset" {
dataset_id = "%s"
}

resource "google_service_account" "bqviewer" {
account_id = "%s"
}
`, datasetID, saID)
}
202 changes: 202 additions & 0 deletions third_party/terraform/tests/resource_bigquery_dataset_iam_test.go
Original file line number Diff line number Diff line change
@@ -0,0 +1,202 @@
package google

import (
"fmt"
"testing"

"github.com/hashicorp/terraform-plugin-sdk/helper/resource"
)

func TestAccBigqueryDatasetIamBinding(t *testing.T) {
t.Parallel()

dataset := "tf_test_dataset_iam_" + randString(t, 10)
account := "tf-test-bq-iam-" + randString(t, 10)
role := "roles/bigquery.dataViewer"

importId := fmt.Sprintf("projects/%s/datasets/%s %s",
getTestProjectFromEnv(), dataset, role)

vcrTest(t, resource.TestCase{
PreCheck: func() { testAccPreCheck(t) },
Providers: testAccProviders,
Steps: []resource.TestStep{
{
// Test IAM Binding creation
Config: testAccBigqueryDatasetIamBinding_basic(dataset, account, role),
Check: resource.ComposeTestCheckFunc(
resource.TestCheckResourceAttr(
"google_bigquery_dataset_iam_binding.binding", "role", role),
),
},
{
ResourceName: "google_bigquery_dataset_iam_binding.binding",
ImportStateId: importId,
ImportState: true,
ImportStateVerify: true,
},
{
// Test IAM Binding update
Config: testAccBigqueryDatasetIamBinding_update(dataset, account, role),
},
{
ResourceName: "google_bigquery_dataset_iam_binding.binding",
ImportStateId: importId,
ImportState: true,
ImportStateVerify: true,
},
},
})
}

func TestAccBigqueryDatasetIamMember(t *testing.T) {
t.Parallel()

dataset := "tf_test_dataset_iam_" + randString(t, 10)
account := "tf-test-bq-iam-" + randString(t, 10)
role := "roles/editor"

importId := fmt.Sprintf("projects/%s/datasets/%s %s serviceAccount:%s",
getTestProjectFromEnv(),
dataset,
role,
serviceAccountCanonicalEmail(account))

vcrTest(t, resource.TestCase{
PreCheck: func() { testAccPreCheck(t) },
Providers: testAccProviders,
Steps: []resource.TestStep{
{
// Test IAM Binding creation
Config: testAccBigqueryDatasetIamMember(dataset, account, role),
Check: resource.ComposeTestCheckFunc(
resource.TestCheckResourceAttr(
"google_bigquery_dataset_iam_member.member", "role", role),
resource.TestCheckResourceAttr(
"google_bigquery_dataset_iam_member.member", "member", "serviceAccount:"+serviceAccountCanonicalEmail(account)),
),
},
{
ResourceName: "google_bigquery_dataset_iam_member.member",
ImportStateId: importId,
ImportState: true,
ImportStateVerify: true,
},
},
})
}

func TestAccBigqueryDatasetIamPolicy(t *testing.T) {
t.Parallel()

dataset := "tf_test_dataset_iam_" + randString(t, 10)
account := "tf-test-bq-iam-" + randString(t, 10)
role := "roles/bigquery.dataOwner"

importId := fmt.Sprintf("projects/%s/datasets/%s",
getTestProjectFromEnv(), dataset)

vcrTest(t, resource.TestCase{
PreCheck: func() { testAccPreCheck(t) },
Providers: testAccProviders,
Steps: []resource.TestStep{
{
// Test IAM Binding creation
Config: testAccBigqueryDatasetIamPolicy(dataset, account, role),
},
{
ResourceName: "google_bigquery_dataset_iam_policy.policy",
ImportStateId: importId,
ImportState: true,
ImportStateVerify: true,
},
},
})
}

func testAccBigqueryDatasetIamBinding_basic(dataset, account, role string) string {
return fmt.Sprintf(testBigqueryDatasetIam+`
resource "google_service_account" "test-account1" {
account_id = "%s-1"
display_name = "Bigquery Dataset IAM Testing Account"
}

resource "google_service_account" "test-account2" {
account_id = "%s-2"
display_name = "Bigquery Dataset Iam Testing Account"
}

resource "google_bigquery_dataset_iam_binding" "binding" {
dataset_id = google_bigquery_dataset.dataset.dataset_id
role = "%s"
members = [
"serviceAccount:${google_service_account.test-account1.email}",
]
}
`, dataset, account, account, role)
}

func testAccBigqueryDatasetIamBinding_update(dataset, account, role string) string {
return fmt.Sprintf(testBigqueryDatasetIam+`
resource "google_service_account" "test-account1" {
account_id = "%s-1"
display_name = "Bigquery Dataset IAM Testing Account"
}

resource "google_service_account" "test-account2" {
account_id = "%s-2"
display_name = "Bigquery Dataset IAM Testing Account"
}

resource "google_bigquery_dataset_iam_binding" "binding" {
dataset_id = google_bigquery_dataset.dataset.dataset_id
role = "%s"
members = [
"serviceAccount:${google_service_account.test-account1.email}",
"serviceAccount:${google_service_account.test-account2.email}",
]
}
`, dataset, account, account, role)
}

func testAccBigqueryDatasetIamMember(dataset, account, role string) string {
return fmt.Sprintf(testBigqueryDatasetIam+`
resource "google_service_account" "test-account" {
account_id = "%s"
display_name = "Bigquery Dataset IAM Testing Account"
}

resource "google_bigquery_dataset_iam_member" "member" {
dataset_id = google_bigquery_dataset.dataset.dataset_id
role = "%s"
member = "serviceAccount:${google_service_account.test-account.email}"
}
`, dataset, account, role)
}

func testAccBigqueryDatasetIamPolicy(dataset, account, role string) string {
return fmt.Sprintf(testBigqueryDatasetIam+`
resource "google_service_account" "test-account" {
account_id = "%s"
display_name = "Bigquery Dataset IAM Testing Account"
}

data "google_iam_policy" "policy" {
binding {
role = "%s"
members = ["serviceAccount:${google_service_account.test-account.email}"]
}
}

resource "google_bigquery_dataset_iam_policy" "policy" {
dataset_id = google_bigquery_dataset.dataset.dataset_id
policy_data = data.google_iam_policy.policy.policy_data
}
`, dataset, account, role)
}

var testBigqueryDatasetIam = `
resource "google_bigquery_dataset" "dataset" {
dataset_id = "%s"
}
`
Loading