Prepare for splitting things into separate packages

Move everything into a sprinklers_rs package and create cargo workspace
2020-09-30 15:05:45 -06:00 · 2020-09-30 15:05:45 -06:00 · 174d69fbcc
commit 174d69fbcc
parent 2eb64bbdc0
38 changed files with 43 additions and 37 deletions
--- a/Cargo.toml
+++ b/Cargo.toml
@ -1,35 +1,5 @@
-[package]
-name = "sprinklers_rs"
-version = "0.1.0"
-authors = ["Alex Mikhalev <alexmikhalevalex@gmail.com>"]
-edition = "2018"
+[workspace]

-# See more keys and their definitions at https://doc.rust-lang.org/cargo/reference/manifest.html
-
-[dependencies]
-rusqlite = "0.24.0"
-color-eyre = "0.5.1"
-eyre = "0.6.0"
-thiserror = "1.0.20"
-tokio = { version = "0.2.22", features = ["rt-core", "time", "stream", "sync", "signal", "macros", "test-util"] }
-tracing = { version = "0.1.19", features = ["log"] }
-tracing-futures = "0.2.4"
-pin-project = "0.4.23"
-im = "15.0.0"
-chrono = { version = "0.4.15" }
-assert_matches = "1.3.0"
-serde = { version = "1.0.116", features = ["derive"] }
-serde_json = "1.0.57"
-actix = { version = "0.10.0", default-features = false }
-actix-rt = "1.1.1"
-futures-util = { version = "0.3.5", default-features = false, features = ["std", "async-await", "sink"] }
-num-traits = "0.2.12"
-num-derive = "0.3.2"
-
-[dependencies.rumqttc]
-version = "0.1.0"
-
-[dependencies.tracing-subscriber]
-version = "0.2.11"
-default-features = false
-features = ["registry", "fmt", "env-filter", "ansi"]
+members = [
+    "sprinklers_rs"
+]
--- a/sprinklers_rs/Cargo.toml
+++ b/sprinklers_rs/Cargo.toml
@ -0,0 +1,35 @@
+[package]
+name = "sprinklers_rs"
+version = "0.1.0"
+authors = ["Alex Mikhalev <alexmikhalevalex@gmail.com>"]
+edition = "2018"
+
+# See more keys and their definitions at https://doc.rust-lang.org/cargo/reference/manifest.html
+
+[dependencies]
+rusqlite = "0.24.0"
+color-eyre = "0.5.1"
+eyre = "0.6.0"
+thiserror = "1.0.20"
+tokio = { version = "0.2.22", features = ["rt-core", "time", "stream", "sync", "signal", "macros", "test-util"] }
+tracing = { version = "0.1.19", features = ["log"] }
+tracing-futures = "0.2.4"
+pin-project = "0.4.23"
+im = "15.0.0"
+chrono = { version = "0.4.15" }
+assert_matches = "1.3.0"
+serde = { version = "1.0.116", features = ["derive"] }
+serde_json = "1.0.57"
+actix = { version = "0.10.0", default-features = false }
+actix-rt = "1.1.1"
+futures-util = { version = "0.3.5", default-features = false, features = ["std", "async-await", "sink"] }
+num-traits = "0.2.12"
+num-derive = "0.3.2"
+
+[dependencies.rumqttc]
+version = "0.1.0"
+
+[dependencies.tracing-subscriber]
+version = "0.2.11"
+default-features = false
+features = ["registry", "fmt", "env-filter", "ansi"]
--- a/sprinklers_rs/scripts/add_migration.sh
+++ b/sprinklers_rs/scripts/add_migration.sh
--- a/sprinklers_rs/src/database/migration.rs
+++ b/sprinklers_rs/src/database/migration.rs
--- a/sprinklers_rs/src/database/migrations/0001-table_sections-down.sql
+++ b/sprinklers_rs/src/database/migrations/0001-table_sections-down.sql
--- a/sprinklers_rs/src/database/migrations/0001-table_sections-up.sql
+++ b/sprinklers_rs/src/database/migrations/0001-table_sections-up.sql
--- a/sprinklers_rs/src/database/migrations/0002-section_rows-down.sql
+++ b/sprinklers_rs/src/database/migrations/0002-section_rows-down.sql
--- a/sprinklers_rs/src/database/migrations/0002-section_rows-up.sql
+++ b/sprinklers_rs/src/database/migrations/0002-section_rows-up.sql
--- a/sprinklers_rs/src/database/migrations/0003-table_programs-down.sql
+++ b/sprinklers_rs/src/database/migrations/0003-table_programs-down.sql
--- a/sprinklers_rs/src/database/migrations/0003-table_programs-up.sql
+++ b/sprinklers_rs/src/database/migrations/0003-table_programs-up.sql
--- a/sprinklers_rs/src/database/migrations/0004-program_rows-down.sql
+++ b/sprinklers_rs/src/database/migrations/0004-program_rows-down.sql
--- a/sprinklers_rs/src/database/migrations/0004-program_rows-up.sql
+++ b/sprinklers_rs/src/database/migrations/0004-program_rows-up.sql
--- a/sprinklers_rs/src/database/migrations/0005-view_program_sequence-down.sql
+++ b/sprinklers_rs/src/database/migrations/0005-view_program_sequence-down.sql
--- a/sprinklers_rs/src/database/migrations/0005-view_program_sequence-up.sql
+++ b/sprinklers_rs/src/database/migrations/0005-view_program_sequence-up.sql
--- a/sprinklers_rs/src/database/migrations/0006-fix_view_program_seq-down.sql
+++ b/sprinklers_rs/src/database/migrations/0006-fix_view_program_seq-down.sql
--- a/sprinklers_rs/src/database/migrations/0006-fix_view_program_seq-up.sql
+++ b/sprinklers_rs/src/database/migrations/0006-fix_view_program_seq-up.sql
--- a/sprinklers_rs/src/database/migrations/mod.rs
+++ b/sprinklers_rs/src/database/migrations/mod.rs
--- a/sprinklers_rs/src/database/mod.rs
+++ b/sprinklers_rs/src/database/mod.rs
--- a/sprinklers_rs/src/main.rs
+++ b/sprinklers_rs/src/main.rs
--- a/sprinklers_rs/src/model/mod.rs
+++ b/sprinklers_rs/src/model/mod.rs
--- a/sprinklers_rs/src/model/program.rs
+++ b/sprinklers_rs/src/model/program.rs
--- a/sprinklers_rs/src/model/section.rs
+++ b/sprinklers_rs/src/model/section.rs
--- a/sprinklers_rs/src/mqtt/actor.rs
+++ b/sprinklers_rs/src/mqtt/actor.rs
--- a/sprinklers_rs/src/mqtt/event_loop.rs
+++ b/sprinklers_rs/src/mqtt/event_loop.rs
--- a/sprinklers_rs/src/mqtt/mod.rs
+++ b/sprinklers_rs/src/mqtt/mod.rs
--- a/sprinklers_rs/src/mqtt/request/mod.rs
+++ b/sprinklers_rs/src/mqtt/request/mod.rs
--- a/sprinklers_rs/src/mqtt/request/programs.rs
+++ b/sprinklers_rs/src/mqtt/request/programs.rs
--- a/sprinklers_rs/src/mqtt/request/sections.rs
+++ b/sprinklers_rs/src/mqtt/request/sections.rs
--- a/sprinklers_rs/src/mqtt/topics.rs
+++ b/sprinklers_rs/src/mqtt/topics.rs
--- a/sprinklers_rs/src/option_future.rs
+++ b/sprinklers_rs/src/option_future.rs
--- a/sprinklers_rs/src/program_runner.rs
+++ b/sprinklers_rs/src/program_runner.rs
@ -689,9 +689,10 @@ mod test {
        runner.update_programs(programs).await.unwrap();

        // First try a non-existant program id
-        runner.run_program_id(3).await.unwrap();
-        yield_now().await;
-        assert_matches!(prog_events.try_recv(), Err(broadcast::TryRecvError::Empty));
+        assert_matches!(
+            runner.run_program_id(3).await,
+            Err(ProgramRunnerError::InvalidProgramId(3))
+        );

        runner.run_program_id(1).await.unwrap();
        yield_now().await;
--- a/sprinklers_rs/src/schedule.rs
+++ b/sprinklers_rs/src/schedule.rs
--- a/sprinklers_rs/src/section_interface.rs
+++ b/sprinklers_rs/src/section_interface.rs
--- a/sprinklers_rs/src/section_runner.rs
+++ b/sprinklers_rs/src/section_runner.rs
--- a/sprinklers_rs/src/section_runner_json.rs
+++ b/sprinklers_rs/src/section_runner_json.rs
--- a/sprinklers_rs/src/serde.rs
+++ b/sprinklers_rs/src/serde.rs
--- a/sprinklers_rs/src/trace_listeners.rs
+++ b/sprinklers_rs/src/trace_listeners.rs
--- a/sprinklers_rs/src/update_listener.rs
+++ b/sprinklers_rs/src/update_listener.rs