chore: add get user subscriptions route
This commit is contained in:
@@ -11,6 +11,7 @@ import { PaginationUtils } from "../../utils/providers/pagination.utils";
|
||||
import { Wallet } from "../../wallets/entities/wallet.entity";
|
||||
import { WalletsService } from "../../wallets/providers/wallets.service";
|
||||
import { AddSubscriptionsToServiceDto } from "../DTO/create-subscription.dto";
|
||||
import { SearchUserSubsQueryDto } from "../DTO/search-user-subs-query.dto";
|
||||
import { ServiceSubsQueryDto } from "../DTO/service-subs-query.dto";
|
||||
import { SubscribeServiceDto } from "../DTO/subscribe-service.dto";
|
||||
import { UpdateSubscriptionPlanDto } from "../DTO/update-subscription.dto";
|
||||
@@ -18,13 +19,13 @@ import { SubscriptionPlan } from "../entities/subscription.entity";
|
||||
import { UserSubscription } from "../entities/user-subscription.entity";
|
||||
import { SubscriptionStatus } from "../enums/subscription-status.enum";
|
||||
import { SubscriptionsPlanRepository } from "../repositories/subscriptions.repository";
|
||||
// import { UserSubscriptionsRepository } from "../repositories/user-subscriptions.repository";
|
||||
import { UserSubscriptionsRepository } from "../repositories/user-subscriptions.repository";
|
||||
|
||||
@Injectable()
|
||||
export class SubscriptionsService {
|
||||
constructor(
|
||||
private readonly subscriptionsPlanRepository: SubscriptionsPlanRepository,
|
||||
// private readonly userSubscriptionsRepository: UserSubscriptionsRepository,
|
||||
private readonly userSubscriptionsRepository: UserSubscriptionsRepository,
|
||||
private readonly invoicesService: InvoicesService,
|
||||
private readonly usersService: UsersService,
|
||||
private readonly walletsService: WalletsService,
|
||||
@@ -58,6 +59,47 @@ export class SubscriptionsService {
|
||||
subscriptions: createdSubscriptions,
|
||||
};
|
||||
}
|
||||
|
||||
//************************************ */
|
||||
async getUserSubscriptions(userId: string, queryDto: SearchUserSubsQueryDto) {
|
||||
const queryBuilder = this.userSubscriptionsRepository
|
||||
.createQueryBuilder("userSubscription")
|
||||
.leftJoinAndSelect("userSubscription.plan", "plan")
|
||||
.leftJoinAndSelect("plan.service", "service")
|
||||
.where("userSubscription.user.id = :userId", { userId });
|
||||
|
||||
if (queryDto.q) {
|
||||
queryBuilder.andWhere("(service.name ILIKE :query OR service.title ILIKE :query OR service.description ILIKE :query)", {
|
||||
query: `%${queryDto.q}%`,
|
||||
});
|
||||
}
|
||||
|
||||
const subscriptions = await queryBuilder.getMany();
|
||||
|
||||
return {
|
||||
subscriptions,
|
||||
};
|
||||
}
|
||||
//************************************ */
|
||||
|
||||
async getUserSubscriptionById(userSubId: string, userId: string) {
|
||||
const userSubscription = await this.userSubscriptionsRepository.findOne({
|
||||
where: { id: userSubId, user: { id: userId } },
|
||||
relations: {
|
||||
plan: {
|
||||
service: {
|
||||
images: true,
|
||||
subscriptionPlans: true,
|
||||
},
|
||||
},
|
||||
},
|
||||
});
|
||||
if (!userSubscription) throw new BadRequestException(SubscriptionMessage.USER_SUBS_NOT_FOUND);
|
||||
|
||||
return {
|
||||
userSubscription,
|
||||
};
|
||||
}
|
||||
//************************************ */
|
||||
async updateSubscriptionPlan(id: string, updateDto: UpdateSubscriptionPlanDto) {
|
||||
if (updateDto.serviceId) {
|
||||
|
||||
Reference in New Issue
Block a user