1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
|
#include "propertyproxy.h"
#include "sconnect.h"
#include "contextproperty.h"
#include "contextpropertyinfo.h"
#include "property.h"
#include "logging.h"
PropertyProxy::PropertyProxy(QString key, bool enabled, QObject *parent) :
QObject(parent), enabled(enabled)
{
provider = new ContextProvider::Property(key, this);
subscriber = new ContextProperty(key, this);
subscriber->unsubscribe();
sconnect(provider, SIGNAL(firstSubscriberAppeared(QString)),
this, SLOT(onFirstSubscriber(QString)));
sconnect(provider, SIGNAL(lastSubscriberDisappeared(QString)),
this, SLOT(onLastSubscriber()));
sconnect(subscriber, SIGNAL(valueChanged()),
this, SLOT(onValueChanged()));
enable(enabled);
}
void PropertyProxy::enable(bool enable)
{
qDebug() << (const char *)(enable ? "enabled" : "disabled") <<
"proxying" << provider->key();
enabled = enable;
if (enable)
provider->setValue(value);
}
QVariant PropertyProxy::realValue() const
{
return value;
}
QString PropertyProxy::type() const
{
return subscriber->info()->type();
}
void PropertyProxy::onFirstSubscriber(const QString &key)
{
contextDebug() << "First client subscription received, commander subscribes to provider" << subscriber->key();
subscriber->subscribe();
}
void PropertyProxy::onLastSubscriber()
{
contextDebug() << "Last client unsubscribed, commander unsubscribes from provider" << subscriber->key();
subscriber->unsubscribe();
}
void PropertyProxy::onValueChanged()
{
value = subscriber->value();
if (enabled)
provider->setValue(value);
QTextStream out(stdout);
out << "real: " << type() << " " << subscriber->key();
if (realValue().isNull())
out << " is Unknown" << endl;
else
out << " = " << realValue().toString() << endl;
out.flush();
}
|
