✨ Implemented the Admin Cloud Organization Directory Service.

admin/apl_client_impl.go

@@ -49,7 +49,11 @@ func New(httpClient common.HttpClient) (*Client, error) {
 		Schema: internal.NewSCIMSchemaService(client),
 	}
 
-	client.Organization = internal.NewOrganizationService(client, internal.NewOrganizationPolicyService(client))
+	client.Organization = internal.NewOrganizationService(
+		client,
+		internal.NewOrganizationPolicyService(client),
+		internal.NewOrganizationDirectoryService(client))
+
 	client.User = internal.NewUserService(client, internal.NewUserTokenService(client))
 
 	return client, nil

admin/internal/organization_directory_impl.go

@@ -0,0 +1,176 @@
+package internal
+
+import (
+	"context"
+	"fmt"
+	model "github.com/ctreminiom/go-atlassian/pkg/infra/models"
+	"github.com/ctreminiom/go-atlassian/service"
+	"github.com/ctreminiom/go-atlassian/service/admin"
+	"net/http"
+)
+
+func NewOrganizationDirectoryService(client service.Client) *OrganizationDirectoryService {
+	return &OrganizationDirectoryService{internalClient: &internalOrganizationDirectoryServiceImpl{c: client}}
+}
+
+type OrganizationDirectoryService struct {
+	internalClient admin.OrganizationDirectoryConnector
+}
+
+// Activity returns a user’s last active date for each product listed in Atlassian Administration.
+//
+// Active is defined as viewing a product's page for a minimum of 2 seconds.
+//
+// Last activity data can be delayed by up to 4 hours.
+//
+// If the user has not accessed a product, the product_access response field will be empty.
+//
+// The added_to_org date field is available only to customers using the new user management experience.
+//
+// GET /admin/v1/orgs/{orgId}/directory/users/{accountId}/last-active-dates
+//
+// https://docs.go-atlassian.io/atlassian-admin-cloud/organization/directory#users-last-active-dates
+func (o *OrganizationDirectoryService) Activity(ctx context.Context, organizationID, accountID string) (*model.UserProductAccessScheme, *model.ResponseScheme, error) {
+	return o.internalClient.Activity(ctx, organizationID, accountID)
+}
+
+// Remove removes user access to products listed in Atlassian Administration.
+//
+// -- The API is available for customers using the new user management experience only. --
+//
+// Note: Users with emails whose domain is claimed can still be found in Managed accounts in Directory.
+//
+// DELETE /admin/v1/orgs/{orgId}/directory/users/{accountId}
+//
+// https://docs.go-atlassian.io/atlassian-admin-cloud/organization/directory#remove-user-access
+func (o *OrganizationDirectoryService) Remove(ctx context.Context, organizationID, accountID string) (*model.ResponseScheme, error) {
+	return o.internalClient.Remove(ctx, organizationID, accountID)
+}
+
+// Suspend suspends user access to products listed in Atlassian Administration.
+//
+// -- The API is available for customers using the new user management experience only. --
+//
+// Note: Users with emails whose domain is claimed can still be found in Managed accounts in Directory.
+//
+// POST /admin/v1/orgs/{orgId}/directory/users/{accountId}/suspend-access
+//
+// https://docs.go-atlassian.io/atlassian-admin-cloud/organization/directory#suspend-user-access
+func (o *OrganizationDirectoryService) Suspend(ctx context.Context, organizationID, accountID string) (*model.GenericActionSuccessScheme, *model.ResponseScheme, error) {
+	return o.internalClient.Suspend(ctx, organizationID, accountID)
+}
+
+// Restore restores user access to products listed in Atlassian Administration.
+//
+// -- The API is available for customers using the new user management experience only. --
+//
+// Note: Users with emails whose domain is claimed can still be found in Managed accounts in Directory.
+//
+// POST /admin/v1/orgs/{orgId}/directory/users/{accountId}/restore-access
+//
+// https://docs.go-atlassian.io/atlassian-admin-cloud/organization/directory#restore-user-access
+func (o *OrganizationDirectoryService) Restore(ctx context.Context, organizationID, accountID string) (*model.GenericActionSuccessScheme, *model.ResponseScheme, error) {
+	return o.internalClient.Restore(ctx, organizationID, accountID)
+}
+
+type internalOrganizationDirectoryServiceImpl struct {
+	c service.Client
+}
+
+func (i *internalOrganizationDirectoryServiceImpl) Activity(ctx context.Context, organizationID, accountID string) (*model.UserProductAccessScheme, *model.ResponseScheme, error) {
+
+	if organizationID == "" {
+		return nil, nil, model.ErrNoAdminOrganizationError
+	}
+
+	if accountID == "" {
+		return nil, nil, model.ErrNoAdminAccountIDError
+	}
+
+	endpoint := fmt.Sprintf("admin/v1/orgs/%v/directory/users/%v/last-active-dates", organizationID, accountID)
+
+	request, err := i.c.NewRequest(ctx, http.MethodGet, endpoint, nil)
+	if err != nil {
+		return nil, nil, err
+	}
+
+	accessInfo := new(model.UserProductAccessScheme)
+	response, err := i.c.Call(request, accessInfo)
+	if err != nil {
+		return nil, response, err
+	}
+
+	return accessInfo, response, nil
+}
+
+func (i *internalOrganizationDirectoryServiceImpl) Remove(ctx context.Context, organizationID, accountID string) (*model.ResponseScheme, error) {
+
+	if organizationID == "" {
+		return nil, model.ErrNoAdminOrganizationError
+	}
+
+	if accountID == "" {
+		return nil, model.ErrNoAdminAccountIDError
+	}
+
+	endpoint := fmt.Sprintf("admin/v1/orgs/%v/directory/users/%v", organizationID, accountID)
+
+	request, err := i.c.NewRequest(ctx, http.MethodDelete, endpoint, nil)
+	if err != nil {
+		return nil, err
+	}
+
+	return i.c.Call(request, nil)
+}
+
+func (i *internalOrganizationDirectoryServiceImpl) Suspend(ctx context.Context, organizationID, accountID string) (*model.GenericActionSuccessScheme, *model.ResponseScheme, error) {
+
+	if organizationID == "" {
+		return nil, nil, model.ErrNoAdminOrganizationError
+	}
+
+	if accountID == "" {
+		return nil, nil, model.ErrNoAdminAccountIDError
+	}
+
+	endpoint := fmt.Sprintf("admin/v1/orgs/%v/directory/users/%v/suspend-access", organizationID, accountID)
+
+	request, err := i.c.NewRequest(ctx, http.MethodPost, endpoint, nil)
+	if err != nil {
+		return nil, nil, err
+	}
+
+	message := new(model.GenericActionSuccessScheme)
+	response, err := i.c.Call(request, message)
+	if err != nil {
+		return nil, response, err
+	}
+
+	return message, response, nil
+}
+
+func (i *internalOrganizationDirectoryServiceImpl) Restore(ctx context.Context, organizationID, accountID string) (*model.GenericActionSuccessScheme, *model.ResponseScheme, error) {
+
+	if organizationID == "" {
+		return nil, nil, model.ErrNoAdminOrganizationError
+	}
+
+	if accountID == "" {
+		return nil, nil, model.ErrNoAdminAccountIDError
+	}
+
+	endpoint := fmt.Sprintf("admin/v1/orgs/%v/directory/users/%v/restore-access", organizationID, accountID)
+
+	request, err := i.c.NewRequest(ctx, http.MethodPost, endpoint, nil)
+	if err != nil {
+		return nil, nil, err
+	}
+
+	message := new(model.GenericActionSuccessScheme)
+	response, err := i.c.Call(request, message)
+	if err != nil {
+		return nil, response, err
+	}
+
+	return message, response, nil
+}