diff options
| -rw-r--r-- | liveview/liveview.cpp | 194 | ||||
| -rw-r--r-- | liveview/liveview.h | 75 |
2 files changed, 226 insertions, 43 deletions
diff --git a/liveview/liveview.cpp b/liveview/liveview.cpp index bd0cdbe..f4b7434 100644 --- a/liveview/liveview.cpp +++ b/liveview/liveview.cpp @@ -1,13 +1,19 @@ +#include <QtEndian> + #include "liveview.h" using namespace sowatch; QTM_USE_NAMESPACE +#define PROTOCOL_DEBUG 1 + LiveView::LiveView(ConfigKey* settings, QObject* parent) : BluetoothWatch(QBluetoothAddress(settings->value("address").toString()), parent), - _settings(settings->getSubkey(QString(), this)) + _settings(settings->getSubkey(QString(), this)), + _sendTimer(new QTimer(this)) { - + _sendTimer->setInterval(DelayBetweenMessages); + connect(_sendTimer, SIGNAL(timeout()), SLOT(handleSendTimerTick())); } LiveView::~LiveView() @@ -35,11 +41,6 @@ QStringList LiveView::buttons() const return QStringList(); } -bool LiveView::isConnected() const -{ - return false; -} - bool LiveView::busy() const { return false; // TODO @@ -47,15 +48,20 @@ bool LiveView::busy() const void LiveView::setDateTime(const QDateTime& dateTime) { - + // It seems LiveView _requests_ the current date rather than expecting + // the phone to be sending it. + // Wonder what will happen during DST changes? + // Do nothing here. } + void LiveView::queryDateTime() { - + // LiveView does not support this. } + QDateTime LiveView::dateTime() const { - return QDateTime::currentDateTime(); // TODO + return QDateTime::currentDateTime(); } void LiveView::queryBatteryLevel() @@ -99,10 +105,176 @@ void LiveView::vibrate(int msecs) void LiveView::setupBluetoothWatch() { - + connect(_socket, SIGNAL(readyRead()), SLOT(handleDataReceived())); + updateDisplayProperties(); } void LiveView::desetupBluetoothWatch() { } + +void LiveView::send(const Message &msg) +{ + _sendingMsgs.enqueue(msg); + if (!_sendTimer->isActive()) { + _sendTimer->start(); + } +} + +void LiveView::updateDisplayProperties() +{ + static const char *software_version = "0.0.3"; + + send(Message(GetDisplayProperties, + QByteArray(software_version, strlen(software_version) + 1))); +} + +void LiveView::updateSoftwareVersion() +{ + send(Message(GetSoftwareVersion, QByteArray(1, 0))); +} + +void LiveView::enableLed() +{ + QByteArray data; + data.append(char(0xFF)); + data.append(char(0xFF)); + data.append(char(0x00)); + data.append(char(0x64)); + data.append(char(0x00)); + data.append(char(0xFA)); + + send(Message(EnableLed, data)); +} + +void LiveView::handleMessage(const Message &msg) +{ + send(Message(Ack, QByteArray(1, msg.type))); + switch (msg.type) { + case GetDisplayPropertiesResponse: + handleDisplayProperties(msg); + break; + } +} + +void LiveView::handleDisplayProperties(const Message &msg) +{ + updateSoftwareVersion(); +} + +void LiveView::handleDataReceived() +{ +#pragma pack(push) +#pragma pack(1) + static const int HEADER_SIZE = 6; + union header_t { + char c[HEADER_SIZE]; + struct header_fields_t { + quint8 msg_type; + quint8 header_len; + quint32 data_len; + } h; + } header; +#pragma pack(pop) + + Q_ASSERT(sizeof(header) == HEADER_SIZE); + + do { + qint64 dataRead; + + qDebug() << "received" << _socket->bytesAvailable() << "bytes"; + + if (_receivingMsg.type == NoMessage) { + /* Still not received even the packet type */ + /* Receive the full header. */ + if (_socket->bytesAvailable() < HEADER_SIZE) { + /* Still not enough data available. */ + return; /* Wait for more, if non blocking. */ + } + + dataRead = _socket->read(header.c, HEADER_SIZE); +#if PROTOCOL_DEBUG + qDebug() << "received header" << QByteArray(header.c, HEADER_SIZE).toHex(); +#endif + if (dataRead < HEADER_SIZE) { + qWarning() << "Short read"; + return; + } + + _receivingMsg.type = static_cast<MessageType>(header.h.msg_type); + if (header.h.header_len != HEADER_SIZE - 2) { + qWarning() << "Unexpected header length:" << header.h.header_len; + } + + unsigned long data_size = qFromBigEndian(header.h.data_len); + if (data_size > 1048576) { + // If input packet is > 1 MiB, consider a protocol error. + qWarning() << "Too large data size: " << data_size; + data_size = 0; + } + _receivingMsg.data.resize(data_size); + + qDebug() << "got header (type=" << _receivingMsg.type << + "size=" << data_size << ")"; + } + + /* We have the header; now, try to get the complete packet. */ + if (_socket->bytesAvailable() < _receivingMsg.data.size()) { +#if PROTOCOL_DEBUG + qDebug() << "Waiting for more data" << _socket->bytesAvailable() << "/" << _receivingMsg.data.size(); +#endif + return; /* Wait for more. */ + } + + dataRead = _socket->read(_receivingMsg.data.data(), _receivingMsg.data.size()); + if (dataRead < _receivingMsg.data.size()) { + qWarning() << "Short read"; + return; + } + +#if PROTOCOL_DEBUG + qDebug() << "received" << _receivingMsg.type << _receivingMsg.data.toHex(); +#endif + handleMessage(_receivingMsg); + + // Prepare for the next packet + _receivingMsg.data.clear(); + _receivingMsg.type = NoMessage; + } while (_socket->bytesAvailable() > 0); +} + +void LiveView::handleSendTimerTick() +{ + static const int HEADER_SIZE = 6; + qDebug() << "Send tick"; + // If there are packets to be sent... + if (!_sendingMsgs.empty()) { + // Send a message to the watch + Message msg = _sendingMsgs.dequeue(); + const quint32 data_size = msg.data.size(); + QByteArray packet; + + Q_ASSERT(_connected && _socket); + + packet.resize(HEADER_SIZE + data_size); + packet[0] = msg.type; + packet[1] = HEADER_SIZE - 2; + packet[2] = (data_size & 0xFF000000U) >> 24; + packet[3] = (data_size & 0x00FF0000U) >> 16; + packet[4] = (data_size & 0x0000FF00U) >> 8; + packet[5] = (data_size & 0x000000FFU); + packet.replace(HEADER_SIZE, data_size, msg.data); + +#if PROTOCOL_DEBUG + qDebug() << "sending" << packet.toHex(); +#endif + + _socket->write(packet); + } + // If we just finished sending all packets... + if (_sendingMsgs.empty()) { + // Stop the send timer to save battery + _sendTimer->stop(); + } +} diff --git a/liveview/liveview.h b/liveview/liveview.h index 03c5499..69016b5 100644 --- a/liveview/liveview.h +++ b/liveview/liveview.h @@ -1,34 +1,3 @@ -/** - -This file is partially based on the work from Andrew de Quincey: - - Copyright (c) 2011, Andrew de Quincey - All rights reserved. - - Redistribution and use in source and binary forms, with or without - modification, are permitted provided that the following conditions are met: - * Redistributions of source code must retain the above copyright - notice, this list of conditions and the following disclaimer. - * Redistributions in binary form must reproduce the above copyright - notice, this list of conditions and the following disclaimer in the - documentation and/or other materials provided with the distribution. - * Neither the name of the organization nor the - names of its contributors may be used to endorse or promote products - derived from this software without specific prior written permission. - - THIS SOFTWARE IS PROVIDED BY THE COPYRIGHT HOLDERS AND CONTRIBUTORS "AS IS" AND - ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE IMPLIED - WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE ARE - DISCLAIMED. IN NO EVENT SHALL <COPYRIGHT HOLDER> BE LIABLE FOR ANY - DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES - (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES; - LOSS OF USE, DATA, OR PROFITS; OR BUSINESS INTERRUPTION) HOWEVER CAUSED AND - ON ANY THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT - (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT OF THE USE OF THIS - SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE. - -*/ - #ifndef LIVEVIEW_H #define LIVEVIEW_H @@ -51,7 +20,7 @@ public: QString model() const; QStringList buttons() const; - bool isConnected() const; + bool busy() const; void setDateTime(const QDateTime& dateTime); @@ -71,11 +40,53 @@ public: void vibrate(int msecs); protected: + static const int DelayBetweenMessages = 5; + + enum MessageType { + NoMessage = 0, + GetDisplayProperties = 1, + GetDisplayPropertiesResponse = 2, + StandBy = 7, + StandByResponse = 8, + EnableLed = 40, + EnableLedResponse = 41, + Ack = 44, + GetSoftwareVersion = 68, + GetSoftwareVersionResponse = 69 + }; + + struct Message { + MessageType type; + QByteArray data; + Message(MessageType ntype = NoMessage, QByteArray ndata = QByteArray()) : + type(ntype), data(ndata) + { } + }; + void setupBluetoothWatch(); void desetupBluetoothWatch(); + void send(const Message& msg); + + void updateDisplayProperties(); + void updateSoftwareVersion(); + void enableLed(); + + void handleMessage(const Message& msg); + void handleDisplayProperties(const Message& msg); + +private slots: + void handleDataReceived(); + void handleSendTimerTick(); + private: ConfigKey *_settings; + + /** Message outbox queue. */ + QQueue<Message> _sendingMsgs; + QTimer* _sendTimer; + /** Incomplete message that is being received. */ + Message _receivingMsg; }; } |