summaryrefslogtreecommitdiff
path: root/tests/papod.go
diff options
context:
space:
mode:
Diffstat (limited to 'tests/papod.go')
-rw-r--r--tests/papod.go124
1 files changed, 54 insertions, 70 deletions
diff --git a/tests/papod.go b/tests/papod.go
index af2a5f7..2d908f5 100644
--- a/tests/papod.go
+++ b/tests/papod.go
@@ -4,46 +4,42 @@ import (
"bufio"
"database/sql"
"errors"
- "os"
- "reflect"
"strings"
- "testing"
- "testing/internal/testdeps"
+ // "q"
g "gobang"
)
-func errorIf(t *testing.T, err error) {
- if err != nil {
- t.Errorf("Unexpected error: %#v\n", err)
- }
-}
-func errorIfNotI(t *testing.T, i int, err error) {
- if err == nil {
- t.Errorf("Expected error, got nil (i = %d)\n", i)
+func test_initDB() {
+ g.TestStart("initDB()")
+
+ /*
+ q := new(liteq.Queue)
+ sql.Register("sqliteq", liteq.MakeDriver(q))
+
+ db, err := sql.Open("sqliteq", "file:papod-test.db?mode=memory&cache=shared")
+ if err != nil {
+ panic(err)
}
-}
+ // defer db.Close()
-func assertEqualI(t *testing.T, i int, given any, expected any) {
- if !reflect.DeepEqual(given, expected) {
- t.Errorf("given != expected (i = %d)\n", i)
- t.Errorf("given: %#v\n", given)
- t.Errorf("expected: %#v\n", expected)
+ *q, err = liteq.New(db)
+ if err != nil {
+ panic(err)
}
-}
+ // defer q.Close()
-func assertEqual(t *testing.T, given any, expected any) {
- if !reflect.DeepEqual(given, expected) {
- t.Errorf("given != expected")
- t.Errorf("given: %#v\n", given)
- t.Errorf("expected: %#v\n", expected)
+ // _, err = New(db, *q)
+ // _, err = initDB(db,
+ if err != nil {
+ panic(err)
}
+ */
}
-
-func TestSplitOnCRLF(t *testing.T) {
+func test_SplitOnCRLF() {
type tableT struct {
input string
expected []string
@@ -83,7 +79,7 @@ func TestSplitOnCRLF(t *testing.T) {
},
}
- for i, entry := range table {
+ for _, entry := range table {
var given []string
scanner := bufio.NewScanner(strings.NewReader(entry.input))
scanner.Split(SplitOnCRLF)
@@ -92,12 +88,12 @@ func TestSplitOnCRLF(t *testing.T) {
}
err := scanner.Err()
- errorIf(t, err)
- assertEqualI(t, i, given, entry.expected)
+ g.TErrorIf(err)
+ g.TAssertEqual(given, entry.expected)
}
}
-func TestSplitOnRawMessage(t *testing.T) {
+func test_SplitOnRawMessage() {
type tableT struct {
input string
expected []string
@@ -114,7 +110,7 @@ func TestSplitOnRawMessage(t *testing.T) {
}
- for i, entry := range table {
+ for _, entry := range table {
var given []string
scanner := bufio.NewScanner(strings.NewReader(entry.input))
scanner.Split(SplitOnRawMessage)
@@ -123,12 +119,12 @@ func TestSplitOnRawMessage(t *testing.T) {
}
err := scanner.Err()
- errorIf(t, err)
- assertEqualI(t, i, given, entry.expected)
+ g.TErrorIf(err)
+ g.TAssertEqual(given, entry.expected)
}
}
-func TestParseMessageParams(t *testing.T) {
+func test_ParseMessageParams() {
type tableT struct {
input string
expected MessageParams
@@ -311,13 +307,13 @@ func TestParseMessageParams(t *testing.T) {
},
}
- for i, entry := range table {
+ for _, entry := range table {
given := ParseMessageParams(entry.input)
- assertEqualI(t, i, given, entry.expected)
+ g.TAssertEqual(given, entry.expected)
}
}
-func TestParseMessage(t *testing.T) {
+func test_ParseMessage() {
type tableTOK struct {
input string
expected Message
@@ -442,16 +438,16 @@ func TestParseMessage(t *testing.T) {
},
}}
- for i, entry := range tableOK {
+ for _, entry := range tableOK {
given, err := ParseMessage(entry.input)
- errorIf(t, err)
- assertEqualI(t, i, given, entry.expected)
+ g.TErrorIf(err)
+ g.TAssertEqual(given, entry.expected)
}
type tableErrorT struct {
input string
- expected error
+ expected error
}
parseErr := errors.New("Can't parse message")
tableError := []tableErrorT {
@@ -469,31 +465,31 @@ func TestParseMessage(t *testing.T) {
},
}
- for i, entry := range tableError {
+ for _, entry := range tableError {
_, given := ParseMessage(entry.input)
- assertEqualI(t, i, given, entry.expected)
+ g.TAssertEqual(given, entry.expected)
}
}
-func TestInitMigrations(t *testing.T) {
+func test_InitMigrations() {
const query = `SELECT filename FROM migrations;`
db, err := sql.Open("sqlite3", ":memory:")
g.FatalIf(err)
_, err = db.Query(query)
- assertEqual(t, err.Error(), "no such table: migrations")
+ g.TAssertEqual(err.Error(), "no such table: migrations")
for i := 0; i < 5; i++ {
InitMigrations(db)
rows, err := db.Query(query)
g.FatalIf(err)
- assertEqual(t, rows.Next(), false)
+ g.TAssertEqual(rows.Next(), false)
g.FatalIf(rows.Err())
}
}
-func TestPendingMigrations(t *testing.T) {
+func test_PendingMigrations() {
db, err := sql.Open("sqlite3", ":memory:")
g.FatalIf(err)
@@ -501,10 +497,10 @@ func TestPendingMigrations(t *testing.T) {
pending1 := PendingMigrations(db)
pending2 := PendingMigrations(db)
- assertEqual(t, pending1, pending2)
+ g.TAssertEqual(pending1, pending2)
}
-func TestRunMigrations(t *testing.T) {
+func test_RunMigrations() {
db, err := sql.Open("sqlite3", ":memory:")
g.FatalIf(err)
@@ -516,25 +512,13 @@ func TestRunMigrations(t *testing.T) {
func MainTest() {
- tests := []testing.InternalTest {
- { "TestSplitOnCRLF", TestSplitOnCRLF },
- { "TestSplitOnRawMessage", TestSplitOnRawMessage },
- { "TestParseMessageParams", TestParseMessageParams },
- { "TestParseMessage", TestParseMessage },
- { "TestInitMigrations", TestInitMigrations },
- { "TestPendingMigrations", TestPendingMigrations },
- { "TestRunMigrations", TestRunMigrations },
- }
-
- benchmarks := []testing.InternalBenchmark {}
- fuzzTargets := []testing.InternalFuzzTarget {}
- examples := []testing.InternalExample {}
- m := testing.MainStart(
- testdeps.TestDeps {},
- tests,
- benchmarks,
- fuzzTargets,
- examples,
- )
- os.Exit(m.Run())
+ test_initDB()
+ test_SplitOnCRLF()
+ test_SplitOnRawMessage()
+ test_ParseMessageParams()
+ test_ParseMessage()
+
+ // { "TestInitMigrations", TestInitMigrations },
+ // { "TestPendingMigrations", TestPendingMigrations },
+ // { "TestRunMigrations", TestRunMigrations },
}