package com.orchard;

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

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

public class SplitGlobalSoundRecordingsUdtfTests {
    @Test
    public void ShouldSplitGlobalParticipantsJson() {
        String inputJson = GlobalSoundRecordingsStreamsTests.GlobalSoundRecordingsStreamsJson +
                "\n" + GlobalSoundRecordingsStreamsTests.GlobalSoundRecordingsStreamsJson;
        SplitGlobalSoundRecordingsUdtf udtf = new SplitGlobalSoundRecordingsUdtf();
        List<Struct> result = udtf.split_global_sound_recordings(inputJson);
        // Deserialization tested in other tests, verifying the correct splitting.
        assertEquals(2, result.size());
    }
}