Funqy dynamic json parsing

[vladaman]

Is there any way to conditionally parse different event types with Funqy?

We use Funqy to process multiple AWS Cognito events such as CognitoUserPoolPreAuthenticationEvent or CognitoUserPoolPostAuthenticationEvent.

We'd like to have single handler and single running function and branching based on the event type.

We tried following approach but getting JSON as string doesn't work here. Is there any solution to this?

   @Funq("handleString")
    public Uni<? extends CognitoUserPoolEvent> handleString(String cognitoEvent) {
        ObjectMapper objectMapper = new ObjectMapper();
        try {
            CognitoUserPoolEvent baseEvent = objectMapper.readValue(cognitoEvent, CognitoUserPoolEvent.class);
            if (baseEvent.getTriggerSource().equals("PreAuthentication_Authentication")) {
                return preAuthentication(objectMapper.readValue(cognitoEvent, CognitoUserPoolPreAuthenticationEvent.class));
            } else if (baseEvent.getTriggerSource().equals("PostAuthentication_Authentication")) {
                return postAuthentication(objectMapper.readValue(cognitoEvent, CognitoUserPoolPostAuthenticationEvent.class));
            } else if (baseEvent.getTriggerSource().equals("PreSignUp_SignUp")) {
                return preSignup(objectMapper.readValue(cognitoEvent, CognitoUserPoolPreSignUpEvent.class));
            } else {
                return Uni.createFrom().item(baseEvent);
            }
        } catch (JsonProcessingException e) {
            throw new RuntimeException(e);
        }
    }

[quarkus-bot[bot]]

/cc @matejvasek, @patriot1burke

[matejvasek]

Does't byte[] work?

[vladaman]

Hi @matejvasek thanks! I tried byte[] but I get an error

START RequestId: 8622cd53-5958-4b45-a3e4-2a2a8cdcf55c Version: $LATEST
Cannot deserialize value of type `[B` from Object value (token `JsonToken.START_OBJECT`)
 at [Source: (ByteArrayInputStream); line: 1, column: 1]: com.fasterxml.jackson.databind.exc.MismatchedInputException
com.fasterxml.jackson.databind.exc.MismatchedInputException: Cannot deserialize value of type `[B` from Object value (token `JsonToken.START_OBJECT`)
 at [Source: (ByteArrayInputStream); line: 1, column: 1]
	at com.fasterxml.jackson.databind.exc.MismatchedInputException.from(MismatchedInputException.java:59)

My code:

    @Funq("handle")
    public Uni<? extends CognitoUserPoolEvent> handleString(byte[] cognitoPayload) {
        ObjectMapper mapper = new ObjectMapper();
        try {
            CognitoUserPoolEvent userPoolEvent = mapper.readValue(cognitoPayload, CognitoUserPoolEvent.class);

[matejvasek]

@vladaman I will need to check that. I pretty sure byte[] should work with HTTP/Knative binding, not sure above aws/google bindings.

[matejvasek]

@vladaman what binding do you use? aws lambda?

[vladaman]

@matejvasek we use quarkus-amazon-lambda-http

[patriot1burke]

If you are using Lambda constructs like Cognito, why not just use Lambda?

[patriot1burke]

byte[] will not work with funqy-lambda. We need to fix that. Not sure why String doesn't work for you though. You aren't getting json?

[matejvasek]

I believe that with String you need to pass actual JSON string as body, i.e. "{}".

[matejvasek]

I mean including begin/end quotes and escaping.

[matejvasek]

@patriot1burke draft matejvasek@d43743f

[matejvasek]

@vladaman could you try the code above?

[patriot1burke]

@patriot1burke draft matejvasek@d43743f

looks good Matej!

[vladaman]

@matejvasek I would love to! Unfortunately I don't know how to use your github repository in our project to test out. Is there any guide? Thank you.

[matejvasek]

@vladaman btw do you use native-image build? I suspect that with Uni<? extends CognitoUserPoolEvent> Quarkus will not know what classes register for reflection.

[vladaman]

I don't have experience with native images & lambda. So we deploy target/function.zip to lambda as bunch of jar files. Cold start is 7s for some reason. So we prefer to have one function to handle multiple scenarios with Funqy to minimize number of cold starts needed.

We package functions with mvn clean package

Duration: 8519.28 ms Billed Duration: 8520 ms Memory Size: 1024 MB Max Memory Used: 209 MB Init Duration: 2328.38 ms

List of included artifacts:

      <artifactId>url-connection-client</artifactId>
      <artifactId>quarkus-funqy-amazon-lambda</artifactId>
      <artifactId>quarkus-junit5</artifactId>
      <artifactId>quarkus-test-amazon-lambda</artifactId>
      <artifactId>aws-java-sdk-cognitoidp</artifactId>
      <artifactId>jnanoid</artifactId>
      <artifactId>eventbridge</artifactId>
      <artifactId>quarkus-maven-plugin</artifactId>
      <artifactId>maven-compiler-plugin</artifactId>
      <artifactId>maven-surefire-plugin</artifactId>
      <artifactId>maven-failsafe-plugin</artifactId>

Do you think moving to native image would help?

[vladaman]

So I tried native compilation which results in many errors. I guess it requires major code refactoring from our side to make it work. But I guess that would be for another discussion.