summaryrefslogtreecommitdiff
path: root/src/modules
diff options
context:
space:
mode:
authorYossi Gottlieb <yossigo@gmail.com>2019-03-24 12:00:33 +0200
committerYossi Gottlieb <yossigo@gmail.com>2019-03-24 12:00:33 +0200
commit822a992f913484162ce508fdb073d8f2ddb6d7c8 (patch)
tree89f776c89b35f0871a743f0d449d5048707a065b /src/modules
parent5e8caca0366e5fdf5fc36292c86964360203de77 (diff)
downloadredis-822a992f913484162ce508fdb073d8f2ddb6d7c8.tar.gz
fix: missing initialization.
Diffstat (limited to 'src/modules')
-rw-r--r--src/modules/hellofilter.c149
1 files changed, 0 insertions, 149 deletions
diff --git a/src/modules/hellofilter.c b/src/modules/hellofilter.c
deleted file mode 100644
index 448e12983..000000000
--- a/src/modules/hellofilter.c
+++ /dev/null
@@ -1,149 +0,0 @@
-#define REDISMODULE_EXPERIMENTAL_API
-#include "../redismodule.h"
-
-#include <string.h>
-
-static RedisModuleString *log_key_name;
-
-static const char log_command_name[] = "hellofilter.log";
-static const char ping_command_name[] = "hellofilter.ping";
-static const char unregister_command_name[] = "hellofilter.unregister";
-static int in_log_command = 0;
-
-static RedisModuleCommandFilter *filter = NULL;
-
-int HelloFilter_UnregisterCommand(RedisModuleCtx *ctx, RedisModuleString **argv, int argc)
-{
- (void) argc;
- (void) argv;
-
- RedisModule_ReplyWithLongLong(ctx,
- RedisModule_UnregisterCommandFilter(ctx, filter));
-
- return REDISMODULE_OK;
-}
-
-int HelloFilter_PingCommand(RedisModuleCtx *ctx, RedisModuleString **argv, int argc)
-{
- (void) argc;
- (void) argv;
-
- RedisModuleCallReply *reply = RedisModule_Call(ctx, "ping", "c", "@log");
- if (reply) {
- RedisModule_ReplyWithCallReply(ctx, reply);
- RedisModule_FreeCallReply(reply);
- } else {
- RedisModule_ReplyWithSimpleString(ctx, "Unknown command or invalid arguments");
- }
-
- return REDISMODULE_OK;
-}
-
-int HelloFilter_LogCommand(RedisModuleCtx *ctx, RedisModuleString **argv, int argc)
-{
- RedisModuleString *s = RedisModule_CreateString(ctx, "", 0);
-
- int i;
- for (i = 1; i < argc; i++) {
- size_t arglen;
- const char *arg = RedisModule_StringPtrLen(argv[i], &arglen);
-
- if (i > 1) RedisModule_StringAppendBuffer(ctx, s, " ", 1);
- RedisModule_StringAppendBuffer(ctx, s, arg, arglen);
- }
-
- RedisModuleKey *log = RedisModule_OpenKey(ctx, log_key_name, REDISMODULE_WRITE|REDISMODULE_READ);
- RedisModule_ListPush(log, REDISMODULE_LIST_HEAD, s);
- RedisModule_CloseKey(log);
- RedisModule_FreeString(ctx, s);
-
- in_log_command = 1;
-
- size_t cmdlen;
- const char *cmdname = RedisModule_StringPtrLen(argv[1], &cmdlen);
- RedisModuleCallReply *reply = RedisModule_Call(ctx, cmdname, "v", &argv[2], argc - 2);
- if (reply) {
- RedisModule_ReplyWithCallReply(ctx, reply);
- RedisModule_FreeCallReply(reply);
- } else {
- RedisModule_ReplyWithSimpleString(ctx, "Unknown command or invalid arguments");
- }
-
- in_log_command = 0;
-
- return REDISMODULE_OK;
-}
-
-void HelloFilter_CommandFilter(RedisModuleCommandFilterCtx *filter)
-{
- if (in_log_command) return; /* don't process our own RM_Call() from HelloFilter_LogCommand() */
-
- /* Fun manipulations:
- * - Remove @delme
- * - Replace @replaceme
- * - Append @insertbefore or @insertafter
- * - Prefix with Log command if @log encounterd
- */
- int log = 0;
- int pos = 0;
- while (pos < RedisModule_CommandFilterArgsCount(filter)) {
- const RedisModuleString *arg = RedisModule_CommandFilterArgGet(filter, pos);
- size_t arg_len;
- const char *arg_str = RedisModule_StringPtrLen(arg, &arg_len);
-
- if (arg_len == 6 && !memcmp(arg_str, "@delme", 6)) {
- RedisModule_CommandFilterArgDelete(filter, pos);
- continue;
- }
- if (arg_len == 10 && !memcmp(arg_str, "@replaceme", 10)) {
- RedisModule_CommandFilterArgReplace(filter, pos,
- RedisModule_CreateString(NULL, "--replaced--", 12));
- } else if (arg_len == 13 && !memcmp(arg_str, "@insertbefore", 13)) {
- RedisModule_CommandFilterArgInsert(filter, pos,
- RedisModule_CreateString(NULL, "--inserted-before--", 19));
- pos++;
- } else if (arg_len == 12 && !memcmp(arg_str, "@insertafter", 12)) {
- RedisModule_CommandFilterArgInsert(filter, pos + 1,
- RedisModule_CreateString(NULL, "--inserted-after--", 18));
- pos++;
- } else if (arg_len == 4 && !memcmp(arg_str, "@log", 4)) {
- log = 1;
- }
- pos++;
- }
-
- if (log) RedisModule_CommandFilterArgInsert(filter, 0,
- RedisModule_CreateString(NULL, log_command_name, sizeof(log_command_name)-1));
-}
-
-int RedisModule_OnLoad(RedisModuleCtx *ctx, RedisModuleString **argv, int argc) {
- if (RedisModule_Init(ctx,"hellofilter",1,REDISMODULE_APIVER_1)
- == REDISMODULE_ERR) return REDISMODULE_ERR;
-
- if (argc != 2) {
- RedisModule_Log(ctx, "warning", "Log key name not specified");
- return REDISMODULE_ERR;
- }
-
- long long noself = 0;
- log_key_name = RedisModule_CreateStringFromString(ctx, argv[0]);
- RedisModule_StringToLongLong(argv[1], &noself);
-
- if (RedisModule_CreateCommand(ctx,log_command_name,
- HelloFilter_LogCommand,"write deny-oom",1,1,1) == REDISMODULE_ERR)
- return REDISMODULE_ERR;
-
- if (RedisModule_CreateCommand(ctx,ping_command_name,
- HelloFilter_PingCommand,"deny-oom",1,1,1) == REDISMODULE_ERR)
- return REDISMODULE_ERR;
-
- if (RedisModule_CreateCommand(ctx,unregister_command_name,
- HelloFilter_UnregisterCommand,"write deny-oom",1,1,1) == REDISMODULE_ERR)
- return REDISMODULE_ERR;
-
- if ((filter = RedisModule_RegisterCommandFilter(ctx, HelloFilter_CommandFilter,
- noself ? REDISMODULE_CMDFILTER_NOSELF : 0))
- == NULL) return REDISMODULE_ERR;
-
- return REDISMODULE_OK;
-}