From 47ada94baa424e56d2ded256fddc91e6aa4d3090 Mon Sep 17 00:00:00 2001
From: "Javier S. Pedro" <maemo@javispedro.com>
Date: Tue, 3 Dec 2013 03:05:47 +0100
Subject: initial import

---
 gatoatt.h | 97 +++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++
 1 file changed, 97 insertions(+)
 create mode 100644 gatoatt.h

(limited to 'gatoatt.h')

diff --git a/gatoatt.h b/gatoatt.h
new file mode 100644
index 0000000..27cea3e
--- /dev/null
+++ b/gatoatt.h
@@ -0,0 +1,97 @@
+#ifndef GATOATTSOCKET_H
+#define GATOATTSOCKET_H
+
+#include <QtCore/QObject>
+#include <QtCore/QQueue>
+#include "gatosocket.h"
+#include "gatouuid.h"
+
+class GatoAtt : public QObject
+{
+	Q_OBJECT
+
+public:
+	explicit GatoAtt(QObject *parent = 0);
+	~GatoAtt();
+
+	GatoSocket::State state() const;
+
+	bool connectTo(const GatoAddress& addr);
+	void close();
+
+	struct InformationData
+	{
+		GatoHandle handle;
+		GatoUUID uuid;
+	};
+	struct HandleInformation
+	{
+		GatoHandle start;
+		GatoHandle end;
+	};
+	struct AttributeData
+	{
+		GatoHandle handle;
+		QByteArray value;
+	};
+	struct AttributeGroupData
+	{
+		GatoHandle start;
+		GatoHandle end;
+		QByteArray value;
+	};
+
+	uint request(int opcode, const QByteArray &data, QObject *receiver, const char *member);
+	uint requestExchangeMTU(quint8 client_mtu, QObject *receiver, const char *member);
+	uint requestFindInformation(GatoHandle start, GatoHandle end, QObject *receiver, const char *member);
+	uint requestFindByTypeValue(GatoHandle start, GatoHandle end, const GatoUUID &uuid, const QByteArray& value, QObject *receiver, const char *member);
+	uint requestReadByType(GatoHandle start, GatoHandle end, const GatoUUID &uuid, QObject *receiver, const char *member);
+	uint requestRead(GatoHandle handle, QObject *receiver, const char *member);
+	uint requestReadByGroupType(GatoHandle start, GatoHandle end, const GatoUUID &uuid, QObject *receiver, const char *member);
+	uint requestWrite(GatoHandle handle, const QByteArray &value, QObject *receiver, const char *member);
+	void cancelRequest(uint id);
+
+	void command(int opcode, const QByteArray &data);
+
+signals:
+	void connected();
+	void disconnected();
+
+	void attributeUpdated(GatoHandle handle, const QByteArray &value, bool confirmed);
+
+private:
+	struct Request
+	{
+		uint id;
+		quint8 opcode;
+		QByteArray pkt;
+		QObject *receiver;
+		QByteArray member;
+	};
+
+	void sendARequest();
+	bool handleEvent(const QByteArray &event);
+	bool handleResponse(const Request& req, const QByteArray &response);
+
+	void writeUuid16or128(QDataStream& s, const GatoUUID& uuid);
+
+	QList<InformationData> parseInformationData(const QByteArray &data);
+	QList<HandleInformation> parseHandleInformation(const QByteArray &data);
+	QList<AttributeData> parseAttributeData(const QByteArray &data);
+	QList<AttributeGroupData> parseAttributeGroupData(const QByteArray &data);
+
+private slots:
+	void handleSocketConnected();
+	void handleSocketDisconnected();
+	void handleSocketReadyRead();
+
+	void handleServerMTU(uint req, quint8 server_mtu);
+
+private:
+	GatoSocket *socket;
+	quint8 mtu;
+	uint next_id;
+	QQueue<Request> pending_requests;
+};
+
+#endif // GATOATTSOCKET_H
-- 
cgit v1.2.3