hjaremko / asciinem Goto Github PK

Make use of async asio, use websockets and make it "sync, then stream".

Network module facade is a simple interface exposing module's services.

Steps:

• Add interface
• Implement factory that assembles network facade using asio implementations of the submodules

Suggested interface:

class network {
    virtual auto poll_message() -> types::msg = 0;
    virtual void queue_message(const types::msg&) = 0;
}

Connection manager manages current connected players.
It should poll all connected clients according to the clock and push received data to the message_queue. It should also remove disconnected players from the list.

Done:

• Interface
• Connection list
• Client polling
• Disconnected players and error handling
• Broadcasting data to the clients on clock tick

Some header still can be split up to .hpp and .cpp files

Implement server clock using Observer pattern.
Clock should run in separate thread notify all subscribers of a new tick id at fixed intervals.

Suggested interfaces:

class clock
{
    virtual void next_tick() /* notify */ = 0;
    virtual void attach(clock_observer) = 0;
    virtual void detach(clock_observer) = 0;
};

next_tick()
{
    for each observer in observers {
        observer->update();
    }
}

class clock_observer
{
    virtual auto update() -> types::tick_id;
   /* update function invokes function that should run on next tick */
};

This module consists of:

• Module facade (#7)
• Listener (#8)
• Connection manager (#9)
• Message queue (#10)
• Clock (#11)

Everything should be in asciinem::server::network namespace.

Listener should work in the background and collect new incoming connections. They should be delegated to the connection_manager submodule for further handling.

Steps:

• Add interface
• Add asio implementation

Add CI step to Verify workflow that will enforce proper code formatting

Instead of sending XML data and looking for EOF char, send size of serialized data first

Using Bridge design pattern add database connection interface and implement it using SQLite.
Interface should provide method to execute SQL query (including select queries).

Should provide basic queue functionality and contain objects of type types::msg.
The queue should be thread safe.

Steps:

• Add interface
• Implement interface using std::deque, keep in mind that this queue could be converted into priority queue in the future

Suggested interface:

class message_queue
{
    virtual auto poll() -> types::msg = 0;
    virtual auto push(const types::msg&) = 0;
};