diff options
| author | Xe Iaso <me@xeiaso.net> | 2024-11-08 08:24:18 -0500 |
|---|---|---|
| committer | Xe Iaso <me@xeiaso.net> | 2024-11-08 08:24:18 -0500 |
| commit | d9c0ca365ced7ad855d320c25665b937c077db4f (patch) | |
| tree | b9865acd28a538f112884520653771a788562fe8 /cmd/mi/services/posse | |
| parent | e2cc4812dcb0018fce7a72174ca3650cbad4ebdd (diff) | |
| download | x-d9c0ca365ced7ad855d320c25665b937c077db4f.tar.xz x-d9c0ca365ced7ad855d320c25665b937c077db4f.zip | |
cmd/mi/services/posse: only announce prod domains
Signed-off-by: Xe Iaso <me@xeiaso.net>
Diffstat (limited to 'cmd/mi/services/posse')
| -rw-r--r-- | cmd/mi/services/posse/posse.go | 12 |
1 files 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 { |
