Spring boot cloud contract usage with wiremock for integration tests and UI testing

See also questions close to this topic

• 64bit Integer has the same limit as 32bit integer

  This is just a short question but I'm still curious. When I initialize a int variable with the highest value 2147483647 it's allright. but when I want to initialize a long and assign it to it's max value, it gives me a "number too large" error

  int i = 2147483647;
  long j = 9223372036854775807;
  
• Android MediaPlayer files path not found

  I'm new in android development trying to play a simple audio file. I organized my audio files in multiple nested folders.

  Here is the complete source on disk "app/src/main/res/raw/sounds/first/nested/my_sound_1.mp3" ... Certainly there are other files in different folders.

  This is the method I'm using to play the audio file

  fun audioPlayer(path : String, fileName: String) {
  
     var mediaPlayer = MediaPlayer()
  
      try {
          mediaPlayer.setDataSource(path + File.separator + fileName)
          mediaPlayer.prepare()
          mediaPlayer.start()
  
      } catch (e: Exception) {
          e.printStackTrace()
      }
  
  }
  

  and on a button click event I'm using this code

  audioPlayer("raw.sounds.first.nested", "my_sound_1.mp3")
  

  Here is the error.

  java.io.IOException: setDataSource failed.
  
• block()/blockFirst()/blockLast() are blocking error when calling bodyToMono AFTER exchange()

  I am trying to use Webflux to stream a generated file to another location, however, if the generation of the file ran into an error, the api returns success, but with a DTO detailing the errors while generating the file instead of the file itself. This is using a very old and poorly designed api so please excuse the use of post and the api design.

  The response from the api call (exchange()) is a ClientResponse. From here I can either convert to a ByteArrayResource using bodyToMono which can be streamed to a file, or, if there is an error in creating the file, then I can convert to the DTO also using bodyToMono. However, I cannot seem to do either or depending on the contents of the header of ClientResponse.

  In run time I get an IllegalStateException caused by

  block()/blockFirst()/blockLast() are blocking, which is not supported in thread reactor-http-client-epoll-12

  I think my issue is that I cannot call block() twice in the same function chain.

  My code snippet is like so:

  webClient.post()
          .uri(uriBuilder -> uriBuilder.path("/file/")
                                        .queryParams(params).build())
          .exchange()
          .doOnSuccess(cr -> {
                  if (MediaType.APPLICATION_JSON_UTF8.equals(cr.headers().contentType().get())) {
                      NoPayloadResponseDto dto = cr.bodyToMono(NoPayloadResponseDto.class).block();
                      createErrorFile(dto);
                  }
                  else {
                      ByteArrayResource bAr = cr.bodyToMono(ByteArrayResource.class).block();
                      createSpreadsheet(bAr);
                  }
              }
          )
          .block();
  

  Basically I want to process the ClientResponse differently based on the MediaType which is defined in the header.

  Is this possible?
• sinon trying to spy express res object

  I'm trying to test this simple express middleware function

  function onlyInternal (req, res, next) {
    if (!ReqHelpers.isInternal(req)) {
      return res.status(HttpStatus.FORBIDDEN).send() <-- TRYING TO ASSERT THIS LINE
    }
    next()
  }
  

  This is my test currently

  describe.only('failure', () => {
        let resSpy
        before(() => {
          let res = {
            status: () => {
              return {
                send: () => {}
              }
            }
          }
  
          resSpy = sinon.spy(res, 'status')
        })
  
        after(() => {
          sinon.restore()
        })
  
        it('should call next', () => {
          const result = middleware.onlyInternal(req, resSpy)
          expect(resSpy.called).to.be.true
        })
      })
  

  And i'm getting this error: TypeError: res.status is not a function

  Why is res.status not a function? It clearly looks like a function to me..
• How to mock express in nodejs when express app is located inside function?

  I have httpListener.ts, which looks like this:

  export function startListening() {
       const app = express();
       app
           .use(bodyParser.json())
           .post('/home/about', func1)
           .get('/user/product/:id', func2)
           .use(function (req, res) {
               res.status(404).send(`no routing for path ${req.url}`);
           })
           .listen(httpListenerConfig.port, () => {
               console.log('listening..');
           });
   }
  

  and I have to write unit tests for func1 and func2 (these functions are private),I want to invoke them using fake http request..

  any idea?
• JavaScript test (mocha) code organization

  I wrote a JavaScript test using Mocha. In my project I have folder named "helpers" with export modules like back_to_main_menu, go_Offline, go_Online, etc. I also have another folder where we can find files with single test.

  Every file starts with a lot of lines which look like

  const {someFunction} = require(‘../helpers/someFunction’)
  

  I want to ask you how to organize it better and avoid this many lines of code in every test file. I don't want to put all the helper functions in one file, because I want to keep quick overview of the names of functions.
• Could not autowire no beans of 'NewsNow' type found

  New Spring boot app from spring starter and I want it to kick off a service call once the app starts up. When I try to use the service in the Main class, it tells me that Could not autowire no beans of 'NewsNow' type found. When I run the app it throws a NullPointerException since the newsNow object is null I know I'm missing something obvious but I cannot figure out what it is.

  Main Class

  package com.mcgowan.newsnow;
  
  import org.springframework.boot.CommandLineRunner;
  import org.springframework.boot.SpringApplication;
  import org.springframework.boot.autoconfigure.SpringBootApplication;
  import service.impl.NewsNow;
  
  import javax.inject.Inject;
  
  @SpringBootApplication
  public class NewsnowApplication implements CommandLineRunner {
  
      @Inject
      private NewsNow newsNow;
  
      public static void main(String[] args) {
          SpringApplication.run(NewsnowApplication.class, args);
      }
  
      @Override
      public void run(String... args) {
          newsNow.process();
      }
  }
  

  Service Class

  package service.impl;
  
  import lombok.extern.log4j.Log4j2;
  import org.springframework.stereotype.Service;
  import service.IWebPageLoader;
  
  import javax.inject.Inject;
  
  @Log4j2
  @Service
  public class NewsNow {
  
      private final IWebPageLoader webPageLoader;
  
      @Inject
      public NewsNow(IWebPageLoader webPageLoader) {
          this.webPageLoader = webPageLoader;
      }
  
      public void process() {
          log.info("processing");
  
      }
  }
  
• Spring Boot JPA - Join by two columns

  TL;DR : Help me join a table by two columns, one by fixed and another by variable value. It is @OneToOne.

  Do this but in hibernate magic :

  SELECT t.*, c.*
  FROM grid.app_users t
    JOIN app_dictionaries c on c.primary = 'USER_STATES' and c.secondary = t.state
  ;
  

  ---

  I was trying to add another join column to my user entity (mapped to table app_users).

  

  This column has to be filtered by primary (fixed USER_STATES) and secondary (variable, in this case A or P) codes on app_dictionaries table.

  

  Help me find a suitable join approach.

  I could have just created a view and joined it by the above mentioned columns but that entails losing the ability to insert and update on app_users.

  I am not very friendly with Hibernate and Spring JPA Repository.

  My User entity :

  package com.core.app.admin.entity;
  
  import com.core.app.admin.auth.ValidPassword;
  import com.core.app.admin.repository.RState;
  import com.core.app.dicts.entity.EDict;
  import com.fasterxml.jackson.annotation.JsonIgnoreProperties;
  import lombok.Data;
  import org.springframework.beans.factory.annotation.Autowired;
  
  import javax.persistence.*;
  import java.util.Set;
  
  @Entity
  @Table(name = "app_users")
  @JsonIgnoreProperties({"hibernateLazyInitializer", "handler"})
  @Data
  public class EUser {
  
    @Autowired
    RState repository;
  
    @Id
    @GeneratedValue(strategy = GenerationType.IDENTITY)
    @Column(name = "user_id")
    private int userId;
    @Column(name = "user_group_id")
    private int userGroupId;
    @Column(name = "name")
    private String name;
    @Column(name = "login")
    private String login;
    @ValidPassword
    @Column(name = "password")
    private String password;
    @Column(name = "state")
    private String state;
    @OneToMany(cascade = CascadeType.ALL, fetch = FetchType.EAGER)
    @JoinTable(
      name = "app_user_roles",
      joinColumns = @JoinColumn(name = "user_id"),
      inverseJoinColumns = @JoinColumn(name = "role_id")
    )
    private Set<ERole> roles;
    @OneToOne(cascade = CascadeType.ALL, fetch = FetchType.LAZY, mappedBy = "app_dictionaries")
    private EDict stateName = repository.getByPrimaryAndSecondary();
  
  }
  

  My dictionary entity :

  package com.core.app.dicts.entity;
  
  import lombok.Data;
  
  import javax.persistence.*;
  import java.io.Serializable;
  
  @Entity
  @Table(
    name = "app_dictionaries",
    uniqueConstraints = {@UniqueConstraint(columnNames = {"primary", "secondary"})}
  )
  @Data
  public class EDict implements Serializable {
  
    private static final long serialVersionUID = 1L;
  
    @Id
    @GeneratedValue(strategy = GenerationType.IDENTITY)
    @Column(name = "line_id")
    private int lineId;
    @Column(name = "primary")
    private String primary;
    @Column(name = "secondary")
    private String secondary;
    @Column(name = "name")
    private String name;
    @Column(name = "state")
    private String state;
  
  }
  

  My state / dictionary repository :

  package com.core.app.admin.repository;
  
  import com.core.app.dicts.entity.EDict;
  import org.springframework.data.jpa.repository.JpaRepository;
  import org.springframework.stereotype.Repository;
  
  import java.util.List;
  
  @Repository
  public interface RState extends JpaRepository<EDict, Integer> {
  
    List<EDict> findByPrimary(String primary);
    EDict getByPrimaryAndSecondary();
  
  }
  

  My error :

  [org.springframework.orm.jpa.SharedEntityManagerCreator] while setting bean property 'entityManager'; nested exception is org.springframework.beans.factory.BeanCreationException: Error creating bean with name '(inner bean)#51933ecb': Cannot resolve reference to bean 'entityManagerFactory' while setting constructor argument; nested exception is org.springframework.beans.factory.BeanCreationException: Error creating bean with name 'entityManagerFactory' defined in class path resource [org/springframework/boot/autoconfigure/orm/jpa/HibernateJpaConfiguration.class]: Invocation of init method failed; nested exception is org.hibernate.AnnotationException: Unknown mappedBy in: com.core.app.admin.entity.EUser.stateName, referenced property unknown: com.core.app.dicts.entity.EDict.app_dictionaries
  

  Thanks in advance.
• Multiple queues with Spring Boot and Azure Service Bus Starter & Scheduled consumption

  I'm refering this sample for working with Azure Service Bus https://github.com/Microsoft/azure-spring-boot/tree/master/azure-spring-boot-samples/azure-servicebus-spring-boot-sample

  I'm able to get the sample working without any issues.

  1- As an extension to it, I now have multiple Queues created in with in same service bus namespace. And I would like to read and post messages to each of the queues. With the azure-servicebus-spring-boot-starter project how can I specifiy multiple queues to work with.

  2- I would like to listen to a queue say every 10 second. For the same in the sprint boot application I enabled scheduling. In the components method that get scheduled every 10 second, as of now I'm registering message handler .

  queueClient.registerMessageHandler(new MessageHandler(),options);
  

  Can registering again & again have issues? If so how to code for the same.

  thanks
• Wiremocking delete not happening

  I am trying to mock a restful delete operation from a https soap service. the rest call is as follows

  http://ixyz.elb.amazonaws.com/credit-cards/accounts/B2J1ofVLu%2B%25YTNU8%3D/payments/A%2BohlapfKazCWU8UuxF5I%2Fbf%2FhBFRHB%2B
  

  I am using the following to stub the delete

  stubFor(delete(urlPathMatching("/credit-cards/accounts/~/payments/~"))
                          .willReturn(aResponse()
                              .withStatus(200)));
  

  The delete code is below its sample but the actual code is diff

  HttpEntity <?> entity = new HttpEntity <>(new HttpHeaders());
  new RestHelper().exchange(url, HttpMethod.DELETE, entity, String.class);
  

  But the call is not getting stubbed with this. I tried using * instead of ~ but still not working. Any help will be appreciated.
• WireMock - Spring Boot not working properly when external IP is added

  I was using WireMock to mock some of the API request which some of my classes are using during the development of the Unit Test Cases.

  WireMock is giving expected results when address is localhost but when proper IP address is added so that after adding to Prod. Server the code works as intended is not working at all. As WireMock is hitting the actual address. What to do??

  @Rule public WireMockRule wireMockRule = new WireMockRule(options().port(8087));
• Spring Cloud Contract with Spring AMQP

  So I've been trying to use Spring Cloud Contract to test RabbitListener.

  So far I have found out that by defining "triggeredBy" in contract, the generated test will call the method provided there and so we will need to provide the actual implementation of what that method do in the TestBase. Another thing is "outputMessage", where we can verify whether the method call before have correctly resulting on some message body sent to certain exchange.

  Source: documentation and sample

  My question is, is there any way to produce the input message from the contract, instead of triggering own custom method? Perhaps something similar like Spring Integration or Spring Cloud Stream example in the documentation:

  Contract.make {
      name("Book Success")
      label("book_success")
      input {
          messageFrom 'input.exchange.and.maybe.route'
          messageHeaders {
              header('contentType': 'application/json')
              header('otherMessageHeader': '1')
          }
          messageBody ([
                  bookData: someData
          ])
      }
      outputMessage {
          sentTo 'output.exchange.and.maybe.route'
          headers {
              header('contentType': 'application/json')
              header('otherMessageHeader': '2')
          }
          body([
                  bookResult: true
          ])
      }
  }
  

  I couldn't find any examples in their sample project that show how to do this.

  Having used spring cloud contract to document and test rest api services, if possible I would like to stay consistent by defining both the input and expected output in contract files for event based services.
• Spring Cloud Contract Debugging

  Im new to Spring Cloud contract. I have written the groovy contract but the wiremock tests are failing. All I see in the console is

  org.junit.ComparisonFailure: expected:<[2]00> but was:<[4]00>

  Can anyone please guide me how to enable more debugging ad also is there a way to print the request and response sent by wiremock? I have set the logging.level.com.github.tomakehurst.wiremock=DEBUG in my spring boot app but no luck