[Sw] Add CLI-Tool.

3.Software/CLI-Tool/.gitignore

@@ -0,0 +1,30 @@
+
+# Python Distribution / packaging
+.Python
+#env/
+#build/
+#develop-eggs/
+/dist/
+#downloads/
+#eggs/
+#.eggs/
+#lib/
+#lib64/
+#parts/
+#sdist/
+#var/
+/*.egg-info/
+#.installed.cfg
+#*.egg
+/MANIFEST
+
+# 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
+*.pyc
+
+# Installer logs
+pip-log.txt
+pip-delete-this-directory.txt

3.Software/CLI-Tool/_addition/ref_demo.py

@@ -0,0 +1,11 @@
+#!/usr/bin/env python3
+
+from __future__ import print_function
+import ref_tool
+
+# Find a connected REF-Unit (this will block until you connect one)
+print("finding an ref_tool...")
+my_drive = ref_tool.find_any()
+
+# Find an REF-Unit that is connected on the serial port /dev/ttyUSB0
+# my_drive = ref_tool.find_any("serial:/dev/ttyUSB0")

3.Software/CLI-Tool/fibre/__init__.py

@@ -0,0 +1,5 @@
+
+from .discovery import find_any, find_all
+from .utils import Event, Logger, TimeoutError
+from .protocol import ChannelBrokenException, ChannelDamagedException
+from .shell import launch_shell

3.Software/CLI-Tool/fibre/discovery.py

@@ -0,0 +1,129 @@
+"""
+Provides functions for the discovery of Fibre nodes
+"""
+
+import sys
+import json
+import time
+import threading
+import traceback
+import fibre.protocol
+import fibre.utils
+import fibre.remote_object
+from fibre.utils import Event, Logger
+from fibre.protocol import ChannelBrokenException, TimeoutError
+
+# Load all installed transport layers
+
+channel_types = {}
+
+try:
+    import fibre.usbbulk_transport
+    channel_types['usb'] = fibre.usbbulk_transport.discover_channels
+except ImportError:
+    pass
+
+try:
+    import fibre.serial_transport
+    channel_types['serial'] = fibre.serial_transport.discover_channels
+except ImportError:
+    pass
+
+try:
+    import fibre.tcp_transport
+    channel_types['tcp'] = fibre.tcp_transport.discover_channels
+except ImportError:
+    pass
+
+try:
+    import fibre.udp_transport
+    channel_types['udp'] = fibre.udp_transport.discover_channels
+except ImportError:
+    pass
+
+def noprint(text):
+    pass
+
+def find_all(path, serial_number,
+         did_discover_object_callback,
+         search_cancellation_token,
+         channel_termination_token,
+         logger):
+    """
+    Starts scanning for Fibre nodes that match the specified path spec and calls
+    the callback for each Fibre node that is found.
+    This function is non-blocking.
+    """
+
+    def did_discover_channel(channel):
+        """
+        Inits an object from a given channel and then calls did_discover_object_callback
+        with the created object
+        This queries the endpoint 0 on that channel to gain information
+        about the interface, which is then used to init the corresponding object.
+        """
+        try:
+            logger.debug("Connecting to device on " + channel._name)
+            try:
+                json_bytes = channel.remote_endpoint_read_buffer(0)
+            except (TimeoutError, ChannelBrokenException):
+                logger.debug("no response - probably incompatible")
+                return
+            json_crc16 = fibre.protocol.calc_crc16(fibre.protocol.PROTOCOL_VERSION, json_bytes)
+            channel._interface_definition_crc = json_crc16
+            try:
+                json_string = json_bytes.decode("ascii")
+            except UnicodeDecodeError:
+                logger.debug("device responded on endpoint 0 with something that is not ASCII")
+                return
+            logger.debug("JSON: " + json_string.replace('{"name"', '\n{"name"'))
+            logger.debug("JSON checksum: 0x{:02X} 0x{:02X}".format(json_crc16 & 0xff, (json_crc16 >> 8) & 0xff))
+            try:
+                json_data = json.loads(json_string)
+            except json.decoder.JSONDecodeError as error:
+                logger.debug("device responded on endpoint 0 with something that is not JSON: " + str(error))
+                return
+            json_data = {"name": "fibre_node", "members": json_data}
+            obj = fibre.remote_object.RemoteObject(json_data, None, channel, logger)
+
+            obj.__dict__['_json_data'] = json_data['members']
+            obj.__dict__['_json_crc'] = json_crc16
+
+            device_serial_number = fibre.utils.get_serial_number_str(obj)
+            if serial_number != None and device_serial_number != serial_number:
+                logger.debug("Ignoring device with serial number {}".format(device_serial_number))
+                return
+            did_discover_object_callback(obj)
+        except Exception:
+            logger.debug("Unexpected exception after discovering channel: " + traceback.format_exc())
+
+    # For each connection type, kick off an appropriate discovery loop
+    for search_spec in path.split(','):
+        prefix = search_spec.split(':')[0]
+        the_rest = ':'.join(search_spec.split(':')[1:])
+        if prefix in channel_types:
+            t = threading.Thread(target=channel_types[prefix],
+                             args=(the_rest, serial_number, did_discover_channel, search_cancellation_token, channel_termination_token, logger))
+            t.daemon = True
+            t.start()
+        else:
+            raise Exception("Invalid path spec \"{}\"".format(search_spec))
+
+
+def find_any(path="usb", serial_number=None,
+        search_cancellation_token=None, channel_termination_token=None,
+        timeout=None, logger=Logger(verbose=False)):
+    """
+    Blocks until the first matching Fibre node is connected and then returns that node
+    """
+    result = [ None ]
+    done_signal = Event(search_cancellation_token)
+    def did_discover_object(obj):
+        result[0] = obj
+        done_signal.set()
+    find_all(path, serial_number, did_discover_object, done_signal, channel_termination_token, logger)
+    try:
+        done_signal.wait(timeout=timeout)
+    finally:
+        done_signal.set() # terminate find_all
+    return result[0]