Writable_Command_Processor.cpp

Go to the documentation of this file.

#include "joedb/ui/Writable_Command_Processor.h"
#include "joedb/ui/type_io.h"
#include "joedb/Writable.h"
 
#include <ctime>
 
namespace joedb
{
 ////////////////////////////////////////////////////////////////////////////
 Command_Processor::Status Writable_Command_Processor::process_command
 ////////////////////////////////////////////////////////////////////////////
 (
  const std::string &command,
  std::istream &parameters,
  std::istream &in,
  std::ostream &out
 )
 {
  if (command == "help") ////////////////////////////////////////////////////
  {
   out << R"RRR(Journal
~~~~~~~
 timestamp [<stamp>] (if no value is given, use current time)
 comment "<comment_string>"
 valid_data
 flush
 [soft_]checkpoint
 hard_checkpoint
 write_blob <data_string>
 
)RRR";
 
   return Status::ok;
  }
  else if (command == "comment") ///////////////////////////////////////////
  {
   const std::string comment = read_string(parameters);
   writable.comment(comment);
  }
  else if (command == "timestamp") /////////////////////////////////////////
  {
   int64_t timestamp = 0;
   parameters >> timestamp;
   if (parameters.fail())
    timestamp = std::time(nullptr);
   writable.timestamp(timestamp);
  }
  else if (command == "valid_data") ////////////////////////////////////////
  {
   writable.valid_data();
  }
  else if (command == "flush") /////////////////////////////////////////////
  {
   writable.flush();
  }
  else if (command == "soft_checkpoint" || command == "checkpoint") ////////
  {
   writable.soft_checkpoint();
  }
  else if (command == "hard_checkpoint") ///////////////////////////////////
  {
   writable.hard_checkpoint();
  }
  else if (command == "write_blob") ////////////////////////////////////////
  {
   const std::string value = read_string(parameters);
   const Blob blob = blob_writer.write_blob(value);
   write_blob(out, blob);
   out << '\n';
  }
  else
   return Status::not_found;
 
  return Status::done;
 }
}