Add sanity checks (#174)

* [feature] add sanity checks

* feat: add runner to run sanity checks flow

---------

Co-authored-by: Mathieu Gabelle <[email protected]>

src/test/java/io/kestra/plugin/fs/RunnerTest.java

@@ -0,0 +1,28 @@
+package io.kestra.plugin.fs;
+
+import io.kestra.core.junit.annotations.ExecuteFlow;
+import io.kestra.core.junit.annotations.KestraTest;
+import io.kestra.core.models.executions.Execution;
+import io.kestra.core.models.flows.State;
+import org.junit.jupiter.api.Test;
+
+import static org.hamcrest.MatcherAssert.assertThat;
+import static org.hamcrest.Matchers.hasSize;
+import static org.hamcrest.Matchers.is;
+
+@KestraTest(startRunner = true)
+class RunnerTest {
+    @Test
+    @ExecuteFlow("sanity-checks/download.yaml")
+    void download(Execution execution) {
+        assertThat(execution.getTaskRunList(), hasSize(2));
+        assertThat(execution.getState().getCurrent(), is(State.Type.SUCCESS));
+    }
+
+    @Test
+    @ExecuteFlow("sanity-checks/request.yaml")
+    void request(Execution execution) {
+        assertThat(execution.getTaskRunList(), hasSize(2));
+        assertThat(execution.getState().getCurrent(), is(State.Type.SUCCESS));
+    }
+}

src/test/resources/sanity-checks/download.yaml

@@ -0,0 +1,13 @@
+id: download
+namespace: qa
+
+tasks:
+  - id: download
+    type: io.kestra.plugin.core.http.Download
+    uri: https://huggingface.co/datasets/kestra/datasets/raw/main/csv/orders.csv
+
+  - id: assert
+    type: io.kestra.plugin.core.execution.Assert
+    conditions:
+      - "{{ outputs.download.length == 5837 }}"
+      - "{{ outputs.download.code == 200 }}"

src/test/resources/sanity-checks/request.yaml

@@ -0,0 +1,13 @@
+id: request
+namespace: qa
+
+tasks:
+  - id: request
+    type: io.kestra.plugin.core.http.Request
+    uri: https://dummyjson.com/products
+
+  - id: assert
+    type: io.kestra.plugin.core.execution.Assert
+    conditions:
+      - "{{ outputs.request.code == 200 }}"
+      - "{{ json(outputs.request.body).products[0].id == 1}}"