Subversion Repositories HomeAutomation

Rev

Rev 1939 | Blame | Compare with Previous | Last modification | View Log | SVN | RSS feed

  1. /*
  2.  *
  3.  *  Copyright (C) 2010  Mattias Runge
  4.  *
  5.  *  This program is free software; you can redistribute it and/or modify
  6.  *  it under the terms of the GNU General Public License as published by
  7.  *  the Free Software Foundation; either version 2 of the License, or
  8.  *  (at your option) any later version.
  9.  *
  10.  *  This program is distributed in the hope that it will be useful,
  11.  *  but WITHOUT ANY WARRANTY; without even the implied warranty of
  12.  *  MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
  13.  *  GNU General Public License for more details.
  14.  *
  15.  *  You should have received a copy of the GNU General Public License along
  16.  *  with this program; if not, write to the Free Software Foundation, Inc.,
  17.  *  51 Franklin Street, Fifth Floor, Boston, MA 02110-1301 USA.
  18.  *
  19.  */
  20.  
  21. #include "Storage.h"
  22.  
  23. #include <boost/lexical_cast.hpp>
  24.  
  25. #include "storage/Manager.h"
  26. #include "storage/Store.h"
  27. #include "vm/Manager.h"
  28.  
  29. namespace atom {
  30. namespace vm {
  31. namespace plugin {
  32.  
  33. logging::Logger Storage::LOG("vm::plugin::storage");
  34.  
  35. Storage::Storage(boost::asio::io_service& io_service) : Plugin(io_service)
  36. {
  37.     this->name_ = "storage";
  38.  
  39.     this->ExportFunction("StorageExport_GetParameters", Storage::Export_GetParameters);
  40.     this->ExportFunction("StorageExport_GetParameter",  Storage::Export_GetParameter);
  41.     this->ExportFunction("StorageExport_SetParameter",  Storage::Export_SetParameter);
  42. }
  43.  
  44. Storage::~Storage()
  45. {
  46. }
  47.  
  48. void Storage::InitializeDone()
  49. {
  50.     Plugin::InitializeDone();
  51. }
  52.  
  53. void Storage::CallOutput(unsigned int request_id, std::string output)
  54. {
  55.     LOG.Info(output);
  56. }
  57.  
  58. Value Storage::Export_GetParameters(const v8::Arguments& args)
  59. {
  60.     v8::Locker lock;
  61.     v8::Context::Scope context_scope(vm::Manager::Instance()->GetContext());
  62.     v8::HandleScope handle_scope;
  63.  
  64.     //LOG.Debug(std::string(__FUNCTION__) + " called!");
  65.  
  66.     if (args.Length() < 1)
  67.     {
  68.         LOG.Error(std::string(__FUNCTION__) + ": To few arguments.");
  69.         return handle_scope.Close(v8::Boolean::New(false));
  70.     }
  71.  
  72.     v8::String::AsciiValue store_name(args[0]);
  73.  
  74.     storage::Store::ParameterList parameters = storage::Manager::Instance()->GetParameters(*store_name);
  75.  
  76.     v8::Local<v8::Array> params = v8::Array::New(parameters.size());
  77.  
  78.     for (storage::Store::ParameterList::iterator it = parameters.begin(); it != parameters.end(); it++)
  79.     {
  80.         //LOG.Debug(std::string(__FUNCTION__) + ": first=\"" + it->first.data() + "\", second=\"" + it->second.data() + "\"");
  81.         params->Set(v8::String::New(it->first.data()), v8::String::New(it->second.data()));
  82.     }
  83.  
  84.     return handle_scope.Close(params);
  85. }
  86.  
  87. Value Storage::Export_GetParameter(const v8::Arguments& args)
  88. {
  89.     v8::Locker lock;
  90.     v8::Context::Scope context_scope(vm::Manager::Instance()->GetContext());
  91.     v8::HandleScope handle_scope;
  92.  
  93.     //LOG.Debug(std::string(__FUNCTION__) + " called!");
  94.  
  95.     if (args.Length() < 2)
  96.     {
  97.         LOG.Error(std::string(__FUNCTION__) + ": To few arguments.");
  98.         return handle_scope.Close(v8::Boolean::New(false));
  99.     }
  100.  
  101.     v8::String::AsciiValue store_name(args[0]);
  102.     v8::String::AsciiValue parameter_name(args[1]);
  103.  
  104.     Value result;
  105.  
  106.     try
  107.     {
  108.         result = v8::String::New(storage::Manager::Instance()->GetParameter(*store_name, *parameter_name).data());
  109.     }
  110.     catch (std::runtime_error& e)
  111.     {
  112.         result = v8::Undefined();
  113.     }
  114.  
  115.     return handle_scope.Close(result);
  116. }
  117.  
  118. Value Storage::Export_SetParameter(const v8::Arguments& args)
  119. {
  120.     v8::Locker lock;
  121.     v8::Context::Scope context_scope(vm::Manager::Instance()->GetContext());
  122.     v8::HandleScope handle_scope;
  123.  
  124.     //LOG.Debug(std::string(__FUNCTION__) + " called!");
  125.  
  126.     if (args.Length() < 3)
  127.     {
  128.         LOG.Error(std::string(__FUNCTION__) + ": To few arguments.");
  129.         return handle_scope.Close(v8::Boolean::New(false));
  130.     }
  131.  
  132.     v8::String::AsciiValue store_name(args[0]);
  133.     v8::String::AsciiValue parameter_name(args[1]);
  134.     v8::String::AsciiValue parameter_value(args[2]);
  135.  
  136.     storage::Manager::Instance()->SetParameter(*store_name, *parameter_name, *parameter_value);
  137.  
  138.     return handle_scope.Close(v8::String::New("OK"));
  139. }
  140.  
  141. }; // namespace plugin
  142. }; // namespace vm
  143. }; // namespace atom
  144.