Cache offers in json rpc APIs.

status-im · Nov 4, 2024 · a76d712 · a76d712
1 parent 6404565
commit a76d712
Show file tree

Hide file tree

Showing 3 changed files with 4 additions and 4 deletions.
diff --git a/fluffy/rpc/rpc_portal_beacon_api.nim b/fluffy/rpc/rpc_portal_beacon_api.nim
@@ -116,7 +116,7 @@ proc installPortalBeaconApiHandlers*(rpcServer: RpcServer, p: PortalProtocol) =
       contentId = p.toContentId(key).valueOr:
         raise invalidKeyErr()
 
-    p.storeContent(key, contentId, contentValueBytes)
+    p.storeContent(key, contentId, contentValueBytes, cacheOffer = true)
 
   rpcServer.rpc("portal_beaconLocalContent") do(contentKey: string) -> string:
     let

diff --git a/fluffy/rpc/rpc_portal_history_api.nim b/fluffy/rpc/rpc_portal_history_api.nim
@@ -116,7 +116,7 @@ proc installPortalHistoryApiHandlers*(rpcServer: RpcServer, p: PortalProtocol) =
       contentId = p.toContentId(key).valueOr:
         raise invalidKeyErr()
 
-    p.storeContent(key, contentId, contentValueBytes)
+    p.storeContent(key, contentId, contentValueBytes, cacheOffer = true)
 
   rpcServer.rpc("portal_historyLocalContent") do(contentKey: string) -> string:
     let

diff --git a/fluffy/rpc/rpc_portal_state_api.nim b/fluffy/rpc/rpc_portal_state_api.nim
@@ -137,7 +137,7 @@ proc installPortalStateApiHandlers*(rpcServer: RpcServer, p: PortalProtocol) =
       contentValue = validateOfferGetValue(Opt.none(Hash32), key, contentBytes).valueOr:
         raise invalidValueErr()
 
-    p.storeContent(keyBytes, contentId, contentValue)
+    p.storeContent(keyBytes, contentId, contentValue, cacheOffer = true)
 
   rpcServer.rpc("portal_stateLocalContent") do(contentKey: string) -> string:
     let
@@ -159,7 +159,7 @@ proc installPortalStateApiHandlers*(rpcServer: RpcServer, p: PortalProtocol) =
       contentValue = validateOfferGetValue(Opt.none(Hash32), key, contentBytes).valueOr:
         raise invalidValueErr()
 
-    p.storeContent(keyBytes, contentId, contentValue)
+    p.storeContent(keyBytes, contentId, contentValue, cacheOffer = true)
 
     await p.neighborhoodGossip(
       Opt.none(NodeId), ContentKeysList(@[keyBytes]), @[contentBytes]