discover nodes in memberlist for raft join config

adapters/handlers/rest/configure_api.go

@@ -248,9 +248,7 @@ func MakeAppState(ctx context.Context, options *swag.CommandLineOptionsGroup) *s
  schemaTxPersistence := txstore.NewStore(
  appState.ServerConfig.Config.Persistence.DataPath, appState.Logger)
 
- /// TODO-RAFT START
- //
- server2port, err := parseNode2Port(appState)
+ server2port, err := discoverNodes2Port(appState)
  if len(server2port) == 0 || err != nil {
  appState.Logger.
  WithField("action", "startup").
@@ -426,8 +424,13 @@ func MakeAppState(ctx context.Context, options *swag.CommandLineOptionsGroup) *s
  return appState
 }
 
-func parseNode2Port(appState *state.State) (m map[string]int, err error) {
- m = make(map[string]int, len(appState.ServerConfig.Config.Raft.Join))
+// discoverNodes2Port it will collect nodes info from configrued RAFT_JOIN, RAFT_PORT
+// and will get nodes from memberlist if weren't configured and assign them with
+// default RAFT port
+func discoverNodes2Port(appState *state.State) (m map[string]int, err error) {
+ m = make(map[string]int, len(appState.Cluster.AllNames()))
+
+ // parse RAFT_JOIN config
  for _, raftNamePort := range appState.ServerConfig.Config.Raft.Join {
  np := strings.Split(raftNamePort, ":")
  if np[0] == appState.Cluster.LocalName() {
@@ -439,6 +442,16 @@ func parseNode2Port(appState *state.State) (m map[string]int, err error) {
  }
  }
 
+ // memberlist doesn't match raft join
+ if len(appState.ServerConfig.Config.Raft.Join) != len(appState.Cluster.AllNames()) {
+ for _, n := range appState.Cluster.AllNames() {
+ if n == appState.Cluster.LocalName() {
+ continue
+ }
+ m[n] = config.DefaultRaftInternalPort
+ }
+ }
+
  return m, nil
 }