git.squeep.com Git - akkoma/blob - lib/pleroma/activity.ex

   1 defmodule Pleroma.Activity do
   2   use Ecto.Schema
   3   alias Pleroma.{Repo, Activity}
   4   import Ecto.Query
   5
   6   schema "activities" do
   7     field :data, :map
   8
   9     timestamps()
  10   end
  11
  12   def get_by_ap_id(ap_id) do
  13     Repo.one(from activity in Activity,
  14       where: fragment("? @> ?", activity.data, ^%{id: ap_id}))
  15   end
  16
  17   def all_by_object_ap_id(ap_id) do
  18     Repo.all(from activity in Activity,
  19       where: fragment("? @> ?", activity.data, ^%{object: %{id: ap_id}}))
  20   end
  21 end