diff --git a/vendor/asyncudp/.github/FUNDING.yml b/vendor/asyncudp/.github/FUNDING.yml new file mode 100644 index 0000000000..91d9b70351 --- /dev/null +++ b/vendor/asyncudp/.github/FUNDING.yml @@ -0,0 +1 @@ +github: eerimoq diff --git a/vendor/asyncudp/.github/workflows/pythonpackage.yml b/vendor/asyncudp/.github/workflows/pythonpackage.yml new file mode 100644 index 0000000000..9b3f5cd31d --- /dev/null +++ b/vendor/asyncudp/.github/workflows/pythonpackage.yml @@ -0,0 +1,50 @@ +name: Test + +on: + push: + pull_request: + +jobs: + + linux: + + runs-on: ubuntu-20.04 + strategy: + max-parallel: 4 + matrix: + python-version: [3.7, 3.8, 3.9] + + steps: + - uses: actions/checkout@v1 + - name: Set up Python ${{ matrix.python-version }} + uses: actions/setup-python@v3 + with: + python-version: ${{ matrix.python-version }} + - name: Test + run: | + python -m unittest + + release: + needs: [linux] + runs-on: ubuntu-20.04 + if: startsWith(github.ref, 'refs/tags') + + steps: + - name: Checkout + uses: actions/checkout@v1 + - name: Set up Python 3.9 + uses: actions/setup-python@v3 + with: + python-version: 3.9 + - name: Install pypa/build + run: | + python -m pip install build --user + - name: Build a source tarball + run: | + git clean -dfx + python -m build --sdist --outdir dist/ . + - name: Publish distribution 📦 to PyPI + uses: pypa/gh-action-pypi-publish@master + with: + skip_existing: true + password: ${{secrets.pypi_password}} diff --git a/vendor/asyncudp/.gitignore b/vendor/asyncudp/.gitignore new file mode 100644 index 0000000000..d86d71d397 --- /dev/null +++ b/vendor/asyncudp/.gitignore @@ -0,0 +1,72 @@ +# Byte-compiled / optimized / DLL files +__pycache__/ +*.py[cod] + +# C extensions +*.so +*.o +a.out + +# Distribution / packaging +.Python +env/ +venv/ +.venv/ +build/ +develop-eggs/ +dist/ +downloads/ +eggs/ +.eggs/ +lib/ +lib64/ +parts/ +sdist/ +var/ +*.egg-info/ +.installed.cfg +*.egg + +# PyInstaller +# Usually these files are written by a python script from a template +# before PyInstaller builds the exe, so as to inject date/other infos into it. +*.manifest +*.spec + +# Installer logs +pip-log.txt +pip-delete-this-directory.txt + +# Unit test / coverage reports +htmlcov/ +.tox/ +.coverage +.coverage.* +.cache +nosetests.xml +coverage.xml +*,cover + +# Translations +*.mo +*.pot + +# Django stuff: +*.log + +# Sphinx documentation +docs/_build/ + +# PyBuilder +target/ + +# Vim IDE +*~ +*.swp +*.swo + +# IntelliJ IDEA +.idea/ + +# pyenv +.python-version diff --git a/vendor/asyncudp/LICENSE b/vendor/asyncudp/LICENSE new file mode 100644 index 0000000000..2d5c757d4d --- /dev/null +++ b/vendor/asyncudp/LICENSE @@ -0,0 +1,22 @@ +The MIT License (MIT) + +Copyright (c) 2021 Erik Moqvist + +Permission is hereby granted, free of charge, to any person obtaining a copy +of this software and associated documentation files (the "Software"), to deal +in the Software without restriction, including without limitation the rights +to use, copy, modify, merge, publish, distribute, sublicense, and/or sell +copies of the Software, and to permit persons to whom the Software is +furnished to do so, subject to the following conditions: + +The above copyright notice and this permission notice shall be included in all +copies or substantial portions of the Software. + +THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS OR +IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF MERCHANTABILITY, +FITNESS FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT. IN NO EVENT SHALL THE +AUTHORS OR COPYRIGHT HOLDERS BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER +LIABILITY, WHETHER IN AN ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING FROM, +OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN THE +SOFTWARE. + diff --git a/vendor/asyncudp/MANIFEST.in b/vendor/asyncudp/MANIFEST.in new file mode 100644 index 0000000000..90b3902af1 --- /dev/null +++ b/vendor/asyncudp/MANIFEST.in @@ -0,0 +1,2 @@ +include LICENSE +recursive-include tests *.py \ No newline at end of file diff --git a/vendor/asyncudp/README.rst b/vendor/asyncudp/README.rst new file mode 100644 index 0000000000..5b8ea965aa --- /dev/null +++ b/vendor/asyncudp/README.rst @@ -0,0 +1,56 @@ +Asyncio high level UDP sockets +============================== + +Asyncio high level UDP sockets. + +Project homepage: https://github.com/eerimoq/asyncudp + +Documentation: https://asyncudp.readthedocs.org/en/latest + +Installation +============ + +.. code-block:: python + + $ pip install asyncudp + +Example client +============== + +.. code-block:: python + + import asyncio + import asyncudp + + async def main(): + sock = await asyncudp.create_socket(remote_addr=('127.0.0.1', 9999)) + sock.sendto(b'Hello!') + print(await sock.recvfrom()) + sock.close() + + asyncio.run(main()) + +Example server +============== + +.. code-block:: python + + import asyncio + import asyncudp + + async def main(): + sock = await asyncudp.create_socket(local_addr=('127.0.0.1', 9999)) + + while True: + data, addr = await sock.recvfrom() + print(data, addr) + sock.sendto(data, addr) + + asyncio.run(main()) + +Test +==== + +.. code-block:: + + $ python3 -m unittest diff --git a/vendor/asyncudp/asyncudp/__init__.py b/vendor/asyncudp/asyncudp/__init__.py new file mode 100644 index 0000000000..2709e0ded9 --- /dev/null +++ b/vendor/asyncudp/asyncudp/__init__.py @@ -0,0 +1,125 @@ +import asyncio + +from .version import __version__ + + +class ClosedError(Exception): + pass + + +class _SocketProtocol: + + def __init__(self, packets_queue_max_size): + self._error = None + self._packets = asyncio.Queue(packets_queue_max_size) + + def connection_made(self, transport): + pass + + def connection_lost(self, transport): + self._packets.put_nowait(None) + + def datagram_received(self, data, addr): + self._packets.put_nowait((data, addr)) + + def error_received(self, exc): + self._error = exc + self._packets.put_nowait(None) + + async def recvfrom(self): + return await self._packets.get() + + def raise_if_error(self): + if self._error is None: + return + + error = self._error + self._error = None + + raise error + + +class Socket: + """A UDP socket. Use :func:`~asyncudp.create_socket()` to create an + instance of this class. + + """ + + def __init__(self, transport, protocol): + self._transport = transport + self._protocol = protocol + + def close(self): + """Close the socket. + + """ + + self._transport.close() + + def sendto(self, data, addr=None): + """Send given packet to given address ``addr``. Sends to + ``remote_addr`` given to the constructor if ``addr`` is + ``None``. + + Raises an error if a connection error has occurred. + + >>> sock.sendto(b'Hi!') + + """ + + self._transport.sendto(data, addr) + self._protocol.raise_if_error() + + async def recvfrom(self): + """Receive a UDP packet. + + Raises ClosedError on connection error, often by calling the + close() method from another task. May raise other errors as + well. + + >>> data, addr = sock.recvfrom() + + """ + + packet = await self._protocol.recvfrom() + self._protocol.raise_if_error() + + if packet is None: + raise ClosedError() + + return packet + + def getsockname(self): + """Get bound infomation. + + >>> local_address, local_port = sock.getsockname() + + """ + + return self._transport.get_extra_info('sockname') + + async def __aenter__(self): + return self + + async def __aexit__(self, *exc_info): + self.close() + + +async def create_socket(local_addr=None, + remote_addr=None, + packets_queue_max_size=0, + reuse_port=None): + """Create a UDP socket with given local and remote addresses. + + >>> sock = await asyncudp.create_socket(local_addr=('127.0.0.1', 9999)) + + """ + + loop = asyncio.get_running_loop() + transport, protocol = await loop.create_datagram_endpoint( + lambda: _SocketProtocol(packets_queue_max_size), + local_addr=local_addr, + remote_addr=remote_addr, + reuse_port=reuse_port) + + return Socket(transport, protocol) diff --git a/vendor/asyncudp/asyncudp/version.py b/vendor/asyncudp/asyncudp/version.py new file mode 100644 index 0000000000..9d1bb721be --- /dev/null +++ b/vendor/asyncudp/asyncudp/version.py @@ -0,0 +1 @@ +__version__ = '0.10.0' diff --git a/vendor/asyncudp/docs/Makefile b/vendor/asyncudp/docs/Makefile new file mode 100644 index 0000000000..4fbb276295 --- /dev/null +++ b/vendor/asyncudp/docs/Makefile @@ -0,0 +1,192 @@ +# Makefile for Sphinx documentation +# + +# You can set these variables from the command line. +SPHINXOPTS = +SPHINXBUILD = sphinx-build +PAPER = +BUILDDIR = _build + +# User-friendly check for sphinx-build +ifeq ($(shell which $(SPHINXBUILD) >/dev/null 2>&1; echo $$?), 1) +$(error The '$(SPHINXBUILD)' command was not found. Make sure you have Sphinx installed, then set the SPHINXBUILD environment variable to point to the full path of the '$(SPHINXBUILD)' executable. Alternatively you can add the directory with the executable to your PATH. If you don't have Sphinx installed, grab it from http://sphinx-doc.org/) +endif + +# Internal variables. +PAPEROPT_a4 = -D latex_paper_size=a4 +PAPEROPT_letter = -D latex_paper_size=letter +ALLSPHINXOPTS = -d $(BUILDDIR)/doctrees $(PAPEROPT_$(PAPER)) $(SPHINXOPTS) . +# the i18n builder cannot share the environment and doctrees with the others +I18NSPHINXOPTS = $(PAPEROPT_$(PAPER)) $(SPHINXOPTS) . + +.PHONY: help clean html dirhtml singlehtml pickle json htmlhelp qthelp devhelp epub latex latexpdf text man changes linkcheck doctest coverage gettext + +help: + @echo "Please use \`make ' where is one of" + @echo " html to make standalone HTML files" + @echo " dirhtml to make HTML files named index.html in directories" + @echo " singlehtml to make a single large HTML file" + @echo " pickle to make pickle files" + @echo " json to make JSON files" + @echo " htmlhelp to make HTML files and a HTML help project" + @echo " qthelp to make HTML files and a qthelp project" + @echo " applehelp to make an Apple Help Book" + @echo " devhelp to make HTML files and a Devhelp project" + @echo " epub to make an epub" + @echo " latex to make LaTeX files, you can set PAPER=a4 or PAPER=letter" + @echo " latexpdf to make LaTeX files and run them through pdflatex" + @echo " latexpdfja to make LaTeX files and run them through platex/dvipdfmx" + @echo " text to make text files" + @echo " man to make manual pages" + @echo " texinfo to make Texinfo files" + @echo " info to make Texinfo files and run them through makeinfo" + @echo " gettext to make PO message catalogs" + @echo " changes to make an overview of all changed/added/deprecated items" + @echo " xml to make Docutils-native XML files" + @echo " pseudoxml to make pseudoxml-XML files for display purposes" + @echo " linkcheck to check all external links for integrity" + @echo " doctest to run all doctests embedded in the documentation (if enabled)" + @echo " coverage to run coverage check of the documentation (if enabled)" + +clean: + rm -rf $(BUILDDIR)/* + +html: + $(SPHINXBUILD) -b html $(ALLSPHINXOPTS) $(BUILDDIR)/html + @echo + @echo "Build finished. The HTML pages are in $(BUILDDIR)/html." + +dirhtml: + $(SPHINXBUILD) -b dirhtml $(ALLSPHINXOPTS) $(BUILDDIR)/dirhtml + @echo + @echo "Build finished. The HTML pages are in $(BUILDDIR)/dirhtml." + +singlehtml: + $(SPHINXBUILD) -b singlehtml $(ALLSPHINXOPTS) $(BUILDDIR)/singlehtml + @echo + @echo "Build finished. The HTML page is in $(BUILDDIR)/singlehtml." + +pickle: + $(SPHINXBUILD) -b pickle $(ALLSPHINXOPTS) $(BUILDDIR)/pickle + @echo + @echo "Build finished; now you can process the pickle files." + +json: + $(SPHINXBUILD) -b json $(ALLSPHINXOPTS) $(BUILDDIR)/json + @echo + @echo "Build finished; now you can process the JSON files." + +htmlhelp: + $(SPHINXBUILD) -b htmlhelp $(ALLSPHINXOPTS) $(BUILDDIR)/htmlhelp + @echo + @echo "Build finished; now you can run HTML Help Workshop with the" \ + ".hhp project file in $(BUILDDIR)/htmlhelp." + +qthelp: + $(SPHINXBUILD) -b qthelp $(ALLSPHINXOPTS) $(BUILDDIR)/qthelp + @echo + @echo "Build finished; now you can run "qcollectiongenerator" with the" \ + ".qhcp project file in $(BUILDDIR)/qthelp, like this:" + @echo "# qcollectiongenerator $(BUILDDIR)/qthelp/asyncudp.qhcp" + @echo "To view the help file:" + @echo "# assistant -collectionFile $(BUILDDIR)/qthelp/asyncudp.qhc" + +applehelp: + $(SPHINXBUILD) -b applehelp $(ALLSPHINXOPTS) $(BUILDDIR)/applehelp + @echo + @echo "Build finished. The help book is in $(BUILDDIR)/applehelp." + @echo "N.B. You won't be able to view it unless you put it in" \ + "~/Library/Documentation/Help or install it in your application" \ + "bundle." + +devhelp: + $(SPHINXBUILD) -b devhelp $(ALLSPHINXOPTS) $(BUILDDIR)/devhelp + @echo + @echo "Build finished." + @echo "To view the help file:" + @echo "# mkdir -p $$HOME/.local/share/devhelp/asyncudp" + @echo "# ln -s $(BUILDDIR)/devhelp $$HOME/.local/share/devhelp/asyncudp" + @echo "# devhelp" + +epub: + $(SPHINXBUILD) -b epub $(ALLSPHINXOPTS) $(BUILDDIR)/epub + @echo + @echo "Build finished. The epub file is in $(BUILDDIR)/epub." + +latex: + $(SPHINXBUILD) -b latex $(ALLSPHINXOPTS) $(BUILDDIR)/latex + @echo + @echo "Build finished; the LaTeX files are in $(BUILDDIR)/latex." + @echo "Run \`make' in that directory to run these through (pdf)latex" \ + "(use \`make latexpdf' here to do that automatically)." + +latexpdf: + $(SPHINXBUILD) -b latex $(ALLSPHINXOPTS) $(BUILDDIR)/latex + @echo "Running LaTeX files through pdflatex..." + $(MAKE) -C $(BUILDDIR)/latex all-pdf + @echo "pdflatex finished; the PDF files are in $(BUILDDIR)/latex." + +latexpdfja: + $(SPHINXBUILD) -b latex $(ALLSPHINXOPTS) $(BUILDDIR)/latex + @echo "Running LaTeX files through platex and dvipdfmx..." + $(MAKE) -C $(BUILDDIR)/latex all-pdf-ja + @echo "pdflatex finished; the PDF files are in $(BUILDDIR)/latex." + +text: + $(SPHINXBUILD) -b text $(ALLSPHINXOPTS) $(BUILDDIR)/text + @echo + @echo "Build finished. The text files are in $(BUILDDIR)/text." + +man: + $(SPHINXBUILD) -b man $(ALLSPHINXOPTS) $(BUILDDIR)/man + @echo + @echo "Build finished. The manual pages are in $(BUILDDIR)/man." + +texinfo: + $(SPHINXBUILD) -b texinfo $(ALLSPHINXOPTS) $(BUILDDIR)/texinfo + @echo + @echo "Build finished. The Texinfo files are in $(BUILDDIR)/texinfo." + @echo "Run \`make' in that directory to run these through makeinfo" \ + "(use \`make info' here to do that automatically)." + +info: + $(SPHINXBUILD) -b texinfo $(ALLSPHINXOPTS) $(BUILDDIR)/texinfo + @echo "Running Texinfo files through makeinfo..." + make -C $(BUILDDIR)/texinfo info + @echo "makeinfo finished; the Info files are in $(BUILDDIR)/texinfo." + +gettext: + $(SPHINXBUILD) -b gettext $(I18NSPHINXOPTS) $(BUILDDIR)/locale + @echo + @echo "Build finished. The message catalogs are in $(BUILDDIR)/locale." + +changes: + $(SPHINXBUILD) -b changes $(ALLSPHINXOPTS) $(BUILDDIR)/changes + @echo + @echo "The overview file is in $(BUILDDIR)/changes." + +linkcheck: + $(SPHINXBUILD) -b linkcheck $(ALLSPHINXOPTS) $(BUILDDIR)/linkcheck + @echo + @echo "Link check complete; look for any errors in the above output " \ + "or in $(BUILDDIR)/linkcheck/output.txt." + +doctest: + $(SPHINXBUILD) -b doctest $(ALLSPHINXOPTS) $(BUILDDIR)/doctest + @echo "Testing of doctests in the sources finished, look at the " \ + "results in $(BUILDDIR)/doctest/output.txt." + +coverage: + $(SPHINXBUILD) -b coverage $(ALLSPHINXOPTS) $(BUILDDIR)/coverage + @echo "Testing of coverage in the sources finished, look at the " \ + "results in $(BUILDDIR)/coverage/python.txt." + +xml: + $(SPHINXBUILD) -b xml $(ALLSPHINXOPTS) $(BUILDDIR)/xml + @echo + @echo "Build finished. The XML files are in $(BUILDDIR)/xml." + +pseudoxml: + $(SPHINXBUILD) -b pseudoxml $(ALLSPHINXOPTS) $(BUILDDIR)/pseudoxml + @echo + @echo "Build finished. The pseudo-XML files are in $(BUILDDIR)/pseudoxml." diff --git a/vendor/asyncudp/docs/conf.py b/vendor/asyncudp/docs/conf.py new file mode 100644 index 0000000000..d4733a2a41 --- /dev/null +++ b/vendor/asyncudp/docs/conf.py @@ -0,0 +1,291 @@ +# -*- coding: utf-8 -*- +# +# asyncudp documentation build configuration file, created by +# sphinx-quickstart on Sat Apr 25 11:54:09 2015. +# +# This file is execfile()d with the current directory set to its +# containing dir. +# +# Note that not all possible configuration values are present in this +# autogenerated file. +# +# All configuration values have a default; values that are commented out +# serve to show the default. + +import sys +import os +import shlex + +# If extensions (or modules to document with autodoc) are in another directory, +# add these directories to sys.path here. If the directory is relative to the +# documentation root, use os.path.abspath to make it absolute, like shown here. +sys.path.insert(0, os.path.abspath('..')) + +import asyncudp + +# -- General configuration ------------------------------------------------ + +# If your documentation needs a minimal Sphinx version, state it here. +#needs_sphinx = '1.0' + +# Add any Sphinx extension module names here, as strings. They can be +# extensions coming with Sphinx (named 'sphinx.ext.*') or your custom +# ones. +extensions = [ + 'sphinx.ext.autodoc', + 'sphinx.ext.viewcode', +] + +# Add any paths that contain templates here, relative to this directory. +templates_path = ['_templates'] + +# The suffix(es) of source filenames. +# You can specify multiple suffix as a list of string: +# source_suffix = ['.rst', '.md'] +source_suffix = '.rst' + +# The encoding of source files. +#source_encoding = 'utf-8-sig' + +# The master toctree document. +master_doc = 'index' + +# General information about the project. +project = u'asyncudp' +copyright = u'2019, Erik Moqvist' +author = u'Erik Moqvist' + +# The version info for the project you're documenting, acts as replacement for +# |version| and |release|, also used in various other places throughout the +# built documents. +# +# The short X.Y version. +version = asyncudp.__version__ +# The full version, including alpha/beta/rc tags. +release = asyncudp.__version__ + +# The language for content autogenerated by Sphinx. Refer to documentation +# for a list of supported languages. +# +# This is also used if you do content translation via gettext catalogs. +# Usually you set "language" from the command line for these cases. +language = None + +# There are two options for replacing |today|: either, you set today to some +# non-false value, then it is used: +#today = '' +# Else, today_fmt is used as the format for a strftime call. +#today_fmt = '%B %d, %Y' + +# List of patterns, relative to source directory, that match files and +# directories to ignore when looking for source files. +exclude_patterns = ['_build'] + +# The reST default role (used for this markup: `text`) to use for all +# documents. +#default_role = None + +# If true, '()' will be appended to :func: etc. cross-reference text. +#add_function_parentheses = True + +# If true, the current module name will be prepended to all description +# unit titles (such as .. function::). +#add_module_names = True + +# If true, sectionauthor and moduleauthor directives will be shown in the +# output. They are ignored by default. +#show_authors = False + +# The name of the Pygments (syntax highlighting) style to use. +pygments_style = 'sphinx' + +# A list of ignored prefixes for module index sorting. +#modindex_common_prefix = [] + +# If true, keep warnings as "system message" paragraphs in the built documents. +#keep_warnings = False + +# If true, `todo` and `todoList` produce output, else they produce nothing. +todo_include_todos = False + + +# -- Options for HTML output ---------------------------------------------- + +# The theme to use for HTML and HTML Help pages. See the documentation for +# a list of builtin themes. +html_theme = 'sphinx_rtd_theme' + +# Theme options are theme-specific and customize the look and feel of a theme +# further. For a list of options available for each theme, see the +# documentation. +#html_theme_options = {} + +# Add any paths that contain custom themes here, relative to this directory. +#html_theme_path = [] + +# The name for this set of Sphinx documents. If None, it defaults to +# " v documentation". +#html_title = None + +# A shorter title for the navigation bar. Default is the same as html_title. +#html_short_title = None + +# The name of an image file (relative to this directory) to place at the top +# of the sidebar. +#html_logo = None + +# The name of an image file (within the static path) to use as favicon of the +# docs. This file should be a Windows icon file (.ico) being 16x16 or 32x32 +# pixels large. +#html_favicon = None + +# Add any paths that contain custom static files (such as style sheets) here, +# relative to this directory. They are copied after the builtin static files, +# so a file named "default.css" will overwrite the builtin "default.css". +html_static_path = ['_static'] + +# Add any extra paths that contain custom files (such as robots.txt or +# .htaccess) here, relative to this directory. These files are copied +# directly to the root of the documentation. +#html_extra_path = [] + +# If not '', a 'Last updated on:' timestamp is inserted at every page bottom, +# using the given strftime format. +#html_last_updated_fmt = '%b %d, %Y' + +# If true, SmartyPants will be used to convert quotes and dashes to +# typographically correct entities. +#html_use_smartypants = True + +# Custom sidebar templates, maps document names to template names. +#html_sidebars = {} + +# Additional templates that should be rendered to pages, maps page names to +# template names. +#html_additional_pages = {} + +# If false, no module index is generated. +#html_domain_indices = True + +# If false, no index is generated. +#html_use_index = True + +# If true, the index is split into individual pages for each letter. +#html_split_index = False + +# If true, links to the reST sources are added to the pages. +#html_show_sourcelink = True + +# If true, "Created using Sphinx" is shown in the HTML footer. Default is True. +#html_show_sphinx = True + +# If true, "(C) Copyright ..." is shown in the HTML footer. Default is True. +#html_show_copyright = True + +# If true, an OpenSearch description file will be output, and all pages will +# contain a tag referring to it. The value of this option must be the +# base URL from which the finished HTML is served. +#html_use_opensearch = '' + +# This is the file name suffix for HTML files (e.g. ".xhtml"). +#html_file_suffix = None + +# Language to be used for generating the HTML full-text search index. +# Sphinx supports the following languages: +# 'da', 'de', 'en', 'es', 'fi', 'fr', 'hu', 'it', 'ja' +# 'nl', 'no', 'pt', 'ro', 'ru', 'sv', 'tr' +#html_search_language = 'en' + +# A dictionary with options for the search language support, empty by default. +# Now only 'ja' uses this config value +#html_search_options = {'type': 'default'} + +# The name of a javascript file (relative to the configuration directory) that +# implements a search results scorer. If empty, the default will be used. +#html_search_scorer = 'scorer.js' + +# Output file base name for HTML help builder. +htmlhelp_basename = 'asyncudpdoc' + +# -- Options for LaTeX output --------------------------------------------- + +latex_elements = { +# The paper size ('letterpaper' or 'a4paper'). +#'papersize': 'letterpaper', + +# The font size ('10pt', '11pt' or '12pt'). +#'pointsize': '10pt', + +# Additional stuff for the LaTeX preamble. +#'preamble': '', + +# Latex figure (float) alignment +#'figure_align': 'htbp', +} + +# Grouping the document tree into LaTeX files. List of tuples +# (source start file, target name, title, +# author, documentclass [howto, manual, or own class]). +latex_documents = [ + (master_doc, 'asyncudp.tex', u'asyncudp Documentation', + u'Erik Moqvist', 'manual'), +] + +# The name of an image file (relative to this directory) to place at the top of +# the title page. +#latex_logo = None + +# For "manual" documents, if this is true, then toplevel headings are parts, +# not chapters. +#latex_use_parts = False + +# If true, show page references after internal links. +#latex_show_pagerefs = False + +# If true, show URL addresses after external links. +#latex_show_urls = False + +# Documents to append as an appendix to all manuals. +#latex_appendices = [] + +# If false, no module index is generated. +#latex_domain_indices = True + + +# -- Options for manual page output --------------------------------------- + +# One entry per manual page. List of tuples +# (source start file, name, description, authors, manual section). +man_pages = [ + (master_doc, 'asyncudp', u'Asyncudp Documentation', + [author], 1) +] + +# If true, show URL addresses after external links. +#man_show_urls = False + + +# -- Options for Texinfo output ------------------------------------------- + +# Grouping the document tree into Texinfo files. List of tuples +# (source start file, target name, title, author, +# dir menu entry, description, category) +texinfo_documents = [ + (master_doc, 'asyncudp', u'Asyncudp Documentation', + author, 'asyncudp', 'One line description of project.', + 'Miscellaneous'), +] + +# Documents to append as an appendix to all manuals. +#texinfo_appendices = [] + +# If false, no module index is generated. +#texinfo_domain_indices = True + +# How to display URL addresses: 'footnote', 'no', or 'inline'. +#texinfo_show_urls = 'footnote' + +# If true, do not generate a @detailmenu in the "Top" node's menu. +#texinfo_no_detailmenu = False + +autodoc_member_order = 'bysource' diff --git a/vendor/asyncudp/docs/index.rst b/vendor/asyncudp/docs/index.rst new file mode 100644 index 0000000000..4f8c752f82 --- /dev/null +++ b/vendor/asyncudp/docs/index.rst @@ -0,0 +1,55 @@ +.. asyncudp documentation master file, created by + sphinx-quickstart on Sat Apr 25 11:54:09 2015. + You can adapt this file completely to your liking, but it should at least + contain the root `toctree` directive. + +.. include:: ../README.rst + +Examples +======== + +Client +------ + +.. code-block:: python + + import asyncio + import asyncudp + + async def main(): + sock = await asyncudp.create_socket(remote_addr=('127.0.0.1', 9999)) + sock.sendto(b'Hello!') + print(await sock.recvfrom()) + sock.close() + + asyncio.run(main()) + +Server +------ + +.. code-block:: python + + import asyncio + import asyncudp + + async def main(): + sock = await asyncudp.create_socket(local_addr=('127.0.0.1', 9999)) + + while True: + data, addr = await sock.recvfrom() + print(data, addr) + sock.sendto(data, addr) + + asyncio.run(main()) + +Functions and classes +===================== + +.. autofunction:: asyncudp.create_socket + +.. autoclass:: asyncudp.Socket + + .. automethod:: asyncudp.Socket.close + .. automethod:: asyncudp.Socket.sendto + .. automethod:: asyncudp.Socket.recvfrom + .. automethod:: asyncudp.Socket.getsockname diff --git a/vendor/asyncudp/docs/make.bat b/vendor/asyncudp/docs/make.bat new file mode 100644 index 0000000000..a54309f782 --- /dev/null +++ b/vendor/asyncudp/docs/make.bat @@ -0,0 +1,263 @@ +@ECHO OFF + +REM Command file for Sphinx documentation + +if "%SPHINXBUILD%" == "" ( + set SPHINXBUILD=sphinx-build +) +set BUILDDIR=_build +set ALLSPHINXOPTS=-d %BUILDDIR%/doctrees %SPHINXOPTS% . +set I18NSPHINXOPTS=%SPHINXOPTS% . +if NOT "%PAPER%" == "" ( + set ALLSPHINXOPTS=-D latex_paper_size=%PAPER% %ALLSPHINXOPTS% + set I18NSPHINXOPTS=-D latex_paper_size=%PAPER% %I18NSPHINXOPTS% +) + +if "%1" == "" goto help + +if "%1" == "help" ( + :help + echo.Please use `make ^` where ^ is one of + echo. html to make standalone HTML files + echo. dirhtml to make HTML files named index.html in directories + echo. singlehtml to make a single large HTML file + echo. pickle to make pickle files + echo. json to make JSON files + echo. htmlhelp to make HTML files and a HTML help project + echo. qthelp to make HTML files and a qthelp project + echo. devhelp to make HTML files and a Devhelp project + echo. epub to make an epub + echo. latex to make LaTeX files, you can set PAPER=a4 or PAPER=letter + echo. text to make text files + echo. man to make manual pages + echo. texinfo to make Texinfo files + echo. gettext to make PO message catalogs + echo. changes to make an overview over all changed/added/deprecated items + echo. xml to make Docutils-native XML files + echo. pseudoxml to make pseudoxml-XML files for display purposes + echo. linkcheck to check all external links for integrity + echo. doctest to run all doctests embedded in the documentation if enabled + echo. coverage to run coverage check of the documentation if enabled + goto end +) + +if "%1" == "clean" ( + for /d %%i in (%BUILDDIR%\*) do rmdir /q /s %%i + del /q /s %BUILDDIR%\* + goto end +) + + +REM Check if sphinx-build is available and fallback to Python version if any +%SPHINXBUILD% 2> nul +if errorlevel 9009 goto sphinx_python +goto sphinx_ok + +:sphinx_python + +set SPHINXBUILD=python -m sphinx.__init__ +%SPHINXBUILD% 2> nul +if errorlevel 9009 ( + echo. + echo.The 'sphinx-build' command was not found. Make sure you have Sphinx + echo.installed, then set the SPHINXBUILD environment variable to point + echo.to the full path of the 'sphinx-build' executable. Alternatively you + echo.may add the Sphinx directory to PATH. + echo. + echo.If you don't have Sphinx installed, grab it from + echo.http://sphinx-doc.org/ + exit /b 1 +) + +:sphinx_ok + + +if "%1" == "html" ( + %SPHINXBUILD% -b html %ALLSPHINXOPTS% %BUILDDIR%/html + if errorlevel 1 exit /b 1 + echo. + echo.Build finished. The HTML pages are in %BUILDDIR%/html. + goto end +) + +if "%1" == "dirhtml" ( + %SPHINXBUILD% -b dirhtml %ALLSPHINXOPTS% %BUILDDIR%/dirhtml + if errorlevel 1 exit /b 1 + echo. + echo.Build finished. The HTML pages are in %BUILDDIR%/dirhtml. + goto end +) + +if "%1" == "singlehtml" ( + %SPHINXBUILD% -b singlehtml %ALLSPHINXOPTS% %BUILDDIR%/singlehtml + if errorlevel 1 exit /b 1 + echo. + echo.Build finished. The HTML pages are in %BUILDDIR%/singlehtml. + goto end +) + +if "%1" == "pickle" ( + %SPHINXBUILD% -b pickle %ALLSPHINXOPTS% %BUILDDIR%/pickle + if errorlevel 1 exit /b 1 + echo. + echo.Build finished; now you can process the pickle files. + goto end +) + +if "%1" == "json" ( + %SPHINXBUILD% -b json %ALLSPHINXOPTS% %BUILDDIR%/json + if errorlevel 1 exit /b 1 + echo. + echo.Build finished; now you can process the JSON files. + goto end +) + +if "%1" == "htmlhelp" ( + %SPHINXBUILD% -b htmlhelp %ALLSPHINXOPTS% %BUILDDIR%/htmlhelp + if errorlevel 1 exit /b 1 + echo. + echo.Build finished; now you can run HTML Help Workshop with the ^ +.hhp project file in %BUILDDIR%/htmlhelp. + goto end +) + +if "%1" == "qthelp" ( + %SPHINXBUILD% -b qthelp %ALLSPHINXOPTS% %BUILDDIR%/qthelp + if errorlevel 1 exit /b 1 + echo. + echo.Build finished; now you can run "qcollectiongenerator" with the ^ +.qhcp project file in %BUILDDIR%/qthelp, like this: + echo.^> qcollectiongenerator %BUILDDIR%\qthelp\asyncudp.qhcp + echo.To view the help file: + echo.^> assistant -collectionFile %BUILDDIR%\qthelp\asyncudp.ghc + goto end +) + +if "%1" == "devhelp" ( + %SPHINXBUILD% -b devhelp %ALLSPHINXOPTS% %BUILDDIR%/devhelp + if errorlevel 1 exit /b 1 + echo. + echo.Build finished. + goto end +) + +if "%1" == "epub" ( + %SPHINXBUILD% -b epub %ALLSPHINXOPTS% %BUILDDIR%/epub + if errorlevel 1 exit /b 1 + echo. + echo.Build finished. The epub file is in %BUILDDIR%/epub. + goto end +) + +if "%1" == "latex" ( + %SPHINXBUILD% -b latex %ALLSPHINXOPTS% %BUILDDIR%/latex + if errorlevel 1 exit /b 1 + echo. + echo.Build finished; the LaTeX files are in %BUILDDIR%/latex. + goto end +) + +if "%1" == "latexpdf" ( + %SPHINXBUILD% -b latex %ALLSPHINXOPTS% %BUILDDIR%/latex + cd %BUILDDIR%/latex + make all-pdf + cd %~dp0 + echo. + echo.Build finished; the PDF files are in %BUILDDIR%/latex. + goto end +) + +if "%1" == "latexpdfja" ( + %SPHINXBUILD% -b latex %ALLSPHINXOPTS% %BUILDDIR%/latex + cd %BUILDDIR%/latex + make all-pdf-ja + cd %~dp0 + echo. + echo.Build finished; the PDF files are in %BUILDDIR%/latex. + goto end +) + +if "%1" == "text" ( + %SPHINXBUILD% -b text %ALLSPHINXOPTS% %BUILDDIR%/text + if errorlevel 1 exit /b 1 + echo. + echo.Build finished. The text files are in %BUILDDIR%/text. + goto end +) + +if "%1" == "man" ( + %SPHINXBUILD% -b man %ALLSPHINXOPTS% %BUILDDIR%/man + if errorlevel 1 exit /b 1 + echo. + echo.Build finished. The manual pages are in %BUILDDIR%/man. + goto end +) + +if "%1" == "texinfo" ( + %SPHINXBUILD% -b texinfo %ALLSPHINXOPTS% %BUILDDIR%/texinfo + if errorlevel 1 exit /b 1 + echo. + echo.Build finished. The Texinfo files are in %BUILDDIR%/texinfo. + goto end +) + +if "%1" == "gettext" ( + %SPHINXBUILD% -b gettext %I18NSPHINXOPTS% %BUILDDIR%/locale + if errorlevel 1 exit /b 1 + echo. + echo.Build finished. The message catalogs are in %BUILDDIR%/locale. + goto end +) + +if "%1" == "changes" ( + %SPHINXBUILD% -b changes %ALLSPHINXOPTS% %BUILDDIR%/changes + if errorlevel 1 exit /b 1 + echo. + echo.The overview file is in %BUILDDIR%/changes. + goto end +) + +if "%1" == "linkcheck" ( + %SPHINXBUILD% -b linkcheck %ALLSPHINXOPTS% %BUILDDIR%/linkcheck + if errorlevel 1 exit /b 1 + echo. + echo.Link check complete; look for any errors in the above output ^ +or in %BUILDDIR%/linkcheck/output.txt. + goto end +) + +if "%1" == "doctest" ( + %SPHINXBUILD% -b doctest %ALLSPHINXOPTS% %BUILDDIR%/doctest + if errorlevel 1 exit /b 1 + echo. + echo.Testing of doctests in the sources finished, look at the ^ +results in %BUILDDIR%/doctest/output.txt. + goto end +) + +if "%1" == "coverage" ( + %SPHINXBUILD% -b coverage %ALLSPHINXOPTS% %BUILDDIR%/coverage + if errorlevel 1 exit /b 1 + echo. + echo.Testing of coverage in the sources finished, look at the ^ +results in %BUILDDIR%/coverage/python.txt. + goto end +) + +if "%1" == "xml" ( + %SPHINXBUILD% -b xml %ALLSPHINXOPTS% %BUILDDIR%/xml + if errorlevel 1 exit /b 1 + echo. + echo.Build finished. The XML files are in %BUILDDIR%/xml. + goto end +) + +if "%1" == "pseudoxml" ( + %SPHINXBUILD% -b pseudoxml %ALLSPHINXOPTS% %BUILDDIR%/pseudoxml + if errorlevel 1 exit /b 1 + echo. + echo.Build finished. The pseudo-XML files are in %BUILDDIR%/pseudoxml. + goto end +) + +:end diff --git a/vendor/asyncudp/examples/client.py b/vendor/asyncudp/examples/client.py new file mode 100644 index 0000000000..471b95b79c --- /dev/null +++ b/vendor/asyncudp/examples/client.py @@ -0,0 +1,12 @@ +import asyncio +import asyncudp + + +async def main(): + sock = await asyncudp.create_socket(remote_addr=('127.0.0.1', 9999)) + sock.sendto(b'Hello!') + print(await sock.recvfrom()) + sock.close() + + +asyncio.run(main()) diff --git a/vendor/asyncudp/examples/server.py b/vendor/asyncudp/examples/server.py new file mode 100644 index 0000000000..b6b1534b95 --- /dev/null +++ b/vendor/asyncudp/examples/server.py @@ -0,0 +1,14 @@ +import asyncio +import asyncudp + + +async def main(): + sock = await asyncudp.create_socket(local_addr=('127.0.0.1', 9999)) + + while True: + data, addr = await sock.recvfrom() + print(data, addr) + sock.sendto(data, addr) + + +asyncio.run(main()) diff --git a/vendor/asyncudp/setup.py b/vendor/asyncudp/setup.py new file mode 100644 index 0000000000..3e6fdf0a78 --- /dev/null +++ b/vendor/asyncudp/setup.py @@ -0,0 +1,29 @@ +#!/usr/bin/env python3 + +import re +import setuptools +from setuptools import find_packages + + +def find_version(): + return re.search(r"^__version__ = '(.*)'$", + open('asyncudp/version.py', 'r').read(), + re.MULTILINE).group(1) + + +setuptools.setup( + name='asyncudp', + version=find_version(), + description='Asyncio high level UDP sockets.', + long_description=open('README.rst', 'r').read(), + author='Erik Moqvist', + author_email='erik.moqvist@gmail.com', + license='MIT', + classifiers=[ + 'License :: OSI Approved :: MIT License', + 'Programming Language :: Python :: 3', + ], + keywords=['asyncio'], + url='https://github.com/eerimoq/asyncudp', + packages=find_packages(exclude=['tests']), + test_suite="tests") diff --git a/vendor/asyncudp/tests/__init__.py b/vendor/asyncudp/tests/__init__.py new file mode 100644 index 0000000000..e69de29bb2 diff --git a/vendor/asyncudp/tests/test_asyncudp.py b/vendor/asyncudp/tests/test_asyncudp.py new file mode 100644 index 0000000000..d69f0d8547 --- /dev/null +++ b/vendor/asyncudp/tests/test_asyncudp.py @@ -0,0 +1,148 @@ +import asyncio +import unittest + +import asyncudp + + +class AsyncudpTest(unittest.TestCase): + + def test_local_addresses(self): + asyncio.run(self.local_addresses()) + + async def local_addresses(self): + server_addr = ('127.0.0.1', 13000) + client_addr = ('127.0.0.1', 13001) + + server = await asyncudp.create_socket(local_addr=server_addr) + client = await asyncudp.create_socket(local_addr=client_addr) + + client.sendto(b'local_addresses to server', server_addr) + data, addr = await server.recvfrom() + + self.assertEqual(data, b'local_addresses to server') + self.assertEqual(addr, client_addr) + + server.sendto(b'local_addresses to client', client_addr) + data, addr = await client.recvfrom() + + self.assertEqual(data, b'local_addresses to client') + self.assertEqual(addr, server_addr) + + server.close() + client.close() + + def test_getsockname(self): + asyncio.run(self.getsockname()) + + async def getsockname(self): + addr = ('127.0.0.1', 0) + socket = await asyncudp.create_socket(local_addr=addr) + actual_addr, actual_port = socket.getsockname() + self.assertTrue(actual_port > 0) + self.assertEqual(actual_addr, '127.0.0.1') + socket.close() + + def test_remote_address(self): + asyncio.run(self.remote_address()) + + async def remote_address(self): + server_addr = ('127.0.0.1', 13000) + client_addr = ('127.0.0.1', 13001) + + server = await asyncudp.create_socket(local_addr=server_addr) + client = await asyncudp.create_socket(local_addr=client_addr, + remote_addr=server_addr) + + client.sendto(b'remote_address to server') + data, addr = await server.recvfrom() + + self.assertEqual(data, b'remote_address to server') + self.assertEqual(addr, client_addr) + + server.close() + client.close() + + def test_cancel(self): + asyncio.run(self.cancel()) + + async def server_main(self, event): + server = await asyncudp.create_socket(local_addr=('127.0.0.1', 13000)) + + try: + await server.recvfrom() + except asyncio.CancelledError: + server.close() + event.set() + + async def cancel(self): + event = asyncio.Event() + task = asyncio.create_task(self.server_main(event)) + await asyncio.sleep(1.0) + task.cancel() + await event.wait() + + def test_context(self): + asyncio.run(self.context()) + + async def context(self): + server_addr = ('127.0.0.1', 13000) + client_addr = ('127.0.0.1', 13001) + + server = await asyncudp.create_socket(local_addr=server_addr) + client = await asyncudp.create_socket(local_addr=client_addr) + + async with server, client: + client.sendto(b'local_addresses to server', server_addr) + data, addr = await server.recvfrom() + + self.assertEqual(data, b'local_addresses to server') + self.assertEqual(addr, client_addr) + + server.sendto(b'local_addresses to client', client_addr) + data, addr = await client.recvfrom() + + self.assertEqual(data, b'local_addresses to client') + self.assertEqual(addr, server_addr) + + self.assertEqual(server._transport.is_closing(), False) + self.assertEqual(client._transport.is_closing(), False) + + self.assertEqual(server._transport.is_closing(), True) + self.assertEqual(client._transport.is_closing(), True) + + def test_packets_queue_max_size(self): + asyncio.run(self.packets_queue_max_size()) + + async def packets_queue_max_size(self): + server = await asyncudp.create_socket(local_addr=('127.0.0.1', 0), + packets_queue_max_size=1) + server_addr = server.getsockname() + client = await asyncudp.create_socket(remote_addr=server_addr) + + client.sendto(b'local_addresses to server 1') + client.sendto(b'local_addresses to server 2') + await asyncio.sleep(1.0) + data, _ = await server.recvfrom() + self.assertEqual(data, b'local_addresses to server 1') + + client.sendto(b'local_addresses to server 3') + data, _ = await server.recvfrom() + self.assertEqual(data, b'local_addresses to server 3') + + server.close() + client.close() + + def test_create_socket_reuse_port(self): + asyncio.run(self.create_socket_reuse_port()) + + async def create_socket_reuse_port(self): + sock = await asyncudp.create_socket(local_addr=('127.0.0.1', 13003), + reuse_port=True) + + with self.assertRaises(OSError): + await asyncudp.create_socket(local_addr=('127.0.0.1', 13003)) + + sock.close() + sock2 = await asyncudp.create_socket(local_addr=('127.0.0.1', 13003), + reuse_port=True) + sock2.close()