feat: Add Sysdig User datasource

sysdig/data_source_sysdig_user.go

@@ -0,0 +1,67 @@
+package sysdig
+
+import (
+	"context"
+	"strconv"
+	"time"
+
+	"github.com/hashicorp/terraform-plugin-sdk/v2/diag"
+	"github.com/hashicorp/terraform-plugin-sdk/v2/helper/schema"
+)
+
+func dataSourceSysdigUser() *schema.Resource {
+	timeout := 30 * time.Second
+
+	return &schema.Resource{
+		ReadContext: dataSourceSysdigUserRead,
+
+		Timeouts: &schema.ResourceTimeout{
+			Read: schema.DefaultTimeout(timeout),
+		},
+
+		Schema: map[string]*schema.Schema{
+			"email": {
+				Type:     schema.TypeString,
+				Required: true,
+			},
+			"system_role": {
+				Type:     schema.TypeString,
+				Computed: true,
+			},
+			"first_name": {
+				Type:     schema.TypeString,
+				Computed: true,
+			},
+			"last_name": {
+				Type:     schema.TypeString,
+				Computed: true,
+			},
+			"version": {
+				Type:     schema.TypeInt,
+				Computed: true,
+			},
+		},
+	}
+}
+
+func dataSourceSysdigUserRead(ctx context.Context, d *schema.ResourceData, meta interface{}) diag.Diagnostics {
+	client, err := meta.(SysdigClients).sysdigCommonClient()
+	if err != nil {
+		return diag.FromErr(err)
+	}
+
+	u, err := client.GetUserByEmail(ctx, d.Get("email").(string))
+
+	if err != nil {
+		return diag.FromErr(err)
+	}
+
+	d.SetId(strconv.Itoa(u.ID))
+	d.Set("version", u.Version)
+	d.Set("system_role", u.SystemRole)
+	d.Set("first_name", u.FirstName)
+	d.Set("last_name", u.LastName)
+
+	return nil
+
+}

sysdig/data_source_sysdig_user_test.go

@@ -0,0 +1,46 @@
+package sysdig_test
+
+import (
+	"os"
+	"testing"
+
+	"github.com/hashicorp/terraform-plugin-sdk/v2/helper/resource"
+	"github.com/hashicorp/terraform-plugin-sdk/v2/helper/schema"
+
+	"github.com/draios/terraform-provider-sysdig/sysdig"
+)
+
+func TestAccDataUser(t *testing.T) {
+	resource.ParallelTest(t, resource.TestCase{
+		PreCheck: func() {
+			monitor := os.Getenv("SYSDIG_MONITOR_API_TOKEN")
+			secure := os.Getenv("SYSDIG_SECURE_API_TOKEN")
+			if monitor == "" && secure == "" {
+				t.Fatal("either SYSDIG_MONITOR_API_TOKEN or SYSDIG_SECURE_API_TOKEN must be set for acceptance tests")
+			}
+		},
+		ProviderFactories: map[string]func() (*schema.Provider, error){
+			"sysdig": func() (*schema.Provider, error) {
+				return sysdig.Provider(), nil
+			},
+		},
+		Steps: []resource.TestStep{
+			{
+				Config: getUser(),
+			},
+		},
+	})
+}
+
+func getUser() string {
+	return `
+resource "sysdig_user" "sample" {
+  email = "terraform-test+user@sysdig.com"
+}
+
+data "sysdig_user" "me" {
+	depends_on = ["sysdig_user.sample"]
+	email = sysdig_user.sample.email
+}
+`
+}

sysdig/internal/client/common/client.go

@@ -12,11 +12,12 @@ import (
 )
 
 type SysdigCommonClient interface {
-	CreateUser(context.Context, User) (User, error)
-	GetUserById(context.Context, int) (User, error)
+	CreateUser(context.Context, *User) (*User, error)
+	GetUserById(context.Context, int) (*User, error)
+	GetUserByEmail(context.Context, string) (*User, error)
 	DeleteUser(context.Context, int) error
-	UpdateUser(context.Context, User) (User, error)
-	GetCurrentUser(context.Context) (User, error)
+	UpdateUser(context.Context, *User) (*User, error)
+	GetCurrentUser(context.Context) (*User, error)
 }
 
 func WithExtraHeaders(client SysdigCommonClient, extraHeaders map[string]string) SysdigCommonClient {

sysdig/internal/client/common/users.go

@@ -2,13 +2,14 @@ package common
 
 import (
 	"context"
+	"encoding/json"
 	"errors"
 	"fmt"
 	"io/ioutil"
 	"net/http"
 )
 
-func (client *sysdigCommonClient) GetUserById(ctx context.Context, id int) (u User, err error) {
+func (client *sysdigCommonClient) GetUserById(ctx context.Context, id int) (u *User, err error) {
 	response, err := client.doSysdigCommonRequest(ctx, http.MethodGet, client.GetUserUrl(id), nil)
 	if err != nil {
 		return
@@ -22,12 +23,43 @@ func (client *sysdigCommonClient) GetUserById(ctx context.Context, id int) (u Us
 		return
 	}
 
-	u = UserFromJSON(body)
+	user := UserFromJSON(body)
+	return &user, nil
+}
+
+func (client *sysdigCommonClient) GetUserByEmail(ctx context.Context, email string) (u *User, err error) {
+	response, err := client.doSysdigCommonRequest(ctx, http.MethodGet, client.GetUsersUrl(), nil)
+	if err != nil {
+		return
+	}
+	defer response.Body.Close()
+
+	body, _ := ioutil.ReadAll(response.Body)
+
+	if response.StatusCode != http.StatusOK {
+		err = errors.New(response.Status)
+		return
+	}
+
+	var userList struct {
+		Users []User `json:"users"`
+	}
+
+	err = json.Unmarshal(body, &userList)
+	if err != nil {
+		return
+	}
+
+	for _, user := range userList.Users {
+		if user.Email == email {
+			return &user, nil
+		}
+	}
 
-	return
+	return nil, fmt.Errorf("user not found for the given email")
 }
 
-func (client *sysdigCommonClient) CreateUser(ctx context.Context, uRequest User) (u User, err error) {
+func (client *sysdigCommonClient) CreateUser(ctx context.Context, uRequest *User) (u *User, err error) {
 	response, err := client.doSysdigCommonRequest(ctx, http.MethodPost, client.GetUsersUrl(), uRequest.ToJSON())
 
 	if err != nil {
@@ -42,11 +74,11 @@ func (client *sysdigCommonClient) CreateUser(ctx context.Context, uRequest User)
 		return
 	}
 
-	u = UserFromJSON(body)
-	return
+	user := UserFromJSON(body)
+	return &user, nil
 }
 
-func (client *sysdigCommonClient) UpdateUser(ctx context.Context, uRequest User) (u User, err error) {
+func (client *sysdigCommonClient) UpdateUser(ctx context.Context, uRequest *User) (u *User, err error) {
 	response, err := client.doSysdigCommonRequest(ctx, http.MethodPut, client.GetUserUrl(uRequest.ID), uRequest.ToJSON())
 	if err != nil {
 		return
@@ -60,8 +92,8 @@ func (client *sysdigCommonClient) UpdateUser(ctx context.Context, uRequest User)
 		return
 	}
 
-	u = UserFromJSON(body)
-	return
+	user := UserFromJSON(body)
+	return &user, nil
 }
 
 func (client *sysdigCommonClient) DeleteUser(ctx context.Context, id int) error {
@@ -77,7 +109,7 @@ func (client *sysdigCommonClient) DeleteUser(ctx context.Context, id int) error
 	return nil
 }
 
-func (client *sysdigCommonClient) GetCurrentUser(ctx context.Context) (u User, err error) {
+func (client *sysdigCommonClient) GetCurrentUser(ctx context.Context) (u *User, err error) {
 	response, err := client.doSysdigCommonRequest(ctx, http.MethodGet, client.GetCurrentUserUrl(), nil)
 	if err != nil {
 		return
@@ -90,8 +122,8 @@ func (client *sysdigCommonClient) GetCurrentUser(ctx context.Context) (u User, e
 	}
 	body, _ := ioutil.ReadAll(response.Body)
 
-	u = UserFromJSON(body)
-	return
+	user := UserFromJSON(body)
+	return &user, nil
 }
 
 func (client *sysdigCommonClient) GetUsersUrl() string {

sysdig/provider.go

@@ -87,6 +87,7 @@ func Provider() *schema.Provider {
 		DataSourcesMap: map[string]*schema.Resource{
 			"sysdig_secure_notification_channel": dataSourceSysdigSecureNotificationChannel(),
 			"sysdig_current_user":                dataSourceSysdigCurrentUser(),
+			"sysdig_user":                        dataSourceSysdigUser(),
 		},
 		ConfigureContextFunc: providerConfigure,
 	}

sysdig/resource_sysdig_user.go

@@ -102,12 +102,12 @@ func resourceSysdigUserUpdate(ctx context.Context, d *schema.ResourceData, meta
 		return diag.FromErr(err)
 	}
 
-	u := userFromResourceData(d)
+	user := userFromResourceData(d)
 
-	u.Version = d.Get("version").(int)
-	u.ID, _ = strconv.Atoi(d.Id())
+	user.Version = d.Get("version").(int)
+	user.ID, _ = strconv.Atoi(d.Id())
 
-	_, err = client.UpdateUser(ctx, u)
+	_, err = client.UpdateUser(ctx, user)
 	if err != nil {
 		return diag.FromErr(err)
 	}
@@ -130,8 +130,8 @@ func resourceSysdigUserDelete(ctx context.Context, d *schema.ResourceData, meta
 	return nil
 }
 
-func userFromResourceData(d *schema.ResourceData) (u common.User) {
-	u = common.User{
+func userFromResourceData(d *schema.ResourceData) (u *common.User) {
+	u = &common.User{
 		SystemRole: d.Get("system_role").(string),
 		Email:      d.Get("email").(string),
 		FirstName:  d.Get("first_name").(string),

website/docs/d/sysdig_user.md

@@ -0,0 +1,31 @@
+---
+layout: "sysdig"
+page_title: "Sysdig: sysdig_user"
+sidebar_current: "docs-sysdig-user-ds"
+description: |-
+  Retrieves information about a user from their email
+---
+
+# sysdig\_user
+
+Retrieves information about a user from their email
+
+`~> **Note:** Sysdig Terraform Provider is under rapid development at this point. If you experience any issue or discrepancy while using it, please make sure you have the latest version. If the issue persists, or you have a Feature Request to support an additional set of resources, please open a [new issue](https://github.com/sysdiglabs/terraform-provider-sysdig/issues/new) in the GitHub repository.`
+
+## Example usage
+
+```hcl
+data "sysdig_user" "user" {
+	email = "terraform-test+user@sysdig.com"
+}
+```
+
+## Attributes Reference
+
+* `id` - The user's ID.
+
+* `first_name` - The user's first name.
+
+* `last_name` - The user's last name.
+
+* `system_role` - The user's system role.

website/sysdig.erb

@@ -146,6 +146,9 @@
                 <li<%= sidebar_current("docs-sysdig-current-user-ds") %>>
                   <a href="/docs/providers/sysdig/d/sysdig_current_user.html">sysdig_current_user</a>
                 </li>
+                <li<%= sidebar_current("docs-sysdig-user-ds") %>>
+                  <a href="/docs/providers/sysdig/d/sysdig_user.html">sysdig_user</a>
+                </li>
               </ul>
             </li>
           </ul>