-
Notifications
You must be signed in to change notification settings - Fork 23
/
server.go
37 lines (30 loc) · 1.08 KB
/
server.go
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
package virtualfilter
import (
"github.com/Conflux-Chain/confura/cmd/util"
"github.com/Conflux-Chain/confura/store/mysql"
"github.com/Conflux-Chain/confura/util/rpc"
)
// MustNewEvmSpaceServerFromViper creates evm space virtual filters RPC server from viper settings
func MustNewEvmSpaceServerFromViper(
shutdownContext util.GracefulShutdownContext,
vfls *mysql.VirtualFilterLogStore,
) (*rpc.Server, string) {
conf := mustNewEthConfigFromViper()
fs := newEthFilterSystem(conf, vfls, shutdownContext)
srv := rpc.MustNewServer("eth_vfilter", map[string]interface{}{
"eth": newEthFilterApi(fs),
})
return srv, conf.Endpoint
}
// MustNewCoreSpaceServerFromViper creates core space virtual filters RPC server from viper settings
func MustNewCoreSpaceServerFromViper(
shutdownContext util.GracefulShutdownContext,
vfls *mysql.VirtualFilterLogStore,
) (*rpc.Server, string) {
conf := mustNewCfxConfigFromViper()
fs := newCfxFilterSystem(conf, vfls, shutdownContext)
srv := rpc.MustNewServer("cfx_vfilter", map[string]interface{}{
"cfx": newCfxFilterApi(fs),
})
return srv, conf.Endpoint
}