pep8 fixes (#16)

Author: lwalter86

.gitignore

@@ -55,3 +55,6 @@ docs/_build/
 
 # PyBuilder
 target/
+
+# VisualStudio Code
+.vscode

.travis.yml

@@ -16,5 +16,5 @@ install:
 # command to run tests
 script:
   - flake8 --version
-  - flake8 numpy_buffer samples test
+  - flake8 --ignore E501 numpy_buffer samples test
   - nosetests

numpy_buffer/__init__.py

@@ -1,3 +1,3 @@
 #!/usr/bin/env python
 
-from .ring import RingBuffer
+from .ring import RingBuffer  # noqa

numpy_buffer/ring.py

@@ -2,6 +2,7 @@
 
 import numpy as np
 
+
 class RingBuffer(object):
     def __init__(self, size_max, default_value=0.0, dtype=float, overflow=None):
         """initialization"""
@@ -28,23 +29,23 @@ def clear(self, size_max=None, default_value=None, dtype=None, overflow=None):
             if len(default_value) == size_max:
                 self._data = default_value
             else:
-                raise(NotImplementedError("len(default_value)=%d but size_max=%d",
-                    " but they should be equal" % (len(default_value), size_max)))
+                msg = "len(default_value)=%d but size_max=%d, but they should be equal" % (len(default_value), size_max)
+                raise NotImplementedError(msg)
 
         self.size = 0
-        
+
         self.full = False
-        self.append = self._append_not_full        
+        self.append = self._append_not_full
 
     def _append_not_full(self, value):
         """append an element"""
         self._data = np.roll(self._data, 1)
-        self._data[0] = value 
+        self._data[0] = value
 
         self.size += 1
-                
+
         if self.size == self.size_max:
-            self.full  = True
+            self.full = True
             self.append = self._append_full
             self.overflow = self.overflow(self)
 
@@ -53,20 +54,19 @@ def _append_full(self, value):
         self._data = np.roll(self._data, 1)
         self._data[0] = value
 
-
     @property
     def all(self):
         """return a list of elements from the oldest to the newest (len: size_max)"""
         return self._data
-        
+
     @property
     def partial(self):
         """return a list of elements from the oldest to the newest (len: size)"""
         return self.all[0:self.size]
 
     def view(self, *args, **kwargs):
         return self.partial[::-1].view(*args, **kwargs)
-    
+
     def __len__(self):
         """return size (not size_max)"""
         return self.size
@@ -81,11 +81,10 @@ def __repr__(self):
     all:     %s
     partial: %s
     size/size_max: %d / %d
->""" % (self.__class__.__name__, 
-    self.all.__repr__(), 
-    self.partial.__repr__(),
-    self.size, self.size_max
-)
+>""" % (self.__class__.__name__,
+            self.all.__repr__(),
+            self.partial.__repr__(),
+            self.size, self.size_max)
         return s
 
     def overflow(self, *args, **kwargs):

samples/mqtt_publish.py

@@ -1,34 +1,36 @@
 #!/usr/bin/env python
- 
+
 import mosquitto
 from mqtt_settings import config
-import time
 import datetime
 import pytz
 import numpy as np
 import json
 
+
 def on_message(mosq, obj, msg):
     print("%-20s %d %s" % (msg.topic, msg.qos, msg.payload))
     mosq.publish('pong', "Thanks", 0)
- 
+
+
 def on_publish(mosq, obj, mid):
     print("publish %s %s %s" % (mosq, obj, mid))
 
+
 def main():
     cli = mosquitto.Mosquitto()
     cli.on_message = on_message
     cli.on_publish = on_publish
 
-    #cli.tls_set('root.ca',
-    #certfile='c1.crt',
-    #keyfile='c1.key')
+    # cli.tls_set('root.ca',
+    # certfile='c1.crt',
+    # keyfile='c1.key')
 
-    #cli.username_pw_set("guigui", password="abloc")
+    # cli.username_pw_set("guigui", password="abloc")
 
     cli.connect(config['host'], config['port'], config['keepalive'])
- 
-    y = 100 # initial value
+
+    y = 100  # initial value
 
     while cli.loop() == 0:
         now = datetime.datetime.now(pytz.utc)
@@ -39,10 +41,9 @@ def main():
                 'y': y
             }
         }
-        payload = json.dumps(data) # serialization
+        payload = json.dumps(data)  # serialization
         cli.publish(topic='/sensors/sensor01', payload=payload, qos=0, retain=False)
-        #time.sleep(1)
-        #print("wait")
+
 
 if __name__ == '__main__':
     main()

samples/mqtt_subscribe.py

@@ -1,41 +1,44 @@
 #!/usr/bin/env python
- 
+
 import mosquitto
 import json
 from mqtt_settings import config
-from numpy_buffer import RingBuffer
 import datetime
 import pytz
 import dateutil.parser
 
+
 def on_message(mosq, obj, msg):
-    data = json.loads(msg.payload.decode("utf-8")) # deserialization
-    sent = dateutil.parser.parse(data['ts']) # iso 8601 to datetime.datetime
+    data = json.loads(msg.payload.decode("utf-8"))  # deserialization
+    sent = dateutil.parser.parse(data['ts'])  # iso 8601 to datetime.datetime
     data['ts'] = sent
     received = datetime.datetime.now(pytz.utc)
     lag = received - sent
     print("%-20s %d %s lag=%s" % (msg.topic, msg.qos, data, lag))
-    #mosq.publish('pong', "Thanks", 0)
- 
+    # mosq.publish('pong', "Thanks", 0)
+
+
 def on_publish(mosq, obj, mid):
     pass
 
+
 def main():
     cli = mosquitto.Mosquitto()
     cli.on_message = on_message
     cli.on_publish = on_publish
 
-    #cli.tls_set('root.ca',
-    #certfile='c1.crt',
-    #keyfile='c1.key')
+    # cli.tls_set('root.ca',
+    # certfile='c1.crt',
+    # keyfile='c1.key')
 
-    #cli.username_pw_set("guigui", password="abloc")
+    # cli.username_pw_set("guigui", password="abloc")
 
     cli.connect(config['host'], config['port'], config['keepalive'])
     cli.subscribe("/sensors/#", 0)
- 
+
     while cli.loop() == 0:
         pass
 
+
 if __name__ == '__main__':
     main()

samples/mqtt_subscribe_matplotlib.py

@@ -1,5 +1,5 @@
 #!/usr/bin/env python
- 
+
 import matplotlib.pyplot as plt
 import mosquitto
 import json
@@ -9,9 +9,11 @@
 import pytz
 import dateutil.parser
 
+
 def now():
     return datetime.datetime.now(pytz.utc)
 
+
 maxlen = 500
 data_x = RingBuffer(maxlen, now(), dtype=datetime.datetime)
 data_y = RingBuffer(maxlen)
@@ -20,14 +22,15 @@ def now():
 line, = ax.plot(data_x.all[::-1], data_y.all[::-1], linestyle='-', marker='+', color='r', markeredgecolor='b')
 ax.set_ylim([0, 100])
 
+
 def on_message(mosq, obj, msg):
-    data = json.loads(msg.payload.decode("utf-8")) # deserialization
-    sent = dateutil.parser.parse(data['ts']) # iso 8601 to datetime.datetime
+    data = json.loads(msg.payload.decode("utf-8"))  # deserialization
+    sent = dateutil.parser.parse(data['ts'])  # iso 8601 to datetime.datetime
     data['ts'] = sent
     received = now()
     lag = received - sent
     print("%-20s %d %s lag=%s" % (msg.topic, msg.qos, data, lag))
-    #mosq.publish('pong', "Thanks", 0)
+    # mosq.publish('pong', "Thanks", 0)
 
     data_x.append(sent)
     data_y.append(data['d']['y'])
@@ -40,26 +43,29 @@ def on_message(mosq, obj, msg):
     if ymax > ymin:
         ax.set_ylim([ymin, ymax])
     plt.pause(0.001)
- 
+
+
 def on_publish(mosq, obj, mid):
     pass
 
+
 def main():
     cli = mosquitto.Mosquitto()
     cli.on_message = on_message
     cli.on_publish = on_publish
 
-    #cli.tls_set('root.ca',
-    #certfile='c1.crt',
-    #keyfile='c1.key')
+    # cli.tls_set('root.ca',
+    # certfile='c1.crt',
+    # keyfile='c1.key')
 
-    #cli.username_pw_set("guigui", password="abloc")
+    # cli.username_pw_set("guigui", password="abloc")
 
     cli.connect(config['host'], config['port'], config['keepalive'])
     cli.subscribe("/sensors/#", 0)
- 
+
     while cli.loop() == 0:
         pass
 
+
 if __name__ == '__main__':
     main()

samples/sample_matplotlib_no_datetime.py

@@ -4,12 +4,13 @@
 import numpy as np
 from numpy_buffer import RingBuffer
 
+
 def main():
     maxlen = 50
-    #data_x = RingBuffer(maxlen)
+    # data_x = RingBuffer(maxlen)
     data_y = RingBuffer(maxlen)
 
-    y = 100 # initial value
+    y = 100  # initial value
 
     fig, ax = plt.subplots()
     line, = ax.plot(data_y.all[::-1])
@@ -22,5 +23,6 @@ def main():
         line.set_ydata(data_y.all[::-1])
         plt.pause(0.001)
 
+
 if __name__ == '__main__':
     main()

samples/sample_matplotlib_with_datetime.py

@@ -5,12 +5,13 @@
 import datetime
 from numpy_buffer import RingBuffer
 
+
 def main():
     maxlen = 500
     data_x = RingBuffer(maxlen, datetime.datetime.utcnow(), dtype=datetime.datetime)
     data_y = RingBuffer(maxlen)
 
-    y = 100 # initial value
+    y = 100  # initial value
 
     fig, ax = plt.subplots()
     line, = ax.plot(data_x.all[::-1], data_y.all[::-1], linestyle='-', marker='+', color='r', markeredgecolor='b')
@@ -32,5 +33,6 @@ def main():
             ax.set_ylim([ymin, ymax])
         plt.pause(0.001)
 
+
 if __name__ == '__main__':
     main()

samples/sample_pyqtgraph_no_datetime.py

@@ -1,19 +1,19 @@
 import sys
 import numpy as np
-import datetime
 
-from PyQt4.QtCore import QTime, QTimer
+from PyQt4.QtCore import QTimer
 from pyqtgraph.Qt import QtGui, QtCore
 import pyqtgraph as pg
 
-from timestamp import now_timestamp, int2dt
+from timestamp import now_timestamp
 from numpy_buffer import RingBuffer
 
+
 class MyApplication(QtGui.QApplication):
     def __init__(self, *args, **kwargs):
         super(MyApplication, self).__init__(*args, **kwargs)
-        #self.t = QTime()
-        #self.t.start()
+        # self.t = QTime()
+        # self.t.start()
 
         maxlen = 50
         self.data_x = RingBuffer(maxlen)
@@ -24,9 +24,9 @@ def __init__(self, *args, **kwargs):
         self.win.setWindowTitle('Plot with PyQtGraph')
 
         self.plot = self.win.addPlot(title='Timed data')
-        #self.plot.setYRange(0, 150)
+        # self.plot.setYRange(0, 150)
 
-        #self.curve = self.plot.plot()
+        # self.curve = self.plot.plot()
 
         pen = pg.mkPen('r', style=QtCore.Qt.SolidLine)
         self.curve = self.plot.plot(pen=pen, symbol='+')
@@ -38,16 +38,17 @@ def __init__(self, *args, **kwargs):
         self.y = 100
 
     def update(self):
-        #self.data.append({'x': self.t.elapsed(), 'y': np.random.randint(0, 100)})
+        # self.data.append({'x': self.t.elapsed(), 'y': np.random.randint(0, 100)})
         x = now_timestamp()
         self.y = self.y + np.random.uniform(-1, 1)
 
         self.data_x.append(x)
         self.data_y.append(self.y)
 
-        #self.curve.setData(x=self.data_x, y=self.data_y)
+        # self.curve.setData(x=self.data_x, y=self.data_y)
         self.curve.setData(y=self.data_y)
 
+
 def main():
     # Set PyQtGraph colors
     pg.setConfigOption('background', 'w')
@@ -59,5 +60,6 @@ def main():
     app = MyApplication(sys.argv)
     sys.exit(app.exec_())
 
+
 if __name__ == '__main__':
     main()