refactor

1 files changed, 35 insertions, 0 deletions

diff --git a/service/rpc/config.go b/service/rpc/config.go
new file mode 100644
index 00000000..06d63d65
--- /dev/null
+++ b/service/rpc/config.go
@@ -0,0 +1,35 @@
+package rpc
+
+import (
+	"errors"
+	"net"
+	"strings"
+)
+
+type config struct {
+	// Indicates if RPC connection is enabled.
+	Enable bool
+
+	// AddListener string
+	Listen string
+}
+
+// listener creates new rpc socket listener.
+func (cfg *config) listener() (net.Listener, error) {
+	dsn := strings.Split(cfg.Listen, "://")
+	if len(dsn) != 2 {
+		return nil, errors.New("invalid socket DSN (tcp://:6001, unix://rpc.sock)")
+	}
+
+	return net.Listen(dsn[0], dsn[1])
+}
+
+// dialer creates rpc socket dialer.
+func (cfg *config) dialer() (net.Conn, error) {
+	dsn := strings.Split(cfg.Listen, "://")
+	if len(dsn) != 2 {
+		return nil, errors.New("invalid socket DSN (tcp://:6001, unix://rpc.sock)")
+	}
+
+	return net.Dial(dsn[0], dsn[1])
+}