Function RedisGearsPy_Execute

plugins/python/redisgears_python.c:5001–5180

}

int RedisGearsPy_Execute(RedisModuleCtx *ctx, RedisModuleString **argv, int argc){
#define ID_SIZE 40
    char id[ID_SIZE + 1] = {0}; // buffer to generate session id

    int ctxFlags = RedisModule_GetContextFlags(ctx);

    if(ctxFlags & (REDISMODULE_CTX_FLAGS_LUA|REDISMODULE_CTX_FLAGS_MULTI|REDISMODULE_CTX_FLAGS_DENY_BLOCKING)){
        RedisModule_ReplyWithError(ctx, "Can not run gears inside a multi exec, lua, or when blocking is not allowed");
        return REDISMODULE_OK;
    }

    if(argc < 2){
        return RedisModule_WrongArity(ctx);
    }

    VERIFY_CLUSTER_INITIALIZE(ctx);

    const char* script = RedisModule_StringPtrLen(argv[1], NULL);
    char *sessionName = NULL;
    char *replaceWith = NULL;
    char *sessionDesc = NULL;
    bool isBlocking = true;
    bool upgrade = false;
    bool forceRequirementsReinstallation = false;
    size_t currArg = 2;
    for(; currArg < argc ; ++currArg) {
        const char* option = RedisModule_StringPtrLen(argv[currArg], NULL);
        if(strcasecmp(option, "UNBLOCKING") == 0){
            isBlocking = false;
            continue;
        }
        if(strcasecmp(option, "UPGRADE") == 0){
            upgrade = true;
            continue;
        }
        if(strcasecmp(option, "FORCE_REINSTALL_REQUIREMENTS") == 0){
            forceRequirementsReinstallation = true;
            continue;
        }
        if(strcasecmp(option, "REPLACE_WITH") == 0){
            if (++currArg >= argc) {
                RedisModule_ReplyWithError(ctx, "REPLACE_WITH is missing");
                return REDISMODULE_OK;
            }
            replaceWith = (char*)RedisModule_StringPtrLen(argv[currArg], NULL);
            continue;
        }
        if(strcasecmp(option, "ID") == 0){
            if (++currArg >= argc) {
                RedisModule_ReplyWithError(ctx, "ID is missing");
                return REDISMODULE_OK;
            }
            sessionName = (char*)RedisModule_StringPtrLen(argv[currArg], NULL);
            if (RedisGearsPy_VerifySessionId(sessionName) != REDISMODULE_OK) {
                RedisModule_ReplyWithError(ctx, "ID must be compose of: ['A'-'Z' | 'a'-'z' | '0' - '9' | '-' | '_']");
                return REDISMODULE_OK;
            }
            continue;