First commit

Author: martinRenou

.gitignore

@@ -0,0 +1,8 @@
+xeus-python-shell.egg-info/*
+test/__pycache__/*
+xeus-python-shell/__pycache__/*
+xeus-python-shell/functions/__pycache__/*
+.pytest_cache/*
+build/*
+dist/*
+.coverage

LICENSE

@@ -0,0 +1,29 @@
+BSD 3-Clause License
+
+Copyright (c) 2019, QuantStack
+All rights reserved.
+
+Redistribution and use in source and binary forms, with or without
+modification, are permitted provided that the following conditions are met:
+
+1. Redistributions of source code must retain the above copyright notice, this
+   list of conditions and the following disclaimer.
+
+2. 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.
+
+3. Neither the name of the copyright holder 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.

README.md

@@ -0,0 +1 @@
+# xeus-python-shell

setup.py

@@ -0,0 +1,34 @@
+#!/usr/bin/env python
+
+from setuptools import setup, find_packages
+
+__AUTHOR__ = 'QuantStack dev team'
+
+setup(
+    name='xeus-python-shell',
+    version='0.1.0',
+    description='The xeus-python core python logic.',
+    author=__AUTHOR__,
+    maintainer=__AUTHOR__,
+    url='https://github.com/jupyter-xeus/xeus-python-shell',
+    license='BSD 3-Clause',
+    keywords='python ipython xeus-python',
+    packages=find_packages(exclude=['test']),
+    python_requires='>=3.6',
+    install_requires=[
+    ],
+    extras_require={
+        'testing': ['flake8'],
+    },
+    platforms=['any'],
+    classifiers=[
+        'Intended Audience :: Developers',
+        'Operating System :: OS Independent',
+        'Programming Language :: Python :: 3',
+        'Programming Language :: Python :: 3.6',
+        'Programming Language :: Python :: 3.7',
+        'Programming Language :: Python :: 3.8',
+        'Programming Language :: Python :: 3.9',
+        'Topic :: Software Development :: Libraries :: Python Modules',
+    ],
+)

xeus_python_shell/__init__.py

@@ -0,0 +1,26 @@
+from IPython.core.compilerop import CachingCompiler
+
+
+def default_get_filename(raw_code):
+    return '<string>'
+
+
+class XCachingCompiler(CachingCompiler):
+    get_filename = default_get_filename
+
+    def __init__(self, *args, **kwargs):
+        super(XCachingCompiler, self).__init__(*args, **kwargs)
+
+        self.filename_mapper = None
+
+    def get_code_name(self, raw_code, code, number):
+        filename = XCachingCompiler.get_filename(raw_code)
+
+        if self.filename_mapper is not None:
+            self.filename_mapper(filename, number)
+
+        return filename
+
+    @classmethod
+    def set_filename_getter(cls, get_filename):
+        cls.get_filename = get_filename

xeus_python_shell/compiler.py

@@ -0,0 +1,29 @@
+from IPython.core.completer import provisionalcompleter, rectify_completions
+
+        scope["shell"] = m_ipython_shell;
+        scope["code"] = code;
+        scope["cursor_pos"] = cursor_pos;
+        exec(py::str(R"(
+
+
+with provisionalcompleter():
+    raw_completions = shell.Completer.completions(code, cursor_pos)
+    completions = list(rectify_completions(code, raw_completions))
+
+    comps = []
+    for comp in completions:
+        comps.append(dict(
+            start=comp.start,
+            end=comp.end,
+            text=comp.text,
+            type=comp.type,
+        ))
+
+if completions:
+    cursor_start = completions[0].start
+    cursor_end = completions[0].end
+    matches = [c.text for c in completions]
+else:
+    cursor_start = cursor_pos
+    cursor_end = cursor_pos
+    matches = []

xeus_python_shell/completer.py

@@ -0,0 +1,37 @@
+import sys
+
+from IPython.core.displaypub import DisplayPublisher
+from IPython.core.displayhook import DisplayHook
+
+
+class XDisplayPublisher(DisplayPublisher):
+    def publish(
+            self, data, metadata=None, source=None, *,
+            transient=None, update=False, **kwargs
+            ) -> None:
+        publish_display_data(data, metadata, transient, update)
+
+    def clear_output(self, wait=False):
+        clear_output(wait)
+
+
+class XDisplayHook(DisplayHook):
+    def start_displayhook(self):
+        self.data = {}
+        self.metadata = {}
+
+    def write_output_prompt(self):
+        pass
+
+    def write_format_data(self, format_dict, md_dict=None):
+        self.data = format_dict
+        self.metadata = md_dict
+
+    def finish_displayhook(self):
+        sys.stdout.flush()
+        sys.stderr.flush()
+
+        publish_execution_result(self.prompt_count, self.data, self.metadata)
+
+        self.data = {}
+        self.metadata = {}

xeus_python_shell/display.py

@@ -0,0 +1,97 @@
+import sys
+
+from IPython.core.interactiveshell import InteractiveShell
+from IPython.core.shellapp import InteractiveShellApp
+from IPython.core.application import BaseIPythonApplication
+from IPython.core import page, payloadpage
+from IPython.core.completer import provisionalcompleter, rectify_completions
+
+from .compiler import XCachingCompiler
+from .display import XDisplayPublisher, XDisplayHook
+
+
+class XKernel():
+    def __init__(self):
+        self.comm_manager = CommManager()
+
+    def get_parent(self):
+        return get_parent_header()
+
+    @property
+    def _parent_header(self):
+        return self.get_parent()
+
+
+class XPythonShell(InteractiveShell):
+    def __init__(self, *args, **kwargs):
+        super(XPythonShell, self).__init__(*args, **kwargs)
+
+        self.kernel = XKernel()
+
+    def enable_gui(self, gui=None):
+        """Not implemented yet."""
+        pass
+
+    def init_hooks(self):
+        super(XPythonShell, self).init_hooks()
+        self.set_hook('show_in_pager', page.as_hook(payloadpage.page), 99)
+
+    # Workaround for preventing IPython to show error traceback
+    # in the console, we catch it and will display it later
+    def _showtraceback(self, etype, evalue, stb):
+        self.last_error = [str(etype), str(evalue), stb]
+
+    def complete_code(self, code, cursor_pos):
+        with provisionalcompleter():
+            raw_completions = self.Completer.completions(code, cursor_pos)
+            completions = list(rectify_completions(code, raw_completions))
+
+            comps = []
+            for comp in completions:
+                comps.append(dict(
+                    start=comp.start,
+                    end=comp.end,
+                    text=comp.text,
+                    type=comp.type,
+                ))
+
+        if completions:
+            cursor_start = completions[0].start
+            cursor_end = completions[0].end
+            matches = [c.text for c in completions]
+        else:
+            cursor_start = cursor_pos
+            cursor_end = cursor_pos
+            matches = []
+
+        return matches, cursor_start, cursor_end
+
+
+class XPythonShellApp(BaseIPythonApplication, InteractiveShellApp):
+    def initialize(self, argv=None):
+        super(XPythonShellApp, self).initialize(argv)
+
+        self.user_ns = {}
+
+        # self.init_io() ?
+
+        self.init_path()
+        self.init_shell()
+
+        self.init_extensions()
+        self.init_code()
+
+        sys.stdout.flush()
+        sys.stderr.flush()
+
+    def init_shell(self):
+        self.shell = XPythonShell.instance(
+            display_pub_class=XDisplayPublisher,
+            displayhook_class=XDisplayHook,
+            compiler_class=XCachingCompiler,
+            user_ns=self.user_ns
+        )
+
+    # Overwrite exit logic, this is not part of the kernel protocol
+    def exit(self, exit_status=0):
+        pass