2.1-RemoteHealthcare/Proftaak Remote Healthcare/FietsClientV2/DataHandler.cs

using System;
using System.Collections.Generic;
using System.IO.Ports;
using System.Linq;
using System.Text;
using System.Threading.Tasks;

namespace FietsClientV2
{

    //alle data die ontvagen wordt van de fiets gaat als eerst door de DataHandler klasse heen voordat hij verwerkt wordt door de model klasse.
    // TLDR: ontvangt fiets data 

    class DataHandler
    {
        // vaste waarden
        public static readonly string COMMAND = "CU";
        public static readonly string CMD_TIME = "PT";
        public static readonly string CMD_DISTANCE = "PD";
        public static readonly string CMD_POWER = "PW";
        public static readonly string CMD_ENERGY = "PE";
        public static readonly string RESET = "RS";
        public static readonly string STATUS = "ST";

        // private fields
        private string portname;
        private int baudrate = 9600;
        private string bufferOut;
        private string[] bufferIn;

        // public fields
        public enum State { notConnected, connected, reset, command }
        public enum ReturnData { ERROR, ACK, RUN, STATUS }

        public State state = State.notConnected;
        public ReturnData returnData;

        private SerialPort ComPort;

        // custom events
        public delegate void DataDelegate(string[] data);
        public static event DataDelegate IncomingDataEvent;

        public delegate void DebugDelegate(string debugData);
        public static event DebugDelegate IncomingDebugLineEvent;

        public DataHandler()
        {

        }

        private static void OnIncomingDataEvent(string[] data)
        {
            DataDelegate handler = IncomingDataEvent;
            if (handler != null) handler(data);
        }

        public static void OnIncomingDebugLineEvent(string debugData)
        {
            DebugDelegate handler = IncomingDebugLineEvent;
            if (handler != null) handler(debugData);
        }

        public void initComm(string portname)
        {
            this.portname = portname;
            if (ComPort.IsOpen)
                ComPort.Close();

            try
            {
                ComPort = new SerialPort(this.portname, this.baudrate);
                ComPort.Open();
                ComPort.WriteLine(RESET);
                ComPort.DataReceived += new SerialDataReceivedEventHandler(ComPort_DataReceived);
            }
            catch (Exception)
            {
                OnIncomingDebugLineEvent("ERROR: Exception throwed");
                try { ComPort.Close(); } catch (Exception) { } // probeer om de ComPort wel te sluiten.
            }


        }

        public void closeComm()
        {
            ComPort.Close();
        }

        public void sendData(string data)
        {
            bufferOut = data;
            ComPort.WriteLine(data);
        }

        private void ComPort_DataReceived(object sender, SerialDataReceivedEventArgs e)
        {
            string buffer = ComPort.ReadLine();
            switch (buffer) //kijk wat er binnenkomt
            {
                case "ERROR": //wanneer "Error"
                    returnData = ReturnData.ERROR;
                    handleError();
                    break;
                case "ACK": // ACK betekent acknowledged.
                    returnData = ReturnData.ACK;
                    break;
                case "RUN":
                    returnData = ReturnData.RUN;
                    break;
                default:    // alle andere waarden.
                    returnData = ReturnData.STATUS;
                    handleBikeValues(buffer);
                    break;
            }
        }

        private void handleError()
        {
            for (int i = 0; i < 3; i++)
                if (bufferOut == "RS")
                    sendData("RS");  //gewoon nog een keer proberen tot 3 keer toe, net zolang totdat hij werkt.
        }

        private void handleBikeValues(string buffer)
        {
            buffer = buffer.TrimEnd('\r');
            Console.WriteLine(buffer);
            bufferIn = buffer.Split('\t');
            OnIncomingDataEvent(bufferIn);
        }

        private bool checkBikeState()
        {
            switch (state)
            {
                case State.reset:
                    setCommandMode();
                    if (returnData != ReturnData.ERROR)
                        return true;
                    return false;
                case State.connected:
                    setCommandMode();
                    return true;
                case State.command:
                    return true;
                case State.notConnected:
                    Console.WriteLine("ERROR: not connected to bike.");
                    return false;
                default:
                    return false;
            }
        }

        public void setCommandMode()
        {
            sendData(COMMAND);
        }

        public void setTime()
        {
            if (!checkBikeState())
                return;
            sendData(CMD_TIME);
        }

        public void setDistance()
        {
            if (!checkBikeState())
                return;
            sendData(CMD_DISTANCE);
        }

        public void setPower()
        {
            if (!checkBikeState())
                return;
            sendData(CMD_POWER);
        }

        public void setEnergy()
        {
            if (!checkBikeState())
                return;
            sendData(CMD_ENERGY);
        }
    }
}