[perf] check duplicat accept respond

app/boxes.py

@@ -22,7 +22,7 @@ from urllib.parse import urlparse
 from sqlalchemy import select
 from sqlalchemy import delete
 from sqlalchemy.orm import joinedload
-from sqlalchemy.exc import  IntegrityError
+from sqlalchemy.exc import IntegrityError
 from loguru import logger
 from uuid import uuid4
 from datetime import datetime
@@ -166,9 +166,15 @@ async def process_incoming(
         ).unique().scalar_one_or_none()
 
         if "Accept" == ap_object["type"]:
-            inbox_object = build_object(ap_object)
-            db_session.add(inbox_object)
-            await db_session.flush()
+            try:
+                inbox_object = build_object(ap_object)
+                db_session.add(inbox_object)
+                await db_session.flush()
+            except IntegrityError:
+                logger.warning("Duplicate accept respond?")
+                await db_session.rollback()
+                return True
+
             await db_session.refresh(inbox_object)
 
             following = models.Following(