1 files changed, 77 insertions, 0 deletions
diff --git a/sap/sappeer.h b/sap/sappeer.h
new file mode 100644
index 0000000..1c477c4
--- /dev/null
+++ b/sap/sappeer.h
@@ -0,0 +1,77 @@
+#ifndef SAPPEER_H
+#define SAPPEER_H
+
+#include <QtCore/QObject>
+#include <QtCore/QQueue>
+
+#include "saprotocol.h"
+#include "sapserviceinfo.h"
+
+class WMSPeer;
+class CapabilityPeer;
+class SAPConnection;
+class SAPConnectionRequest;
+class SAPSocket;
+class SAPAgent;
+
+class SAPPeer : public QObject
+{
+	Q_OBJECT
+public:
+	explicit SAPPeer(SAProtocol::Role role, const QString &localName, const QString &peerName, QObject *parent = 0);
+	~SAPPeer();
+
+	SAPConnection* createServiceConnection(const QString &profile, const QString &requesterProfile, SAPServiceInfo::Role requesterRole);
+	bool terminateServiceConnection(const QString &profile, const QString &requesterProfile, SAPServiceInfo::Role requesterRole);
+
+	SAProtocol::Role role() const;
+	QString localName() const;
+	QString peerName() const;
+
+signals:
+	void connected();
+	void disconnected();
+
+protected:
+	/** Transmits a frame to the underlying transport. */
+	virtual void sendFrame(const QByteArray &data) = 0;
+
+	CapabilityPeer *capabilityPeer();
+
+	/** Writes data to the remote. */
+	void writeDataToSession(int session, const QByteArray &data);
+	/** Writes a control frame to the remote. */
+	void writeControlToSession(int session, const QByteArray &control);
+
+	void acceptServiceConnection(SAPConnectionRequest *connReq, int statusCode);
+
+	/** Distributes data to the appropiate socket. */
+	void handleSessionData(int session, const QByteArray &data);
+
+	/** Distributes a control message to the apropiate socket. */
+	void handleSessionControl(int session, const QByteArray &data);
+
+	/** Perform service discovery once connected. */
+	void handleConnected();
+	void handleDisconnected();
+
+private:
+	int findUnusedSessionId() const;
+	void handleDefaultSessionMessage(const QByteArray &message);
+
+protected:
+	WMSPeer *_wms;
+
+private:
+	const SAProtocol::Role _role;
+	const QString _localName;
+	const QString _peerName;
+
+	QMap<QString, SAPConnection*> _conns;
+	QMap<int, SAPSocket*> _sessions;
+
+	friend class SAPSocket;
+	friend class SAPConnectionRequest;
+};
+
+#endif // SAPPEER_H