2 Copyright (C) 2012 Intel Corporation
4 This library is free software; you can redistribute it and/or
5 modify it under the terms of the GNU Lesser General Public
6 License as published by the Free Software Foundation; either
7 version 2.1 of the License, or (at your option) any later version.
9 This library is distributed in the hope that it will be useful,
10 but WITHOUT ANY WARRANTY; without even the implied warranty of
11 MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU
12 Lesser General Public License for more details.
14 You should have received a copy of the GNU Lesser General Public
15 License along with this library; if not, write to the Free Software
16 Foundation, Inc., 51 Franklin Street, Fifth Floor, Boston, MA 02110-1301 USA
20 #include "pluginloader.h"
23 #include <json-glib/json-glib.h>
27 /********************************************
28 * Example JSON config:
30 * sources: [ path1, path2, path3 ]
31 * sinks: [ path1, path2, path3 ]
34 **********************************************/
36 PluginLoader::PluginLoader(string configFile, AbstractRoutingEngine* re): f_create(NULL), routingEngine(re)
38 DebugOut()<<"Loading config file: "<<configFile<<endl;
40 JsonParser* parser = json_parser_new();
41 GError* error = nullptr;
42 if(!json_parser_load_from_file(parser, configFile.c_str(), &error))
44 DebugOut()<<"Failed to load config: "<<error->message;
45 throw std::runtime_error("Failed to load config");
48 JsonNode* node = json_parser_get_root(parser);
51 throw std::runtime_error("Unable to get JSON root object");
53 JsonReader* reader = json_reader_new(node);
56 throw std::runtime_error("Unable to create JSON reader");
58 DebugOut()<<"Config members: "<<json_reader_count_members(reader)<<endl;
60 gchar** members = json_reader_list_members(reader);
62 for(int i=0; i< json_reader_count_members(reader); i++)
64 cout<<"member: "<<members[i]<<endl;
67 json_reader_read_member(reader,"sources");
69 const GError * srcReadError = json_reader_get_error(reader);
71 if(srcReadError != nullptr)
73 DebugOut()<<"Error getting sources member: "<<srcReadError->message<<endl;
74 throw std::runtime_error("Error getting sources member");
77 g_assert(json_reader_is_array(reader));
80 for(int i=0; i < json_reader_count_elements(reader); i++)
82 json_reader_read_element(reader,i);
84 gchar** srcMembers = json_reader_list_members(reader);
86 std::map<std::string, std::string> configurationMap;
88 for(int i=0; i< json_reader_count_members(reader); i++)
90 json_reader_read_member(reader,srcMembers[i]);
91 configurationMap[srcMembers[i]] = json_reader_get_string_value(reader);
92 DebugOut()<<"plugin config key: "<<srcMembers[i]<<" value: "<<configurationMap[srcMembers[i]]<<endl;
93 json_reader_end_member(reader);
96 json_reader_read_member(reader, "path");
97 string path = json_reader_get_string_value(reader);
98 json_reader_end_member(reader);
100 AbstractSource* plugin = loadPlugin<AbstractSource*>(path,configurationMap);
102 if(plugin != nullptr)
104 mSources.push_back(plugin);
107 json_reader_end_element(reader);
110 json_reader_end_member(reader);
114 json_reader_read_member(reader,"sinks");
116 for(int i=0; i < json_reader_count_elements(reader); i++)
118 json_reader_read_element(reader,i);
120 gchar** srcMembers = json_reader_list_members(reader);
122 std::map<std::string, std::string> configurationMap;
124 for(int i=0; i< json_reader_count_members(reader); i++)
126 json_reader_read_member(reader,srcMembers[i]);
127 configurationMap[srcMembers[i]] = json_reader_get_string_value(reader);
128 json_reader_end_member(reader);
131 json_reader_read_member(reader, "path");
132 string path = json_reader_get_string_value(reader);
133 json_reader_end_member(reader);
135 AbstractSinkManager* plugin = loadPlugin<AbstractSinkManager*>(path, configurationMap);
137 if(plugin == nullptr)
139 throw std::runtime_error("plugin is not a SinkManager");
142 json_reader_end_element(reader);
145 json_reader_end_member(reader);
147 ///TODO: this will probably explode:
149 if(error) g_error_free(error);
151 g_object_unref(reader);
152 g_object_unref(parser);
156 PluginLoader::~PluginLoader()
158 for(auto itr = mSinks.begin(); itr != mSinks.end(); itr++)
163 for(auto itr = mSources.begin(); itr != mSources.end(); itr++)
169 SinkList PluginLoader::sinks()
174 SourceList PluginLoader::sources()
181 std::string PluginLoader::errorString()