packages(sticky): added new interfaces to dto

apps/admin-gateway/src/module.api/admin.controller.ts

@@ -137,4 +137,9 @@ export class AdminController {
       )
     )
   }
+
+  @Get('ping')
+  async ping (): Promise<string> {
+    return await lastValueFrom<any>(this.adminClient.send(QUEUE_MESSAGE.ADMIN_SERVICE_REQUEST_PING, {}))
+  }
 }

apps/admin-service/src/admin-service.controller.ts

@@ -119,4 +119,17 @@ export class AdminServiceController {
       this.rmqService.ack(context)
     }
   }
+
+  @MessagePattern(QUEUE_MESSAGE.ADMIN_SERVICE_REQUEST_PING)
+  async ping (
+    @Ctx() context: RmqContext
+  ): Promise<string | undefined> {
+    try {
+      return await this.adminServiceService.ping()
+    } catch (error) {
+      throw new RpcException(error)
+    } finally {
+      this.rmqService.ack(context)
+    }
+  }
 }

apps/admin-service/src/admin-service.service.ts

@@ -142,4 +142,8 @@ export class AdminServiceService {
     }
     return getRequest
   }
+
+  async ping (): Promise<string> {
+    return 'PONG'
+  }
 }

apps/api-gateway/src/module.api/address-book.controller.ts

@@ -116,9 +116,4 @@ export class AddressBookController {
         )
     )
   }
-
-  @Get('check/ping')
-  async ping (): Promise<string> {
-    return 'Address Book PONG'
-  }
 }

apps/api-gateway/src/module.api/auth.controller.ts

@@ -22,9 +22,4 @@ export class AuthController {
   async logout (@Res({ passthrough: true }) response: Response): Promise<void> {
     return this.authService.logout(response)
   }
-
-  @Get('ping')
-  async ping (): Promise<string> {
-    return 'Auth Controller PONG'
-  }
 }

apps/api-gateway/src/module.api/coupon.controller.ts

@@ -1,7 +1,6 @@
 import {
   Body,
   Controller,
-  Get,
   HttpException,
   Inject,
   Post,
@@ -49,9 +48,4 @@ export class CouponController {
         )
     )
   }
-
-  @Get('ping')
-  async ping (): Promise<string> {
-    return 'Coupon Controller PONG'
-  }
 }

apps/api-gateway/src/module.api/deliveries.controller.ts

@@ -39,6 +39,6 @@ export class DeliveriesController {
 
   @Get('ping')
   async ping (): Promise<string> {
-    return 'Delivery Controller PONG'
+    return await lastValueFrom<any>(this.driversClient.send(QUEUE_MESSAGE.DRIVER_SERVICE_REQUEST_PING, {}))
   }
 }

apps/api-gateway/src/module.api/general.controller.ts

@@ -10,9 +10,4 @@ export class GeneralController {
       delivery: DELIVERY_PRICE_META
     }
   }
-
-  @Get('ping')
-  async ping (): Promise<string> {
-    return 'General Controller PONG'
-  }
 }

apps/api-gateway/src/module.api/listing.controller.ts

@@ -159,6 +159,6 @@ export class ListingsController {
 
   @Get('ping')
   async ping (): Promise<string> {
-    return 'Listing Controller PONG'
+    return await lastValueFrom<any>(this.listingClient.send(QUEUE_MESSAGE.LISTING_SERVICE_REQUEST_PING, {}))
   }
 }

apps/api-gateway/src/module.api/location.controller.ts

@@ -61,6 +61,6 @@ export class LocationController {
 
   @Get('ping')
   async ping (): Promise<string> {
-    return 'Location Controller PONG'
+    return await lastValueFrom<any>(this.locationClient.send(QUEUE_MESSAGE.LOCATION_SERVICE_REQUEST_PING, {}))
   }
 }

apps/api-gateway/src/module.api/order.controller.ts

@@ -97,6 +97,6 @@ export class OrderController {
 
   @Get('ping')
   async ping (): Promise<string> {
-    return 'Order Controller PONG'
+    return await lastValueFrom<any>(this.orderClient.send(QUEUE_MESSAGE.ORDER_SERVICE_REQUEST_PING, {}))
   }
 }

apps/api-gateway/src/module.api/payment.controller.ts

@@ -168,6 +168,6 @@ export class PaymentController {
 
   @Get('ping')
   async ping (): Promise<string> {
-    return 'Payment Controller PONG'
+    return await lastValueFrom<any>(this.paymentClient.send(QUEUE_MESSAGE.PAYMENT_SERVICE_REQUEST_PING, {}))
   }
 }

apps/api-gateway/src/module.api/review.controller.ts

@@ -104,8 +104,8 @@ export class ReviewController {
     )
   }
 
-  @Get('check/ping')
+  @Get('ping')
   async ping (): Promise<string> {
-    return 'Review Controller PONG'
+    return await lastValueFrom<any>(this.reviewClient.send(QUEUE_MESSAGE.REVIEW_SERVICE_REQUEST_PING, {}))
   }
 }

apps/api-gateway/src/module.api/users.controller.ts

@@ -158,6 +158,6 @@ export class UsersController {
 
   @Get('ping')
   async ping (): Promise<string> {
-    return 'User Controller PONG'
+    return await lastValueFrom<any>(this.usersClient.send(QUEUE_MESSAGE.USER_SERVICE_REQUEST_PING, {}))
   }
 }

apps/api-gateway/src/module.api/vendors.controller.ts

@@ -170,6 +170,6 @@ export class VendorsController {
 
   @Get('check/ping')
   async ping (): Promise<string> {
-    return 'Vendor Controller PONG'
+    return await lastValueFrom<any>(this.vendorsClient.send(QUEUE_MESSAGE.VENDOR_SERVICE_REQUEST_PING, {}))
   }
 }

apps/api-gateway/src/module.api/webapp.controller.ts

@@ -58,9 +58,4 @@ export class WebAppController {
         )
     )
   }
-
-  @Get('ping')
-  async ping (): Promise<string> {
-    return 'WebApp Controller PONG'
-  }
 }

apps/drivers-service/src/auth.controller.ts

@@ -30,9 +30,4 @@ export class DriversAuthController {
   async getUserProfile (@CurrentUser() driver: Driver): Promise<Driver> {
     return driver
   }
-
-  @Get('ping')
-  async ping (): Promise<string> {
-    return 'Auth Controller PONG'
-  }
 }

apps/drivers-service/src/drivers-service.controller.ts

@@ -229,11 +229,6 @@ export class DriversServiceController {
     }
   }
 
-  @Get('ping')
-  async ping (): Promise<string> {
-    return 'Driver Controlller PONG'
-  }
-
   @MessagePattern(QUEUE_MESSAGE.ADMIN_GET_DRIVERS)
   async getDrivers (@Ctx() context: RmqContext): Promise<Driver[]> {
     try {
@@ -310,4 +305,17 @@ export class DriversServiceController {
       this.rmqService.ack(context)
     }
   }
+
+  @MessagePattern(QUEUE_MESSAGE.DRIVER_SERVICE_REQUEST_PING)
+  async ping (
+    @Ctx() context: RmqContext
+  ): Promise<string | undefined> {
+    try {
+      return await this.driversServiceService.ping()
+    } catch (error) {
+      throw new RpcException(error)
+    } finally {
+      this.rmqService.ack(context)
+    }
+  }
 }

apps/drivers-service/src/drivers-service.service.ts

@@ -318,4 +318,8 @@ export class DriversServiceService {
       )
     }
   }
+
+  async ping (): Promise<string> {
+    return 'PONG'
+  }
 }

apps/listings-service/src/listings.controller.ts

@@ -508,4 +508,17 @@ export class ListingsController {
       this.rmqService.ack(context)
     }
   }
+
+  @MessagePattern(QUEUE_MESSAGE.LISTING_SERVICE_REQUEST_PING)
+  async ping (
+    @Ctx() context: RmqContext
+  ): Promise<string | undefined> {
+    try {
+      return await this.listingService.ping()
+    } catch (error) {
+      throw new RpcException(error)
+    } finally {
+      this.rmqService.ack(context)
+    }
+  }
 }

apps/listings-service/src/listings.service.ts

@@ -945,6 +945,10 @@ export class ListingsService {
       )
     }
   }
+
+  async ping (): Promise<string> {
+    return 'PONG'
+  }
 }
 
 function getVendorsMapper (vendors: VendorI[]): VendorUserI[] {

apps/location-service/src/location-service.controller.ts

@@ -87,4 +87,17 @@ export class LocationController {
       this.rmqService.ack(context)
     }
   }
+
+  @MessagePattern(QUEUE_MESSAGE.LOCATION_SERVICE_REQUEST_PING)
+  async ping (
+    @Ctx() context: RmqContext
+  ): Promise<string | undefined> {
+    try {
+      return await this.locationService.ping()
+    } catch (error) {
+      throw new RpcException(error)
+    } finally {
+      this.rmqService.ack(context)
+    }
+  }
 }

apps/location-service/src/location-service.service.ts

@@ -94,4 +94,8 @@ export class LocationService {
       )
     }
   }
+
+  async ping (): Promise<string> {
+    return 'PONG'
+  }
 }

apps/notification-service/src/notification-service.controller.ts

@@ -191,4 +191,17 @@ export class NotificationServiceController {
       this.rmqService.ack(context)
     }
   }
+
+  @MessagePattern(QUEUE_MESSAGE.NOTIFICATION_SERVICE_REQUEST_PING)
+  async ping (
+    @Ctx() context: RmqContext
+  ): Promise<string | undefined> {
+    try {
+      return await this.notificationServiceService.ping()
+    } catch (error) {
+      throw new RpcException(error)
+    } finally {
+      this.rmqService.ack(context)
+    }
+  }
 }

apps/notification-service/src/notification-service.service.ts

@@ -258,4 +258,8 @@ export class NotificationServiceService {
       }))
     } catch (error) {}
   }
+
+  async ping (): Promise<string> {
+    return 'PONG'
+  }
 }

apps/orders-service/src/orders-service.controller.ts

@@ -261,4 +261,17 @@ export class OrdersServiceController {
       this.rmqService.ack(context)
     }
   }
+
+  @MessagePattern(QUEUE_MESSAGE.ORDER_SERVICE_REQUEST_PING)
+  async ping (
+    @Ctx() context: RmqContext
+  ): Promise<string | undefined> {
+    try {
+      return await this.ordersServiceService.ping()
+    } catch (error) {
+      throw new RpcException(error)
+    } finally {
+      this.rmqService.ack(context)
+    }
+  }
 }

apps/orders-service/src/orders-service.service.ts

@@ -558,4 +558,8 @@ export class OrdersServiceService {
       console.error(error)
     }
   }
+
+  async ping (): Promise<string> {
+    return 'PONG'
+  }
 }

apps/payment-service/src/wallet/driver/wallet.controller.ts

@@ -144,4 +144,17 @@ export class DriverWalletController {
       this.rmqService.ack(context)
     }
   }
+
+  @MessagePattern(QUEUE_MESSAGE.PAYMENT_SERVICE_REQUEST_PING)
+  async ping (
+    @Ctx() context: RmqContext
+  ): Promise<string | undefined> {
+    try {
+      return await this.walletService.ping()
+    } catch (error) {
+      throw new RpcException(error)
+    } finally {
+      this.rmqService.ack(context)
+    }
+  }
 }

apps/payment-service/src/wallet/driver/wallet.service.ts

@@ -259,4 +259,8 @@ export class DriverWalletService {
 
     return balance >= amount
   }
+
+  async ping (): Promise<string> {
+    return 'PONG'
+  }
 }

apps/reviews-service/src/reviews-service.controller.ts

@@ -175,4 +175,17 @@ export class ReviewsServiceController {
       this.rmqService.ack(context)
     }
   }
+
+  @MessagePattern(QUEUE_MESSAGE.REVIEW_SERVICE_REQUEST_PING)
+  async ping (
+    @Ctx() context: RmqContext
+  ): Promise<string | undefined> {
+    try {
+      return await this.reviewService.ping()
+    } catch (error) {
+      throw new RpcException(error)
+    } finally {
+      this.rmqService.ack(context)
+    }
+  }
 }

apps/reviews-service/src/reviews-service.service.ts

@@ -286,4 +286,8 @@ export class ReviewsService implements ReviewsServiceI {
       reviews: listingReview
     }
   }
+
+  async ping (): Promise<string> {
+    return 'PONG'
+  }
 }

apps/users-service/src/users-service.controller.ts

@@ -254,4 +254,17 @@ export class UsersServiceController {
       this.rmqService.ack(context)
     }
   }
+
+  @MessagePattern(QUEUE_MESSAGE.USER_SERVICE_REQUEST_PING)
+  async ping (
+    @Ctx() context: RmqContext
+  ): Promise<string | undefined> {
+    try {
+      return await this.usersService.ping()
+    } catch (error) {
+      throw new RpcException(error)
+    } finally {
+      this.rmqService.ack(context)
+    }
+  }
 }