50 lines
1.4 KiB
Go
50 lines
1.4 KiB
Go
package frontend
|
|
|
|
import (
|
|
"net"
|
|
|
|
"github.com/btcsuite/btcd/rpcclient"
|
|
"github.com/pkg/errors"
|
|
ini "gopkg.in/ini.v1"
|
|
)
|
|
|
|
func NewZRPCFromConf(confPath interface{}) (*rpcclient.Client, error) {
|
|
connCfg, err := connFromConf(confPath)
|
|
if err != nil {
|
|
return nil, err
|
|
}
|
|
return rpcclient.New(connCfg, nil)
|
|
}
|
|
|
|
// If passed a string, interpret as a path, open and read; if passed
|
|
// a byte slice, interpret as the config file content (used in testing).
|
|
func connFromConf(confPath interface{}) (*rpcclient.ConnConfig, error) {
|
|
cfg, err := ini.Load(confPath)
|
|
if err != nil {
|
|
return nil, errors.Wrap(err, "failed to read config file")
|
|
}
|
|
|
|
rpcaddr := cfg.Section("").Key("rpcbind").String()
|
|
if rpcaddr == "" {
|
|
rpcaddr = "127.0.0.1"
|
|
}
|
|
rpcport := cfg.Section("").Key("rpcport").String()
|
|
if rpcport == "" {
|
|
rpcport = "8232" // mainnet
|
|
}
|
|
username := cfg.Section("").Key("rpcuser").String()
|
|
password := cfg.Section("").Key("rpcpassword").String()
|
|
|
|
// Connect to local Zcash RPC server using HTTP POST mode.
|
|
connCfg := &rpcclient.ConnConfig{
|
|
Host: net.JoinHostPort(rpcaddr, rpcport),
|
|
User: username,
|
|
Pass: password,
|
|
HTTPPostMode: true, // Zcash only supports HTTP POST mode
|
|
DisableTLS: true, // Zcash does not provide TLS by default
|
|
}
|
|
// Notice the notification parameter is nil since notifications are
|
|
// not supported in HTTP POST mode.
|
|
return connCfg, nil
|
|
}
|