0

I am working on Micro-Services Project and a requirement came where the communication between 2 micro-services need to happen. So, I used FeignClient Interface Approach to get it done.

Here is the FeignClientInterface.java Class:

@AuthorizedFeignClient(name = "fcfhpickorders")
public interface FCFHPickOrderService {
    @PutMapping(value = "/api/prescriptions/prescriptionCode", consumes = {"application/json", "application/merge-patch+json"})
    public ResponseEntity<PrescriptionDTO> updatePrescriptionForBucketKey(
        @NotNull @RequestBody PrescriptionDTO prescriptionDTO
    );
}

Below is the function where I used the above declared function:

public Bucket setLinkedPrescriptionCode(Bucket bucket) {
    if (bucket.getLinkedPrescriptionCode() != null) {
        PrescriptionDTO prescription = new PrescriptionDTO();
        prescription.setBucketKey(bucket.getBucketKey());
        prescription.setPrescriptionCode(bucket.getLinkedPrescriptionCode());
        ResponseEntity<PrescriptionDTO> prescriptionDTOResponseEntity = fcfhPickOrderService.updatePrescriptionForBucketKey(prescription);
        if(prescriptionDTOResponseEntity.getStatusCode().isError()) {
            bucket.setLinkedPrescriptionCode(null);
            bucketRepository.save(bucket);
            throw new ResourceNotFoundException("Prescription with " + bucket.getLinkedPrescriptionCode() + "Not Found");
        }
    }
    return bucket;
}

I used the setLinkedPrescriptionCode(Bucket bucket) function while saving and updating an existing bucket. It worked fine.

I have some previously written test cases for creation and updation of bucket that are failing now because of the addition of the REST call.

@IntegrationTest
@ExtendWith(MockitoExtension.class)
@AutoConfigureMockMvc
@WithMockUser
class BucketResourceIT {

    private static final String DEFAULT_BUCKET_KEY = "AAAAAAAAAA";
    private static final String UPDATED_BUCKET_KEY = "BBBBBBBBBB";

    private static final String DEFAULT_QR_CODE = "AAAAAAAAAA";
    private static final String UPDATED_QR_CODE = "BBBBBBBBBB";

    private static final String DEFAULT_LINKED_PRESCRIPTION_CODE = "AAAAAAAAAA";
    private static final String UPDATED_LINKED_PRESCRIPTION_CODE = "BBBBBBBBBB";

    private static final String ENTITY_API_URL = "/api/buckets";
    private static final String ENTITY_API_URL_ID = ENTITY_API_URL + "/{id}";

    private static Random random = new Random();
    private static AtomicLong count = new AtomicLong(random.nextInt() + (2 * Integer.MAX_VALUE));

    @Autowired
    private BucketRepository bucketRepository;

    @Mock
    private BucketRepository bucketRepositoryMock;

    @Autowired
    private BucketMapper bucketMapper;

    @Mock
    private BucketService bucketServiceMock;

    @Autowired
    private EntityManager em;

    @Autowired
    private MockMvc restBucketMockMvc;

    private Bucket bucket;
    @Mock
    private FCFHPickOrderService fcfhPickOrderService;

    public static Bucket createEntity(EntityManager em) {
        Bucket bucket = new Bucket()
            .bucketKey(DEFAULT_BUCKET_KEY)
            .qrCode(DEFAULT_QR_CODE)
            .linkedPrescriptionCode(DEFAULT_LINKED_PRESCRIPTION_CODE);
        return bucket;
    }

    public static Bucket createUpdatedEntity(EntityManager em) {
        Bucket bucket = new Bucket()
            .bucketKey(UPDATED_BUCKET_KEY)
            .qrCode(UPDATED_QR_CODE)
            .linkedPrescriptionCode(UPDATED_LINKED_PRESCRIPTION_CODE);
        return bucket;
    }

    @BeforeEach
    public void initTest() {
        bucket = createEntity(em);
    }


    @Test
    @Transactional
    void createBucket() throws Exception {
        int databaseSizeBeforeCreate = bucketRepository.findAll().size();
        // Create the Bucket
        BucketDTO bucketDTO = bucketMapper.toDto(bucket);
        restBucketMockMvc
            .perform(
                post(ENTITY_API_URL)
                    .with(csrf())
                    .contentType(MediaType.APPLICATION_JSON)
                    .content(TestUtil.convertObjectToJsonBytes(bucketDTO))
            )
            *.andExpect(status().isCreated());*

        // Validate the Bucket in the database
        List<Bucket> bucketList = bucketRepository.findAll();
        assertThat(bucketList).hasSize(databaseSizeBeforeCreate + 1);
        Bucket testBucket = bucketList.get(bucketList.size() - 1);
        assertThat(testBucket.getBucketKey()).isEqualTo(DEFAULT_BUCKET_KEY);
        assertThat(testBucket.getQrCode()).isEqualTo(DEFAULT_QR_CODE);
        assertThat(testBucket.getLinkedPrescriptionCode()).isEqualTo(DEFAULT_LINKED_PRESCRIPTION_CODE);
    }


@Test
    @Transactional
    void putNewBucket() throws Exception {
        bucketRepository.saveAndFlush(bucket);

        int databaseSizeBeforeUpdate = bucketRepository.findAll().size();

        // Update the bucket
        Bucket updatedBucket = bucketRepository.findById(bucket.getId()).get();
        // Disconnect from session so that the updates on updatedBucket are not directly saved in db
        em.detach(updatedBucket);
        updatedBucket.bucketKey(UPDATED_BUCKET_KEY).qrCode(UPDATED_QR_CODE).linkedPrescriptionCode(UPDATED_LINKED_PRESCRIPTION_CODE);
        BucketDTO bucketDTO = bucketMapper.toDto(updatedBucket);

        restBucketMockMvc
            .perform(
                put(ENTITY_API_URL_ID, bucketDTO.getId())
                    .with(csrf())
                    .contentType(MediaType.APPLICATION_JSON)
                    .content(TestUtil.convertObjectToJsonBytes(bucketDTO))
            )
            *.andExpect(status().isOk());*

        // Validate the Bucket in the database
        List<Bucket> bucketList = bucketRepository.findAll();
        assertThat(bucketList).hasSize(databaseSizeBeforeUpdate);
        Bucket testBucket = bucketList.get(bucketList.size() - 1);
        assertThat(testBucket.getBucketKey()).isEqualTo(UPDATED_BUCKET_KEY);
        assertThat(testBucket.getQrCode()).isEqualTo(UPDATED_QR_CODE);
        assertThat(testBucket.getLinkedPrescriptionCode()).isEqualTo(UPDATED_LINKED_PRESCRIPTION_CODE);
    }

How should I update the above tests in order to fix the Assertion Errors that I am receiving?

BucketResourceIT > createBucket() FAILED java.lang.AssertionError at BucketResourceIT.java:133

BucketResourceIT > putNewBucket() FAILED java.lang.AssertionError at BucketResourceIT.java:294

0

Your Answer

By clicking “Post Your Answer”, you agree to our terms of service, privacy policy and cookie policy