refacote dbcontext

Author: DevCodeMathias

Data/CepRepository.cs

@@ -1,43 +1,61 @@
-using System.Security.Cryptography.Xml;
-using Dapper;
+using Dapper;
 using Npgsql;
+using mail_api.InternalInterface;
+using mail_api.Model;
+using Microsoft.Extensions.Configuration;
+using System.Threading.Tasks;
+using System;
+using Microsoft.Extensions.Logging;
 
 namespace mail_api.Data
 {
-    public class CepRepository: ICepRepository
+    public class CepRepository : ICepRepository
     {
-        private const string connectionString = " connection String  ";
+        private readonly string _connectionString;
+        private readonly ILogger<CepRepository> _logger;
 
+       
+        public CepRepository(IConfiguration configuration, ILogger<CepRepository> logger)
+        {
+            _connectionString = configuration.GetConnectionString("DefaultConnection");
+            _logger = logger;
+        }
+
+       
         public async Task<CepInfo> GetAdressByCep(string cep)
         {
             const string sql = @"
                 SELECT Cep, Logradouro, Complemento, Bairro, Localidade, Uf, Ibge, Gia, Ddd, Siafi
-                FROM CepInfo
+                FROM cepinfo
                 WHERE Cep = @Cep";
 
             try
             {
-                await using (var connection = new NpgsqlConnection(connectionString))
+               
+                await using (var connection = new NpgsqlConnection(_connectionString))
                 {
                     var result = await connection.QuerySingleOrDefaultAsync<CepInfo>(sql, new { Cep = cep }).ConfigureAwait(false);
                     return result;
                 }
             }
             catch (Exception ex)
             {
+              
+                Console.WriteLine("Error fetching data from the database", ex);
                 throw new Exception("Error fetching data from the database", ex);
             }
         }
 
         public async Task<bool> Create(CepInfo cep)
         {
             const string sql = @"
-                INSERT INTO CepInfo (Cep, Logradouro, Complemento, Bairro, Localidade, Uf, Ibge, Gia, Ddd, Siafi) 
+                INSERT INTO cepinfo (Cep, Logradouro, Complemento, Bairro, Localidade, Uf, Ibge, Gia, Ddd, Siafi) 
                 VALUES (@Cep, @Logradouro, @Complemento, @Bairro, @Localidade, @Uf, @Ibge, @Gia, @Ddd, @Siafi)";
 
             try
             {
-                await using (var connection = new NpgsqlConnection(connectionString))
+            
+                await using (var connection = new NpgsqlConnection(_connectionString))
                 {
                     var result = await connection.ExecuteAsync(sql, new
                     {
@@ -47,20 +65,21 @@ INSERT INTO CepInfo (Cep, Logradouro, Complemento, Bairro, Localidade, Uf, Ibge,
                         cep.Bairro,
                         cep.Localidade,
                         cep.Uf,
-                        cep.Ibge,
+                        Ibge = (int)cep.Ibge,
                         cep.Gia,
-                        cep.Ddd,
-                        cep.Siafi
+                        ddd = (int)cep.Ibge,
+                        Siafi = (int)cep.Siafi   
                     }).ConfigureAwait(false);
 
-                    return result > 0;
+                    return result > 0; 
                 }
             }
             catch (Exception ex)
             {
-                throw new Exception("Error fetching data from the database", ex);
+
+                _logger.LogError($"Error connecting to the database: {ex.Message}");
+                throw new Exception("Error inserting data into the database", ex);
             }
         }
-
     }
 }

Model/CepInfo.cs

@@ -8,9 +8,9 @@ public class CepInfo
         public string Bairro { get; set; }
         public string Localidade { get; set; }
         public string Uf { get; set; }
-        public string Ibge { get; set; }
+        public int Ibge { get; set; }
         public string Gia { get; set; }
-        public string Ddd { get; set; }
-        public string Siafi { get; set; }
+        public int Ddd { get; set; }
+        public int Siafi { get; set; }
     }
 }

Program.cs

@@ -1,25 +1,37 @@
+using mail_api.Data;
+using mail_api.Interfaces;
+using mail_api.InternalInterface;
+using mail_api.Service;
+
 var builder = WebApplication.CreateBuilder(args);
 
-// Add services to the container.
-builder.Services.AddRazorPages();
+// Registra IHttpClientFactory
+builder.Services.AddHttpClient();
+
+// Registrar ICepService com CepService
+builder.Services.AddScoped<ICepService, CepService>();
+
+// Registrar ICepRepository com CepRepository
+builder.Services.AddScoped<ICepRepository, CepRepository>();
+
+// Adicionando suporte para controllers (API)
+builder.Services.AddControllers();
 
 var app = builder.Build();
 
-// Configure the HTTP request pipeline.
+// Configuração do middleware
 if (!app.Environment.IsDevelopment())
 {
     app.UseExceptionHandler("/Error");
-    // The default HSTS value is 30 days. You may want to change this for production scenarios, see https://aka.ms/aspnetcore-hsts.
-    app.UseHsts();
+    app.UseHsts();  // Habilita HTTP Strict Transport Security em produção
 }
 
 app.UseHttpsRedirection();
 app.UseStaticFiles();
-
 app.UseRouting();
-
 app.UseAuthorization();
 
-app.MapRazorPages();
+app.MapControllers();
 
 app.Run();
+

Service/CepService.cs

@@ -1,13 +1,14 @@
 using mail_api.Data;
 using mail_api.DTO;
+using mail_api.Interfaces;
 using mail_api.InternalInterface;
 using mail_api.Model;
 using Newtonsoft.Json;
 using System.Text.RegularExpressions;
 
 namespace mail_api.Service
 {
-    public class CepService
+    public class CepService:ICepService
     {
 
         private readonly HttpClient _httpClient;

appsettings.json

@@ -1,4 +1,7 @@
 {
+  "ConnectionStrings": {
+    "DefaultConnection": "Host=localhost;Port=5432;Username=postgres;Password=claro5mathias;Database=cep;"
+  },
   "Logging": {
     "LogLevel": {
       "Default": "Information",

controller/controller.cs

@@ -9,11 +9,11 @@ namespace mail_api.controller
 
     [ApiController]
     [Route("api/[controller]")]
-    public class controller:ControllerBase
+    public class Cepcontroller:ControllerBase
     {
 
         private readonly ICepService _cepService;
-        public controller(ICepService cepService)
+        public Cepcontroller(ICepService cepService)
         {
             _cepService = cepService;
         }
@@ -35,6 +35,7 @@ public async Task<IActionResult> GetCep(string cep)
             }
             catch (Exception ex)
             {
+                Console.WriteLine( ex);
                 return StatusCode(500, $"Internal error: {ex.Message}");
             }
         }
@@ -63,10 +64,13 @@ public async Task<IActionResult> PostAsync([FromBody] cepRequest cepRequest)
             }
             catch (Exception ex)
             {
+                Console.WriteLine("Error fetching data from the database", ex);
                 return StatusCode(500, $"Internal error: {ex.Message}");
             }
         }
 
 
+
+
     }
 }