Added embedded openssh server.

Updated example.
Updated setup.py to work correctly without cython.
Added integration tests with test key pair.
Updated sources files with updated cython.

Author: Pan

embedded_server/__init__.py

@@ -0,0 +1 @@
+ssh-rsa AAAAB3NzaC1yc2EAAAADAQABAAABAQDOQrrFtUEF8owviZEAGHaitvHkmWg3Jyo+JF4i6CGIwXDDIuGIdCZK+dO7fyUHh72EW2Dt787okkXXx4dVWwmPzw0d/xE9ejkn9MCfYnA/tNBIEctDpnuXpiaIYDhxd9jRKVV+yppantFPTH4SR212HQYZBMXWM59aeNg/48OC8RlENyvJOo5kLeMCEza4ohiFylndeKlWVHHhC69fz63SeV2S8x2GJINKinmcjsH6actoGuZY2/iyzf7fdJhUgTI96GsyfvdESkzTFm/W5KQwgJqCZUt1tXupedkPHaUKN5ZTlc/dHdBWqwOFq1qgmUqrSwsXFGE0Fu7pFnK+JAvb

embedded_server/authorized_keys

@@ -0,0 +1,52 @@
+# This file is part of ssh2-python.
+# Copyright (C) 2017 Panos Kittenis
+
+# This library is free software; you can redistribute it and/or
+# modify it under the terms of the GNU Lesser General Public
+# License as published by the Free Software Foundation, version 2.1.
+
+# This library is distributed in the hope that it will be useful,
+# but WITHOUT ANY WARRANTY; without even the implied warranty of
+# MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the GNU
+# Lesser General Public License for more details.
+
+# You should have received a copy of the GNU Lesser General Public
+# License along with this library; if not, write to the Free Software
+# Foundation, Inc., 51 Franklin Street, Fifth Floor, Boston, MA  02110-1301  USA
+
+import os
+import socket
+
+from subprocess import Popen
+from time import sleep
+
+
+SERVER_KEY = os.path.sep.join([os.path.dirname(__file__), 'rsa.key'])
+SSHD_CONFIG = os.path.sep.join([os.path.dirname(__file__), 'sshd_config'])
+
+class OpenSSHServer(object):
+
+    def __init__(self, port=2222):
+        self.port = port
+        self.server_proc = None
+
+    def start_server(self):
+        cmd = ['/usr/sbin/sshd', '-q', '-D', '-p', str(self.port),
+               '-h', SERVER_KEY, '-f', SSHD_CONFIG]
+        server = Popen(cmd)
+        self.server_proc = server
+        self._wait_for_port()
+
+    def _wait_for_port(self):
+        sock = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
+        while sock.connect_ex(('127.0.0.1', self.port)) != 0:
+            sleep(.1)
+        del sock
+
+    def stop(self):
+        if self.server_proc is not None and self.server_proc.returncode is None:
+            self.server_proc.terminate()
+            self.server_proc.wait()
+
+    def __del__(self):
+        self.stop()

embedded_server/openssh.py

@@ -0,0 +1,15 @@
+-----BEGIN RSA PRIVATE KEY-----
+MIICXQIBAAKBgQDI7iK3d8eWYZlYloat94c5VjtFY7c/0zuGl8C7uMnZ3t6i2G99
+66hEW0nCFSZkOW5F0XKEVj+EUCHvo8koYC6wiohAqWQnEwIoOoh7GSAcB8gP/qaq
++adIl/Rvlby/mHakj+y05LBND6nFWHAn1y1gOFFKUXSJNRZPXSFy47gqzwIBIwKB
+gQCbANjz7q/pCXZLp1Hz6tYHqOvlEmjK1iabB1oqafrMpJ0eibUX/u+FMHq6StR5
+M5413BaDWHokPdEJUnabfWXXR3SMlBUKrck0eAer1O8m78yxu3OEdpRk+znVo4DL
+guMeCdJB/qcF0kEsx+Q8HP42MZU1oCmk3PbfXNFwaHbWuwJBAOQ/ry/hLD7AqB8x
+DmCM82A9E59ICNNlHOhxpJoh6nrNTPCsBAEu/SmqrL8mS6gmbRKUaya5Lx1pkxj2
+s/kWOokCQQDhXCcYXjjWiIfxhl6Rlgkk1vmI0l6785XSJNv4P7pXjGmShXfIzroh
+S8uWK3tL0GELY7+UAKDTUEVjjQdGxYSXAkEA3bo1JzKCwJ3lJZ1ebGuqmADRO6UP
+40xH977aadfN1mEI6cusHmgpISl0nG5YH7BMsvaT+bs1FUH8m+hXDzoqOwJBAK3Z
+X/za+KV/REya2z0b+GzgWhkXUGUa/owrEBdHGriQ47osclkUgPUdNqcLmaDilAF4
+1Z4PHPrI5RJIONAx+JECQQC/fChqjBgFpk6iJ+BOdSexQpgfxH/u/457W10Y43HR
+soS+8btbHqjQkowQ/2NTlUfWvqIlfxs6ZbFsIp/HrhZL
+-----END RSA PRIVATE KEY-----

embedded_server/rsa.key

@@ -0,0 +1,14 @@
+Protocol 2
+UsePrivilegeSeparation no
+UsePAM no
+RhostsRSAAuthentication no
+HostbasedAuthentication no
+IgnoreUserKnownHosts yes
+GSSAPIAuthentication no
+
+KeyRegenerationInterval 3600
+ServerKeyBits 1024
+
+AcceptEnv LANG LC_*
+Subsystem sftp /usr/lib/openssh/sftp-server
+AuthorizedKeysFile ssh2-python/embedded_server/authorized_keys

embedded_server/sshd_config

@@ -24,11 +24,12 @@
 session.agent_auth(user)
 
 # Agent capabilities
-# agent = session.agent_init()
-# agent.connect()
-# identities = agent.get_identities(user)
-# print(identities)
-# print(identities[0].magic)
+agent = session.agent_init()
+agent.connect()
+identities = agent.get_identities(user)
+print(identities)
+print(identities[0].magic)
+del agent
 
 # Public key blob available as identities[0].blob
 

examples/example_echo.py

@@ -0,0 +1 @@
+cython

requirements_dev.txt

@@ -3,6 +3,7 @@
 import platform
 import os
 import sys
+from glob import glob
 
 # import versioneer
 from setuptools import setup, find_packages, Extension
@@ -16,11 +17,13 @@
 else:
     USING_CYTHON = True
 
+names = 'ssh2/*'
 ext = 'pyx' if USING_CYTHON else 'c'
+sources = ['ssh2/*.%s' % (ext,)]
 
 extensions = [
     Extension('ssh2/*',
-              sources=['ssh2/*.pyx'],
+              sources=sources,
               libraries=['ssh2'],
               # extra_compile_args=["-O3"],
               extra_compile_args=["-ggdb"],
@@ -30,6 +33,21 @@
     # for ext in extensions
 ]
 
+if ext == 'c':
+    sources = glob(sources[0])
+    # names = [ for s in sources]
+    extensions = [
+        Extension(sources[i].split('.')[0].replace('/', '.'),
+                  sources=[sources[i]],
+                  libraries=['ssh2'],
+                  # extra_compile_args=["-O3"],
+                  extra_compile_args=["-ggdb"],
+                  # For conditional compilation
+                  # pyrex_compile_time_env
+        )
+        for i in range(len(sources))]
+
+
 if USING_CYTHON:
     extensions = cythonize(
         extensions,