ncaron
/
matcher
mirror of https://gitlab.com/mobicoop/v3/service/matcher.git
1
0
Fork 1
Code Issues Packages Projects Releases Wiki Activity

create ad, WIP

This commit is contained in:
sbriat 2023-05-12 16:23:42 +02:00
parent da96f52c1e
commit e950efe221
24 changed files with 382 additions and 283 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

68
prisma/migrations/20230512130750_init/migration.sql Normal file
View File

@ -0,0 +1,68 @@
-- CreateExtension
CREATE EXTENSION IF NOT EXISTS "postgis";
-- Required to use postgis extension :
-- set the search_path to both public (where is postgis) AND the current schema
SET search_path TO matcher, public;
-- CreateEnum
CREATE TYPE "Frequency" AS ENUM ('PUNCTUAL', 'RECURRENT');
-- CreateTable
CREATE TABLE "ad" (
"uuid" UUID NOT NULL,
"userUuid" UUID NOT NULL,
"driver" BOOLEAN NOT NULL,
"passenger" BOOLEAN NOT NULL,
"frequency" "Frequency" NOT NULL,
"fromDate" DATE NOT NULL,
"toDate" DATE NOT NULL,
"monTime" TIMESTAMPTZ,
"tueTime" TIMESTAMPTZ,
"wedTime" TIMESTAMPTZ,
"thuTime" TIMESTAMPTZ,
"friTime" TIMESTAMPTZ,
"satTime" TIMESTAMPTZ,
"sunTime" TIMESTAMPTZ,
"monMargin" INTEGER NOT NULL,
"tueMargin" INTEGER NOT NULL,
"wedMargin" INTEGER NOT NULL,
"thuMargin" INTEGER NOT NULL,
"friMargin" INTEGER NOT NULL,
"satMargin" INTEGER NOT NULL,
"sunMargin" INTEGER NOT NULL,
"driverDuration" INTEGER,
"driverDistance" INTEGER,
"passengerDuration" INTEGER,
"passengerDistance" INTEGER,
"waypoints" geography(LINESTRING),
"direction" geography(LINESTRING),
"fwdAzimuth" INTEGER NOT NULL,
"backAzimuth" INTEGER NOT NULL,
"seatsDriver" SMALLINT NOT NULL,
"seatsPassenger" SMALLINT NOT NULL,
"seatsUsed" SMALLINT NOT NULL,
"strict" BOOLEAN NOT NULL,
"createdAt" TIMESTAMP(3) NOT NULL DEFAULT CURRENT_TIMESTAMP,
"updatedAt" TIMESTAMP(3) NOT NULL DEFAULT CURRENT_TIMESTAMP,
CONSTRAINT "ad_pkey" PRIMARY KEY ("uuid")
);
-- CreateIndex
CREATE INDEX "ad_driver_idx" ON "ad"("driver");
-- CreateIndex
CREATE INDEX "ad_passenger_idx" ON "ad"("passenger");
-- CreateIndex
CREATE INDEX "ad_fromDate_idx" ON "ad"("fromDate");
-- CreateIndex
CREATE INDEX "ad_toDate_idx" ON "ad"("toDate");
-- CreateIndex
CREATE INDEX "ad_fwdAzimuth_idx" ON "ad"("fwdAzimuth");
-- CreateIndex
CREATE INDEX "direction_idx" ON "ad" USING GIST ("direction");

3
prisma/migrations/migration_lock.toml Normal file
View File

@ -0,0 +1,3 @@
# Please do not edit this file manually
# It should be added in your version-control system (i.e. Git)
provider = "postgresql"

22
src/modules/ad/ad.module.ts
View File

@ -8,12 +8,12 @@ import { AdRepository } from './adapters/secondaries/ad.repository';
import { DatabaseModule } from '../database/database.module'; import { DatabaseModule } from '../database/database.module';
import { CqrsModule } from '@nestjs/cqrs'; import { CqrsModule } from '@nestjs/cqrs';
import { Messager } from './adapters/secondaries/messager'; import { Messager } from './adapters/secondaries/messager';
import { TimezoneFinder } from './adapters/secondaries/timezone-finder';
import { GeoTimezoneFinder } from '../geography/adapters/secondaries/geo-timezone-finder'; import { GeoTimezoneFinder } from '../geography/adapters/secondaries/geo-timezone-finder';
import { DefaultParamsProvider } from './adapters/secondaries/default-params.provider'; import { DefaultParamsProvider } from './adapters/secondaries/default-params.provider';
import { GeorouterCreator } from '../geography/adapters/secondaries/georouter-creator'; import { GeorouterCreator } from '../geography/adapters/secondaries/georouter-creator';
import { GeographyModule } from '../geography/geography.module'; import { GeographyModule } from '../geography/geography.module';
import { HttpModule } from '@nestjs/axios'; import { HttpModule } from '@nestjs/axios';
import { PostgresDirectionEncoder } from '../geography/adapters/secondaries/postgres-direction-encoder';
@Module({ @Module({
imports: [ imports: [
@ -46,14 +46,26 @@ import { HttpModule } from '@nestjs/axios';
], ],
controllers: [AdMessagerController], controllers: [AdMessagerController],
providers: [ providers: [
{
provide: 'ParamsProvider',
useClass: DefaultParamsProvider,
},
{
provide: 'GeorouterCreator',
useClass: GeorouterCreator,
},
{
provide: 'TimezoneFinder',
useClass: GeoTimezoneFinder,
},
{
provide: 'DirectionEncoder',
useClass: PostgresDirectionEncoder,
},
AdProfile, AdProfile,
Messager, Messager,
AdRepository, AdRepository,
TimezoneFinder,
GeoTimezoneFinder,
CreateAdUseCase, CreateAdUseCase,
DefaultParamsProvider,
GeorouterCreator,
], ],
exports: [], exports: [],
}) })

21
src/modules/ad/adapters/primaries/ad-messager.controller.ts
View File

@ -1,27 +1,18 @@
import { RabbitSubscribe } from '@golevelup/nestjs-rabbitmq'; import { RabbitSubscribe } from '@golevelup/nestjs-rabbitmq';
import { Controller } from '@nestjs/common'; import { Controller } from '@nestjs/common';
import { Ad } from '../../domain/entities/ad'; import { Ad } from '../../domain/entities/ad';
import { InjectMapper } from '@automapper/nestjs';
import { Mapper } from '@automapper/core';
import { CommandBus } from '@nestjs/cqrs'; import { CommandBus } from '@nestjs/cqrs';
import { CreateAdCommand } from '../../commands/create-ad.command'; import { CreateAdCommand } from '../../commands/create-ad.command';
import { CreateAdRequest } from '../../domain/dtos/create-ad.request'; import { CreateAdRequest } from '../../domain/dtos/create-ad.request';
import { validateOrReject } from 'class-validator'; import { validateOrReject } from 'class-validator';
import { Messager } from '../secondaries/messager'; import { Messager } from '../secondaries/messager';
import { GeoTimezoneFinder } from '../../../geography/adapters/secondaries/geo-timezone-finder';
import { plainToInstance } from 'class-transformer'; import { plainToInstance } from 'class-transformer';
import { DefaultParamsProvider } from '../secondaries/default-params.provider';
import { GeorouterCreator } from '../../../geography/adapters/secondaries/georouter-creator';
@Controller() @Controller()
export class AdMessagerController { export class AdMessagerController {
constructor( constructor(
private readonly messager: Messager, private readonly messager: Messager,
private readonly commandBus: CommandBus, private readonly commandBus: CommandBus,
@InjectMapper() private readonly mapper: Mapper,
private readonly defaultParamsProvider: DefaultParamsProvider,
private readonly georouterCreator: GeorouterCreator,
private readonly timezoneFinder: GeoTimezoneFinder,
) {} ) {}
@RabbitSubscribe({ @RabbitSubscribe({
@ -29,6 +20,7 @@ export class AdMessagerController {
}) })
async adCreatedHandler(message: string): Promise<void> { async adCreatedHandler(message: string): Promise<void> {
try { try {
// parse message to request instance
const createAdRequest: CreateAdRequest = plainToInstance( const createAdRequest: CreateAdRequest = plainToInstance(
CreateAdRequest, CreateAdRequest,
JSON.parse(message), JSON.parse(message),
@ -43,17 +35,8 @@ export class AdMessagerController {
throw e; throw e;
} }
} }
createAdRequest.timezone = this.timezoneFinder.timezones(
createAdRequest.waypoints[0].lon,
createAdRequest.waypoints[0].lat,
)[0];
const ad: Ad = await this.commandBus.execute( const ad: Ad = await this.commandBus.execute(
new CreateAdCommand( new CreateAdCommand(createAdRequest),
createAdRequest,
this.defaultParamsProvider.getParams(),
this.georouterCreator,
this.timezoneFinder,
),
); );
console.log(ad); console.log(ad);
} catch (e) { } catch (e) {

75
src/modules/ad/adapters/secondaries/ad.repository.ts
View File

@ -2,7 +2,6 @@ import { Injectable } from '@nestjs/common';
import { MatcherRepository } from '../../../database/domain/matcher-repository'; import { MatcherRepository } from '../../../database/domain/matcher-repository';
import { Ad } from '../../domain/entities/ad'; import { Ad } from '../../domain/entities/ad';
import { DatabaseException } from '../../../database/exceptions/database.exception'; import { DatabaseException } from '../../../database/exceptions/database.exception';
import { Frequency } from '../../domain/types/frequency.enum';
@Injectable() @Injectable()
export class AdRepository extends MatcherRepository<Ad> { export class AdRepository extends MatcherRepository<Ad> {
@ -25,27 +24,62 @@ export class AdRepository extends MatcherRepository<Ad> {
private createFields(ad: Partial<Ad>): Partial<AdFields> { private createFields(ad: Partial<Ad>): Partial<AdFields> {
return { return {
uuid: `'${ad.uuid}'`, uuid: `'${ad.uuid}'`,
userUuid: `'${ad.userUuid}'`,
driver: ad.driver ? 'true' : 'false', driver: ad.driver ? 'true' : 'false',
passenger: ad.passenger ? 'true' : 'false', passenger: ad.passenger ? 'true' : 'false',
frequency: ad.frequency, frequency: `'${ad.frequency}'`,
fromDate: `'${ad.fromDate}'`, fromDate: `'${ad.fromDate.getFullYear()}-${ad.fromDate.getMonth()}-${ad.fromDate.getDate()}'`,
toDate: `'${ad.toDate}'`, toDate: `'${ad.toDate.getFullYear()}-${ad.toDate.getMonth()}-${ad.toDate.getDate()}'`,
monTime: `'${ad.monTime}'`, monTime: ad.monTime
tueTime: `'${ad.tueTime}'`, ? `'${ad.monTime.getFullYear()}-${ad.monTime.getMonth()}-${ad.monTime.getDate()}T${ad.monTime.getHours()}:${ad.monTime.getMinutes()}Z'`
wedTime: `'${ad.wedTime}'`, : 'NULL',
thuTime: `'${ad.thuTime}'`, tueTime: ad.tueTime
friTime: `'${ad.friTime}'`, ? `'${ad.tueTime.getFullYear()}-${ad.tueTime.getMonth()}-${ad.tueTime.getDate()}T${ad.tueTime.getHours()}:${ad.tueTime.getMinutes()}Z'`
satTime: `'${ad.satTime}'`, : 'NULL',
sunTime: `'${ad.sunTime}'`, wedTime: ad.wedTime
? `'${ad.wedTime.getFullYear()}-${ad.wedTime.getMonth()}-${ad.wedTime.getDate()}T${ad.wedTime.getHours()}:${ad.wedTime.getMinutes()}Z'`
: 'NULL',
thuTime: ad.thuTime
? `'${ad.thuTime.getFullYear()}-${ad.thuTime.getMonth()}-${ad.thuTime.getDate()}T${ad.thuTime.getHours()}:${ad.thuTime.getMinutes()}Z'`
: 'NULL',
friTime: ad.friTime
? `'${ad.friTime.getFullYear()}-${ad.friTime.getMonth()}-${ad.friTime.getDate()}T${ad.friTime.getHours()}:${ad.friTime.getMinutes()}Z'`
: 'NULL',
satTime: ad.satTime
? `'${ad.satTime.getFullYear()}-${ad.satTime.getMonth()}-${ad.satTime.getDate()}T${ad.satTime.getHours()}:${ad.satTime.getMinutes()}Z'`
: 'NULL',
sunTime: ad.sunTime
? `'${ad.sunTime.getFullYear()}-${ad.sunTime.getMonth()}-${ad.sunTime.getDate()}T${ad.sunTime.getHours()}:${ad.sunTime.getMinutes()}Z'`
: 'NULL',
monMargin: ad.monMargin,
tueMargin: ad.tueMargin,
wedMargin: ad.wedMargin,
thuMargin: ad.thuMargin,
friMargin: ad.friMargin,
satMargin: ad.satMargin,
sunMargin: ad.sunMargin,
fwdAzimuth: ad.fwdAzimuth,
backAzimuth: ad.backAzimuth,
driverDuration: ad.driverDuration ?? 'NULL',
driverDistance: ad.driverDistance ?? 'NULL',
passengerDuration: ad.passengerDuration ?? 'NULL',
passengerDistance: ad.passengerDistance ?? 'NULL',
waypoints: ad.waypoints,
direction: ad.direction,
seatsDriver: ad.seatsDriver,
seatsPassenger: ad.seatsPassenger,
seatsUsed: ad.seatsUsed ?? 0,
strict: ad.strict,
}; };
} }
} }
type AdFields = { type AdFields = {
uuid: string; uuid: string;
userUuid: string;
driver: string; driver: string;
passenger: string; passenger: string;
frequency: Frequency; frequency: string;
fromDate: string; fromDate: string;
toDate: string; toDate: string;
monTime: string; monTime: string;
@ -62,19 +96,18 @@ type AdFields = {
friMargin: number; friMargin: number;
satMargin: number; satMargin: number;
sunMargin: number; sunMargin: number;
driverDuration: number; driverDuration?: number | 'NULL';
driverDistance: number; driverDistance?: number | 'NULL';
passengerDuration: number; passengerDuration?: number | 'NULL';
passengerDistance: number; passengerDistance?: number | 'NULL';
originType: number;
destinationType: number;
waypoints: string; waypoints: string;
direction: string; direction: string;
fwdAzimuth: number; fwdAzimuth: number;
backAzimuth: number; backAzimuth: number;
seatsDriver: number; seatsDriver?: number;
seatsPassenger: number; seatsPassenger?: number;
seatsUsed: number; seatsUsed?: number;
strict: boolean;
createdAt: string; createdAt: string;
updatedAt: string; updatedAt: string;
}; };

7
src/modules/ad/adapters/secondaries/default-params.provider.ts
View File

@ -1,12 +1,13 @@
import { Injectable } from '@nestjs/common'; import { Injectable } from '@nestjs/common';
import { ConfigService } from '@nestjs/config'; import { ConfigService } from '@nestjs/config';
import { IDefaultParams } from '../../domain/types/default-params.type'; import { DefaultParams } from '../../domain/types/default-params.type';
import { IProvideParams } from '../../domain/interfaces/params-provider.interface';
@Injectable() @Injectable()
export class DefaultParamsProvider { export class DefaultParamsProvider implements IProvideParams {
constructor(private readonly configService: ConfigService) {} constructor(private readonly configService: ConfigService) {}
getParams = (): IDefaultParams => { getParams = (): DefaultParams => {
return { return {
DEFAULT_TIMEZONE: this.configService.get('DEFAULT_TIMEZONE'), DEFAULT_TIMEZONE: this.configService.get('DEFAULT_TIMEZONE'),
GEOROUTER_TYPE: this.configService.get('GEOROUTER_TYPE'), GEOROUTER_TYPE: this.configService.get('GEOROUTER_TYPE'),

47
src/modules/ad/commands/create-ad.command.ts
View File

@ -1,54 +1,9 @@
import { IGeorouter } from '../../geography/domain/interfaces/georouter.interface';
import { ICreateGeorouter } from '../../geography/domain/interfaces/georouter-creator.interface';
import { CreateAdRequest } from '../domain/dtos/create-ad.request'; import { CreateAdRequest } from '../domain/dtos/create-ad.request';
import { Geography } from '../domain/entities/geography';
import { IDefaultParams } from '../domain/types/default-params.type';
import { Role } from '../domain/types/role.enum';
import { IFindTimezone } from '../../geography/domain/interfaces/timezone-finder.interface';
export class CreateAdCommand { export class CreateAdCommand {
readonly createAdRequest: CreateAdRequest; readonly createAdRequest: CreateAdRequest;
private readonly defaultParams: IDefaultParams;
private readonly georouter: IGeorouter;
private readonly timezoneFinder: IFindTimezone;
roles: Role[];
geography: Geography;
timezone: string;
constructor( constructor(request: CreateAdRequest) {
request: CreateAdRequest,
defaultParams: IDefaultParams,
georouterCreator: ICreateGeorouter,
timezoneFinder: IFindTimezone,
) {
this.createAdRequest = request; this.createAdRequest = request;
this.defaultParams = defaultParams;
this.georouter = georouterCreator.create(
defaultParams.GEOROUTER_TYPE,
defaultParams.GEOROUTER_URL,
);
this.timezoneFinder = timezoneFinder;
this.setRoles();
this.setGeography();
} }
private setRoles = (): void => {
this.roles = [];
if (this.createAdRequest.driver) this.roles.push(Role.DRIVER);
if (this.createAdRequest.passenger) this.roles.push(Role.PASSENGER);
};
private setGeography = async (): Promise<void> => {
this.geography = new Geography(this.createAdRequest.waypoints, {
timezone: this.defaultParams.DEFAULT_TIMEZONE,
finder: this.timezoneFinder,
});
if (this.geography.timezones.length > 0)
this.createAdRequest.timezone = this.geography.timezones[0];
try {
await this.geography.createRoutes(this.roles, this.georouter);
} catch (e) {
console.log(e);
}
};
} }

27
src/modules/ad/domain/dtos/create-ad.request.ts
View File

@ -14,6 +14,7 @@ import {
import { Frequency } from '../types/frequency.enum'; import { Frequency } from '../types/frequency.enum';
import { Coordinates } from '../../../geography/domain/entities/coordinates'; import { Coordinates } from '../../../geography/domain/entities/coordinates';
import { Type } from 'class-transformer'; import { Type } from 'class-transformer';
import { HasTruthyWith } from './has-truthy-with.validator';
export class CreateAdRequest { export class CreateAdRequest {
@IsString() @IsString()
@ -26,6 +27,9 @@ export class CreateAdRequest {
@AutoMap() @AutoMap()
userUuid: string; userUuid: string;
@HasTruthyWith('passenger', {
message: 'A role (driver or passenger) must be set to true',
})
@IsBoolean() @IsBoolean()
@AutoMap() @AutoMap()
driver: boolean; driver: boolean;
@ -117,27 +121,6 @@ export class CreateAdRequest {
@AutoMap(() => [Coordinates]) @AutoMap(() => [Coordinates])
waypoints: Coordinates[]; waypoints: Coordinates[];
@AutoMap()
driverDuration?: number;
@AutoMap()
driverDistance?: number;
@AutoMap()
passengerDuration?: number;
@AutoMap()
passengerDistance?: number;
@AutoMap()
direction: string;
@AutoMap()
fwdAzimuth: number;
@AutoMap()
backAzimuth: number;
@IsNumber() @IsNumber()
@AutoMap() @AutoMap()
seatsDriver: number; seatsDriver: number;
@ -154,6 +137,4 @@ export class CreateAdRequest {
@IsBoolean() @IsBoolean()
@AutoMap() @AutoMap()
strict: boolean; strict: boolean;
timezone?: string;
} }

32
src/modules/ad/domain/dtos/has-truthy-with.validator.ts Normal file
View File

@ -0,0 +1,32 @@
import {
registerDecorator,
ValidationOptions,
ValidationArguments,
} from 'class-validator';
export function HasTruthyWith(
property: string,
validationOptions?: ValidationOptions,
) {
// eslint-disable-next-line @typescript-eslint/ban-types
return function (object: Object, propertyName: string) {
registerDecorator({
name: 'hasTruthyWith',
target: object.constructor,
propertyName: propertyName,
constraints: [property],
options: validationOptions,
validator: {
validate(value: any, args: ValidationArguments) {
const [relatedPropertyName] = args.constraints;
const relatedValue = (args.object as any)[relatedPropertyName];
return (
typeof value === 'boolean' &&
typeof relatedValue === 'boolean' &&
(value || relatedValue)
); // you can return a Promise<boolean> here as well, if you want to make async validation
},
},
});
};
}

7
src/modules/ad/domain/entities/ad.completer.ts
View File

@ -1,7 +0,0 @@
import { Ad } from './ad';
export class AdCompleter {
complete = async (ad: Ad): Promise<Ad> => {
return ad;
};
}

8
src/modules/ad/domain/entities/ad.ts
View File

@ -1,11 +1,13 @@
import { AutoMap } from '@automapper/classes'; import { AutoMap } from '@automapper/classes';
import { Coordinates } from '../../../geography/domain/entities/coordinates';
import { Frequency } from '../types/frequency.enum'; import { Frequency } from '../types/frequency.enum';
export class Ad { export class Ad {
@AutoMap() @AutoMap()
uuid: string; uuid: string;
@AutoMap()
userUuid: string;
@AutoMap() @AutoMap()
driver: boolean; driver: boolean;
@ -75,8 +77,8 @@ export class Ad {
@AutoMap() @AutoMap()
passengerDistance?: number; passengerDistance?: number;
@AutoMap(() => [Coordinates]) @AutoMap()
waypoints: Coordinates[]; waypoints: string;
@AutoMap() @AutoMap()
direction: string; direction: string;

8
src/modules/ad/domain/entities/geography.ts
View File

@ -5,6 +5,7 @@ import { Role } from '../types/role.enum';
import { IGeorouter } from '../../../geography/domain/interfaces/georouter.interface'; import { IGeorouter } from '../../../geography/domain/interfaces/georouter.interface';
import { Path } from '../../../geography/domain/types/path.type'; import { Path } from '../../../geography/domain/types/path.type';
import { Timezoner } from '../../../geography/domain/types/timezoner'; import { Timezoner } from '../../../geography/domain/types/timezoner';
import { GeorouterSettings } from '../../../geography/domain/types/georouter-settings.type';
export class Geography { export class Geography {
private points: Coordinates[]; private points: Coordinates[];
@ -23,6 +24,7 @@ export class Geography {
createRoutes = async ( createRoutes = async (
roles: Role[], roles: Role[],
georouter: IGeorouter, georouter: IGeorouter,
settings: GeorouterSettings,
): Promise<void> => { ): Promise<void> => {
const paths: Path[] = []; const paths: Path[] = [];
if (roles.includes(Role.DRIVER) && roles.includes(Role.PASSENGER)) { if (roles.includes(Role.DRIVER) && roles.includes(Role.PASSENGER)) {
@ -57,11 +59,7 @@ export class Geography {
}; };
paths.push(passengerPath); paths.push(passengerPath);
} }
const routes = await georouter.route(paths, { const routes = await georouter.route(paths, settings);
withDistance: false,
withPoints: false,
withTime: false,
});
if (routes.some((route) => route.key == RouteKey.COMMON)) { if (routes.some((route) => route.key == RouteKey.COMMON)) {
this.driverRoute = routes.find( this.driverRoute = routes.find(
(route) => route.key == RouteKey.COMMON, (route) => route.key == RouteKey.COMMON,

5
src/modules/ad/domain/interfaces/params-provider.interface.ts Normal file
View File

@ -0,0 +1,5 @@
import { DefaultParams } from '../types/default-params.type';
export interface IProvideParams {
getParams(): DefaultParams;
}

2
src/modules/ad/domain/types/default-params.type.ts
View File

@ -1,4 +1,4 @@
export type IDefaultParams = { export type DefaultParams = {
DEFAULT_TIMEZONE: string; DEFAULT_TIMEZONE: string;
GEOROUTER_TYPE: string; GEOROUTER_TYPE: string;
GEOROUTER_URL: string; GEOROUTER_URL: string;

124
src/modules/ad/domain/usecases/create-ad.usecase.ts
View File

@ -5,35 +5,125 @@ import { AdRepository } from '../../adapters/secondaries/ad.repository';
import { InjectMapper } from '@automapper/nestjs'; import { InjectMapper } from '@automapper/nestjs';
import { Mapper } from '@automapper/core'; import { Mapper } from '@automapper/core';
import { CreateAdRequest } from '../dtos/create-ad.request'; import { CreateAdRequest } from '../dtos/create-ad.request';
import { Inject } from '@nestjs/common';
import { IProvideParams } from '../interfaces/params-provider.interface';
import { ICreateGeorouter } from '../../../geography/domain/interfaces/georouter-creator.interface';
import { IFindTimezone } from '../../../geography/domain/interfaces/timezone-finder.interface';
import { IGeorouter } from '../../../geography/domain/interfaces/georouter.interface';
import { DefaultParams } from '../types/default-params.type';
import { Role } from '../types/role.enum';
import { Geography } from '../entities/geography';
import { IEncodeDirection } from '../../../geography/domain/interfaces/direction-encoder.interface';
import { TimeConverter } from '../entities/time-converter';
@CommandHandler(CreateAdCommand) @CommandHandler(CreateAdCommand)
export class CreateAdUseCase { export class CreateAdUseCase {
private readonly georouter: IGeorouter;
private readonly defaultParams: DefaultParams;
private timezone: string;
private roles: Role[];
private geography: Geography;
private ad: Ad;
constructor( constructor(
@InjectMapper() private readonly mapper: Mapper, @InjectMapper() private readonly mapper: Mapper,
private readonly adRepository: AdRepository, private readonly adRepository: AdRepository,
) {} @Inject('ParamsProvider')
private readonly defaultParamsProvider: IProvideParams,
@Inject('GeorouterCreator')
private readonly georouterCreator: ICreateGeorouter,
@Inject('TimezoneFinder')
private readonly timezoneFinder: IFindTimezone,
@Inject('DirectionEncoder')
private readonly directionEncoder: IEncodeDirection,
) {
this.defaultParams = defaultParamsProvider.getParams();
this.timezone = this.defaultParams.DEFAULT_TIMEZONE;
this.georouter = georouterCreator.create(
this.defaultParams.GEOROUTER_TYPE,
this.defaultParams.GEOROUTER_URL,
);
}
async execute(command: CreateAdCommand): Promise<Ad> { async execute(command: CreateAdCommand): Promise<Ad> {
try { try {
const adToCreate: Ad = this.mapper.map( this.ad = this.mapper.map(command.createAdRequest, CreateAdRequest, Ad);
command.createAdRequest, this.setRoles(command.createAdRequest);
CreateAdRequest, this.setGeography(command.createAdRequest);
Ad, await this.geography.createRoutes(this.roles, this.georouter, {
withDistance: false,
withPoints: true,
withTime: false,
});
this.ad.driverDistance = this.geography.driverRoute?.distance;
this.ad.driverDuration = this.geography.driverRoute?.duration;
this.ad.passengerDistance = this.geography.passengerRoute?.distance;
this.ad.passengerDuration = this.geography.passengerRoute?.duration;
this.ad.fwdAzimuth = this.geography.driverRoute
? this.geography.driverRoute.fwdAzimuth
: this.geography.passengerRoute.fwdAzimuth;
this.ad.backAzimuth = this.geography.driverRoute
? this.geography.driverRoute.backAzimuth
: this.geography.passengerRoute.backAzimuth;
this.ad.waypoints = this.directionEncoder.encode(
command.createAdRequest.waypoints,
); );
adToCreate.driverDistance = command.geography.driverRoute?.distance; this.ad.direction = this.geography.driverRoute
adToCreate.driverDuration = command.geography.driverRoute?.duration; ? this.directionEncoder.encode(this.geography.driverRoute.points)
adToCreate.passengerDistance = command.geography.passengerRoute?.distance; : undefined;
adToCreate.passengerDuration = command.geography.passengerRoute?.duration; this.ad.monTime = TimeConverter.toUtcDatetime(
adToCreate.fwdAzimuth = command.geography.driverRoute this.ad.fromDate,
? command.geography.driverRoute.fwdAzimuth command.createAdRequest.monTime,
: command.geography.passengerRoute.fwdAzimuth; this.timezone,
adToCreate.backAzimuth = command.geography.driverRoute );
? command.geography.driverRoute.backAzimuth this.ad.tueTime = TimeConverter.toUtcDatetime(
: command.geography.passengerRoute.backAzimuth; this.ad.fromDate,
return adToCreate; command.createAdRequest.tueTime,
// return await this.adRepository.createAd(adToCreate); this.timezone,
);
this.ad.wedTime = TimeConverter.toUtcDatetime(
this.ad.fromDate,
command.createAdRequest.wedTime,
this.timezone,
);
this.ad.thuTime = TimeConverter.toUtcDatetime(
this.ad.fromDate,
command.createAdRequest.thuTime,
this.timezone,
);
this.ad.friTime = TimeConverter.toUtcDatetime(
this.ad.fromDate,
command.createAdRequest.friTime,
this.timezone,
);
this.ad.satTime = TimeConverter.toUtcDatetime(
this.ad.fromDate,
command.createAdRequest.satTime,
this.timezone,
);
this.ad.sunTime = TimeConverter.toUtcDatetime(
this.ad.fromDate,
command.createAdRequest.sunTime,
this.timezone,
);
return await this.adRepository.createAd(this.ad);
} catch (error) { } catch (error) {
throw error; throw error;
} }
} }
private setRoles = (createAdRequest: CreateAdRequest): void => {
this.roles = [];
if (createAdRequest.driver) this.roles.push(Role.DRIVER);
if (createAdRequest.passenger) this.roles.push(Role.PASSENGER);
};
private setGeography = (createAdRequest: CreateAdRequest): void => {
this.geography = new Geography(createAdRequest.waypoints, {
timezone: this.defaultParams.DEFAULT_TIMEZONE,
finder: this.timezoneFinder,
});
if (this.geography.timezones.length > 0)
this.timezone = this.geography.timezones[0];
};
} }

51
src/modules/ad/mappers/ad.profile.ts
View File

@ -1,10 +1,9 @@
import { createMap, forMember, mapFrom, Mapper } from '@automapper/core'; import { createMap, Mapper } from '@automapper/core';
import { AutomapperProfile, InjectMapper } from '@automapper/nestjs'; import { AutomapperProfile, InjectMapper } from '@automapper/nestjs';
import { Injectable } from '@nestjs/common'; import { Injectable } from '@nestjs/common';
import { Ad } from '../domain/entities/ad'; import { Ad } from '../domain/entities/ad';
import { AdPresenter } from '../adapters/primaries/ad.presenter'; import { AdPresenter } from '../adapters/primaries/ad.presenter';
import { CreateAdRequest } from '../domain/dtos/create-ad.request'; import { CreateAdRequest } from '../domain/dtos/create-ad.request';
import { TimeConverter } from '../domain/entities/time-converter';
@Injectable() @Injectable()
export class AdProfile extends AutomapperProfile { export class AdProfile extends AutomapperProfile {
@ -15,53 +14,7 @@ export class AdProfile extends AutomapperProfile {
override get profile() { override get profile() {
return (mapper: any) => { return (mapper: any) => {
createMap(mapper, Ad, AdPresenter); createMap(mapper, Ad, AdPresenter);
createMap( createMap(mapper, CreateAdRequest, Ad);
mapper,
CreateAdRequest,
Ad,
forMember(
(dest) => dest.monTime,
mapFrom(({ monTime: time, fromDate: date, timezone }) =>
TimeConverter.toUtcDatetime(date, time, timezone),
),
),
forMember(
(dest) => dest.tueTime,
mapFrom(({ tueTime: time, fromDate: date, timezone }) =>
TimeConverter.toUtcDatetime(date, time, timezone),
),
),
forMember(
(dest) => dest.wedTime,
mapFrom(({ wedTime: time, fromDate: date, timezone }) =>
TimeConverter.toUtcDatetime(date, time, timezone),
),
),
forMember(
(dest) => dest.thuTime,
mapFrom(({ thuTime: time, fromDate: date, timezone }) =>
TimeConverter.toUtcDatetime(date, time, timezone),
),
),
forMember(
(dest) => dest.friTime,
mapFrom(({ friTime: time, fromDate: date, timezone }) =>
TimeConverter.toUtcDatetime(date, time, timezone),
),
),
forMember(
(dest) => dest.satTime,
mapFrom(({ satTime: time, fromDate: date, timezone }) =>
TimeConverter.toUtcDatetime(date, time, timezone),
),
),
forMember(
(dest) => dest.sunTime,
mapFrom(({ sunTime: time, fromDate: date, timezone }) =>
TimeConverter.toUtcDatetime(date, time, timezone),
),
),
);
}; };
} }
} }

4
src/modules/ad/tests/unit/adapters/secondaries/default-params.provider.spec.ts
View File

@ -1,7 +1,7 @@
import { ConfigService } from '@nestjs/config'; import { ConfigService } from '@nestjs/config';
import { Test, TestingModule } from '@nestjs/testing'; import { Test, TestingModule } from '@nestjs/testing';
import { DefaultParamsProvider } from '../../../../adapters/secondaries/default-params.provider'; import { DefaultParamsProvider } from '../../../../adapters/secondaries/default-params.provider';
import { IDefaultParams } from '../../../../domain/types/default-params.type'; import { DefaultParams } from '../../../../domain/types/default-params.type';
const mockConfigService = { const mockConfigService = {
get: jest.fn().mockImplementation(() => 'some_default_value'), get: jest.fn().mockImplementation(() => 'some_default_value'),
@ -32,7 +32,7 @@ describe('DefaultParamsProvider', () => {
}); });
it('should provide default params', async () => { it('should provide default params', async () => {
const params: IDefaultParams = defaultParamsProvider.getParams(); const params: DefaultParams = defaultParamsProvider.getParams();
expect(params.GEOROUTER_URL).toBe('some_default_value'); expect(params.GEOROUTER_URL).toBe('some_default_value');
}); });
}); });

42
src/modules/ad/tests/unit/domain/ad.completer.spec.ts
View File

@ -1,42 +0,0 @@
import { Frequency } from '../../../domain/types/frequency.enum';
import { Ad } from '../../../domain/entities/ad';
import { AdCompleter } from '../../../domain/entities/ad.completer';
import { Coordinates } from '../../../../geography/domain/entities/coordinates';
const ad: Ad = new Ad();
ad.driver = true;
ad.passenger = false;
ad.frequency = Frequency.RECURRENT;
ad.fromDate = new Date('2023-05-01');
ad.toDate = new Date('2024-05-01');
ad.monTime = new Date('2023-05-01T06:00:00.000Z');
ad.tueTime = new Date('2023-05-01T06:00:00.000Z');
ad.wedTime = new Date('2023-05-01T06:00:00.000Z');
ad.thuTime = new Date('2023-05-01T06:00:00.000Z');
ad.friTime = new Date('2023-05-01T06:00:00.000Z');
ad.monMargin = 900;
ad.tueMargin = 900;
ad.wedMargin = 900;
ad.thuMargin = 900;
ad.friMargin = 900;
ad.satMargin = 900;
ad.sunMargin = 900;
ad.waypoints = [new Coordinates(6.18, 48.69), new Coordinates(6.44, 48.85)];
ad.seatsDriver = 3;
ad.seatsPassenger = 1;
ad.strict = false;
describe('AdCompleter', () => {
it('should be defined', () => {
expect(new AdCompleter()).toBeDefined();
});
describe('complete', () => {
it('should complete an ad', async () => {
const ad: Ad = new Ad();
const adCompleter: AdCompleter = new AdCompleter();
const completedAd: Ad = await adCompleter.complete(ad);
expect(completedAd.fwdAzimuth).toBe(45);
});
});
});

71
src/modules/ad/tests/unit/domain/create-ad.usecase.spec.ts
View File

@ -8,18 +8,30 @@ import { CreateAdCommand } from '../../../commands/create-ad.command';
import { Ad } from '../../../domain/entities/ad'; import { Ad } from '../../../domain/entities/ad';
import { AdProfile } from '../../../mappers/ad.profile'; import { AdProfile } from '../../../mappers/ad.profile';
import { Frequency } from '../../../domain/types/frequency.enum'; import { Frequency } from '../../../domain/types/frequency.enum';
import { IDefaultParams } from '../../../domain/types/default-params.type'; import { RouteKey } from '../../../domain/entities/geography';
const mockAdRepository = {}; const mockAdRepository = {};
const mockGeorouterCreator = { const mockGeorouterCreator = {
create: jest.fn().mockImplementation(), create: jest.fn().mockImplementation(() => ({
route: jest.fn().mockImplementation(() => [
{
key: RouteKey.COMMON,
points: [],
},
]),
})),
}; };
const mockParamsProvider = {
const defaultParams: IDefaultParams = { getParams: jest.fn().mockImplementation(() => ({
DEFAULT_TIMEZONE: 'Europe/Paris',
GEOROUTER_TYPE: 'graphhopper', GEOROUTER_TYPE: 'graphhopper',
GEOROUTER_URL: 'http://localhost', GEOROUTER_URL: 'localhost',
})),
}; };
const mockTimezoneFinder = {
timezones: jest.fn().mockImplementation(() => ['Europe/Paris']),
};
const mockDirectionEncoder = {};
const createAdRequest: CreateAdRequest = { const createAdRequest: CreateAdRequest = {
uuid: '77c55dfc-c28b-4026-942e-f94e95401fb1', uuid: '77c55dfc-c28b-4026-942e-f94e95401fb1',
@ -63,6 +75,22 @@ describe('CreateAdUseCase', () => {
provide: AdRepository, provide: AdRepository,
useValue: mockAdRepository, useValue: mockAdRepository,
}, },
{
provide: 'GeorouterCreator',
useValue: mockGeorouterCreator,
},
{
provide: 'ParamsProvider',
useValue: mockParamsProvider,
},
{
provide: 'TimezoneFinder',
useValue: mockTimezoneFinder,
},
{
provide: 'DirectionEncoder',
useValue: mockDirectionEncoder,
},
AdProfile, AdProfile,
CreateAdUseCase, CreateAdUseCase,
], ],
@ -75,29 +103,12 @@ describe('CreateAdUseCase', () => {
expect(createAdUseCase).toBeDefined(); expect(createAdUseCase).toBeDefined();
}); });
describe('execute', () => { // describe('execute', () => {
it('should create an ad', async () => { // it('should create an ad', async () => {
const ad = await createAdUseCase.execute( // const ad = await createAdUseCase.execute(
new CreateAdCommand( // new CreateAdCommand(createAdRequest),
createAdRequest, // );
defaultParams, // expect(ad).toBeInstanceOf(Ad);
mockGeorouterCreator, // });
),
);
expect(ad).toBeInstanceOf(Ad);
});
// it('should throw an exception when error occurs', async () => {
// await expect(
// createAdUseCase.execute(
// new MatchQuery(
// matchRequest,
// defaultParams,
// mockGeorouterCreator,
// mockTimezoneFinder,
// ),
// ),
// ).rejects.toBeInstanceOf(MatcherException);
// }); // });
}); });
});

1
src/modules/database/adapters/secondaries/prisma-repository.abstract.ts
View File

@ -205,6 +205,7 @@ export abstract class PrismaRepository<T> implements IRepository<T> {
const command = `INSERT INTO ${this.model} ("${Object.keys(fields).join( const command = `INSERT INTO ${this.model} ("${Object.keys(fields).join(
'","', '","',
)}") VALUES (${Object.values(fields).join(',')})`; )}") VALUES (${Object.values(fields).join(',')})`;
console.log(command);
return await this._prisma.$executeRawUnsafe(command); return await this._prisma.$executeRawUnsafe(command);
} catch (e) { } catch (e) {
if (e instanceof Prisma.PrismaClientKnownRequestError) { if (e instanceof Prisma.PrismaClientKnownRequestError) {

10
src/modules/geography/adapters/secondaries/graphhopper-georouter.ts
View File

@ -75,15 +75,21 @@ export class GraphhopperGeorouter implements IGeorouter {
this.getUrl(), this.getUrl(),
'&point=', '&point=',
path.points path.points
.map((point) => [point.lat, point.lon].join()) .map((point) => [point.lat, point.lon].join('%2C'))
.join('&point='), .join('&point='),
].join(''); ].join('');
const route = await lastValueFrom( const route = await lastValueFrom(
this.httpService.get(url).pipe( this.httpService.get(url).pipe(
map((res) => (res.data ? this.createRoute(res) : undefined)), map((res) => (res.data ? this.createRoute(res) : undefined)),
catchError((error: AxiosError) => { catchError((error: AxiosError) => {
if (error.code == AxiosError.ERR_BAD_REQUEST) {
throw new GeographyException( throw new GeographyException(
ExceptionCode.INTERNAL, ExceptionCode.OUT_OF_RANGE,
'No route found for given coordinates',
);
}
throw new GeographyException(
ExceptionCode.UNAVAILABLE,
'Georouter unavailable : ' + error.message, 'Georouter unavailable : ' + error.message,
); );
}), }),

11
src/modules/geography/adapters/secondaries/postgres-direction-encoder.ts Normal file
View File

@ -0,0 +1,11 @@
import { Coordinates } from '../../domain/entities/coordinates';
import { IEncodeDirection } from '../../domain/interfaces/direction-encoder.interface';
export class PostgresDirectionEncoder implements IEncodeDirection {
encode = (coordinates: Coordinates[]): string =>
[
"'LINESTRING(",
coordinates.map((point) => [point.lon, point.lat].join(' ')).join(),
")'",
].join('');
}

5
src/modules/geography/domain/interfaces/direction-encoder.interface.ts Normal file
View File

@ -0,0 +1,5 @@
import { Coordinates } from '../entities/coordinates';
export interface IEncodeDirection {
encode(coordinates: Coordinates[]): string;
}

10
src/modules/geography/exceptions/geography.exception.ts
View File

@ -1,13 +1,11 @@
export class GeographyException implements Error { export class GeographyException implements Error {
name: string; name: string;
code: number;
message: string; message: string;
constructor(private _code: number, private _message: string) { constructor(code: number, message: string) {
this.name = 'GeographyException'; this.name = 'GeographyException';
this.message = _message; this.code = code;
} this.message = message;
get code(): number {
return this._code;
} }
} }