Merge pull request #27 from DevoInc/release-next

[1.5.1] - 2018-12-28

Author: Worvast

.travis.yml

@@ -1,10 +1,16 @@
 language: python
 python:
-  - "2.7"
-  - "3.6"
+- '2.7'
+- '3.6'
 install:
-  - pip install .
-  - pip install pyyaml
-# command to run tests
+- pip install .
+- pip install pyyaml
 script:
-  - python run_tests.py
+- python run_tests.py
+deploy:
+  provider: pypi
+  user: worvast
+  password:
+    secure: J3YPGEaDHD1H9pVQscrh4J2U18ptq8pM5UsjIKGe6WGlgiTMhR+WYRcdQSFIGSyKZMkdnLavSuvImcUzBSL6L3WqarRZ6HBgGXtxxHRVNmk96ZZlBN5qq0AUJzHN61x5JbG+OWzJMZE1HDo6zcD36KvaIAfKu3AyaEYeVes54PY5cLC/JH/HooOP0FS643kbttkiTYKmEajJiCgu/SiXH5dtfuz5GO0CXrEp0ww+FtcTmC9T9txyjS+IBIvbNPHJC9M5jg6bgu214fCIr5iGNZ8LQulRskBOsqhCRbyyWjuF0wgl3Dkefa0z3YJpl2KYHYW0bT0UY2J8WXnE66NT6js2sv/mNdcRAZjjzugcr9mr11FrLazIjNJwDwlSTtuNoys4E449wQZfQ4vUsUANwnsXQJAdujANS8O2Yuk65uIlgnNpYBxXI71OPYZ6dzhDOsAcwlUrS9jZi2+UWGtOXoZX3i3qLWwBHEASXNSN2WLZOVj3lTEyBB7WCbBqDANHCRLrkyHMrUkOP9ptE7lvATCVfHIO2axsaxNJRKHI6W53p+6uMRAt9u0LIKBB4hyZMo51j7xkq6uO4cQt2CINVU24gYajcalswtJ/Cr0onj26xx2g/xq19sU1L7rpp8OZGFnLPHptxV3ezTlhdk86ZfwOQI1TC4KPAQlRZARDeSk=
+  on:
+    tags: true

CHANGELOG.md

@@ -4,7 +4,16 @@ All notable changes to this project will be documented in this file.
 The format is based on [Keep a Changelog](http://keepachangelog.com/en/1.0.0/)
 and this project adheres to [Semantic Versioning](http://semver.org/spec/v2.0.0.html).
 
-## [1.5.0]
+
+## [1.5.1] - 2018-12-28
+#### Fixed
+ * devo.common buffer now receive data when CSV response
+ * devo.common buffer.is_empty
+
+#### Added
+ * Travis CI deploy automatic options
+
+## [1.5.0] - 2018-12-27
 #### Changed
  * Modify Configuration loads functions
  * Now Sender send, send_raw, flush_buffer and fill_buffer return the number of lines sent
@@ -13,7 +22,7 @@ and this project adheres to [Semantic Versioning](http://semver.org/spec/v2.0.0.
  * Problems when loads configuration from default sites
  * Problems with local_server
 
-## [1.4.0]
+## [1.4.0] - 2018-12-17
 #### Added
  * Allow the parameters user, application name and comment to queries
  * Add tests (test_pragmas and test_pragmas test_pragmas_not_comment_free) in the query.py file.

README.md

@@ -1,7 +1,7 @@
 
 [![master Build Status](https://travis-ci.com/DevoInc/python-sdk.svg?branch=master)](https://travis-ci.com/DevoInc/python-sdk) [![LICENSE](https://img.shields.io/dub/l/vibe-d.svg)](https://github.com/DevoInc/python-sdk/blob/master/LICENSE)
 
-[![wheel](https://img.shields.io/badge/wheel-yes-brightgreen.svg)](https://pypi.org/project/devo-sdk/) [![version](https://img.shields.io/badge/version-1.5.0-blue.svg)](https://pypi.org/project/devo-sdk/) [![python](https://img.shields.io/badge/python-2.7%20%7C%203.3%20%7C%203.4%20%7C%203.5%20%7C%203.6%20%7C%203.7-blue.svg)](https://pypi.org/project/devo-sdk/)
+[![wheel](https://img.shields.io/badge/wheel-yes-brightgreen.svg)](https://pypi.org/project/devo-sdk/) [![version](https://img.shields.io/badge/version-1.5.1-blue.svg)](https://pypi.org/project/devo-sdk/) [![python](https://img.shields.io/badge/python-2.7%20%7C%203.3%20%7C%203.4%20%7C%203.5%20%7C%203.6%20%7C%203.7-blue.svg)](https://pypi.org/project/devo-sdk/)
 
 
 # Devo Python SDK

devo/__version__.py

@@ -1,6 +1,6 @@
 __description__ = 'Devo Python Library.'
 __url__ = 'http://www.devo.com'
-__version__ = "1.5.0"
+__version__ = "1.5.1"
 __author__ = 'Devo'
 __author_email__ = 'support@devo.com'
 __license__ = 'MIT'

devo/api/client.py

@@ -194,7 +194,7 @@ def query(self, **kwargs):
             self.connect()
 
         if self.buffer is None:
-            self.buffer = Buffer()
+            self.buffer = Buffer(api_response=opts['response'])
         self.buffer.create_thread(
             target=self._call_stream,
             kwargs=({'payload': self._get_payload(query, query_id,

devo/common/data/buffer.py

@@ -15,13 +15,14 @@ class DevoBufferException(Exception):
 
 class Buffer(object):
     """ Simple Buffer class """
-    def __init__(self, buffer_max_size=1000):
+    def __init__(self, buffer_max_size=1000, api_response="json/compact"):
         self.queue = Queue.Queue(maxsize=buffer_max_size)
         self.thread = None
         self.temp = None
         self.error = None
         self.close = False
         self.timeout = 0
+        self.response_split = "\n" if api_response is "csv" else "\r\n "
 
     def is_alive(self):
         return self.thread.isAlive()
@@ -30,7 +31,7 @@ def set_timeout(self, timeout):
         self.timeout = timeout
 
     def is_empty(self):
-        return True if self.size() > 0 else False
+        return True if self.size() < 0 else False
 
     def create_thread(self, target, kwargs):
         """ Function for create one separate thread for Queue"""
@@ -77,7 +78,7 @@ def proccess_recv(self, data):
         if not isinstance(data, str):
             data = data.decode('utf8')
 
-        data = data[data.find("\r\n") + 2:].split("\r\n ")
+        data = data[data.find("\r\n") + 2:].split(self.response_split)
 
         data_len = len(data)
         if self.temp is not None: