1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
|
# frozen_string_literal: true
class Stream::Base
TYPES_OF_POST_IN_STREAM = ['StatusMessage', 'Reshare']
attr_accessor :max_time, :order, :user, :publisher
def initialize(user, opts={})
self.user = user
self.max_time = opts[:max_time]
self.order = opts[:order]
self.publisher = Publisher.new(self.user, publisher_opts)
end
#requied to implement said stream
def link(opts={})
'change me in lib/base_stream.rb!'
end
def post_from_group(post)
[]
end
# @return [String]
def title
'a title'
end
# @return [ActiveRecord::Relation<Post>]
def posts
Post.all
end
# @return [Array<Post>]
def stream_posts
self.posts.for_a_stream(max_time, order, self.user).tap do |posts|
like_posts_for_stream!(posts) #some sql person could probably do this with joins.
end
end
# @return [ActiveRecord::Association<Person>] AR association of people within stream's given aspects
def people
people_ids = self.stream_posts.map{|x| x.author_id}
Person.where(:id => people_ids).
includes(:profile)
end
# @return [Boolean]
def for_all_aspects?
true
end
#NOTE: MBS bad bad methods the fact we need these means our views are foobared. please kill them and make them
#private methods on the streams that need them
def aspects
user.post_default_aspects
end
# @return [Aspect] The first aspect in #aspects
def aspect
aspects.first
end
def max_time=(time_string)
@max_time = Time.at(time_string.to_i) unless time_string.blank?
@max_time ||= (Time.now + 1)
end
def order=(order_string)
@order = order_string
@order ||= 'created_at'
end
protected
# @return [void]
def like_posts_for_stream!(posts)
return posts unless @user
likes = Like.where(:author_id => @user.person_id, :target_id => posts.map(&:id), :target_type => "Post")
like_hash = likes.inject({}) do |hash, like|
hash[like.target_id] = like
hash
end
posts.each do |post|
post.user_like = like_hash[post.id]
end
end
# @return [Hash]
def publisher_opts
{}
end
# Memoizes all Contacts present in the Stream
#
# @return [Array<Contact>]
def contacts_in_stream
@contacts_in_stream ||= Contact.where(:user_id => user.id, :person_id => people.map(&:id)).load
end
end
|
