/** * This file is part of the KDE project * Copyright (C) 2008 Kevin Ottens <ervin@kde.org> * * This library is free software; you can redistribute it and/or * modify it under the terms of the GNU Library General Public * License as published by the Free Software Foundation; either * version 2 of the License, or (at your option) any later version. * * This library is distributed in the hope that it will be useful, * but WITHOUT ANY WARRANTY; without even the implied warranty of * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU * Library General Public License for more details. * * You should have received a copy of the GNU Library General Public License * along with this library; see the file COPYING.LIB. If not, write to * the Free Software Foundation, Inc., 51 Franklin Street, Fifth Floor, * Boston, MA 02110-1301, USA. */ #ifndef QTJOLIE_SODEPHELPERS_P_H #define QTJOLIE_SODEPHELPERS_P_H #include <QtCore/QIODevice> #include <QtCore/QString> #include <QtCore/QStringList> #include "value.h" #include "fault.h" #include "message.h" namespace Jolie { inline void sodepWrite(QIODevice &io, double value) { const char *in = (const char*)&value; char out[8]; for (int i=0; i<8; ++i) { out[i] = in[7-i]; } io.write(out, 8); } inline void sodepWrite(QIODevice &io, qint32 value) { const char *in = (const char*)&value; char out[4]; for (int i=0; i<4; ++i) { out[i] = in[3-i]; } io.write(out, 4); } inline void sodepWrite(QIODevice &io, qint64 value) { const char *in = (const char*)&value; char out[8]; for (int i=0; i<8; ++i) { out[i] = in[7-i]; } io.write(out, 8); } inline void sodepWrite(QIODevice &io, const QString &value) { QByteArray data = value.toUtf8(); sodepWrite(io, data.size()); io.write(data); } inline void sodepWrite(QIODevice &io, const Value &value) { if (value.isDouble()) { io.putChar(3); sodepWrite(io, value.toDouble()); } else if (value.isInt()) { io.putChar(2); sodepWrite(io, value.toInt()); } else if (value.isString()) { io.putChar(1); sodepWrite(io, value.toString()); } else { io.putChar(0); } sodepWrite(io, value.childrenNames().size()); foreach (const QString &name, value.childrenNames()) { sodepWrite(io, name); QList<Value> values = value.children(name); qint32 valueCount = values.size(); sodepWrite(io, valueCount); for (int j=0; j<valueCount; ++j) { sodepWrite(io, values[j]); } } } inline void sodepWrite(QIODevice &io, const Fault &fault) { if (!fault.isValid()) { io.putChar(0); return; } io.putChar(1); sodepWrite(io, fault.name()); sodepWrite(io, fault.data()); } inline void sodepWrite(QIODevice &io, const Message &message) { sodepWrite(io, message.id()); sodepWrite(io, message.resourcePath()); sodepWrite(io, message.operationName()); sodepWrite(io, message.fault()); sodepWrite(io, message.data()); } inline double sodepReadDouble(QIODevice &io) { while (io.bytesAvailable()<8) { io.waitForReadyRead(-1); } double d; char *out = (char*)&d; char in[8]; io.read(in, 8); for (int i=0; i<8; ++i) { out[i] = in[7-i]; } return d; } inline qint32 sodepReadInt32(QIODevice &io) { while (io.bytesAvailable()<4) { io.waitForReadyRead(-1); } qint32 i; char *out = (char*)&i; char in[4]; io.read(in, 4); for (int j=0; j<4; ++j) { out[j] = in[3-j]; } return i; } inline qint64 sodepReadInt64(QIODevice &io) { while (io.bytesAvailable()<8) { io.waitForReadyRead(-1); } qint64 i; char *out = (char*)&i; char in[8]; io.read(in, 8); for (int j=0; j<8; ++j) { out[j] = in[7-j]; } return i; } inline QString sodepReadString(QIODevice &io) { qint32 length = sodepReadInt32(io); while (io.bytesAvailable()<length) { io.waitForReadyRead(-1); } char *data = new char[length+1]; io.read(data, length); data[length] = '\0'; QString result = QString::fromUtf8(data); delete[] data; return result; } inline Value sodepReadValue(QIODevice &io) { Value result; while (io.bytesAvailable()<1) { io.waitForReadyRead(-1); } char code; io.getChar(&code); switch(code) { case 3: { result = Value(sodepReadDouble(io)); break; } case 2: { result = Value(sodepReadInt32(io)); break; } case 1: { result = Value(sodepReadString(io)); break; } default: break; } qint32 childrenCount = sodepReadInt32(io); for (int i=0; i<childrenCount; ++i) { QString name = sodepReadString(io); qint32 valueCount = sodepReadInt32(io); for (int j=0; j<valueCount; ++j) { result.children(name) << sodepReadValue(io); } } return result; } inline Fault sodepReadFault(QIODevice &io) { while (io.bytesAvailable()<1) { io.waitForReadyRead(-1); } char code; io.getChar(&code); if (code!=1) { return Fault(); } QString name = sodepReadString(io); Value data = sodepReadValue(io); return Fault(name, data); } inline Message sodepReadMessage(QIODevice &io) { qint64 id = sodepReadInt64(io); QString resourcePath = sodepReadString(io); QString operationName = sodepReadString(io); Message result(resourcePath, operationName, id); result.setFault(sodepReadFault(io)); result.setData(sodepReadValue(io)); return result; } } // namespace Jolie #endif