mirror of
https://github.com/logos-messaging/logos-messaging-go.git
synced 2026-01-08 00:43:10 +00:00
ci: fix linter, storev3 tests and nix-flake jobs (#1289)
Signed-off-by: Jakub Sokołowski <jakub@status.im> Co-authored-by: Jakub Sokołowski <jakub@status.im>
This commit is contained in:
parent
d6b9120de3
commit
6ceea038ff
2
.github/docker-compose/nwaku.yml
vendored
2
.github/docker-compose/nwaku.yml
vendored
@ -1,6 +1,6 @@
|
|||||||
services:
|
services:
|
||||||
nwaku:
|
nwaku:
|
||||||
image: "harbor.status.im/wakuorg/nwaku:latest"
|
image: "harbor.status.im/wakuorg/nwaku:v0.35.1"
|
||||||
command:
|
command:
|
||||||
[
|
[
|
||||||
"--relay",
|
"--relay",
|
||||||
|
|||||||
4
.github/workflows/ci.yml
vendored
4
.github/workflows/ci.yml
vendored
@ -74,8 +74,8 @@ jobs:
|
|||||||
- name: Execute golangci-lint
|
- name: Execute golangci-lint
|
||||||
uses: golangci/golangci-lint-action@v3
|
uses: golangci/golangci-lint-action@v3
|
||||||
with:
|
with:
|
||||||
version: v1.55.2
|
version: v1.64.6
|
||||||
args: --deadline=5m
|
args: --timeout=5m
|
||||||
|
|
||||||
build:
|
build:
|
||||||
needs: [changes, env]
|
needs: [changes, env]
|
||||||
|
|||||||
@ -1,4 +1,4 @@
|
|||||||
library 'status-jenkins-lib@v1.9.16'
|
library 'status-jenkins-lib@v1.9.26'
|
||||||
|
|
||||||
pipeline {
|
pipeline {
|
||||||
agent {
|
agent {
|
||||||
@ -28,7 +28,7 @@ pipeline {
|
|||||||
stages {
|
stages {
|
||||||
stage('Build') {
|
stage('Build') {
|
||||||
steps { script {
|
steps { script {
|
||||||
nix.flake('node',[path: 'git+https://github.com/waku-org/go-waku'])
|
nix.flake('node')
|
||||||
} }
|
} }
|
||||||
}
|
}
|
||||||
stage('Check') {
|
stage('Check') {
|
||||||
|
|||||||
@ -13,6 +13,8 @@ import (
|
|||||||
libp2pProtocol "github.com/libp2p/go-libp2p/core/protocol"
|
libp2pProtocol "github.com/libp2p/go-libp2p/core/protocol"
|
||||||
"github.com/libp2p/go-msgio/pbio"
|
"github.com/libp2p/go-msgio/pbio"
|
||||||
"github.com/prometheus/client_golang/prometheus"
|
"github.com/prometheus/client_golang/prometheus"
|
||||||
|
"go.uber.org/zap"
|
||||||
|
|
||||||
"github.com/waku-org/go-waku/logging"
|
"github.com/waku-org/go-waku/logging"
|
||||||
"github.com/waku-org/go-waku/waku/v2/peermanager"
|
"github.com/waku-org/go-waku/waku/v2/peermanager"
|
||||||
"github.com/waku-org/go-waku/waku/v2/protocol"
|
"github.com/waku-org/go-waku/waku/v2/protocol"
|
||||||
@ -21,7 +23,6 @@ import (
|
|||||||
"github.com/waku-org/go-waku/waku/v2/service"
|
"github.com/waku-org/go-waku/waku/v2/service"
|
||||||
"github.com/waku-org/go-waku/waku/v2/timesource"
|
"github.com/waku-org/go-waku/waku/v2/timesource"
|
||||||
"github.com/waku-org/go-waku/waku/v2/utils"
|
"github.com/waku-org/go-waku/waku/v2/utils"
|
||||||
"go.uber.org/zap"
|
|
||||||
)
|
)
|
||||||
|
|
||||||
// FilterSubscribeID_v20beta1 is the current Waku Filter protocol identifier for servers to
|
// FilterSubscribeID_v20beta1 is the current Waku Filter protocol identifier for servers to
|
||||||
@ -282,7 +283,7 @@ func (wf *WakuFilterFullNode) pushMessage(ctx context.Context, logger *zap.Logge
|
|||||||
|
|
||||||
stream, err := wf.h.NewStream(ctx, peerID, FilterPushID_v20beta1)
|
stream, err := wf.h.NewStream(ctx, peerID, FilterPushID_v20beta1)
|
||||||
if err != nil {
|
if err != nil {
|
||||||
if errors.Is(context.DeadlineExceeded, err) {
|
if errors.Is(err, context.DeadlineExceeded) {
|
||||||
wf.metrics.RecordError(pushTimeoutFailure)
|
wf.metrics.RecordError(pushTimeoutFailure)
|
||||||
} else {
|
} else {
|
||||||
wf.metrics.RecordError(dialFailure)
|
wf.metrics.RecordError(dialFailure)
|
||||||
@ -297,7 +298,7 @@ func (wf *WakuFilterFullNode) pushMessage(ctx context.Context, logger *zap.Logge
|
|||||||
writer := pbio.NewDelimitedWriter(stream)
|
writer := pbio.NewDelimitedWriter(stream)
|
||||||
err = writer.WriteMsg(messagePush)
|
err = writer.WriteMsg(messagePush)
|
||||||
if err != nil {
|
if err != nil {
|
||||||
if errors.Is(context.DeadlineExceeded, err) {
|
if errors.Is(err, context.DeadlineExceeded) {
|
||||||
wf.metrics.RecordError(pushTimeoutFailure)
|
wf.metrics.RecordError(pushTimeoutFailure)
|
||||||
} else {
|
} else {
|
||||||
wf.metrics.RecordError(writeResponseFailure)
|
wf.metrics.RecordError(writeResponseFailure)
|
||||||
|
|||||||
Loading…
x
Reference in New Issue
Block a user