- def render("chat_update.json", %{chat_message_reference: cm_ref}) do
- # Explicitly giving the cmr for the object here, so we don't accidentally
- # send a later 'last_message' that was inserted between inserting this and
- # streaming it out
- Logger.debug("Trying to stream out #{inspect(cm_ref)}")
+ def render("status_update.json", %Activity{} = activity, topic) do
+ activity = Activity.get_create_by_object_ap_id_with_object(activity.object.data["id"])