hbs2-peer do reset command

hbs2-peer/app/PeerMain.hs

@@ -143,10 +143,6 @@ import Graphics.Vty.Platform.Unix qualified as Vty
 
 import Control.Concurrent.Async (ExceptionInLinkedThread(..))
 
-data GoAgainException = GoAgainException
-                        deriving (Eq,Ord,Show,Typeable)
-
-instance Exception GoAgainException
 
 -- TODO: write-workers-to-config
 defStorageThreads :: Integral a => a
@@ -1354,7 +1350,8 @@ runPeer opts = respawnOnError opts $ do
   setProbe rpcmsg rpcProbe
   addProbe rpcProbe
 
-  let rpcctx = RPC2Context { rpcConfig = fromPeerConfig conf
+  let rpcctx = RPC2Context { rpcSelf = myself
+                           , rpcConfig = fromPeerConfig conf
                            , rpcMessaging = rpcmsg
                            , rpcTCP = tcp
                            , rpcPokeAnswer = pokeAnsw

hbs2-peer/app/PeerTypes.hs

@@ -65,6 +65,11 @@ import UnliftIO
 
 import Streaming.Prelude qualified as S
 
+data GoAgainException = GoAgainException
+                        deriving (Eq,Ord,Show,Typeable)
+
+instance Exception GoAgainException
+
 data PeerInfo e =
   PeerInfo
   { _peerBurst          :: TVar Int

hbs2-peer/app/RPC2.hs

@@ -79,7 +79,7 @@ import Streaming.Prelude qualified as S
 instance (e ~ L4Proto, MonadUnliftIO m, HasRpcContext PeerAPI RPC2Context m) => HandleMethod m RpcRunScript where
   handleMethod top = do
 
-    co <- getRpcContext @PeerAPI
+    co@RPC2Context{..} <- getRpcContext @PeerAPI
 
     let cli = parseTop top & fromRight mempty
 
@@ -218,6 +218,11 @@ instance (e ~ L4Proto, MonadUnliftIO m, HasRpcContext PeerAPI RPC2Context m) =>
           _ -> do
             pure nil
 
+
+        entry $ bindMatch "reset" $ const do
+          throwTo rpcSelf GoAgainException
+          pure $ mkSym "reset"
+
         entry $ bindMatch "peer-info" $ const do
 
           now <- getTimeCoarse

hbs2-peer/lib/HBS2/Peer/RPC/Internal/Types.hs

@@ -25,13 +25,15 @@ import Data.Config.Suckless.Parse
 import Data.Kind
 import Control.Monad
 import Control.Monad.Reader
+import Control.Concurrent (ThreadId)
 import Data.ByteString ( ByteString )
 import UnliftIO
 import HBS2.Prelude (asyncLinked)
 
 data RPC2Context =
   RPC2Context
-  { rpcConfig              :: [Syntax C]
+  { rpcSelf                :: ThreadId
+  , rpcConfig              :: [Syntax C]
   , rpcMessaging           :: MessagingUnix
   , rpcTCP                 :: Maybe MessagingTCP
   , rpcPokeAnswer          :: String