lib/social_profile/people/vkontakte.rb in social_profile-0.2.1 vs lib/social_profile/people/vkontakte.rb in social_profile-0.2.2

@@ -31,14 +31,200 @@
         counters = response["counters"] 
         return nil if counters["friends"].blank? && counters["followers"].blank?
 
         counters["friends"].to_i + counters["followers"].to_i
       end
+
+      # Get last limited posts from user_timeline, max 100 by query
+      #
+      def last_posts(options = {})
+        params = { 
+          :owner_id => user.identifier,
+          :count => 100, 
+          :filter => "owner", 
+          :offset => 0
+        }
+
+        params.merge!(options)
+
+        fetch_all_method_items_with_days("wall.get", params)
+      end
+
+      # Get last posts by N days from user_timeline
+      #
+      def last_post_by_days(days, options = {})
+        options = { :days => days }.merge(options)
+
+        last_posts(options)
+      end      
+
+      # Get object likes (post, comment, photo, audio, video, note, photo_comment, video_comment, topic_comment, sitepage)
+      #
+      def object_likes(uid, options = {})
+        fetch_all = options.delete(:fetch_all)
+
+        params = { 
+          :owner_id => user.identifier,
+          :count => 1000, 
+          :type => "post", 
+          :item_id => uid,
+          :offset => 0
+        }
+        params.merge!(options)
+        
+        if fetch_all
+          return fetch_all_method_items("likes.getList", params)
+        end
+
+
+        user.likes.getList(params)
+      end
+
+      # Get post comments
+      #
+      def post_comments(uid, options = {})
+        fetch_all = options.delete(:fetch_all)
+
+        params = { 
+          :owner_id => user.identifier,
+          :count => 100, 
+          :preview_length => 0, 
+          :need_likes => 1,
+          :post_id => uid,
+          :offset => 0
+        }
+        params.merge!(options)
+
+        if fetch_all
+          return fetch_all_method_items("wall.getComments", params)
+        end
+
+        user.wall.getComments(params)  
+      end
+
+      # Get post shares
+      #
+      def post_shares(uid, options = {})
+        fetch_all = options.delete(:fetch_all)
+
+        params = { 
+          :owner_id => user.identifier,
+          :count => 1000, 
+          :post_id => uid,
+          :offset => 0
+        }
+        params.merge!(options)
+
+        if fetch_all
+          return fetch_all_method_items("wall.getReposts", params)
+        end
+
+        user.wall.getReposts(params)  
+      end
+
+      # Get all photos comments
+      #
+      def photos_comments(options = {})
+        params = { 
+          :owner_id => user.identifier,
+          :count => 100, 
+          :need_likes => 1,
+          :offset => 0
+        }
+
+        params.merge!(options)
+
+        fetch_all_method_items_with_days("photos.getAllComments", params)
+      end
+
+      # Get all photos comments by days
+      #
+      def photos_comments_by_days(days, options = {})
+        options = { :days => days }.merge(options)
+
+        photos_comments(options)
+      end
+
+      # Get all friends list
+      #
+      def friends(options={})
+        options = {
+          :count => 5000,
+          :offset => 0,
+          :fields => "domain"
+        }.merge(options)
+
+        fetch_all_method_items(:fetch_friends, options)
+      end
+
+      # Get all followers list
+      #
+      def followers(options={})
+        options = {
+          :count => 1000,
+          :offset => 0,
+          :fields => "screen_name"
+        }.merge(options)
+
+        fetch_all_method_items(:fetch_followers, options)
+      end
       
       protected
       
         def user
           @user ||= ::Vkontakte::App::User.new(uid, :access_token => access_token)
+        end
+
+        def fetch_all_method_items(name, options)
+          methods = name.to_s.split(".")
+          response = methods.size == 2 ? user.send(methods[0]).send(methods[1], options) : user.send(name, options)
+
+          _items = response["items"]
+          return [] if _items.blank?
+
+          iteration = (response["count"].to_i / _items.size.to_f).ceil
+
+          iteration.times do |index|
+            next if index == 0
+
+            options[:offset] += options[:count]
+            _items += (methods.size == 2 ? user.send(methods[0]).send(methods[1], options) : user.send(name, options))["items"]
+          end
+
+          _items
+        end
+
+        def fetch_all_method_items_with_days(name, options)
+          days = options.delete(:days)
+          date_end = options.delete(:date_end)
+
+          methods = name.to_s.split(".")
+          response = methods.size == 2 ? user.send(methods[0]).send(methods[1], options) : user.send(name, options)
+
+          return [] if response.blank? || !response.is_a?(Hash)
+
+          _items = response["items"]
+          return [] if _items.blank?
+
+          if days
+            date = (date_end || Time.now) - days.days
+            iteration = (response["count"].to_i / _items.size.to_f).ceil
+            last_date = _items.last ? Time.at(_items.last["date"].to_i).to_datetime : nil
+
+            iteration.times do |index|
+              next if index == 0
+
+              options[:offset] += options[:count]
+              _items += (methods.size == 2 ? user.send(methods[0]).send(methods[1], options) : user.send(name, options))["items"]
+
+              last_date = _items.last ? Time.at(_items.last["date"].to_i).to_datetime : nil
+              break if last_date.blank? || last_date < date
+            end if !last_date.blank? && last_date > date
+
+            return _items.select { |item| Time.at(item["date"].to_i).to_datetime > date }
+          end
+          
+          _items
         end
     end
 
     class Album
       
\ No newline at end of file