Function registerCreateCommandArgs

plugins/python/redisgears_python.c:1858–1913

}

static void* registerCreateCommandArgs(PyObject *kargs){
    const char* trigger = NULL;
    const char* keyPrefix = NULL;
    const char* hook = NULL;
    int inOrder = 0;
    PyObject* pyTrigger = GearsPyDict_GetItemString(kargs, "trigger");
    if(pyTrigger){
        if(!PyUnicode_Check(pyTrigger)){
            PyErr_SetString(GearsError, "trigger argument is not string");
            return NULL;
        }
        trigger = PyUnicode_AsUTF8AndSize(pyTrigger, NULL);
    }

    PyObject* pyInOrder = GearsPyDict_GetItemString(kargs, "inorder");
    if(pyInOrder){
        if(!PyBool_Check(pyInOrder)){
            PyErr_SetString(GearsError, "inorder argument is be boolean");
            return NULL;
        }
        inOrder = Py_True == pyInOrder ? 1 : 0;
    }

    PyObject* PykeyPrefix = GearsPyDict_GetItemString(kargs, "keyprefix");
    if(PykeyPrefix){
        if(!PyUnicode_Check(PykeyPrefix)){
            PyErr_SetString(GearsError, "keyprefix argument is not string");
            return NULL;
        }
        keyPrefix = PyUnicode_AsUTF8AndSize(PykeyPrefix, NULL);
    }

    PyObject* PyHook = GearsPyDict_GetItemString(kargs, "hook");
    if(PyHook){
        if(!PyUnicode_Check(PyHook)){
            PyErr_SetString(GearsError, "hook argument is not string");
            return NULL;
        }
        hook = PyUnicode_AsUTF8AndSize(PyHook, NULL);
    }

    if(trigger){
        if(keyPrefix || hook){
            PyErr_SetString(GearsError, "trigger argument can not be given with keyprefix or hook");
            return NULL;
        }
        return RedisGears_CommandReaderTriggerArgsCreate(trigger, inOrder);
    }else{
        if(!hook){
            PyErr_SetString(GearsError, "no trigger or hook argument was given");
            return NULL;
        }
        return RedisGears_CommandReaderTriggerArgsCreateHook(hook, keyPrefix, inOrder);
    }

}

static void* registerCreateArgs(FlatExecutionPlan* fep, PyObject *kargs, ExecutionMode mode){