Fix newPeerEnv: add _envEncryptionKeys

This commit is contained in:
Sergey Ivanov 2023-07-19 00:15:12 +04:00
parent 3abf7cbe1b
commit d8b1937b78
1 changed files with 4 additions and 1 deletions

View File

@ -157,7 +157,7 @@ data PeerEnv e =
, _envReqMsgLimit :: Cache (Peer e, Integer, Encoded e) () , _envReqMsgLimit :: Cache (Peer e, Integer, Encoded e) ()
, _envReqProtoLimit :: Cache (Peer e, Integer) () , _envReqProtoLimit :: Cache (Peer e, Integer) ()
, _envAsymmetricKeyPair :: AsymmKeypair (Encryption e) , _envAsymmetricKeyPair :: AsymmKeypair (Encryption e)
, _envEncryptionKeys :: TVar (HashMap (PeerData L4Proto) (CommonSecret (Encryption L4Proto))) , _envEncryptionKeys :: TVar (HashMap (PeerData e) (CommonSecret (Encryption e)))
} }
setEncryptionKey :: setEncryptionKey ::
@ -415,6 +415,8 @@ newPeerEnv :: forall e m . ( MonadIO m
, Pretty (Peer e) , Pretty (Peer e)
, HasNonces () m , HasNonces () m
, Asymm (Encryption e) , Asymm (Encryption e)
, Hashable (PubKey 'Sign (Encryption e))
, Hashable PeerNonce
) )
=> AnyStorage => AnyStorage
-> Fabriq e -> Fabriq e
@ -435,6 +437,7 @@ newPeerEnv s bus p = do
_envReqMsgLimit <- liftIO (Cache.newCache (Just defRequestLimit)) _envReqMsgLimit <- liftIO (Cache.newCache (Just defRequestLimit))
_envReqProtoLimit <- liftIO (Cache.newCache (Just defRequestLimit)) _envReqProtoLimit <- liftIO (Cache.newCache (Just defRequestLimit))
_envAsymmetricKeyPair <- asymmNewKeypair @(Encryption e) _envAsymmetricKeyPair <- asymmNewKeypair @(Encryption e)
_envEncryptionKeys <- liftIO (newTVarIO mempty)
pure PeerEnv {..} pure PeerEnv {..}
runPeerM :: forall e m . ( MonadIO m runPeerM :: forall e m . ( MonadIO m