From cfe67294678f3cce56d3cade3318001cbf164cee Mon Sep 17 00:00:00 2001
From: Russell <RussellChamp@gmail.com>
Date: Fri, 8 Feb 2019 16:09:37 -0500
Subject: [PATCH] Add support for ops commands. Fixes #48

---
 pinhook/bot.py    | 38 ++++++++++++++++++++++----------------
 pinhook/plugin.py | 23 +++++++++++++++++++++--
 2 files changed, 43 insertions(+), 18 deletions(-)

diff --git a/pinhook/bot.py b/pinhook/bot.py
index bbc02dc..869be73 100644
--- a/pinhook/bot.py
+++ b/pinhook/bot.py
@@ -11,6 +11,7 @@ import irc.bot
 
 irc.client.ServerConnection.buffer_class.errors = 'replace'
 
+print('LOADED LOCAL!')
 
 class Bot(irc.bot.SingleServerIRCBot):
     def __init__(self, channels, nickname, server, **kwargs):
@@ -134,8 +135,9 @@ class Bot(irc.bot.SingleServerIRCBot):
     def on_action(self, c, e):
         self.process_event(c, e)
 
-    def call_help(self):
-        helplist = sorted([i for i in pinhook.plugin.cmds])
+    def call_help(self, op):
+        print('HELP', pinhook.plugin.cmds)
+        helplist = sorted([i for i in pinhook.plugin.cmds if op or not ('ops' in pinhook.plugin.cmds[i] and pinhook.plugin.cmds[i]['ops'])])
         msg = ', '.join(helplist)
         return self.output_message('Available commands: {}'.format(msg))
 
@@ -154,7 +156,7 @@ class Bot(irc.bot.SingleServerIRCBot):
             c.quit("See y'all later!")
             quit()
         elif cmd == '!help':
-            output = self.call_help()
+            output = self.call_help(op)
         elif cmd == '!reload' and op:
             self.logger.info('reloading plugins per request of {}'.format(nick))
             self.load_plugins()
@@ -165,19 +167,23 @@ class Bot(irc.bot.SingleServerIRCBot):
         output = None
         if cmd in pinhook.plugin.cmds:
             try:
-                output = pinhook.plugin.cmds[cmd]['run'](self.Message(
-                    channel=chan,
-                    cmd=cmd,
-                    nick_list=nick_list,
-                    nick=nick,
-                    arg=arg,
-                    privmsg=privmsg,
-                    action=action,
-                    notice=notice,
-                    botnick=self.bot_nick,
-                    ops=self.ops,
-                    logger=self.logger
-                ))
+                if 'ops' in pinhook.plugin.cmds[cmd] and nick not in self.ops:
+                    if pinhook.plugin.cmds[cmd]['ops_msg']:
+                        output =  self.output_message(pinhook.plugin.cmds[cmd]['ops_msg'])
+                else:
+                    output = pinhook.plugin.cmds[cmd]['run'](self.Message(
+                        channel=chan,
+                        cmd=cmd,
+                        nick_list=nick_list,
+                        nick=nick,
+                        arg=arg,
+                        privmsg=privmsg,
+                        action=action,
+                        notice=notice,
+                        botnick=self.bot_nick,
+                        ops=self.ops,
+                        logger=self.logger
+                    ))
             except Exception as e:
                 self.logger.exception('issue with command {}'.format(cmd))
         else:
diff --git a/pinhook/plugin.py b/pinhook/plugin.py
index f94313e..3f39028 100644
--- a/pinhook/plugin.py
+++ b/pinhook/plugin.py
@@ -1,4 +1,5 @@
 from enum import Enum
+from functools import wraps
 
 
 cmds = {}
@@ -31,10 +32,20 @@ def message(msg):
 
 
 def _add_plugin(command, help_text, func):
-    cmds[command] = {
+    if command not in cmds:
+        cmds[command] = {}
+    cmds[command].update({
         'run': func,
         'help': help_text
-    }
+    })
+
+def _ops_plugin(command, ops_msg, func):
+    if command not in cmds:
+        cmds[command] = {}
+    cmds[command].update({
+        'ops': True,
+        'ops_msg': ops_msg,
+    })
 
 
 def _add_listener(name, func):
@@ -47,6 +58,7 @@ def clear_plugins():
 
 
 def register(command, help_text=None):
+    @wraps(command)
     def register_for_command(func):
         _add_plugin(command, help_text, func)
         return func
@@ -58,3 +70,10 @@ def listener(name):
         _add_listener(name, func)
         return func
     return register_as_listener
+
+def ops(command, msg=None):
+    @wraps(command)
+    def register_ops_command(func):
+        _ops_plugin(command, msg, func)
+        return func
+    return register_ops_command