(1 . 4)(1 . 4)
VERSION = "9989"
VERSION = "9988"

import os
import select
(9 . 6)(9 . 7)
import time
import string
import binascii
import hashlib
import datetime
from datetime import datetime
from lib.client import Client 
(24 . 7)(25 . 6)
from lib.infosec import Infosec
from lib.peer import Peer
from lib.message import Message
from lib.ringbuffer import Ringbuffer
from funcs import *
from commands import BROADCAST
from commands import DIRECT 
(63 . 7)(63 . 6)
        self.channels = {}  # irc_lower(Channel name) --> Channel instance.
        self.clients = {}  # Socket --> Client instance..peers = ""
        self.nicknames = {}  # irc_lower(Nickname) --> Client instance.
        self.recent = Ringbuffer(100)
        if self.logdir:
            create_directory(self.logdir)
        if self.statedir:
(207 . 11)(206 . 22)
        message.original = True
        if message.command == DIRECT:
            peer = self.state.get_peer_by_handle(message.handle)
            message_bytes = self.infosec.get_message_bytes(message, peer)
            message_hash = binascii.hexlify(hashlib.sha256(message_bytes).digest())
            self.state.add_to_dedup_queue(message_hash)

            self.state.log(message.speaker, message_bytes, peer.peer_id)
            if peer and (peer.get_key() != None):
                peer.send(message)
            else:
                self.print_debug("Discarding message to unknown handle or handle with no key: %s" % message.handle)
        else:
            message.timestamp = int(time.time())
            message_bytes = self.infosec.get_message_bytes(message)
            if message.command != IGNORE:
                self.state.log(message.speaker, message_bytes)
                message_hash = binascii.hexlify(hashlib.sha256(message_bytes).digest())
                self.state.add_to_dedup_queue(message_hash)
            for peer in self.state.get_peers():
                if peer.get_key() != None:
                    peer.send(message)
(228 . 14)(238 . 13)


    def sendrubbish(self):
        for peer in self.state.get_peers():
            for socket in self.clients:
                self.peer_message(Message({
                    "speaker": self.clients[socket].nickname,
                    "command": IGNORE,
                    "bounces": 0,
                    "body": self.infosec.gen_rubbish_body()
                }, self))
        for socket in self.clients:
            self.peer_message(Message({
                "speaker": self.clients[socket].nickname,
                "command": IGNORE,
                "bounces": 0,
                "body": self.infosec.gen_rubbish_body()
            }, self))
     
    def start(self):
        # Setup UDP first