aboutsummaryrefslogtreecommitdiff
path: root/cmd/mi/services/posse
diff options
context:
space:
mode:
authorXe Iaso <me@xeiaso.net>2024-11-08 08:24:18 -0500
committerXe Iaso <me@xeiaso.net>2024-11-08 08:24:18 -0500
commitd9c0ca365ced7ad855d320c25665b937c077db4f (patch)
treeb9865acd28a538f112884520653771a788562fe8 /cmd/mi/services/posse
parente2cc4812dcb0018fce7a72174ca3650cbad4ebdd (diff)
downloadx-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.go12
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 {