package com.orchard;

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

import com.orchard.models.GlobalParticipantStreamsTests;
import java.util.List;
import org.apache.kafka.connect.data.Struct;
import org.junit.jupiter.api.Test;

public class SplitGlobalParticipantUdtfTests {

    @Test
    public void ShouldSplitGlobalParticipantsJson() {
        String inputJson = GlobalParticipantStreamsTests.GlobalParticipantStreamsJson +
                "\n" + GlobalParticipantStreamsTests.GlobalParticipantStreamsJson;
        SplitGlobalParticipantsUdtf udtf = new SplitGlobalParticipantsUdtf();
        List<Struct> result = udtf.split_global_participants(inputJson);
        // Deserialization tested in other tests, verifying the correct splitting.
        assertEquals(2, result.size());
    }
}