Onionr/static-data/default-plugins/tor/announce.py

import config
import logger

from getsocks import get_socks
from torpeer import TorPeer
from gossip.peerset import gossip_peer_set


def on_announce_rec(api, data=None):
    socks_address, socks_port = get_socks()[0]

    announced = data['address']
    try:
        announced = announced.decode('utf-8')
    except AttributeError:
        pass

    if announced == config.get('tor.transport_address'):
        logger.warn("Recieved announcement for our own node, which shouldnt happen")
        return

    announced += '.onion'

    data['callback'](
        gossip_peer_set,
        TorPeer(socks_address, socks_port, announced))