modifying code for pep 8 compliance

1 files changed, 71 insertions, 35 deletions

diff --git a/python/examples/dev-console.py b/python/examples/dev-console.py
index 383fa68..7814cef 100755
--- a/python/examples/dev-console.py
+++ b/python/examples/dev-console.py
@@ -1,4 +1,4 @@
-## www.pubnub.com - PubNub Real-time push service in the cloud. 
+## www.pubnub.com - PubNub Real-time push service in the cloud.
 # coding=utf8
 
 ## PubNub Real-time Push APIs and Notifications Framework
@@ -55,41 +55,55 @@ parser.add_option("--uuid",
 
 print(options)
 
-pubnub = Pubnub(options.publish_key, options.subscribe_key, options.secret_key, options.cipher_key, options.auth_key, options.ssl, options.origin, options.uuid)
+pubnub = Pubnub(options.publish_key,
+                options.subscribe_key,
+                options.secret_key,
+                options.cipher_key,
+                options.auth_key,
+                options.ssl,
+                options.origin,
+                options.uuid)
 
 
 class color:
-   PURPLE = '\033[95m'
-   CYAN = '\033[96m'
-   DARKCYAN = '\033[36m'
-   BLUE = '\033[94m'
-   GREEN = '\033[92m'
-   YELLOW = '\033[93m'
-   RED = '\033[91m'
-   BOLD = '\033[1m'
-   UNDERLINE = '\033[4m'
-   END = '\033[0m'
+    PURPLE = '\033[95m'
+    CYAN = '\033[96m'
+    DARKCYAN = '\033[36m'
+    BLUE = '\033[94m'
+    GREEN = '\033[92m'
+    YELLOW = '\033[93m'
+    RED = '\033[91m'
+    BOLD = '\033[1m'
+    UNDERLINE = '\033[4m'
+    END = '\033[0m'
 
 from datetime import datetime
 
+
 def print_ok(msg, channel=None):
-    chstr = color.PURPLE + "[" + datetime.now().strftime('%Y-%m-%d %H:%M:%S') + "] " + color.END
-    chstr += color.CYAN + "[Channel : " + channel + "] " if channel is not None else "" + color.END
+    chstr = color.PURPLE + "[" + datetime.now().strftime(
+        '%Y-%m-%d %H:%M:%S') + "] " + color.END
+    chstr += color.CYAN + "[Channel : " + channel + \
+        "] " if channel is not None else "" + color.END
     try:
-        print(chstr + color.GREEN +  str(msg) + color.END)
+        print(chstr + color.GREEN + str(msg) + color.END)
     except Exception as e:
         print(msg)
 
+
 def print_error(msg, channel=None):
-    chstr = color.PURPLE + "[" + datetime.now().strftime('%Y-%m-%d %H:%M:%S') + "] " + color.END
-    chstr += color.CYAN + "[Channel : " + channel + "] " if channel is not None else "" + color.END
+    chstr = color.PURPLE + "[" + datetime.now().strftime(
+        '%Y-%m-%d %H:%M:%S') + "] " + color.END
+    chstr += color.CYAN + "[Channel : " + channel + \
+        "] " if channel is not None else "" + color.END
     try:
-        print( chstr + color.RED + color.BOLD +str(msg) + color.END)
+        print(chstr + color.RED + color.BOLD + str(msg) + color.END)
     except:
         print(msg)
 
 import threading
 
+
 def kill_all_threads():
     for thread in threading.enumerate():
         if thread.isAlive():
@@ -101,6 +115,7 @@ def kill_all_threads():
                 #thread.exit()
                 #print(str(thread.getName()) + ' could not be terminated')
 
+
 def get_input(message, t=None):
     while True:
         try:
@@ -117,7 +132,8 @@ def get_input(message, t=None):
                 raise ValueError
 
             if t is not None and t == bool:
-                if command in ["True", "true", "1", 1, "y", "Y", "yes", "Yes", "YES"]:
+                valid = ["True", "true", "1", 1, "y", "Y", "yes", "Yes", "YES"]
+                if command in valid:
                     return True
                 else:
                     return False
@@ -131,18 +147,20 @@ def get_input(message, t=None):
             print_error("Invalid input : " + command)
 
 
-
 def _publish_command_handler():
 
     channel = get_input("[PUBLISH] Enter Channel Name ", str)
     if channel is None:
         return
     while True:
-        message = get_input("[PUBLISH] Enter Message ( QUIT or CTRL-C for exit from publish mode ) ")
-        if message == 'QUIT' or message == 'quit' or message == None:
-            return  
+        message = get_input("[PUBLISH] Enter Message \
+            ( QUIT or CTRL-C for exit from publish mode ) ")
+        if message == 'QUIT' or message == 'quit' or message is None:
+            return
+
         def _callback(r):
             print_ok(r)
+
         def _error(r):
             print_error(r)
         pubnub.publish(channel, message, _callback, _error)
@@ -150,23 +168,30 @@ def _publish_command_handler():
 
 def _subscribe_command_handler():
     channel = get_input("[SUBSCRIBE] Enter Channel Name ", str)
+
     def _callback(r):
         print_ok(r, channel)
+
     def _error(r):
         print_error(r, channel)
     pubnub.subscribe(channel, _callback, _error)
 
+
 def _unsubscribe_command_handler():
     channel = get_input("[UNSUBSCRIBE] Enter Channel Name ", str)
+
     def _callback(r):
         print_ok(r)
+
     def _error(r):
         print_error(r)
     pubnub.unsubscribe(channel)
 
+
 def _grant_command_handler():
     def _callback(r):
         print_ok(r)
+
     def _error(r):
         print_error(r)
     channel = get_input("[GRANT] Enter Channel Name ", str)
@@ -174,11 +199,13 @@ def _grant_command_handler():
     ttl = get_input("[GRANT] Enter ttl ", int)
     read = get_input("[GRANT] Read ? ", bool)
     write = get_input("[GRANT] Write ? ", bool)
-    pubnub.grant(channel, auth_key,read,write,ttl, _callback)
+    pubnub.grant(channel, auth_key, read, write, ttl, _callback)
+
 
 def _revoke_command_handler():
     def _callback(r):
         print_ok(r)
+
     def _error(r):
         print_error(r)
     channel = get_input("[REVOKE] Enter Channel Name ", str)
@@ -187,18 +214,22 @@ def _revoke_command_handler():
 
     pubnub.revoke(channel, auth_key, ttl, _callback)
 
+
 def _audit_command_handler():
     def _callback(r):
         print_ok(r)
+
     def _error(r):
         print_error(r)
     channel = get_input("[AUDIT] Enter Channel Name ", str)
     auth_key = get_input("[AUDIT] Enter Auth Key ", str)
     pubnub.audit(channel, auth_key, _callback)
 
+
 def _history_command_handler():
     def _callback(r):
         print_ok(r)
+
     def _error(r):
         print_error(r)
     channel = get_input("[HISTORY] Enter Channel Name ", str)
@@ -210,6 +241,7 @@ def _history_command_handler():
 def _here_now_command_handler():
     def _callback(r):
         print_ok(r)
+
     def _error(r):
         print_error(r)
     channel = get_input("[HERE NOW] Enter Channel Name ", str)
@@ -218,28 +250,32 @@ def _here_now_command_handler():
 
 
 commands = []
-commands.append({"command" : "publish", "handler" : _publish_command_handler})
-commands.append({"command" : "subscribe", "handler" : _subscribe_command_handler})
-commands.append({"command" : "unsubscribe", "handler" : _unsubscribe_command_handler})
-commands.append({"command" : "here_now", "handler" : _here_now_command_handler})
-commands.append({"command" : "history", "handler" : _history_command_handler})
-commands.append({"command" : "grant", "handler" : _grant_command_handler})
-commands.append({"command" : "revoke", "handler" : _revoke_command_handler})
-commands.append({"command" : "audit", "handler" : _audit_command_handler})
+commands.append({"command": "publish", "handler": _publish_command_handler})
+commands.append(
+    {"command": "subscribe", "handler": _subscribe_command_handler})
+commands.append(
+    {"command": "unsubscribe", "handler": _unsubscribe_command_handler})
+commands.append(
+    {"command": "here_now", "handler": _here_now_command_handler})
+commands.append({"command": "history", "handler": _history_command_handler})
+commands.append({"command": "grant", "handler": _grant_command_handler})
+commands.append({"command": "revoke", "handler": _revoke_command_handler})
+commands.append({"command": "audit", "handler": _audit_command_handler})
 
 # last command is quit. add new commands before this line
-commands.append({"command" : "QUIT"})
+commands.append({"command": "QUIT"})
+
 
 def get_help():
     help = ""
     help += "Channels currently subscribed to : "
     help += str(pubnub.get_channel_array())
     help += "\n"
-    for i,v in enumerate(commands):
+    for i, v in enumerate(commands):
         help += "Enter " + str(i) + " for " + v['command'] + "\n"
     return help
 
-            
+
 while True:
     command = get_input(color.BLUE + get_help(), int)
     if command == len(commands) - 1 or command is None: