Function getCommand

plugins/python/redisgears_python.c:4625–4653

}

static PyObject* getCommand(PyObject *cls, PyObject *args){
    PythonThreadCtx* ptctx = GetPythonThreadCtx();

    CommandCtx* commandCtx = getCommandCtx(ptctx);
    if(!commandCtx){
        PyErr_SetString(GearsError, "Can not get command ctx");
        return NULL;
    }

    // we must take the lock, it is not safe to access the command args without the lock because redis might
    // change them under our noise
    RedisGears_LockHanlderAcquire(staticCtx);

    size_t len;
    RedisModuleString** argv = RedisGears_CommandCtxGetCommand(commandCtx, &len);

    PyObject *list = PyList_New(0);

    for(size_t i = 0 ; i < len ; ++i){
        size_t strLen;
        const char* arg = RedisModule_StringPtrLen(argv[i], &strLen);
        PyObject* pyArg = PyUnicode_FromStringAndSize(arg, strLen);
        PyList_Append(list, pyArg);
    }

    RedisGears_LockHanlderRelease(staticCtx);

    return list;
}

static PyObject* callNext(PyObject *cls, PyObject *args){
    PythonThreadCtx* ptctx = GetPythonThreadCtx();