+ activity_results = Task.await(activity_task)
+ direct_activity = Task.await(activity_fetch_task)
+
+ activity_results =
+ if direct_activity == nil do
+ activity_results
+ else
+ [direct_activity | activity_results]
+ end
+
+ activity_results
+ end
+
+ @impl true
+ def add_to_index(activity) do
+ Elasticsearch.put_document(Pleroma.Search.Elasticsearch.Cluster, activity, "activities")
+ end
+
+ @impl true
+ def remove_from_index(object) do
+ Elasticsearch.delete_document(Pleroma.Search.Elasticsearch.Cluster, object, "activities")