bug fix

Author: davissp14

pkg/flypg/node.go

@@ -139,6 +139,11 @@ func (n *Node) Init() error {
 				return fmt.Errorf("failed to resolve my role according to the primary: %s", err)
 			}
 			role, err := memberRoleByHostname(context.TODO(), remoteConn, n.PrivateIP)
+			if err != nil {
+				return fmt.Errorf("failed to resolve role for %s: %s", primaryIP, err)
+			}
+
+			fmt.Printf("My Role is: %s\n", role)
 			// Don't re-clone if we are already a standby.
 			if role == standbyRoleName {
 				clonePrimary = false

pkg/flypg/repmgr.go

@@ -11,6 +11,7 @@ import (
 const (
 	primaryRoleName = "primary"
 	standbyRoleName = "standby"
+	unknownRoleName = ""
 )
 
 func initializeRepmgr(node Node) error {
@@ -157,7 +158,7 @@ func memberRole(ctx context.Context, pg *pgx.Conn, id int) (string, error) {
 }
 
 func memberRoleByHostname(ctx context.Context, pg *pgx.Conn, hostname string) (string, error) {
-	sql := fmt.Sprintf("select n.type from repmgr.nodes n LEFT JOIN repmgr.nodes un ON un.node_id = n.upstream_node_id where n.connInfo LIKE '%%%s';", hostname)
+	sql := fmt.Sprintf("select n.type from repmgr.nodes n LEFT JOIN repmgr.nodes un ON un.node_id = n.upstream_node_id where n.connInfo LIKE '%%%s%%';", hostname)
 	var role string
 	err := pg.QueryRow(ctx, sql).Scan(&role)
 	if err != nil {