feat: begin tracking relay sends/receipts for ap analytics

src/activitypub/analytics.js

@@ -57,4 +57,16 @@ Analytics.receiptError = async (body, error) => {
 		analytics.increment(['ap.inErr', `ap.inErr:byHost:${hostname}`]),
 	]);
 	await db.expire(`ap.errors:${id}`, 60 * 60 * 24); // 24 hours
+};
+
+Analytics.relays = {};
+
+Analytics.relays.in = (relay) => {
+	const { hostname } = new URL(relay);
+	analytics.increment(['ap.relayIn', `ap.relayIn:byHost:${hostname}`]);
+};
+
+Analytics.relays.out = (relay) => {
+	const { hostname } = new URL(relay);
+	analytics.increment(['ap.relayOut', `ap.relayOut:byHost:${hostname}`]);
 };

src/activitypub/feps.js

@@ -77,4 +77,8 @@ Feps.announce = async function announce(id, activity) {
 		cc,
 		object: activity,
 	});
+
+	relays.forEach((relay) => {
+		activitypub.analytics.relay.out(relay);
+	});
 };

src/activitypub/inbox.js

@@ -469,6 +469,10 @@ inbox.announce = async (req) => {
 						await topics.crossposts.add(tid, cid, 0);
 					}));
 				}
+
+				if (fromRelay) {
+					activitypub.analytics.relays.in(actor);
+				}
 			}
 
 			if (!cid) { // Topic events from actors followed by users only