{"type":"doc","content":[{"type":"heading","attrs":{"level":3},"content":[{"text":"Performer Controller Code Samples","type":"text"}]},{"type":"codeBlock","content":[{"text":"import {\n Controller,\n Injectable,\n HttpCode,\n HttpStatus,\n UsePipes,\n ValidationPipe,\n Get,\n Param,\n Query,\n HttpException,\n Put,\n Body,\n UseGuards,\n Request,\n Post\n} from '@nestjs/common';\nimport { omit } from 'lodash';\nimport {\n DataResponse,\n PageableData\n} from 'src/kernel';\nimport { Roles } from 'src/modules/auth';\nimport { AuthGuard, RoleGuard } from 'src/modules/auth/guards';\nimport { ContactPayload } from 'src/modules/contact/payloads';\nimport { MailerService } from 'src/modules/mailer';\nimport { PERFORMER_STATUSES, UNALLOWED_SELF_UPDATE_FIELDS } from '../constants';\nimport {\n PerformerDto,\n IPerformerResponse\n} from '../dtos';\nimport {\n PerformerSearchPayload, PerformerUpdatePayload\n} from '../payloads';\nimport { PerformerService, PerformerSearchService } from '../services';\n\n@Injectable()\n@Controller('performers')\nexport class PerformerController {\n constructor(\n private readonly performerService: PerformerService,\n private readonly performerSearchService: PerformerSearchService,\n private readonly mailService: MailerService\n ) {}\n\n @Get('/search')\n @HttpCode(HttpStatus.OK)\n @UsePipes(new ValidationPipe({ transform: true }))\n async usearch(\n @Query() req: PerformerSearchPayload\n ): Promise>> {\n req.status = 'active';\n // default sort is score\n // req.sort = 'popular';\n const data = await this.performerSearchService.search(req);\n return DataResponse.ok(data);\n }\n\n @Get('/me')\n @HttpCode(HttpStatus.OK)\n @Roles('performer')\n @UseGuards(RoleGuard)\n @UsePipes(new ValidationPipe({ transform: true }))\n async getMyProfile(@Request() req: any): Promise> {\n const { authUser, jwtToken } = req;\n const performer = await this.performerService.findByUserId(\n authUser.sourceId\n );\n const details = await this.performerService.getDetails(performer._id, {\n responseDocument: true,\n jwtToken\n });\n if (details.status === PERFORMER_STATUSES.INACTIVE) {\n throw new HttpException('This account is suspended', 403);\n }\n return DataResponse.ok(details.toResponse(true));\n }\n\n @Get('/:username')\n @HttpCode(HttpStatus.OK)\n async getDetails(\n @Param('username') performerUsername: string\n ): Promise>> {\n const data = await this.performerService.findByUsername(performerUsername);\n\n if (data.status !== PERFORMER_STATUSES.ACTIVE) {\n throw new HttpException('This account is suspended', 403);\n }\n\n return DataResponse.ok(data.toPublicDetailsResponse());\n }\n\n @Put('/')\n @HttpCode(HttpStatus.OK)\n @Roles('performer')\n @UseGuards(RoleGuard)\n @UsePipes(new ValidationPipe({ transform: true }))\n async updateMyProfile(\n @Body() payload: PerformerUpdatePayload,\n @Request() req: any\n ): Promise>> {\n const { sourceId } = req.authUser;\n const performer = await this.performerService.findByUserId(sourceId);\n\n const data = await this.performerService.update(\n performer._id,\n\n // remove unwanted fields\n omit(payload, UNALLOWED_SELF_UPDATE_FIELDS)\n );\n\n return DataResponse.ok(data);\n }\n\n @Get('/:username/related')\n @HttpCode(HttpStatus.OK)\n async getRelated(\n @Param('username') username: string\n ): Promise> {\n const data = await this.performerService.getRelated(username);\n return DataResponse.ok(data);\n }\n\n @Post('/:username/contact')\n @HttpCode(HttpStatus.OK)\n @UseGuards(AuthGuard)\n async contact(\n @Param('username') username: string,\n @Body() payload: ContactPayload\n ): Promise> {\n const performer = await this.performerService.findByUsername(username);\n if (!performer || performer.status !== 'active') { return DataResponse.error(new Error(\"Model doesn't exists\")); }\n await this.mailService.send({\n subject: `New contact from ${payload.name}`,\n to: performer.email,\n data: payload,\n template: 'contact-performer'\n });\n return DataResponse.ok(true);\n }\n}","type":"text"}]},{"type":"heading","attrs":{"level":3},"content":[{"text":"Performer Service Code Samples","type":"text"}]},{"type":"codeBlock","content":[{"text":"import {\n Injectable, forwardRef, Inject\n} from '@nestjs/common';\nimport { Model } from 'mongoose';\nimport {\n EntityNotFoundException, QueueEventService\n} from 'src/kernel';\nimport { ObjectId } from 'mongodb';\nimport { FileService } from 'src/modules/file/services';\nimport { FileDto } from 'src/modules/file';\nimport { UserDto } from 'src/modules/user/dtos';\nimport { REF_TYPE } from 'src/modules/file/constants';\nimport { isObjectId } from 'src/kernel/helpers/string.helper';\nimport { CategoryService } from 'src/modules/category/services';\nimport { EVENT } from 'src/kernel/constants';\nimport { UserService } from 'src/modules/user/services';\nimport { PerformerDto } from '../dtos';\nimport {\n UsernameExistedException\n} from '../exceptions';\nimport {\n PerformerModel\n} from '../models';\nimport {\n PerformerCreatePayload,\n PerformerUpdatePayload\n} from '../payloads';\nimport { PERFORMER_MODEL_PROVIDER } from '../providers';\nimport { PERFORMER_CHANNEL } from '../constants';\n\n@Injectable()\nexport class PerformerService {\n constructor(\n @Inject(forwardRef(() => CategoryService))\n private readonly categoryService: CategoryService,\n @Inject(PERFORMER_MODEL_PROVIDER)\n private readonly Performer: Model,\n private readonly fileService: FileService,\n @Inject(forwardRef(() => UserService))\n private readonly userService: UserService,\n private readonly queueEventService: QueueEventService\n ) {}\n\n public async findById(id: string | ObjectId): Promise {\n const model = await this.Performer.findById(id);\n if (!model) return null;\n return new PerformerDto(model);\n }\n\n public async findByEmail(email: string): Promise {\n if (!email) {\n return null;\n }\n const model = await this.Performer.findOne({\n email: email.toLowerCase()\n });\n if (!model) return null;\n return new PerformerDto(model);\n }\n\n public async create(\n payload: PerformerCreatePayload,\n user?: UserDto\n ): Promise {\n const data = {\n ...payload,\n updatedAt: new Date(),\n createdAt: new Date()\n } as any;\n const userNameCheck = await this.Performer.countDocuments({\n username: payload.username.trim()\n });\n if (userNameCheck) {\n throw new UsernameExistedException();\n }\n const usernameCheck2 = await this.userService.findByUsername(\n payload.username.trim()\n );\n if (usernameCheck2) {\n throw new UsernameExistedException();\n }\n\n if (user) {\n data.createdBy = user._id;\n }\n data.username = data.username.trim();\n data.email = data.email ? data.email.toLowerCase() : null;\n if (!data.name) data.name = data.username;\n\n const performer = await this.Performer.create(data);\n\n // update / create auth\n await this.queueEventService.publish({\n channel: PERFORMER_CHANNEL,\n eventName: EVENT.CREATED,\n data: {\n performer: performer.toObject(),\n payload\n }\n });\n\n return new PerformerDto(performer);\n }\n\n public async update(\n id: string | ObjectId,\n payload: Partial\n ): Promise {\n const performer = await this.Performer.findById(id);\n if (!performer) {\n throw new EntityNotFoundException();\n }\n const data = { ...payload, updatedAt: new Date() } as any;\n if (!data.name) {\n data.name = [data.firstName || '', data.lastName || ''].join(' ');\n }\n if (data.username && data.username.trim() !== performer.username) {\n const usernameCheck = await this.Performer.countDocuments({\n username: data.username.trim(),\n _id: { $ne: performer._id }\n });\n if (usernameCheck) {\n throw new UsernameExistedException();\n }\n const usernameCheck2 = await this.userService.findByUsername(\n payload.username.trim()\n );\n if (usernameCheck2._id.toString() !== performer.userId?.toString()) {\n throw new UsernameExistedException();\n }\n data.username = data.username.trim();\n }\n data.categoryIds = data.categoryIds || [];\n if (!data.name) data.name = data.username;\n await this.Performer.updateOne({ _id: id }, data);\n\n // update / create auth\n await this.queueEventService.publish({\n channel: PERFORMER_CHANNEL,\n eventName: EVENT.UPDATED,\n data: {\n performer: performer.toObject(),\n payload\n }\n });\n return { updated: true };\n }\n\n public async updateAvatar(performer: PerformerDto, file: FileDto) {\n await this.Performer.updateOne(\n { _id: performer._id },\n {\n avatarId: file._id,\n avatarPath: file.path\n }\n );\n await this.fileService.addRef(file._id, {\n itemId: performer._id,\n itemType: REF_TYPE.PERFORMER\n });\n\n const p = await this.Performer.findById(performer._id);\n\n await this.queueEventService.publish({\n channel: PERFORMER_CHANNEL,\n eventName: 'avatarUpdated',\n data: {\n performer: p.toObject(),\n file\n }\n });\n\n return file;\n }\n\n public async updateWelcomeVideo(user: PerformerDto, file: FileDto) {\n await this.Performer.updateOne(\n { _id: user._id },\n {\n welcomeVideoId: file._id,\n welcomeVideoPath: file.path\n }\n );\n\n await this.fileService.addRef(file._id, {\n itemId: user._id,\n itemType: REF_TYPE.PERFORMER\n });\n\n return file;\n }\n\n public async findByUserId(userId: string | ObjectId) {\n return this.Performer.findOne({ userId });\n }\n\n public async calculateScore(performerId) {\n const performer = performerId instanceof this.Performer\n ? performerId\n : await this.Performer.findById(performerId);\n if (!performer) return 0;\n\n let score = 0;\n if (performer.vip) score += 1;\n if (performer.verified) score += 1;\n return score;\n }\n}","type":"text"}]},{"type":"heading","attrs":{"level":3},"content":[{"text":"Frontend - Model Page Code Samples","type":"text"}]},{"type":"codeBlock","content":[{"text":"import moment from 'moment';\nimport Head from 'next/head';\nimport Router from 'next/router';\nimport React, { useEffect, useState } from 'react';\nimport { truncate } from 'lodash';\nimport {\n Layout, Row, Col, Button, Tag, message\n} from 'antd';\nimport { connect, useSelector } from 'react-redux';\nimport { performerService } from 'src/services';\nimport Review from '@components/reviews';\nimport { IPerformer, IUIConfig } from 'src/interfaces';\nimport { ProfileImagesCarousel } from '@components/performer/profile-images-carousel';\nimport ProfileContact from '@components/performer/profile-contact';\nimport { ProfileRates } from '@components/performer/profile-rates';\nimport { PerformeServicesList } from '@components/performer/peformer-services-list';\nimport { RelatedProfiles } from '@components/performer';\nimport { getYtbEmbeddedLink } from '@lib/utils';\nimport { VideoPopUp } from '@components/video-popup/video-popup';\nimport RightSideBanner from '@components/common/right-side-bar';\nimport Link from 'next/link';\n\nimport '@components/performer/performer.less';\nimport './index.less';\n\ninterface IProps {\n ui: IUIConfig;\n performer: IPerformer;\n attributes: any;\n}\n\nfunction redirect404(ctx: any) {\n if (process.browser) {\n Router.replace('/');\n message.error('The model account has been deactivated');\n return;\n }\n\n ctx.res.writeHead && ctx.res.writeHead(302, { Location: '/' });\n ctx.res.end && ctx.res.end();\n}\n\nfunction PerformerProfile({ performer, ui, attributes }: IProps) {\n const [details, setDetails] = useState({} as any);\n const [serviceSettings, setServiceSettings] = useState([]);\n const [rateSettings, setRateSettings] = useState([]);\n const loggedIn = useSelector((state: any) => state.auth.loggedIn);\n const currentUser = useSelector((state: any) => state.user.current);\n const loadSettings = async (p) => {\n try {\n const { data } = await performerService.loadSettings(p._id);\n const service = data.find((d) => d.group === 'services');\n if (service) setServiceSettings(service.settings);\n\n const rate = data.find((d) => d.group === 'rates');\n if (rate) setRateSettings(rate.settings);\n\n // eslint-disable-next-line no-empty\n } catch (e) {\n }\n };\n\n const escapeHtml = (unsafe) => (unsafe || '')\n .replace(/&/g, '&')\n .replace(//g, '>')\n .replace(/\"/g, '"')\n .replace(/'/g, ''')\n .replace(/\\n\\s*\\n/g, '\\n')\n // new line to br\n .replace(/(\\r\\n|\\n|\\r)/gm, '
');\n\n const getAge = (date) => moment().diff(date, 'years');\n\n useEffect(() => {\n const mapData = performerService.mapWithAttributes(performer, attributes);\n setDetails(mapData);\n }, [performer, attributes]);\n\n useEffect(() => {\n if (performer) loadSettings(performer);\n }, [performer]);\n const print = (attrData) => {\n if (Array.isArray(attrData)) return attrData.join('; ');\n return attrData;\n };\n\n const scrollDownToReviewList = () => {\n document.getElementById('review-list').scrollIntoView({\n behavior: 'smooth'\n });\n };\n return (\n \n \n \n {`${ui?.siteName} | ${performer?.username || 'Loading...'}`}\n \n \n \n {/* OG tags */}\n \n \n \n \n \n \n \n

{details?.name || details?.username}

\n {getYtbEmbeddedLink(details.introVideoLink) && (\n \n )}\n

{details?.name}

\n Last seen online:\n {' '}\n {details.offlineAt && (\n \n {moment(details.offlineAt).format('DD/MM/YYYY HH:mm')}\n \n )}\n

\n \n

\n\n \n \n \n \n \n

My details

\n Gender: \n {print(details.gender)}\n

\n Age: \n {getAge(details.dateOfBirth)}\n

\n Eyes: \n {print(details.eyes)}\n

\n Hair color: \n {print(details.hairColor)}\n

\n Hair length: \n {print(details.hairLength)}\n

\n Bust size: \n {print(details.bustSize)}\n

\n Bust type: \n {print(details.bustType)}\n

\n Travels: \n {print(details.travels)}\n

\n Weight: \n {print(details.weight)}\n

\n Height: \n {print(details.height)}\n

\n Ethnicity: \n {print(details.ethnicity)}\n

\n Orientation: \n {print(details.orientation)}\n

\n Smoker: \n {print(details.smoker)}\n

\n Tattoo: \n {print(details.tattoo)}\n

\n Nationality: \n {details.country}\n

\n Languages: \n {details.languages?.map((m) => ({print(m)}))}\n

\n Services: \n {details.services?.map((ser) => ({print(ser)}))}\n

\n Provides: \n {print(details.provides)}\n

\n Meeting with: \n {details.meetingWith?.map((m) => {print(m)})}\n

\n {details?.categories?.length && (\n

\n Category: \n {details.categories?.map((c) => (\n \n \n {c.name}\n \n \n )).reduce((prev, curr) => [prev, '; ', curr])}\n

\n )}\n

\n \n \n {\n if (!loggedIn) {\n message.info('Please login to chat with the model');\n return;\n }\n Router.push({ pathname: '/messages', query: { toSource: 'performer', toId: details.userId } }, `/messages?toSource=performer&toId=${details.userId}`);\n }}\n disabled={currentUser?.roles.includes('performer')}\n >\n CHAT\n \n \n \n {\n if (!loggedIn) {\n message.info('Please login to chat with the model');\n return;\n }\n Router.push({ pathname: '/booking', query: { username: performer?.username } });\n }}\n >\n BOOK\n \n \n \n

\n \n \n \n

RATES

\n \n

SERVICES

\n \n

REVIEW

\n {/* */}\n \n

\n \n \n \n \n \n \n \n );\n}\n\nconst mapStates = (state: any) => ({\n ui: state.ui,\n attributes: state.settings.attributes\n});\n\nconst ProfileConnectRedux = connect(mapStates)(PerformerProfile) as any;\n\nProfileConnectRedux.getInitialProps = async ({ ctx }) => {\n try {\n const { query } = ctx;\n const resp = await performerService.findOne(query.id);\n const { data: performer } = resp;\n\n if (!performer) {\n return redirect404(ctx);\n }\n\n return {\n performer\n };\n } catch (e) {\n return redirect404(ctx);\n }\n};\n\nexport default ProfileConnectRedux;","type":"text"}]}],"version":1}

Browser not supported