feat(backend): add error handler to NATS functions

backend/common/src/main/kotlin/com/linkedout/common/utils/CloudStreamErrorHandler.kt

@@ -0,0 +1,11 @@
+package com.linkedout.common.utils
+
+import com.linkedout.proto.ResponseOuterClass.Response
+
+inline fun handleRequestError(block: () -> Response): Response {
+    return try {
+        block()
+    } catch (e: Exception) {
+        RequestResponseFactory.newFailedResponse(e.message ?: "Unknown error").build()
+    }
+}

backend/employer/src/main/kotlin/com/linkedout/employer/function/employer/GetEmployer.kt

@@ -1,6 +1,7 @@
 package com.linkedout.employer.function.employer
 
 import com.linkedout.common.utils.RequestResponseFactory
+import com.linkedout.common.utils.handleRequestError
 import com.linkedout.employer.service.EmployerService
 import com.linkedout.proto.RequestOuterClass.Request
 import com.linkedout.proto.ResponseOuterClass.Response
@@ -13,9 +14,9 @@ import java.util.function.Function
 
 @Component
 class GetEmployer(private val employerService: EmployerService) : Function<Request, Response> {
-    override fun apply(t: Request): Response {
+    override fun apply(t: Request): Response = handleRequestError {
         // Get the employer from the database
-        val responseMono = employerService.findOne(UUID.fromString(t.getEmployerRequest.id))
+        val reactiveResponse = employerService.findOne(UUID.fromString(t.getEmployerRequest.id))
             .map { employer ->
                 EmployerOuterClass.Employer.newBuilder()
                     .setId(employer.id.toString())
@@ -32,11 +33,7 @@ class GetEmployer(private val employerService: EmployerService) : Function<Reque
             }
 
         // Block until the response is ready
-        val response = try {
-            responseMono.block()
-        } catch (e: Exception) {
-            return RequestResponseFactory.newFailedResponse(e.message ?: "Unknown error").build()
-        }
+        val response = reactiveResponse.block()
             ?: return RequestResponseFactory.newFailedResponse("Employer not found", HttpStatus.NOT_FOUND).build()
 
         return RequestResponseFactory.newSuccessfulResponse()

backend/employer/src/main/kotlin/com/linkedout/employer/function/employer/GetMultipleEmployers.kt

@@ -1,6 +1,7 @@
 package com.linkedout.employer.function.employer
 
 import com.linkedout.common.utils.RequestResponseFactory
+import com.linkedout.common.utils.handleRequestError
 import com.linkedout.employer.service.EmployerService
 import com.linkedout.proto.RequestOuterClass.Request
 import com.linkedout.proto.ResponseOuterClass.Response
@@ -12,13 +13,13 @@ import java.util.function.Function
 
 @Component
 class GetMultipleEmployers(private val employerService: EmployerService) : Function<Request, Response> {
-    override fun apply(t: Request): Response {
+    override fun apply(t: Request): Response = handleRequestError {
         // Get multiple employers from the database
         val ids = t.getMultipleEmployersRequest
             .idsList
             .map(UUID::fromString)
 
-        val responseMono = employerService.findMultiple(ids)
+        val reactiveResponse = employerService.findMultiple(ids)
             .map { employer ->
                 EmployerOuterClass.Employer.newBuilder()
                     .setId(employer.id.toString())
@@ -37,11 +38,7 @@ class GetMultipleEmployers(private val employerService: EmployerService) : Funct
             }
 
         // Block until the response is ready
-        val response = try {
-            responseMono.block()
-        } catch (e: Exception) {
-            return RequestResponseFactory.newFailedResponse(e.message ?: "Unknown error").build()
-        }
+        val response = reactiveResponse.block()
             ?: return RequestResponseFactory.newSuccessfulResponse()
                 .setGetMultipleEmployersResponse(GetMultipleEmployersResponse.getDefaultInstance())
                 .build()

backend/jobs/src/main/kotlin/com/linkedout/jobs/function/companies/GetCompanies.kt

@@ -1,6 +1,7 @@
 package com.linkedout.jobs.function.companies
 
 import com.linkedout.common.utils.RequestResponseFactory
+import com.linkedout.common.utils.handleRequestError
 import com.linkedout.jobs.service.CompanyService
 import com.linkedout.proto.RequestOuterClass.Request
 import com.linkedout.proto.ResponseOuterClass.Response
@@ -11,9 +12,9 @@ import java.util.function.Function
 
 @Component
 class GetCompanies(private val companyService: CompanyService) : Function<Request, Response> {
-    override fun apply(t: Request): Response {
+    override fun apply(t: Request): Response = handleRequestError {
         // Get the companies from the database
-        val responseMono = companyService.findAll()
+        val reactiveResponse = companyService.findAll()
             .map { company ->
                 CompanyOuterClass.Company.newBuilder()
                     .setId(company.id.toString())
@@ -26,12 +27,9 @@ class GetCompanies(private val companyService: CompanyService) : Function<Reques
             .map { builder ->
                 builder.build()
             }
+
         // Block until the response is ready
-        val response = try {
-            responseMono.block()
-        } catch (e: Exception) {
-            return RequestResponseFactory.newFailedResponse(e.message ?: "Unknown error").build()
-        }
+        val response = reactiveResponse.block()
             ?: return RequestResponseFactory.newSuccessfulResponse()
                 .setGetCompaniesResponse(Jobs.GetCompaniesResponse.getDefaultInstance())
                 .build()

backend/jobs/src/main/kotlin/com/linkedout/jobs/function/companies/GetCompany.kt

@@ -1,6 +1,7 @@
 package com.linkedout.jobs.function.companies
 
 import com.linkedout.common.utils.RequestResponseFactory
+import com.linkedout.common.utils.handleRequestError
 import com.linkedout.jobs.service.CompanyService
 import com.linkedout.proto.RequestOuterClass.Request
 import com.linkedout.proto.ResponseOuterClass.Response
@@ -13,9 +14,9 @@ import java.util.function.Function
 
 @Component
 class GetCompany(private val companyService: CompanyService) : Function<Request, Response> {
-    override fun apply(t: Request): Response {
+    override fun apply(t: Request): Response = handleRequestError {
         // Get the company from the database
-        val responseMono = companyService.findOne(UUID.fromString(t.getCompanyRequest.id))
+        val reactiveResponse = companyService.findOne(UUID.fromString(t.getCompanyRequest.id))
             .map { company ->
                 CompanyOuterClass.Company.newBuilder()
                     .setId(company.id.toString())
@@ -28,11 +29,7 @@ class GetCompany(private val companyService: CompanyService) : Function<Request,
                     .build()
             }
         // Block until the response is ready
-        val response = try {
-            responseMono.block()
-        } catch (e: Exception) {
-            return RequestResponseFactory.newFailedResponse(e.message ?: "Unknown error").build()
-        }
+        val response = reactiveResponse.block()
             ?: return RequestResponseFactory.newFailedResponse("Company not found", HttpStatus.NOT_FOUND).build()
 
         return RequestResponseFactory.newSuccessfulResponse()

backend/jobs/src/main/kotlin/com/linkedout/jobs/function/jobCategories/GetJobCategories.kt

@@ -1,6 +1,7 @@
 package com.linkedout.jobs.function.jobCategories
 
 import com.linkedout.common.utils.RequestResponseFactory
+import com.linkedout.common.utils.handleRequestError
 import com.linkedout.jobs.service.JobCategoryService
 import com.linkedout.proto.RequestOuterClass.Request
 import com.linkedout.proto.ResponseOuterClass.Response
@@ -11,9 +12,9 @@ import java.util.function.Function
 
 @Component
 class GetJobCategories(private val jobCategoryService: JobCategoryService) : Function<Request, Response> {
-    override fun apply(t: Request): Response {
+    override fun apply(t: Request): Response = handleRequestError {
         // Get all the job categories from the database
-        val responseMono = jobCategoryService.findAll()
+        val reactiveResponse = jobCategoryService.findAll()
             .map { jobCategory ->
                 JobCategoryOuterClass.JobCategory.newBuilder()
                     .setId(jobCategory.id.toString())
@@ -29,11 +30,7 @@ class GetJobCategories(private val jobCategoryService: JobCategoryService) : Fun
             }
 
         // Block until the response is ready
-        val response = try {
-            responseMono.block()
-        } catch (e: Exception) {
-            return RequestResponseFactory.newFailedResponse(e.message ?: "Unknown error").build()
-        }
+        val response = reactiveResponse.block()
             ?: return RequestResponseFactory.newSuccessfulResponse()
                 .setGetJobCategoriesResponse(Jobs.GetJobCategoriesResponse.getDefaultInstance())
                 .build()

backend/jobs/src/main/kotlin/com/linkedout/jobs/function/jobOffers/GetJobOffer.kt

@@ -1,6 +1,7 @@
 package com.linkedout.jobs.function.jobOffers
 
 import com.linkedout.common.utils.RequestResponseFactory
+import com.linkedout.common.utils.handleRequestError
 import com.linkedout.jobs.service.JobOfferService
 import com.linkedout.proto.RequestOuterClass.Request
 import com.linkedout.proto.ResponseOuterClass.Response
@@ -15,9 +16,9 @@ import java.util.function.Function
 
 @Component
 class GetJobOffer(private val jobOfferService: JobOfferService) : Function<Request, Response> {
-    override fun apply(t: Request): Response {
+    override fun apply(t: Request): Response = handleRequestError {
         // Get the job offer from the database
-        val responseMono = jobOfferService.findOne(UUID.fromString(t.getJobOfferRequest.id))
+        val reactiveResponse = jobOfferService.findOne(UUID.fromString(t.getJobOfferRequest.id))
             .map { jobOffer ->
                 JobOfferOuterClass.JobOffer.newBuilder()
                     .setId(jobOffer.jobOfferId)
@@ -48,11 +49,7 @@ class GetJobOffer(private val jobOfferService: JobOfferService) : Function<Reque
             }
 
         // Block until the response is ready
-        val response = try {
-            responseMono.block()
-        } catch (e: Exception) {
-            return RequestResponseFactory.newFailedResponse(e.message ?: "Unknown error").build()
-        }
+        val response = reactiveResponse.block()
             ?: return RequestResponseFactory.newFailedResponse("Job offer not found", HttpStatus.NOT_FOUND).build()
 
         return RequestResponseFactory.newSuccessfulResponse()

backend/jobs/src/main/kotlin/com/linkedout/jobs/function/jobOffers/GetJobOffers.kt

@@ -1,8 +1,8 @@
 package com.linkedout.jobs.function.jobOffers
 
 import com.linkedout.common.utils.RequestResponseFactory
+import com.linkedout.common.utils.handleRequestError
 import com.linkedout.jobs.service.JobOfferService
-import com.linkedout.jobs.service.JobService
 import com.linkedout.proto.RequestOuterClass.Request
 import com.linkedout.proto.ResponseOuterClass.Response
 import com.linkedout.proto.models.CompanyOuterClass
@@ -13,10 +13,10 @@ import org.springframework.stereotype.Component
 import java.util.function.Function
 
 @Component
-class GetJobOffers(private val jobOfferService: JobOfferService, private val jobService: JobService) : Function<Request, Response> {
-    override fun apply(t: Request): Response {
+class GetJobOffers(private val jobOfferService: JobOfferService) : Function<Request, Response> {
+    override fun apply(t: Request): Response = handleRequestError {
         // Get all the job offers from the database
-        val responseMono = jobOfferService.findAll()
+        val reactiveResponse = jobOfferService.findAll()
             .map { jobOffer ->
                 JobOfferOuterClass.JobOffer.newBuilder()
                     .setId(jobOffer.jobOfferId)
@@ -50,11 +50,7 @@ class GetJobOffers(private val jobOfferService: JobOfferService, private val job
             }
 
         // Block until the response is ready
-        val response = try {
-            responseMono.block()
-        } catch (e: Exception) {
-            return RequestResponseFactory.newFailedResponse(e.message ?: "Unknown error").build()
-        }
+        val response = reactiveResponse.block()
             ?: return RequestResponseFactory.newSuccessfulResponse()
                 .setGetJobOffersResponse(Jobs.GetJobOffersResponse.getDefaultInstance())
                 .build()

backend/jobs/src/main/kotlin/com/linkedout/jobs/function/jobs/GetJob.kt

@@ -1,6 +1,7 @@
 package com.linkedout.jobs.function.jobs
 
 import com.linkedout.common.utils.RequestResponseFactory
+import com.linkedout.common.utils.handleRequestError
 import com.linkedout.jobs.service.JobService
 import com.linkedout.proto.RequestOuterClass.Request
 import com.linkedout.proto.ResponseOuterClass.Response
@@ -13,9 +14,9 @@ import java.util.function.Function
 
 @Component
 class GetJob(private val jobService: JobService) : Function<Request, Response> {
-    override fun apply(t: Request): Response {
+    override fun apply(t: Request): Response = handleRequestError {
         // Get the job from the database
-        val responseMono = jobService.findOneWithCategory(UUID.fromString(t.getJobRequest.id))
+        val reactiveResponse = jobService.findOneWithCategory(UUID.fromString(t.getJobRequest.id))
             .map { job ->
                 JobOuterClass.Job.newBuilder()
                     .setId(job.id)
@@ -30,11 +31,7 @@ class GetJob(private val jobService: JobService) : Function<Request, Response> {
             }
 
         // Block until the response is ready
-        val response = try {
-            responseMono.block()
-        } catch (e: Exception) {
-            return RequestResponseFactory.newFailedResponse(e.message ?: "Unknown error").build()
-        }
+        val response = reactiveResponse.block()
             ?: return RequestResponseFactory.newFailedResponse("Job not found", HttpStatus.NOT_FOUND).build()
 
         return RequestResponseFactory.newSuccessfulResponse()

backend/jobs/src/main/kotlin/com/linkedout/jobs/function/jobs/GetJobs.kt

@@ -1,6 +1,7 @@
 package com.linkedout.jobs.function.jobs
 
 import com.linkedout.common.utils.RequestResponseFactory
+import com.linkedout.common.utils.handleRequestError
 import com.linkedout.jobs.service.JobService
 import com.linkedout.proto.RequestOuterClass.Request
 import com.linkedout.proto.ResponseOuterClass.Response
@@ -11,9 +12,9 @@ import java.util.function.Function
 
 @Component
 class GetJobs(private val jobService: JobService) : Function<Request, Response> {
-    override fun apply(t: Request): Response {
+    override fun apply(t: Request): Response = handleRequestError {
         // Get all the jobs from the database
-        val responseMono = jobService.findAllWithCategory()
+        val reactiveResponse = jobService.findAllWithCategory()
             .map { job ->
                 JobOuterClass.Job.newBuilder()
                     .setId(job.id)
@@ -30,11 +31,7 @@ class GetJobs(private val jobService: JobService) : Function<Request, Response>
             }
 
         // Block until the response is ready
-        val response = try {
-            responseMono.block()
-        } catch (e: Exception) {
-            return RequestResponseFactory.newFailedResponse(e.message ?: "Unknown error").build()
-        }
+        val response = reactiveResponse.block()
             ?: return RequestResponseFactory.newSuccessfulResponse()
                 .setGetJobsResponse(Jobs.GetJobsResponse.getDefaultInstance())
                 .build()

backend/messaging/src/main/kotlin/com/linkedout/messaging/function/messageChannels/GetChannelOfUser.kt

@@ -1,6 +1,7 @@
 package com.linkedout.messaging.function.messageChannels
 
 import com.linkedout.common.utils.RequestResponseFactory
+import com.linkedout.common.utils.handleRequestError
 import com.linkedout.messaging.service.MessageChannelService
 import com.linkedout.proto.RequestOuterClass.Request
 import com.linkedout.proto.ResponseOuterClass.Response
@@ -13,10 +14,10 @@ import java.util.function.Function
 
 @Component
 class GetChannelOfUser(private val messageChannelService: MessageChannelService) : Function<Request, Response> {
-    override fun apply(t: Request): Response {
+    override fun apply(t: Request): Response = handleRequestError {
         // Get the message channel from the database
         val request = t.getUserMessageChannelRequest
-        val responseMono = messageChannelService.findOneWithSeasonworkerId(UUID.fromString(request.userId), UUID.fromString(request.messageChannelId))
+        val reactiveResponse = messageChannelService.findOneWithSeasonworkerId(UUID.fromString(request.userId), UUID.fromString(request.messageChannelId))
             .map { messageChannel ->
                 MessageChannelOuterClass.MessageChannel.newBuilder()
                     .setId(messageChannel.id.toString())
@@ -31,11 +32,7 @@ class GetChannelOfUser(private val messageChannelService: MessageChannelService)
             }
 
         // Block until the response is ready
-        val response = try {
-            responseMono.block()
-        } catch (e: Exception) {
-            return RequestResponseFactory.newFailedResponse(e.message ?: "Unknown error").build()
-        }
+        val response = reactiveResponse.block()
             ?: return RequestResponseFactory.newFailedResponse("Message channel not found", HttpStatus.NOT_FOUND).build()
 
         return RequestResponseFactory.newSuccessfulResponse()

backend/messaging/src/main/kotlin/com/linkedout/messaging/function/messageChannels/GetChannelOfUserWithEmployer.kt

@@ -1,6 +1,7 @@
 package com.linkedout.messaging.function.messageChannels
 
 import com.linkedout.common.utils.RequestResponseFactory
+import com.linkedout.common.utils.handleRequestError
 import com.linkedout.messaging.service.MessageChannelService
 import com.linkedout.proto.RequestOuterClass.Request
 import com.linkedout.proto.ResponseOuterClass.Response
@@ -13,10 +14,10 @@ import java.util.function.Function
 
 @Component
 class GetChannelOfUserWithEmployer(private val messageChannelService: MessageChannelService) : Function<Request, Response> {
-    override fun apply(t: Request): Response {
+    override fun apply(t: Request): Response = handleRequestError {
         // Get the message channel from the database
         val request = t.getUserMessageChannelWithEmployerRequest
-        val responseMono = messageChannelService.findOneWithSeasonworkerIdAndEmployerId(UUID.fromString(request.userId), UUID.fromString(request.employerId))
+        val reactiveResponse = messageChannelService.findOneWithSeasonworkerIdAndEmployerId(UUID.fromString(request.userId), UUID.fromString(request.employerId))
             .map { messageChannel ->
                 MessageChannelOuterClass.MessageChannel.newBuilder()
                     .setId(messageChannel.id.toString())
@@ -31,11 +32,7 @@ class GetChannelOfUserWithEmployer(private val messageChannelService: MessageCha
             }
 
         // Block until the response is ready
-        val response = try {
-            responseMono.block()
-        } catch (e: Exception) {
-            return RequestResponseFactory.newFailedResponse(e.message ?: "Unknown error").build()
-        }
+        val response = reactiveResponse.block()
             ?: return RequestResponseFactory.newFailedResponse("Message channel not found", HttpStatus.NOT_FOUND).build()
 
         return RequestResponseFactory.newSuccessfulResponse()