Bug fixes

Author: davissp14

pkg/flypg/admin/admin.go

@@ -76,7 +76,7 @@ func ResolveRole(ctx context.Context, pg *pgx.Conn) (string, error) {
 }
 
 func EnableExtension(pg *pgx.Conn, extension string) error {
-	sql := fmt.Sprintf("CREATE EXTENSION %s;", extension)
+	sql := fmt.Sprintf("CREATE EXTENSION IF NOT EXISTS %s;", extension)
 	_, err := pg.Exec(context.Background(), sql)
 	return err
 }

pkg/flypg/node.go

@@ -91,7 +91,7 @@ func NewNode() (*Node, error) {
 		ConfigPath:   "/data/repmgr.conf",
 		DataDir:      node.DataDir,
 		PrivateIP:    node.PrivateIP,
-		Port:         5432,
+		Port:         5433,
 		DatabaseName: "repmgr",
 		Credentials: Credentials{
 			Username: "repmgr",
@@ -112,7 +112,6 @@ func (n *Node) Init() error {
 		return fmt.Errorf("failed to establish connection with consul: %s", err)
 	}
 
-	// Check to see if there's already a registered primary.
 	primaryIP, err := consul.CurrentPrimary()
 	if err != nil {
 		return fmt.Errorf("failed to query current primary: %s", err)
@@ -224,6 +223,7 @@ func (n *Node) PostInit() error {
 		}
 
 		// Creates the replication manager database.
+		fmt.Println("Perform Repmgr setup")
 		if err := repmgr.setup(conn); err != nil {
 			return fmt.Errorf("failed to setup repmgr: %s", err)
 		}

pkg/flypg/repmgr.go

@@ -109,7 +109,7 @@ func (r *RepMgr) writeManagerConf() error {
 }
 
 func (r *RepMgr) registerPrimary() error {
-	cmdStr := fmt.Sprintf("repmgr -f %s primary register -F", r.ConfigPath)
+	cmdStr := fmt.Sprintf("repmgr -f %s primary register -F -v", r.ConfigPath)
 	if err := runCommand(cmdStr); err != nil {
 		return err
 	}