lilytalk.py

   1 #!/usr/bin/env python2
   2 # vim:fileencoding=utf-8
   3
   4 import re
   5 import logging
   6 import datetime
   7
   8 from google.appengine.ext import db
   9 from google.appengine.api import xmpp
  10
  11 import utils
  12 import config
  13
  14 notice = u'这是一个测试群'
  15 helpre = re.compile(r'^\W{0,2}help$')
  16
  17 #用户所有资源离线时，会加上“完全”二字
  18 OFFLINE = u'离线'
  19 AWAY    = u'离开'
  20 XAWAY   = u'离开'
  21 BUSY    = u'忙碌'
  22 ONLINE  = u'在线'
  23 CHAT    = u'和我说话吧'
  24
  25 NEW        = u'加入'
  26 LEAVE      = u'退出'
  27 NICK       = u'昵称更改 (%s -> %s)'
  28 SNOOZE     = u'snooze %ds'
  29 BLACK      = u'禁言 %s %ds'
  30 BLACK_AUTO = u'被禁言 %ds'
  31 KICK       = u'删除 %s (%s)'
  32 ADMIN      = u'%s 成为管理员 (by %s)'
  33 UNADMIN    = u'%s 不再是管理员 (by %s)'
  34
  35 STATUS_CODE = {
  36   '':     ONLINE,
  37   'away': AWAY,
  38   'dnd':  BUSY,
  39   'xa':   XAWAY,
  40   'chat': CHAT,
  41 }
  42
  43 #状态的排序顺序
  44 STATUS_LIST = [CHAT, ONLINE, AWAY, XAWAY, BUSY, OFFLINE]
  45
  46 timezone = datetime.timedelta(hours=config.timezoneoffset)
  47
  48 class User(db.Model):
  49   jid = db.StringProperty(required=True, indexed=True)
  50   nick = db.StringProperty(required=True, indexed=True)
  51
  52   add_date = db.DateTimeProperty(auto_now_add=True)
  53   last_online_date = db.DateTimeProperty()
  54   last_offline_date = db.DateTimeProperty()
  55   last_speak_date = db.DateTimeProperty()
  56
  57   msg_count = db.IntegerProperty(required=True, default=0)
  58   msg_chars = db.IntegerProperty(required=True, default=0)
  59   credit = db.IntegerProperty(required=True, default=0)
  60
  61   black_before = db.DateTimeProperty(auto_now_add=True)
  62   snooze_before = db.DateTimeProperty()
  63   flooding_point = db.IntegerProperty(default=0)
  64
  65   avail = db.StringProperty(required=True)
  66   is_admin = db.BooleanProperty(required=True, default=False)
  67   resources = db.StringListProperty(required=True)
  68   #允许他人私信？
  69   reject_pm = db.BooleanProperty(default=False)
  70
  71   prefix = db.StringProperty(required=True, default=config.default_prefix)
  72   nick_pattern = db.StringProperty(required=True, default='[%s]')
  73   nick_changed = db.BooleanProperty(required=True, default=False)
  74   intro = db.StringProperty()
  75
  76 class Log(db.Model):
  77   time = db.DateTimeProperty(auto_now_add=True, indexed=True)
  78   msg = db.StringProperty(required=True, multiline=True)
  79   jid = db.StringProperty()
  80   nick = db.StringProperty()
  81   type = db.StringProperty(required=True, indexed=True,
  82                            choices=set(['chat', 'member', 'misc']))
  83
  84 def log_msg(sender, msg):
  85   l = Log(jid=sender.jid, nick=sender.nick,
  86           type='chat', msg=msg)
  87   l.put()
  88
  89 def log_onoff(sender, action, resource=''):
  90   if resource:
  91     if action == OFFLINE and not sender.resources:
  92       msg = u'完全%s (%s)' % (action, resource)
  93     else:
  94       msg = '%s (%s)' % (action, resource)
  95   else:
  96     msg = action
  97   l = Log(jid=sender.jid, nick=sender.nick,
  98           type='member', msg=msg)
  99   l.put()
 100
 101 def get_user_by_jid(jid):
 102   return User.gql('where jid = :1', jid.lower()).get()
 103
 104 def get_user_by_nick(nick):
 105   return User.gql('where nick = :1', nick).get()
 106
 107 def get_member_list():
 108   r = []
 109   now = datetime.datetime.now()
 110   #一个查询中最多只能有一个不等比较
 111   l = User.gql('where avail != :1', OFFLINE)
 112   for u in l:
 113     r.append(u)
 114   return [unicode(x.jid) for x in r \
 115           if x.snooze_before is None or x.snooze_before < now]
 116
 117 def send_to_all_except(jid, message):
 118   if isinstance(jid, str):
 119     jids = [x for x in get_member_list() if x != jid]
 120   else:
 121     jids = [x for x in get_member_list() if x not in jid]
 122   logging.debug(jid)
 123   logging.debug(jids)
 124   try:
 125     xmpp.send_message(jids, message)
 126   except xmpp.InvalidJidError:
 127     pass
 128
 129 def send_to_all(message):
 130   jids = get_member_list()
 131   xmpp.send_message(jids, message)
 132
 133 def handle_message(msg):
 134   sender = get_user_by_jid(msg.sender.split('/')[0])
 135   if sender is None:
 136     msg.reply('很抱歉，出错了，请重新添加好友。')
 137     return
 138   if msg.body.startswith('?OTR:'):
 139     msg.reply('不支持 OTR 加密！')
 140     return
 141   if len(msg.body) > 500:
 142     msg.reply('由于技术限制，每条消息最长为 500 字。大段文本请贴 paste 网站。')
 143     return
 144   if sender.is_admin or sender.jid == config.root:
 145     ch = AdminCommand(msg, sender)
 146   else:
 147     ch = BasicCommand(msg, sender)
 148   if not ch.handled:
 149     now = datetime.datetime.now()
 150     if sender.black_before is not None \
 151        and sender.black_before > now:
 152       if (datetime.datetime.today()+timezone).date() == \
 153          (sender.black_before+timezone).date():
 154         format = '%H时%M分%S秒'
 155       else:
 156         format = '%m月%d日 %H时%M分%S秒'
 157       msg.reply('你已被禁言至 ' \
 158                 + (sender.black_before+timezone).strftime(format))
 159       return
 160
 161     if sender.last_speak_date is not None:
 162       d = now - sender.last_speak_date
 163       t = d.seconds
 164       if d.days > 0 or t > 60:
 165         sender.flooding_point = 0
 166       else:
 167         k = 1000 / (t * t + 1)
 168         if k > 0:
 169           sender.flooding_point += k
 170         else:
 171           sender.flooding_point = 0
 172
 173         k = sender.flooding_point / 1500
 174         if k > 0:
 175           msg.reply('刷屏啊？禁言 %d 分钟！' % k)
 176           send_to_all_except(sender.jid,
 177             (u'%s 已因刷屏而被禁言 %d 分钟。' % (sender.nick, k)) \
 178                                   .encode('utf-8'))
 179           log_onoff(sender, BLACK_AUTO % (60 * k))
 180           sender.black_before = now + datetime.timedelta(seconds=60*k)
 181           sender.put()
 182           return
 183
 184     sender.last_speak_date = now
 185     sender.snooze_before = None
 186     try:
 187       sender.msg_count += 1
 188       sender.msg_chars += len(msg.body)
 189     except TypeError:
 190       sender.msg_count = 1
 191       sender.msg_chars = len(msg.body)
 192     sender.put()
 193     body = utils.removelinks(msg.body)
 194     for u in User.gql('where avail != :1', OFFLINE):
 195       if u.snooze_before is not None and u.snooze_before >= now:
 196         continue
 197       if u.jid == sender.jid:
 198         continue
 199       try:
 200         message = '%s %s' % (
 201           u.nick_pattern % sender.nick,
 202           body
 203         )
 204         xmpp.send_message(u.jid, message)
 205       except xmpp.InvalidJidError:
 206         pass
 207     log_msg(sender, msg.body)
 208
 209 def try_add_user(jid, show=OFFLINE, resource=''):
 210   '''使用 memcache 作为锁添加用户'''
 211   L = utils.MemLock('add_user')
 212   L.require()
 213   try:
 214     u = get_user_by_jid(jid)
 215     if u is not None:
 216       return
 217     u = add_user(jid, show, resource)
 218   finally:
 219     L.release()
 220   if show != OFFLINE:
 221     log_onoff(u, show, resource)
 222   logging.info(u'%s added', jid)
 223
 224 def add_user(jid, show=OFFLINE, resource=''):
 225   '''resource 在 presence type 为 available 里使用'''
 226   nick = jid.split('@')[0]
 227   old = get_user_by_nick(nick)
 228   while old:
 229     nick += '_'
 230     old = get_user_by_nick(nick)
 231   u = User(jid=jid.lower(), avail=show, nick=nick)
 232   if show != OFFLINE:
 233     u.last_online_date = datetime.datetime.now()
 234   if resource:
 235     u.resources.append(resource)
 236   u.put()
 237   log_onoff(u, NEW)
 238   logging.info(u'%s 已经加入' % jid)
 239   send_to_all_except(jid, u'%s 已经加入' % u.nick)
 240   xmpp.send_presence(jid, status=notice)
 241   xmpp.send_message(jid, u'欢迎 %s 加入！获取使用帮助，请输入 %shelp' % (
 242     u.nick, u.prefix))
 243   return u
 244
 245 class BasicCommand:
 246   handled = True
 247   def __init__(self, msg, sender):
 248     self.sender = sender
 249     self.msg = msg
 250
 251     if helpre.match(msg.body):
 252       self.do_help()
 253     elif msg.body.startswith(sender.prefix):
 254       cmd = msg.body[len(sender.prefix):].split()
 255       try:
 256         handle = getattr(self, 'do_' + cmd[0])
 257       except AttributeError:
 258         msg.reply(u'错误：未知命令 %s' % cmd[0])
 259       except IndexError:
 260         msg.reply(u'错误：无命令')
 261       except UnicodeEncodeError:
 262         msg.reply(u'错误：命令名解码失败。此问题在 GAE 升级其 Python 到 3.x 后方能解决。')
 263       else:
 264         handle(cmd[1:])
 265         logging.debug('%s did command %s' % (sender.jid, cmd[0]))
 266     else:
 267       self.handled = False
 268
 269   def do_online(self, args):
 270     '''显示在线成员列表'''
 271     r = []
 272     now = datetime.datetime.now()
 273     l = User.gql('where avail != :1', OFFLINE)
 274     for u in l:
 275       m = u.nick
 276       status = u.avail
 277       if status != u'在线':
 278         m += u' (%s)' % status
 279       if u.snooze_before is not None and u.snooze_before > now:
 280         m += u' (snoozing)'
 281       if u.black_before is not None and u.black_before > now:
 282         m += u' (已禁言)'
 283       r.append(unicode('* ' + m))
 284     r.sort()
 285     n = len(r)
 286     r.insert(0, u'在线成员列表:')
 287     r.append(u'共 %d 人在线。' % n)
 288     self.msg.reply(u'\n'.join(r).encode('utf-8'))
 289
 290   def do_lsadmin(self, args):
 291     '''显示管理员列表'''
 292     r = []
 293     now = datetime.datetime.now()
 294     l = User.gql('where is_admin = :1', True)
 295     for u in l:
 296       m = u.nick
 297       status = u.avail
 298       if status != u'在线':
 299         m += u' (%s)' % status
 300       if u.snooze_before is not None and u.snooze_before > now:
 301         m += u' (snoozing)'
 302       if u.black_before is not None and u.black_before > now:
 303         m += u' (已禁言)'
 304       r.append(unicode('* ' + m))
 305     r.sort()
 306     n = len(r)
 307     r.insert(0, u'管理员列表:')
 308     r.append(u'共 %d 位管理员。' % n)
 309     self.msg.reply(u'\n'.join(r).encode('utf-8'))
 310
 311   def do_chatty(self, args):
 312     '''显示成员发送的消息数量'''
 313     r = []
 314     for u in User.gql('ORDER BY msg_chars ASC'):
 315       m = u.nick
 316       m = u'* %s:\t%5d条，共 %s' % (
 317         u.nick, u.msg_count,
 318         utils.filesize(u.msg_chars))
 319       r.append(m)
 320     n = len(r)
 321     r.insert(0, u'消息数量排行:')
 322     r.append(u'共 %d 人。' % n)
 323     self.msg.reply(u'\n'.join(r).encode('utf-8'))
 324
 325   def do_nick(self, args):
 326     '''更改昵称，需要一个参数'''
 327     if len(args) != 1:
 328       self.msg.reply('错误：请给出你想到的昵称（不能包含空格）')
 329       return
 330
 331     q = get_user_by_nick(args[0])
 332     if q is not None:
 333       self.msg.reply('错误：该昵称已被使用，请使用其它昵称')
 334     elif not utils.checkNick(args[0]):
 335       self.msg.reply('错误：非法的昵称')
 336     else:
 337       if not config.nick_can_change and self.sender.nick_changed:
 338         self.msg.reply('乖哦，你已经没机会再改昵称了')
 339         return
 340       old_nick = self.sender.nick
 341       log_onoff(self.sender, NICK % (old_nick, args[0]))
 342       self.sender.nick = args[0]
 343       self.sender.nick_changed = True
 344       self.sender.put()
 345       send_to_all_except(self.sender.jid,
 346         (u'%s 的昵称改成了 %s' % (old_nick, args[0])).encode('utf-8'))
 347       self.msg.reply('昵称更改成功！')
 348   do_nick.__doc__ += '，最长 %d 字节' % config.nick_maxlen
 349
 350   def do_whois(self, args):
 351     '''查看某用户的信息'''
 352     if len(args) != 1:
 353       self.msg.reply('错误：你想知道关于谁的信息？')
 354       return
 355
 356     u = get_user_by_nick(args[0])
 357     if u is None:
 358       self.msg.reply(u'Sorry，查无此人。')
 359       return
 360
 361     now = datetime.datetime.now()
 362     status = u.avail
 363     addtime = (u.add_date + timezone).strftime('%Y年%m月%d日 %H时%M分').decode('utf-8')
 364     allowpm = u'否' if u.reject_pm else u'是'
 365     if u.snooze_before is not None and u.snooze_before > now:
 366       status += u' (snoozing)'
 367     if u.black_before is not None and u.black_before > now:
 368       status += u' (已禁言)'
 369     r = u'昵称：\t\t%s\n状态：\t\t%s\n消息数：\t\t%d\n消息总量：\t%s\n加入时间：\t%s\n接受私信：\t%s\n自我介绍：\t%s' % (
 370       u.nick, status, u.msg_count, utils.filesize(u.msg_chars), addtime,
 371       allowpm, u.intro)
 372     self.msg.reply(r.encode('utf-8'))
 373
 374   def do_help(self, args=None):
 375     '''显示本帮助'''
 376     doc = []
 377     prefix = self.sender.prefix
 378
 379     for b in self.__class__.__bases__ + (self.__class__,):
 380       for c, f in b.__dict__.items():
 381         if c.startswith('do_'):
 382           doc.append(u'%s%s:\t%s' % (prefix, c[3:], f.__doc__.decode('utf-8')))
 383
 384     doc.sort()
 385     doc.insert(0, u'命令指南 (当前命令前缀 %s，可设置)' % prefix)
 386     doc.append(u'要离开，直接删掉好友即可。')
 387     self.msg.reply(u'\n'.join(doc).encode('utf-8'))
 388
 389   def do_iam(self, args):
 390     '''查看自己的信息'''
 391     u = self.sender
 392     addtime = (u.add_date + timezone).strftime('%Y年%m月%d日 %H时%M分').decode('utf-8')
 393     allowpm = u'否' if u.reject_pm else u'是'
 394     r = u'昵称：\t\t%s\nJID：\t\t%s\n消息数：\t\t%d\n消息总量：\t%s\n加入时间：\t%s\n接受私信：\t%s\n命令前缀：\t%s\n自我介绍：\t%s' % (
 395       u.nick, u.jid, u.msg_count, utils.filesize(u.msg_chars), addtime,
 396       allowpm, u.prefix, u.intro)
 397     self.msg.reply(r.encode('utf-8'))
 398
 399   def do_m(self, args):
 400     '''给某人发私信，需要昵称和内容两个参数。私信不会以任何方式被记录。'''
 401     if len(args) < 2:
 402       self.msg.reply('请给出昵称和内容。')
 403       return
 404
 405     target = get_user_by_nick(args[0])
 406     if target is None:
 407       self.msg.reply('Sorry，查无此人。')
 408       return
 409
 410     if target.reject_pm:
 411       self.msg.reply('很抱歉，对方不接受私信。')
 412       return
 413
 414     msg = self.msg.body[len(self.sender.prefix):].split(None, 2)[-1]
 415     msg = u'_私信_ %s %s' % (target.nick_pattern % self.sender.nick, msg)
 416     if xmpp.send_message(target.jid, msg) == xmpp.NO_ERROR:
 417       self.msg.reply(u'OK')
 418     else:
 419       self.msg.reply(u'消息发送失败')
 420
 421   def do_intro(self, arg):
 422     '''设置自我介绍信息'''
 423     if not arg:
 424       self.msg.reply('请给出自我介绍的内容。')
 425       return
 426
 427     msg = self.msg.body[len(self.sender.prefix):].split(None, 1)[-1]
 428     u = self.sender
 429     try:
 430       u.intro = msg
 431     except db.BadValueError:
 432       # 过长文本已在 handle_message 中被拦截
 433       self.msg.reply('错误：自我介绍内容只能为一行。')
 434       return
 435
 436     u.put()
 437     send_to_all_except(u.jid,
 438       (u'%s 的新自我介绍：%s' % (u.nick, msg)).encode('utf-8'))
 439     self.msg.reply(u'设置成功！')
 440
 441   def do_snooze(self, args):
 442     '''暂停接收消息，参数为时间（默认单位为秒）。再次发送消息时自动清除'''
 443     if len(args) != 1:
 444       self.msg.reply('你想停止接收消息多久？')
 445       return
 446     else:
 447       try:
 448         n = utils.parseTime(args[0])
 449       except ValueError:
 450         self.msg.reply('Sorry，我无法理解你说的时间。')
 451         return
 452
 453     try:
 454       self.sender.snooze_before = datetime.datetime.now() + datetime.timedelta(seconds=n)
 455     except OverflowError:
 456       self.msg.reply('Sorry，你不能睡太久。')
 457       return
 458     self.sender.put()
 459     if n == 0:
 460       self.msg.reply('你已经醒来。')
 461     else:
 462       self.msg.reply('OK，停止接收消息 %d 秒。' % n)
 463     log_onoff(self.sender, SNOOZE % n)
 464
 465   def do_offline(self, args):
 466     '''让程序认为你的所有资源已离线。如在你离线时程序仍认为你在线，请使用此命令。'''
 467     del self.sender.resources[:]
 468     self.sender.avail = OFFLINE
 469     self.sender.last_offline_date = datetime.datetime.now()
 470     self.sender.put()
 471     self.msg.reply('OK，在下次你说你在线之前我都认为你已离线。')
 472
 473   def do_old(self, args):
 474     '''查询聊天记录，可选一个数字参数。默认为最后20条。特殊参数 OFFLINE 显示离线消息（最多 100 条）'''
 475     s = self.sender
 476     q = False
 477     if not args:
 478       q = Log.gql("WHERE type = 'chat' ORDER BY time DESC LIMIT 20")
 479     elif len(args) == 1:
 480       try:
 481         n = int(args[0])
 482         if n > 0:
 483           q = Log.gql("WHERE type = 'chat' ORDER BY time DESC LIMIT %d" % n)
 484       except ValueError:
 485         if args[0].upper() == 'OFFLINE':
 486           q = Log.gql("WHERE time < :1 AND time > :2 AND type = 'chat' ORDER BY time DESC LIMIT 100", s.last_online_date, s.last_offline_date)
 487         else:
 488           pass
 489     if q is not False:
 490       r = []
 491       q = list(q)
 492       q.reverse()
 493       if q:
 494         if datetime.datetime.today() - q[0].time > datetime.timedelta(hours=24):
 495           show_date = True
 496         else:
 497           show_date = False
 498       for l in q:
 499         message = '%s %s %s' % (
 500           utils.strftime(l.time, timezone, show_date),
 501           s.nick_pattern % l.nick,
 502           l.msg
 503         )
 504         r.append(message)
 505       if r:
 506         self.msg.reply(u'\n'.join(r).encode('utf-8'))
 507       else:
 508         self.msg.reply('没有符合的聊天记录。')
 509     else:
 510       self.msg.reply('Oops, 参数不正确哦。')
 511
 512   def do_set(self, args):
 513     '''设置一些参数。参数格式 key=value；不带参数以查看说明。'''
 514     #注意：选项名/值中不能包含空格
 515     if len(args) != 1:
 516       doc = []
 517       for c, f in self.__class__.__dict__.items():
 518         if c.startswith('set_'):
 519           doc.append(u'* %s:\t%s' % (c[4:], f.__doc__.decode('utf-8')))
 520       for b in self.__class__.__bases__:
 521         for c, f in b.__dict__.items():
 522           if c.startswith('set_'):
 523             doc.append(u'* %s:\t%s' % (c[4:], f.__doc__.decode('utf-8')))
 524       doc.sort()
 525       doc.insert(0, u'设置选项：')
 526       self.msg.reply(u'\n'.join(doc).encode('utf-8'))
 527     else:
 528       msg = self.msg
 529       cmd = msg.body.split(None, 1)[1].split('=', 1)
 530       if len(cmd) == 1:
 531         msg.reply(u'错误：请给出选项值')
 532         return
 533       try:
 534         handle = getattr(self, 'set_' + cmd[0])
 535       except AttributeError:
 536         msg.reply(u'错误：未知选项 %s' % cmd[0])
 537       except IndexError:
 538         msg.reply(u'错误：无选项')
 539       except UnicodeEncodeError:
 540         msg.reply(u'错误：选项名解码失败。此问题在 GAE 升级其 Python 到 3.x 后方能解决。')
 541       else:
 542         handle(cmd[1])
 543
 544   def set_prefix(self, arg):
 545     '''设置命令前缀'''
 546     self.sender.prefix = arg
 547     self.sender.put()
 548     self.msg.reply(u'设置成功！')
 549
 550   def set_nickpattern(self, arg):
 551     '''设置昵称显示格式，用 %s 表示昵称的位置'''
 552     try:
 553       arg % 'test'
 554     except (TypeError, ValueError):
 555       self.msg.reply(u'错误：不正确的格式')
 556       return
 557
 558     self.sender.nick_pattern = arg
 559     self.sender.put()
 560     self.msg.reply(u'设置成功！')
 561
 562   def set_allowpm(self, arg):
 563     '''设置是否接受私信，参数为 y（接受）或者 n（拒绝）'''
 564     if arg not in 'yn':
 565       self.msg.reply(u'错误的参数。')
 566       return
 567
 568     if arg == 'y':
 569       self.sender.reject_pm = False
 570     else:
 571       self.sender.reject_pm = True
 572     self.sender.put()
 573     self.msg.reply(u'设置成功！')
 574
 575 class AdminCommand(BasicCommand):
 576   def do_kick(self, args):
 577     '''删除某人。他仍可以重新加入。'''
 578     if len(args) != 1:
 579       self.msg.reply('请给出昵称。')
 580       return
 581
 582     target = get_user_by_nick(args[0])
 583     if target is None:
 584       self.msg.reply('Sorry，查无此人。')
 585       return
 586
 587     if target.jid == config.root:
 588       self.msg.reply('不能删除 root 用户')
 589       return
 590
 591     targetjid = target.jid
 592     targetnick = target.nick
 593     target.delete()
 594     self.msg.reply((u'OK，删除 %s。' % target.nick).encode('utf-8'))
 595     send_to_all_except(self.sender.jid, (u'%s 已被删除。' % self.sender.nick) \
 596                        .encode('utf-8'))
 597     xmpp.send_message(targetjid, u'你已被管理员从此群中删除，请删除该好友。')
 598     log_onoff(self.sender, KICK % (targetnick, targetjid))
 599
 600   def do_quiet(self, args):
 601     '''禁言某人，参数为昵称和时间（默认单位秒）'''
 602     if len(args) != 2:
 603       self.msg.reply('请给出昵称和时间。')
 604       return
 605     else:
 606       try:
 607         n = utils.parseTime(args[1])
 608       except ValueError:
 609         self.msg.reply('Sorry，我无法理解你说的时间。')
 610         return
 611
 612     target = get_user_by_nick(args[0])
 613     if target is None:
 614       self.msg.reply('Sorry，查无此人。')
 615       return
 616
 617     target.black_before = datetime.datetime.now() + datetime.timedelta(seconds=n)
 618     target.put()
 619     self.msg.reply((u'OK，禁言 %s %d 秒。' % (target.nick, n)).encode('utf-8'))
 620     send_to_all_except((self.sender.jid, target.jid),
 621                        (u'%s 已被禁言 %s 秒。' % (self.sender.nick, n)) \
 622                        .encode('utf-8'))
 623     xmpp.send_message(target.jid, u'你已被管理员禁言 %d 秒。' % n)
 624     log_onoff(self.sender, BLACK % (target.nick, n))
 625
 626   def do_admin(self, args):
 627     '''将某人添加为管理员'''
 628     if len(args) != 1:
 629       self.msg.reply(u'请给出昵称。')
 630       return
 631
 632     target = get_user_by_nick(args[0])
 633     if target is None:
 634       self.msg.reply(u'Sorry，查无此人。')
 635       return
 636
 637     if target.is_admin:
 638       self.msg.reply(u'%s 已经是管理员了。' % target.nick)
 639       return
 640
 641     target.is_admin = True
 642     target.put()
 643     send_to_all_except(target.jid,
 644                        (u'%s 已成为管理员。' % target.nick) \
 645                        .encode('utf-8'))
 646     xmpp.send_message(target.jid, u'你已是本群管理员。')
 647     log_onoff(self.sender, ADMIN % (target.nick, self.sender.nick))
 648
 649   def do_unadmin(self, args):
 650     '''取消某人管理员的权限'''
 651     if len(args) != 1:
 652       self.msg.reply(u'请给出昵称。')
 653       return
 654
 655     target = get_user_by_nick(args[0])
 656     if target is None:
 657       self.msg.reply(u'Sorry，查无此人。')
 658       return
 659
 660     if not target.is_admin:
 661       self.msg.reply(u'%s 不是管理员。' % target.nick)
 662       return
 663
 664     target.is_admin = False
 665     target.put()
 666     send_to_all_except(target.jid,
 667                        (u'%s 已不再是管理员。' % target.nick) \
 668                        .encode('utf-8'))
 669     xmpp.send_message(target.jid, u'你已不再是本群管理员。')
 670     log_onoff(self.sender, UNADMIN % (target.nick, self.sender.nick))
 671