implemented new abstractrouting things in core
[profile/ivi/automotive-message-broker.git] / ambd / core.h
1 /*
2     Copyright (C) 2012  Intel Corporation
3
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.
8
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.
13
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
17 */
18
19
20 #ifndef CORE_H
21 #define CORE_H
22
23 #include "abstractsink.h"
24 #include "abstractsource.h"
25 #include "abstractroutingengine.h"
26
27 #include <map>
28
29 class Core: public AbstractRoutingEngine
30 {
31         
32 public:
33         Core();
34         
35         /// sources:
36
37         void setSupported(PropertyList supported, AbstractSource* source);
38         void updateSupported(PropertyList added, PropertyList removed);
39         void updateProperty(VehicleProperty::Property property, AbstractPropertyType* value, string uuid);
40         
41         /// sinks:
42
43         std::list<std::string> sourcesForProperty(VehicleProperty::Property property);
44         
45         void registerSink(AbstractSink *self);
46         void unregisterSink(AbstractSink *self);
47         AsyncPropertyReply* getPropertyAsync(AsyncPropertyRequest request);
48         AsyncRangePropertyReply* getRangePropertyAsync(AsyncRangePropertyRequest request);
49         AsyncPropertyReply * setProperty(AsyncSetPropertyRequest request);
50         void subscribeToProperty(VehicleProperty::Property, AbstractSink* self);
51         void subscribeToProperty(VehicleProperty::Property, std::string sourceUuidFilter, AbstractSink *self);
52         void unsubscribeToProperty(VehicleProperty::Property, AbstractSink* self);
53         PropertyList supported() { return mMasterPropertyList; }
54
55         PropertyInfo getPropertyInfo(VehicleProperty::Property, std::string sourceUuid);
56         std::list<std::string> getSourcesForProperty(VehicleProperty::Property property);
57     
58         ~Core();
59         
60 private:
61         PropertyList mMasterPropertyList;
62         
63         SourceList mSources;
64         SinkList mSinks;
65
66         int propertiesPerSecond;
67         
68         std::map<VehicleProperty::Property, SinkList> propertySinkMap;
69
70         std::map<AbstractSink*, std::string> filteredSourceSinkMap;
71
72         std::map<VehicleProperty::Property, std::string> previousValueMap;
73     
74 };
75
76 #endif // CORE_H