1 # Pleroma: A lightweight social networking server
2 # Copyright © 2017-2020 Pleroma Authors <https://pleroma.social/>
3 # SPDX-License-Identifier: AGPL-3.0-only
5 defmodule Pleroma.Hashtag do
19 many_to_many(:objects, Object, join_through: "hashtags_objects", on_replace: :delete)
24 def normalize_name(name) do
30 def get_by_name(name) do
31 Repo.get_by(Hashtag, name: normalize_name(name))
34 def get_or_create_by_name(name) when is_bitstring(name) do
35 with %Hashtag{} = hashtag <- get_by_name(name) do
40 |> changeset(%{name: name})
45 def get_or_create_by_names(names) when is_list(names) do
46 names = Enum.map(names, &normalize_name/1)
47 timestamp = NaiveDateTime.truncate(NaiveDateTime.utc_now(), :second)
50 Enum.map(names, fn name ->
52 |> changeset(%{name: name})
54 |> Map.merge(%{inserted_at: timestamp, updated_at: timestamp})
58 with {:ok, %{query_op: hashtags}} <-
60 |> Multi.insert_all(:insert_all_op, Hashtag, structs,
61 on_conflict: :nothing,
62 conflict_target: :name
64 |> Multi.run(:query_op, fn _repo, _changes ->
65 {:ok, Repo.all(from(ht in Hashtag, where: ht.name in ^names))}
67 |> Repo.transaction() do
70 {:error, _name, value, _changes_so_far} -> {:error, value}
77 def changeset(%Hashtag{} = struct, params) do
79 |> cast(params, [:name])
80 |> update_change(:name, &normalize_name/1)
81 |> validate_required([:name])
82 |> unique_constraint(:name)
85 def unlink(%Object{id: object_id}) do
86 with {_, hashtag_ids} <-
87 from(hto in "hashtags_objects",
88 where: hto.object_id == ^object_id,
89 select: hto.hashtag_id
92 {:ok, unreferenced_count} <- delete_unreferenced(hashtag_ids) do
93 {:ok, length(hashtag_ids), unreferenced_count}
97 @delete_unreferenced_query """
98 DELETE FROM hashtags WHERE id IN
99 (SELECT hashtags.id FROM hashtags
100 LEFT OUTER JOIN hashtags_objects
101 ON hashtags_objects.hashtag_id = hashtags.id
102 WHERE hashtags_objects.hashtag_id IS NULL AND hashtags.id = ANY($1));
105 def delete_unreferenced(ids) do
106 with {:ok, %{num_rows: deleted_count}} <- Repo.query(@delete_unreferenced_query, [ids]) do