Function TestSpop

IceFireDB-PubSub/test/cmd_set_test.go:300–360

Test SMOVE *func TestSmove(t *testing.T) { server.Clear() c, err := proto.Dial(server.Addr()) ok(t, err) defer c.Close() s := server.Direct() s.SetAdd("s", "aap", "noot") { must1(t, c, "SMOVE", "s", "s2", "aap", ) m, err := s.IsMember("s", "aap") ok(t, err) equals(t, false, m)

(t *testing.T)

// Test SPOP
func TestSpop(t *testing.T) {
	server.Clear()
	c, err := proto.Dial(server.Addr())
	ok(t, err)
	defer c.Close()
	s := server.Direct()

	t.Run("basics", func(t *testing.T) {
		s.SetAdd("s", "aap", "noot")

		res, err := c.Do("SPOP", "s")
		ok(t, err)
		assert(t, res == proto.String("aap") || res == proto.String("noot"), "spop got something")

		res, err = c.Do("SPOP", "s")
		ok(t, err)
		assert(t, res == proto.String("aap") || res == proto.String("noot"), "spop got something")

		assert(t, !s.Exists("s"), "all spopped away")
	})

	t.Run("nonexisting key", func(t *testing.T) {
		mustNil(t, c, "SPOP", "nosuch")
	})

	t.Run("various errors", func(t *testing.T) {
		s.SetAdd("chk", "aap", "noot")
		s.Set("str", "value")

		/*mustDo(t, c,
			"SMOVE",
			proto.Error(errWrongNumber("smove")),
		)
		mustDo(t, c,
			"SMOVE", "chk", "set2",
			proto.Error(errWrongNumber("smove")),
		)*/

		mustDo(t, c,
			"SPOP", "str",
			proto.Error(msgWrongType),
		)
	})

	t.Run("count argument", func(t *testing.T) {
		s.SetAdd("s", "aap", "noot", "mies", "vuur")
		directDo(t, c, "SPOP", "s", "2")
		/*mustDo(t, c,
			"SPOP", "s", "2",
			proto.Strings("aap", "noot"),
		)*/
		members, err := s.Members("s")
		ok(t, err)
		assert(t, len(members) == 2, "SPOP s 2")

		mustDo(t, c,
			"SPOP", "str", "-12",
			proto.Error(msgOutOfRange),