99 lines
2.5 KiB
C++
99 lines
2.5 KiB
C++
//
|
|
// Copyright (C) 2012 Telldus Technologies AB. All rights reserved.
|
|
//
|
|
// Copyright: See COPYING file that comes with this distribution
|
|
//
|
|
//
|
|
#define _CRT_RAND_S
|
|
#include "service/Controller.h"
|
|
#include <stdlib.h>
|
|
#include <time.h>
|
|
#include <map>
|
|
#include <list>
|
|
#include <string>
|
|
#include "service/Protocol.h"
|
|
#include "service/EventUpdateManager.h"
|
|
#include "common/Strings.h"
|
|
|
|
inline int random( unsigned int* seed ) {
|
|
#ifdef _WINDOWS
|
|
unsigned int randomNumber;
|
|
rand_s( &randomNumber ); // no seed needed
|
|
return randomNumber;
|
|
#else
|
|
return rand_r( seed );
|
|
#endif
|
|
}
|
|
|
|
class Controller::PrivateData {
|
|
public:
|
|
TelldusCore::EventRef event, updateEvent;
|
|
int id, firmwareVersion;
|
|
unsigned int randSeed;
|
|
std::map<std::string, time_t> duplicates;
|
|
};
|
|
|
|
Controller::Controller(int id, TelldusCore::EventRef event, TelldusCore::EventRef updateEvent) {
|
|
d = new PrivateData;
|
|
d->event = event;
|
|
d->updateEvent = updateEvent;
|
|
d->id = id;
|
|
d->firmwareVersion = 0;
|
|
d->randSeed = time(NULL);
|
|
}
|
|
|
|
Controller::~Controller() {
|
|
delete d;
|
|
}
|
|
|
|
void Controller::publishData(const std::string &msg) const {
|
|
ControllerEventData *data = new ControllerEventData;
|
|
data->msg = msg;
|
|
data->controllerId = d->id;
|
|
d->event->signal(data);
|
|
}
|
|
|
|
void Controller::decodePublishData(const std::string &data) const {
|
|
// Garbange collect?
|
|
if (random(&d->randSeed) % 1000 == 1) {
|
|
time_t t = time(NULL);
|
|
// Standard associative-container erase idiom
|
|
for (std::map<std::string, time_t>::iterator it = d->duplicates.begin(); it != d->duplicates.end(); /* no increment */) {
|
|
if ((*it).second != t) {
|
|
d->duplicates.erase(it++);
|
|
} else {
|
|
++it;
|
|
}
|
|
}
|
|
}
|
|
// Duplicate check
|
|
if (d->duplicates.count(data) > 0) {
|
|
time_t t = d->duplicates[data];
|
|
if (t == time(NULL)) {
|
|
// Duplicate message
|
|
return;
|
|
}
|
|
}
|
|
d->duplicates[data] = time(NULL);
|
|
|
|
std::list<std::string> msgList = Protocol::decodeData(data);
|
|
|
|
for (std::list<std::string>::iterator msgIt = msgList.begin(); msgIt != msgList.end(); ++msgIt) {
|
|
this->publishData(*msgIt);
|
|
}
|
|
}
|
|
|
|
int Controller::firmwareVersion() const {
|
|
return d->firmwareVersion;
|
|
}
|
|
|
|
void Controller::setFirmwareVersion(int version) {
|
|
d->firmwareVersion = version;
|
|
EventUpdateData *eventData = new EventUpdateData();
|
|
eventData->messageType = L"TDControllerEvent";
|
|
eventData->controllerId = d->id;
|
|
eventData->eventState = TELLSTICK_DEVICE_CHANGED;
|
|
eventData->eventChangeType = TELLSTICK_CHANGE_FIRMWARE;
|
|
eventData->eventValue = TelldusCore::intToWstring(version);
|
|
d->updateEvent->signal(eventData);
|
|
}
|