Add settings switch for activity debug reports

config/settings-default.yaml

@@ -160,3 +160,8 @@ drop-delivery-after:
 retry-delivery-every:
   amount:               1
   unit:                 hours
+
+# How many activities to remember in the debug report list, showing latest
+# activities received in local inboxes and the result of their processing.
+# 'null' means disable the report page entirely.
+#activity-debug-reports: 10

src/Vervis/Application.hs

@@ -130,7 +130,10 @@ makeFoundation appSettings = do
 
     appActorFetchShare <- newResultShare actorFetchShareAction
 
-    appActivities <- newTVarIO mempty
+    appActivities <-
+        case appInboxDebugReportLength appSettings of
+            Nothing -> return Nothing
+            Just n -> Just . (n,) <$> newTVarIO mempty
 
     -- We need a log function to create a connection pool. We need a connection
     -- pool to create our foundation. And we need our foundation to get a

src/Vervis/Foundation.hs

@@ -113,7 +113,7 @@ data App = App
     , appHashidsContext :: HashidsContext
     , appActorFetchShare :: ActorFetchShare App
 
-    , appActivities  :: TVar (Vector ActivityReport)
+    , appActivities  :: Maybe (Int, TVar (Vector ActivityReport))
     }
 
 -- Aliases for the routes file, because it doesn't like spaces in path piece

src/Vervis/Handler/Inbox.hs

@@ -105,7 +105,8 @@ import Vervis.Settings
 
 getInboxR :: Handler Html
 getInboxR = do
-    acts <- liftIO . readTVarIO =<< getsYesod appActivities
+    acts <-
+        liftIO . readTVarIO . snd =<< maybe notFound return =<< getsYesod appActivities
     defaultLayout
         [whamlet|
             <p>
@@ -187,17 +188,18 @@ postSharerInboxR shrRecip = do
                 "application/ld+json; \
                 \profile=\"https://www.w3.org/ns/activitystreams\""
     recordActivity now result contentTypes = do
-        acts <- getsYesod appActivities
+        macts <- getsYesod appActivities
-        liftIO $ atomically $ modifyTVar' acts $ \ vec ->
+        for_ macts $ \ (size, acts) ->
-            let (msg, body) =
+            liftIO $ atomically $ modifyTVar' acts $ \ vec ->
-                    case result of
+                let (msg, body) =
-                        Left t -> (t, "{?}")
+                        case result of
-                        Right (o, t) -> (t, encodePretty o)
+                            Left t -> (t, "{?}")
-                item = ActivityReport now msg contentTypes body
+                            Right (o, t) -> (t, encodePretty o)
-                vec' = item `V.cons` vec
+                    item = ActivityReport now msg contentTypes body
-            in  if V.length vec' > 10
+                    vec' = item `V.cons` vec
-                    then V.init vec'
+                in  if V.length vec' > size
-                    else vec'
+                        then V.init vec'
+                        else vec'
 
 postProjectInboxR :: ShrIdent -> PrjIdent -> Handler ()
 postProjectInboxR _ _ = error "TODO implement postProjectInboxR"

src/Vervis/Settings.hs

@@ -148,6 +148,10 @@ data AppSettings = AppSettings
     , appDropDeliveryAfter        :: NominalDiffTime
       -- | How much time to wait between retries of failed deliveries.
     , appDeliveryRetryFreq        :: TimeInterval
+      -- | How many activities to remember in the debug report list, showing
+      -- latest activities received in local inboxes and the result of their
+      -- processing. 'Nothing' means disable the report page entirely.
+    , appInboxDebugReportLength   :: Maybe Int
     }
 
 instance FromJSON AppSettings where
@@ -196,6 +200,7 @@ instance FromJSON AppSettings where
         appRejectOnMaxKeys          <- o .: "reject-on-max-keys"
         appDropDeliveryAfter        <- ndt <$> o .: "drop-delivery-after"
         appDeliveryRetryFreq        <- interval <$> o .: "retry-delivery-every"
+        appInboxDebugReportLength   <- o .:? "activity-debug-reports"
 
         return AppSettings {..}
         where