def receivedUpstream(self, data):
        if not self.send_crypto:
            log.debug("Got upstream data before doing handshake. Caching.")
            self.pending_data_to_send = True
            return

        log.debug("obfs2 receivedUpstream: Transmitting %d bytes.", len(data))
        # Encrypt and proxy them.
        self.circuit.downstream.write(self.send_crypto.crypt(data.read()))
Got data from upstream. We need to obfuscated and proxy them downstream.
dataset/ETHPy150Open isislovecruft/obfsproxy/obfsproxy/transports/obfs2.py/Obfs2Transport.receivedUpstream