From 4e2f5436f826a85706858660e8e502fa072c4543 Mon Sep 17 00:00:00 2001 From: Yuri Tseretyan Date: Thu, 24 Apr 2025 17:24:08 -0400 Subject: [PATCH] remove unused --- pkg/services/ngalert/notifier/receiver_svc.go | 68 ------------------- 1 file changed, 68 deletions(-) diff --git a/pkg/services/ngalert/notifier/receiver_svc.go b/pkg/services/ngalert/notifier/receiver_svc.go index a4ba285d311..2f67ba58fc6 100644 --- a/pkg/services/ngalert/notifier/receiver_svc.go +++ b/pkg/services/ngalert/notifier/receiver_svc.go @@ -241,74 +241,6 @@ func (rs *ReceiverService) GetReceivers(ctx context.Context, q models.GetReceive return limitOffset(filtered, q.Offset, q.Limit), nil } -// ListReceivers returns a list of receivers a user has access to. -// Receivers can be filtered by name. -// This offers an looser permissions compared to GetReceivers. When a user doesn't have read access it will check for list access instead of returning an empty list. -// If the users has list access, all receiver settings will be removed from the response. This option is for backwards compatibility with the v1/receivers endpoint -// and should be removed when FGAC is fully implemented. -func (rs *ReceiverService) ListReceivers(ctx context.Context, q models.ListReceiversQuery, user identity.Requester) ([]*models.Receiver, error) { // TODO: Remove this method with FGAC. - ctx, span := rs.tracer.Start(ctx, "alerting.receivers.list", trace.WithAttributes( - attribute.Int64("query_org_id", q.OrgID), - attribute.StringSlice("query_names", q.Names), - attribute.Int("query_limit", q.Limit), - attribute.Int("query_offset", q.Offset), - )) - defer span.End() - - listAccess, err := rs.authz.HasList(ctx, user) - if err != nil { - return nil, err - } - - uids := make([]string, 0, len(q.Names)) - for _, name := range q.Names { - uids = append(uids, legacy_storage.NameToUid(name)) - } - - revision, err := rs.cfgStore.Get(ctx, q.OrgID) - if err != nil { - return nil, err - } - postables := revision.GetReceivers(uids) - - span.AddEvent("Loaded receivers", trace.WithAttributes( - attribute.String("concurrency_token", revision.ConcurrencyToken), - attribute.Int("count", len(postables)), - )) - - storedProvenances, err := rs.provisioningStore.GetProvenances(ctx, q.OrgID, (&definitions.EmbeddedContactPoint{}).ResourceType()) - if err != nil { - return nil, err - } - receivers, err := PostableApiReceiversToReceivers(postables, storedProvenances) - if err != nil { - return nil, err - } - - if !listAccess { - var err error - receivers, err = rs.authz.FilterRead(ctx, user, receivers...) - if err != nil { - return nil, err - } - - span.AddEvent("Applied access control filter", trace.WithAttributes( - attribute.Int("count", len(receivers)), - )) - } - - // Remove settings. - for _, r := range receivers { - for _, integration := range r.Integrations { - integration.Settings = nil - integration.SecureSettings = nil - integration.DisableResolveMessage = false - } - } - - return limitOffset(receivers, q.Offset, q.Limit), nil -} - // DeleteReceiver deletes a receiver by uid. // UID field currently does not exist, we assume the uid is a particular hashed value of the receiver name. func (rs *ReceiverService) DeleteReceiver(ctx context.Context, uid string, callerProvenance definitions.Provenance, version string, orgID int64, user identity.Requester) error {