jprdonnelly/kestra
1
0
Fork 0
mirror of https://github.com/kestra-io/kestra.git synced 2025-12-19 18:05:41 -05:00
Code Issues Packages Projects Releases Wiki Activity

test(processor): add edge-case tests for ServicesFiles utility (#8828)

Browse Source
This commit is contained in:
Daniel Rivas
2025-07-04 07:17:22 -07:00
committed by GitHub
parent 281e1ef979
commit 2b3324797b
1 changed files with 64 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

65
processor/src/test/java/io/kestra/core/plugins/processor/ServicesFilesTest.java
View File

@@ -5,8 +5,11 @@ import org.junit.jupiter.api.Test;
import javax.annotation.processing.Processor;
import java.io.ByteArrayInputStream;
import java.io.ByteArrayOutputStream;
import java.io.IOException;
import java.io.InputStream;
import java.nio.charset.StandardCharsets;
import java.util.Set;
class ServicesFilesTest {
@@ -18,4 +21,64 @@ class ServicesFilesTest {
Set<String> providers = ServicesFiles.readServiceFile(inputStream);
Assertions.assertEquals(Set.of(PluginProcessor.class.getCanonicalName()), providers);
}
}
@Test
void testWriteAndReadServiceFileRoundTrip() throws IOException {
Set<String> services = Set.of("com.example.ServiceA", "com.example.ServiceB");
ByteArrayOutputStream out = new ByteArrayOutputStream();
ServicesFiles.writeServiceFile(services, out);
ByteArrayInputStream in = new ByteArrayInputStream(out.toByteArray());
Set<String> read = ServicesFiles.readServiceFile(in);
Assertions.assertEquals(services, read);
}
@Test
void testReadServiceFileWithCommentsAndWhitespace() throws IOException {
String content = """
# comment
com.example.ServiceA
com.example.ServiceB # inline comment
""";
ByteArrayInputStream in = new ByteArrayInputStream(content.getBytes(StandardCharsets.UTF_8));
Set<String> read = ServicesFiles.readServiceFile(in);
Assertions.assertEquals(Set.of("com.example.ServiceA", "com.example.ServiceB"), read);
}
@Test
void testReadServiceFileWithDuplicates() throws IOException {
String content = """
com.example.ServiceA
com.example.ServiceA
com.example.ServiceB
""";
ByteArrayInputStream in = new ByteArrayInputStream(content.getBytes(StandardCharsets.UTF_8));
Set<String> read = ServicesFiles.readServiceFile(in);
Assertions.assertEquals(Set.of("com.example.ServiceA", "com.example.ServiceB"), read);
}
@Test
void testWriteEmptyServiceFile() throws IOException {
ByteArrayOutputStream out = new ByteArrayOutputStream();
ServicesFiles.writeServiceFile(Set.of(), out);
Assertions.assertEquals("", out.toString(StandardCharsets.UTF_8));
}
@Test
void testReadEmptyServiceFile() throws IOException {
ByteArrayInputStream in = new ByteArrayInputStream(new byte[0]);
Set<String> read = ServicesFiles.readServiceFile(in);
Assertions.assertTrue(read.isEmpty());
}
@Test
void testReadMalformedServiceFile() throws IOException {
String content = "# only a comment\n\n";
ByteArrayInputStream in = new ByteArrayInputStream(content.getBytes(StandardCharsets.UTF_8));
Set<String> read = ServicesFiles.readServiceFile(in);
Assertions.assertTrue(read.isEmpty());
}
}