add incomplete db test
This commit is contained in:
parent
c52bccb140
commit
48209e7738
93
db_test.go
Normal file
93
db_test.go
Normal file
|
@ -0,0 +1,93 @@
|
|||
package gotelem
|
||||
|
||||
import (
|
||||
"reflect"
|
||||
"testing"
|
||||
|
||||
"github.com/jmoiron/sqlx"
|
||||
"github.com/kschamplin/gotelem/skylab"
|
||||
)
|
||||
|
||||
// helper func to get a random bus event with random data.
|
||||
func GetRandomBusEvent() skylab.BusEvent {
|
||||
return
|
||||
}
|
||||
|
||||
func TestTelemDb(t *testing.T) {
|
||||
|
||||
var tdb *TelemDb
|
||||
|
||||
t.Run("test opening database", func(t *testing.T) {
|
||||
var err error
|
||||
tdb, err = OpenTelemDb("file::memory:?cache=shared")
|
||||
if err != nil {
|
||||
t.Errorf("could not open db: %v", err)
|
||||
}
|
||||
tdb.db.Ping()
|
||||
})
|
||||
|
||||
t.Run("test inserting bus event", func(t *testing.T) {
|
||||
type args struct {
|
||||
events []skylab.BusEvent
|
||||
}
|
||||
tests := []struct {
|
||||
name string
|
||||
args args
|
||||
wantErr bool
|
||||
}{
|
||||
{
|
||||
name: "add no packet",
|
||||
args: args{
|
||||
events: []skylab.BusEvent{},
|
||||
},
|
||||
wantErr: false,
|
||||
},
|
||||
{
|
||||
name: "add single packet",
|
||||
args: args{
|
||||
events: []skylab.BusEvent{},
|
||||
},
|
||||
wantErr: false,
|
||||
},
|
||||
}
|
||||
for _, tt := range tests {
|
||||
t.Run(tt.name, func(t *testing.T) {
|
||||
if err := tdb.AddEvents(tt.args.events...); (err != nil) != tt.wantErr {
|
||||
t.Errorf("TelemDb.AddEvents() error = %v, wantErr %v", err, tt.wantErr)
|
||||
}
|
||||
})
|
||||
}
|
||||
|
||||
})
|
||||
type fields struct {
|
||||
db *sqlx.DB
|
||||
}
|
||||
type args struct {
|
||||
limit int
|
||||
where []QueryFrag
|
||||
}
|
||||
tests := []struct {
|
||||
name string
|
||||
fields fields
|
||||
args args
|
||||
wantEvents []skylab.BusEvent
|
||||
wantErr bool
|
||||
}{
|
||||
// TODO: Add test cases.
|
||||
}
|
||||
for _, tt := range tests {
|
||||
t.Run(tt.name, func(t *testing.T) {
|
||||
tdb := &TelemDb{
|
||||
db: tt.fields.db,
|
||||
}
|
||||
gotEvents, err := tdb.GetEvents(tt.args.limit, tt.args.where...)
|
||||
if (err != nil) != tt.wantErr {
|
||||
t.Errorf("TelemDb.GetEvents() error = %v, wantErr %v", err, tt.wantErr)
|
||||
return
|
||||
}
|
||||
if !reflect.DeepEqual(gotEvents, tt.wantEvents) {
|
||||
t.Errorf("TelemDb.GetEvents() = %v, want %v", gotEvents, tt.wantEvents)
|
||||
}
|
||||
})
|
||||
}
|
||||
}
|
Loading…
Reference in a new issue