Fix connection bug (#136)

Author: davissp14

internal/flypg/node.go

@@ -276,7 +276,7 @@ func (n *Node) PostInit(ctx context.Context) error {
 		case StandbyRoleName:
 			// Register existing standby to take-on any configuration changes.
 			if err := n.RepMgr.registerStandby(); err != nil {
-				fmt.Printf("failed to register standby: %s\n", err)
+				fmt.Printf("failed to register existing standby: %s\n", err)
 			}
 		default:
 			return fmt.Errorf("member has unknown role: %q", member.Role)
@@ -342,7 +342,7 @@ func (n *Node) PostInit(ctx context.Context) error {
 			// Configure as standby
 			fmt.Println("Registering standby")
 			if err := n.RepMgr.registerStandby(); err != nil {
-				fmt.Printf("failed to register standby: %s\n", err)
+				fmt.Printf("failed to register new standby: %s\n", err)
 			}
 
 			// Let the boot process know that we've already been configured.

internal/flypg/registration.go

@@ -21,7 +21,7 @@ func isRegistered(ctx context.Context, conn *pgx.Conn, n *Node) (bool, error) {
 	// Below is for backwards compatibility
 	databases, err := admin.ListDatabases(ctx, conn)
 	if err != nil {
-		return false, err
+		return false, fmt.Errorf("failed to list databases: %s", err)
 	}
 
 	repmgrExists := false
@@ -38,11 +38,11 @@ func isRegistered(ctx context.Context, conn *pgx.Conn, n *Node) (bool, error) {
 
 	repConn, err := n.RepMgr.NewLocalConnection(ctx)
 	if err != nil {
-		return false, err
+		return false, fmt.Errorf("failed to connect to local repmgr: %s", err)
 	}
 	defer func() { _ = repConn.Close(ctx) }()
 
-	member, err := n.RepMgr.Member(ctx, conn)
+	member, err := n.RepMgr.Member(ctx, repConn)
 	if err != nil {
 		if errors.Is(err, pgx.ErrNoRows) {
 			return false, nil