INSTANCE:
    chan v2_req_receiver
    
    // Collects reputation changes and sends them in one batch to relieve network cahnnels
    reputation ReputationAggregator

ENTRYPOINT:

    chan v2_comm_channel
    spawn -> task_responder 
                args[INSTANCE.v2_req_receiver, v2_comm_channel]       

infinity loop {
    
    await_for {
    
    reputation_delay:
        INSTANCE.reputation.send()
        reset(reputation_delay)
        continue
    
    FanIn(
        state,
        overseer_channel:
        v2_comm_channel,
    ):
        
        case message:
        From(SubsystemMsg):
            Handle_Subsystem_Message
        From(V1Requester):
            Handle_LegacyV1_Requester_Message
        From(V1Responder):
            Handle_LegacyV1_Responder_Message
        From(V2Responder):
            Handle_V2_Answer_Request
        From(Receive_Response):
            Handle_V2_Handle_Response
        From(Retry_Request)
            // do nothing
    
    }
    
    Dispatch_V2_Requests
}

FanIn:
    req_manager, resp_manager = INSTANCE.state.req_res_manager()
    receiver_resp_ch := receive_resp(resp_manager)
    retry_req_ch := next_entry(req_manager)

    select {
    
    case msg <- overseer_channel:
        return SingleOutputCh <- MuxedMessage {
            SubsystemMsg: msg
        }
    case msg <- v2_comm_channel:
        return SingleOuputCh <- MuxedMessage {
            V2Responder: msg
        }
    case msg <- receiver_resp_ch:
        return SingleOutputCh <- MuxedMessage {
            Receive_Response: msg
        }
    case msg <- retry_request:
        return SingleOutputCh <- MuxedMessage {
            Retry_Request: msg
        }
    }