feat(login): additionally use email/phone for authentication (#4563)

* feat: add ability to disable login by email and phone

* feat: check login by email and phone

* fix: set verified email / phone correctly on notify users

* update projection version

* fix merge

* fix email/phone verified reduce tests

* fix user tests

* loginname check

* cleanup

* fix: update user projection version to handle fixed statement

internal/eventstore/handler/crdb/statement.go

@@ -123,7 +123,7 @@ func getUpdateCols(cols, conflictTarget []string) (updateCols, updateVals []stri
 
 func NewUpdateStatement(event eventstore.Event, values []handler.Column, conditions []handler.Condition, opts ...execOption) *handler.Statement {
 	cols, params, args := columnsToQuery(values)
-	wheres, whereArgs := conditionsToWhere(conditions, len(params))
+	wheres, whereArgs := conditionsToWhere(conditions, len(args))
 	args = append(args, whereArgs...)
 
 	config := execConfig{
@@ -278,6 +278,13 @@ func NewArrayIntersectCol(column string, value interface{}) handler.Column {
 	}
 }
 
+func NewCopyCol(column, from string) handler.Column {
+	return handler.Column{
+		Name:  column,
+		Value: handler.NewCol(from, nil),
+	}
+}
+
 // NewCopyStatement creates a new upsert statement which updates a column from an existing row
 // cols represent the columns which are objective to change.
 // if the value of a col is empty the data will be copied from the selected row
@@ -359,15 +366,22 @@ func columnsToQuery(cols []handler.Column) (names []string, parameters []string,
 	names = make([]string, len(cols))
 	values = make([]interface{}, len(cols))
 	parameters = make([]string, len(cols))
+	var parameterIndex int
 	for i, col := range cols {
 		names[i] = col.Name
-		values[i] = col.Value
-		parameters[i] = "$" + strconv.Itoa(i+1)
+		if c, ok := col.Value.(handler.Column); ok {
+			parameters[i] = c.Name
+			continue
+		} else {
+			values[parameterIndex] = col.Value
+		}
+		parameters[i] = "$" + strconv.Itoa(parameterIndex+1)
 		if col.ParameterOpt != nil {
 			parameters[i] = col.ParameterOpt(parameters[i])
 		}
+		parameterIndex++
 	}
-	return names, parameters, values
+	return names, parameters, values[:parameterIndex]
 }
 
 func conditionsToWhere(cols []handler.Condition, paramOffset int) (wheres []string, values []interface{}) {

internal/eventstore/handler/crdb/statement_test.go

@@ -1352,6 +1352,32 @@ func Test_columnsToQuery(t *testing.T) {
 				values: []interface{}{1, 3.14},
 			},
 		},
+		{
+			name: "with copy column",
+			args: args{
+				cols: []handler.Column{
+					{
+						Name:  "col1",
+						Value: 1,
+					},
+					{
+						Name: "col2",
+						Value: handler.Column{
+							Name: "col1",
+						},
+					},
+					{
+						Name:  "col3",
+						Value: "something",
+					},
+				},
+			},
+			want: want{
+				names:  []string{"col1", "col2", "col3"},
+				params: []string{"$1", "col1", "$2"},
+				values: []interface{}{1, "something"},
+			},
+		},
 	}
 	for _, tt := range tests {
 		t.Run(tt.name, func(t *testing.T) {