Changeset 19

Timestamp:

12/27/06 10:03:25 (17 years ago)

Author:

atzm

Message:

• untabify, and cosmeticize debug messages

File:

• trunk/amazonbot/amazonbot.py (modified) (2 diffs)

trunk/amazonbot/amazonbot.py

@@ -21 +21 @@
 from irclib import nm_to_n
 
-import config
-config.init()
+try:
+    set, frozenset
+except NameError:
+    from sets import Set as set, ImmutableSet as frozenset
+
+
+import config; config.init()
 
 import my_amazon
@@ -28 +33 @@
 my_amazon.setLicense(config.get('amazon', 'access_key'))
 
-try:
-        set, frozenset
-except NameError:
-        from sets import Set as set, ImmutableSet as frozenset
+
+DEBUG_MSG_TO = sys.stderr
+
 
 def uniq(sequence):
-        """リストから重耇を取り陀く (é †ç•ªãŒç‹‚ã†ã®ã§æ³šæ„)
-        """
-        return list(set(sequence))
+    """リストから重耇を取り陀く (é †ç•ªãŒç‹‚ã†ã®ã§æ³šæ„)
+    """
+    return list(set(sequence))
 
 def unicoding(text):
-        """text を匷制的に unicode オブゞェクトに倉換
-        """
-        if type(text) is unicode:
-                return text
-        return unicode(nkf.nkf('-w', text), 'utf-8')
+    """text を匷制的に unicode オブゞェクトに倉換
+    """
+    if type(text) is unicode:
+        return text
+    return unicode(nkf.nkf('-w', text), 'utf-8')
 
 def ununicoding(text, encoding='iso-2022-jp'):
-        """text を指定された encoding で゚ンコヌドしraw str に匷制倉換
-        """
-        if type(text) is not unicode:
-                return unicoding(text).encode(encoding)
-        return text.encode(encoding)
+    """text を指定された encoding で゚ンコヌドしraw str に匷制倉換
+    """
+    if type(text) is not unicode:
+        return unicoding(text).encode(encoding)
+    return text.encode(encoding)
 
 def mecab_parse(text):
-        """MeCab を䜿っお圢æ
+    """MeCab を䜿っお圢æ
 ‹çŽ 解析し固有名詞ず䞀般名詞だけを抜出する
-        """
-        def choice_nominal(wlist):
-                res = []
-                for word, wtype in wlist:
-                        wtypes = wtype.split('-')
-                        if '固有名詞' in wtypes or ('名詞' in wtypes and '䞀般' in wtypes):
-                                res.append(unicoding(word))
-                return res
-
-        text = ununicoding(text, 'utf-8')
-        result = []
-        tag = MeCab.Tagger('-Ochasen')
-        for line in tag.parse(text).split('\n'):
-                if not line or line == 'EOS':
-                        break
-                words = line.split()
-                result.append((words[0], words[-1])) # word, word-type
-
-        result = uniq(choice_nominal(result))
-        return result
+    """
+    def choice_nominal(wlist):
+        res = []
+        for word, wtype in wlist:
+            wtypes = wtype.split('-')
+            if '固有名詞' in wtypes or ('名詞' in wtypes and '䞀般' in wtypes):
+                res.append(unicoding(word))
+        return res
+
+    text = ununicoding(text, 'utf-8')
+    result = []
+    tag = MeCab.Tagger('-Ochasen')
+    for line in tag.parse(text).split('\n'):
+        if not line or line == 'EOS':
+            break
+        words = line.split()
+        result.append((words[0], words[-1])) # word, word-type
+
+    result = uniq(choice_nominal(result))
+    return result
+
+def _debug(fmt, *args):
+    if __debug__:
+        timeline = time.strftime("%b %d %T", time.localtime())
+        try:
+            fmt = ununicoding(fmt, 'euc-jp')
+            args = list(args)
+            for i in range(len(args)):
+                if isinstance(args[i], basestring):
+                    args[i] = ununicoding(args[i], 'euc-jp')
+
+            print >> DEBUG_MSG_TO, '(%s) <DEBUG>' % timeline,
+            print >> DEBUG_MSG_TO, fmt % tuple(args)
+
+        except:
+            print >> DEBUG_MSG_TO, '(%s) <DEBUG>' % timeline,
+            print >> DEBUG_MSG_TO, '!! debug message print failed !!'
 
 class AmazonBotBase(SingleServerIRCBot):
-        """アマゟンボットのベヌスクラス
-        単䜓では受け取ったメッセヌゞの圢æ
+    """アマゟンボットのベヌスクラス
+    単䜓では受け取ったメッセヌゞの圢æ
 ‹çŽ 解析ず名詞抜出たでしかやらない
-        サブクラスで process_keyword を実è£
+    サブクラスで process_keyword を実è£
 しお Amazon ぞク゚リを投げるべし
 
-        サブクラスには onmsg_HOGEHOGE(self, conn, ev, to, args) ãƒ¡ã‚œãƒƒãƒ‰ã‚’äœœã‚‹ã“ãšã§ã‚³ãƒžãƒ³ãƒ‰è¿œåŠ å¯èƒœ
-        コマンド曞匏は !HOGEHOGE arg [, arg2, ...] ずなる
-        ヘルプはメ゜ッドに docstring を曞けば OK
-        """
-        def __init__(self):
-                _server = [(config.get('irc', 'server'), config.get('irc', 'port', 'int'))]
-                _nick = config.get('bot', 'nick')
-
-                self._current_lines = 0
-                self._prev_time = time.time() - config.get('freq', 'timeout', 'int')
-                self._silent = False
-                SingleServerIRCBot.__init__(self, _server, _nick, _nick)
-
-        def start(self):
-                try:
-                        SingleServerIRCBot.start(self)
-                except KeyboardInterrupt:
-                        self.die(ununicoding(config.get('bot', 'bye')))
-
-        def on_welcome(self, c, e):
-                c.join(config.get('irc', 'channel'))
-                if __debug__:
-                        print >> sys.stderr, 'DEBUG> Joined %s' % config.get('irc', 'channel')
-
-        def on_nicknameinuse(self, c, e):
-                c.nick(c.get_nickname() + '_')
-
-        def on_privmsg(self, c, e):
-                return self.on_pubmsg(c, e, to=nm_to_n(e.source()))
-
-        def on_pubmsg(self, c, e, to=config.get('irc', 'channel')):
-                msg = unicoding(e.arguments()[0])
-
-                if __debug__:
-                        try:
-                                print >> sys.stderr, 'DEBUG> pubmsg incoming "%s", should be reply to %s' % (ununicoding(msg, 'euc-jp'), to)
-                        except:
-                                print >> sys.stderr, 'DEBUG> pubmsg incoming, but could not en/decode message. should be reply to %s' % to
-
-                if msg[0] == '!':
-                        try:
-                                words = shlex.split(ununicoding(msg, 'utf-8')[1:])
-                        except:
-                                return False
-                        if not words:
-                                return False
-                        method = getattr(self, 'onmsg_%s' % words[0], lambda *arg: False)
-                        return method(c, e, to, words[1:]) # words[0] == command name
-
-                # freq_lines
-                self._current_lines += 1
-                _freq_lines = config.get('freq', 'lines', 'int')
-                if _freq_lines:
-                        if config.get('freq', 'lines_random', 'boolean'):
-                                _freq_lines = random.randint(int(_freq_lines/2)+1, _freq_lines)
-
-                        if __debug__:
-                                print >> sys.stderr, 'DEBUG> Line count: now %d, next: %d' % (self._current_lines, _freq_lines)
-
-                        if self._current_lines < _freq_lines:
-                                return False
-                self._current_lines = 0
-
-                # freq
-                _current_time = time.time()
-                if _current_time < self._prev_time + config.get('freq', 'timeout', 'int'):
-                        if __debug__:
-                                cur = time.strftime('%H:%M:%S', time.localtime(_current_time))
-                                go = time.strftime('%H:%M:%S', time.localtime(self._prev_time + config.get('freq', 'timeout', 'int')))
-                                print >> sys.stderr, 'DEBUG> Not expired: now %s, be expired at: %s' % (cur, go)
-                        return False
-                self._prev_time = _current_time
-
-                # silence
-                self.silence(msg, c, e, to)
-                if self._silent:
-                        return False
-
-                nominals = mecab_parse(msg)
-                if not nominals:
-                        if __debug__:
-                                print >> sys.stderr, "DEBUG> Couldn't find nominal words"
-                        return False
-
-                title, url = self.process_keyword(' '.join(nominals))
-                if title and url:
-                        content = unicoding(config.get('bot', 'content'))
-                        try:
-                                message = ununicoding(': '.join([content, title, url]))
-                        except UnicodeError, err:
-                                # なぜかたたに unicode オブゞェクトを iso-2022-jp で゚ンコヌドできない
-                                if __debug__:
-                                        print >> sys.stderr, 'DEBUG> %s' % str(err)
-                                return False
-
-                        c.notice(to, message)
-                        return True
-                return False
-
-        ACTIVE_PATTERN = re.compile(unicoding(config.get('bot', 'active_pattern')))
-        SILENT_PATTERN = re.compile(unicoding(config.get('bot', 'silent_pattern')))
-        def silence(self, msg, c, e, to):
-                active = self.ACTIVE_PATTERN.search(msg)
-                silent = self.SILENT_PATTERN.search(msg)
-                if __debug__:
-                        print >> sys.stderr, 'DEBUG> ACT_PATT: %s, SIL_PATT: %s' % (str(active), str(silent))
-
-                if active:
-                        self._silent = False
-                        c.notice(to, ununicoding(config.get('bot', 'thanks')))
-                elif silent:
-                        self._silent = True
-                        c.notice(to, ununicoding(config.get('bot', 'sorry')))
-
-        def process_keyword(self, keyword):
-                return [None, None]
+    サブクラスには onmsg_HOGEHOGE(self, conn, ev, to, args) ãƒ¡ã‚œãƒƒãƒ‰ã‚’äœœã‚‹ã“ãšã§ã‚³ãƒžãƒ³ãƒ‰è¿œåŠ å¯èƒœ
+    コマンド曞匏は !HOGEHOGE arg [, arg2, ...] ずなる
+    ヘルプはメ゜ッドに docstring を曞けば OK
+    """
+    def __init__(self):
+        _server = [(config.get('irc', 'server'), config.get('irc', 'port', 'int'))]
+        _nick = config.get('bot', 'nick')
+
+        self._current_lines = 0
+        self._prev_time = time.time() - config.get('freq', 'timeout', 'int')
+        self._silent = False
+        SingleServerIRCBot.__init__(self, _server, _nick, _nick)
+
+    def start(self):
+        try:
+            SingleServerIRCBot.start(self)
+        except KeyboardInterrupt:
+            self.die(ununicoding(config.get('bot', 'bye')))
+
+    def on_welcome(self, c, e):
+        c.join(config.get('irc', 'channel'))
+        _debug('Joined %s', config.get('irc', 'channel'))
+
+    def on_nicknameinuse(self, c, e):
+        c.nick(c.get_nickname() + '_')
+
+    def on_privmsg(self, c, e):
+        return self.on_pubmsg(c, e, to=nm_to_n(e.source()))
+
+    def on_pubmsg(self, c, e, to=config.get('irc', 'channel')):
+        msg = unicoding(e.arguments()[0])
+        _debug('pubmsg incoming "%s", should be reply to %s', msg, to)
+
+        if msg[0] == '!':
+            try:
+                words = shlex.split(ununicoding(msg, 'utf-8')[1:])
+            except:
+                return False
+            if not words:
+                return False
+            method = getattr(self, 'onmsg_%s' % words[0], lambda *arg: False)
+            return method(c, e, to, words[1:]) # words[0] == command name
+
+        # freq_lines
+        self._current_lines += 1
+        _freq_lines = config.get('freq', 'lines', 'int')
+        if _freq_lines:
+            if config.get('freq', 'lines_random', 'boolean'):
+                _freq_lines = random.randint(int(_freq_lines/2)+1, _freq_lines)
+
+            _debug('Line count: now %d, next: %d', self._current_lines, _freq_lines)
+
+            if self._current_lines < _freq_lines:
+                return False
+        self._current_lines = 0
+
+        # freq
+        _current_time = time.time()
+        if _current_time < self._prev_time + config.get('freq', 'timeout', 'int'):
+            cur = time.strftime('%H:%M:%S', time.localtime(_current_time))
+            go = time.strftime('%H:%M:%S', time.localtime(
+                self._prev_time + config.get('freq', 'timeout', 'int')))
+            _debug('Not expired: now %s, be expired at: %s', cur, go)
+            return False
+        self._prev_time = _current_time
+
+        # silence
+        self.silence(msg, c, e, to)
+        if self._silent:
+            return False
+
+        nominals = mecab_parse(msg)
+        if not nominals:
+            _debug("Couldn't find nominal words")
+            return False
+
+        title, url = self.process_keyword(' '.join(nominals))
+        if title and url:
+            content = unicoding(config.get('bot', 'content'))
+            try:
+                message = ununicoding(': '.join([content, title, url]))
+            except UnicodeError, err:
+                # なぜかたたに unicode オブゞェクトを iso-2022-jp で゚ンコヌドできない
+                _debug('%s', str(err))
+                return False
+
+            c.notice(to, message)
+            return True
+        return False
+
+    ACTIVE_PATTERN = re.compile(unicoding(config.get('bot', 'active_pattern')))
+    SILENT_PATTERN = re.compile(unicoding(config.get('bot', 'silent_pattern')))
+    def silence(self, msg, c, e, to):
+        active = self.ACTIVE_PATTERN.search(msg)
+        silent = self.SILENT_PATTERN.search(msg)
+        _debug('ACT_PATT: %s, SIL_PATT: %s', str(active), str(silent))
+
+        if active:
+            self._silent = False
+            c.notice(to, ununicoding(config.get('bot', 'thanks')))
+        elif silent:
+            self._silent = True
+            c.notice(to, ununicoding(config.get('bot', 'sorry')))
+
+    def process_keyword(self, keyword):
+        return [None, None]
 
 class AmazonBot(AmazonBotBase):
-        """アマゟンボットの実è£
+    """アマゟンボットの実è£
 クラス
-        process_keyword メ゜ッドで Amazon ぞク゚リを投げお結果を返す
-        """
-        _AVAIL_PRODUCT_LINES = {
-                'books-jp': '(和曞, default)',
-                'books-us': '(掋曞)',
-                'music-jp': '(ポピュラヌ音楜)',
-                'classical-jp': '(クラシック音楜)',
-                'dvd-jp': '(DVD)',
-                'vhs-jp': '(ビデオ)',
-                'electronics-jp': '(゚レクトロニクス)',
-                'kitchen-jp': '(ホヌムキッチン)',
-                'software-jp': '(゜フトりェア)',
-                'videogames-jp': '(ゲヌム)',
-                'magazines-jp': '(雑誌)',
-                'toys-jp': '(おもちゃホビヌ)',
-        }
-
-        def __init__(self):
-                AmazonBotBase.__init__(self)
-
-        def get_version(self):
-                return 'AmazonBot by %s, based on python-irclib' % __author__
-
-        def onmsg_isbn(self, c, e, to, args):
-                """Syntax: !isbn <ISBN number>
-                """
-                return self.onmsg_asin(c, e, to, args)
-        def onmsg_asin(self, c, e, to, args):
-                """Syntax: !asin <ASIN number>
-                """
-                if __debug__:
-                        print >> sys.stderr, 'DEBUG> in asin command: %s' % str(args)
-
-                try:
-                        data = my_amazon.searchByASIN(args[0])
-                except my_amazon.AmazonError, err:
-                        c.notice(to, ununicoding(config.get('bot', 'no_products')))
-                        if __debug__:
-                                print >> sys.stderr, 'DEBUG> Caught AmazonError in onmsg_asin: %s' % str(err)
-                        return False
-                except IndexError, err:
-                        c.notice(to, 'Please specify an argument.')
-                        return False
-
-                return self._process_onmsg(c, e, to, data)
-
-        def onmsg_k(self, c, e, to, args): return self.onmsg_keyword(c, e, to, args)
-        def onmsg_keyword(self, c, e, to, args):
-                """Syntax: !keyword [-h] [-t type] <keyword1> [, keyword2, ...]
-                """
-                if __debug__:
-                        print >> sys.stderr, 'DEBUG> in keyword command: %s' % str(args)
-
-                try:
-                        options, rest = getopt.getopt(args, 't:h', ['type=', 'help'])
-                except getopt.GetoptError, err:
-                        if __debug__:
-                                print >> sys.stderr, 'DEBUG> Caught GetoptError in onmsg_keyword: %s' % str(err)
-                        return False
-
-                keyword = ' '.join(rest).strip()
-                product_line = 'books-jp'
-                for opt, val in options:
-                        if opt in ['-t', '--type']:
-                                if val not in self._AVAIL_PRODUCT_LINES.keys():
-                                        c.notice(to, 'Type "%s" is not available.' % val)
-                                        return False
-
-                                product_line = val
-                                break
-
-                        elif opt in ['-h', '--help']:
-                                _from = nm_to_n(e.source()) # ログを流しおしたうのでヘルプは盎接送信å
+    process_keyword メ゜ッドで Amazon ぞク゚リを投げお結果を返す
+    """
+    _AVAIL_PRODUCT_LINES = {
+        'books-jp': '(和曞, default)',
+        'books-us': '(掋曞)',
+        'music-jp': '(ポピュラヌ音楜)',
+        'classical-jp': '(クラシック音楜)',
+        'dvd-jp': '(DVD)',
+        'vhs-jp': '(ビデオ)',
+        'electronics-jp': '(゚レクトロニクス)',
+        'kitchen-jp': '(ホヌムキッチン)',
+        'software-jp': '(゜フトりェア)',
+        'videogames-jp': '(ゲヌム)',
+        'magazines-jp': '(雑誌)',
+        'toys-jp': '(おもちゃホビヌ)',
+    }
+
+    def __init__(self):
+        AmazonBotBase.__init__(self)
+
+    def get_version(self):
+        return 'AmazonBot by %s, based on python-irclib' % __author__
+
+    def onmsg_isbn(self, c, e, to, args):
+        """Syntax: !isbn <ISBN number>
+        """
+        return self.onmsg_asin(c, e, to, args)
+    def onmsg_asin(self, c, e, to, args):
+        """Syntax: !asin <ASIN number>
+        """
+        _debug('in asin command: %s', str(args))
+
+        try:
+            data = my_amazon.searchByASIN(args[0])
+        except my_amazon.AmazonError, err:
+            c.notice(to, ununicoding(config.get('bot', 'no_products')))
+            _debug('Caught AmazonError in onmsg_asin: %s', str(err))
+            return False
+        except IndexError, err:
+            c.notice(to, 'Please specify an argument.')
+            return False
+
+        return self._process_onmsg(c, e, to, data)
+
+    def onmsg_k(self, c, e, to, args): return self.onmsg_keyword(c, e, to, args)
+    def onmsg_keyword(self, c, e, to, args):
+        """Syntax: !keyword [-h] [-t type] <keyword1> [, keyword2, ...]
+        """
+        _debug('in keyword command: %s', str(args))
+
+        try:
+            options, rest = getopt.getopt(args, 't:h', ['type=', 'help'])
+        except getopt.GetoptError, err:
+            _debug('Caught GetoptError in onmsg_keyword: %s', str(err))
+            return False
+
+        keyword = ' '.join(rest).strip()
+        product_line = 'books-jp'
+        for opt, val in options:
+            if opt in ['-t', '--type']:
+                if val not in self._AVAIL_PRODUCT_LINES.keys():
+                    c.notice(to, 'Type "%s" is not available.' % val)
+                    return False
+
+                product_line = val
+                break
+
+            elif opt in ['-h', '--help']:
+                _from = nm_to_n(e.source()) # ログを流しおしたうのでヘルプは盎接送信å
 ƒãž
-                                c.notice(_from, ununicoding('Available types:'))
-
-                                for key, val in self._AVAIL_PRODUCT_LINES.iteritems():
-                                        time.sleep(1) # XXX: 連続投皿するず匟かれるこずがあるので暫定察凊
-                                        c.notice(_from, ununicoding(' * %s: %s' % (key, val)))
-
-                                return True
-
-                if not keyword:
-                        c.notice(to, 'Please specify keywords.')
-                        return False
-
-                if __debug__:
-                        fmt = 'DEBUG> keyword="%s", product_line=%s'
-                        print >> sys.stderr, fmt % (ununicoding(keyword, 'euc-jp'), product_line)
-
-                try:
-                        data = my_amazon.searchByKeyword(keyword, product_line=product_line)
-                except my_amazon.AmazonError, err:
-                        c.notice(to, ununicoding(config.get('bot', 'no_products')))
-                        if __debug__:
-                                print >> sys.stderr, 'DEBUG> Caught AmazonError in onmsg_amazon: %s' % str(err)
-                        return False
-
-                return self._process_onmsg(c, e, to, data)
-
-        def onmsg_h(self, c, e, to, args): return self.onmsg_help(c, e, to, args)
-        def onmsg_help(self, c, e, to, args):
-                """Syntax: !help
-                """
-                if __debug__:
-                        print >> sys.stderr, 'DEBUG> in help command: %s' % str(args)
-
-                _from = nm_to_n(e.source()) # ログを流しおしたうのでヘルプは盎接送信å
+                c.notice(_from, ununicoding('Available types:'))
+
+                for key, val in self._AVAIL_PRODUCT_LINES.iteritems():
+                    time.sleep(1) # XXX: 連続投皿するず匟かれるこずがあるので暫定察凊
+                    c.notice(_from, ununicoding(' * %s: %s' % (key, val)))
+
+                return True
+
+        if not keyword:
+            c.notice(to, 'Please specify keywords.')
+            return False
+
+        _debug('keyword="%s", product_line=%s', keyword, product_line)
+
+        try:
+            data = my_amazon.searchByKeyword(keyword, product_line=product_line)
+        except my_amazon.AmazonError, err:
+            c.notice(to, ununicoding(config.get('bot', 'no_products')))
+            _debug('Caught AmazonError in onmsg_amazon: %s', str(err))
+            return False
+
+        return self._process_onmsg(c, e, to, data)
+
+    def onmsg_h(self, c, e, to, args): return self.onmsg_help(c, e, to, args)
+    def onmsg_help(self, c, e, to, args):
+        """Syntax: !help
+        """
+        _debug('in help command: %s', str(args))
+
+        _from = nm_to_n(e.source()) # ログを流しおしたうのでヘルプは盎接送信å
 ƒãž
-                docs = []
-                for key in dir(self):
-                        val = getattr(self, key, '')
-                        if __debug__:
-                                print >> sys.stderr, 'DEBUG> key=%s, val=%s' % (key, ununicoding(str(val), 'euc-jp'))
-
-                        if key[:6] != 'onmsg_':
-                                continue
-
-                        doc = val.__doc__
-                        if doc:
-                                doc = doc.strip()
-                                if not doc:
-                                        continue
-                                time.sleep(1) # XXX: 連続投皿するず匟かれるっぜいので暫定察凊
-                                c.notice(_from, doc)
-
-                return True
-
-        def _process_onmsg(self, c, e, to, data):
-                if type(data.Details) is not list:
-                        data.Details = [data.Details]
-
-                detail = random.choice(data.Details)
-                title = ununicoding(detail.ProductName)
-                url = ununicoding(detail.URL)
-                c.notice(to, '%(title)s: %(url)s' % locals())
-
-                return True
-
-        def process_keyword(self, keyword):
-                keyword = ununicoding(keyword, 'utf-8')
-                if __debug__:
-                        print >> sys.stderr, 'DEBUG> KEYWORD: %s' % ununicoding(keyword, 'euc-jp')
-
-                try:
-                        data = my_amazon.searchByBlended(keyword)
-                        if type(data.ProductLine) is not type([]):
-                                data.ProductLine = [data.ProductLine]
-                except my_amazon.AmazonError, err:
-                        if __debug__:
-                                print >> sys.stderr, 'DEBUG> Caught AmazonError: %s' % str(err)
-                        return [None, None]
-
-                product_line = random.choice(data.ProductLine)
-                detail = random.choice(product_line.ProductInfo.Details)
-
-                url = unicoding(getattr(detail, 'URL', None))
-                product_name = unicoding(getattr(detail, 'ProductName', None))
-
-                return [product_name, url]
+        docs = []
+        for key in dir(self):
+            val = getattr(self, key, '')
+            _debug('key=%s, val=%s', key, str(val))
+
+            if key[:6] != 'onmsg_':
+                continue
+
+            doc = val.__doc__
+            if doc:
+                doc = doc.strip()
+                if not doc:
+                    continue
+                time.sleep(1) # XXX: 連続投皿するず匟かれるっぜいので暫定察凊
+                c.notice(_from, doc)
+
+        return True
+
+    def _process_onmsg(self, c, e, to, data):
+        if type(data.Details) is not list:
+            data.Details = [data.Details]
+
+        detail = random.choice(data.Details)
+        title = ununicoding(detail.ProductName)
+        url = ununicoding(detail.URL)
+        c.notice(to, '%(title)s: %(url)s' % locals())
+
+        return True
+
+    def process_keyword(self, keyword):
+        keyword = ununicoding(keyword, 'utf-8')
+        _debug('KEYWORD: %s', keyword)
+
+        try:
+            data = my_amazon.searchByBlended(keyword)
+            if type(data.ProductLine) is not type([]):
+                data.ProductLine = [data.ProductLine]
+        except my_amazon.AmazonError, err:
+            _debug('Caught AmazonError: %s', str(err))
+            return [None, None]
+
+        product_line = random.choice(data.ProductLine)
+        detail = random.choice(product_line.ProductInfo.Details)
+
+        url = unicoding(getattr(detail, 'URL', None))
+        product_name = unicoding(getattr(detail, 'ProductName', None))
+
+        return [product_name, url]
 
 if __name__ == '__main__':
-        bot = AmazonBot()
-        bot.start()
-        print '> Bye ;)'
+    bot = AmazonBot()
+    bot.start()
+    print '> Bye ;)'