rm: resource manager funcs

Author: socialyadept

pkg/connector/team.go

@@ -365,196 +365,6 @@ func (o *teamResourceType) Revoke(ctx context.Context, grant *v2.Grant) (annotat
 	return nil, nil
 }
 
-// Create creates a new team in a GitHub organization.
-// The resource must have a parent resource ID that references the organization.
-// The team name is taken from the resource's DisplayName field.
-// Optional profile fields:
-//   - description: string - Team description
-//   - privacy: string - "secret" or "closed" (default: "secret")
-//   - parent_team_id: int64 - ID of the parent team for nested teams
-func (o *teamResourceType) Create(ctx context.Context, resource *v2.Resource) (*v2.Resource, annotations.Annotations, error) {
-	l := ctxzap.Extract(ctx)
-
-	if resource == nil {
-		return nil, nil, fmt.Errorf("github-connector: resource cannot be nil")
-	}
-
-	if resource.Id == nil || resource.Id.ResourceType != resourceTypeTeam.Id {
-		return nil, nil, fmt.Errorf("github-connector: invalid resource type for team creation")
-	}
-
-	// Get the parent org resource ID
-	parentResourceID := resource.GetParentResourceId()
-	if parentResourceID == nil {
-		return nil, nil, fmt.Errorf("github-connector: parent organization resource ID is required to create a team")
-	}
-
-	if parentResourceID.ResourceType != resourceTypeOrg.Id {
-		return nil, nil, fmt.Errorf("github-connector: parent resource must be an organization, got %s", parentResourceID.ResourceType)
-	}
-
-	// Get the organization name
-	orgName, err := o.orgCache.GetOrgName(ctx, parentResourceID)
-	if err != nil {
-		return nil, nil, fmt.Errorf("github-connector: failed to get organization name: %w", err)
-	}
-
-	// Get team name from display name
-	teamName := resource.GetDisplayName()
-	if teamName == "" {
-		return nil, nil, fmt.Errorf("github-connector: team name (DisplayName) is required")
-	}
-
-	l.Info("github-connector: creating team",
-		zap.String("team_name", teamName),
-		zap.String("org_name", orgName),
-	)
-
-	// Build the NewTeam request
-	newTeam := github.NewTeam{
-		Name: teamName,
-	}
-
-	// Extract optional fields from the group trait profile if available
-	groupTrait, err := rType.GetGroupTrait(resource)
-	if err == nil && groupTrait != nil && groupTrait.Profile != nil {
-		// Get description if provided
-		if description, ok := rType.GetProfileStringValue(groupTrait.Profile, "description"); ok && description != "" {
-			newTeam.Description = github.Ptr(description)
-		}
-
-		// Get privacy setting if provided ("secret" or "closed")
-		if privacy, ok := rType.GetProfileStringValue(groupTrait.Profile, "privacy"); ok && privacy != "" {
-			if privacy == "secret" || privacy == "closed" {
-				newTeam.Privacy = github.Ptr(privacy)
-			} else {
-				l.Warn("github-connector: invalid privacy value, using default",
-					zap.String("provided_privacy", privacy),
-				)
-			}
-		}
-
-		// Get parent team ID if provided (for nested teams)
-		if parentTeamID, ok := rType.GetProfileInt64Value(groupTrait.Profile, "parent_team_id"); ok && parentTeamID > 0 {
-			newTeam.ParentTeamID = github.Ptr(parentTeamID)
-		}
-	}
-
-	// Create the team via GitHub API
-	createdTeam, resp, err := o.client.Teams.CreateTeam(ctx, orgName, newTeam)
-	if err != nil {
-		return nil, nil, wrapGitHubError(err, resp, fmt.Sprintf("github-connector: failed to create team %s in org %s", teamName, orgName))
-	}
-
-	// Extract rate limit data for annotations
-	var annos annotations.Annotations
-	if rateLimitData, err := extractRateLimitData(resp); err == nil {
-		annos.WithRateLimiting(rateLimitData)
-	}
-
-	l.Info("github-connector: team created successfully",
-		zap.String("team_name", createdTeam.GetName()),
-		zap.Int64("team_id", createdTeam.GetID()),
-		zap.String("team_slug", createdTeam.GetSlug()),
-	)
-
-	// Create the resource representation of the newly created team
-	createdResource, err := teamResource(createdTeam, parentResourceID)
-	if err != nil {
-		return nil, annos, fmt.Errorf("github-connector: failed to create resource representation for team: %w", err)
-	}
-
-	return createdResource, annos, nil
-}
-
-// Delete deletes a team from a GitHub organization.
-// The team is identified by its resource ID which contains the GitHub team ID.
-func (o *teamResourceType) Delete(ctx context.Context, resourceId *v2.ResourceId) (annotations.Annotations, error) {
-	l := ctxzap.Extract(ctx)
-
-	if resourceId == nil {
-		return nil, fmt.Errorf("github-connector: resource ID cannot be nil")
-	}
-
-	if resourceId.ResourceType != resourceTypeTeam.Id {
-		return nil, fmt.Errorf("github-connector: invalid resource type %s, expected %s", resourceId.ResourceType, resourceTypeTeam.Id)
-	}
-
-	// Parse the team ID from the resource
-	teamID, err := strconv.ParseInt(resourceId.GetResource(), 10, 64)
-	if err != nil {
-		return nil, fmt.Errorf("github-connector: invalid team ID %s: %w", resourceId.GetResource(), err)
-	}
-
-	l.Info("github-connector: deleting team",
-		zap.Int64("team_id", teamID),
-	)
-
-	// We need to find the org that this team belongs to.
-	// We'll iterate through the organizations in the org cache.
-	var annos annotations.Annotations
-	var deleted bool
-	var lastErr error
-	var lastResp *github.Response
-
-	// Use the org cache to get the list of organizations
-	// We need to iterate through the configured organizations
-	o.orgCache.RLock()
-	orgIDs := make([]string, 0, len(o.orgCache.orgNames))
-	for orgID := range o.orgCache.orgNames {
-		orgIDs = append(orgIDs, orgID)
-	}
-	o.orgCache.RUnlock()
-
-	for _, orgID := range orgIDs {
-		orgIDInt, err := strconv.ParseInt(orgID, 10, 64)
-		if err != nil {
-			continue
-		}
-
-		// Try to get the team first to verify it exists in this org
-		_, resp, err := o.client.Teams.GetTeamByID(ctx, orgIDInt, teamID)
-		if err != nil {
-			// Team doesn't exist in this org, continue to next
-			if isNotFoundError(resp) {
-				continue
-			}
-			lastErr = err
-			lastResp = resp
-			continue
-		}
-
-		// Team found in this org, delete it
-		resp, err = o.client.Teams.DeleteTeamByID(ctx, orgIDInt, teamID)
-		if err != nil {
-			lastErr = err
-			lastResp = resp
-			continue
-		}
-
-		// Successfully deleted
-		deleted = true
-		if rateLimitData, err := extractRateLimitData(resp); err == nil {
-			annos.WithRateLimiting(rateLimitData)
-		}
-
-		l.Info("github-connector: team deleted successfully",
-			zap.Int64("team_id", teamID),
-			zap.Int64("org_id", orgIDInt),
-		)
-		break
-	}
-
-	if !deleted {
-		if lastErr != nil {
-			return annos, wrapGitHubError(lastErr, lastResp, fmt.Sprintf("github-connector: failed to delete team %d", teamID))
-		}
-		return annos, fmt.Errorf("github-connector: team %d not found in any accessible organization", teamID)
-	}
-
-	return annos, nil
-}
-
 // ResourceActions registers the resource actions for the team resource type.
 // This implements the ResourceActionProvider interface.
 func (o *teamResourceType) ResourceActions(ctx context.Context, registry actions.ResourceTypeActionRegistry) error {