VFS_stream.cpp

Go to the documentation of this file.

 
#include "VFS.h"
#include "VFS_base/VFS_icons.h"
#include "VFS_stream.h"
 
#include <QJsonObject>
 
VFS_stream::VFS_stream(quint32 maxSize, bool newlineTrim)
: VFS_node()
, _maxSize(maxSize)
, _newlineTrim(newlineTrim)
{
}
 
VFS_stream::~VFS_stream()
{
}
 
QByteArray VFS_stream::icon()
{
        return VFS_icons::get("stream");
}
 
QString VFS_stream::reportDetails()
{
        QString s = QString("%1 / %2").arg(_data.size()).arg(_maxSize);
        return s;
}
 
void VFS_stream::read(VFS_request *r)
{
        //QMutexLocker l(&_lock);
 
        QJsonObject o;
        o["data"] = _data;
        QJsonDocument d(o);
 
        r->_data = d;
        r->_success = true;
}
 
void VFS_stream::metadata(VFS_request *r)
{
        VFS_node::metadata(r);
 
        r->_metadata["type"] = "textStream";
 
        r->_success = true;
}
 
void VFS_stream::write(VFS_request *r)
{
        //QMutexLocker l(&_lock);
 
        //printf("STREAM WRITE: %p\n",r->_origin);
 
        QJsonObject o = r->_data.object();
        if (o.contains("data"))
        {
                QJsonValue v = o["data"];
 
                if (v.isString())
                {
                        QString data = v.toString();
 
                        _data += data + (data.right(1)!="\n"? "\n" : "");
 
                        if (_maxSize)
                        {       if (_newlineTrim)
                                {
                                        while( _data.size() > _maxSize)
                                        {
                                                int i = _data.indexOf("\n");
                                                if (i > -1)
                                                        _data = _data.remove(0,i+1);
                                                else
                                                        _data = "";
                                        }
                                }
                                else
                                        _data = _data.right(_maxSize);
                        }
 
                        r->_success = true;
 
                        emit diff(this,r);
 
                        return;
                }
 
                if (v.isNull())                 //clear the stream
                {
                        _data = "";
 
                        r->_success = true;
 
                        emit diff(this,r);
 
                        return;
                }
        }
 
        //printf("BAD DATA!\n");
        r->_success = false;
        r->_reason = "Bad stream data... only strings and null are allowed, and a 'data' field must exist.";
}
 
void VFS_stream::submit(VFS_request *r)
{
        write(r);
}
 
void VFS_stream::applyDiff(VFS_request *r)
{
        write(r);
 
        //VFS_node::applyDiff(r);
}
 
bool VFS_stream::isContainer()
{
        return false;
}