Merge pull request #330 from kotl/master

Add bi-directional (stream + get/set) support and refactoring of the internal classes

Author: proppy

contrib/src/modem/command.h

@@ -1,7 +1,7 @@
 #ifndef MODEM_COMMAND_H
 #define MODEM_COMMAND_H
 
-#include "Firebase.h"
+#include "FirebaseArduino.h"
 #include "modem/output-stream.h"
 #include "modem/input-stream.h"
 
@@ -10,19 +10,19 @@ namespace modem {
 
 class Command {
  public:
-  Command(Firebase* fbase) : fbase_(fbase) {}
+  Command(FirebaseArduino* fbase) : fbase_(fbase) {}
 
   // Execute command, reading any additional data needed from stream.
   // Return false if execution failed.
   virtual bool execute(const String& command,
                        InputStream* in, OutputStream* out) = 0;
  protected:
-  Firebase& fbase() {
+  FirebaseArduino& fbase() {
     return *fbase_;
   }
 
  private:
-  Firebase* fbase_;
+  FirebaseArduino* fbase_;
 };
 
 }  // modem

contrib/src/modem/db/DatabaseProtocol.cpp

@@ -42,7 +42,7 @@ void DatabaseProtocol::Execute(const String& command_name, InputStream* in,
 }
 
 std::unique_ptr<Command> DatabaseProtocol::CreateCommand(const String& text,
-                                                         Firebase* fbase) {
+                                                         FirebaseArduino* fbase) {
   std::unique_ptr<Command> command;
   if (text == "GET") {
     command.reset(new GetCommand(fbase));

contrib/src/modem/db/DatabaseProtocol.h

@@ -13,9 +13,9 @@ class DatabaseProtocol : public SerialProtocol {
   const std::vector<String>& commands() const override;
   void Execute(const String& command, InputStream* in, OutputStream* out) override;
  private:
-  std::unique_ptr<Command> CreateCommand(const String& text, Firebase* fbase);
+  std::unique_ptr<Command> CreateCommand(const String& text, FirebaseArduino* fbase);
 
-  std::unique_ptr<Firebase> fbase_;
+  std::unique_ptr<FirebaseArduino> fbase_;
 };
 
 

contrib/src/modem/db/begin-command.cpp

@@ -33,13 +33,14 @@ bool BeginCommand::execute(const String& command,
     return false;
   }
 
-  new_firebase_.reset(new Firebase(host.c_str(), auth.c_str()));
+  new_firebase_.reset(new FirebaseArduino());
+  new_firebase_.get()->begin(host.c_str(), auth.c_str());
 
   out->println("+OK");
   return true;
 }
 
-std::unique_ptr<Firebase> BeginCommand::firebase() {
+std::unique_ptr<FirebaseArduino> BeginCommand::firebase() {
   return std::move(new_firebase_);
 }
 

contrib/src/modem/db/commands.h

@@ -1,7 +1,7 @@
 #ifndef MODEM_DB_COMMANDS_H
 #define MODEM_DB_COMMANDS_H
 
-#include "Firebase.h"
+#include "FirebaseArduino.h"
 #include "modem/command.h"
 #include "modem/output-stream.h"
 #include "modem/input-stream.h"
@@ -11,28 +11,28 @@ namespace modem {
 
 class GetCommand : public Command {
  public:
-  GetCommand(Firebase* fbase) : Command(fbase) {}
+  GetCommand(FirebaseArduino* fbase) : Command(fbase) {}
 
   bool execute(const String& command, InputStream* in, OutputStream* out);
 };
 
 class SetCommand : public Command {
  public:
-  SetCommand(Firebase* fbase) : Command(fbase) {}
+  SetCommand(FirebaseArduino* fbase) : Command(fbase) {}
 
   bool execute(const String& command, InputStream* in, OutputStream* out);
 };
 
 class RemoveCommand : public Command {
  public:
-  RemoveCommand(Firebase* fbase) : Command(fbase) {}
+  RemoveCommand(FirebaseArduino* fbase) : Command(fbase) {}
 
   bool execute(const String& command, InputStream* in, OutputStream* out);
 };
 
 class PushCommand : public Command {
  public:
-  PushCommand(Firebase* fbase) : Command(fbase) {}
+  PushCommand(FirebaseArduino* fbase) : Command(fbase) {}
 
   bool execute(const String& command, InputStream* in, OutputStream* out);
 };
@@ -44,15 +44,15 @@ class BeginCommand : public Command {
   bool execute(const String& command, InputStream* in, OutputStream* out);
 
   // This can only be called once.
-  std::unique_ptr<Firebase> firebase();
+  std::unique_ptr<FirebaseArduino> firebase();
 
  private:
-  std::unique_ptr<Firebase> new_firebase_;
+  std::unique_ptr<FirebaseArduino> new_firebase_;
 };
 
 class StreamCommand : public Command {
  public:
-  StreamCommand(Firebase* fbase) : Command(fbase) {}
+  StreamCommand(FirebaseArduino* fbase) : Command(fbase) {}
 
   bool execute(const String& command, InputStream* in, OutputStream* out);
 };

contrib/src/modem/db/get-command.cpp

@@ -13,16 +13,14 @@ bool GetCommand::execute(const String& command,
     return false;
   }
 
-  std::string path = in->readLine().c_str();
-  std::unique_ptr<FirebaseGet> get(fbase().getPtr(path));
-
-  if (get->error()) {
+  String path = in->readLine();
+  String value = fbase().getString(path);
+  if (fbase().error().length() != 0) {
     out->print("-FAIL ");
-    out->println(get->error().message().c_str());
+    out->println(fbase().error().c_str());
     return false;
   }
 
-  String value(get->response().c_str());
   // TODO implement json parsing to pull and process value.
   out->print("+");
   out->println(value);

contrib/src/modem/db/push-command.cpp

@@ -14,15 +14,14 @@ bool PushCommand::execute(const String& command,
     return false;
   }
 
-  std::string path(in->readStringUntil(' ').c_str());
-  std::string data(in->readLine().c_str());
+  String path =  in->readStringUntil(' ');
+  String data = in->readLine();
 
-  std::unique_ptr<FirebasePush> push(
-      fbase().pushPtr(path, EncodeForJson(data)));
+  fbase().pushString(path, data);
 
-  if (push->error()) {
+  if (fbase().error().length() != 0) {
     out->print("-FAIL ");
-    out->println(push->error().message().c_str());
+    out->println(fbase().error().c_str());
     return false;
   } else {
     out->println("+OK");

contrib/src/modem/db/remove-command.cpp

@@ -14,11 +14,11 @@ bool RemoveCommand::execute(const String& command,
   }
 
   String path = in->readLine();
-  std::unique_ptr<FirebaseRemove> get(fbase().removePtr(path.c_str()));
+  fbase().remove(path);
 
-  if (get->error()) {
+  if (fbase().error().length() != 0) {
     out->print("-FAIL ");
-    out->println(get->error().message().c_str());
+    out->println(fbase().error().c_str());
     return false;
   }
 

contrib/src/modem/db/set-command.cpp

@@ -14,15 +14,14 @@ bool SetCommand::execute(const String& command,
     return false;
   }
 
-  std::string path(in->readStringUntil(' ').c_str());
-  std::string data(in->readLine().c_str());
+  String path = in->readStringUntil(' ');
+  String data = in->readLine();
 
-  std::unique_ptr<FirebaseSet> set(fbase().setPtr(path,
-                                                  EncodeForJson(data)));
+  fbase().setString(path, data);
 
-  if (set->error()) {
+  if (fbase().error().length() != 0) {
     out->print("-FAIL ");
-    out->println(set->error().message().c_str());
+    out->println(fbase().error().c_str());
     return false;
   } else {
     out->println("+OK");

contrib/src/modem/db/stream-command.cpp

@@ -13,27 +13,24 @@ bool StreamCommand::execute(const String& command,
     return false;
   }
 
-  std::string path = in->readLine().c_str();
-  std::unique_ptr<FirebaseStream> stream(fbase().streamPtr(path));
+  String path = in->readLine().c_str();
+  fbase().stream(path);  
 
-  if (stream->error()) {
+  if (fbase().error().length() != 0) {
     out->print("-FAIL ");
-    out->println(stream->error().message().c_str());
+    out->println(fbase().error().c_str());
     return false;
   }
-
   bool running = true;
   DynamicJsonBuffer buffer;
   while(running) {
-    if (stream->available()) {
-      std::string json;
-      FirebaseStream::Event event = stream->read(json);
+    if (fbase().available()) {
+      FirebaseObject event = fbase().readEvent();
       out->print("+");
-      out->print(FirebaseStream::EventToName(event).c_str());
+      out->print(event.getString("type").c_str());
       out->print(" ");
-      const auto& object = buffer.parseObject(json.c_str());
-      String data = object["data"].asString();
-      out->println(object["path"].asString());
+      String data = event.getString("data");
+      out->println(event.getString("path"));
       out->println(data.length());
       out->println(data);
     } else if (in->available()) {