huginn/app/models/agents/weibo_user_agent.rb

# encoding: utf-8 
require "weibo_2"

module Agents
  class WeiboUserAgent < Agent
    cannot_receive_events!

    description <<-MD
      The WeiboUserAgent follows the timeline of a specified Weibo user. It uses this endpoint: http://open.weibo.com/wiki/2/statuses/user_timeline/en

      You must first set up a Weibo app and generate an `acess_token` to authenticate with. Provide that, along with the `app_key` and `app_secret` for your Weibo app in the options.

      Specify the `uid` of the Weibo user whose timeline you want to watch.

      Set `expected_update_period_in_days` to the maximum amount of time that you'd expect to pass between Events being created by this Agent.
    MD

    event_description <<-MD
      Events are the raw JSON provided by the Twitter API. Should look something like:

        {
          "created_at": "Tue May 31 17:46:55 +0800 2011",
          "id": 11488058246,
          "text": "求关注。",
          "source": "<a href=\"http://weibo.com\" rel=\"nofollow\">新浪微博</a>",
          "favorited": false,
          "truncated": false,
          "in_reply_to_status_id": "",
          "in_reply_to_user_id": "",
          "in_reply_to_screen_name": "",
          "geo": null,
          "mid": "5612814510546515491",
          "reposts_count": 8,
          "comments_count": 9,
          "annotations": [],
          "user": {
              "id": 1404376560,
              "screen_name": "zaku",
              "name": "zaku",
              "province": "11",
              "city": "5",
              "location": "北京 朝阳区",
              "description": "人生五十年，乃如梦如幻；有生斯有死，壮士复何憾。",
              "url": "http://blog.sina.com.cn/zaku",
              "profile_image_url": "http://tp1.sinaimg.cn/1404376560/50/0/1",
              "domain": "zaku",
              "gender": "m",
              "followers_count": 1204,
              "friends_count": 447,
              "statuses_count": 2908,
              "favourites_count": 0,
              "created_at": "Fri Aug 28 00:00:00 +0800 2009",
              "following": false,
              "allow_all_act_msg": false,
              "remark": "",
              "geo_enabled": true,
              "verified": false,
              "allow_all_comment": true,
              "avatar_large": "http://tp1.sinaimg.cn/1404376560/180/0/1",
              "verified_reason": "",
              "follow_me": false,
              "online_status": 0,
              "bi_followers_count": 215
          }
        }
    MD

    default_schedule "every_1h"

    def validate_options
      unless options[:uid].present? &&
        options[:expected_update_period_in_days].present? &&
        options[:app_key].present? &&
        options[:app_secret].present? &&
        options[:access_token].present?
        errors.add(:base, "expected_update_period_in_days, uid, app_key, app_secret and access_token are required")
      end
    end

    def working?
      (event = event_created_within(options[:expected_update_period_in_days].to_i.days)) && event.payload.present?
    end

    def default_options
      {
          :uid => "",
          :access_token => "---",
          :app_key => "---",
          :app_secret => "---",
          :expected_update_period_in_days => "2"
      }
    end

    def check
      WeiboOAuth2::Config.api_key = options[:app_key] # WEIBO_APP_KEY
      WeiboOAuth2::Config.api_secret = options[:app_secret] # WEIBO_APP_SECRET
      client = WeiboOAuth2::Client.new
      client.get_token_from_hash :access_token => options[:access_token]


      since_id = memory[:since_id] || nil
      opts = {:uid => options[:uid].to_i}
      opts.merge! :since_id => since_id unless since_id.nil?

      # http://open.weibo.com/wiki/2/statuses/user_timeline/en
      resp = client.statuses.user_timeline opts
      if resp[:statuses]


        resp[:statuses].each do |status|
          memory[:since_id] = status.id if !memory[:since_id] || (status.id > memory[:since_id])

          create_event :payload => status.as_json
        end
      end

      save!
    end
  end
end