Improve logging for error processing source

Author: jesusfcr

Diff for: pkg/processor/processor.go

@@ -148,10 +148,11 @@ func (p *CheckProcessor) ProcessMessage(m string) error {
 	l.Debugf("Processing source with %d source findings: %#v", len(sourceFindings), source)
 	source, err = p.store.ProcessSourceExecution(source, sourceFindings)
 	if err != nil {
-		l.Errorf("Error while processing source: %#v", err)
-		if !store.IsDuplicateErr(err) {
-			return err
+		if store.IsDuplicateErr(err) {
+			l.Warnf("duplicated source: %#v", err)
+			return nil
 		}
+		return err
 	}
 
 	l.Debug("Sending open findings")

Diff for: pkg/store/sources.go

@@ -271,7 +271,7 @@ func (db *psqlxStore) lockTxBySources(tx *sqlx.Tx, sff SourceFamilies) error {
 }
 
 func createSource(ctx context.Context, tx *sqlx.Tx, s Source) (*Source, error) {
-	r := tx.QueryRowxContext(ctx, `INSERT INTO sources (name, component, instance, options, time, target_id) 
+	r := tx.QueryRowxContext(ctx, `INSERT INTO sources (name, component, instance, options, time, target_id)
 	  VALUES ($1, $2, $3, $4, $5, $6) RETURNING *`, s.Name, s.Component, s.Instance, s.Options, s.Time, s.Target)
 	err := r.StructScan(&s)
 	if err != nil {
@@ -284,11 +284,11 @@ func createSourceIfNotExists(ctx context.Context, tx *sqlx.Tx, s Source) (*Sourc
 	var err error
 	q := `
 	WITH  q as (
-    SELECT * FROM sources 
+    SELECT * FROM sources
 	WHERE name=$1 AND component=$2 AND instance=$3 AND options=$4
-	), 
+	),
 	c AS (
-      INSERT INTO sources (name, component, instance, options, time, target_id) 
+      INSERT INTO sources (name, component, instance, options, time, target_id)
       SELECT $1, $2, $3, $4, $5, $6
       WHERE NOT EXISTS (SELECT 1 FROM q)
       RETURNING *