Added invalid reply type and empty constructor. Rewrote most of the parsing routines.

include/qredis/reply.h

@@ -19,6 +19,13 @@ namespace QRedis
              */
             enum Type {
 
+                /**
+                 * @brief An invalid reply
+                 *
+                 * This value is only set when the default constructor is used.
+                 */
+                Invalid,
+
                 /**
                  * @brief A status reply
                  *
@@ -61,10 +68,14 @@ namespace QRedis
                 MultiBulk
             };
 
+            /**
+             * @brief Creates an empty reply
+             */
+            Reply() : _type(Invalid) {}
+
             /**
              * @brief Initializes the reply
              * @param type the type of the reply
-             * @param value the value of the reply
              */
             Reply(Type type) : _type(type) {}
 
@@ -75,7 +86,7 @@ namespace QRedis
             Type type() const { return _type; }
 
             /**
-             * @brief Returns the value of the reply
+             * @brief Returns a reference to the value of the reply
              * @return the reply value
              */
             QVariant & value() { return _value; }
@@ -87,4 +98,6 @@ namespace QRedis
     };
 }
 
+Q_DECLARE_METATYPE(QRedis::Reply)
+
 #endif // QREDIS_REPLY_H

src/parser.cpp

@@ -1,5 +1,7 @@
 #include "parser.h"
 
+using namespace QRedis;
+
 Parser::Parser(Lexer * lexer, QObject * parent)
     : QObject(parent)
 {
@@ -16,11 +18,11 @@ void Parser::readCharacter(char c)
 {
     switch(c)
     {
-        case '+': stack.append(Task(Task::ReadStatus));    break;
+        case '+': stack.append(Task(Reply::Status));    break;
-        case '-': stack.append(Task(Task::ReadError));     break;
+        case '-': stack.append(Task(Reply::Error));     break;
-        case ':': stack.append(Task(Task::ReadInteger));   break;
+        case ':': stack.append(Task(Reply::Integer));   break;
-        case '$': stack.append(Task(Task::ReadBulk));      break;
+        case '$': stack.append(Task(Reply::Bulk));      break;
-        case '*': stack.append(Task(Task::ReadMultiBulk)); break;
+        case '*': stack.append(Task(Reply::MultiBulk)); break;
         default:
             qWarning("Skipping unexpected character '%x'", static_cast<int>(c));
             break;
@@ -29,58 +31,35 @@ void Parser::readCharacter(char c)
 
 void Parser::readUnsafeString(const QString & value)
 {
-    if(tos().action == Task::ReadMultiBulk)
+    if(tos().reply.type() == Reply::MultiBulk)
         tos().count = value.toInt();
     else
-    {
+        tos().reply.value() = value;
-        Task::Action action = tos().action;
-        stack.removeLast();
 
-        if(action == Task::ReadStatus)
-            ;//emit status(value);
-        else if(action == Task::ReadError)
-        {
-            int pos = value.indexOf(' ');
-            ;//emit error(value.left(pos), value.right(pos + 1));
-        }
-        else if(!stack.count())
-            ;//emit integer(value.toLongLong());
-        else
-        {
-            tos().value.toList().append(value);
     descend();
-        }
-    }
 }
 
 void Parser::readSafeString(const QByteArray & value)
 {
-    stack.removeLast();
+    tos().reply.value() = value;
-
-    if(!stack.count())
-        ;//emit bulk(value);
-    else
-    {
-        tos().value.toList().append(value);
     descend();
-    }
 }
 
 void Parser::descend()
 {
     while(true)
     {
-        if(tos().value.toList().count() < tos().count)
+        if(tos().reply.type() == Reply::MultiBulk &&
-            break;
+           tos().reply.value().toList().count() < tos().count)
+            return;
 
         if(stack.count() == 1)
         {
-            ;//emit multiBulk(tos().value.toList());
+            emit reply(stack.takeLast().reply);
-            stack.removeLast();
+            return;
-            break;
         }
 
-        Task task = stack.takeLast();
+        Reply r = stack.takeLast().reply;
-        tos().value.toList().append(task.value);
+        tos().reply.value().toList().append(QVariant::fromValue(r));
     }
 }

src/parser.h

@@ -1,16 +1,18 @@
-#ifndef PARSER_H
+#ifndef QREDIS_PARSER_H
-#define PARSER_H
+#define QREDIS_PARSER_H
 
 #include <QList>
 #include <QObject>
+#include <QPair>
 #include <QVariant>
-#include <QVariantList>
 
 #include <qredis/reply.h>
 #include "lexer.h"
 
-class Parser : public QObject
+namespace QRedis
 {
+    class Parser : public QObject
+    {
         Q_OBJECT
 
         public:
@@ -20,7 +22,7 @@ class Parser : public QObject
 
         Q_SIGNALS:
 
-        void reply(QRedis::Reply &);
+            void reply(const Reply &);
 
         private Q_SLOTS:
 
@@ -36,26 +38,18 @@ class Parser : public QObject
             {
                 public:
 
-                enum Action {
-                    ReadStatus,
-                    ReadError,
-                    ReadInteger,
-                    ReadBulk,
-                    ReadMultiBulk
-                };
-
                     enum { Unknown = -2 };
 
-                Task(Action action) : action(action), count(Unknown) {}
+                    Task(Reply::Type type) : reply(type), count(Unknown) {}
 
-                Action action;
+                    Reply reply;
                     int count;
-                QVariant value;
             };
 
             QList<Task> stack;
 
-        inline Task & tos() { return stack.last(); }
+            Task & tos() { return stack.last(); }
-};
+    };
+}
 
-#endif // PARSER_H
+#endif // QREDIS_PARSER_H