User queries added (Check if email exists and get user bu email)

Author: RuiCost

API.cs

@@ -7,6 +7,7 @@
 using Microsoft.Azure.Functions.Worker;
 using Microsoft.Azure.Functions.Worker.Http;
 using Microsoft.Extensions.Logging;
+using System.Web;
 
 namespace MODSI_SQLRestAPI
 {
@@ -431,6 +432,49 @@ public async Task<HttpResponseData> UpdateUserById([HttpTrigger(AuthorizationLev
             }
         }
 
+        [Function("EmailUserExists")]
+
+        public async Task<HttpResponseData> EmailUserExists([HttpTrigger(AuthorizationLevel.Function, "get", Route = "User/EmailExists/{email}")] HttpRequestData req, string email)
+        {
+            try
+            {
+                _logger.LogInformation($"Checking if email exists: {email}");
+                var exists = await _databaseHandler.EmailUserExistsAsync(email);
+                var response = req.CreateResponse(HttpStatusCode.OK);
+                response.Headers.Add("Content-Type", "application/json; charset=utf-8");
+                await response.WriteStringAsync(JsonSerializer.Serialize(new { Exists = exists }));
+                return response;
+            }
+            catch (Exception ex)
+            {
+                _logger.LogError(ex, $"An error occurred while checking if email exists: {email}");
+                return req.CreateResponse(HttpStatusCode.InternalServerError);
+            }
+        }
+
+        [Function("GetUserByEmail")]
+        public async Task<HttpResponseData> GetUserByEmail([HttpTrigger(AuthorizationLevel.Function, "get", Route = "User/GetByEmail/{email}")] HttpRequestData req, string email)
+        {
+            try
+            {
+                _logger.LogInformation($"Retrieving user with email: {email}");
+                var user = await _databaseHandler.GetUserByEmailAsync(email);
+                if (user == null)
+                {
+                    return req.CreateResponse(HttpStatusCode.NotFound);
+                }
+                var response = req.CreateResponse(HttpStatusCode.OK);
+                response.Headers.Add("Content-Type", "application/json; charset=utf-8");
+                await response.WriteStringAsync(JsonSerializer.Serialize(user));
+                return response;
+            }
+            catch (Exception ex)
+            {
+                _logger.LogError(ex, $"An error occurred while retrieving user with email {email}.");
+                return req.CreateResponse(HttpStatusCode.InternalServerError);
+            }
+        }
+
         #endregion
 
 

DatabaseHandler.cs

@@ -370,6 +370,55 @@ public async Task UpdateUserByIdAsync(User user)
             }
         }
 
+        public async Task<bool> EmailUserExistsAsync(string email)
+        {
+            using (SqlConnection conn = new SqlConnection(_connectionString))
+            {
+                await conn.OpenAsync();
+                var query = "SELECT COUNT(*) FROM [user] WHERE Email = @Email";
+                using (SqlCommand cmd = new SqlCommand(query, conn))
+                {
+                    cmd.Parameters.AddWithValue("@Email", email);
+                    int count = (int)await cmd.ExecuteScalarAsync();
+                    return count > 0;
+                }
+            }
+        }
+        // Get user by email
+        public async Task<User> GetUserByEmailAsync(string email)
+        {
+            User user = null;
+            using (SqlConnection conn = new SqlConnection(_connectionString))
+            {
+                await conn.OpenAsync();
+                var query = $"SELECT ID, Name, Email, Password, Username, Role, CreatedAt, IsActive FROM [user] WHERE Email = @Email";
+                using (SqlCommand cmd = new SqlCommand(query, conn))
+                {
+                    cmd.Parameters.AddWithValue("@Email", email);
+                    using (SqlDataReader reader = await cmd.ExecuteReaderAsync())
+                    {
+                        if (await reader.ReadAsync())
+                        {
+                            user = new User
+                            {
+                                ID = reader.GetInt32(0),
+                                Name = reader.GetString(1),
+                                Email = reader.GetString(2),
+                                Password = reader.GetString(3),
+                                Username = reader.GetString(4),
+                                Role = reader.GetString(5),
+                                CreatedAt = reader.GetDateTime(6),
+                                IsActive = reader.GetString(7)
+                            };
+                        }
+                    }
+                }
+            }
+            return user;
+        }
+
+
+
         #endregion
 
     }