Adds warnings to jobmapping validator (#3155)

backend/internal/utils/utils.go

@@ -2,7 +2,6 @@ package utils
 
 import (
 	"net/http"
-	"slices"
 	"strings"
 
 	nucleuserrors "github.com/nucleuscloud/neosync/backend/internal/errors"
@@ -53,30 +52,6 @@ func NoElementEqual[T comparable](slice []T, value T) bool {
 	return true
 }
 
-func CompareSlices(slice1, slice2 []string) bool {
-	if len(slice1) != len(slice2) {
-		return false
-	}
-	for _, ele := range slice1 {
-		if !slices.Contains(slice2, ele) {
-			return false
-		}
-	}
-	return true
-}
-
-func DedupeSlice[T comparable](input []T) []T {
-	set := map[T]any{}
-	for _, i := range input {
-		set[i] = struct{}{}
-	}
-	output := make([]T, 0, len(set))
-	for key := range set {
-		output = append(output, key)
-	}
-	return output
-}
-
 func GetBearerTokenFromHeader(
 	header http.Header,
 	key string,

backend/protos/mgmt/v1alpha1/job.proto

@@ -1072,6 +1072,8 @@ message ValidateJobMappingsRequest {
   string connection_id = 3 [(buf.validate.field).string.uuid = true];
   // The list of virtual foreign keys
   repeated VirtualForeignConstraint virtual_foreign_keys = 4;
+  // The source options of the job
+  optional JobSource job_source = 5;
 }
 
 message ColumnError {
@@ -1085,6 +1087,17 @@ message ColumnError {
   repeated string errors = 4;
 }
 
+message ColumnWarning {
+  // The schema of the table
+  string schema = 1;
+  // The table of the column
+  string table = 2;
+  // The column of the warning
+  string column = 3;
+  // The list of warnings
+  repeated string warnings = 5;
+}
+
 message DatabaseError {
   // The list of errors
   repeated string errors = 1;
@@ -1094,6 +1107,8 @@ message ValidateJobMappingsResponse {
   repeated ColumnError column_errors = 1;
   // The database error
   DatabaseError database_errors = 2;
+  // The list of column warnings
+  repeated ColumnWarning column_warnings = 3;
 }
 
 message VirtualForeignKey {