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
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
|
#include <QSettings>
#include <QDBusInterface>
#include <QDBusConnection>
#include <QDateTime>
#include <QFile>
#include <QTextStream>
#include <QStandardPaths>
#include <QTimer>
#include <QDebug>
#include "logger.h"
#include "sensorPlugins/stepCounter.h"
#include "sensorPlugins/heartrateSensor.h"
Logger::Logger(QObject *parent) :
QObject(parent){
m_iface = new QDBusInterface("com.nokia.mce","/com/nokia/mce/signal", "com.nokia.mce.signal", QDBusConnection::systemBus());
QSettings settings;
//intialise HRM
if (heartrateSensorEnabled) { //add check for HRM
m_heartrateSensor = new HeartrateSensorPlugin(this,settings.value("stepsInterval",600000).toInt());
}
//initialise step counter
if (stepCounterEnabled) { //add check for step sensor
m_stepCounter = new StepCounterPlugin(this,settings.value("stepsInterval",600000).toInt());
}
if(!m_iface->isValid()) {
qDebug() << "interface is not valid";
qDebug() << m_iface->lastError();
}
if(connect(m_iface, SIGNAL(display_status_ind(QString)), this, SLOT(displayOn(QString)))) { //this fires when the display turns on
qDebug() << "healthd connected display_status signal to slot";
}
qDebug() << "healthd sensors logger initialised";
}
void Logger::displayOn(QString displayState) {
if (displayState == "off")
return;
qDebug() << "display on detected";
uint currTime = QDateTime::currentMSecsSinceEpoch();
if (heartrateSensorEnabled) {
m_heartrateSensor->timeUpdate();
}
if (stepCounterEnabled) {
m_stepCounter->timeUpdate();
}
}
void fileAddRecord(QString sensorPrefix, QString logdata, QDateTime recordTime) { //adds a record to today's log file for the given sensor
qDebug() << fileNameForDate(recordTime.date(), sensorPrefix);
QFile file(fileNameForDate(recordTime.date(), sensorPrefix));
if (!file.open(QIODevice::ReadWrite | QIODevice::Text)) {
qDebug() << "failed to open file";
return;
}
file.seek(file.size());
QTextStream out(&file);
out << QString::number(recordTime.currentSecsSinceEpoch()) + ":" + logdata + "\n";
file.close();
}
bool dayFileExists(QString sensorPrefix, QDateTime dateTime) {
return QFile::exists(fileNameForDate(dateTime.date(), sensorPrefix));
}
QStringList fileGetPrevRecord(QString sensorPrefix, QDateTime recordTime) {
qDebug() << fileNameForDate(recordTime.date(), sensorPrefix);
QFile file(fileNameForDate(recordTime.date(), sensorPrefix));
if (!file.open(QIODevice::ReadWrite | QIODevice::Text)) {
qDebug() << "failed to open file";
return {0,0};
}
QTextStream inStream(&file);
QString line;
int i;
while(!inStream.atEnd())
{
line = inStream.readLine();
qDebug() << line;
i++;
}
file.close();
return line.split(":");
}
QString fileNameForDate(QDate date, QString prefix) {
return QStandardPaths::writableLocation(QStandardPaths::HomeLocation) + "/asteroid-healthloggerd/" + prefix + "/" + date.toString("yyyy-MM-dd.log");
}
|
