basic ad entity without direction

src/modules/ad/ad.di-tokens.ts

@@ -1,3 +1,4 @@
 export const AD_REPOSITORY = Symbol('AD_REPOSITORY');
 export const GEOROUTER = Symbol('GEOROUTER');
+export const AD_DIRECTION_ENCODER = Symbol('AD_DIRECTION_ENCODER');
 export const AD_MESSAGE_PUBLISHER = Symbol('AD_MESSAGE_PUBLISHER');

src/modules/ad/ad.mapper.ts

@@ -1,5 +1,5 @@
 import { Mapper } from '@mobicoop/ddd-library';
-import { Injectable } from '@nestjs/common';
+import { Inject, Injectable } from '@nestjs/common';
 import { AdEntity } from './core/domain/ad.entity';
 import {
   AdWriteModel,
@@ -9,6 +9,8 @@ import {
 import { Frequency } from './core/domain/ad.types';
 import { v4 } from 'uuid';
 import { ScheduleItemProps } from './core/domain/value-objects/schedule-item.value-object';
+import { DirectionEncoderPort } from '@modules/geography/core/application/ports/direction-encoder.port';
+import { AD_DIRECTION_ENCODER } from './ad.di-tokens';
 
 /**
  * Mapper constructs objects that are used in different layers:
@@ -21,6 +23,11 @@ import { ScheduleItemProps } from './core/domain/value-objects/schedule-item.val
 export class AdMapper
   implements Mapper<AdEntity, AdReadModel, AdWriteModel, undefined>
 {
+  constructor(
+    @Inject(AD_DIRECTION_ENCODER)
+    private readonly directionEncoder: DirectionEncoderPort,
+  ) {}
+
   toPersistence = (entity: AdEntity): AdWriteModel => {
     const copy = entity.getProps();
     const now = new Date();
@@ -54,7 +61,7 @@ export class AdMapper
       driverDistance: copy.driverDistance,
       passengerDuration: copy.passengerDuration,
       passengerDistance: copy.passengerDistance,
-      waypoints: '',
+      waypoints: this.directionEncoder.encode(copy.waypoints),
       direction: '',
       fwdAzimuth: copy.fwdAzimuth,
       backAzimuth: copy.backAzimuth,

src/modules/ad/ad.module.ts

@@ -1,11 +1,16 @@
 import { Module, Provider } from '@nestjs/common';
 import { CqrsModule } from '@nestjs/cqrs';
-import { AD_MESSAGE_PUBLISHER, AD_REPOSITORY } from './ad.di-tokens';
+import {
+  AD_MESSAGE_PUBLISHER,
+  AD_REPOSITORY,
+  AD_DIRECTION_ENCODER,
+} from './ad.di-tokens';
 import { MessageBrokerPublisher } from '@mobicoop/message-broker-module';
 import { AdRepository } from './infrastructure/ad.repository';
 import { PrismaService } from './infrastructure/prisma.service';
 import { AdMapper } from './ad.mapper';
 import { AdCreatedMessageHandler } from './interface/message-handlers/ad-created.message-handler';
+import { PostgresDirectionEncoder } from '@modules/geography/infrastructure/postgres-direction-encoder';
 
 const messageHandlers = [AdCreatedMessageHandler];
 
@@ -24,8 +29,16 @@ const messagePublishers: Provider[] = [
     useExisting: MessageBrokerPublisher,
   },
 ];
+
 const orms: Provider[] = [PrismaService];
 
+const adapters: Provider[] = [
+  {
+    provide: AD_DIRECTION_ENCODER,
+    useClass: PostgresDirectionEncoder,
+  },
+];
+
 @Module({
   imports: [CqrsModule],
   providers: [
@@ -34,7 +47,8 @@ const orms: Provider[] = [PrismaService];
     ...repositories,
     ...messagePublishers,
     ...orms,
+    ...adapters,
   ],
-  exports: [PrismaService, AdMapper, AD_REPOSITORY],
+  exports: [PrismaService, AdMapper, AD_REPOSITORY, AD_DIRECTION_ENCODER],
 })
 export class AdModule {}

src/modules/ad/tests/unit/ad.mapper.spec.ts

@@ -1,3 +1,4 @@
+import { AD_DIRECTION_ENCODER } from '@modules/ad/ad.di-tokens';
 import { AdMapper } from '@modules/ad/ad.mapper';
 import { AdEntity } from '@modules/ad/core/domain/ad.entity';
 import { Frequency } from '@modules/ad/core/domain/ad.types';
@@ -5,6 +6,7 @@ import {
   AdReadModel,
   AdWriteModel,
 } from '@modules/ad/infrastructure/ad.repository';
+import { DirectionEncoderPort } from '@modules/geography/core/application/ports/direction-encoder.port';
 import { Test } from '@nestjs/testing';
 
 const now = new Date('2023-06-21 06:00:00');
@@ -76,12 +78,26 @@ const adReadModel: AdReadModel = {
   updatedAt: now,
 };
 
+const mockDirectionEncoder: DirectionEncoderPort = {
+  encode: jest
+    .fn()
+    .mockImplementation(
+      () => "'LINESTRING(6.1765102 48.689445,2.3522 48.8566)'",
+    ),
+};
+
 describe('Ad Mapper', () => {
   let adMapper: AdMapper;
 
   beforeAll(async () => {
     const module = await Test.createTestingModule({
-      providers: [AdMapper],
+      providers: [
+        AdMapper,
+        {
+          provide: AD_DIRECTION_ENCODER,
+          useValue: mockDirectionEncoder,
+        },
+      ],
     }).compile();
     adMapper = module.get<AdMapper>(AdMapper);
   });
@@ -93,6 +109,9 @@ describe('Ad Mapper', () => {
   it('should map domain entity to persistence data', async () => {
     const mapped: AdWriteModel = adMapper.toPersistence(adEntity);
     expect(mapped.schedule.create.length).toBe(1);
+    expect(mapped.waypoints).toBe(
+      "'LINESTRING(6.1765102 48.689445,2.3522 48.8566)'",
+    );
   });
 
   it('should map persisted data to domain entity', async () => {

src/modules/ad/tests/unit/infrastructure/ad.repository.spec.ts

@@ -1,6 +1,8 @@
+import { AD_DIRECTION_ENCODER } from '@modules/ad/ad.di-tokens';
 import { AdMapper } from '@modules/ad/ad.mapper';
 import { AdRepository } from '@modules/ad/infrastructure/ad.repository';
 import { PrismaService } from '@modules/ad/infrastructure/prisma.service';
+import { DirectionEncoderPort } from '@modules/geography/core/application/ports/direction-encoder.port';
 import { EventEmitter2, EventEmitterModule } from '@nestjs/event-emitter';
 import { Test, TestingModule } from '@nestjs/testing';
 
@@ -8,6 +10,10 @@ const mockMessagePublisher = {
   publish: jest.fn().mockImplementation(),
 };
 
+const mockDirectionEncoder: DirectionEncoderPort = {
+  encode: jest.fn(),
+};
+
 describe('Ad repository', () => {
   let prismaService: PrismaService;
   let adMapper: AdMapper;
@@ -16,7 +22,14 @@ describe('Ad repository', () => {
   beforeAll(async () => {
     const module: TestingModule = await Test.createTestingModule({
       imports: [EventEmitterModule.forRoot()],
-      providers: [PrismaService, AdMapper],
+      providers: [
+        PrismaService,
+        AdMapper,
+        {
+          provide: AD_DIRECTION_ENCODER,
+          useValue: mockDirectionEncoder,
+        },
+      ],
     }).compile();
 
     prismaService = module.get<PrismaService>(PrismaService);