cerc-io/lotus
16
0
Fork 0
Code Issues Pull Requests Packages Projects Releases 27 Wiki Activity

lotus-provider: fix RPC construction

Browse Source
This commit is contained in:
Łukasz Magiera 2023-12-04 14:10:24 +01:00
parent 0c866e08cb
commit ae67cbdb4d
3 changed files with 6 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
api/permissioned.go
View File

@ -41,8 +41,8 @@ func PermissionedWorkerAPI(a Worker) Worker {
return &out return &out
} }
func PermissionedAPI[T any](a T) T { func PermissionedAPI[T, P any](a T) P {
var out T var out P
permissionedProxies(a, &out) permissionedProxies(a, &out)
return out return out
} }

4
cmd/lotus-provider/rpc/rpc.go
View File

@ -26,9 +26,9 @@ func LotusProviderHandler(
readerHandler, readerServerOpt := rpcenc.ReaderParamDecoder() readerHandler, readerServerOpt := rpcenc.ReaderParamDecoder()
rpcServer := jsonrpc.NewServer(jsonrpc.WithServerErrors(api.RPCErrors), readerServerOpt) rpcServer := jsonrpc.NewServer(jsonrpc.WithServerErrors(api.RPCErrors), readerServerOpt)
wapi := proxy.MetricedAPI(a) wapi := proxy.MetricedAPI[api.LotusProvider, api.LotusProviderStruct](a)
if permissioned { if permissioned {
wapi = api.PermissionedAPI(wapi) wapi = api.PermissionedAPI[api.LotusProvider, api.LotusProviderStruct](wapi)
} }
rpcServer.Register("Filecoin", wapi) rpcServer.Register("Filecoin", wapi)

4
metrics/proxy/proxy.go
View File

@ -10,8 +10,8 @@ import (
"github.com/filecoin-project/lotus/metrics" "github.com/filecoin-project/lotus/metrics"
) )
func MetricedAPI[T any](a T) T { func MetricedAPI[T, P any](a T) P {
var out T var out P
proxy(a, &out) proxy(a, &out)
return out return out
} }