Skip to content

test: beekeeper #5012

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

Closed
acha-bill wants to merge 3 commits into from
Closed

test: beekeeper #5012

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
982dad4
test: pss and gsoc
acha-bill Feb 18, 2025
8753d6c
chore: remove other tests
acha-bill Feb 18, 2025
189104f
chore: set beekeeper
acha-bill Feb 18, 2025
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
78 changes: 39 additions & 39 deletions .github/workflows/beekeeper.yml
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -14,7 +14,7 @@ env:
SETUP_CONTRACT_IMAGE: "ethersphere/bee-localchain"
SETUP_CONTRACT_IMAGE_TAG: "0.9.2"
BEELOCAL_BRANCH: "main"
BEEKEEPER_BRANCH: "master"
BEEKEEPER_BRANCH: "fix/pss"
BEEKEEPER_METRICS_ENABLED: false
REACHABILITY_OVERRIDE_PUBLIC: true
BATCHFACTOR_OVERRIDE_PUBLIC: 2
Expand Down Expand Up @@ -132,50 +132,50 @@ jobs:
- name: Test fullconnectivity
id: fullconnectivity
run: timeout ${TIMEOUT} bash -c 'until beekeeper check --cluster-name local-dns --checks=ci-full-connectivity; do echo "waiting for full connectivity..."; sleep .3; done'
- name: Test settlements
id: settlements
run: timeout ${TIMEOUT} beekeeper check --cluster-name local-dns --checks=ci-settlements
- name: Sleep for time allowance to replenish
run: sleep 2
# - name: Test settlements
# id: settlements
# run: timeout ${TIMEOUT} beekeeper check --cluster-name local-dns --checks=ci-settlements
# - name: Sleep for time allowance to replenish
# run: sleep 2
- name: Test pss
id: pss
run: timeout ${TIMEOUT} beekeeper check --cluster-name local-dns --checks=ci-pss
- name: Test soc
id: soc
run: timeout ${TIMEOUT} beekeeper check --cluster-name local-dns --checks=ci-soc
# - name: Test soc
# id: soc
# run: timeout ${TIMEOUT} beekeeper check --cluster-name local-dns --checks=ci-soc
- name: Test gsoc
id: gsoc
run: timeout ${TIMEOUT} beekeeper check --cluster-name local-dns --checks=ci-gsoc
- name: Test pushsync (chunks)
id: pushsync-chunks-1
run: timeout ${TIMEOUT} beekeeper check --cluster-name local-dns --checks=ci-pushsync-chunks
- name: Test pushsync (light mode chunks)
id: pushsync-chunks-2
run: timeout ${TIMEOUT} beekeeper check --cluster-name local-dns --checks=ci-pushsync-light-chunks
- name: Test retrieval
id: retrieval
run: timeout ${TIMEOUT} beekeeper check --cluster-name local-dns --checks=ci-retrieval
- name: Test manifest
id: manifest
run: timeout ${TIMEOUT} beekeeper check --cluster-name local-dns --checks=ci-manifest
- name: Test postage stamps
id: postage-stamps
run: timeout ${TIMEOUT} beekeeper check --cluster-name local-dns --checks ci-postage
- name: Test staking
id: stake
run: timeout ${TIMEOUT} beekeeper check --cluster-name local-dns --checks ci-stake
- name: Test withdraw
id: withdraw
run: timeout ${TIMEOUT} bash -c 'until beekeeper check --cluster-name local-dns --checks ci-withdraw; do echo "waiting for withdraw..."; sleep .3; done'
- name: Test redundancy
id: redundancy
run: timeout ${TIMEOUT} beekeeper check --cluster-name local-dns --checks ci-redundancy
- name: Test act
id: act
run: timeout ${TIMEOUT} bash -c 'until beekeeper check --cluster-name local-dns --checks ci-act; do echo "waiting for act..."; sleep .3; done'
- name: Test feeds
id: feeds
run: timeout ${TIMEOUT} beekeeper check --cluster-name local-dns --checks=ci-feed
# - name: Test pushsync (chunks)
# id: pushsync-chunks-1
# run: timeout ${TIMEOUT} beekeeper check --cluster-name local-dns --checks=ci-pushsync-chunks
# - name: Test pushsync (light mode chunks)
# id: pushsync-chunks-2
# run: timeout ${TIMEOUT} beekeeper check --cluster-name local-dns --checks=ci-pushsync-light-chunks
# - name: Test retrieval
# id: retrieval
# run: timeout ${TIMEOUT} beekeeper check --cluster-name local-dns --checks=ci-retrieval
# - name: Test manifest
# id: manifest
# run: timeout ${TIMEOUT} beekeeper check --cluster-name local-dns --checks=ci-manifest
# - name: Test postage stamps
# id: postage-stamps
# run: timeout ${TIMEOUT} beekeeper check --cluster-name local-dns --checks ci-postage
# - name: Test staking
# id: stake
# run: timeout ${TIMEOUT} beekeeper check --cluster-name local-dns --checks ci-stake
# - name: Test withdraw
# id: withdraw
# run: timeout ${TIMEOUT} bash -c 'until beekeeper check --cluster-name local-dns --checks ci-withdraw; do echo "waiting for withdraw..."; sleep .3; done'
# - name: Test redundancy
# id: redundancy
# run: timeout ${TIMEOUT} beekeeper check --cluster-name local-dns --checks ci-redundancy
# - name: Test act
# id: act
# run: timeout ${TIMEOUT} bash -c 'until beekeeper check --cluster-name local-dns --checks ci-act; do echo "waiting for act..."; sleep .3; done'
# - name: Test feeds
# id: feeds
# run: timeout ${TIMEOUT} beekeeper check --cluster-name local-dns --checks=ci-feed
- name: Collect debug artifacts
if: failure()
run: |
Expand Down
1 change: 1 addition & 0 deletions pkg/api/gsoc.go
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -78,6 +78,7 @@ func (s *Service) gsocListeningWs(conn *websocket.Conn, socAddress swarm.Address
for {
select {
case b := <-dataC:
s.logger.Debug("gsoc ws: sending message", "address", socAddress, "data", b)
err = conn.SetWriteDeadline(time.Now().Add(writeDeadline))
if err != nil {
s.logger.Debug("gsoc ws: set write deadline failed", "error", err)
Expand Down
1 change: 1 addition & 0 deletions pkg/gsoc/gsoc.go
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -73,6 +73,7 @@ func (l *listener) Handle(c *soc.SOC) {

for _, hh := range h {
go func(hh Handler) {
l.logger.Debug("handling GSOC message", "GSOC Address", addr, "wrapped chunk address", c.WrappedChunk().Address(), "data", c.WrappedChunk().Data()[swarm.SpanSize:])
hh(c.WrappedChunk().Data()[swarm.SpanSize:])
}(*hh)
}
Expand Down
Loading