NewRequiredPropertyFromMetadataTests.java

package io.eventdriven.eventsversioning.upcasters;

import io.eventdriven.eventsversioning.serialization.Serializer;
import io.eventdriven.eventsversioning.v1.ShoppingCartEvent;
import org.junit.jupiter.api.Test;

import java.util.UUID;

import static org.junit.jupiter.api.Assertions.*;

public class NewRequiredPropertyFromMetadataTests {
  public record EventMetadata(
    UUID userId
  ) {
  }

  public record ShoppingCartOpened(
    UUID shoppingCartId,
    UUID clientId,
    UUID initializedBy
  ) {
  }

  public static ShoppingCartOpened upcast(
    ShoppingCartEvent.ShoppingCartOpened oldEvent,
    EventMetadata eventMetadata
  ) {
    return new ShoppingCartOpened(
      oldEvent.shoppingCartId(),
      oldEvent.clientId(),
      eventMetadata.userId()
    );
  }

  public static ShoppingCartOpened upcast(
    byte[] oldEventJson,
    byte[] eventMetadataJson
  ) {
    var oldEvent = Serializer.deserialize(oldEventJson);
    var eventMetadata = Serializer.deserialize(eventMetadataJson);

    return new ShoppingCartOpened(
      UUID.fromString(oldEvent.at("/shoppingCartId").asText()),
      UUID.fromString(oldEvent.at("/clientId").asText()),
      UUID.fromString(eventMetadata.at("/userId").asText())
    );
  }

  @Test
  public void UpcastObjects_Should_BeForwardCompatible() {
    // Given
    var oldEvent = new ShoppingCartEvent.ShoppingCartOpened(UUID.randomUUID(), UUID.randomUUID());
    var eventMetadata = new EventMetadata(UUID.randomUUID());

    // When
    var event = upcast(oldEvent, eventMetadata);

    // Then
    assertNotNull(event);

    assertEquals(oldEvent.shoppingCartId(), event.shoppingCartId());
    assertEquals(oldEvent.clientId(), event.clientId());
    assertEquals(eventMetadata.userId(), event.initializedBy());
  }

  @Test
  public void UpcastJson_Should_BeForwardCompatible() {
    // Given
    var oldEvent = new ShoppingCartEvent.ShoppingCartOpened(UUID.randomUUID(), UUID.randomUUID());
    var eventMetadata = new EventMetadata(UUID.randomUUID());

    // When
    var event = upcast(
      Serializer.serialize(oldEvent),
      Serializer.serialize(eventMetadata)
    );

    // Then
    assertNotNull(event);

    assertEquals(oldEvent.shoppingCartId(), event.shoppingCartId());
    assertEquals(oldEvent.clientId(), event.clientId());
    assertEquals(eventMetadata.userId(), event.initializedBy());
  }
}