redirect to OP thread if not OP

1 files changed, 12 insertions, 0 deletions

diff --git a/activitypub/object.go b/activitypub/object.go
index f2241b7..4682832 100644
--- a/activitypub/object.go
+++ b/activitypub/object.go
@@ -54,6 +54,18 @@ func (obj ObjectBase) CheckIfOP() (bool, error) {
 	return true, nil
 }
 
+func (obj ObjectBase) GetOP() (string, error) {
+	var id string
+
+	query := `select id from replies where inreplyto='' and id in (select inreplyto from replies where id=$1)`
+
+	if err := config.DB.QueryRow(query, obj.Id).Scan(&id); err != nil {
+		return obj.Id, nil
+	}
+
+	return id, nil
+}
+
 func (obj ObjectBase) CreatePreview() *NestedObjectBase {
 	var nPreview NestedObjectBase