Selenium test for WebUI

.gitignore

@@ -24,6 +24,7 @@ lcov.info
 
 .idea
 *.iml
+.DS_Store
 
 benches/galen_data/
 benches/gdelt-data/

crates/webui-tester/Cargo.toml

@@ -0,0 +1,11 @@
+[package]
+name = "webui-tester"
+version = "0.1.0"
+edition = "2021"
+
+[dev-dependencies]
+thirtyfour = "0.32.0-rc.7"
+tokio = "1.28"
+anyhow = "1.0"
+futures = "0.3.28"
+log = "0.4"

crates/webui-tester/src/lib.rs

@@ -0,0 +1,4 @@
+#[cfg(test)]
+mod smoke;
+#[cfg(test)]
+mod ui;

crates/webui-tester/src/smoke.rs

@@ -0,0 +1,131 @@
+// A basic UI workflow test.
+//
+// This test will:
+// 1. Create a program.
+// 2. Create a connector.
+// 3. Create a pipeline.
+// 4. Start the pipeline.
+
+use anyhow::Result;
+use thirtyfour::prelude::*;
+use thirtyfour::TimeoutConfiguration;
+use tokio::time::Duration;
+
+use std::time::{SystemTime, UNIX_EPOCH};
+
+use crate::ui::*;
+
+/// This is the SQL code that will be saved.
+///
+/// I noticed that if you put newlines immediately after the braces, the code
+/// editor might add another brace to complete it, and then the code won't be
+/// correct anymore.
+const SQL_CODE: &str = "
+CREATE TABLE USERS ( name varchar );
+CREATE VIEW OUTPUT_USERS as SELECT * from USERS;
+";
+
+/// A config for a HTTP endpoint.
+///
+/// The \x08 is a backspace character, which is needed to remove the space that
+/// is inserted by the editor.
+const HTTP_ENDPOINT_CONFIG: &str = "
+transport:
+  name: http
+\x08format:
+  name: csv
+";
+
+#[tokio::test]
+async fn smoke_workflow() -> Result<()> {
+    //let caps = DesiredCapabilities::firefox();
+    //let mut driver = WebDriver::new("http://localhost:4444", caps).await?;
+    let nanos = SystemTime::now()
+        .duration_since(UNIX_EPOCH)
+        .expect("Can't get time")
+        .subsec_nanos();
+
+    let caps = DesiredCapabilities::chrome();
+    let driver = WebDriver::new("http://localhost:9515", caps).await?;
+
+    let timeouts =
+        TimeoutConfiguration::new(None, None, Some(std::time::Duration::from_millis(2000)));
+    driver.update_timeouts(timeouts).await?;
+
+    driver.goto("http://localhost:3000").await?;
+    let elem = driver.find(By::Id("navigation")).await?;
+    let menu = VerticalMenu::from(elem);
+
+    // First we make a program, then we compile it.
+    menu.navigate_to("SQL Editor").await?;
+    let code_page = SqlEditor::from(driver.find(By::Id("editor-content")).await?);
+    let program_name = format!("My Program {}", nanos);
+    code_page.set_code(SQL_CODE, &driver).await?;
+    code_page.set_name(&program_name).await?;
+    code_page.set_description("This is a program").await?;
+    code_page.wait_until_saved(Duration::from_secs(20)).await?;
+    code_page
+        .wait_until_compiled(Duration::from_secs(20))
+        .await?;
+
+    // Next we make a connector.
+    menu.navigate_to("Connector Creator").await?;
+    let connector_creator =
+        ConnectorCreator::from(driver.find(By::Id("connector-creator-content")).await?);
+    connector_creator
+        .add_generic_connector(
+            &driver,
+            "My HTTP Connector",
+            "This is a HTTP connector",
+            HTTP_ENDPOINT_CONFIG,
+        )
+        .await?;
+
+    // Finally we make a pipeline.
+    menu.navigate_to("Pipeline Builder").await?;
+    let pipeline_builder =
+        PipelineBuilder::from(driver.find(By::Id("pipeline-builder-content")).await?);
+    let pipeline_name = format!("My Pipeline {}", nanos);
+    pipeline_builder.set_name(&pipeline_name).await?;
+    pipeline_builder
+        .set_description("This is a pipeline")
+        .await?;
+    pipeline_builder.set_program(&program_name).await?;
+    pipeline_builder
+        .add_input(&driver, "My HTTP Connector")
+        .await?;
+    pipeline_builder
+        .add_output(&driver, "My HTTP Connector")
+        .await?;
+    pipeline_builder
+        .connect_input(&driver, "My HTTP Connector", "USERS")
+        .await?;
+    pipeline_builder
+        .connect_output(&driver, "OUTPUT_USERS", "My HTTP Connector")
+        .await?;
+    pipeline_builder
+        .wait_until_saved(Duration::from_secs(3))
+        .await?;
+
+    // Start the pipeline.
+    menu.navigate_to("Pipeline Management").await?;
+    let pipeline_management =
+        PipelineManagementTable::from(driver.find(By::Id("pipeline-management-content")).await?);
+    pipeline_management.start(&pipeline_name).await?;
+    pipeline_management
+        .wait_until_running(&pipeline_name, Duration::from_secs(10))
+        .await?;
+
+    let details = pipeline_management
+        .open_details(&driver, &pipeline_name)
+        .await?;
+    assert_eq!(details.get_records_for_table("USERS").await?, 0);
+    assert_eq!(details.get_records_for_view("OUTPUT_USERS").await?, 0);
+    // TODO: send some stuff
+
+    pipeline_management.pause(&pipeline_name).await?;
+
+    driver.quit().await?;
+
+    Ok(())
+}