From 896db12b418877967d7689e2731c266d8dd1d4f9 Mon Sep 17 00:00:00 2001 From: Dvir Volk Date: Mon, 27 Nov 2017 23:13:45 +0200 Subject: fixed test --- src/modules/testmodule.c | 8 +++++++- 1 file changed, 7 insertions(+), 1 deletion(-) diff --git a/src/modules/testmodule.c b/src/modules/testmodule.c index e360866f9..8ab8c4ea3 100644 --- a/src/modules/testmodule.c +++ b/src/modules/testmodule.c @@ -155,7 +155,8 @@ int TestUnlink(RedisModuleCtx *ctx, RedisModuleString **argv, int argc) { } int NotifyCallback(RedisModuleCtx *ctx, int type, const char *event, RedisModuleString *key) { - // Increment a counter on the notifications + // Increment a counter on the notifications: + // for each key notified we increment a counter RedisModule_Log(ctx, "notice", "Got event type %d, event %s, key %s\n", type, event, RedisModule_StringPtrLen(key, NULL)); RedisModule_Call(ctx, "HINCRBY", "csc", "notifications", key, "1"); @@ -218,13 +219,18 @@ int TestNotifications(RedisModuleCtx *ctx, RedisModuleString **argv, int argc) { FAIL("Got reply '%.*s'. expected '1'", sz, rep); } } + // for l we expect nothing since we didn't subscribe to list events r = RedisModule_Call(ctx, "HGET", "cc", "notifications", "l"); if (r == NULL || RedisModule_CallReplyType(r) != REDISMODULE_REPLY_NULL) { FAIL("Wrong reply for l"); } + RedisModule_Call(ctx, "FLUSHDB", ""); + return RedisModule_ReplyWithSimpleString(ctx, "OK"); err: + RedisModule_Call(ctx, "FLUSHDB", ""); + return RedisModule_ReplyWithSimpleString(ctx, "ERR"); } -- cgit v1.2.1