From 3283900b0d0b98e5ca956f61ce09ab373cf0cbe8 Mon Sep 17 00:00:00 2001
From: tobi <31960611+tsmethurst@users.noreply.github.com>
Date: Fri, 27 Jan 2023 14:48:11 +0100
Subject: [feature] Federate reports to remote instance as Flag (if desired)
 (#1386)

* reports federate out, we did it lxds

* fix optional line start (should be optional slash)
---
 internal/processing/fromclientapi.go | 65 +++++++++++++++++++++++++++++++++---
 1 file changed, 61 insertions(+), 4 deletions(-)

(limited to 'internal/processing/fromclientapi.go')

diff --git a/internal/processing/fromclientapi.go b/internal/processing/fromclientapi.go
index 997e76691..6035130e2 100644
--- a/internal/processing/fromclientapi.go
+++ b/internal/processing/fromclientapi.go
@@ -345,10 +345,19 @@ func (p *processor) processDeleteAccountFromClientAPI(ctx context.Context, clien
 }
 
 func (p *processor) processReportAccountFromClientAPI(ctx context.Context, clientMsg messages.FromClientAPI) error {
-	// TODO: in a separate PR, handle side effects of flag/report
-	// 1. email admin(s)
-	// 2. federate report if necessary
-	return nil
+	report, ok := clientMsg.GTSModel.(*gtsmodel.Report)
+	if !ok {
+		return errors.New("report was not parseable as *gtsmodel.Report")
+	}
+
+	// TODO: in a separate PR, also email admin(s)
+
+	if !*report.Forwarded {
+		// nothing to do, don't federate the report
+		return nil
+	}
+
+	return p.federateReport(ctx, report)
 }
 
 // TODO: move all the below functions into federation.Federator
@@ -922,3 +931,51 @@ func (p *processor) federateUnblock(ctx context.Context, block *gtsmodel.Block)
 	_, err = p.federator.FederatingActor().Send(ctx, outboxIRI, undo)
 	return err
 }
+
+func (p *processor) federateReport(ctx context.Context, report *gtsmodel.Report) error {
+	if report.TargetAccount == nil {
+		reportTargetAccount, err := p.db.GetAccountByID(ctx, report.TargetAccountID)
+		if err != nil {
+			return fmt.Errorf("federateReport: error getting report target account from database: %w", err)
+		}
+		report.TargetAccount = reportTargetAccount
+	}
+
+	if len(report.StatusIDs) > 0 && len(report.Statuses) == 0 {
+		statuses, err := p.db.GetStatuses(ctx, report.StatusIDs)
+		if err != nil {
+			return fmt.Errorf("federateReport: error getting report statuses from database: %w", err)
+		}
+		report.Statuses = statuses
+	}
+
+	flag, err := p.tc.ReportToASFlag(ctx, report)
+	if err != nil {
+		return fmt.Errorf("federateReport: error converting report to AS flag: %w", err)
+	}
+
+	// add bto so that our federating actor knows where to
+	// send the Flag; it'll still use a shared inbox if possible
+	reportTargetURI, err := url.Parse(report.TargetAccount.URI)
+	if err != nil {
+		return fmt.Errorf("federateReport: error parsing outboxURI %s: %w", report.TargetAccount.URI, err)
+	}
+	bTo := streams.NewActivityStreamsBtoProperty()
+	bTo.AppendIRI(reportTargetURI)
+	flag.SetActivityStreamsBto(bTo)
+
+	// deliver the flag using the outbox of the
+	// instance account to anonymize the report
+	instanceAccount, err := p.db.GetInstanceAccount(ctx, "")
+	if err != nil {
+		return fmt.Errorf("federateReport: error getting instance account: %w", err)
+	}
+
+	outboxIRI, err := url.Parse(instanceAccount.OutboxURI)
+	if err != nil {
+		return fmt.Errorf("federateReport: error parsing outboxURI %s: %w", instanceAccount.OutboxURI, err)
+	}
+
+	_, err = p.federator.FederatingActor().Send(ctx, outboxIRI, flag)
+	return err
+}
-- 
cgit v1.2.3