(t *testing.T)
| 36 | return msg.Bytes() |
| 37 | } |
| 38 | |
| 39 | func TestReadStartupMessageValid(t *testing.T) { |
| 40 | msg := buildStartupMessage(196608, map[string]string{ // protocol 3.0 |
| 41 | "user": "alice", |
| 42 | "database": "db1", |
| 43 | }) |
| 44 | startup, err := ReadStartupMessage(bytes.NewReader(msg)) |
| 45 | if err != nil { |
| 46 | t.Fatalf("ReadStartupMessage: %v", err) |
| 47 | } |
| 48 | if startup.Params["user"] != "alice" || startup.Params["database"] != "db1" { |
| 49 | t.Fatalf("unexpected params: %v", startup.Params) |
| 50 | } |
| 51 | } |
| 52 | |
| 53 | func TestReadStartupMessageSSLRequest(t *testing.T) { |
nothing calls this directly
no test coverage detected