Function TestUpdateRedis

cmd/cache/cache_test.go:17–56

TestUpdateRedis tests a message insertion into cache

(t *testing.T)

// TestUpdateRedis tests a message insertion into cache
func TestUpdateRedis(t *testing.T) {
	s, err := miniredis.Run()
	if err != nil {
		t.Fatalf("miniredis connection: %s", err)
	}
	defer s.Close()

	c := redis.NewClient(&redis.Options{Addr: s.Addr()})

	now := time.Now().UnixMilli()
	var tests = []struct {
		message string
		source  string
		time    int64
	}{
		{"Hello", "back", now},
		{"Another test!", "back", now},
		{"1", "front", now},
		{" ", "back", now - 60*60*1000},
	}
	for _, test := range tests {
		d := testArguments(t, test.message, test.source, test.time)
		updateRedis(*d, c)
	}

	if got, err := s.Get("total"); err != nil || got != strconv.Itoa(len(tests)) {
		t.Error("'total' has the wrong value")
	}

	list, err := s.List("messages")
	if err != nil {
		t.Errorf("list 'messages': %s", err)
	}

	if len(list) != len(tests) {
		t.Error("'messages' has wrong length")
	}

	// TODO: compare each message
}

// testArguments produces arguments for the function being tested
func testArguments(t *testing.T, message, source string, time int64) *amqp.Delivery {