work in progress

.editorconfig

@@ -0,0 +1,21 @@
+# http://editorconfig.org
+
+root = true
+
+[*]
+indent_style = space
+indent_size = 4
+trim_trailing_whitespace = true
+insert_final_newline = true
+charset = utf-8
+end_of_line = lf
+
+[*.bat]
+indent_style = tab
+end_of_line = crlf
+
+[LICENSE]
+insert_final_newline = false
+
+[Makefile]
+indent_style = tab

.travis.yml

@@ -0,0 +1,15 @@
+# Config file for automatic testing at travis-ci.org
+
+language: python
+
+python:
+  - "3.4"
+  - "3.3"
+  - "2.7"
+  - "pypy"
+
+# command to install dependencies, e.g. pip install -r requirements.txt --use-mirrors
+install: pip install -r requirements.txt
+
+# command to run tests, e.g. python setup.py test
+script: python setup.py test

AUTHORS.rst

@@ -0,0 +1,13 @@
+=======
+Credits
+=======
+
+Development Lead
+----------------
+
+* Heiko Heiko <[email protected]>
+
+Contributors
+------------
+
+None yet. Why not be the first?

CONTRIBUTING.rst

@@ -0,0 +1,117 @@
+============
+Contributing
+============
+
+Contributions are welcome, and they are greatly appreciated! Every
+little bit helps, and credit will always be given.
+
+You can contribute in many ways:
+
+Types of Contributions
+----------------------
+
+Report Bugs
+~~~~~~~~~~~
+
+Report bugs at https://github.com/heikoheiko/pydevp2p/issues.
+
+If you are reporting a bug, please include:
+
+* Your operating system name and version.
+* Any details about your local setup that might be helpful in troubleshooting.
+* Detailed steps to reproduce the bug.
+
+Fix Bugs
+~~~~~~~~
+
+Look through the GitHub issues for bugs. Anything tagged with "bug"
+is open to whoever wants to implement it.
+
+Implement Features
+~~~~~~~~~~~~~~~~~~
+
+Look through the GitHub issues for features. Anything tagged with "feature"
+is open to whoever wants to implement it.
+
+Write Documentation
+~~~~~~~~~~~~~~~~~~~
+
+pydevp2p could always use more documentation, whether as part of the
+official pydevp2p docs, in docstrings, or even on the web in blog posts,
+articles, and such.
+
+Submit Feedback
+~~~~~~~~~~~~~~~
+
+The best way to send feedback is to file an issue at https://github.com/heikoheiko/pydevp2p/issues.
+
+If you are proposing a feature:
+
+* Explain in detail how it would work.
+* Keep the scope as narrow as possible, to make it easier to implement.
+* Remember that this is a volunteer-driven project, and that contributions
+  are welcome :)
+
+Get Started!
+------------
+
+Ready to contribute? Here's how to set up `pydevp2p` for local development.
+
+1. Fork the `pydevp2p` repo on GitHub.
+2. Clone your fork locally::
+
+    $ git clone [email protected]:your_name_here/pydevp2p.git
+
+3. Install your local copy into a virtualenv. Assuming you have virtualenvwrapper installed, this is how you set up your fork for local development::
+
+    $ mkvirtualenv pydevp2p
+    $ cd pydevp2p/
+    $ python setup.py develop
+
+4. Create a branch for local development::
+
+    $ git checkout -b name-of-your-bugfix-or-feature
+
+   Now you can make your changes locally.
+
+5. When you're done making changes, check that your changes pass flake8 and the tests, including testing other Python versions with tox::
+
+    $ flake8 pydevp2p tests
+    $ python setup.py test
+    $ tox
+
+   To get flake8 and tox, just pip install them into your virtualenv.
+
+6. Commit your changes and push your branch to GitHub::
+
+    $ git add .
+    $ git commit -m "Your detailed description of your changes."
+    $ git push origin name-of-your-bugfix-or-feature
+
+7. Submit a pull request through the GitHub website.
+
+Pull Request Guidelines
+-----------------------
+
+Before you submit a pull request, check that it meets these guidelines:
+
+1. The pull request should include tests.
+2. If the pull request adds functionality, the docs should be updated. Put
+   your new functionality into a function with a docstring, and add the
+   feature to the list in README.rst.
+3. The pull request should work for Python 2.6, 2.7, 3.3, and 3.4, and for PyPy. Check
+   https://travis-ci.org/heikoheiko/pydevp2p/pull_requests
+   and make sure that the tests pass for all supported Python versions.
+
+Tips
+----
+
+To run a subset of tests::
+
+    $ python -m unittest tests.test_pydevp2p
+
+To do a release::
+
+Check out these sources:
+  Checklist: https://gist.github.com/audreyr/5990987
+  Helper: https://github.com/michaeljoseph/changes

HISTORY.rst

@@ -0,0 +1,9 @@
+.. :changelog:
+
+History
+-------
+
+0.0.1 (2014-01-11)
+---------------------
+
+* First release on PyPI.

LICENSE

@@ -0,0 +1,12 @@
+Copyright (c) 2014, Heiko Heiko
+All rights reserved.
+
+Redistribution and use in source and binary forms, with or without modification, are permitted provided that the following conditions are met:
+
+* Redistributions of source code must retain the above copyright notice, this list of conditions and the following disclaimer.
+
+* Redistributions in binary form must reproduce the above copyright notice, this list of conditions and the following disclaimer in the documentation and/or other materials provided with the distribution.
+
+* Neither the name of pydevp2p nor the names of its contributors may be used to endorse or promote products derived from this software without specific prior written permission.
+
+THIS SOFTWARE IS PROVIDED BY THE COPYRIGHT HOLDERS AND CONTRIBUTORS "AS IS" AND ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE ARE DISCLAIMED. IN NO EVENT SHALL THE COPYRIGHT HOLDER OR CONTRIBUTORS BE LIABLE FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES; LOSS OF USE, DATA, OR PROFITS; OR BUSINESS INTERRUPTION) HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE.

MANIFEST.in

@@ -0,0 +1,11 @@
+include AUTHORS.rst
+include CONTRIBUTING.rst
+include HISTORY.rst
+include LICENSE
+include README.rst
+
+recursive-include tests *
+recursive-exclude * __pycache__
+recursive-exclude * *.py[co]
+
+recursive-include docs *.rst conf.py Makefile make.bat

Makefile

@@ -0,0 +1,64 @@
+.PHONY: clean-pyc clean-build docs clean
+
+help:
+	@echo "clean - remove all build, test, coverage and Python artifacts"
+	@echo "clean-build - remove build artifacts"
+	@echo "clean-pyc - remove Python file artifacts"
+	@echo "clean-test - remove test and coverage artifacts"
+	@echo "lint - check style with flake8"
+	@echo "test - run tests quickly with the default Python"
+	@echo "test-all - run tests on every Python version with tox"
+	@echo "coverage - check code coverage quickly with the default Python"
+	@echo "docs - generate Sphinx HTML documentation, including API docs"
+	@echo "release - package and upload a release"
+	@echo "dist - package"
+
+clean: clean-build clean-pyc clean-test
+
+clean-build:
+	rm -fr build/
+	rm -fr dist/
+	rm -fr *.egg-info
+
+clean-pyc:
+	find . -name '*.pyc' -exec rm -f {} +
+	find . -name '*.pyo' -exec rm -f {} +
+	find . -name '*~' -exec rm -f {} +
+	find . -name '__pycache__' -exec rm -fr {} +
+
+clean-test:
+	rm -fr .tox/
+	rm -f .coverage
+	rm -fr htmlcov/
+
+lint:
+	flake8 pydevp2p tests
+
+test:
+	python setup.py test
+
+test-all:
+	tox
+
+coverage:
+	coverage run --source devp2p setup.py test
+	coverage report -m
+	coverage html
+	open htmlcov/index.html
+
+docs:
+	rm -f docs/pydevp2p.rst
+	rm -f docs/modules.rst
+	sphinx-apidoc -o docs/ pydevp2p
+	$(MAKE) -C docs clean
+	$(MAKE) -C docs html
+	open docs/_build/html/index.html
+
+release: clean
+	python setup.py sdist upload
+	python setup.py bdist_wheel upload
+
+dist: clean
+	python setup.py sdist
+	python setup.py bdist_wheel
+	ls -l dist

README.rst

@@ -0,0 +1,23 @@
+===============================
+pydevp2p
+===============================
+
+.. image:: https://badge.fury.io/py/pydevp2p.png
+    :target: http://badge.fury.io/py/pydevp2p
+
+.. image:: https://travis-ci.org/heikoheiko/pydevp2p.png?branch=master
+        :target: https://travis-ci.org/heikoheiko/pydevp2p
+
+.. image:: https://pypip.in/d/pydevp2p/badge.png
+        :target: https://pypi.python.org/pypi/pydevp2p
+
+
+Python implementation of the Ethereum P@P2P stack
+
+* Free software: BSD license
+* Documentation: https://pydevp2p.readthedocs.org.
+
+Features
+--------
+
+* TODO

devp2p/app.py

@@ -0,0 +1,86 @@
+from collections import UserDict
+from service import BaseService
+from slogging import get_logger
+log = get_logger('app')
+
+
+class BaseApp(object):
+
+    def __init__(self, config):
+        self.config = config
+        self.services = UserDict()
+
+    def register_service(self, service):
+        """
+        registeres protocol with peer, which will be accessible as
+        peer.<protocol.name> (e.g. peer.p2p or peer.eth)
+        """
+        assert isinstance(service, BaseService)
+        assert service.name not in self.services
+        log.info('registering service', service=service.name)
+        self.services[service.name] = service
+        setattr(self.services, service.name, service)
+
+    def deregister_service(self, service):
+        assert isinstance(service, BaseService)
+        self._services.remove(service)
+        delattr(self.services, service.name)
+
+    def start(self):
+        for service in self._services:
+            service.start()
+
+    def stop(self):
+        for service in self._services:
+            service.stop()
+
+
+if __name__ == '__main__':
+    # config
+    import ConfigParser
+    import io
+    import sys
+    import signal
+    import gevent
+    from peermanager import PeerManager
+    from jsonrpc import JSONRPCServer
+
+    import slogging
+    log = slogging.get_logger('app')
+
+    # read config
+    sample_config = """
+[p2p]
+num_peers = 10
+bootstrap_host = localhost
+bootstrap_port = 30303
+listen_host = 127.0.0.1
+listen_port = 30302
+    """
+    config = ConfigParser.ConfigParser()
+    if len(sys.argv) == 1:
+        config.readfp(io.BytesIO(sample_config))
+    else:
+        fn = sys.argv[1]
+        log.info('loading config from', fn=fn)
+        config.readfp(open(fn))
+
+    # create app
+    app = BaseApp(config)
+
+    # register services
+    PeerManager.register_with_app(app)
+    JSONRPCServer.register_with_app(app)
+
+    # start app
+    app.start()
+
+    # wait for interupt
+    evt = gevent.event.Event()
+    gevent.signal(signal.SIGQUIT, evt.set)
+    gevent.signal(signal.SIGTERM, evt.set)
+    gevent.signal(signal.SIGINT, evt.set)
+    evt.wait()
+
+    # finally stop
+    app.stop()