make changes in sore.go fro json wrong format and make CI job exit on errors

This commit is contained in:
aya 2025-05-15 18:50:29 +03:00
parent a790561322
commit f17a654158
3 changed files with 11 additions and 5 deletions

View File

@ -36,7 +36,9 @@ jobs:
run: sudo sh -c "ulimit -n 8192"
- name: Run Endurance Test (Group 1)
shell: bash
run: |
set -euo pipefail
go test -p=1 -v ./waku -count=1 -timeout=360m -run '^(TestStressMemoryUsageForThreeNodes|TestStressStoreQuery5kMessagesWithPagination|TestStressConnectDisconnect500Iteration|TestStressHighThroughput10kPublish)$' | tee testlogs1.log
- name: Upload Test Logs (Group 1)
@ -83,7 +85,10 @@ jobs:
run: sudo sh -c "ulimit -n 8192"
- name: Run Endurance Test (Group 2)
shell: bash
run: |
set -euo pipefail
go test -p=1 -v ./waku -count=1 -timeout=360m -run '^(TestStressRandomNodesInMesh|TestStress2Nodes500IterationTearDown|TestPeerExchangePXLoad)$' | tee testlogs2.log
- name: Upload Test Logs (Group 2)

View File

@ -1,15 +1,15 @@
package common
type StoreQueryRequest struct {
RequestId string `json:"requestId"`
IncludeData bool `json:"includeData"`
RequestId string `json:"request_id"`
IncludeData bool `json:"include_data"`
PubsubTopic string `json:"pubsubTopic,omitempty"`
ContentTopics *[]string `json:"contentTopics,omitempty"`
TimeStart *int64 `json:"timeStart,omitempty"`
TimeEnd *int64 `json:"timeEnd,omitempty"`
MessageHashes *[]MessageHash `json:"messageHashes,omitempty"`
PaginationCursor *MessageHash `json:"paginationCursor,omitempty"`
PaginationForward bool `json:"paginationForward"`
PaginationForward bool `json:"pagination_forward"`
PaginationLimit *uint64 `json:"paginationLimit,omitempty"`
}

View File

@ -86,7 +86,7 @@ func TestStressStoreQuery5kMessagesWithPagination(t *testing.T) {
}()
iterations := 5000
iterations := 3000
captureMemory(t.Name(), "at start")
@ -104,6 +104,7 @@ func TestStressStoreQuery5kMessagesWithPagination(t *testing.T) {
TimeStart: queryTimestamp,
IncludeData: true,
PaginationLimit: proto.Uint64(50),
PaginationForward: false,
}
storedmsgs, err := wakuNode.GetStoredMessages(node2, storeQueryRequest)
@ -136,7 +137,7 @@ func TestStressHighThroughput10kPublish(t *testing.T) {
captureMemory(t.Name(), "at start")
totalMessages := 2500
totalMessages := 5
pubsubTopic := DefaultPubsubTopic
for i := 0; i < totalMessages; i++ {