feat: Add --validate and --test-parsing flags for config validation

bigquery/client.go

@@ -30,26 +30,6 @@ type BigQueryAdapter struct {
 	cancel    context.CancelFunc
 }
 
-func (bq *BigQueryConfig) Validate() error {
-	if bq.ProjectId == "" {
-		return errors.New("missing project_id")
-	}
-	// this will usually be th same as projectID but could be different if using outside project dataset such as a public data set
-	if bq.BigQueryProject == "" {
-		return errors.New("missing bigquery project name")
-	}
-	if bq.DatasetName == "" {
-		return errors.New("missing dataset_name")
-	}
-	if bq.TableName == "" {
-		return errors.New("missing table_name")
-	}
-	if bq.SqlQuery == "" {
-		return errors.New("missing sql query")
-	}
-	return nil
-}
-
 func NewBigQueryAdapter(ctx context.Context, conf BigQueryConfig) (*BigQueryAdapter, chan struct{}, error) {
 	// Create bq cancellable context
 	ctx, cancel := context.WithCancel(context.Background())

bigquery/conf.go

@@ -1,6 +1,8 @@
 package usp_bigquery
 
 import (
+	"errors"
+
 	"github.com/refractionPOINT/go-uspclient"
 )
 
@@ -15,3 +17,33 @@ type BigQueryConfig struct {
 	QueryInterval       string                  `json:"query_interval" yaml:"query_interval"`
 	IsOneTimeLoad       bool                    `json:"is_one_time_load" yaml:"is_one_time_load"`
 }
+
+// Validate validates the BigQuery adapter configuration.
+//
+// Parameters:
+//
+//	None
+//
+// Returns:
+//
+//	error - Returns nil if validation passes, or an error describing the validation failure.
+func (c *BigQueryConfig) Validate() error {
+	if c.ProjectId == "" {
+		return errors.New("missing project_id")
+	}
+	// BigQueryProject will usually be the same as ProjectId but could be different
+	// if using outside project dataset such as a public data set.
+	if c.BigQueryProject == "" {
+		return errors.New("missing bigquery_project")
+	}
+	if c.DatasetName == "" {
+		return errors.New("missing dataset_name")
+	}
+	if c.TableName == "" {
+		return errors.New("missing table_name")
+	}
+	if c.SqlQuery == "" {
+		return errors.New("missing sql_query")
+	}
+	return nil
+}