Commit 505f7a07 authored by jan.koester's avatar jan.koester
Browse files

new api

parent 64571d29

plugins/media/media.cpp

+3 −1
Original line number Diff line number Diff line
@@ -531,11 +531,13 @@ namespace blogi { 
                blogi::SQL sql;

                blogi::DBResult res;



                sql << "SELECT media_type.ctype from media_items_files LEFT JOIN media_type ON media_type.id=media_type.id WHERE media_items_files.redis_uuid='";

                sql << "SELECT media_type.ctype FROM media_items_files LEFT JOIN media_type ON media_items_files.id=media_type.id WHERE media_items_files.redis_uuid='";

                sql.escaped(suuid.data()) <<"'";



                int n = Args->database->exec(&sql,res);



                std::cout << res[0][0] << std::endl;



                if(n>0){

                    _store->load(req,suuid.data(),res[0][0]);

                }else{

plugins/media/redis.cpp

+2 −6
Original line number Diff line number Diff line
@@ -38,7 +38,7 @@ blogi::RedisStore::RedisStore(const char *host,int port,const char *password){ 


    struct timeval timeout = { 1, 0 }; // 1.5 seconds



    _RedisCTX=redisConnectWithTimeout(host,port,timeout);

    _RedisCTX=redisConnect(host,port);



    if (_RedisCTX->err) {

        libhttppp::HTTPException exp;
@@ -80,12 +80,8 @@ void blogi::RedisStore::load(libhttppp::HttpRequest *req,const char *key,const c 
        libhttppp::HttpResponse curres;

        curres.setContentType(ctype);

        curres.setState(HTTP200);

        curres.setContentLength(rep->len);

        curres.send(req,nullptr,-1);



        req->addSendData(rep->str,rep->len);

        curres.send(req,rep->str,rep->len);

        freeReplyObject(rep);

        req->sending(true);

    }catch(libhttppp::HTTPException &e){

        libhttppp::HttpResponse curres;

        curres.setContentType(ctype);