(30 . 6)(30 . 10)
        metavar="X",
        help="load the configfile from X")
    op.add_option(
        "-n", "--channel-name",
        metavar="X",
        help="specify the channel name for this Pest network")
    op.add_option(
        "-d", "--daemon",
        action="store_true",
        help="fork and become a daemon")
(84 . 6)(88 . 8)
                 " (requires root)")

    (options, args) = op.parse_args(argv[1:])
    if options.channel_name is None:
        options.channel_name = "#pest"
    if options.debug:
        options.verbose = True
    if options.irc_ports is None:

(48 . 7)(48 . 7)
            return True

    def get_prefix(self):
        return "%s!%s@%s" % (self.nickname, self.user, self.host)
        return "%s" % (self.nickname)
    prefix = property(get_prefix)

    def check_aliveness(self):
(217 . 8)(217 . 8)
                self.reply("353 %s = %s :%s"
                           % (self.nickname,
                              channelname,
                              " ".join(sorted(x.nickname
                                              for x in channel.members))))
                              " ".join(sorted(x
                                              for x in self.server.state.get_peer_handles()))))
                self.reply("366 %s %s :End of NAMES list"
                           % (self.nickname, channelname))

(490 . 6)(490 . 7)
                try:
                    self.server.state.add_peer(arguments[0])
                    self.pest_reply("added new peer %s" % arguments[0])
                    self.message(":%s JOIN %s" % (arguments[0], self.server.channel_name))
                except:
                    self.pest_reply("error attempting to add peer %s" % arguments[0])
            else:
(500 . 6)(501 . 7)
                try:
                    self.server.state.remove_peer(arguments[0])
                    self.pest_reply("removed peer %s" % arguments[0])
                    self.message(":%s PART %s" % (arguments[0], self.server.channel_name))
                except Exception, e:
                    self.server.print_debug(e)
                    self.pest_reply("Error attempting to remove peer")

(138 . 15)(138 . 16)

        nonce, bounces, version, command, message_bytes = struct.unpack(RED_PACKET_FORMAT, red_packet_bytes)

        # nothing to be done for an IGNORE command

        if command == IGNORE:
            return Message({"error_code": IGNORED})

        # unpack message

        int_ts, self_chain, net_chain, speaker, message = struct.unpack(MESSAGE_PACKET_FORMAT, message_bytes)
        speaker = speaker.strip()

        # nothing to be done for an IGNORE command

        if command == IGNORE:
            return Message({"speaker": speaker, "error_code": IGNORED})

        
        # check timestamp

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

import os
import select
(36 . 6)(36 . 7)
    def __init__(self, options):
        self.irc_ports = options.irc_ports
        self.udp_port = options.udp_port
        self.channel_name = options.channel_name
        self.password = options.password
        self.motdfile = options.motd
        self.verbose = options.verbose
(163 . 18)(164 . 7)
                if(error_code == None):
                    self.print_debug("[%s] -> %s" % (peer.handles[0], message.body))

                    # we only update the address table if the speaker is same as peer

                    try: 
                        idx = peer.handles.index(message.speaker)
                    except:
                        idx = None

                    if idx != None:
                        self.state.update_address_table({"handle": message.speaker,
                                                         "address": address[0],
                                                         "port": address[1]
                                                        })
                    self.conditionally_update_address_table(peer, message, address)
                    # send the message to all clients
                    for c in self.clients:
                        if (self.clients[c].is_addressed_to_me(message.body)):
(193 . 12)(183 . 26)
                    self.print_debug("[%s:%d] -> malformed packet: %s" % packet_info)
                    return 
                elif error_code == IGNORED:
                    self.conditionally_update_address_table(peer, message, address)
                    self.print_debug("[%s:%d] -> ignoring packet: %s" % packet_info)
                    return 
                elif error_code == INVALID_SIGNATURE:
                    pass 
        self.print_debug("[%s:%d] -> martian packet: %s" % packet_info)
    
    # we only update the address table if the speaker is same as peer

    def conditionally_update_address_table(self, peer, message, address):
        try: 
            idx = peer.handles.index(message.speaker)
        except:
            idx = None

        if idx != None:
            self.state.update_address_table({"handle": message.speaker,
                                             "address": address[0],
                                             "port": address[1]
                                            })
    def peer_message(self, message):
        message.original = True
        if message.command == DIRECT:

(175 . 6)(175 . 10)
        return list(chain.from_iterable(self.cursor.execute("select handle_id from handles where peer_id=?",
                                                            (peer_id,)).fetchall()))
        
    def get_peer_handles(self):
        handles = list(chain.from_iterable(self.cursor.execute("select handle from handles").fetchall()))
        return handles
        
    def get_peers(self):
        peers = []
        handles = self.cursor.execute("select handle from handles").fetchall()

(1 . 6)(1 . 6)
#!/bin/bash

# start 3 servers on different ports
./blatta --debug --irc-port 6668 --udp-port 7778 --db-path a.db --address-table-path test_net_configs/a.py > logs/a &
./blatta --debug --irc-port 6669 --udp-port 7779 --db-path b.db --address-table-path test_net_configs/b.py > logs/b &
./blatta --debug --irc-port 6670 --udp-port 7780 --db-path c.db --address-table-path test_net_configs/c.py > logs/c &
./blatta --debug --channel-name \#aleth --irc-port 6668 --udp-port 7778 --db-path a.db --address-table-path test_net_configs/a.py > logs/a &
./blatta --debug --channel-name \#aleth --irc-port 6669 --udp-port 7779 --db-path b.db --address-table-path test_net_configs/b.py > logs/b &
./blatta --debug --channel-name \#aleth --irc-port 6670 --udp-port 7780 --db-path c.db --address-table-path test_net_configs/c.py > logs/c &