Function futureContinue

plugins/python/redisgears_python.c:2050–2108

}

static PyObject* futureContinue(PyObject *self, PyObject *args){
    if(PyTuple_Size(args) != 1){
        PyErr_SetString(GearsError, "Continue function expect an object");
        return NULL;
    }

    PyFuture* pyFuture = (PyFuture*)self;
    if(!pyFuture->asyncRecord){
        PyErr_SetString(GearsError, "Can not continue with the same future twice");
        return NULL;
    }

    Record* record = NULL;

    PyObject* obj = PyTuple_GetItem(args, 0);
    switch(pyFuture->continueType){
    case ContinueType_Default:
        Py_INCREF(obj);
        record = PyObjRecordCreate();
        PyObjRecordSet(record, obj);
        break;
    case ContinueType_Filter:
        if(PyObject_IsTrue(obj)){
            record = RedisGears_GetDummyRecord(); // everithing other then NULL will be true;
        }
        break;
    case ContinueType_Flat:
        if(PyList_Check(obj)){
            size_t len = PyList_Size(obj);
            record = RedisGears_ListRecordCreate(len);
            for(size_t i = 0 ; i < len ; ++i){
                PyObject* temp = PyList_GetItem(obj, i);
                Record* pyRecord = PyObjRecordCreate();
                Py_INCREF(temp);
                PyObjRecordSet(pyRecord, temp);
                RedisGears_ListRecordAdd(record, pyRecord);
            }
        }else{
            // just a normal pyobject
            Py_INCREF(obj);
            record = PyObjRecordCreate();
            PyObjRecordSet(record, obj);
        }
        break;
    case ContinueType_Foreach:
        record = RedisGears_GetDummyRecord(); // continue with the old record
        break;
    default:
        PyErr_SetString(GearsError, "Can not handle future untill it returned from the callback");
        return NULL;
        break;
    }

    RedisGears_AsyncRecordContinue(pyFuture->asyncRecord, record);
    pyFuture->asyncRecord = NULL;

    Py_INCREF(Py_None);
    return Py_None;