Initial commit.

Author: mrstegeman

.gitignore

@@ -0,0 +1,6 @@
+*.pyc
+*.swp
+*.tgz
+lib/
+package/
+SHA256SUMS

CODE_OF_CONDUCT.md

@@ -0,0 +1,15 @@
+# Community Participation Guidelines
+
+This repository is governed by Mozilla's code of conduct and etiquette guidelines. 
+For more details, please read the
+[Mozilla Community Participation Guidelines](https://www.mozilla.org/about/governance/policies/participation/). 
+
+## How to Report
+For more information on how to report violations of the Community Participation Guidelines, please read our '[How to Report](https://www.mozilla.org/about/governance/policies/participation/reporting/)' page.
+
+<!--
+## Project Specific Etiquette
+
+In some cases, there will be additional project etiquette i.e.: (https://bugzilla.mozilla.org/page.cgi?id=etiquette.html).
+Please update for your project.
+-->

LICENSE

@@ -0,0 +1,25 @@
+# tide-calendar-adapter
+
+Tide calendar adapter for Mozilla WebThings Gateway.
+
+# Configuration
+
+To configure the adapter, navigate to _Settings -> Add-ons_ in the user interface and click the _Configure_ button on the entry for this adapter.
+
+## Stations
+
+Each station is a numeric station ID. You can find the station ID by searching on [this website](https://tidesandcurrents.noaa.gov/) for the station closest to you.
+
+## Unit
+
+This is the tide level unit you want, either feet (english) or meters (metric).
+
+# Requirements
+
+If you're running this add-on outside of the official gateway image for the Raspberry Pi, i.e. you're running on a development machine, you'll need to do the following (adapt as necessary for non-Ubuntu/Debian):
+
+```
+sudo apt install python3-dev libnanomsg-dev
+sudo pip3 install nnpy
+sudo pip3 install git+https://github.com/mozilla-iot/gateway-addon-python.git
+```

README.md

@@ -0,0 +1,45 @@
+"""Tide calendar adapter for Mozilla WebThings Gateway."""
+
+from os import path
+import functools
+import gateway_addon
+import signal
+import sys
+import time
+
+sys.path.append(path.join(path.dirname(path.abspath(__file__)), 'lib'))
+
+from pkg.tide_calendar_adapter import TideCalendarAdapter  # noqa
+
+
+_API_VERSION = {
+    'min': 2,
+    'max': 2,
+}
+_ADAPTER = None
+
+print = functools.partial(print, flush=True)
+
+
+def cleanup(signum, frame):
+    """Clean up any resources before exiting."""
+    if _ADAPTER is not None:
+        _ADAPTER.close_proxy()
+
+    sys.exit(0)
+
+
+if __name__ == '__main__':
+    if gateway_addon.API_VERSION < _API_VERSION['min'] or \
+            gateway_addon.API_VERSION > _API_VERSION['max']:
+        print('Unsupported API version.')
+        sys.exit(0)
+
+    signal.signal(signal.SIGINT, cleanup)
+    signal.signal(signal.SIGTERM, cleanup)
+    _ADAPTER = TideCalendarAdapter(verbose=True)
+
+    # Wait until the proxy stops running, indicating that the gateway shut us
+    # down.
+    while _ADAPTER.proxy_running():
+        time.sleep(2)

main.py

@@ -0,0 +1,71 @@
+{
+  "name": "tide-calendar-adapter",
+  "display_name": "Tide Calendar",
+  "version": "0.1.0",
+  "description": "Tide calendar for Mozilla WebThings Gateway",
+  "author": "Mozilla IoT",
+  "main": "main.py",
+  "keywords": [
+    "mozilla",
+    "iot",
+    "adapter",
+    "tide",
+    "noaa"
+  ],
+  "homepage": "https://github.com/mozilla-iot/tide-calendar-adapter",
+  "license": "MPL-2.0",
+  "repository": {
+    "type": "git",
+    "url": "https://github.com/mozilla-iot/tide-calendar-adapter.git"
+  },
+  "bugs": {
+    "url": "https://github.com/mozilla-iot/tide-calendar-adapter/issues"
+  },
+  "files": [
+    "LICENSE",
+    "SHA256SUMS",
+    "lib",
+    "main.py",
+    "pkg/__init__.py",
+    "pkg/tide_calendar_adapter.py",
+    "pkg/tide_calendar_device.py",
+    "pkg/tide_calendar_property.py",
+    "pkg/util.py"
+  ],
+  "moziot": {
+    "api": {
+      "min": 2,
+      "max": 2
+    },
+    "plugin": true,
+    "exec": "python3 {path}/main.py",
+    "config": {
+      "stations": [],
+      "unit": "ft"
+    },
+    "schema": {
+      "type": "object",
+      "required": [
+        "stations",
+        "unit"
+      ],
+      "properties": {
+        "stations": {
+          "type": "array",
+          "description": "List of NOAA station IDs",
+          "items": {
+            "type": "integer"
+          }
+        },
+        "unit": {
+          "type": "string",
+          "description": "Water level unit system",
+          "enum": [
+            "english",
+            "metric"
+          ]
+        }
+      }
+    }
+  }
+}

package.json

@@ -0,0 +1,31 @@
+#!/bin/bash
+
+set -e
+
+version=$(grep version package.json | cut -d: -f2 | cut -d\" -f2)
+
+# Clean up from previous releases
+rm -rf *.tgz package
+rm -f SHA256SUMS
+rm -rf lib
+
+# Prep new package
+mkdir lib
+mkdir package
+
+# Pull down Python dependencies
+pip3 install -r requirements.txt -t lib --no-binary pyHS100 --prefix ""
+
+# Put package together
+cp -r lib pkg LICENSE package.json *.py package/
+find package -type f -name '*.pyc' -delete
+find package -type d -empty -delete
+
+# Generate checksums
+cd package
+sha256sum *.py pkg/*.py LICENSE > SHA256SUMS
+find lib -type f -exec sha256sum {} \; >> SHA256SUMS
+cd -
+
+# Make the tarball
+tar czf "tide-calendar-adapter-${version}.tgz" package

package.sh

@@ -0,0 +1 @@
+"""Make this a package."""

pkg/__init__.py

@@ -0,0 +1,63 @@
+"""Tide calendar adapter for Mozilla WebThings Gateway."""
+
+from gateway_addon import Adapter, Database
+
+from .tide_calendar_device import TideCalendarDevice, StationException
+
+
+class TideCalendarAdapter(Adapter):
+    """Adapter for NOAA tide calendars."""
+
+    def __init__(self, verbose=False):
+        """
+        Initialize the object.
+
+        verbose -- whether or not to enable verbose logging
+        """
+        self.name = self.__class__.__name__
+        Adapter.__init__(self,
+                         'tide-calendar-adapter',
+                         'tide-calendar-adapter',
+                         verbose=verbose)
+
+        self.pairing = False
+        self.start_pairing()
+
+    def start_pairing(self, timeout=None):
+        """
+        Start the pairing process.
+
+        timeout -- Timeout in seconds at which to quit pairing
+        """
+        if self.pairing:
+            return
+
+        self.pairing = True
+
+        database = Database('tide-calendar-adapter')
+        if not database.open():
+            return
+
+        config = database.load_config()
+        database.close()
+
+        if not config or 'stations' not in config or 'unit' not in config:
+            return
+
+        unit = config['unit']
+
+        for station in config['stations']:
+            _id = 'tide-calendar-{}'.format(station)
+            if _id not in self.devices:
+                try:
+                    device = TideCalendarDevice(self, _id, station, unit)
+                except StationException as e:
+                    print(e)
+                else:
+                    self.handle_device_added(device)
+
+        self.pairing = False
+
+    def cancel_pairing(self):
+        """Cancel the pairing process."""
+        self.pairing = False