Skip to content
Merged
Show file tree
Hide file tree
Changes from all commits
Commits
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
49 changes: 49 additions & 0 deletions .github/workflows/pull_request_main.yml
Original file line number Diff line number Diff line change
@@ -0,0 +1,49 @@
name: Run Code Checks

on:
push:
branches:
- main
pull_request:
branches:
- main

jobs:
test:
name: Testing
runs-on: ubuntu-latest
services:
postgres:
image: postgres
ports:
- "2345:5432"
env:
POSTGRES_PASSWORD: password_test
POSTGRES_USER: nebula_test
POSTGRES_DB: nebula_test
options: >-
--health-cmd pg_isready
--health-interval 10s
--health-timeout 5s
--health-retries 5
steps:
- name: Checking out repository code
uses: actions/checkout@v3

- name: Setting up Golang
uses: actions/setup-go@v3
with:
go-version: ~1.19

- name: Caching Golang modules
uses: actions/cache@v3
with:
path: |
~/.cache/go-build
~/go/pkg/mod
key: ${{ runner.os }}-golang-${{ hashFiles('go.sum') }}
restore-keys: |
${{ runner.os }}-golang-

- name: Running tests
run: go test ./...
46 changes: 23 additions & 23 deletions pkg/db/client_test.go
Original file line number Diff line number Diff line change
Expand Up @@ -324,8 +324,8 @@ func TestClient_SessionScenario_1(t *testing.T) {
assert.Equal(t, session.SuccessfulVisitsCount, 1)
assert.Equal(t, session.FailedVisitsCount, int16(0))
assert.Equal(t, session.State, models.SessionStateOpen)
assert.Equal(t, session.FirstSuccessfulVisit.UnixNano(), visitStart.UnixNano())
assert.Equal(t, session.LastVisitedAt.UnixNano(), visitEnd.UnixNano())
assert.InDelta(t, session.FirstSuccessfulVisit.UnixNano(), visitStart.UnixNano(), float64(time.Microsecond))
assert.InDelta(t, session.LastVisitedAt.UnixNano(), visitEnd.UnixNano(), float64(time.Microsecond))
assert.True(t, session.FirstFailedVisit.IsZero())
assert.True(t, session.FinishReason.IsZero())
assert.True(t, session.LastFailedVisit.IsZero())
Expand All @@ -348,8 +348,8 @@ func TestClient_SessionScenario_1(t *testing.T) {
assert.Equal(t, session.SuccessfulVisitsCount, 2)
assert.Equal(t, session.FailedVisitsCount, int16(0))
assert.Equal(t, session.State, models.SessionStateOpen)
assert.NotEqual(t, session.FirstSuccessfulVisit.UnixNano(), visitStart.UnixNano())
assert.Equal(t, session.LastVisitedAt.UnixNano(), visitEnd.UnixNano())
assert.NotEqual(t, session.FirstSuccessfulVisit.UnixMicro(), visitStart.UnixMicro())
assert.InDelta(t, session.LastVisitedAt.UnixNano(), visitEnd.UnixNano(), float64(time.Microsecond))
assert.True(t, session.FirstFailedVisit.IsZero())
assert.True(t, session.FinishReason.IsZero())
assert.True(t, session.LastFailedVisit.IsZero())
Expand All @@ -376,10 +376,10 @@ func TestClient_SessionScenario_1(t *testing.T) {
assert.Equal(t, s.SuccessfulVisitsCount, 2)
assert.Equal(t, s.FailedVisitsCount, int16(1))
assert.Equal(t, s.State, models.SessionStateClosed)
assert.NotEqual(t, s.FirstSuccessfulVisit.UnixNano(), visitStart.UnixNano())
assert.Equal(t, s.LastVisitedAt.UnixNano(), visitEnd.UnixNano())
assert.Equal(t, s.FirstFailedVisit.Time.UnixNano(), visitStart.UnixNano())
assert.Equal(t, s.LastFailedVisit.Time.UnixNano(), visitEnd.UnixNano())
assert.NotEqual(t, s.FirstSuccessfulVisit.UnixMicro(), visitStart.UnixMicro())
assert.InDelta(t, s.LastVisitedAt.UnixNano(), visitEnd.UnixNano(), float64(time.Microsecond))
assert.InDelta(t, s.FirstFailedVisit.Time.UnixNano(), visitStart.UnixNano(), float64(time.Microsecond))
assert.InDelta(t, s.LastFailedVisit.Time.UnixNano(), visitEnd.UnixNano(), float64(time.Microsecond))
assert.Equal(t, s.FinishReason.String, models.NetErrorConnectionRefused)

crawl, err = client.InitCrawl(ctx)
Expand Down Expand Up @@ -429,10 +429,10 @@ func TestClient_SessionScenario_1(t *testing.T) {
assert.Equal(t, newSession.SuccessfulVisitsCount, 1)
assert.Equal(t, newSession.FailedVisitsCount, int16(1))
assert.Equal(t, newSession.State, models.SessionStateClosed)
assert.NotEqual(t, newSession.FirstSuccessfulVisit.UnixNano(), visitStart.UnixNano())
assert.Equal(t, newSession.LastVisitedAt.UnixNano(), visitEnd.UnixNano())
assert.Equal(t, newSession.FirstFailedVisit.Time.UnixNano(), visitStart.UnixNano())
assert.Equal(t, newSession.LastFailedVisit.Time.UnixNano(), visitEnd.UnixNano())
assert.NotEqual(t, newSession.FirstSuccessfulVisit.UnixMicro(), visitStart.UnixMicro())
assert.InDelta(t, newSession.LastVisitedAt.UnixNano(), visitEnd.UnixNano(), float64(time.Microsecond))
assert.InDelta(t, newSession.FirstFailedVisit.Time.UnixNano(), visitStart.UnixNano(), float64(time.Microsecond))
assert.InDelta(t, newSession.LastFailedVisit.Time.UnixNano(), visitEnd.UnixNano(), float64(time.Microsecond))
assert.Equal(t, newSession.FinishReason.String, models.NetErrorNegotiateSecurityProtocol)

err = s.Reload(ctx, client.Handle())
Expand All @@ -443,10 +443,10 @@ func TestClient_SessionScenario_1(t *testing.T) {
assert.Equal(t, s.SuccessfulVisitsCount, 2)
assert.Equal(t, s.FailedVisitsCount, int16(1))
assert.Equal(t, s.State, models.SessionStateClosed)
assert.NotEqual(t, s.FirstSuccessfulVisit.UnixNano(), visitStart.UnixNano())
assert.NotEqual(t, s.LastVisitedAt.UnixNano(), visitStart.UnixNano())
assert.NotEqual(t, s.FirstFailedVisit.Time.UnixNano(), visitStart.UnixNano())
assert.NotEqual(t, s.LastFailedVisit.Time.UnixNano(), visitEnd.UnixNano())
assert.NotEqual(t, s.FirstSuccessfulVisit.UnixMicro(), visitStart.UnixMicro())
assert.NotEqual(t, s.LastVisitedAt.UnixMicro(), visitStart.UnixMicro())
assert.NotEqual(t, s.FirstFailedVisit.Time.UnixMicro(), visitStart.UnixMicro())
assert.NotEqual(t, s.LastFailedVisit.Time.UnixMicro(), visitEnd.UnixMicro())
assert.Equal(t, s.FinishReason.String, models.NetErrorConnectionRefused)
}

Expand Down Expand Up @@ -517,11 +517,11 @@ func TestClient_SessionScenario_2(t *testing.T) {
assert.Equal(t, session.FailedVisitsCount, int16(1))
assert.Equal(t, session.RecoveredCount, 0)
assert.Equal(t, session.State, models.SessionStatePending)
assert.NotEqual(t, session.FirstSuccessfulVisit.UnixNano(), visitStart.UnixNano())
assert.Equal(t, session.LastVisitedAt.UnixNano(), visitEnd.UnixNano())
assert.Equal(t, session.FirstFailedVisit.Time.UnixNano(), visitStart.UnixNano())
assert.NotEqual(t, session.FirstSuccessfulVisit.UnixMicro(), visitStart.UnixMicro())
assert.InDelta(t, session.LastVisitedAt.UnixNano(), visitEnd.UnixNano(), float64(time.Microsecond))
assert.InDelta(t, session.FirstFailedVisit.Time.UnixNano(), visitStart.UnixNano(), float64(time.Microsecond))
assert.Equal(t, session.FinishReason.String, models.NetErrorIoTimeout)
assert.Equal(t, session.LastFailedVisit.Time.UnixNano(), visitEnd.UnixNano())
assert.InDelta(t, session.LastFailedVisit.Time.UnixNano(), visitEnd.UnixNano(), float64(time.Microsecond))

visitStart = time.Now().Add(-time.Second)
visitEnd = time.Now()
Expand All @@ -542,9 +542,9 @@ func TestClient_SessionScenario_2(t *testing.T) {
assert.Equal(t, session.FailedVisitsCount, int16(0))
assert.Equal(t, session.State, models.SessionStateOpen)
assert.Equal(t, session.RecoveredCount, 1)
assert.NotEqual(t, session.FirstSuccessfulVisit.UnixNano(), visitStart.UnixNano())
assert.Equal(t, session.LastSuccessfulVisit.UnixNano(), visitEnd.UnixNano())
assert.Equal(t, session.LastVisitedAt.UnixNano(), visitEnd.UnixNano())
assert.NotEqual(t, session.FirstSuccessfulVisit.UnixMicro(), visitStart.UnixMicro())
assert.InDelta(t, session.LastSuccessfulVisit.UnixNano(), visitEnd.UnixNano(), float64(time.Microsecond))
assert.InDelta(t, session.LastVisitedAt.UnixNano(), visitEnd.UnixNano(), float64(time.Microsecond))
assert.True(t, session.FirstFailedVisit.IsZero())
assert.True(t, session.FinishReason.IsZero())
assert.True(t, session.LastFailedVisit.IsZero())
Expand Down