add NewQuery

Author: UltimateForm

internal/repository/authrep/main.go

@@ -9,7 +9,13 @@ import (
 )
 
 func txUsrExistsAtomically(ctx context.Context, user User) neo4j.ManagedTransactionWorkT[bool] {
-	query := queryComputeUserExistsAtomically(user)
+	query := repository.NewQuery(
+		user,
+		`
+MATCH (u:User {email:$email, password:$password})
+RETURN count(u) > 0 as exists
+		`,
+	)
 
 	return func(tx neo4j.ManagedTransaction) (bool, error) {
 		res, err := query.Execute(tx, ctx)

internal/repository/authrep/queries.go

@@ -4,3 +4,10 @@ type User struct {
 	Email    string
 	Password string
 }
+
+func (src User) ToParams() map[string]any {
+	return map[string]any{
+		"email":    src.Email,
+		"password": src.Password,
+	}
+}

internal/repository/authrep/types.go

@@ -15,3 +15,12 @@ func ExecuteReadWithDriver[T any](ctx context.Context, tx neo4j.ManagedTransacti
 	defer session.Close(readCtx)
 	return neo4j.ExecuteRead(readCtx, session, tx)
 }
+
+func NewQuery(data IQueryParams, query string) QueryRunner {
+	return func(tx neo4j.ManagedTransaction, ctx context.Context) (neo4j.ResultWithContext, error) {
+		return tx.Run(
+			ctx,
+			query,
+			data.ToParams())
+	}
+}

internal/repository/main.go

@@ -11,3 +11,7 @@ type QueryRunner func(tx neo4j.ManagedTransaction, ctx context.Context) (neo4j.R
 func (src QueryRunner) Execute(tx neo4j.ManagedTransaction, ctx context.Context) (neo4j.ResultWithContext, error) {
 	return src(tx, ctx)
 }
+
+type IQueryParams interface {
+	ToParams() map[string]any
+}