initial working library

Author: jwcooper

.gitignore

@@ -0,0 +1,30 @@
+#Useful gitignore for python: https://github.com/github/gitignore/blob/master/Python.gitignore
+*.py[cod]
+
+# C extensions
+*.so
+
+# Packages
+*.egg
+*.egg-info
+dist
+build
+eggs
+parts
+bin
+var
+sdist
+develop-eggs
+.installed.cfg
+lib
+lib64
+__pycache__
+distribute-0.*
+
+# Unit test / coverage reports
+.coverage
+.tox
+nosetests.xml
+
+# Translations
+*.mo

CHANGELOG.md

@@ -0,0 +1,3 @@
+0.0.1
+----
+Initial Changelog

LICENSE.md

@@ -0,0 +1,23 @@
+Copyright (c) 2014 Adafruit
+Author: Justin Cooper
+
+MIT License
+
+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.

LICENSE.txt

@@ -0,0 +1,15 @@
+publish: clean
+	python setup.py sdist upload
+
+clean:
+	#rm -rf Adafruit_BBIO.* build dist
+	rm -f *.pyo
+	rm -f *.egg
+tests:
+	py.test
+
+build:
+	python setup.py build --force
+
+install: build
+	python setup.py install --force

Makefile

@@ -0,0 +1,45 @@
+# Adafruit_IO
+
+TODO: Write a description
+
+## Installation
+
+    pip install Adafruit_IO
+
+## Usage
+
+  Easiest
+  
+    from Adafruit_IO import Client
+    aio = Client('unique_key_id')
+    #data can be of any type, string, number, hash, json
+    aio.send("Feed Name", data)
+
+    #You can also receive data easily:
+    value = aio.receive("Feed Name")
+
+    #It will ge the next input available, and mark it as read.
+
+
+  Advanced
+
+    from Adafruit_IO import Client
+    aio = Client('unique_key_id')
+
+    #get all of your feeds for the key
+    aio.feeds
+
+    #get a specific feed using ID or Name
+    aio.feeds(3)
+    aio.feeds("feed name")
+
+    #create a feed
+    aio.create_feed({:name => "New Feed Name", ...})
+
+## Contributing
+
+1. Fork it ( http://github.com/adafruit/io-client-python/fork )
+2. Create your feature branch (`git checkout -b my-new-feature`)
+3. Commit your changes (`git commit -am 'Add some feature'`)
+4. Push to the branch (`git push origin my-new-feature`)
+5. Create new Pull Request

README.md

@@ -0,0 +1 @@
+from .client import Client

adafruit_io/__init__.py

@@ -0,0 +1,78 @@
+import json
+
+from urllib3 import connection_from_url
+from urllib import urlencode, quote
+
+#fork of ApiClient Class: https://github.com/shazow/apiclient
+class Client(object):
+  BASE_URL = 'http://localhost:3002/'
+
+  def __init__(self, key, rate_limit_lock=None):
+    self.key = key
+    self.rate_limit_lock = rate_limit_lock
+    self.connection_pool = self._make_connection_pool(self.BASE_URL)
+
+  def _make_connection_pool(self, url):
+    return connection_from_url(url)
+
+  def _compose_url(self, path):
+    return self.BASE_URL + path
+
+  def _compose_get_url(self, path, params=None):
+    return self.BASE_URL + path + '?' + urlencode(params)
+
+  def _handle_response(self, response):
+    return json.loads(response.data)
+
+  def _request(self, method, path, params=None):
+    if (method.lower() == "get"):
+      url = self._compose_get_url(path, params)
+    else:
+      url = self._compose_url(path)
+
+    self.rate_limit_lock and self.rate_limit_lock.acquire()
+    headers = {"X-Api-Key": self.key, 'Content-Type':'application/json'}
+    if (method.upper() == "GET"):
+      r = self.connection_pool.urlopen(method.upper(), url, headers=headers)
+    else:
+      r = self.connection_pool.urlopen(method.upper(), url, headers=headers, body=json.dumps(params))
+      
+    return self._handle_response(r)
+
+  def _get(self, path, **params):
+    return self._request('GET', path, params=params)
+
+  def _post(self, path, params):
+    return self._request('POST', path, params=params)
+
+  def send(self, feed_name, data):
+    feed_name = quote(feed_name)
+    path = "api/feeds/{}/streams/send".format(feed_name)
+    return self._post(path, {'value': data})
+
+  def receive(self, feed_name):
+    feed_name = quote(feed_name)
+    path = "api/feeds/{}/streams/last".format(feed_name)
+    return self._get(path)
+
+  def receive_next(self, feed_name):
+    feed_name = quote(feed_name)
+    path = "api/feeds/{}/streams/next".format(feed_name)
+    return self._get(path)
+
+  def receive_previous(self, feed_name):
+    feed_name = quote(feed_name)
+    path = "api/feeds/{}/streams/last".format(feed_name)
+    return self._get(path)
+
+  def streams(self, feed_id_or_key, stream_id=None):
+    if stream_id is None:
+      path = "api/feeds/{}/streams".format(feed_id_or_key)
+    else:
+      path = "api/feeds/{}/streams/{}".format(feed_id_or_key, stream_id)
+    return self._get(path)
+
+  def create_stream(self, feed_id_or_key, data):
+    path = "api/feeds/{}/streams".format(feed_id_or_key)
+    return self._post(path, data)
+

adafruit_io/client.py

@@ -5,10 +5,12 @@
     version='0.0.1',
     author='Justin Cooper',
     author_email='justin@adafruit.com',
-    packages=['adafruit_io'],
+    packages=['Adafruit_IO'],
     url='http://pypi.python.org/pypi/adafruit_io/',
     license='LICENSE.txt',
     description='IO Client library for io.adafruit.com',
     long_description=open('README.md').read(),
-    install_requires=[],
+    install_requires=[
+        "apiclient >= 1.0.2"
+    ],
 )

setup.py

@@ -0,0 +1,11 @@
+from Adafruit_IO import Client
+io = Client('e2b0fac48ae32f324df4aa05247c16e991494b08')
+
+r = io.send("Test Python", 12)
+print r
+
+r = io.receive("Test Python")
+print r
+
+r = io.receive_next("Test Python")
+print r

test.py

@@ -0,0 +1,12 @@
+import pytest
+
+from Adafruit_IO import Client
+
+def teardown_module(module):
+  pass
+
+class TestSetup:    
+  def test_set_key(self):
+    key = "unique_key_id"
+    io = Client(key)
+    assert key == io.key