Method List

app/controlplane/pkg/data/apitoken.go:119–170

(ctx context.Context, orgID *uuid.UUID, filters *biz.APITokenListFilters)

}

func (r *APITokenRepo) List(ctx context.Context, orgID *uuid.UUID, filters *biz.APITokenListFilters) ([]*biz.APIToken, error) {
	ctx, span := otelx.Start(ctx, apiTokenRepoTracer, "APITokenRepo.List")
	defer span.End()

	query := r.data.DB.APIToken.Query().WithProject().WithWorkflow().WithOrganization()

	if filters == nil {
		filters = &biz.APITokenListFilters{}
	}

	if orgID != nil {
		query = query.Where(apitoken.OrganizationIDEQ(*orgID))
	}

	if len(filters.FilterByProjects) > 0 {
		query = query.Where(apitoken.ProjectIDIn(filters.FilterByProjects...))
	}

	if !filters.IncludeSystem {
		query = query.Where(apitoken.IsSystem(false))
	}

	switch filters.FilterByScope {
	case biz.APITokenScopeProject:
		query = query.Where(apitoken.ProjectIDNotNil())
	case biz.APITokenScopeGlobal:
		query = query.Where(apitoken.ProjectIDIsNil())
	case biz.APITokenScopeInstance:
		query = query.Where(apitoken.OrganizationIDIsNil())
	}

	switch filters.StatusFilter {
	case biz.APITokenStatusFilterRevoked:
		query = query.Where(apitoken.RevokedAtNotNil())
	case biz.APITokenStatusFilterAll:
		// no filter — return all tokens
	default: // APITokenStatusFilterActive
		query = query.Where(apitoken.RevokedAtIsNil())
	}

	tokens, err := query.Order(ent.Asc(apitoken.FieldCreatedAt)).All(ctx)
	if err != nil {
		return nil, err
	}

	result := make([]*biz.APIToken, 0, len(tokens))
	for _, t := range tokens {
		result = append(result, entAPITokenToBiz(t))
	}

	return result, nil
}

func (r *APITokenRepo) Revoke(ctx context.Context, orgID *uuid.UUID, id uuid.UUID) error {
	ctx, span := otelx.Start(ctx, apiTokenRepoTracer, "APITokenRepo.Revoke")