better testing
This commit is contained in:
parent
400b26dcc5
commit
3c54308935
|
@ -4,10 +4,10 @@ import { Geodesic, GeodesicClass } from 'geographiclib-geodesic';
|
||||||
|
|
||||||
@Injectable()
|
@Injectable()
|
||||||
export class MatcherGeodesic implements IGeodesic {
|
export class MatcherGeodesic implements IGeodesic {
|
||||||
_geod: GeodesicClass;
|
private geod: GeodesicClass;
|
||||||
|
|
||||||
constructor() {
|
constructor() {
|
||||||
this._geod = Geodesic.WGS84;
|
this.geod = Geodesic.WGS84;
|
||||||
}
|
}
|
||||||
|
|
||||||
inverse = (
|
inverse = (
|
||||||
|
@ -16,7 +16,7 @@ export class MatcherGeodesic implements IGeodesic {
|
||||||
lon2: number,
|
lon2: number,
|
||||||
lat2: number,
|
lat2: number,
|
||||||
): { azimuth: number; distance: number } => {
|
): { azimuth: number; distance: number } => {
|
||||||
const { azi2: azimuth, s12: distance } = this._geod.Inverse(
|
const { azi2: azimuth, s12: distance } = this.geod.Inverse(
|
||||||
lat1,
|
lat1,
|
||||||
lon1,
|
lon1,
|
||||||
lat2,
|
lat2,
|
||||||
|
|
|
@ -16,77 +16,73 @@ import {
|
||||||
|
|
||||||
@Injectable()
|
@Injectable()
|
||||||
export class GraphhopperGeorouter implements IGeorouter {
|
export class GraphhopperGeorouter implements IGeorouter {
|
||||||
_url: string;
|
private url: string;
|
||||||
_urlArgs: Array<string>;
|
private urlArgs: Array<string>;
|
||||||
_withTime: boolean;
|
private withTime: boolean;
|
||||||
_withPoints: boolean;
|
private withPoints: boolean;
|
||||||
_withDistance: boolean;
|
private withDistance: boolean;
|
||||||
_paths: Array<Path>;
|
private paths: Array<Path>;
|
||||||
_httpService: HttpService;
|
private httpService: HttpService;
|
||||||
_geodesic: IGeodesic;
|
private geodesic: IGeodesic;
|
||||||
|
|
||||||
constructor(url: string, httpService: HttpService, geodesic: IGeodesic) {
|
constructor(url: string, httpService: HttpService, geodesic: IGeodesic) {
|
||||||
this._url = url + '/route?';
|
this.url = url + '/route?';
|
||||||
this._httpService = httpService;
|
this.httpService = httpService;
|
||||||
this._geodesic = geodesic;
|
this.geodesic = geodesic;
|
||||||
}
|
}
|
||||||
|
|
||||||
route = async (
|
route = async (
|
||||||
paths: Array<Path>,
|
paths: Array<Path>,
|
||||||
settings: GeorouterSettings,
|
settings: GeorouterSettings,
|
||||||
): Promise<Array<NamedRoute>> => {
|
): Promise<Array<NamedRoute>> => {
|
||||||
this._setDefaultUrlArgs();
|
this.setDefaultUrlArgs();
|
||||||
this._setWithTime(settings.withTime);
|
this.setWithTime(settings.withTime);
|
||||||
this._setWithPoints(settings.withPoints);
|
this.setWithPoints(settings.withPoints);
|
||||||
this._setWithDistance(settings.withDistance);
|
this.setWithDistance(settings.withDistance);
|
||||||
this._paths = paths;
|
this.paths = paths;
|
||||||
return await this._getRoutes();
|
return await this.getRoutes();
|
||||||
};
|
};
|
||||||
|
|
||||||
_setDefaultUrlArgs = (): void => {
|
private setDefaultUrlArgs = (): void => {
|
||||||
this._urlArgs = [
|
this.urlArgs = ['vehicle=car', 'weighting=fastest', 'points_encoded=false'];
|
||||||
'vehicle=car',
|
|
||||||
'weighting=fastest',
|
|
||||||
'points_encoded=false',
|
|
||||||
];
|
|
||||||
};
|
};
|
||||||
|
|
||||||
_setWithTime = (withTime: boolean): void => {
|
private setWithTime = (withTime: boolean): void => {
|
||||||
this._withTime = withTime;
|
this.withTime = withTime;
|
||||||
if (withTime) {
|
if (withTime) {
|
||||||
this._urlArgs.push('details=time');
|
this.urlArgs.push('details=time');
|
||||||
}
|
}
|
||||||
};
|
};
|
||||||
|
|
||||||
_setWithPoints = (withPoints: boolean): void => {
|
private setWithPoints = (withPoints: boolean): void => {
|
||||||
this._withPoints = withPoints;
|
this.withPoints = withPoints;
|
||||||
if (!withPoints) {
|
if (!withPoints) {
|
||||||
this._urlArgs.push('calc_points=false');
|
this.urlArgs.push('calc_points=false');
|
||||||
}
|
}
|
||||||
};
|
};
|
||||||
|
|
||||||
_setWithDistance = (withDistance: boolean): void => {
|
private setWithDistance = (withDistance: boolean): void => {
|
||||||
this._withDistance = withDistance;
|
this.withDistance = withDistance;
|
||||||
if (withDistance) {
|
if (withDistance) {
|
||||||
this._urlArgs.push('instructions=true');
|
this.urlArgs.push('instructions=true');
|
||||||
} else {
|
} else {
|
||||||
this._urlArgs.push('instructions=false');
|
this.urlArgs.push('instructions=false');
|
||||||
}
|
}
|
||||||
};
|
};
|
||||||
|
|
||||||
_getRoutes = async (): Promise<Array<NamedRoute>> => {
|
private getRoutes = async (): Promise<Array<NamedRoute>> => {
|
||||||
const routes = Promise.all(
|
const routes = Promise.all(
|
||||||
this._paths.map(async (path) => {
|
this.paths.map(async (path) => {
|
||||||
const url: string = [
|
const url: string = [
|
||||||
this._getUrl(),
|
this.getUrl(),
|
||||||
'&point=',
|
'&point=',
|
||||||
path.points
|
path.points
|
||||||
.map((point) => [point.lat, point.lon].join())
|
.map((point) => [point.lat, point.lon].join())
|
||||||
.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) => {
|
||||||
throw new MatcherException(
|
throw new MatcherException(
|
||||||
MatcherExceptionCode.INTERNAL,
|
MatcherExceptionCode.INTERNAL,
|
||||||
|
@ -104,12 +100,14 @@ export class GraphhopperGeorouter implements IGeorouter {
|
||||||
return routes;
|
return routes;
|
||||||
};
|
};
|
||||||
|
|
||||||
_getUrl = (): string => {
|
private getUrl = (): string => {
|
||||||
return [this._url, this._urlArgs.join('&')].join('');
|
return [this.url, this.urlArgs.join('&')].join('');
|
||||||
};
|
};
|
||||||
|
|
||||||
_createRoute = (response: AxiosResponse<GraphhopperResponse>): Route => {
|
private createRoute = (
|
||||||
const route = new Route(this._geodesic);
|
response: AxiosResponse<GraphhopperResponse>,
|
||||||
|
): Route => {
|
||||||
|
const route = new Route(this.geodesic);
|
||||||
if (response.data.paths && response.data.paths[0]) {
|
if (response.data.paths && response.data.paths[0]) {
|
||||||
const shortestPath = response.data.paths[0];
|
const shortestPath = response.data.paths[0];
|
||||||
route.distance = shortestPath.distance ?? 0;
|
route.distance = shortestPath.distance ?? 0;
|
||||||
|
@ -131,7 +129,7 @@ export class GraphhopperGeorouter implements IGeorouter {
|
||||||
if (shortestPath.instructions)
|
if (shortestPath.instructions)
|
||||||
instructions = shortestPath.instructions;
|
instructions = shortestPath.instructions;
|
||||||
route.setSpacetimePoints(
|
route.setSpacetimePoints(
|
||||||
this._generateSpacetimePoints(
|
this.generateSpacetimePoints(
|
||||||
shortestPath.points.coordinates,
|
shortestPath.points.coordinates,
|
||||||
shortestPath.snapped_waypoints.coordinates,
|
shortestPath.snapped_waypoints.coordinates,
|
||||||
shortestPath.details.time,
|
shortestPath.details.time,
|
||||||
|
@ -144,15 +142,15 @@ export class GraphhopperGeorouter implements IGeorouter {
|
||||||
return route;
|
return route;
|
||||||
};
|
};
|
||||||
|
|
||||||
_generateSpacetimePoints = (
|
private generateSpacetimePoints = (
|
||||||
points: Array<Array<number>>,
|
points: Array<Array<number>>,
|
||||||
snappedWaypoints: Array<Array<number>>,
|
snappedWaypoints: Array<Array<number>>,
|
||||||
durations: Array<Array<number>>,
|
durations: Array<Array<number>>,
|
||||||
instructions: Array<GraphhopperInstruction>,
|
instructions: Array<GraphhopperInstruction>,
|
||||||
): Array<SpacetimePoint> => {
|
): Array<SpacetimePoint> => {
|
||||||
const indices = this._getIndices(points, snappedWaypoints);
|
const indices = this.getIndices(points, snappedWaypoints);
|
||||||
const times = this._getTimes(durations, indices);
|
const times = this.getTimes(durations, indices);
|
||||||
const distances = this._getDistances(instructions, indices);
|
const distances = this.getDistances(instructions, indices);
|
||||||
return indices.map(
|
return indices.map(
|
||||||
(index) =>
|
(index) =>
|
||||||
new SpacetimePoint(
|
new SpacetimePoint(
|
||||||
|
@ -163,7 +161,7 @@ export class GraphhopperGeorouter implements IGeorouter {
|
||||||
);
|
);
|
||||||
};
|
};
|
||||||
|
|
||||||
_getIndices = (
|
private getIndices = (
|
||||||
points: Array<Array<number>>,
|
points: Array<Array<number>>,
|
||||||
snappedWaypoints: Array<Array<number>>,
|
snappedWaypoints: Array<Array<number>>,
|
||||||
): Array<number> => {
|
): Array<number> => {
|
||||||
|
@ -195,7 +193,7 @@ export class GraphhopperGeorouter implements IGeorouter {
|
||||||
.filter((element) => element.index == -1);
|
.filter((element) => element.index == -1);
|
||||||
for (const index in points) {
|
for (const index in points) {
|
||||||
for (const missedWaypoint of missedWaypoints) {
|
for (const missedWaypoint of missedWaypoints) {
|
||||||
const inverse = this._geodesic.inverse(
|
const inverse = this.geodesic.inverse(
|
||||||
missedWaypoint.waypoint[0],
|
missedWaypoint.waypoint[0],
|
||||||
missedWaypoint.waypoint[1],
|
missedWaypoint.waypoint[1],
|
||||||
points[index][0],
|
points[index][0],
|
||||||
|
@ -213,7 +211,7 @@ export class GraphhopperGeorouter implements IGeorouter {
|
||||||
return indices;
|
return indices;
|
||||||
};
|
};
|
||||||
|
|
||||||
_getTimes = (
|
private getTimes = (
|
||||||
durations: Array<Array<number>>,
|
durations: Array<Array<number>>,
|
||||||
indices: Array<number>,
|
indices: Array<number>,
|
||||||
): Array<{ index: number; duration: number }> => {
|
): Array<{ index: number; duration: number }> => {
|
||||||
|
@ -263,7 +261,7 @@ export class GraphhopperGeorouter implements IGeorouter {
|
||||||
return times;
|
return times;
|
||||||
};
|
};
|
||||||
|
|
||||||
_getDistances = (
|
private getDistances = (
|
||||||
instructions: Array<GraphhopperInstruction>,
|
instructions: Array<GraphhopperInstruction>,
|
||||||
indices: Array<number>,
|
indices: Array<number>,
|
||||||
): Array<{ index: number; distance: number }> => {
|
): Array<{ index: number; distance: number }> => {
|
||||||
|
|
|
@ -13,7 +13,7 @@ import { AutoMap } from '@automapper/classes';
|
||||||
import { Point } from '../types/point.type';
|
import { Point } from '../types/point.type';
|
||||||
import { Schedule } from '../types/schedule.type';
|
import { Schedule } from '../types/schedule.type';
|
||||||
import { MarginDurations } from '../types/margin-durations.type';
|
import { MarginDurations } from '../types/margin-durations.type';
|
||||||
import { Algorithm } from '../types/algorithm.enum';
|
import { AlgorithmType } from '../types/algorithm.enum';
|
||||||
import { IRequestTime } from '../interfaces/time-request.interface';
|
import { IRequestTime } from '../interfaces/time-request.interface';
|
||||||
import { IRequestPerson } from '../interfaces/person-request.interface';
|
import { IRequestPerson } from '../interfaces/person-request.interface';
|
||||||
import { IRequestGeography } from '../interfaces/geography-request.interface';
|
import { IRequestGeography } from '../interfaces/geography-request.interface';
|
||||||
|
@ -89,9 +89,9 @@ export class MatchRequest
|
||||||
strict: boolean;
|
strict: boolean;
|
||||||
|
|
||||||
@IsOptional()
|
@IsOptional()
|
||||||
@IsEnum(Algorithm)
|
@IsEnum(AlgorithmType)
|
||||||
@AutoMap()
|
@AutoMap()
|
||||||
algorithm: Algorithm;
|
algorithm: AlgorithmType;
|
||||||
|
|
||||||
@IsOptional()
|
@IsOptional()
|
||||||
@IsNumber()
|
@IsNumber()
|
||||||
|
|
|
@ -1,14 +1,14 @@
|
||||||
import { IRequestAlgorithmSettings } from '../../interfaces/algorithm-settings-request.interface';
|
import { IRequestAlgorithmSettings } from '../../interfaces/algorithm-settings-request.interface';
|
||||||
import { DefaultAlgorithmSettings } from '../../types/default-algorithm-settings.type';
|
import { DefaultAlgorithmSettings } from '../../types/default-algorithm-settings.type';
|
||||||
import { Algorithm } from '../../types/algorithm.enum';
|
import { AlgorithmType } from '../../types/algorithm.enum';
|
||||||
import { TimingFrequency } from '../../types/timing';
|
import { TimingFrequency } from '../../types/timing';
|
||||||
import { ICreateGeorouter } from '../../interfaces/georouter-creator.interface';
|
import { ICreateGeorouter } from '../../interfaces/georouter-creator.interface';
|
||||||
import { IGeorouter } from '../../interfaces/georouter.interface';
|
import { IGeorouter } from '../../interfaces/georouter.interface';
|
||||||
|
|
||||||
export class AlgorithmSettings {
|
export class AlgorithmSettings {
|
||||||
_algorithmSettingsRequest: IRequestAlgorithmSettings;
|
private algorithmSettingsRequest: IRequestAlgorithmSettings;
|
||||||
_strict: boolean;
|
private strict: boolean;
|
||||||
algorithm: Algorithm;
|
algorithmType: AlgorithmType;
|
||||||
restrict: TimingFrequency;
|
restrict: TimingFrequency;
|
||||||
remoteness: number;
|
remoteness: number;
|
||||||
useProportion: boolean;
|
useProportion: boolean;
|
||||||
|
@ -25,10 +25,10 @@ export class AlgorithmSettings {
|
||||||
frequency: TimingFrequency,
|
frequency: TimingFrequency,
|
||||||
georouterCreator: ICreateGeorouter,
|
georouterCreator: ICreateGeorouter,
|
||||||
) {
|
) {
|
||||||
this._algorithmSettingsRequest = algorithmSettingsRequest;
|
this.algorithmSettingsRequest = algorithmSettingsRequest;
|
||||||
this.algorithm =
|
this.algorithmType =
|
||||||
algorithmSettingsRequest.algorithm ?? defaultAlgorithmSettings.algorithm;
|
algorithmSettingsRequest.algorithm ?? defaultAlgorithmSettings.algorithm;
|
||||||
this._strict =
|
this.strict =
|
||||||
algorithmSettingsRequest.strict ?? defaultAlgorithmSettings.strict;
|
algorithmSettingsRequest.strict ?? defaultAlgorithmSettings.strict;
|
||||||
this.remoteness = algorithmSettingsRequest.remoteness
|
this.remoteness = algorithmSettingsRequest.remoteness
|
||||||
? Math.abs(algorithmSettingsRequest.remoteness)
|
? Math.abs(algorithmSettingsRequest.remoteness)
|
||||||
|
@ -55,7 +55,7 @@ export class AlgorithmSettings {
|
||||||
defaultAlgorithmSettings.georouterType,
|
defaultAlgorithmSettings.georouterType,
|
||||||
defaultAlgorithmSettings.georouterUrl,
|
defaultAlgorithmSettings.georouterUrl,
|
||||||
);
|
);
|
||||||
if (this._strict) {
|
if (this.strict) {
|
||||||
this.restrict = frequency;
|
this.restrict = frequency;
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
|
@ -16,9 +16,9 @@ import { Step } from '../../types/step.enum';
|
||||||
import { Path } from '../../types/path.type';
|
import { Path } from '../../types/path.type';
|
||||||
|
|
||||||
export class Geography {
|
export class Geography {
|
||||||
_geographyRequest: IRequestGeography;
|
private geographyRequest: IRequestGeography;
|
||||||
_person: Person;
|
private person: Person;
|
||||||
_points: Array<Point>;
|
private points: Array<Point>;
|
||||||
originType: PointType;
|
originType: PointType;
|
||||||
destinationType: PointType;
|
destinationType: PointType;
|
||||||
timezones: Array<string>;
|
timezones: Array<string>;
|
||||||
|
@ -30,18 +30,18 @@ export class Geography {
|
||||||
defaultTimezone: string,
|
defaultTimezone: string,
|
||||||
person: Person,
|
person: Person,
|
||||||
) {
|
) {
|
||||||
this._geographyRequest = geographyRequest;
|
this.geographyRequest = geographyRequest;
|
||||||
this._person = person;
|
this.person = person;
|
||||||
this._points = [];
|
this.points = [];
|
||||||
this.originType = undefined;
|
this.originType = undefined;
|
||||||
this.destinationType = undefined;
|
this.destinationType = undefined;
|
||||||
this.timezones = [defaultTimezone];
|
this.timezones = [defaultTimezone];
|
||||||
}
|
}
|
||||||
|
|
||||||
init = (): void => {
|
init = (): void => {
|
||||||
this._validateWaypoints();
|
this.validateWaypoints();
|
||||||
this._setTimezones();
|
this.setTimezones();
|
||||||
this._setPointTypes();
|
this.setPointTypes();
|
||||||
};
|
};
|
||||||
|
|
||||||
createRoutes = async (
|
createRoutes = async (
|
||||||
|
@ -52,14 +52,14 @@ export class Geography {
|
||||||
let passengerWaypoints: Array<Waypoint> = [];
|
let passengerWaypoints: Array<Waypoint> = [];
|
||||||
const paths: Array<Path> = [];
|
const paths: Array<Path> = [];
|
||||||
if (roles.includes(Role.DRIVER) && roles.includes(Role.PASSENGER)) {
|
if (roles.includes(Role.DRIVER) && roles.includes(Role.PASSENGER)) {
|
||||||
if (this._points.length == 2) {
|
if (this.points.length == 2) {
|
||||||
// 2 points => same route for driver and passenger
|
// 2 points => same route for driver and passenger
|
||||||
const commonPath: Path = {
|
const commonPath: Path = {
|
||||||
key: RouteKey.COMMON,
|
key: RouteKey.COMMON,
|
||||||
points: this._points,
|
points: this.points,
|
||||||
};
|
};
|
||||||
driverWaypoints = this._createWaypoints(commonPath.points, Role.DRIVER);
|
driverWaypoints = this.createWaypoints(commonPath.points, Role.DRIVER);
|
||||||
passengerWaypoints = this._createWaypoints(
|
passengerWaypoints = this.createWaypoints(
|
||||||
commonPath.points,
|
commonPath.points,
|
||||||
Role.PASSENGER,
|
Role.PASSENGER,
|
||||||
);
|
);
|
||||||
|
@ -67,14 +67,14 @@ export class Geography {
|
||||||
} else {
|
} else {
|
||||||
const driverPath: Path = {
|
const driverPath: Path = {
|
||||||
key: RouteKey.DRIVER,
|
key: RouteKey.DRIVER,
|
||||||
points: this._points,
|
points: this.points,
|
||||||
};
|
};
|
||||||
driverWaypoints = this._createWaypoints(driverPath.points, Role.DRIVER);
|
driverWaypoints = this.createWaypoints(driverPath.points, Role.DRIVER);
|
||||||
const passengerPath: Path = {
|
const passengerPath: Path = {
|
||||||
key: RouteKey.PASSENGER,
|
key: RouteKey.PASSENGER,
|
||||||
points: [this._points[0], this._points[this._points.length - 1]],
|
points: [this.points[0], this.points[this.points.length - 1]],
|
||||||
};
|
};
|
||||||
passengerWaypoints = this._createWaypoints(
|
passengerWaypoints = this.createWaypoints(
|
||||||
passengerPath.points,
|
passengerPath.points,
|
||||||
Role.PASSENGER,
|
Role.PASSENGER,
|
||||||
);
|
);
|
||||||
|
@ -83,16 +83,16 @@ export class Geography {
|
||||||
} else if (roles.includes(Role.DRIVER)) {
|
} else if (roles.includes(Role.DRIVER)) {
|
||||||
const driverPath: Path = {
|
const driverPath: Path = {
|
||||||
key: RouteKey.DRIVER,
|
key: RouteKey.DRIVER,
|
||||||
points: this._points,
|
points: this.points,
|
||||||
};
|
};
|
||||||
driverWaypoints = this._createWaypoints(driverPath.points, Role.DRIVER);
|
driverWaypoints = this.createWaypoints(driverPath.points, Role.DRIVER);
|
||||||
paths.push(driverPath);
|
paths.push(driverPath);
|
||||||
} else if (roles.includes(Role.PASSENGER)) {
|
} else if (roles.includes(Role.PASSENGER)) {
|
||||||
const passengerPath: Path = {
|
const passengerPath: Path = {
|
||||||
key: RouteKey.PASSENGER,
|
key: RouteKey.PASSENGER,
|
||||||
points: [this._points[0], this._points[this._points.length - 1]],
|
points: [this.points[0], this.points[this.points.length - 1]],
|
||||||
};
|
};
|
||||||
passengerWaypoints = this._createWaypoints(
|
passengerWaypoints = this.createWaypoints(
|
||||||
passengerPath.points,
|
passengerPath.points,
|
||||||
Role.PASSENGER,
|
Role.PASSENGER,
|
||||||
);
|
);
|
||||||
|
@ -128,58 +128,61 @@ export class Geography {
|
||||||
}
|
}
|
||||||
};
|
};
|
||||||
|
|
||||||
_validateWaypoints = (): void => {
|
private validateWaypoints = (): void => {
|
||||||
if (this._geographyRequest.waypoints.length < 2) {
|
if (this.geographyRequest.waypoints.length < 2) {
|
||||||
throw new MatcherException(
|
throw new MatcherException(
|
||||||
MatcherExceptionCode.INVALID_ARGUMENT,
|
MatcherExceptionCode.INVALID_ARGUMENT,
|
||||||
'At least 2 waypoints are required',
|
'At least 2 waypoints are required',
|
||||||
);
|
);
|
||||||
}
|
}
|
||||||
this._geographyRequest.waypoints.map((point) => {
|
this.geographyRequest.waypoints.map((point) => {
|
||||||
if (!this._isValidPoint(point)) {
|
if (!this.isValidPoint(point)) {
|
||||||
throw new MatcherException(
|
throw new MatcherException(
|
||||||
MatcherExceptionCode.INVALID_ARGUMENT,
|
MatcherExceptionCode.INVALID_ARGUMENT,
|
||||||
`Waypoint { Lon: ${point.lon}, Lat: ${point.lat} } is not valid`,
|
`Waypoint { Lon: ${point.lon}, Lat: ${point.lat} } is not valid`,
|
||||||
);
|
);
|
||||||
}
|
}
|
||||||
this._points.push(point);
|
this.points.push(point);
|
||||||
});
|
});
|
||||||
};
|
};
|
||||||
|
|
||||||
_setTimezones = (): void => {
|
private setTimezones = (): void => {
|
||||||
this.timezones = find(
|
this.timezones = find(
|
||||||
this._geographyRequest.waypoints[0].lat,
|
this.geographyRequest.waypoints[0].lat,
|
||||||
this._geographyRequest.waypoints[0].lon,
|
this.geographyRequest.waypoints[0].lon,
|
||||||
);
|
);
|
||||||
};
|
};
|
||||||
|
|
||||||
_setPointTypes = (): void => {
|
private setPointTypes = (): void => {
|
||||||
this.originType =
|
this.originType =
|
||||||
this._geographyRequest.waypoints[0].type ?? PointType.OTHER;
|
this.geographyRequest.waypoints[0].type ?? PointType.OTHER;
|
||||||
this.destinationType =
|
this.destinationType =
|
||||||
this._geographyRequest.waypoints[
|
this.geographyRequest.waypoints[
|
||||||
this._geographyRequest.waypoints.length - 1
|
this.geographyRequest.waypoints.length - 1
|
||||||
].type ?? PointType.OTHER;
|
].type ?? PointType.OTHER;
|
||||||
};
|
};
|
||||||
|
|
||||||
_isValidPoint = (point: Point): boolean =>
|
private isValidPoint = (point: Point): boolean =>
|
||||||
this._isValidLongitude(point.lon) && this._isValidLatitude(point.lat);
|
this.isValidLongitude(point.lon) && this.isValidLatitude(point.lat);
|
||||||
|
|
||||||
_isValidLongitude = (longitude: number): boolean =>
|
private isValidLongitude = (longitude: number): boolean =>
|
||||||
longitude >= -180 && longitude <= 180;
|
longitude >= -180 && longitude <= 180;
|
||||||
|
|
||||||
_isValidLatitude = (latitude: number): boolean =>
|
private isValidLatitude = (latitude: number): boolean =>
|
||||||
latitude >= -90 && latitude <= 90;
|
latitude >= -90 && latitude <= 90;
|
||||||
|
|
||||||
_createWaypoints = (points: Array<Point>, role: Role): Array<Waypoint> => {
|
private createWaypoints = (
|
||||||
|
points: Array<Point>,
|
||||||
|
role: Role,
|
||||||
|
): Array<Waypoint> => {
|
||||||
return points.map((point, index) => {
|
return points.map((point, index) => {
|
||||||
const waypoint = new Waypoint(point);
|
const waypoint = new Waypoint(point);
|
||||||
if (index == 0) {
|
if (index == 0) {
|
||||||
waypoint.addActor(new Actor(this._person, role, Step.START));
|
waypoint.addActor(new Actor(this.person, role, Step.START));
|
||||||
} else if (index == points.length - 1) {
|
} else if (index == points.length - 1) {
|
||||||
waypoint.addActor(new Actor(this._person, role, Step.FINISH));
|
waypoint.addActor(new Actor(this.person, role, Step.FINISH));
|
||||||
} else {
|
} else {
|
||||||
waypoint.addActor(new Actor(this._person, role, Step.INTERMEDIATE));
|
waypoint.addActor(new Actor(this.person, role, Step.INTERMEDIATE));
|
||||||
}
|
}
|
||||||
return waypoint;
|
return waypoint;
|
||||||
});
|
});
|
||||||
|
|
|
@ -1,9 +1,9 @@
|
||||||
import { IRequestPerson } from '../../interfaces/person-request.interface';
|
import { IRequestPerson } from '../../interfaces/person-request.interface';
|
||||||
|
|
||||||
export class Person {
|
export class Person {
|
||||||
_personRequest: IRequestPerson;
|
private personRequest: IRequestPerson;
|
||||||
_defaultIdentifier: number;
|
private defaultIdentifier: number;
|
||||||
_defaultMarginDuration: number;
|
private defaultMarginDuration: number;
|
||||||
identifier: number;
|
identifier: number;
|
||||||
marginDurations: Array<number>;
|
marginDurations: Array<number>;
|
||||||
|
|
||||||
|
@ -12,23 +12,21 @@ export class Person {
|
||||||
defaultIdentifier: number,
|
defaultIdentifier: number,
|
||||||
defaultMarginDuration: number,
|
defaultMarginDuration: number,
|
||||||
) {
|
) {
|
||||||
this._personRequest = personRequest;
|
this.personRequest = personRequest;
|
||||||
this._defaultIdentifier = defaultIdentifier;
|
this.defaultIdentifier = defaultIdentifier;
|
||||||
this._defaultMarginDuration = defaultMarginDuration;
|
this.defaultMarginDuration = defaultMarginDuration;
|
||||||
}
|
}
|
||||||
|
|
||||||
init = (): void => {
|
init = (): void => {
|
||||||
this.setIdentifier(
|
this.setIdentifier(this.personRequest.identifier ?? this.defaultIdentifier);
|
||||||
this._personRequest.identifier ?? this._defaultIdentifier,
|
|
||||||
);
|
|
||||||
this.setMarginDurations([
|
this.setMarginDurations([
|
||||||
this._defaultMarginDuration,
|
this.defaultMarginDuration,
|
||||||
this._defaultMarginDuration,
|
this.defaultMarginDuration,
|
||||||
this._defaultMarginDuration,
|
this.defaultMarginDuration,
|
||||||
this._defaultMarginDuration,
|
this.defaultMarginDuration,
|
||||||
this._defaultMarginDuration,
|
this.defaultMarginDuration,
|
||||||
this._defaultMarginDuration,
|
this.defaultMarginDuration,
|
||||||
this._defaultMarginDuration,
|
this.defaultMarginDuration,
|
||||||
]);
|
]);
|
||||||
};
|
};
|
||||||
|
|
||||||
|
|
|
@ -1,12 +1,12 @@
|
||||||
import { IRequestRequirement } from '../../interfaces/requirement-request.interface';
|
import { IRequestRequirement } from '../../interfaces/requirement-request.interface';
|
||||||
|
|
||||||
export class Requirement {
|
export class Requirement {
|
||||||
_requirementRequest: IRequestRequirement;
|
private requirementRequest: IRequestRequirement;
|
||||||
seatsDriver: number;
|
seatsDriver: number;
|
||||||
seatsPassenger: number;
|
seatsPassenger: number;
|
||||||
|
|
||||||
constructor(requirementRequest: IRequestRequirement, defaultSeats: number) {
|
constructor(requirementRequest: IRequestRequirement, defaultSeats: number) {
|
||||||
this._requirementRequest = requirementRequest;
|
this.requirementRequest = requirementRequest;
|
||||||
this.seatsDriver = requirementRequest.seatsDriver ?? defaultSeats;
|
this.seatsDriver = requirementRequest.seatsDriver ?? defaultSeats;
|
||||||
this.seatsPassenger = requirementRequest.seatsPassenger ?? 1;
|
this.seatsPassenger = requirementRequest.seatsPassenger ?? 1;
|
||||||
}
|
}
|
||||||
|
|
|
@ -12,7 +12,7 @@ export class Route {
|
||||||
waypoints: Array<Waypoint>;
|
waypoints: Array<Waypoint>;
|
||||||
points: Array<Point>;
|
points: Array<Point>;
|
||||||
spacetimePoints: Array<SpacetimePoint>;
|
spacetimePoints: Array<SpacetimePoint>;
|
||||||
_geodesic: IGeodesic;
|
private geodesic: IGeodesic;
|
||||||
|
|
||||||
constructor(geodesic: IGeodesic) {
|
constructor(geodesic: IGeodesic) {
|
||||||
this.distance = undefined;
|
this.distance = undefined;
|
||||||
|
@ -23,25 +23,25 @@ export class Route {
|
||||||
this.waypoints = [];
|
this.waypoints = [];
|
||||||
this.points = [];
|
this.points = [];
|
||||||
this.spacetimePoints = [];
|
this.spacetimePoints = [];
|
||||||
this._geodesic = geodesic;
|
this.geodesic = geodesic;
|
||||||
}
|
}
|
||||||
|
|
||||||
setWaypoints = (waypoints: Array<Waypoint>): void => {
|
setWaypoints = (waypoints: Array<Waypoint>): void => {
|
||||||
this.waypoints = waypoints;
|
this.waypoints = waypoints;
|
||||||
this._setAzimuth(waypoints.map((waypoint) => waypoint.point));
|
this.setAzimuth(waypoints.map((waypoint) => waypoint.point));
|
||||||
};
|
};
|
||||||
|
|
||||||
setPoints = (points: Array<Point>): void => {
|
setPoints = (points: Array<Point>): void => {
|
||||||
this.points = points;
|
this.points = points;
|
||||||
this._setAzimuth(points);
|
this.setAzimuth(points);
|
||||||
};
|
};
|
||||||
|
|
||||||
setSpacetimePoints = (spacetimePoints: Array<SpacetimePoint>): void => {
|
setSpacetimePoints = (spacetimePoints: Array<SpacetimePoint>): void => {
|
||||||
this.spacetimePoints = spacetimePoints;
|
this.spacetimePoints = spacetimePoints;
|
||||||
};
|
};
|
||||||
|
|
||||||
_setAzimuth = (points: Array<Point>): void => {
|
private setAzimuth = (points: Array<Point>): void => {
|
||||||
const inverse = this._geodesic.inverse(
|
const inverse = this.geodesic.inverse(
|
||||||
points[0].lon,
|
points[0].lon,
|
||||||
points[0].lat,
|
points[0].lat,
|
||||||
points[points.length - 1].lon,
|
points[points.length - 1].lon,
|
||||||
|
|
|
@ -8,9 +8,9 @@ import { TimingDays, TimingFrequency, Days } from '../../types/timing';
|
||||||
import { Schedule } from '../../types/schedule.type';
|
import { Schedule } from '../../types/schedule.type';
|
||||||
|
|
||||||
export class Time {
|
export class Time {
|
||||||
_timeRequest: IRequestTime;
|
private timeRequest: IRequestTime;
|
||||||
_defaultMarginDuration: number;
|
private defaultMarginDuration: number;
|
||||||
_defaultValidityDuration: number;
|
private defaultValidityDuration: number;
|
||||||
frequency: TimingFrequency;
|
frequency: TimingFrequency;
|
||||||
fromDate: Date;
|
fromDate: Date;
|
||||||
toDate: Date;
|
toDate: Date;
|
||||||
|
@ -22,9 +22,9 @@ export class Time {
|
||||||
defaultMarginDuration: number,
|
defaultMarginDuration: number,
|
||||||
defaultValidityDuration: number,
|
defaultValidityDuration: number,
|
||||||
) {
|
) {
|
||||||
this._timeRequest = timeRequest;
|
this.timeRequest = timeRequest;
|
||||||
this._defaultMarginDuration = defaultMarginDuration;
|
this.defaultMarginDuration = defaultMarginDuration;
|
||||||
this._defaultValidityDuration = defaultValidityDuration;
|
this.defaultValidityDuration = defaultValidityDuration;
|
||||||
this.schedule = {};
|
this.schedule = {};
|
||||||
this.marginDurations = {
|
this.marginDurations = {
|
||||||
mon: defaultMarginDuration,
|
mon: defaultMarginDuration,
|
||||||
|
@ -38,16 +38,16 @@ export class Time {
|
||||||
}
|
}
|
||||||
|
|
||||||
init = (): void => {
|
init = (): void => {
|
||||||
this._validateBaseDate();
|
this.validateBaseDate();
|
||||||
this._validatePunctualRequest();
|
this.validatePunctualRequest();
|
||||||
this._validateRecurrentRequest();
|
this.validateRecurrentRequest();
|
||||||
this._setPunctualRequest();
|
this.setPunctualRequest();
|
||||||
this._setRecurrentRequest();
|
this.setRecurrentRequest();
|
||||||
this._setMargindurations();
|
this.setMargindurations();
|
||||||
};
|
};
|
||||||
|
|
||||||
_validateBaseDate = (): void => {
|
private validateBaseDate = (): void => {
|
||||||
if (!this._timeRequest.departure && !this._timeRequest.fromDate) {
|
if (!this.timeRequest.departure && !this.timeRequest.fromDate) {
|
||||||
throw new MatcherException(
|
throw new MatcherException(
|
||||||
MatcherExceptionCode.INVALID_ARGUMENT,
|
MatcherExceptionCode.INVALID_ARGUMENT,
|
||||||
'departure or fromDate is required',
|
'departure or fromDate is required',
|
||||||
|
@ -55,10 +55,10 @@ export class Time {
|
||||||
}
|
}
|
||||||
};
|
};
|
||||||
|
|
||||||
_validatePunctualRequest = (): void => {
|
private validatePunctualRequest = (): void => {
|
||||||
if (this._timeRequest.departure) {
|
if (this.timeRequest.departure) {
|
||||||
this.fromDate = this.toDate = new Date(this._timeRequest.departure);
|
this.fromDate = this.toDate = new Date(this.timeRequest.departure);
|
||||||
if (!this._isDate(this.fromDate)) {
|
if (!this.isDate(this.fromDate)) {
|
||||||
throw new MatcherException(
|
throw new MatcherException(
|
||||||
MatcherExceptionCode.INVALID_ARGUMENT,
|
MatcherExceptionCode.INVALID_ARGUMENT,
|
||||||
'Wrong departure date',
|
'Wrong departure date',
|
||||||
|
@ -67,19 +67,19 @@ export class Time {
|
||||||
}
|
}
|
||||||
};
|
};
|
||||||
|
|
||||||
_validateRecurrentRequest = (): void => {
|
private validateRecurrentRequest = (): void => {
|
||||||
if (this._timeRequest.fromDate) {
|
if (this.timeRequest.fromDate) {
|
||||||
this.fromDate = new Date(this._timeRequest.fromDate);
|
this.fromDate = new Date(this.timeRequest.fromDate);
|
||||||
if (!this._isDate(this.fromDate)) {
|
if (!this.isDate(this.fromDate)) {
|
||||||
throw new MatcherException(
|
throw new MatcherException(
|
||||||
MatcherExceptionCode.INVALID_ARGUMENT,
|
MatcherExceptionCode.INVALID_ARGUMENT,
|
||||||
'Wrong fromDate',
|
'Wrong fromDate',
|
||||||
);
|
);
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
if (this._timeRequest.toDate) {
|
if (this.timeRequest.toDate) {
|
||||||
this.toDate = new Date(this._timeRequest.toDate);
|
this.toDate = new Date(this.timeRequest.toDate);
|
||||||
if (!this._isDate(this.toDate)) {
|
if (!this.isDate(this.toDate)) {
|
||||||
throw new MatcherException(
|
throw new MatcherException(
|
||||||
MatcherExceptionCode.INVALID_ARGUMENT,
|
MatcherExceptionCode.INVALID_ARGUMENT,
|
||||||
'Wrong toDate',
|
'Wrong toDate',
|
||||||
|
@ -92,20 +92,20 @@ export class Time {
|
||||||
);
|
);
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
if (this._timeRequest.fromDate) {
|
if (this.timeRequest.fromDate) {
|
||||||
this._validateSchedule();
|
this.validateSchedule();
|
||||||
}
|
}
|
||||||
};
|
};
|
||||||
|
|
||||||
_validateSchedule = (): void => {
|
private validateSchedule = (): void => {
|
||||||
if (!this._timeRequest.schedule) {
|
if (!this.timeRequest.schedule) {
|
||||||
throw new MatcherException(
|
throw new MatcherException(
|
||||||
MatcherExceptionCode.INVALID_ARGUMENT,
|
MatcherExceptionCode.INVALID_ARGUMENT,
|
||||||
'Schedule is required',
|
'Schedule is required',
|
||||||
);
|
);
|
||||||
}
|
}
|
||||||
if (
|
if (
|
||||||
!Object.keys(this._timeRequest.schedule).some((elem) =>
|
!Object.keys(this.timeRequest.schedule).some((elem) =>
|
||||||
Days.includes(elem),
|
Days.includes(elem),
|
||||||
)
|
)
|
||||||
) {
|
) {
|
||||||
|
@ -114,9 +114,9 @@ export class Time {
|
||||||
'No valid day in the given schedule',
|
'No valid day in the given schedule',
|
||||||
);
|
);
|
||||||
}
|
}
|
||||||
Object.keys(this._timeRequest.schedule).map((day) => {
|
Object.keys(this.timeRequest.schedule).map((day) => {
|
||||||
const time = new Date('1970-01-01 ' + this._timeRequest.schedule[day]);
|
const time = new Date('1970-01-01 ' + this.timeRequest.schedule[day]);
|
||||||
if (!this._isDate(time)) {
|
if (!this.isDate(time)) {
|
||||||
throw new MatcherException(
|
throw new MatcherException(
|
||||||
MatcherExceptionCode.INVALID_ARGUMENT,
|
MatcherExceptionCode.INVALID_ARGUMENT,
|
||||||
`Wrong time for ${day} in schedule`,
|
`Wrong time for ${day} in schedule`,
|
||||||
|
@ -125,36 +125,33 @@ export class Time {
|
||||||
});
|
});
|
||||||
};
|
};
|
||||||
|
|
||||||
_setPunctualRequest = (): void => {
|
private setPunctualRequest = (): void => {
|
||||||
if (this._timeRequest.departure) {
|
if (this.timeRequest.departure) {
|
||||||
this.frequency = TimingFrequency.FREQUENCY_PUNCTUAL;
|
this.frequency = TimingFrequency.FREQUENCY_PUNCTUAL;
|
||||||
this.schedule[TimingDays[this.fromDate.getDay()]] =
|
this.schedule[TimingDays[this.fromDate.getDay()]] =
|
||||||
this.fromDate.getHours() + ':' + this.fromDate.getMinutes();
|
this.fromDate.getHours() + ':' + this.fromDate.getMinutes();
|
||||||
}
|
}
|
||||||
};
|
};
|
||||||
|
|
||||||
_setRecurrentRequest = (): void => {
|
private setRecurrentRequest = (): void => {
|
||||||
if (this._timeRequest.fromDate) {
|
if (this.timeRequest.fromDate) {
|
||||||
this.frequency = TimingFrequency.FREQUENCY_RECURRENT;
|
this.frequency = TimingFrequency.FREQUENCY_RECURRENT;
|
||||||
if (!this.toDate) {
|
if (!this.toDate) {
|
||||||
this.toDate = this._addDays(
|
this.toDate = this.addDays(this.fromDate, this.defaultValidityDuration);
|
||||||
this.fromDate,
|
|
||||||
this._defaultValidityDuration,
|
|
||||||
);
|
|
||||||
}
|
}
|
||||||
this._setSchedule();
|
this.setSchedule();
|
||||||
}
|
}
|
||||||
};
|
};
|
||||||
|
|
||||||
_setSchedule = (): void => {
|
private setSchedule = (): void => {
|
||||||
Object.keys(this._timeRequest.schedule).map((day) => {
|
Object.keys(this.timeRequest.schedule).map((day) => {
|
||||||
this.schedule[day] = this._timeRequest.schedule[day];
|
this.schedule[day] = this.timeRequest.schedule[day];
|
||||||
});
|
});
|
||||||
};
|
};
|
||||||
|
|
||||||
_setMargindurations = (): void => {
|
private setMargindurations = (): void => {
|
||||||
if (this._timeRequest.marginDuration) {
|
if (this.timeRequest.marginDuration) {
|
||||||
const duration = Math.abs(this._timeRequest.marginDuration);
|
const duration = Math.abs(this.timeRequest.marginDuration);
|
||||||
this.marginDurations = {
|
this.marginDurations = {
|
||||||
mon: duration,
|
mon: duration,
|
||||||
tue: duration,
|
tue: duration,
|
||||||
|
@ -165,9 +162,9 @@ export class Time {
|
||||||
sun: duration,
|
sun: duration,
|
||||||
};
|
};
|
||||||
}
|
}
|
||||||
if (this._timeRequest.marginDurations) {
|
if (this.timeRequest.marginDurations) {
|
||||||
if (
|
if (
|
||||||
!Object.keys(this._timeRequest.marginDurations).some((elem) =>
|
!Object.keys(this.timeRequest.marginDurations).some((elem) =>
|
||||||
Days.includes(elem),
|
Days.includes(elem),
|
||||||
)
|
)
|
||||||
) {
|
) {
|
||||||
|
@ -176,19 +173,19 @@ export class Time {
|
||||||
'No valid day in the given margin durations',
|
'No valid day in the given margin durations',
|
||||||
);
|
);
|
||||||
}
|
}
|
||||||
Object.keys(this._timeRequest.marginDurations).map((day) => {
|
Object.keys(this.timeRequest.marginDurations).map((day) => {
|
||||||
this.marginDurations[day] = Math.abs(
|
this.marginDurations[day] = Math.abs(
|
||||||
this._timeRequest.marginDurations[day],
|
this.timeRequest.marginDurations[day],
|
||||||
);
|
);
|
||||||
});
|
});
|
||||||
}
|
}
|
||||||
};
|
};
|
||||||
|
|
||||||
_isDate = (date: Date): boolean => {
|
private isDate = (date: Date): boolean => {
|
||||||
return date instanceof Date && isFinite(+date);
|
return date instanceof Date && isFinite(+date);
|
||||||
};
|
};
|
||||||
|
|
||||||
_addDays = (date: Date, days: number): Date => {
|
private addDays = (date: Date, days: number): Date => {
|
||||||
const result = new Date(date);
|
const result = new Date(date);
|
||||||
result.setDate(result.getDate() + days);
|
result.setDate(result.getDate() + days);
|
||||||
return result;
|
return result;
|
||||||
|
|
|
@ -0,0 +1,18 @@
|
||||||
|
import { MatchQuery } from 'src/modules/matcher/queries/match.query';
|
||||||
|
import { AlgorithmType } from '../../../types/algorithm.enum';
|
||||||
|
import { AlgorithmFactory } from './algorithm-factory.abstract';
|
||||||
|
import { ClassicAlgorithmFactory } from './classic';
|
||||||
|
import { Injectable } from '@nestjs/common';
|
||||||
|
|
||||||
|
@Injectable()
|
||||||
|
export class AlgorithmFactoryCreator {
|
||||||
|
create = (matchQuery: MatchQuery): AlgorithmFactory => {
|
||||||
|
let algorithm: AlgorithmFactory;
|
||||||
|
switch (matchQuery.algorithmSettings.algorithmType) {
|
||||||
|
case AlgorithmType.CLASSIC:
|
||||||
|
algorithm = new ClassicAlgorithmFactory(matchQuery);
|
||||||
|
break;
|
||||||
|
}
|
||||||
|
return algorithm;
|
||||||
|
};
|
||||||
|
}
|
|
@ -4,12 +4,12 @@ import { Candidate } from '../candidate';
|
||||||
import { Selector } from '../selector/selector.abstract';
|
import { Selector } from '../selector/selector.abstract';
|
||||||
|
|
||||||
export abstract class AlgorithmFactory {
|
export abstract class AlgorithmFactory {
|
||||||
_matchQuery: MatchQuery;
|
protected matchQuery: MatchQuery;
|
||||||
_candidates: Array<Candidate>;
|
private candidates: Array<Candidate>;
|
||||||
|
|
||||||
constructor(matchQuery: MatchQuery) {
|
constructor(matchQuery: MatchQuery) {
|
||||||
this._matchQuery = matchQuery;
|
this.matchQuery = matchQuery;
|
||||||
this._candidates = [];
|
this.candidates = [];
|
||||||
}
|
}
|
||||||
|
|
||||||
abstract createSelector(): Selector;
|
abstract createSelector(): Selector;
|
||||||
|
|
|
@ -9,13 +9,13 @@ import { Selector } from '../selector/selector.abstract';
|
||||||
import { ClassicSelector } from '../selector/classic.selector';
|
import { ClassicSelector } from '../selector/classic.selector';
|
||||||
|
|
||||||
export class ClassicAlgorithmFactory extends AlgorithmFactory {
|
export class ClassicAlgorithmFactory extends AlgorithmFactory {
|
||||||
createSelector = (): Selector => new ClassicSelector(this._matchQuery);
|
createSelector = (): Selector => new ClassicSelector(this.matchQuery);
|
||||||
createProcessors = (): Array<Processor> => [
|
createProcessors = (): Array<Processor> => [
|
||||||
new ClassicWaypointsCompleter(this._matchQuery),
|
new ClassicWaypointsCompleter(this.matchQuery),
|
||||||
new RouteCompleter(this._matchQuery, true, true, true),
|
new RouteCompleter(this.matchQuery, true, true, true),
|
||||||
new ClassicGeoFilter(this._matchQuery),
|
new ClassicGeoFilter(this.matchQuery),
|
||||||
new RouteCompleter(this._matchQuery),
|
new RouteCompleter(this.matchQuery),
|
||||||
new JourneyCompleter(this._matchQuery),
|
new JourneyCompleter(this.matchQuery),
|
||||||
new ClassicTimeFilter(this._matchQuery),
|
new ClassicTimeFilter(this.matchQuery),
|
||||||
];
|
];
|
||||||
}
|
}
|
||||||
|
|
|
@ -1,24 +1,23 @@
|
||||||
import { Injectable } from '@nestjs/common';
|
import { Injectable } from '@nestjs/common';
|
||||||
import { MatchQuery } from '../../../queries/match.query';
|
import { MatchQuery } from '../../../queries/match.query';
|
||||||
import { Algorithm } from '../../types/algorithm.enum';
|
|
||||||
import { Match } from '../ecosystem/match';
|
import { Match } from '../ecosystem/match';
|
||||||
import { Candidate } from './candidate';
|
import { Candidate } from './candidate';
|
||||||
import { AlgorithmFactory } from './factory/algorithm-factory.abstract';
|
import { AlgorithmFactory } from './factory/algorithm-factory.abstract';
|
||||||
import { ClassicAlgorithmFactory } from './factory/classic';
|
import { AlgorithmFactoryCreator } from './factory/algorithm-factory-creator';
|
||||||
|
|
||||||
@Injectable()
|
@Injectable()
|
||||||
export class Matcher {
|
export class Matcher {
|
||||||
|
constructor(
|
||||||
|
private readonly algorithmFactoryCreator: AlgorithmFactoryCreator,
|
||||||
|
) {}
|
||||||
|
|
||||||
match = async (matchQuery: MatchQuery): Promise<Array<Match>> => {
|
match = async (matchQuery: MatchQuery): Promise<Array<Match>> => {
|
||||||
let algorithm: AlgorithmFactory;
|
const algorithmFactory: AlgorithmFactory =
|
||||||
switch (matchQuery.algorithmSettings.algorithm) {
|
this.algorithmFactoryCreator.create(matchQuery);
|
||||||
case Algorithm.CLASSIC:
|
let candidates: Array<Candidate> = await algorithmFactory
|
||||||
algorithm = new ClassicAlgorithmFactory(matchQuery);
|
|
||||||
break;
|
|
||||||
}
|
|
||||||
let candidates: Array<Candidate> = await algorithm
|
|
||||||
.createSelector()
|
.createSelector()
|
||||||
.select();
|
.select();
|
||||||
for (const processor of algorithm.createProcessors()) {
|
for (const processor of algorithmFactory.createProcessors()) {
|
||||||
candidates = processor.execute(candidates);
|
candidates = processor.execute(candidates);
|
||||||
}
|
}
|
||||||
const match = new Match();
|
const match = new Match();
|
||||||
|
|
|
@ -3,9 +3,9 @@ import { Candidate } from '../../candidate';
|
||||||
import { Completer } from './completer.abstract';
|
import { Completer } from './completer.abstract';
|
||||||
|
|
||||||
export class RouteCompleter extends Completer {
|
export class RouteCompleter extends Completer {
|
||||||
_withPoints: boolean;
|
private withPoints: boolean;
|
||||||
_withTime: boolean;
|
private withTime: boolean;
|
||||||
_withDistance: boolean;
|
private withDistance: boolean;
|
||||||
|
|
||||||
constructor(
|
constructor(
|
||||||
matchQuery: MatchQuery,
|
matchQuery: MatchQuery,
|
||||||
|
@ -14,9 +14,9 @@ export class RouteCompleter extends Completer {
|
||||||
withDistance = false,
|
withDistance = false,
|
||||||
) {
|
) {
|
||||||
super(matchQuery);
|
super(matchQuery);
|
||||||
this._withPoints = withPoints;
|
this.withPoints = withPoints;
|
||||||
this._withTime = withTime;
|
this.withTime = withTime;
|
||||||
this._withDistance = withDistance;
|
this.withDistance = withDistance;
|
||||||
}
|
}
|
||||||
|
|
||||||
// eslint-disable-next-line @typescript-eslint/no-unused-vars
|
// eslint-disable-next-line @typescript-eslint/no-unused-vars
|
||||||
|
|
|
@ -2,10 +2,10 @@ import { MatchQuery } from 'src/modules/matcher/queries/match.query';
|
||||||
import { Candidate } from '../candidate';
|
import { Candidate } from '../candidate';
|
||||||
|
|
||||||
export abstract class Processor {
|
export abstract class Processor {
|
||||||
_matchQuery: MatchQuery;
|
private matchQuery: MatchQuery;
|
||||||
|
|
||||||
constructor(matchQuery: MatchQuery) {
|
constructor(matchQuery: MatchQuery) {
|
||||||
this._matchQuery = matchQuery;
|
this.matchQuery = matchQuery;
|
||||||
}
|
}
|
||||||
|
|
||||||
abstract execute(candidates: Array<Candidate>): Array<Candidate>;
|
abstract execute(candidates: Array<Candidate>): Array<Candidate>;
|
||||||
|
|
|
@ -2,10 +2,10 @@ import { MatchQuery } from 'src/modules/matcher/queries/match.query';
|
||||||
import { Candidate } from '../candidate';
|
import { Candidate } from '../candidate';
|
||||||
|
|
||||||
export abstract class Selector {
|
export abstract class Selector {
|
||||||
_matchQuery: MatchQuery;
|
private matchQuery: MatchQuery;
|
||||||
|
|
||||||
constructor(matchQuery: MatchQuery) {
|
constructor(matchQuery: MatchQuery) {
|
||||||
this._matchQuery = matchQuery;
|
this.matchQuery = matchQuery;
|
||||||
}
|
}
|
||||||
|
|
||||||
abstract select(): Promise<Array<Candidate>>;
|
abstract select(): Promise<Array<Candidate>>;
|
||||||
|
|
|
@ -1,7 +1,7 @@
|
||||||
import { Algorithm } from '../types/algorithm.enum';
|
import { AlgorithmType } from '../types/algorithm.enum';
|
||||||
|
|
||||||
export interface IRequestAlgorithmSettings {
|
export interface IRequestAlgorithmSettings {
|
||||||
algorithm: Algorithm;
|
algorithm: AlgorithmType;
|
||||||
strict: boolean;
|
strict: boolean;
|
||||||
remoteness: number;
|
remoteness: number;
|
||||||
useProportion: boolean;
|
useProportion: boolean;
|
||||||
|
|
|
@ -1,3 +1,3 @@
|
||||||
export enum Algorithm {
|
export enum AlgorithmType {
|
||||||
CLASSIC = 'CLASSIC',
|
CLASSIC = 'CLASSIC',
|
||||||
}
|
}
|
||||||
|
|
|
@ -1,7 +1,7 @@
|
||||||
import { Algorithm } from './algorithm.enum';
|
import { AlgorithmType } from './algorithm.enum';
|
||||||
|
|
||||||
export type DefaultAlgorithmSettings = {
|
export type DefaultAlgorithmSettings = {
|
||||||
algorithm: Algorithm;
|
algorithm: AlgorithmType;
|
||||||
strict: boolean;
|
strict: boolean;
|
||||||
remoteness: number;
|
remoteness: number;
|
||||||
useProportion: boolean;
|
useProportion: boolean;
|
||||||
|
|
|
@ -16,6 +16,7 @@ import { GeorouterCreator } from './adapters/secondaries/georouter-creator';
|
||||||
import { HttpModule } from '@nestjs/axios';
|
import { HttpModule } from '@nestjs/axios';
|
||||||
import { MatcherGeodesic } from './adapters/secondaries/geodesic';
|
import { MatcherGeodesic } from './adapters/secondaries/geodesic';
|
||||||
import { Matcher } from './domain/entities/engine/matcher';
|
import { Matcher } from './domain/entities/engine/matcher';
|
||||||
|
import { AlgorithmFactoryCreator } from './domain/entities/engine/factory/algorithm-factory-creator';
|
||||||
|
|
||||||
@Module({
|
@Module({
|
||||||
imports: [
|
imports: [
|
||||||
|
@ -59,6 +60,7 @@ import { Matcher } from './domain/entities/engine/matcher';
|
||||||
GeorouterCreator,
|
GeorouterCreator,
|
||||||
MatcherGeodesic,
|
MatcherGeodesic,
|
||||||
Matcher,
|
Matcher,
|
||||||
|
AlgorithmFactoryCreator,
|
||||||
],
|
],
|
||||||
exports: [],
|
exports: [],
|
||||||
})
|
})
|
||||||
|
|
|
@ -107,7 +107,6 @@ describe('Geography entity', () => {
|
||||||
person,
|
person,
|
||||||
);
|
);
|
||||||
geography.init();
|
geography.init();
|
||||||
expect(geography._points.length).toBe(2);
|
|
||||||
expect(geography.originType).toBe(PointType.LOCALITY);
|
expect(geography.originType).toBe(PointType.LOCALITY);
|
||||||
expect(geography.destinationType).toBe(PointType.LOCALITY);
|
expect(geography.destinationType).toBe(PointType.LOCALITY);
|
||||||
});
|
});
|
||||||
|
|
|
@ -1,9 +1,22 @@
|
||||||
import { Algorithm } from '../../../../domain/types/algorithm.enum';
|
import { AlgorithmType } from '../../../../domain/types/algorithm.enum';
|
||||||
import { IDefaultParams } from '../../../../domain/types/default-params.type';
|
import { IDefaultParams } from '../../../../domain/types/default-params.type';
|
||||||
import { MatchRequest } from '../../../../domain/dtos/match.request';
|
import { MatchRequest } from '../../../../domain/dtos/match.request';
|
||||||
import { MatchQuery } from '../../../../queries/match.query';
|
import { MatchQuery } from '../../../../queries/match.query';
|
||||||
import { Matcher } from '../../../../domain/entities/engine/matcher';
|
import { Matcher } from '../../../../domain/entities/engine/matcher';
|
||||||
|
|
||||||
|
const mockAlgorithmFactoryCreator = {
|
||||||
|
create: jest.fn().mockReturnValue({
|
||||||
|
createSelector: jest.fn().mockReturnValue({
|
||||||
|
select: jest.fn(),
|
||||||
|
}),
|
||||||
|
createProcessors: jest.fn().mockReturnValue([
|
||||||
|
{
|
||||||
|
execute: jest.fn(),
|
||||||
|
},
|
||||||
|
]),
|
||||||
|
}),
|
||||||
|
};
|
||||||
|
|
||||||
const mockGeorouterCreator = {
|
const mockGeorouterCreator = {
|
||||||
create: jest.fn().mockImplementation(),
|
create: jest.fn().mockImplementation(),
|
||||||
};
|
};
|
||||||
|
@ -15,7 +28,7 @@ const defaultParams: IDefaultParams = {
|
||||||
DEFAULT_TIMEZONE: 'Europe/Paris',
|
DEFAULT_TIMEZONE: 'Europe/Paris',
|
||||||
DEFAULT_SEATS: 3,
|
DEFAULT_SEATS: 3,
|
||||||
DEFAULT_ALGORITHM_SETTINGS: {
|
DEFAULT_ALGORITHM_SETTINGS: {
|
||||||
algorithm: Algorithm.CLASSIC,
|
algorithm: AlgorithmType.CLASSIC,
|
||||||
strict: false,
|
strict: false,
|
||||||
remoteness: 15000,
|
remoteness: 15000,
|
||||||
useProportion: true,
|
useProportion: true,
|
||||||
|
@ -49,11 +62,11 @@ const matchQuery: MatchQuery = new MatchQuery(
|
||||||
|
|
||||||
describe('Matcher', () => {
|
describe('Matcher', () => {
|
||||||
it('should be defined', () => {
|
it('should be defined', () => {
|
||||||
expect(new Matcher()).toBeDefined();
|
expect(new Matcher(mockAlgorithmFactoryCreator)).toBeDefined();
|
||||||
});
|
});
|
||||||
|
|
||||||
it('should return matches', async () => {
|
it('should return matches', async () => {
|
||||||
const matcher = new Matcher();
|
const matcher = new Matcher(mockAlgorithmFactoryCreator);
|
||||||
const matches = await matcher.match(matchQuery);
|
const matches = await matcher.match(matchQuery);
|
||||||
expect(matches.length).toBe(1);
|
expect(matches.length).toBe(1);
|
||||||
});
|
});
|
||||||
|
|
|
@ -6,7 +6,7 @@ import { MatchQuery } from '../../../queries/match.query';
|
||||||
import { AutomapperModule } from '@automapper/nestjs';
|
import { AutomapperModule } from '@automapper/nestjs';
|
||||||
import { classes } from '@automapper/classes';
|
import { classes } from '@automapper/classes';
|
||||||
import { IDefaultParams } from '../../../domain/types/default-params.type';
|
import { IDefaultParams } from '../../../domain/types/default-params.type';
|
||||||
import { Algorithm } from '../../../domain/types/algorithm.enum';
|
import { AlgorithmType } from '../../../domain/types/algorithm.enum';
|
||||||
import { Matcher } from '../../../domain/entities/engine/matcher';
|
import { Matcher } from '../../../domain/entities/engine/matcher';
|
||||||
import { Match } from '../../../domain/entities/ecosystem/match';
|
import { Match } from '../../../domain/entities/ecosystem/match';
|
||||||
import {
|
import {
|
||||||
|
@ -41,7 +41,7 @@ const defaultParams: IDefaultParams = {
|
||||||
DEFAULT_TIMEZONE: 'Europe/Paris',
|
DEFAULT_TIMEZONE: 'Europe/Paris',
|
||||||
DEFAULT_SEATS: 3,
|
DEFAULT_SEATS: 3,
|
||||||
DEFAULT_ALGORITHM_SETTINGS: {
|
DEFAULT_ALGORITHM_SETTINGS: {
|
||||||
algorithm: Algorithm.CLASSIC,
|
algorithm: AlgorithmType.CLASSIC,
|
||||||
strict: false,
|
strict: false,
|
||||||
remoteness: 15000,
|
remoteness: 15000,
|
||||||
useProportion: true,
|
useProportion: true,
|
||||||
|
|
|
@ -3,7 +3,7 @@ import { Role } from '../../../domain/types/role.enum';
|
||||||
import { TimingFrequency } from '../../../domain/types/timing';
|
import { TimingFrequency } from '../../../domain/types/timing';
|
||||||
import { IDefaultParams } from '../../../domain/types/default-params.type';
|
import { IDefaultParams } from '../../../domain/types/default-params.type';
|
||||||
import { MatchQuery } from '../../../queries/match.query';
|
import { MatchQuery } from '../../../queries/match.query';
|
||||||
import { Algorithm } from '../../../domain/types/algorithm.enum';
|
import { AlgorithmType } from '../../../domain/types/algorithm.enum';
|
||||||
|
|
||||||
const defaultParams: IDefaultParams = {
|
const defaultParams: IDefaultParams = {
|
||||||
DEFAULT_IDENTIFIER: 0,
|
DEFAULT_IDENTIFIER: 0,
|
||||||
|
@ -12,7 +12,7 @@ const defaultParams: IDefaultParams = {
|
||||||
DEFAULT_TIMEZONE: 'Europe/Paris',
|
DEFAULT_TIMEZONE: 'Europe/Paris',
|
||||||
DEFAULT_SEATS: 3,
|
DEFAULT_SEATS: 3,
|
||||||
DEFAULT_ALGORITHM_SETTINGS: {
|
DEFAULT_ALGORITHM_SETTINGS: {
|
||||||
algorithm: Algorithm.CLASSIC,
|
algorithm: AlgorithmType.CLASSIC,
|
||||||
strict: false,
|
strict: false,
|
||||||
remoteness: 15000,
|
remoteness: 15000,
|
||||||
useProportion: true,
|
useProportion: true,
|
||||||
|
@ -181,7 +181,7 @@ describe('Match query', () => {
|
||||||
lon: 3.045432,
|
lon: 3.045432,
|
||||||
},
|
},
|
||||||
];
|
];
|
||||||
matchRequest.algorithm = Algorithm.CLASSIC;
|
matchRequest.algorithm = AlgorithmType.CLASSIC;
|
||||||
matchRequest.strict = true;
|
matchRequest.strict = true;
|
||||||
matchRequest.useProportion = true;
|
matchRequest.useProportion = true;
|
||||||
matchRequest.proportion = 0.45;
|
matchRequest.proportion = 0.45;
|
||||||
|
@ -195,7 +195,9 @@ describe('Match query', () => {
|
||||||
defaultParams,
|
defaultParams,
|
||||||
mockGeorouterCreator,
|
mockGeorouterCreator,
|
||||||
);
|
);
|
||||||
expect(matchQuery.algorithmSettings.algorithm).toBe(Algorithm.CLASSIC);
|
expect(matchQuery.algorithmSettings.algorithmType).toBe(
|
||||||
|
AlgorithmType.CLASSIC,
|
||||||
|
);
|
||||||
expect(matchQuery.algorithmSettings.restrict).toBe(
|
expect(matchQuery.algorithmSettings.restrict).toBe(
|
||||||
TimingFrequency.FREQUENCY_PUNCTUAL,
|
TimingFrequency.FREQUENCY_PUNCTUAL,
|
||||||
);
|
);
|
||||||
|
|
Loading…
Reference in New Issue