Function ValidateFields

validator.go:55–88

ValidateFields checks if required fields exist

(ctx context.Context, db *sqlx.DB, queueName string)

// ValidateFields checks if required fields exist
func ValidateFields(ctx context.Context, db *sqlx.DB, queueName string) error {
	// --- (1) ----
	// Recover the columns that the queue has
	columns, err := getColumnData(ctx, db, queueName)
	if err != nil {
		return err
	}

	// --- (2) ----
	// Run through each one of the recovered columns and validate if all the mandatory ones are included
	var missingColumns []string
	for _, mandatoryField := range mandatoryFields {
		if _, ok := columns[mandatoryField]; !ok {
			missingColumns = append(missingColumns, mandatoryField)
		}
		delete(columns, mandatoryField)
	}

	// If all the mandatory fields have been found then we don't need to return an error. However,
	// if there is at least one mandatory field missing in the schema then this queue is invalid.
	// TODO: Add some more logic to maybe indicate which field is the one that need to be included
	if len(missingColumns) > 1 {
		return errors.Errorf("some PGQ columns are missing: %v", missingColumns)
	}

	// TODO log extra columns in queue table or ignore them?
	// extraColumns := make([]string, 0, len(columns))
	// for k := range columns {
	//	extraColumns = append(extraColumns, k)
	// }
	// _ = extraColumns

	return nil
}

// ValidateIndexes checks if required indexes exist
func ValidateIndexes(ctx context.Context, db *sqlx.DB, queueName string) error {