Function TestMonitor

command/server_test.go:35–67

(t *testing.T)

}

func TestMonitor(t *testing.T) {
	assert := assert.New(t)
	cli := &context.ClientContext{
		Namespace:  "$unittest",
		ID:         1,
		RemoteAddr: "127.0.0.1",
		DB:         &db.DB{Namespace: "$unittest", ID: 0},
	}
	serv := &context.ServerContext{}

	out := bytes.NewBuffer(nil)
	ctx := &Context{
		Name:    "monitor",
		Args:    nil,
		In:      nil,
		Out:     out,
		Context: context.New(cli, serv),
	}

	Monitor(ctx)
	assert.Equal("+OK\r\n", out.String())

	out.Reset()
	ctx = &Context{
		Name:    "ping",
		Args:    nil,
		In:      nil,
		Out:     ioutil.Discard,
		Context: ctx.Context,
	}
	feedMonitors(ctx)
	assert.Contains(out.String(), "[0 127.0.0.1] ping \r\n")
}

func TestClient_List(t *testing.T) {
	assert := assert.New(t)