Function PythonRecord_SendReply

plugins/python/redisgears_python.c:6945–6988

}

static int PythonRecord_SendReply(Record* r, RedisModuleCtx* rctx){
    PyObject* obj = PyObjRecordGet(r);
    if(PyList_Check(obj)){
        size_t listLen = PyList_Size(obj);
        Record* rgl = RedisGears_ListRecordCreate(listLen);
        for(int i = 0 ; i < listLen ; ++i){
            Record* temp = PyObjRecordCreate();
            PyObject* pItem = PyList_GetItem(obj, i);
            PyObjRecordSet(temp, pItem);
            Py_INCREF(pItem);
            RedisGears_ListRecordAdd(rgl, temp);
        }
        RedisGears_RecordSendReply(rgl, rctx);
        RedisGears_FreeRecord(rgl);
    }else if(PyLong_Check(obj)) {
        RedisModule_ReplyWithLongLong(rctx, PyLong_AsLongLong(obj));
    }else if(PyFloat_Check(obj)){
        double d = PyFloat_AsDouble(obj);
        RedisModuleString* str = RedisModule_CreateStringPrintf(NULL, "%lf", d);
        RedisModule_ReplyWithString(rctx, str);
        RedisModule_FreeString(NULL, str);
    }else if(PyUnicode_Check(obj)) {
        size_t len;
        char* str = (char*)PyUnicode_AsUTF8AndSize(obj, &len);
        if(len > 1){
            if(str[0] == '+'){
                RedisModule_ReplyWithSimpleString(rctx, str + 1);
                return REDISMODULE_OK;
            }else if(str[0] == '-'){
                RedisModule_ReplyWithError(rctx, str + 1);
                return REDISMODULE_OK;
            }
        }
        RedisModule_ReplyWithStringBuffer(rctx, str, len);
    }else if(PyBytes_Check(obj)) {
        size_t len;
        char* str;
        PyBytes_AsStringAndSize(obj, &str, &len);
        RedisModule_ReplyWithStringBuffer(rctx, str, len);
    }else{
        RedisModule_ReplyWithStringBuffer(rctx, "PY RECORD", strlen("PY RECORD"));
    }
    return REDISMODULE_OK;
}

static int PythonRecord_Serialize(ExecutionCtx* ectx, Gears_BufferWriter* bw, Record* base){
    PythonRecord* r = (PythonRecord*)base;