#!/usr/bin/python # -*- coding: utf-8 -*- # # Copyright 2015 BreakWa11  from __future__ import absolute_import, division, print_function, \         with_statement  import sys import os import time import socket import binascii  sys.path.insert(0, os.path.join(os.path.dirname(__file__), '../'))  from shadowsocks import encrypt, eventloop, shell, common  class Relay:         def __init__(self, password, method):                 self._password = password                 self._method = method                 self._encryptor = encrypt.Encryptor(password, method)                 self._remote_sock = None          def create_remote_socket(self, ip):                 addrs = socket.getaddrinfo(ip, 0, 0, socket.SOCK_DGRAM, socket.SOL_UDP)                 if len(addrs) == 0:                         raise Exception("getaddrinfo failed")                 af, socktype, proto, canonname, sa = addrs[0]                 remote_sock = socket.socket(af, socktype, proto)                 self._remote_sock = remote_sock                 remote_sock.setblocking(False)                 return self          def sendto(self, ip, port, data):                 addrs = socket.getaddrinfo(ip, port, 0, socket.SOCK_DGRAM, socket.SOL_UDP)                 af, socktype, proto, canonname, sa = addrs[0]                 print(sa)                 print(binascii.hexlify(data))                 data = encrypt.encrypt_all(self._password, self._method, 1, data)                 print(binascii.hexlify(data))                 self._remote_sock.sendto(data, sa)          def close(self):                 self._remote_sock.close()                 self._remote_sock = None  def main(ip, port, password, method):         r = Relay(password, method)         r.create_remote_socket(ip).sendto(ip, port, common.to_str('\x03\x0101'))         time.sleep(1)         r.close()  if __name__ == '__main__':         main('127.0.0.1', 8988, 'password', 'aes-256-cfb')