summaryrefslogtreecommitdiffstats
path: root/users/models
diff options
context:
space:
mode:
Diffstat (limited to 'users/models')
-rw-r--r--users/models/inbox_message.py9
-rw-r--r--users/models/report.py42
2 files changed, 48 insertions, 3 deletions
diff --git a/users/models/inbox_message.py b/users/models/inbox_message.py
index 6c36043..d6d4f43 100644
--- a/users/models/inbox_message.py
+++ b/users/models/inbox_message.py
@@ -16,7 +16,7 @@ class InboxMessageStates(StateGraph):
@classmethod
async def handle_received(cls, instance: "InboxMessage"):
from activities.models import Post, PostInteraction
- from users.models import Follow, Identity
+ from users.models import Follow, Identity, Report
match instance.message_type:
case "follow":
@@ -29,6 +29,8 @@ class InboxMessageStates(StateGraph):
match instance.message_object_type:
case "note":
await sync_to_async(Post.handle_create_ap)(instance.message)
+ case "question":
+ pass # Drop for now
case unknown:
raise ValueError(
f"Cannot handle activity of type create.{unknown}"
@@ -39,6 +41,8 @@ class InboxMessageStates(StateGraph):
await sync_to_async(Post.handle_update_ap)(instance.message)
case "person":
await sync_to_async(Identity.handle_update_ap)(instance.message)
+ case "question":
+ pass # Drop for now
case unknown:
raise ValueError(
f"Cannot handle activity of type update.{unknown}"
@@ -87,6 +91,9 @@ class InboxMessageStates(StateGraph):
case "remove":
# We are ignoring these right now (probably pinned items)
pass
+ case "flag":
+ # Received reports
+ await sync_to_async(Report.handle_ap)(instance.message)
case unknown:
raise ValueError(f"Cannot handle activity of type {unknown}")
return cls.processed
diff --git a/users/models/report.py b/users/models/report.py
index 7bafd0c..3a26897 100644
--- a/users/models/report.py
+++ b/users/models/report.py
@@ -1,10 +1,12 @@
+from urllib.parse import urlparse
+
import httpx
import urlman
from django.db import models
-from core.ld import canonicalise
+from core.ld import canonicalise, get_list
from stator.models import State, StateField, StateGraph, StatorModel
-from users.models import SystemActor
+from users.models import Domain
class ReportStates(StateGraph):
@@ -18,6 +20,8 @@ class ReportStates(StateGraph):
"""
Sends the report to the remote server if we need to
"""
+ from users.models import SystemActor
+
report = await instance.afetch_full()
if report.forward and not report.subject_identity.domain.local:
system_actor = SystemActor()
@@ -111,7 +115,41 @@ class Report(StatorModel):
"subject_post",
).aget(pk=self.pk)
+ @classmethod
+ def handle_ap(cls, data):
+ """
+ Handles an incoming flag
+ """
+ from activities.models import Post
+ from users.models import Identity
+
+ # Fetch the system actor
+ domain_id = urlparse(data["actor"]).hostname
+ # Resolve the objects into items
+ objects = get_list(data, "object")
+ subject_identity = None
+ subject_post = None
+ for object in objects:
+ identity = Identity.objects.filter(local=True, actor_uri=object).first()
+ post = Post.objects.filter(local=True, object_uri=object).first()
+ if identity:
+ subject_identity = identity
+ if post:
+ subject_post = post
+ if subject_identity is None:
+ raise ValueError("Cannot handle flag: no identity object")
+ # Make a report object
+ cls.objects.create(
+ subject_identity=subject_identity,
+ subject_post=subject_post,
+ source_domain=Domain.get_remote_domain(domain_id),
+ type="remote",
+ complaint=data.get("content"),
+ )
+
def to_ap(self):
+ from users.models import SystemActor
+
system_actor = SystemActor()
if self.subject_post:
objects = [