Page Menu
Home
Phorge
Search
Configure Global Search
Log In
Files
F85829404
No One
Temporary
Actions
View File
Edit File
Delete File
View Transforms
Subscribe
Mute Notifications
Flag For Later
Award Token
Authored By
Unknown
Size
1 KB
Referenced Files
None
Subscribers
None
View Options
diff --git a/lib/pleroma/activity.ex b/lib/pleroma/activity.ex
index c4efc6283..46568bb13 100644
--- a/lib/pleroma/activity.ex
+++ b/lib/pleroma/activity.ex
@@ -1,9 +1,21 @@
defmodule Pleroma.Activity do
use Ecto.Schema
+ alias Pleroma.{Repo, Activity}
+ import Ecto.Query
schema "activities" do
field :data, :map
timestamps()
end
+
+ def get_by_ap_id(ap_id) do
+ Repo.one(from activity in Activity,
+ where: fragment("? @> ?", activity.data, ^%{id: ap_id}))
+ end
+
+ def all_by_object_ap_id(ap_id) do
+ Repo.all(from activity in Activity,
+ where: fragment("? @> ?", activity.data, ^%{object: %{id: ap_id}}))
+ end
end
diff --git a/test/activity_test.exs b/test/activity_test.exs
new file mode 100644
index 000000000..ce6eb1545
--- /dev/null
+++ b/test/activity_test.exs
@@ -0,0 +1,18 @@
+defmodule Pleroma.ActivityTest do
+ use Pleroma.DataCase
+ import Pleroma.Factory
+
+ test "returns an activity by it's AP id" do
+ activity = insert(:note_activity)
+ found_activity = Pleroma.Activity.get_by_ap_id(activity.data["id"])
+
+ assert activity == found_activity
+ end
+
+ test "returns activities by it's objects AP ids" do
+ activity = insert(:note_activity)
+ [found_activity] = Pleroma.Activity.all_by_object_ap_id(activity.data["object"]["id"])
+
+ assert activity == found_activity
+ end
+end
diff --git a/test/object_test.exs b/test/object_test.exs
new file mode 100644
index 000000000..3ffddbbc5
--- /dev/null
+++ b/test/object_test.exs
@@ -0,0 +1,11 @@
+defmodule Pleroma.ObjectTest do
+ use Pleroma.DataCase
+ import Pleroma.Factory
+
+ test "returns an object by it's AP id" do
+ object = insert(:note)
+ found_object = Pleroma.Object.get_by_ap_id(object.data["id"])
+
+ assert object == found_object
+ end
+end
File Metadata
Details
Attached
Mime Type
text/x-diff
Expires
Sat, Oct 31, 7:40 PM (16 h, 49 m)
Storage Engine
blob
Storage Format
Raw Data
Storage Handle
1801725
Default Alt Text
(1 KB)
Attached To
Mode
rPUBE pleroma-upstream
Attached
Detach File
Event Timeline