-
Notifications
You must be signed in to change notification settings - Fork 0
Commit
This commit does not belong to any branch on this repository, and may belong to a fork outside of the repository.
- Loading branch information
pasqualino.cristaudo
committed
Oct 16, 2023
1 parent
ce772f6
commit efbb1ed
Showing
3 changed files
with
224 additions
and
0 deletions.
There are no files selected for viewing
14 changes: 14 additions & 0 deletions
14
src/test/java/it/pagopa/interop/signalhub/persister/exception/PdndGenericExceptionTest.java
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
Original file line number | Diff line number | Diff line change |
---|---|---|
@@ -0,0 +1,14 @@ | ||
package it.pagopa.interop.signalhub.persister.exception; | ||
|
||
import org.junit.jupiter.api.Test; | ||
|
||
import static org.junit.jupiter.api.Assertions.assertDoesNotThrow; | ||
|
||
class PdndGenericExceptionTest { | ||
|
||
@Test | ||
void exceptionTest() { | ||
assertDoesNotThrow(() -> new PdndGenericException(ExceptionTypeEnum.MAPPER_ERROR, ExceptionTypeEnum.MAPPER_ERROR.getMessage())); | ||
assertDoesNotThrow(() -> new PdndGenericException(ExceptionTypeEnum.DUPLICATE_SIGNAL_ERROR, ExceptionTypeEnum.DUPLICATE_SIGNAL_ERROR.getMessage())); | ||
} | ||
} |
102 changes: 102 additions & 0 deletions
102
src/test/java/it/pagopa/interop/signalhub/persister/mapper/DeadSignalMapperTest.java
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
Original file line number | Diff line number | Diff line change |
---|---|---|
@@ -0,0 +1,102 @@ | ||
package it.pagopa.interop.signalhub.persister.mapper; | ||
|
||
import it.pagopa.interop.signalhub.persister.entity.DeadSignal; | ||
import it.pagopa.interop.signalhub.persister.entity.Signal; | ||
import it.pagopa.interop.signalhub.persister.queue.model.SignalType; | ||
import org.junit.jupiter.api.Test; | ||
import org.mapstruct.factory.Mappers; | ||
import static org.junit.jupiter.api.Assertions.*; | ||
|
||
|
||
class DeadSignalMapperTest { | ||
private final DeadSignalMapper deadSignalMapper = Mappers.getMapper(DeadSignalMapper.class); | ||
private final Long signalId = 0L; | ||
private final String objectId = "OBJ1"; | ||
private final String correlationId = "0A"; | ||
private final String eserviceId = "OBJ1"; | ||
private final String objectType = "0E"; | ||
private final Long indexSignal = 0L; | ||
private final String errorReason = "404 Not Found"; | ||
private final String signalType = SignalType.CREATE.toString(); | ||
|
||
|
||
|
||
@Test | ||
void signalToDeadSignalTest() { | ||
Signal signal = getSignal(); | ||
DeadSignal deadSignal = deadSignalMapper.signalToDeadSignal(signal); | ||
assertNotNull(deadSignal); | ||
assertEquals(deadSignal.getSignalId(), this.indexSignal); | ||
assertEquals(deadSignal.getObjectId(), this.objectId); | ||
assertEquals(deadSignal.getEserviceId(), this.eserviceId); | ||
assertEquals(deadSignal.getCorrelationId(), this.correlationId); | ||
assertEquals(deadSignal.getSignalType(), this.signalType); | ||
assertEquals(deadSignal.getObjectType(), this.objectType); | ||
} | ||
|
||
@Test | ||
void signalToDeadSignalNullCaseTest() { | ||
DeadSignal deadSignal = deadSignalMapper.signalToDeadSignal(null); | ||
assertNull(deadSignal); | ||
} | ||
|
||
@Test | ||
void signalToDeadSignalWithSignalTypeNullTest() { | ||
Signal signal = getSignal(); | ||
signal.setSignalType(null); | ||
DeadSignal deadSignal = deadSignalMapper.signalToDeadSignal(signal); | ||
assertNotNull(deadSignal); | ||
assertNull(deadSignal.getSignalType()); | ||
} | ||
|
||
@Test | ||
void deadSignalToSignalTest() { | ||
DeadSignal deadSignal = getDeadSignal(); | ||
Signal signal = deadSignalMapper.deadSignalToSignal(deadSignal); | ||
assertNotNull(signal); | ||
assertEquals(signal.getSignalId(), this.indexSignal); | ||
assertEquals(signal.getObjectId(), this.objectId); | ||
assertEquals(signal.getEserviceId(), this.eserviceId); | ||
assertEquals(signal.getCorrelationId(), this.correlationId); | ||
assertEquals(signal.getSignalType(), this.signalType); | ||
assertEquals(signal.getObjectType(), this.objectType); | ||
} | ||
|
||
@Test | ||
void deadSignalToSignalNullCaseTest() { | ||
Signal signal = deadSignalMapper.deadSignalToSignal(null); | ||
assertNull(signal); | ||
} | ||
|
||
@Test | ||
void deadSignalToSignalWithSignalTypeNullTest() { | ||
DeadSignal deadSignal = getDeadSignal(); | ||
deadSignal.setSignalType(null); | ||
Signal signal = deadSignalMapper.deadSignalToSignal(deadSignal); | ||
assertNotNull(signal); | ||
assertNull(signal.getSignalType()); | ||
} | ||
|
||
private Signal getSignal() { | ||
Signal signal = new Signal(); | ||
signal.setSignalId(this.signalId); | ||
signal.setSignalType(this.signalType); | ||
signal.setObjectType(this.objectType); | ||
signal.setCorrelationId(this.correlationId); | ||
signal.setEserviceId(this.eserviceId); | ||
signal.setObjectId(this.objectId); | ||
return signal; | ||
} | ||
|
||
private DeadSignal getDeadSignal() { | ||
DeadSignal deadSignal = new DeadSignal(); | ||
deadSignal.setSignalType(this.signalType); | ||
deadSignal.setObjectType(this.objectType); | ||
deadSignal.setEserviceId(this.eserviceId); | ||
deadSignal.setObjectId(this.objectId); | ||
deadSignal.setCorrelationId(this.correlationId); | ||
deadSignal.setSignalId(this.signalId); | ||
deadSignal.setErrorReason(this.errorReason); | ||
return deadSignal; | ||
} | ||
} |
108 changes: 108 additions & 0 deletions
108
src/test/java/it/pagopa/interop/signalhub/persister/mapper/SignalMapperTest.java
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
Original file line number | Diff line number | Diff line change |
---|---|---|
@@ -0,0 +1,108 @@ | ||
package it.pagopa.interop.signalhub.persister.mapper; | ||
|
||
import it.pagopa.interop.signalhub.persister.entity.Signal; | ||
import it.pagopa.interop.signalhub.persister.queue.model.SignalEvent; | ||
import it.pagopa.interop.signalhub.persister.queue.model.SignalType; | ||
import org.junit.jupiter.api.Test; | ||
import org.mapstruct.factory.Mappers; | ||
import static org.junit.jupiter.api.Assertions.*; | ||
|
||
|
||
class SignalMapperTest { | ||
private final SignalMapper signalMapper = Mappers.getMapper(SignalMapper.class); | ||
private final Long signalId = 0L; | ||
private final String objectId = "OBJ1"; | ||
private final String correlationId = "0A"; | ||
private final String eserviceId = "OBJ1"; | ||
private final String objectType = "0E"; | ||
private final Long indexSignal = 0L; | ||
private final String signalType = SignalType.CREATE.toString(); | ||
|
||
|
||
@Test | ||
void signalToSignalEventTest() { | ||
Signal signal = getSignal(); | ||
SignalEvent signalEvent = signalMapper.signalToSignalEvent(signal); | ||
assertNotNull(signalEvent); | ||
assertEquals(signalEvent.getObjectId(), this.objectId); | ||
assertEquals(signalEvent.getEserviceId(), this.eserviceId); | ||
assertEquals(signalEvent.getSignalType(), SignalType.CREATE); | ||
assertEquals(signalEvent.getObjectType(), this.objectType); | ||
assertEquals(signalEvent.getIndexSignal(), this.indexSignal); | ||
} | ||
|
||
@Test | ||
void signalToSignalEventNullCaseTest() { | ||
SignalEvent signalEvent = signalMapper.signalToSignalEvent(null); | ||
assertNull(signalEvent); | ||
} | ||
|
||
@Test | ||
void signalToSignalEventWithSignalTypeNullTest() { | ||
Signal signal = getSignal(); | ||
signal.setSignalType(null); | ||
SignalEvent signalEvent = signalMapper.signalToSignalEvent(signal); | ||
assertNotNull(signalEvent); | ||
assertNull(signalEvent.getSignalType()); | ||
} | ||
|
||
@Test | ||
void signalEventToSignalTest() { | ||
SignalEvent signalEvent = getSignalEvent(); | ||
Signal signal = signalMapper.signalEventToSignal(signalEvent, this.correlationId); | ||
assertNotNull(signal); | ||
assertEquals(signal.getSignalId(), this.indexSignal); | ||
assertEquals(signal.getObjectId(), this.objectId); | ||
assertEquals(signal.getEserviceId(), this.eserviceId); | ||
assertEquals(signal.getCorrelationId(), this.correlationId); | ||
assertEquals(signal.getSignalType(), this.signalType); | ||
assertEquals(signal.getObjectType(), this.objectType); | ||
} | ||
|
||
@Test | ||
void signalEventToSignalNullCaseTest() { | ||
Signal signal = signalMapper.signalEventToSignal(null, null); | ||
assertNull(signal); | ||
|
||
signal = signalMapper.signalEventToSignal(null, this.correlationId); | ||
assertNotNull(signal); | ||
|
||
SignalEvent signalEvent = getSignalEvent(); | ||
signal = signalMapper.signalEventToSignal(signalEvent, null); | ||
assertNotNull(signal); | ||
assertEquals(signal.getSignalId(), this.indexSignal); | ||
assertEquals(signal.getObjectId(), this.objectId); | ||
assertEquals(signal.getEserviceId(), this.eserviceId); | ||
assertEquals(signal.getObjectType(), this.objectType); | ||
} | ||
|
||
@Test | ||
void signalEventToSignalWithSignalTypeNullTest() { | ||
SignalEvent signalEvent = getSignalEvent(); | ||
signalEvent.setSignalType(null); | ||
Signal signal = signalMapper.signalEventToSignal(signalEvent, this.correlationId); | ||
assertNotNull(signal); | ||
assertNull(signal.getSignalType()); | ||
} | ||
|
||
private Signal getSignal() { | ||
Signal signal = new Signal(); | ||
signal.setSignalId(this.signalId); | ||
signal.setSignalType(this.signalType); | ||
signal.setObjectType(this.objectType); | ||
signal.setCorrelationId(this.correlationId); | ||
signal.setEserviceId(this.eserviceId); | ||
signal.setObjectId(this.objectId); | ||
return signal; | ||
} | ||
|
||
private SignalEvent getSignalEvent() { | ||
SignalEvent signalEvent = new SignalEvent(); | ||
signalEvent.setSignalType(SignalType.CREATE); | ||
signalEvent.setObjectType(this.objectType); | ||
signalEvent.setEserviceId(this.eserviceId); | ||
signalEvent.setObjectId(this.objectId); | ||
signalEvent.setIndexSignal(this.indexSignal); | ||
return signalEvent; | ||
} | ||
} |