Method CreateWorkspace

idm/workspace/grpc/handler.go:52–100

CreateWorkspace in database

(ctx context.Context, req *idm.CreateWorkspaceRequest)

// CreateWorkspace in database
func (h *Handler) CreateWorkspace(ctx context.Context, req *idm.CreateWorkspaceRequest) (*idm.CreateWorkspaceResponse, error) {
	dao, err := manager.Resolve[workspace.DAO](ctx)
	if err != nil {
		return nil, err
	}

	if req.Workspace.Slug == "" {
		req.Workspace.Slug = slug.Make(req.Workspace.Label)
	}
	update, err := dao.Add(ctx, req.Workspace)
	// ADD POLICIES
	if len(req.Workspace.Policies) > 0 {
		if req.Workspace.Policies, err = dao.AddPolicies(ctx, update, req.Workspace.UUID, req.Workspace.Policies); err != nil {
			return nil, err
		}
	}
	resp := &idm.CreateWorkspaceResponse{
		Workspace: req.Workspace,
	}
	if err != nil {
		return nil, err
	}

	if update {
		// Propagate creation or update event
		broker.MustPublish(ctx, common.TopicIdmEvent, &idm.ChangeEvent{
			Type:      idm.ChangeEventType_UPDATE,
			Workspace: req.Workspace,
		})
		log.Auditer(ctx).Info(
			fmt.Sprintf("Updated workspace [%s]", req.Workspace.Slug),
			log.GetAuditId(common.AuditWsUpdate),
			req.Workspace.ZapUuid(),
		)
	} else {
		// Propagate creation or update event
		broker.MustPublish(ctx, common.TopicIdmEvent, &idm.ChangeEvent{
			Type:      idm.ChangeEventType_CREATE,
			Workspace: req.Workspace,
		})
		log.Auditer(ctx).Info(
			fmt.Sprintf("Created workspace [%s]", req.Workspace.Slug),
			log.GetAuditId(common.AuditWsCreate),
			req.Workspace.ZapUuid(),
		)
	}

	return resp, nil
}

// DeleteWorkspace from database
func (h *Handler) DeleteWorkspace(ctx context.Context, req *idm.DeleteWorkspaceRequest) (*idm.DeleteWorkspaceResponse, error) {