feat: Add resource for subscriptions

.github/workflows/test.yml

@@ -3,7 +3,7 @@ name: test
 on:
   push:
     branches:
-    - master
+      - master
   pull_request:
 
 jobs:
@@ -12,7 +12,7 @@ jobs:
 
     strategy:
       matrix:
-        pgversion: ["latest", 12, 11, 10, 9]
+        pgversion: [14, 13, 12, 11, 10, 9]
 
     env:
       PGVERSION: ${{ matrix.pgversion }}

postgresql/config.go

@@ -38,6 +38,7 @@ const (
 	featurePubTruncate
 	featurePublication
 	featurePubWithoutTruncate
+	featureSubscription
 	featureFunction
 )
 
@@ -103,6 +104,10 @@ var (
 
 		// publication is Supported
 		featurePublication: semver.MustParseRange(">=10.0.0"),
+
+		// subscription is Supported
+		featureSubscription: semver.MustParseRange(">=10.0.0"),
+
 		// We do not support CREATE FUNCTION for Postgresql < 8.4
 		featureFunction: semver.MustParseRange(">=8.4.0"),
 	}
@@ -274,7 +279,8 @@ func (c *Client) Connect() (*DBConnection, error) {
 			db, err = postgres.Open(context.Background(), dsn)
 		}
 		if err != nil {
-			return nil, fmt.Errorf("Error connecting to PostgreSQL server %s (scheme: %s): %w", c.config.Host, c.config.Scheme, err)
+			errString := strings.Replace(err.Error(), c.config.Password, "XXXX", 2)
+			return nil, fmt.Errorf("Error connecting to PostgreSQL server %s (scheme: %s): %s", c.config.Host, c.config.Scheme, errString)
 		}
 
 		// We don't want to retain connection

postgresql/provider.go

@@ -162,6 +162,7 @@ func Provider() *schema.Provider {
 			"postgresql_grant_role":                resourcePostgreSQLGrantRole(),
 			"postgresql_replication_slot":          resourcePostgreSQLReplicationSlot(),
 			"postgresql_publication":               resourcePostgreSQLPublication(),
+			"postgresql_subscription":              resourcePostgreSQLSubscription(),
 			"postgresql_physical_replication_slot": resourcePostgreSQLPhysicalReplicationSlot(),
 			"postgresql_schema":                    resourcePostgreSQLSchema(),
 			"postgresql_role":                      resourcePostgreSQLRole(),