Skip to content

ci: separate stable image publishing and stabilize ingestion checks #189

New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Merged
MrAlders0n merged 3 commits into from
Sep 30, 2026
Merged

ci: separate stable image publishing and stabilize ingestion checks #189

Show file tree
Hide file tree
Changes from all commits
Commits
Show all changes
3 commits
Select commit Hold shift + click to select a range
46aeeea
ci: reserve latest images for stable releases
n30nex Sep 30, 2026
92a8703
test: drain readiness probes before packet assertions
n30nex Sep 30, 2026
ed9c773
ci: tie latest image tag to main
MrAlders0n Sep 30, 2026
File filter

Filter by extension

Filter by extension
Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
4 changes: 3 additions & 1 deletion .github/workflows/docker-publish.yml
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -40,8 +40,10 @@ jobs:
org.opencontainers.image.title=beacon-server
org.opencontainers.image.description=Beacon — MeshCore LoRa mesh observation server
org.opencontainers.image.licenses=AGPL-3.0-or-later
flavor: |
latest=false
tags: |
type=raw,value=latest,enable={{is_default_branch}}
type=raw,value=latest,enable=${{ github.ref == 'refs/heads/main' }}
type=raw,value=dev,enable=${{ github.ref == 'refs/heads/dev' }}
type=semver,pattern={{version}}
type=semver,pattern={{major}}.{{minor}}
Expand Down
16 changes: 15 additions & 1 deletion internal/ingest/packet_summary_test.go
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -6,6 +6,7 @@ package ingest
import (
"context"
"crypto/ed25519"
"crypto/rand"
"encoding/json"
"testing"
"time"
Expand All @@ -24,7 +25,20 @@ func waitForSummarySubscriber(t *testing.T, ctx context.Context, h *hub.Hub, cli
h.Broadcast(hub.Event{Type: hub.EventObserverStatus})
select {
case <-client.Send:
return
// A slow hub can leave more probes queued. Drain through a final
// marker so the next test read receives its packet, not a probe.
marker := json.RawMessage(`"` + rand.Text() + `"`)
h.Broadcast(hub.Event{Type: hub.EventObserverStatus, Payload: marker})
for {
select {
case event := <-client.Send:
if string(event.Payload) == string(marker) {
return
}
case <-ctx.Done():
t.Fatal("hub readiness probes did not drain")
}
}
case <-ticker.C:
case <-ctx.Done():
t.Fatal("hub subscription did not become ready")
Expand Down
Loading