xmr-remote-nodes/internal/monero/report_test.go

package monero

import (
	"testing"

	"github.com/ditatompel/xmr-remote-nodes/internal/paging"
	"github.com/jmoiron/sqlx/types"
)

func TestNode_parseStatuses(t *testing.T) {
	tests := []struct {
		name   string
		report Node
		want   string
	}{
		{
			name: "Invalid initial LastCheckStatus type",
			report: Node{
				IsAvailable:     true,
				LastCheckStatus: types.JSONText("-invalid source-"),
			},
			want: "[2,2,2,2,1]",
		},
		{
			name: "Node goes online",
			report: Node{
				IsAvailable:     true,
				LastCheckStatus: types.JSONText("[0,1,0,0,0]"),
			},
			want: "[1,0,0,0,1]",
		},
		{
			name: "Node goes offline",
			report: Node{
				IsAvailable:     false,
				LastCheckStatus: types.JSONText("[0,1,0,1,1]"),
			},
			want: "[1,0,1,1,0]",
		},
	}
	for _, tt := range tests {
		t.Run(tt.name, func(t *testing.T) {
			n := &ProbeReport{
				Node: Node{
					IsAvailable:     tt.report.IsAvailable,
					LastCheckStatus: tt.report.LastCheckStatus,
				},
			}
			if got := n.parseStatuses(); got != tt.want {
				t.Errorf("Node.parseStatuses() = %v, want %v", got, tt.want)
			}
		})
	}
}

func TestQueryLogs_toSQL(t *testing.T) {
	tests := []struct {
		name              string
		fields            QueryLogs
		wantArgs          []interface{}
		wantWhere         string
		wantSortBy        string
		wantSortDirection string
	}{
		{
			name: "Default query",
			fields: QueryLogs{
				Paging: paging.Paging{
					Limit:         10,
					Page:          1,
					SortBy:        "date_checked",
					SortDirection: "desc",
				},
				NodeID:       0,
				Status:       -1,
				FailedReason: "",
			},
			wantArgs:          []interface{}{},
			wantWhere:         "",
			wantSortBy:        "date_checked",
			wantSortDirection: "DESC",
		},
		{
			name: "With node_id query",
			fields: QueryLogs{
				Paging: paging.Paging{
					Limit:         10,
					Page:          1,
					SortBy:        "date_checked",
					SortDirection: "desc",
				},
				NodeID:       1,
				Status:       -1,
				FailedReason: "",
			},
			wantArgs:          []interface{}{1},
			wantWhere:         "WHERE node_id = ?",
			wantSortBy:        "date_checked",
			wantSortDirection: "DESC",
		},
		{
			name: "All possible query",
			fields: QueryLogs{
				Paging: paging.Paging{
					Limit:         10,
					Page:          1,
					SortBy:        "date_checked",
					SortDirection: "asc",
				},
				NodeID:       1,
				Status:       0,
				FailedReason: "test",
			},
			wantArgs:          []interface{}{1, 0, "%test%"},
			wantWhere:         "WHERE node_id = ? AND is_available = ? AND failed_reason LIKE ?",
			wantSortBy:        "date_checked",
			wantSortDirection: "ASC",
		},
	}
	for _, tt := range tests {
		t.Run(tt.name, func(t *testing.T) {
			q := QueryLogs{
				Paging: paging.Paging{
					Limit:         tt.fields.Limit,
					Page:          tt.fields.Page,
					SortBy:        tt.fields.SortBy,
					SortDirection: tt.fields.SortDirection,
				},
				NodeID:       tt.fields.NodeID,
				Status:       tt.fields.Status,
				FailedReason: tt.fields.FailedReason,
			}
			gotArgs, gotWhere, gotSortBy, gotSortDirection := q.toSQL()
			if !equalArgs(gotArgs, tt.wantArgs) {
				t.Errorf("QueryNodes.toSQL() gotArgs = %v, want %v", gotArgs, tt.wantArgs)
			}
			if gotWhere != tt.wantWhere {
				t.Errorf("QueryLogs.toSQL() gotWhere = %v, want %v", gotWhere, tt.wantWhere)
			}
			if gotSortBy != tt.wantSortBy {
				t.Errorf("QueryLogs.toSQL() gotSortBy = %v, want %v", gotSortBy, tt.wantSortBy)
			}
			if gotSortDirection != tt.wantSortDirection {
				t.Errorf("QueryLogs.toSQL() gotSortDirection = %v, want %v", gotSortDirection, tt.wantSortDirection)
			}
		})
	}
}