backend.h

#ifndef BACKEND_H
#define BACKEND_H

#include <QtCore>
#include <QtNetwork/QTcpSocket>

#include <google/protobuf/io/coded_stream.h>
#include <google/protobuf/io/zero_copy_stream_impl_lite.h>

#include <google/protobuf/text_format.h>

#include "hello.pb.h"
#include "indigoqueue.h"

#include <QGeoPositionInfo>
#include <QGeoPositionInfoSource>
#include <QGeoSatelliteInfoSource>

//#include "qnmeapositioninfosource.h"

#include <QObject>

#ifndef UNDER_ANDROID
#include <QtSerialPort/QSerialPort>
#include <QtSerialPort/QSerialPortInfo>
#endif

#include "taxiorder.h"

class Backend : public QObject
{
	Q_OBJECT

public:
	Backend(QObject *parent);
	~Backend();
	void setDriverName(int _driverName);
	int getDriverName() { return driverName; }
    void setTaxiId(int _taxiId);
    int getTaxiId() { return taxiId;};

signals:
	// передаётся по значению
	void protobuf_message(hello message);
	void connectedToServer(bool status);
	void driverNameChanged(int driverName);
    void taxiOrgChanged(int taxiId);

	void newPosition(QGeoCoordinate coordinate);
	void newSpeed(int speed_kmh);
	void newSatellitesUsed(int satellitesUsed);
	// 0 == stop, 1 == start
	void movementStart(int start);
	
public slots:
	// from gps
	void positionUpdated(const QGeoPositionInfo &update);
    void satellitesInUseUpdated(const QList<QGeoSatelliteInfo> & satelliteInfo);

	void sendMessageQueued(hello var);
	void sendEvent(hello_TaxiEvent event);
	void sendOrderEvent(hello_TaxiEvent event, ITaxiOrder *order);

	// from timer
	void sendLocationData();
	
	void readyRead();
	void connected();
	void error(QAbstractSocket::SocketError &error);
	void disconnected();
	void reconnect();
	void flushOrderEvents();

	
	void send_message(hello &var);

private:
	QSettings *settingsIniFile;
	void consumeSocketData();

	IndigoOrderQueue orderEventsQueue;

	QTcpSocket *socket;
	QMutex socketMutex;
	IndigoQueue receiveBuffer;

	enum receive_state_t
	{
		NOTHING = 0,
		MESSAGE_RECEIVING, // -> NOTHING
	};

	receive_state_t receive_state;
	int index;
	google::protobuf::uint8 message_buffer[2048];
	google::protobuf::uint32 message_length;
	const google::protobuf::uint8 *message_start;
	int remainder;

	int driverName;
	int taxiId;

	QTimer *gpsTimer;
    QGeoPositionInfoSource *positionSource;
	hello positionMessage;

    QIODevice *gpsSerialPort;
	
	void detectStartStop(int speed);
};

#endif // BACKEND_H