@startuml Class_Overview

title Leahi Real-time CDT — Class Overview

skinparam classAttributeIconSize 0
skinparam class {
    BackgroundColor<<generated>> LightYellow
    BackgroundColor<<tool>> LightCyan
}

package "CloudConnect (process)" {
    class CloudConnectController {
        -_settings: QSettings
        -_canInterface: Can::CanInterface
        -_canThread: QThread
        -_dispatcher: Can::MessageDispatcher
        -_msgHandling: QHash<Can::MsgId, MsgHandling>
        -_msgCache: QMap<Can::MsgId, pair<bool, Can::Message>>
        -_appServer: CloudConnectServer
        -_txSequence: quint16
        __
        +CloudConnectController(configPath, msgHandlingPath)
        +listenForApp(): bool
        -loadMsgHandling(msgHandlingPath)
        __
        -onFrameReceive(QCanBusFrame)
        -onMessageReceive(Can::Message)
    }
}

package "Comms (lib)" {
    class "Can::CanInterface" as CanInterface {
        -_canDevice: QSharedPointer<QCanBusDevice>
        -_rxFrameCount: FrameCount
        -_txFrameCount: FrameCount
        -_erFrameCount: FrameCount
        __
        +init(thread: QThread&): bool
        +quitDevice()
        +enableConsoleOut(bool)
        +status(): QString
        __
        +didFrameReceive(QCanBusFrame) <<signal>>
        +didFrameTransmit(bool) <<signal>>
        +didFrameError(QString) <<signal>>
        +didFrameWritten(qint64) <<signal>>
        __
        -onFrameReceive() <<slot>>
        -onFrameTransmit(QCanBusFrame) <<slot>>
        -onFrameError(CanBusError) <<slot>>
        -onFrameWritten(qint64) <<slot>>
    }

    class CloudConnectClient {
        -_socket: QLocalSocket
        -_reconnectTimer: QTimer
        -_socketPath: QString
        -_rxBuf: QByteArray
        -_rxMsg: CloudConnectFrame
        __
        +init(socketPath, reconnectIntervalMs, thread): bool
        +send(type, sequence, payload): bool
        +quit() <<slot>>
        __
        +didMessageReceive(Type, seq, payload) <<signal>>
        +didConnect() <<signal>>
        +didDisconnect() <<signal>>
        __
        -onConnected() <<slot>>
        -onDisconnected() <<slot>>
        -onError(LocalSocketError) <<slot>>
        -onReadyRead() <<slot>>
        -onReconnectTimer() <<slot>>
    }

    class CloudConnectServer {
        -_server: QLocalServer
        -_client: QLocalSocket*
        -_rxBuf: QByteArray
        -_rxMsg: CloudConnectFrame
        __
        +listen(socketPath): bool
        +send(type, sequence, payload): bool
        +isConnected(): bool
        __
        +didMessageReceive(Type, seq, payload) <<signal>>
        +didConnect() <<signal>>
        +didDisconnect() <<signal>>
        __
        -onNewConnection() <<slot>>
        -onDisconnected() <<slot>>
        -onReadyRead() <<slot>>
    }

    class "Can::MessageDispatcher" as MessageDispatcher {
        -_messageList: QHash<CanId, MessageList>
        -_rxSequence: Sequence
        -_builder: Can::MessageBuilder
        __
        +didActionReceive(Can::Message) <<signal>>
        __
        +onFrameReceive(CanId, payload) <<slot>>
        -buildMessage(CanId, payload): bool
        -rxCount(): Sequence
    }

    class "Can::MessageBuilder" as MessageBuilder {
        __
        +buildFrames(MsgId, data, frameList, sequence): bool
        +buildMessage(payload, message, canId): bool
        +enableConsoleOut(bool)
    }

    class CloudConnectFrame {
        -_headerBuf: QByteArray
        -_rxType: Type
        -_rxSequence: quint16
        -_rxPayloadLen: quint32
        -_rxPayload: QByteArray
        __
        +{static} build(type, sequence, payload): QByteArray
        +read(bytes: QByteArray&): ReadState
        +type(): Type
        +sequence(): quint16
        +payload(): QByteArray
        +reset()
    }

    enum "CloudConnectFrame::Type" as Type {
        HighPriority      = 0x0001
        NormalPriority    = 0x0002
        DeviceLogFile     = 0x0003
        TreatmentLogFile  = 0x0004
        CloudSyncLogFile  = 0x0005
    }

    enum "CloudConnectFrame::ReadState" as ReadState {
        Incomplete
        Complete
        HeaderError
        PayloadError
    }
}

package "CANDumpPlayer (process)" {
    class "CANDumpPlayer\n(main)" <<tool>> {
        +can_interface: string
        +candump_file: string
        +--speed: double
        +--test: bool
        __
        Parses candump log and replays\nframes onto SocketCAN at a\nconfigurable speed multiplier
    }
}

' --- composition ---
CloudConnectController *-- CanInterface
CloudConnectController *-- CloudConnectServer
CloudConnectController *-- MessageDispatcher

' --- internal composition ---
MessageDispatcher *-- MessageBuilder

' --- usage ---
CloudConnectServer ..> CloudConnectFrame : uses
CloudConnectClient ..> CloudConnectFrame : uses

' --- enum nesting ---
CloudConnectFrame +-- Type
CloudConnectFrame +-- ReadState

' --- layout hints ---
CanInterface -[hidden]- CloudConnectClient

@enduml