DocumentMappings.Activity.id(activity),
DocumentMappings.Activity.encode(activity)
)
-
- {:ok, _} =
- bulk_post(
- activity.object.hashtags,
- :hashtags
- )
end
def put(%User{} = user) do
)
end
+ def maybe_bulk_post(data, type) do
+ if enabled?() do
+ bulk_post(data, type)
+ end
+ end
+
def bulk_post(data, :users) do
d =
data
{:ok, Repo.all(from(ht in Hashtag, where: ht.name in ^names))}
end)
|> Repo.transaction() do
+ Pleroma.Elasticsearch.bulk_post(hashtags, :hashtags)
{:ok, hashtags}
else
{:error, _name, value, _changes_so_far} -> {:error, value}