summaryrefslogtreecommitdiff
path: root/lib/aggiedit/rooms.ex
diff options
context:
space:
mode:
Diffstat (limited to 'lib/aggiedit/rooms.ex')
-rw-r--r--lib/aggiedit/rooms.ex8
1 files changed, 7 insertions, 1 deletions
diff --git a/lib/aggiedit/rooms.ex b/lib/aggiedit/rooms.ex
index 41df588..239dd90 100644
--- a/lib/aggiedit/rooms.ex
+++ b/lib/aggiedit/rooms.ex
@@ -94,7 +94,7 @@ defmodule Aggiedit.Rooms do
end
def vote_count(post) do
- votes = post
+ post
|> Repo.preload(:votes)
|> Map.get(:votes)
|> Enum.map(fn vote -> if vote.is_up, do: 1, else: -1 end)
@@ -105,11 +105,17 @@ defmodule Aggiedit.Rooms do
is_up = direction == "upvote"
vote = %Vote{is_up: is_up, user: user, post: post}
|> Repo.insert(on_conflict: [set: [is_up: is_up]], conflict_target: [:user_id, :post_id])
+
post = change_post(post, %{score: vote_count(post)})
|> Repo.update()
+
broadcast_post_over_room(post, :post_voted)
end
+ def comment_post(%Post{} = post, %User{} = user, comment) do
+ Repo.insert(%Comment{comment: comment, user: user, post: post})
+ end
+
defp broadcast_post_over_room({:error, _reason}=error, _event), do: error
defp broadcast_post_over_room({:ok, post}, event) do
PubSub.broadcast(Aggiedit.PubSub, "room:#{post.room_id}:posts", {event, post})