Subversion Repositories HomeAutomation

Rev

Rev 1741 | Rev 1939 | Go to most recent revision | Details | Compare with Previous | Last modification | View Log | SVN | RSS feed

Rev Author Line No. Line
1619 runge 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 
 
1625 runge 35 
Storage::Storage(boost::asio::io_service& io_service) : Plugin(io_service)
1619 runge 36 
{
1898 runge 37 
    this->name_ = "storage";
1619 runge 38 
 
1644 runge 39 
    this->ExportFunction("StorageExport_GetParameters", Storage::Export_GetParameters);
40 
    this->ExportFunction("StorageExport_GetParameter",  Storage::Export_GetParameter);
41 
    this->ExportFunction("StorageExport_SetParameter",  Storage::Export_SetParameter);
1619 runge 42 
}
43 
 
44 
Storage::~Storage()
45 
{
46 
}
47 
 
48 
void Storage::InitializeDone()
49 
{
50 
    Plugin::InitializeDone();
51 
}
52 
 
1647 runge 53 
void Storage::CallOutput(unsigned int request_id, std::string output)
54 
{
55 
    LOG.Info(output);
56 
}
57 
 
1619 runge 58 
Value Storage::Export_GetParameters(const v8::Arguments& args)
59 
{
1740 runge 60 
    v8::Locker lock;
1619 runge 61 
    v8::Context::Scope context_scope(vm::Manager::Instance()->GetContext());
1741 runge 62 
    v8::HandleScope handle_scope;
1619 runge 63 
 
1647 runge 64 
    //LOG.Debug(std::string(__FUNCTION__) + " called!");
1619 runge 65 
 
66 
    if (args.Length() < 1)
67 
    {
1644 runge 68 
        LOG.Error(std::string(__FUNCTION__) + ": To few arguments.");
1741 runge 69 
        return handle_scope.Close(v8::Boolean::New(false));
1619 runge 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 
    {
1741 runge 80 
        LOG.Debug(std::string(__FUNCTION__) + ": first=\"" + it->first.data() + "\", second=\"" + it->second.data() + "\"");
1619 runge 81 
        params->Set(v8::String::New(it->first.data()), v8::String::New(it->second.data()));
82 
    }
83 
 
1741 runge 84 
    return handle_scope.Close(params);
1619 runge 85 
}
86 
 
87 
Value Storage::Export_GetParameter(const v8::Arguments& args)
88 
{
1740 runge 89 
    v8::Locker lock;
1625 runge 90 
    v8::Context::Scope context_scope(vm::Manager::Instance()->GetContext());
1741 runge 91 
    v8::HandleScope handle_scope;
1625 runge 92 
 
1647 runge 93 
    //LOG.Debug(std::string(__FUNCTION__) + " called!");
1619 runge 94 
 
95 
    if (args.Length() < 2)
96 
    {
1644 runge 97 
        LOG.Error(std::string(__FUNCTION__) + ": To few arguments.");
1741 runge 98 
        return handle_scope.Close(v8::Boolean::New(false));
1619 runge 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 
 
1741 runge 115 
    return handle_scope.Close(result);
1619 runge 116 
}
117 
 
118 
Value Storage::Export_SetParameter(const v8::Arguments& args)
119 
{
1740 runge 120 
    v8::Locker lock;
1625 runge 121 
    v8::Context::Scope context_scope(vm::Manager::Instance()->GetContext());
1741 runge 122 
    v8::HandleScope handle_scope;
1625 runge 123 
 
1647 runge 124 
    //LOG.Debug(std::string(__FUNCTION__) + " called!");
1619 runge 125 
 
126 
    if (args.Length() < 3)
127 
    {
1644 runge 128 
        LOG.Error(std::string(__FUNCTION__) + ": To few arguments.");
1741 runge 129 
        return handle_scope.Close(v8::Boolean::New(false));
1619 runge 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 
 
1741 runge 138 
    return handle_scope.Close(v8::String::New("OK"));
1619 runge 139 
}
140 
 
141 
}; // namespace plugin
142 
}; // namespace vm
143 
}; // namespace atom