update in Job posting.

jobs/Endpoints/JobEndpoints.cs

@@ -8,7 +8,8 @@ public static class JobEndpoints
         public static void MapJobEndpoints(this IEndpointRouteBuilder routes)
         {
             routes.MapGet("/jobs", async (JobRequestHandler handler) => await handler.GetJobsAsync());
-            routes.MapPost("/jobs", async (JobCategoryDto jobDto, JobRequestHandler handler) => await handler.AddJobAsync(jobDto));
+            routes.MapPost("/jobCategory", async (JobCategoryDto jobDto, JobRequestHandler handler) => await handler.AddJobCategoryAsync(jobDto));
+            routes.MapPost("/jobs", async (JobDto jobDto, JobRequestHandler handler) => await handler.AddJobAsync(jobDto));
             routes.MapGet("/", () => "Test Endpoint");
         }
     }

jobs/Mappers/JobProfile.cs

@@ -10,10 +10,25 @@ public JobProfile()
         {
             CreateMap<JobCategoryDto, JobCategory>()
                 .ForMember(dest => dest.Name, opt => opt.MapFrom(src => src.Name))
+                .ForMember(dest => dest.Skills, opt => opt.MapFrom(src => src.Skills))
                 .ForMember(dest => dest.Description, opt => opt.MapFrom(src => src.Description));
             CreateMap<JobCategory, JobCategoryDto>()
                 .ForMember(dest => dest.Name, opt => opt.MapFrom(src => src.Name))
                 .ForMember(dest => dest.Description, opt => opt.MapFrom(src => src.Description));
+
+                CreateMap<JobDto, Job>()
+                    .ForMember(dest => dest.Title, opt => opt.MapFrom(src => src.Title))
+                    .ForMember(dest => dest.Description, opt => opt.MapFrom(src => src.Description))
+                    // .ForMember(dest => dest.Category, opt => opt.MapFrom(src => src.Category))
+                    .ForMember(dest => dest.Price, opt => opt.MapFrom(src => src.Price))
+                    .ForMember(dest => dest.DatePosted, opt => opt.MapFrom(src => src.DatePosted))
+                    .ForMember(dest => dest.Zipcode, opt => opt.MapFrom(src => src.Zipcode));
+                CreateMap<Job, JobDto>()
+                    .ForMember(dest => dest.Title, opt => opt.MapFrom(src => src.Title))
+                    .ForMember(dest => dest.Description, opt => opt.MapFrom(src => src.Description))
+                    .ForMember(dest => dest.Zipcode, opt => opt.MapFrom(src => src.Zipcode))
+                    .ForMember(dest => dest.Price, opt => opt.MapFrom(src => src.Price));
+                    // .ForMember(dest => dest.Category, opt => opt.MapFrom(src => src.Category));
         }
     }
 }

jobs/Messaging/RabbitMQ/EventListener.cs

@@ -0,0 +1,45 @@
+using RabbitMQ.Client;
+using RabbitMQ.Client.Events;
+using System.Text;
+using System.Text.Json;
+using localhands.Jobs.Models;
+
+
+public class JobConsumer
+{
+    private readonly string _hostname = "localhost";  // RabbitMQ host
+    private readonly string _queueName = "job_queue"; // Queue to receive jobs
+
+    public void ConsumeJobs()
+    {
+        var factory = new ConnectionFactory() { HostName = _hostname };
+
+        using (var connection = factory.CreateConnection())
+        using (var channel = connection.CreateModel())
+        {
+            channel.QueueDeclare(queue: _queueName, durable: false, exclusive: false, autoDelete: false, arguments: null);
+
+            var consumer = new EventingBasicConsumer(channel);
+            consumer.Received += (model, ea) =>
+            {
+                var body = ea.Body.ToArray();
+                var message = Encoding.UTF8.GetString(body);
+                var job = JsonSerializer.Deserialize<Job>(message);
+                ProcessJob(job);
+            };
+
+            channel.BasicConsume(queue: _queueName, autoAck: true, consumer: consumer);
+
+            Console.WriteLine(" Press [enter] to exit.");
+            Console.ReadLine();
+        }
+    }
+
+    private void ProcessJob(Job job)
+    {
+        // Save the job for workers or notify workers
+        // dbContext.WorkerJobs.Add(job);
+        // dbContext.SaveChanges();
+        Console.WriteLine("Processed Job: " + job.Title);
+    }
+}

jobs/Messaging/RabbitMQ/EventProducer.cs

@@ -0,0 +1,26 @@
+using RabbitMQ.Client;
+using System.Text;
+using System.Text.Json;
+using localhands.Jobs.Models;
+
+public class JobProducer
+{
+    private readonly string _hostname = "localhost";  // RabbitMQ host
+    private readonly string _queueName = "job_queue"; // Queue to send jobs
+
+    public void SendJob(Job job)
+    {
+        var factory = new ConnectionFactory() { HostName = _hostname };
+
+        using (var connection = factory.CreateConnection())
+        using (var channel = connection.CreateModel())
+        {
+            channel.QueueDeclare(queue: _queueName, durable: false, exclusive: false, autoDelete: false, arguments: null);
+
+            var message = JsonSerializer.Serialize(job);
+            var body = Encoding.UTF8.GetBytes(message);
+
+            channel.BasicPublish(exchange: "", routingKey: _queueName, basicProperties: null, body: body);
+        }
+    }
+}

jobs/Models/Dto/JobCategoryDto.cs

@@ -6,6 +6,7 @@ public class JobCategoryDto
     {
         public string Name { get; set; } = string.Empty;
         public string Description { get; set; } = string.Empty;
+        public List<string>? Skills { get; set; } 
 
     }
 }

jobs/Models/Dto/JobDto.cs

@@ -1,13 +1,17 @@
+using localhands.Jobs.Models;
+
 namespace localhands.Jobs.DTOs
 {
     public class JobDto
     {
         public string Id { get; set; }  = string.Empty;
         public string Title { get; set; } = string.Empty;
         public string Description { get; set; }  = string.Empty;
-        public string JobCategoryDto { get; set; }  = string.Empty;
+        public DateTime DatePosted { get; set; } = DateTime.Now;
+        // public JobCategoryDto Category { get; set; } = new JobCategoryDto();
         public decimal Price { get; set; } = 0;
-        public JobPosterDto Poster { get; set; } = new JobPosterDto();
+        public string Zipcode { get; set; }
 
     }
+
 }

jobs/Models/Job.cs

@@ -11,11 +11,11 @@ public class Job
         public string Id { get; set; }
         public string Title { get; set; }
         public string Description { get; set; }
-        public JobCategory Category { get; set; }
+        // public JobCategory Category { get; set; }
         public DateTime DatePosted { get; set; }
         public bool IsFilled { get; set; }
         public decimal Price { get; set; }
-        public JobPoster Poster { get; set; }
+        public required string Zipcode { get; set; }
     }
 
     public class JobCategory
@@ -25,6 +25,7 @@ public class JobCategory
         public string Id { get; set; } = string.Empty;
         public string? Name { get; set; }
         public string? Description { get; set; }
+        public List<string>? Skills { get; set; } 
     }
 
      public class JobPoster

jobs/RequestHandler/JobRequesthandler.cs

@@ -19,10 +19,16 @@ public async Task<IResult> GetJobsAsync()
         }
 
 
-        public async Task<IResult> AddJobAsync(JobCategoryDto jobDto)
+        public async Task<IResult> AddJobCategoryAsync(JobCategoryDto jobDto)
         {
-            await _jobService.AddJobAsync(jobDto);
+            await _jobService.AddJobCategoryAsync(jobDto);
             return Results.Created($"/jobs/{jobDto.Name}", jobDto);
         }
+
+        public async Task<IResult> AddJobAsync(JobDto jobDto)
+        {
+            await _jobService.AddJobAsync(jobDto);
+            return Results.Created($"/jobs/{jobDto.Title}", jobDto);
+        }
     }
 }

jobs/ServiceProvider/Interface/IJobServiceProvider.cs

@@ -7,7 +7,8 @@ namespace localhands.Jobs.ServiceProvider.Interface{
     public interface IJobsServiceProvider
     {
         Task<IEnumerable<JobCategoryDto>> GetJobsAsync();
-        Task AddJobAsync(JobCategoryDto jobDto);
+        Task AddJobAsync(JobDto jobDto);
+        Task AddJobCategoryAsync(JobCategoryDto jobDto);
     }
 
 

jobs/ServiceProvider/JobServiceProvider.cs

@@ -12,11 +12,13 @@ namespace localhands.Jobs.ServiceProvider
     public class JobsServiceProvider : IJobsServiceProvider
     {
         private readonly IMongoCollection<JobCategory> _jobCategory;
+        private readonly IMongoCollection<Job> _job;
         private readonly IMapper _mapper;
 
         public JobsServiceProvider(DbServiceProvider context, IMapper mapper)
         {
             _jobCategory = context.JobCategory;
+            _job = context.Jobs;
             _mapper = mapper;
         }
 
@@ -26,11 +28,18 @@ public async Task<IEnumerable<JobCategoryDto>> GetJobsAsync()
             return _mapper.Map<IEnumerable<JobCategoryDto>>(jobs);
         }
 
-        public async Task AddJobAsync(JobCategoryDto jobDto)
+        public async Task AddJobCategoryAsync(JobCategoryDto jobDto)
         {
             var job = _mapper.Map<JobCategory>(jobDto);
             await _jobCategory.InsertOneAsync(job);
 
         }
+
+
+        public async Task AddJobAsync(JobDto jobDto)
+        {
+            var job = _mapper.Map<Job>(jobDto);
+            await _job.InsertOneAsync(job);
+        }
     }
 }

jobs/appsettings.json

@@ -3,6 +3,11 @@
       "ConnectionString": "mongodb+srv://mohammed-saalim:[email protected]/?retryWrites=true&w=majority&appName=localhandscluster",
       "DatabaseName": "your_database_name"
   },
+  "RabbitMQ": {
+    "HostName": "localhost",
+    "UserName": "guest",
+    "Password": "guest"
+  },
   "Logging": {
       "LogLevel": {
           "Default": "Information",

jobs/jobs.csproj

@@ -10,6 +10,7 @@
     <PackageReference Include="AutoMapper" Version="13.0.1" />
     <PackageReference Include="Microsoft.AspNetCore.OpenApi" Version="8.0.5" />
     <PackageReference Include="MongoDB.Driver" Version="2.25.0" />
+    <PackageReference Include="RabbitMQ.Client" Version="6.8.1" />
     <PackageReference Include="Swashbuckle.AspNetCore" Version="6.4.0" />
   </ItemGroup>