tristanable/source/tristanable/watcher.d

module tristanable.watcher;

import core.thread : Thread;
import tristanable.manager : Manager;
import std.socket;

/** 
 * Watches the socket on a thread of its own,
 * performs the decoding of the incoming messages
 * and places them into the correct queues via
 * the associated Manager instance
 */
public class Watcher : Thread
{
    /** 
     * The associated manager to use
     * such that we can place new mail
     * into their respective inboxes (queues)
     */
    private Manager manager;

    /** 
     * The underlying socket to read from
     */
    private Socket socket;

    // TODO: make package-level in a way such
    // ... that only Manager can access this constructor
    // TODO: Add constructor doc
    this(Manager manager, Socket socket)
    {
        this.manager = manager;
        this.socket = socket;
    }

    
    private void watch()
    {
        while(true)
        {
            // TODO: Implement me
        }
    }
}