def recvd_CONNECTED(self, messageSubType, payload):
        if self.peerType == base.CLIENT:
            if self.state == base.STATE_CONNECTING:
                self.state = base.STATE_CONNECTED
                self.logger.info('Connected to peer: %s' % self.sharingWithUser)
            else:
                self.logger.error('Received CONNECTED message from server-peer when in state %s' % self.state)
        else:
            ## server/initiator side of the wire...
            # client is connected, send ACK and set our state to be connected
            self.sendMessage(base.CONNECTED)
            self.state = base.STATE_CONNECTED
            self.logger.info('Connected to peer: %s' % self.sharingWithUser)
            self.notify(collab_event.ESTABLISHED_SESSION, self)
Accepts as kwargs the following arguments to build a dictionary with
dataset/ETHPy150Open nlloyd/SubliminalCollaborator/libs/sub_collab/peer/basic.py/BasicPeer.recvd_CONNECTED--crossover with--dataset/ETHPy150Open cuducos/getgist/tests/mocks.py/parse_mock