From d9c0ca365ced7ad855d320c25665b937c077db4f Mon Sep 17 00:00:00 2001 From: Xe Iaso Date: Fri, 8 Nov 2024 08:24:18 -0500 Subject: cmd/mi/services/posse: only announce prod domains Signed-off-by: Xe Iaso --- cmd/mi/services/posse/posse.go | 12 +++++++----- 1 file changed, 7 insertions(+), 5 deletions(-) diff --git a/cmd/mi/services/posse/posse.go b/cmd/mi/services/posse/posse.go index 0c5623b..e26ac0f 100644 --- a/cmd/mi/services/posse/posse.go +++ b/cmd/mi/services/posse/posse.go @@ -65,14 +65,16 @@ func New(ctx context.Context, dao *models.DAO, cfg Config) (*Announcer, error) { } func (a *Announcer) Announce(ctx context.Context, it *jsonfeed.Item) (*emptypb.Empty, error) { - switch { - case strings.Contains(it.GetUrl(), "svc.alrest.xeserv.us"), - strings.Contains(it.GetUrl(), "shark-harmonic.ts.net"), - strings.Contains(it.GetUrl(), "preview.xeiaso.net"): - slog.Info("skipping announcement", "url", it.GetUrl(), "reason", "staging URLs") + u, err := url.Parse(it.GetUrl()) + if err != nil { + slog.Error("[unexpected] can't parse URL", "err", err, "url", it.GetUrl()) return &emptypb.Empty{}, nil } + if u.Host != "xeiaso.net" { + slog.Info("skipping announcement", "url", it.GetUrl(), "reason", "non-prod URLs") + return &emptypb.Empty{}, nil + } if has, err := a.dao.HasBlogpost(ctx, it.GetUrl()); err != nil { return nil, err } else if has { -- cgit v1.2.3