New resource azuredevops_feed azuredevops_feed_permission Data source azuredevops_feed Basic Feed Management

azuredevops/internal/acceptancetests/data_feed_test.go

@@ -0,0 +1,71 @@
+//go:build (all || core || data_sources || data_feed) && (!data_sources || !exclude_feed)
+// +build all core data_sources data_feed
+// +build !data_sources !exclude_feed
+
+package acceptancetests
+
+import (
+	"fmt"
+	"testing"
+
+	"github.com/hashicorp/terraform-plugin-sdk/v2/helper/resource"
+	"github.com/microsoft/terraform-provider-azuredevops/azuredevops/internal/acceptancetests/testutils"
+)
+
+func TestAccAzureDevOps_DataSource_Feed_By_Name(t *testing.T) {
+	name := testutils.GenerateResourceName()
+
+	FeedData := fmt.Sprintf(`
+		resource "azuredevops_feed" "feed" {
+			name = "%s"
+		}
+
+		data "azuredevops_feed" "feed" {
+			name = azuredevops_feed.feed.name
+		}
+		`, name)
+
+	tfNode := "data.azuredevops_feed.feed"
+	resource.ParallelTest(t, resource.TestCase{
+		PreCheck:          func() { testutils.PreCheck(t, nil) },
+		ProviderFactories: testutils.GetProviderFactories(),
+		Steps: []resource.TestStep{
+			{
+				Config: FeedData,
+				Check: resource.ComposeTestCheckFunc(
+					resource.TestCheckResourceAttrSet(tfNode, "name"),
+					resource.TestCheckResourceAttrSet(tfNode, "feed_id"),
+				),
+			},
+		},
+	})
+}
+
+func TestAccAzureDevOps_DataSource_Feed_By_Feed_Id(t *testing.T) {
+	name := testutils.GenerateResourceName()
+
+	FeedData := fmt.Sprintf(`
+		resource "azuredevops_feed" "feed" {
+			name = "%s"
+		}
+
+		data "azuredevops_feed" "feed" {
+			feed_id = azuredevops_feed.feed.id
+		}
+		`, name)
+
+	tfNode := "data.azuredevops_feed.feed"
+	resource.ParallelTest(t, resource.TestCase{
+		PreCheck:          func() { testutils.PreCheck(t, nil) },
+		ProviderFactories: testutils.GetProviderFactories(),
+		Steps: []resource.TestStep{
+			{
+				Config: FeedData,
+				Check: resource.ComposeTestCheckFunc(
+					resource.TestCheckResourceAttrSet(tfNode, "name"),
+					resource.TestCheckResourceAttrSet(tfNode, "feed_id"),
+				),
+			},
+		},
+	})
+}

azuredevops/internal/acceptancetests/resource_feed_permission_test.go

@@ -0,0 +1,52 @@
+//go:build (all || core || data_sources || data_feed) && (!data_sources || !exclude_feed)
+// +build all core data_sources data_feed
+// +build !data_sources !exclude_feed
+
+package acceptancetests
+
+import (
+	"fmt"
+	"testing"
+
+	"github.com/hashicorp/terraform-plugin-sdk/v2/helper/resource"
+	"github.com/microsoft/terraform-provider-azuredevops/azuredevops/internal/acceptancetests/testutils"
+)
+
+func TestAccAzureDevOps_Resource_FeedPermission(t *testing.T) {
+	name := testutils.GenerateResourceName()
+	groupName := testutils.GenerateResourceName()
+	projectName := testutils.GenerateResourceName()
+
+	FeedResource := fmt.Sprintf(`
+		%s
+
+		resource "azuredevops_feed" "feed" {
+			name = "%s"
+			project_id = azuredevops_project.project.id
+		}
+
+		resource "azuredevops_feed_permission" "permission" {
+			feed_id = azuredevops_feed.feed.id
+			project_id = azuredevops_project.project.id
+			role = "reader"
+			identity_descriptor = azuredevops_group.group.descriptor
+		}
+	`, testutils.HclGroupResource("group", projectName, groupName), name)
+
+	tfNode := "azuredevops_feed_permission.permission"
+	resource.ParallelTest(t, resource.TestCase{
+		PreCheck:          func() { testutils.PreCheck(t, nil) },
+		ProviderFactories: testutils.GetProviderFactories(),
+		Steps: []resource.TestStep{
+			{
+				Config: FeedResource,
+				Check: resource.ComposeTestCheckFunc(
+					resource.TestCheckResourceAttrSet(tfNode, "feed_id"),
+					resource.TestCheckResourceAttrSet(tfNode, "project_id"),
+					resource.TestCheckResourceAttrSet(tfNode, "role"),
+					resource.TestCheckResourceAttrSet(tfNode, "identity_descriptor"),
+				),
+			},
+		},
+	})
+}

azuredevops/internal/acceptancetests/resource_feed_test.go

@@ -0,0 +1,124 @@
+//go:build (all || core || data_sources || data_feed) && (!data_sources || !exclude_feed)
+// +build all core data_sources data_feed
+// +build !data_sources !exclude_feed
+
+package acceptancetests
+
+import (
+	"fmt"
+	"testing"
+
+	"github.com/hashicorp/terraform-plugin-sdk/v2/helper/resource"
+	"github.com/microsoft/terraform-provider-azuredevops/azuredevops/internal/acceptancetests/testutils"
+)
+
+func TestAccAzureDevOps_Resource_Feed(t *testing.T) {
+	name := testutils.GenerateResourceName()
+
+	FeedResource := fmt.Sprintf(`
+		resource "azuredevops_feed" "feed" {
+			name = "%s"
+		}
+	`, name)
+
+	tfNode := "azuredevops_feed.feed"
+	resource.ParallelTest(t, resource.TestCase{
+		PreCheck:          func() { testutils.PreCheck(t, nil) },
+		ProviderFactories: testutils.GetProviderFactories(),
+		Steps: []resource.TestStep{
+			{
+				Config: FeedResource,
+				Check: resource.ComposeTestCheckFunc(
+					resource.TestCheckResourceAttrSet(tfNode, "name"),
+					resource.TestCheckNoResourceAttr(tfNode, "project"),
+				),
+			},
+		},
+	})
+}
+
+func TestAccAzureDevOps_Resource_Feed_with_Project(t *testing.T) {
+	name := testutils.GenerateResourceName()
+	projectName := testutils.GenerateResourceName()
+
+	ProjectResource := testutils.HclProjectResource(projectName)
+	FeedResource := fmt.Sprintf(`
+	%s
+
+	resource "azuredevops_feed" "feed" {
+		name       = "%s"
+		project_id    = azuredevops_project.project.id
+	}
+
+	`, ProjectResource, name)
+
+	tfNode := "azuredevops_feed.feed"
+	resource.ParallelTest(t, resource.TestCase{
+		PreCheck:          func() { testutils.PreCheck(t, nil) },
+		ProviderFactories: testutils.GetProviderFactories(),
+		Steps: []resource.TestStep{
+			{
+				Config: FeedResource,
+				Check: resource.ComposeTestCheckFunc(
+					resource.TestCheckResourceAttrSet(tfNode, "name"),
+					resource.TestCheckResourceAttrSet(tfNode, "project_id"),
+				),
+			},
+		},
+	})
+}
+
+func TestAccAzureDevOps_Resource_Feed_Soft_Delete(t *testing.T) {
+	name := testutils.GenerateResourceName()
+
+	FeedResource := fmt.Sprintf(`
+		resource "azuredevops_feed" "feed" {
+			name = "%s"
+			features {
+				permanent_delete = false
+			}
+		}
+	`, name)
+
+	tfNode := "azuredevops_feed.feed"
+	resource.Test(t, resource.TestCase{
+		PreCheck:          func() { testutils.PreCheck(t, nil) },
+		ProviderFactories: testutils.GetProviderFactories(),
+		Steps: []resource.TestStep{
+			{
+				Config: FeedResource,
+				Check: resource.ComposeTestCheckFunc(
+					resource.TestCheckResourceAttrSet(tfNode, "name"),
+					resource.TestCheckNoResourceAttr(tfNode, "project"),
+					resource.TestCheckResourceAttr(tfNode, "restored", "false"),
+				),
+			},
+		},
+	})
+
+	SecondFeedResource := fmt.Sprintf(`
+		resource "azuredevops_feed" "second_feed" {
+			name = "%s"
+			features {
+				permanent_delete = false
+			}
+		}
+	`, name)
+
+	SecondTfNode := "azuredevops_feed.second_feed"
+
+	resource.Test(t, resource.TestCase{
+		PreCheck:          func() { testutils.PreCheck(t, nil) },
+		ProviderFactories: testutils.GetProviderFactories(),
+		Steps: []resource.TestStep{
+			{
+				Config: SecondFeedResource,
+				Check: resource.ComposeTestCheckFunc(
+					resource.TestCheckResourceAttrSet(SecondTfNode, "name"),
+					resource.TestCheckNoResourceAttr(SecondTfNode, "project"),
+					resource.TestCheckResourceAttr(SecondTfNode, "restored", "true"),
+				),
+			},
+		},
+	})
+}

azuredevops/internal/client/client.go

@@ -12,6 +12,7 @@ import (
 	"github.com/microsoft/azure-devops-go-api/azuredevops/v7/core"
 	"github.com/microsoft/azure-devops-go-api/azuredevops/v7/elastic"
 	"github.com/microsoft/azure-devops-go-api/azuredevops/v7/featuremanagement"
+	"github.com/microsoft/azure-devops-go-api/azuredevops/v7/feed"
 	"github.com/microsoft/azure-devops-go-api/azuredevops/v7/git"
 	"github.com/microsoft/azure-devops-go-api/azuredevops/v7/graph"
 	"github.com/microsoft/azure-devops-go-api/azuredevops/v7/identity"
@@ -58,6 +59,7 @@ type AggregatedClient struct {
 	TaskAgentClient               taskagent.Client
 	MemberEntitleManagementClient memberentitlementmanagement.Client
 	FeatureManagementClient       featuremanagement.Client
+	FeedClient                    feed.Client
 	SecurityClient                security.Client
 	IdentityClient                identity.Client
 	WorkItemTrackingClient        workitemtracking.Client
@@ -147,6 +149,12 @@ func GetAzdoClient(azdoTokenProvider func() (string, error), organizationURL str
 
 	featuremanagementClient := featuremanagement.NewClient(ctx, connection)
 
+	feedClient, err := feed.NewClient(ctx, connection)
+	if err != nil {
+		log.Printf("getAzdoClient(): feed.NewClient failed.")
+		return nil, err
+	}
+
 	workitemtrackingClient, err := workitemtracking.NewClient(ctx, connection)
 	if err != nil {
 		log.Printf("getAzdoClient(): workitemtracking.NewClient failed.")
@@ -195,6 +203,7 @@ func GetAzdoClient(azdoTokenProvider func() (string, error), organizationURL str
 		TaskAgentClient:               taskagentClient,
 		MemberEntitleManagementClient: memberentitlementmanagementClient,
 		FeatureManagementClient:       featuremanagementClient,
+		FeedClient:                    feedClient,
 		SecurityClient:                securityClient,
 		IdentityClient:                identityClient,
 		WorkItemTrackingClient:        workitemtrackingClient,

azuredevops/internal/service/feed/data_feed.go

@@ -0,0 +1,77 @@
+package feed
+
+import (
+	"fmt"
+
+	"github.com/hashicorp/terraform-plugin-sdk/v2/helper/schema"
+	"github.com/hashicorp/terraform-plugin-sdk/v2/helper/validation"
+	"github.com/microsoft/azure-devops-go-api/azuredevops/v7/feed"
+	"github.com/microsoft/terraform-provider-azuredevops/azuredevops/internal/client"
+	"github.com/microsoft/terraform-provider-azuredevops/azuredevops/internal/utils"
+)
+
+func DataFeed() *schema.Resource {
+	return &schema.Resource{
+		Read: dataFeedRead,
+		Schema: map[string]*schema.Schema{
+			"name": {
+				Type:         schema.TypeString,
+				ValidateFunc: validation.StringIsNotWhiteSpace,
+				Optional:     true,
+				AtLeastOneOf: []string{
+					"name", "feed_id",
+				},
+			},
+			"feed_id": {
+				Type:         schema.TypeString,
+				Optional:     true,
+				ValidateFunc: validation.IsUUID,
+				ConflictsWith: []string{
+					"name",
+				},
+			},
+			"project_id": {
+				Type:         schema.TypeString,
+				ValidateFunc: validation.IsUUID,
+				Optional:     true,
+			},
+		},
+	}
+}
+
+func dataFeedRead(d *schema.ResourceData, m interface{}) error {
+	clients := m.(*client.AggregatedClient)
+
+	name := d.Get("name").(string)
+	id := d.Get("feed_id").(string)
+	projectId := d.Get("project_id").(string)
+
+	identifier := id
+	if identifier == "" {
+		identifier = name
+	}
+
+	getFeed, err := clients.FeedClient.GetFeed(clients.Ctx, feed.GetFeedArgs{
+		FeedId:  &identifier,
+		Project: &projectId,
+	})
+
+	if err != nil {
+		if utils.ResponseWasNotFound(err) {
+			d.SetId("")
+			return nil
+		}
+		return fmt.Errorf("Error reading feed during read: %+v", err)
+	}
+
+	if getFeed != nil {
+		d.SetId((*getFeed.Id).String())
+		d.Set("name", *getFeed.Name)
+		d.Set("feed_id", (*getFeed.Id).String())
+		if getFeed.Project != nil {
+			d.Set("project_id", (*getFeed.Project.Id).String())
+		}
+	}
+
+	return nil
+}