Function PythonSessionCtx_Deserialize

plugins/python/redisgears_python.c:927–1025

}

static void* PythonSessionCtx_Deserialize(Gears_BufferReader* br, int version, char** err, bool useSessionsDict){
    if(version > PY_SESSION_TYPE_VERSION){
        *err = RG_STRDUP("unsupported session version");
        return NULL;
    }

    char *id;
    char *desc = NULL;
    if (version < PY_SESSION_TYPE_WITH_NAMES) {
        /* legacy id convert to str */
        size_t len;
        id = RedisGears_BRReadBuffer(br, &len);
        RedisGears_ASprintf(&id, "%.*s-%lld", REDISMODULE_NODE_ID_LEN, id, *(long long*)&id[REDISMODULE_NODE_ID_LEN]);
    } else {
        id = RG_STRDUP(RedisGears_BRReadString(br));
    }

    if (version >= PY_SESSION_TYPE_WITH_DESC) {
        if (RedisGears_BRReadLong(br)) {
            // description exists
            desc = RG_STRDUP(RedisGears_BRReadString(br));
        }
    }

    PythonSessionCtx* s = currentSession;
    if (s) {
        s = PythonSessionCtx_ShallowCopy(s);
    }
    if (!s && useSessionsDict) {
        s = PythonSessionCtx_Get(id);
    }
    bool sessionExists;
    if(!s){
        s = PythonSessionCtx_CreateWithId(id, desc, NULL, 0, false);
        if (useSessionsDict) {
            PythonSessionCtx_Set(s);
        }
        if(!s){
            *err = RG_STRDUP("Could not create session");
            return NULL;
        }
        sessionExists = false;
    }else{
        sessionExists = true;
    }
    RG_FREE(id);
    RG_FREE(desc);
    size_t withFullReqs = (version < PY_SESSION_TYPE_WITH_REQ_NAMES_ONLY);
    if (version >= PY_SESSION_TYPE_WITH_OPTIONAL_REQS) {
        withFullReqs = RedisGears_BRReadLong(br);
    }
    size_t requirementsLen = RedisGears_BRReadLong(br);
    bool requirementsInstalled = false;
    for(size_t i = 0 ; i < requirementsLen ; ++i){
        PythonRequirementCtx* req;
        if(!withFullReqs){
            const char* reqName = RedisGears_BRReadString(br);
            if(!sessionExists){