data/rbot/plugins/twitter.rb

   1 #-- vim:sw=2:et
   2 #++
   3 #
   4 # :title: Twitter Status Update for rbot
   5 #
   6 # Author:: Carter Parks (carterparks) <carter@carterparks.com>
   7 # Author:: Giuseppe "Oblomov" Bilotta <giuseppe.bilotta@gmail.com>
   8 #
   9 # Copyright:: (C) 2007 Carter Parks
  10 # Copyright:: (C) 2007 Giuseppe Bilotta
  11 #
  12 # Users can setup their twitter username and password and then begin updating
  13 # twitter whenever
  14
  15 require 'rexml/rexml'
  16 require 'cgi'
  17
  18 class TwitterPlugin < Plugin
  19   Config.register Config::IntegerValue.new('twitter.status_count',
  20     :default => 1, :validate => Proc.new { |v| v > 0 && v <= 10},
  21     :desc => "Maximum number of status updates shown by 'twitter status'")
  22
  23   def initialize
  24     super
  25
  26     class << @registry
  27       def store(val)
  28         val
  29       end
  30       def restore(val)
  31         val
  32       end
  33     end
  34
  35     @header = {
  36       'X-Twitter-Client' => 'rbot twitter plugin'
  37     }
  38   end
  39
  40   # return a help string when the bot is asked for help on this plugin
  41   def help(plugin, topic="")
  42     return "twitter status [status] => updates your status on twitter | twitter identify [username] [password] => ties your nick to your twitter username and password"
  43   end
  44
  45   # update the status on twitter
  46   def get_status(m, params)
  47
  48     nick = params[:nick] || @registry[m.sourcenick + "_username"]
  49
  50     if not nick
  51       m.reply "you should specify the username of the twitter touse, or identify using 'twitter identify [username] [password]'"
  52       return false
  53     end
  54
  55     user = URI.escape(nick)
  56
  57     count = @bot.config['twitter.status_count']
  58     uri = "http://twitter.com/statuses/user_timeline/#{user}.xml?count=#{count}"
  59
  60     response = @bot.httputil.get(uri, :headers => @header, :cache => false)
  61     debug response
  62
  63     texts = []
  64
  65     if response
  66       begin
  67         rex = REXML::Document.new(response)
  68         rex.root.elements.each("status") { |st|
  69           month, day, hour, min, sec, year = st.elements['created_at'].text.match(/\w+ (\w+) (\d+) (\d+):(\d+):(\d+) \S+ (\d+)/)[1..6]
  70           debug [year, month, day, hour, min, sec].inspect
  71           time = Time.local(year.to_i, month, day.to_i, hour.to_i, min.to_i, sec.to_i)
  72           now = Time.now
  73           delta = now - time
  74           msg = st.elements['text'].to_s + " (#{Utils.secs_to_string(delta.to_i)} ago via #{st.elements['source'].to_s})"
  75           texts << Utils.decode_html_entities(msg).ircify_html
  76         }
  77       rescue
  78         error $!
  79         m.reply "could not parse status for #{nick}"
  80         return false
  81       end
  82       m.reply texts.reverse.join("\n")
  83       return true
  84     else
  85       m.reply "could not get status for #{nick}"
  86       return false
  87     end
  88   end
  89
  90   # update the status on twitter
  91   def update_status(m, params)
  92
  93
  94     unless @registry.has_key?(m.sourcenick + "_password") && @registry.has_key?(m.sourcenick + "_username")
  95       m.reply "you must identify using 'twitter identify [username] [password]'"
  96       return false
  97     end
  98
  99     user = URI.escape(@registry[m.sourcenick + "_username"])
 100     pass = URI.escape(@registry[m.sourcenick + "_password"])
 101     uri = "http://#{user}:#{pass}@twitter.com/statuses/update.xml"
 102
 103     msg = params[:status].to_s
 104
 105     if msg.length > 160
 106       m.reply "your status message update is too long, please keep it under 140 characters if possible, 160 characters maximum"
 107       return
 108     end
 109
 110     if msg.length > 140
 111       m.reply "your status message is longer than 140 characters, which is not optimal, but I'm going to update anyway"
 112     end
 113
 114     source = "source=rbot"
 115     msg = "status=#{CGI.escape(msg)}"
 116     body = [source,msg].join("&")
 117
 118     response = @bot.httputil.post(uri, body, :headers => @header)
 119     debug response
 120
 121     if response.class == Net::HTTPOK
 122       m.reply "status updated"
 123     else
 124       m.reply "could not update status"
 125     end
 126   end
 127
 128   # ties a nickname to a twitter username and password
 129   def identify(m, params)
 130     @registry[m.sourcenick + "_username"] = params[:username].to_s
 131     @registry[m.sourcenick + "_password"] = params[:password].to_s
 132     m.reply "you're all setup!"
 133   end
 134 end
 135
 136 # create an instance of our plugin class and register for the "length" command
 137 plugin = TwitterPlugin.new
 138 plugin.map 'twitter identify :username :password', :action => "identify", :public => false
 139 plugin.map 'twitter update *status', :action => "update_status", :threaded => true
 140 plugin.map 'twitter status [:nick]', :action => "get_status", :threaded => true
 141