1 Commits

Author SHA1 Message Date
071e375cc2 Add alternate bulb list view 2024-02-25 13:53:14 +01:00
24 changed files with 652 additions and 890 deletions

335
Cargo.lock generated
View File

@ -19,9 +19,9 @@ checksum = "f26201604c87b1e01bd3d98f8d5d9a8fcbb815e8cedb41ffccbeb4bf593a35fe"
[[package]] [[package]]
name = "aho-corasick" name = "aho-corasick"
version = "1.1.2" version = "1.1.1"
source = "registry+https://github.com/rust-lang/crates.io-index" source = "registry+https://github.com/rust-lang/crates.io-index"
checksum = "b2969dcb958b36655471fc61f7e416fa76033bdd4bfed0678d8fee1e2d07a1f0" checksum = "ea5d730647d4fadd988536d06fecce94b7b4f2a7efdae548f1cf4b63205518ab"
dependencies = [ dependencies = [
"memchr", "memchr",
] ]
@ -49,13 +49,13 @@ checksum = "a4668cab20f66d8d020e1fbc0ebe47217433c1b6c8f2040faf858554e394ace6"
[[package]] [[package]]
name = "async-trait" name = "async-trait"
version = "0.1.74" version = "0.1.73"
source = "registry+https://github.com/rust-lang/crates.io-index" source = "registry+https://github.com/rust-lang/crates.io-index"
checksum = "a66537f1bb974b254c98ed142ff995236e81b9d0fe4db0575f46612cb15eb0f9" checksum = "bc00ceb34980c03614e35a3a4e218276a0a824e911d07651cd0d858a51e8c0f0"
dependencies = [ dependencies = [
"proc-macro2", "proc-macro2",
"quote", "quote",
"syn 2.0.39", "syn 2.0.37",
] ]
[[package]] [[package]]
@ -98,9 +98,9 @@ checksum = "9e1b586273c5702936fe7b7d6896644d8be71e6314cfe09d3167c95f712589e8"
[[package]] [[package]]
name = "base64" name = "base64"
version = "0.21.5" version = "0.21.4"
source = "registry+https://github.com/rust-lang/crates.io-index" source = "registry+https://github.com/rust-lang/crates.io-index"
checksum = "35636a1494ede3b646cc98f74f8e62c773a38a659ebc777a2cf26b9b74171df9" checksum = "9ba43ea6f343b788c8764558649e08df62f86c6ef251fdaeb1ffd010a9ae50a2"
[[package]] [[package]]
name = "bitflags" name = "bitflags"
@ -125,9 +125,9 @@ checksum = "7f30e7476521f6f8af1a1c4c0b8cc94f0bee37d91763d0ca2665f299b6cd8aec"
[[package]] [[package]]
name = "byteorder" name = "byteorder"
version = "1.5.0" version = "1.4.3"
source = "registry+https://github.com/rust-lang/crates.io-index" source = "registry+https://github.com/rust-lang/crates.io-index"
checksum = "1fd0f2584146f6f2ef48085050886acf353beff7305ebd1ae69500e27c67f64b" checksum = "14c189c53d098945499cdfa7ecc63567cf3886b3332b312a5b4585d8d3a6a610"
[[package]] [[package]]
name = "bytes" name = "bytes"
@ -206,23 +206,13 @@ dependencies = [
[[package]] [[package]]
name = "common" name = "common"
version = "0.2.3" version = "0.2.2"
dependencies = [ dependencies = [
"chrono", "chrono",
"lighter_lib", "lighter_lib",
"serde", "serde",
] ]
[[package]]
name = "core-foundation"
version = "0.9.3"
source = "registry+https://github.com/rust-lang/crates.io-index"
checksum = "194a7a9e6de53fa55116934067c844d9d749312f75c6f6d0980e8c252f8c2146"
dependencies = [
"core-foundation-sys",
"libc",
]
[[package]] [[package]]
name = "core-foundation-sys" name = "core-foundation-sys"
version = "0.8.4" version = "0.8.4"
@ -231,9 +221,9 @@ checksum = "e496a50fda8aacccc86d7529e2c1e0892dbd0f898a6b5645b5561b89c3210efa"
[[package]] [[package]]
name = "cpufeatures" name = "cpufeatures"
version = "0.2.11" version = "0.2.9"
source = "registry+https://github.com/rust-lang/crates.io-index" source = "registry+https://github.com/rust-lang/crates.io-index"
checksum = "ce420fe07aecd3e67c5f910618fe65e94158f6dcc0adf44e00d69ce2bdfe0fd0" checksum = "a17b76ff3a4162b0b27f354a0c87015ddad39d35f9c0c36607a3bdd175dde1f1"
dependencies = [ dependencies = [
"libc", "libc",
] ]
@ -303,16 +293,6 @@ dependencies = [
"termcolor", "termcolor",
] ]
[[package]]
name = "eyre"
version = "0.6.8"
source = "registry+https://github.com/rust-lang/crates.io-index"
checksum = "4c2b6b5a29c02cdc822728b7d7b8ae1bab3e3b05d44522770ddd49722eeac7eb"
dependencies = [
"indenter",
"once_cell",
]
[[package]] [[package]]
name = "fnv" name = "fnv"
version = "1.0.7" version = "1.0.7"
@ -330,9 +310,9 @@ dependencies = [
[[package]] [[package]]
name = "futures" name = "futures"
version = "0.3.29" version = "0.3.28"
source = "registry+https://github.com/rust-lang/crates.io-index" source = "registry+https://github.com/rust-lang/crates.io-index"
checksum = "da0290714b38af9b4a7b094b8a37086d1b4e61f2df9122c3cad2577669145335" checksum = "23342abe12aba583913b2e62f22225ff9c950774065e4bfb61a19cd9770fec40"
dependencies = [ dependencies = [
"futures-channel", "futures-channel",
"futures-core", "futures-core",
@ -345,9 +325,9 @@ dependencies = [
[[package]] [[package]]
name = "futures-channel" name = "futures-channel"
version = "0.3.29" version = "0.3.28"
source = "registry+https://github.com/rust-lang/crates.io-index" source = "registry+https://github.com/rust-lang/crates.io-index"
checksum = "ff4dd66668b557604244583e3e1e1eada8c5c2e96a6d0d6653ede395b78bbacb" checksum = "955518d47e09b25bbebc7a18df10b81f0c766eaf4c4f1cccef2fca5f2a4fb5f2"
dependencies = [ dependencies = [
"futures-core", "futures-core",
"futures-sink", "futures-sink",
@ -355,15 +335,15 @@ dependencies = [
[[package]] [[package]]
name = "futures-core" name = "futures-core"
version = "0.3.29" version = "0.3.28"
source = "registry+https://github.com/rust-lang/crates.io-index" source = "registry+https://github.com/rust-lang/crates.io-index"
checksum = "eb1d22c66e66d9d72e1758f0bd7d4fd0bee04cad842ee34587d68c07e45d088c" checksum = "4bca583b7e26f571124fe5b7561d49cb2868d79116cfa0eefce955557c6fee8c"
[[package]] [[package]]
name = "futures-executor" name = "futures-executor"
version = "0.3.29" version = "0.3.28"
source = "registry+https://github.com/rust-lang/crates.io-index" source = "registry+https://github.com/rust-lang/crates.io-index"
checksum = "0f4fb8693db0cf099eadcca0efe2a5a22e4550f98ed16aba6c48700da29597bc" checksum = "ccecee823288125bd88b4d7f565c9e58e41858e47ab72e8ea2d64e93624386e0"
dependencies = [ dependencies = [
"futures-core", "futures-core",
"futures-task", "futures-task",
@ -372,38 +352,38 @@ dependencies = [
[[package]] [[package]]
name = "futures-io" name = "futures-io"
version = "0.3.29" version = "0.3.28"
source = "registry+https://github.com/rust-lang/crates.io-index" source = "registry+https://github.com/rust-lang/crates.io-index"
checksum = "8bf34a163b5c4c52d0478a4d757da8fb65cabef42ba90515efee0f6f9fa45aaa" checksum = "4fff74096e71ed47f8e023204cfd0aa1289cd54ae5430a9523be060cdb849964"
[[package]] [[package]]
name = "futures-macro" name = "futures-macro"
version = "0.3.29" version = "0.3.28"
source = "registry+https://github.com/rust-lang/crates.io-index" source = "registry+https://github.com/rust-lang/crates.io-index"
checksum = "53b153fd91e4b0147f4aced87be237c98248656bb01050b96bf3ee89220a8ddb" checksum = "89ca545a94061b6365f2c7355b4b32bd20df3ff95f02da9329b34ccc3bd6ee72"
dependencies = [ dependencies = [
"proc-macro2", "proc-macro2",
"quote", "quote",
"syn 2.0.39", "syn 2.0.37",
] ]
[[package]] [[package]]
name = "futures-sink" name = "futures-sink"
version = "0.3.29" version = "0.3.28"
source = "registry+https://github.com/rust-lang/crates.io-index" source = "registry+https://github.com/rust-lang/crates.io-index"
checksum = "e36d3378ee38c2a36ad710c5d30c2911d752cb941c00c72dbabfb786a7970817" checksum = "f43be4fe21a13b9781a69afa4985b0f6ee0e1afab2c6f454a8cf30e2b2237b6e"
[[package]] [[package]]
name = "futures-task" name = "futures-task"
version = "0.3.29" version = "0.3.28"
source = "registry+https://github.com/rust-lang/crates.io-index" source = "registry+https://github.com/rust-lang/crates.io-index"
checksum = "efd193069b0ddadc69c46389b740bbccdd97203899b48d09c5f7969591d6bae2" checksum = "76d3d132be6c0e6aa1534069c705a74a5997a356c0dc2f86a47765e5617c5b65"
[[package]] [[package]]
name = "futures-util" name = "futures-util"
version = "0.3.29" version = "0.3.28"
source = "registry+https://github.com/rust-lang/crates.io-index" source = "registry+https://github.com/rust-lang/crates.io-index"
checksum = "a19526d624e703a3179b3d322efec918b6246ea0fa51d41124525f00f1cc8104" checksum = "26b01e40b772d54cf6c6d721c1d1abd0647a0106a12ecaa1c186273392a69533"
dependencies = [ dependencies = [
"futures-channel", "futures-channel",
"futures-core", "futures-core",
@ -429,9 +409,9 @@ dependencies = [
[[package]] [[package]]
name = "getrandom" name = "getrandom"
version = "0.2.11" version = "0.2.10"
source = "registry+https://github.com/rust-lang/crates.io-index" source = "registry+https://github.com/rust-lang/crates.io-index"
checksum = "fe9006bed769170c11f845cf00c7c1e9092aeb3f268e007c3e760ac68008070f" checksum = "be4136b2a15dd319360be1c07d9933517ccf0be8f16bf62a3bee4f0d618df427"
dependencies = [ dependencies = [
"cfg-if", "cfg-if",
"js-sys", "js-sys",
@ -570,7 +550,7 @@ version = "0.3.9"
source = "registry+https://github.com/rust-lang/crates.io-index" source = "registry+https://github.com/rust-lang/crates.io-index"
checksum = "06683b93020a07e3dbcf5f8c0f6d40080d725bea7936fc01ad345c01b97dc270" checksum = "06683b93020a07e3dbcf5f8c0f6d40080d725bea7936fc01ad345c01b97dc270"
dependencies = [ dependencies = [
"base64 0.21.5", "base64 0.21.4",
"bytes", "bytes",
"headers-core", "headers-core",
"http", "http",
@ -596,7 +576,7 @@ checksum = "95505c38b4572b2d910cecb0281560f54b440a19336cbbcb27bf6ce6adc6f5a8"
[[package]] [[package]]
name = "hemma" name = "hemma"
version = "0.2.3" version = "0.2.2"
dependencies = [ dependencies = [
"anyhow", "anyhow",
"async-trait", "async-trait",
@ -610,7 +590,6 @@ dependencies = [
"log", "log",
"markdown", "markdown",
"pretty_env_logger", "pretty_env_logger",
"rand",
"reqwest", "reqwest",
"ron", "ron",
"serde", "serde",
@ -621,7 +600,7 @@ dependencies = [
[[package]] [[package]]
name = "hemma_web" name = "hemma_web"
version = "0.2.3" version = "0.2.2"
dependencies = [ dependencies = [
"chrono", "chrono",
"common", "common",
@ -653,9 +632,9 @@ checksum = "d77f7ec81a6d05a3abb01ab6eb7590f6083d08449fe5a1c8b1e620283546ccb7"
[[package]] [[package]]
name = "http" name = "http"
version = "0.2.10" version = "0.2.9"
source = "registry+https://github.com/rust-lang/crates.io-index" source = "registry+https://github.com/rust-lang/crates.io-index"
checksum = "f95b9abcae896730d42b78e09c155ed4ddf82c07b4de772c64aee5b2d8b7c150" checksum = "bd6effc99afb63425aff9b05836f029929e345a6148a14b7ecd5ab67af944482"
dependencies = [ dependencies = [
"bytes", "bytes",
"fnv", "fnv",
@ -711,7 +690,7 @@ dependencies = [
"httpdate", "httpdate",
"itoa", "itoa",
"pin-project-lite", "pin-project-lite",
"socket2 0.4.10", "socket2 0.4.9",
"tokio", "tokio",
"tower-service", "tower-service",
"tracing", "tracing",
@ -720,9 +699,9 @@ dependencies = [
[[package]] [[package]]
name = "hyper-rustls" name = "hyper-rustls"
version = "0.24.2" version = "0.24.1"
source = "registry+https://github.com/rust-lang/crates.io-index" source = "registry+https://github.com/rust-lang/crates.io-index"
checksum = "ec3efd23720e2049821a693cbc7e65ea87c72f1c58ff2f9522ff332b1491e590" checksum = "8d78e1e73ec14cf7375674f74d7dde185c8206fd9dea6fb6295e8a98098aaa97"
dependencies = [ dependencies = [
"futures-util", "futures-util",
"http", "http",
@ -734,16 +713,16 @@ dependencies = [
[[package]] [[package]]
name = "iana-time-zone" name = "iana-time-zone"
version = "0.1.58" version = "0.1.57"
source = "registry+https://github.com/rust-lang/crates.io-index" source = "registry+https://github.com/rust-lang/crates.io-index"
checksum = "8326b86b6cff230b97d0d312a6c40a60726df3332e721f72a1b035f451663b20" checksum = "2fad5b825842d2b38bd206f3e81d6957625fd7f0a361e345c30e01a0ae2dd613"
dependencies = [ dependencies = [
"android_system_properties", "android_system_properties",
"core-foundation-sys", "core-foundation-sys",
"iana-time-zone-haiku", "iana-time-zone-haiku",
"js-sys", "js-sys",
"wasm-bindgen", "wasm-bindgen",
"windows-core", "windows",
] ]
[[package]] [[package]]
@ -765,12 +744,6 @@ dependencies = [
"unicode-normalization", "unicode-normalization",
] ]
[[package]]
name = "indenter"
version = "0.3.3"
source = "registry+https://github.com/rust-lang/crates.io-index"
checksum = "ce23b50ad8242c51a442f3ff322d56b02f08852c77e4c0b4d3fd684abc89c683"
[[package]] [[package]]
name = "indexmap" name = "indexmap"
version = "1.9.3" version = "1.9.3"
@ -783,9 +756,9 @@ dependencies = [
[[package]] [[package]]
name = "ipnet" name = "ipnet"
version = "2.9.0" version = "2.8.0"
source = "registry+https://github.com/rust-lang/crates.io-index" source = "registry+https://github.com/rust-lang/crates.io-index"
checksum = "8f518f335dce6725a761382244631d86cf0ccb2863413590b31338feb467f9c3" checksum = "28b29a3cd74f0f4598934efe3aeba42bae0eb4680554128851ebbecb02af14e6"
[[package]] [[package]]
name = "itoa" name = "itoa"
@ -795,9 +768,9 @@ checksum = "af150ab688ff2122fcef229be89cb50dd66af9e01a4ff320cc137eecc9bacc38"
[[package]] [[package]]
name = "js-sys" name = "js-sys"
version = "0.3.64" version = "0.3.63"
source = "registry+https://github.com/rust-lang/crates.io-index" source = "registry+https://github.com/rust-lang/crates.io-index"
checksum = "c5f195fe497f702db0f318b07fdd68edb16955aed830df8363d837542f8f935a" checksum = "2f37a4a5928311ac501dee68b3c7613a1037d0edb30c8e5427bd832d55d1b790"
dependencies = [ dependencies = [
"wasm-bindgen", "wasm-bindgen",
] ]
@ -810,13 +783,14 @@ checksum = "e2abad23fbc42b3700f2f279844dc832adb2b2eb069b2df918f455c4e18cc646"
[[package]] [[package]]
name = "libc" name = "libc"
version = "0.2.150" version = "0.2.148"
source = "registry+https://github.com/rust-lang/crates.io-index" source = "registry+https://github.com/rust-lang/crates.io-index"
checksum = "89d92a4743f9a61002fae18374ed11e7973f530cb3a3255fb354818118b2203c" checksum = "9cdc71e17332e86d2e1d38c1f99edcb6288ee11b815fb1a4b049eaa2114d369b"
[[package]] [[package]]
name = "lighter_lib" name = "lighter_lib"
version = "0.1.0" version = "0.1.0"
source = "git+https://git.nubo.sh/hulthe/lighter.git#0c8f09e825c655e4907fe30221ff4a08ffa274f1"
dependencies = [ dependencies = [
"serde", "serde",
] ]
@ -824,10 +798,10 @@ dependencies = [
[[package]] [[package]]
name = "lighter_manager" name = "lighter_manager"
version = "0.1.0" version = "0.1.0"
source = "git+https://git.nubo.sh/hulthe/lighter.git#0c8f09e825c655e4907fe30221ff4a08ffa274f1"
dependencies = [ dependencies = [
"async-trait", "anyhow",
"clap", "clap",
"eyre",
"lighter_lib", "lighter_lib",
"log", "log",
"mqtt-protocol", "mqtt-protocol",
@ -841,9 +815,9 @@ dependencies = [
[[package]] [[package]]
name = "lock_api" name = "lock_api"
version = "0.4.11" version = "0.4.10"
source = "registry+https://github.com/rust-lang/crates.io-index" source = "registry+https://github.com/rust-lang/crates.io-index"
checksum = "3c168f8615b12bc01f9c17e2eb0cc07dcae1940121185446edc3744920e8ef45" checksum = "c1cc9717a20b1bb222f333e6a92fd32f7d8a18ddc5a3191a11af45dcbf4dcd16"
dependencies = [ dependencies = [
"autocfg", "autocfg",
"scopeguard", "scopeguard",
@ -868,9 +842,9 @@ dependencies = [
[[package]] [[package]]
name = "memchr" name = "memchr"
version = "2.6.4" version = "2.6.3"
source = "registry+https://github.com/rust-lang/crates.io-index" source = "registry+https://github.com/rust-lang/crates.io-index"
checksum = "f665ee40bc4a3c5590afb1e9677db74a508659dfd71e126420da8274909a0167" checksum = "8f232d6ef707e1956a43342693d2a31e72989554d58299d7a88738cc95b0d35c"
[[package]] [[package]]
name = "mime" name = "mime"
@ -899,9 +873,9 @@ dependencies = [
[[package]] [[package]]
name = "mio" name = "mio"
version = "0.8.9" version = "0.8.8"
source = "registry+https://github.com/rust-lang/crates.io-index" source = "registry+https://github.com/rust-lang/crates.io-index"
checksum = "3dce281c5e46beae905d4de1870d8b1509a9142b62eedf18b443b011ca8343d0" checksum = "927a765cd3fc26206e66b296465fa9d3e5ab003e651c1b3c060e7956d96b19d2"
dependencies = [ dependencies = [
"libc", "libc",
"wasi", "wasi",
@ -936,15 +910,15 @@ dependencies = [
"log", "log",
"memchr", "memchr",
"mime", "mime",
"spin", "spin 0.9.8",
"version_check", "version_check",
] ]
[[package]] [[package]]
name = "num-traits" name = "num-traits"
version = "0.2.17" version = "0.2.16"
source = "registry+https://github.com/rust-lang/crates.io-index" source = "registry+https://github.com/rust-lang/crates.io-index"
checksum = "39e3200413f237f41ab11ad6d161bc7239c84dcb631773ccd7de3dfe4b5c267c" checksum = "f30b0abd723be7e2ffca1272140fac1a2f084c77ec3e123c192b66af1ee9e6c2"
dependencies = [ dependencies = [
"autocfg", "autocfg",
] ]
@ -976,9 +950,9 @@ checksum = "dd8b5dd2ae5ed71462c540258bedcb51965123ad7e7ccf4b9a8cafaa4a63576d"
[[package]] [[package]]
name = "os_str_bytes" name = "os_str_bytes"
version = "6.6.1" version = "6.5.1"
source = "registry+https://github.com/rust-lang/crates.io-index" source = "registry+https://github.com/rust-lang/crates.io-index"
checksum = "e2355d85b9a3786f481747ced0e0ff2ba35213a1f9bd406ed906554d7af805a1" checksum = "4d5d9eb14b174ee9aa2ef96dc2b94637a2d4b6e7cb873c7e171f0c20c6cf3eac"
[[package]] [[package]]
name = "parking_lot" name = "parking_lot"
@ -992,9 +966,9 @@ dependencies = [
[[package]] [[package]]
name = "parking_lot_core" name = "parking_lot_core"
version = "0.9.9" version = "0.9.8"
source = "registry+https://github.com/rust-lang/crates.io-index" source = "registry+https://github.com/rust-lang/crates.io-index"
checksum = "4c42a9226546d68acdd9c0a280d17ce19bfe27a46bf68784e4066115788d008e" checksum = "93f00c865fe7cabf650081affecd3871070f26767e7b2070a3ffae14c654b447"
dependencies = [ dependencies = [
"cfg-if", "cfg-if",
"libc", "libc",
@ -1026,7 +1000,7 @@ checksum = "4359fd9c9171ec6e8c62926d6faaf553a8dc3f64e1507e76da7911b4f6a04405"
dependencies = [ dependencies = [
"proc-macro2", "proc-macro2",
"quote", "quote",
"syn 2.0.39", "syn 2.0.37",
] ]
[[package]] [[package]]
@ -1089,9 +1063,9 @@ dependencies = [
[[package]] [[package]]
name = "proc-macro2" name = "proc-macro2"
version = "1.0.69" version = "1.0.67"
source = "registry+https://github.com/rust-lang/crates.io-index" source = "registry+https://github.com/rust-lang/crates.io-index"
checksum = "134c189feb4956b20f6f547d2cf727d4c0fe06722b20a0eec87ed445a97f92da" checksum = "3d433d9f1a3e8c1263d9456598b16fec66f4acc9a74dacffd35c7bb09b3a1328"
dependencies = [ dependencies = [
"unicode-ident", "unicode-ident",
] ]
@ -1143,18 +1117,18 @@ dependencies = [
[[package]] [[package]]
name = "redox_syscall" name = "redox_syscall"
version = "0.4.1" version = "0.3.5"
source = "registry+https://github.com/rust-lang/crates.io-index" source = "registry+https://github.com/rust-lang/crates.io-index"
checksum = "4722d768eff46b75989dd134e5c353f0d6296e5aaa3132e776cbdb56be7731aa" checksum = "567664f262709473930a4bf9e51bf2ebf3348f2e748ccc50dea20646858f8f29"
dependencies = [ dependencies = [
"bitflags", "bitflags",
] ]
[[package]] [[package]]
name = "regex" name = "regex"
version = "1.10.2" version = "1.9.5"
source = "registry+https://github.com/rust-lang/crates.io-index" source = "registry+https://github.com/rust-lang/crates.io-index"
checksum = "380b951a9c5e80ddfd6136919eef32310721aa4aacd4889a8d39124b026ab343" checksum = "697061221ea1b4a94a624f67d0ae2bfe4e22b8a17b6a192afb11046542cc8c47"
dependencies = [ dependencies = [
"aho-corasick", "aho-corasick",
"memchr", "memchr",
@ -1164,9 +1138,9 @@ dependencies = [
[[package]] [[package]]
name = "regex-automata" name = "regex-automata"
version = "0.4.3" version = "0.3.8"
source = "registry+https://github.com/rust-lang/crates.io-index" source = "registry+https://github.com/rust-lang/crates.io-index"
checksum = "5f804c7828047e88b2d32e2d7fe5a105da8ee3264f01902f796c8e067dc2483f" checksum = "c2f401f4955220693b56f8ec66ee9c78abffd8d1c4f23dc41a23839eb88f0795"
dependencies = [ dependencies = [
"aho-corasick", "aho-corasick",
"memchr", "memchr",
@ -1175,17 +1149,17 @@ dependencies = [
[[package]] [[package]]
name = "regex-syntax" name = "regex-syntax"
version = "0.8.2" version = "0.7.5"
source = "registry+https://github.com/rust-lang/crates.io-index" source = "registry+https://github.com/rust-lang/crates.io-index"
checksum = "c08c74e62047bb2de4ff487b251e4a92e24f48745648451635cec7d591162d9f" checksum = "dbb5fb1acd8a1a18b3dd5be62d25485eb770e05afb408a9627d14d451bae12da"
[[package]] [[package]]
name = "reqwest" name = "reqwest"
version = "0.11.22" version = "0.11.20"
source = "registry+https://github.com/rust-lang/crates.io-index" source = "registry+https://github.com/rust-lang/crates.io-index"
checksum = "046cd98826c46c2ac8ddecae268eb5c2e58628688a5fc7a2643704a73faba95b" checksum = "3e9ad3fe7488d7e34558a2033d45a0c90b72d97b4f80705666fea71472e2e6a1"
dependencies = [ dependencies = [
"base64 0.21.5", "base64 0.21.4",
"bytes", "bytes",
"encoding_rs", "encoding_rs",
"futures-core", "futures-core",
@ -1207,7 +1181,6 @@ dependencies = [
"serde", "serde",
"serde_json", "serde_json",
"serde_urlencoded", "serde_urlencoded",
"system-configuration",
"tokio", "tokio",
"tokio-rustls", "tokio-rustls",
"tower-service", "tower-service",
@ -1221,16 +1194,17 @@ dependencies = [
[[package]] [[package]]
name = "ring" name = "ring"
version = "0.17.5" version = "0.16.20"
source = "registry+https://github.com/rust-lang/crates.io-index" source = "registry+https://github.com/rust-lang/crates.io-index"
checksum = "fb0205304757e5d899b9c2e448b867ffd03ae7f988002e47cd24954391394d0b" checksum = "3053cf52e236a3ed746dfc745aa9cacf1b791d846bdaf412f60a8d7d6e17c8fc"
dependencies = [ dependencies = [
"cc", "cc",
"getrandom",
"libc", "libc",
"spin", "once_cell",
"spin 0.5.2",
"untrusted", "untrusted",
"windows-sys", "web-sys",
"winapi",
] ]
[[package]] [[package]]
@ -1252,9 +1226,9 @@ checksum = "d626bb9dae77e28219937af045c257c28bfd3f69333c512553507f5f9798cb76"
[[package]] [[package]]
name = "rustls" name = "rustls"
version = "0.21.8" version = "0.21.7"
source = "registry+https://github.com/rust-lang/crates.io-index" source = "registry+https://github.com/rust-lang/crates.io-index"
checksum = "446e14c5cda4f3f30fe71863c34ec70f5ac79d6087097ad0bb433e1be5edf04c" checksum = "cd8d6c9f025a446bc4d18ad9632e69aec8f287aa84499ee335599fabd20c3fd8"
dependencies = [ dependencies = [
"log", "log",
"ring", "ring",
@ -1264,18 +1238,18 @@ dependencies = [
[[package]] [[package]]
name = "rustls-pemfile" name = "rustls-pemfile"
version = "1.0.4" version = "1.0.3"
source = "registry+https://github.com/rust-lang/crates.io-index" source = "registry+https://github.com/rust-lang/crates.io-index"
checksum = "1c74cae0a4cf6ccbbf5f359f08efdf8ee7e1dc532573bf0db71968cb56b1448c" checksum = "2d3987094b1d07b653b7dfdc3f70ce9a1da9c51ac18c1b06b662e4f9a0e9f4b2"
dependencies = [ dependencies = [
"base64 0.21.5", "base64 0.21.4",
] ]
[[package]] [[package]]
name = "rustls-webpki" name = "rustls-webpki"
version = "0.101.7" version = "0.101.6"
source = "registry+https://github.com/rust-lang/crates.io-index" source = "registry+https://github.com/rust-lang/crates.io-index"
checksum = "8b6275d1ee7a1cd780b64aca7726599a1dbc893b1e64144529e55c3c2f745765" checksum = "3c7d5dece342910d9ba34d259310cae3e0154b873b35408b787b59bce53d34fe"
dependencies = [ dependencies = [
"ring", "ring",
"untrusted", "untrusted",
@ -1301,9 +1275,9 @@ checksum = "94143f37725109f92c262ed2cf5e59bce7498c01bcc1502d7b9afe439a4e9f49"
[[package]] [[package]]
name = "sct" name = "sct"
version = "0.7.1" version = "0.7.0"
source = "registry+https://github.com/rust-lang/crates.io-index" source = "registry+https://github.com/rust-lang/crates.io-index"
checksum = "da046153aa2352493d6cb7da4b6e5c0c057d8a1d0a9aa8560baffdd945acd414" checksum = "d53dcdb7c9f8158937a7981b48accfd39a43af418591a5d008c7b22b5e1b7ca4"
dependencies = [ dependencies = [
"ring", "ring",
"untrusted", "untrusted",
@ -1355,29 +1329,29 @@ dependencies = [
[[package]] [[package]]
name = "serde" name = "serde"
version = "1.0.192" version = "1.0.188"
source = "registry+https://github.com/rust-lang/crates.io-index" source = "registry+https://github.com/rust-lang/crates.io-index"
checksum = "bca2a08484b285dcb282d0f67b26cadc0df8b19f8c12502c13d966bf9482f001" checksum = "cf9e0fcba69a370eed61bcf2b728575f726b50b55cba78064753d708ddc7549e"
dependencies = [ dependencies = [
"serde_derive", "serde_derive",
] ]
[[package]] [[package]]
name = "serde_derive" name = "serde_derive"
version = "1.0.192" version = "1.0.188"
source = "registry+https://github.com/rust-lang/crates.io-index" source = "registry+https://github.com/rust-lang/crates.io-index"
checksum = "d6c7207fbec9faa48073f3e3074cbe553af6ea512d7c21ba46e434e70ea9fbc1" checksum = "4eca7ac642d82aa35b60049a6eccb4be6be75e599bd2e9adb5f875a737654af2"
dependencies = [ dependencies = [
"proc-macro2", "proc-macro2",
"quote", "quote",
"syn 2.0.39", "syn 2.0.37",
] ]
[[package]] [[package]]
name = "serde_json" name = "serde_json"
version = "1.0.108" version = "1.0.107"
source = "registry+https://github.com/rust-lang/crates.io-index" source = "registry+https://github.com/rust-lang/crates.io-index"
checksum = "3d1c7e3eac408d115102c4c24ad393e0821bb3a5df4d506a80f85f7a742a526b" checksum = "6b420ce6e3d8bd882e9b243c6eed35dbc9a6110c9769e74b584e0d68d1f20c65"
dependencies = [ dependencies = [
"itoa", "itoa",
"ryu", "ryu",
@ -1427,15 +1401,15 @@ dependencies = [
[[package]] [[package]]
name = "smallvec" name = "smallvec"
version = "1.11.2" version = "1.11.1"
source = "registry+https://github.com/rust-lang/crates.io-index" source = "registry+https://github.com/rust-lang/crates.io-index"
checksum = "4dccd0940a2dcdf68d092b8cbab7dc0ad8fa938bf95787e1b916b0e3d0e8e970" checksum = "942b4a808e05215192e39f4ab80813e599068285906cc91aa64f923db842bd5a"
[[package]] [[package]]
name = "socket2" name = "socket2"
version = "0.4.10" version = "0.4.9"
source = "registry+https://github.com/rust-lang/crates.io-index" source = "registry+https://github.com/rust-lang/crates.io-index"
checksum = "9f7916fc008ca5542385b89a3d3ce689953c143e9304a9bf8beec1de48994c0d" checksum = "64a4a911eed85daf18834cfaa86a79b7d266ff93ff5ba14005426219480ed662"
dependencies = [ dependencies = [
"libc", "libc",
"winapi", "winapi",
@ -1443,14 +1417,20 @@ dependencies = [
[[package]] [[package]]
name = "socket2" name = "socket2"
version = "0.5.5" version = "0.5.4"
source = "registry+https://github.com/rust-lang/crates.io-index" source = "registry+https://github.com/rust-lang/crates.io-index"
checksum = "7b5fac59a5cb5dd637972e5fca70daf0523c9067fcdc4842f053dae04a18f8e9" checksum = "4031e820eb552adee9295814c0ced9e5cf38ddf1e8b7d566d6de8e2538ea989e"
dependencies = [ dependencies = [
"libc", "libc",
"windows-sys", "windows-sys",
] ]
[[package]]
name = "spin"
version = "0.5.2"
source = "registry+https://github.com/rust-lang/crates.io-index"
checksum = "6e63cff320ae2c57904679ba7cb63280a3dc4613885beafb148ee7bf9aa9042d"
[[package]] [[package]]
name = "spin" name = "spin"
version = "0.9.8" version = "0.9.8"
@ -1476,36 +1456,15 @@ dependencies = [
[[package]] [[package]]
name = "syn" name = "syn"
version = "2.0.39" version = "2.0.37"
source = "registry+https://github.com/rust-lang/crates.io-index" source = "registry+https://github.com/rust-lang/crates.io-index"
checksum = "23e78b90f2fcf45d3e842032ce32e3f2d1545ba6636271dcbf24fa306d87be7a" checksum = "7303ef2c05cd654186cb250d29049a24840ca25d2747c25c0381c8d9e2f582e8"
dependencies = [ dependencies = [
"proc-macro2", "proc-macro2",
"quote", "quote",
"unicode-ident", "unicode-ident",
] ]
[[package]]
name = "system-configuration"
version = "0.5.1"
source = "registry+https://github.com/rust-lang/crates.io-index"
checksum = "ba3a3adc5c275d719af8cb4272ea1c4a6d668a777f37e115f6d11ddbc1c8e0e7"
dependencies = [
"bitflags",
"core-foundation",
"system-configuration-sys",
]
[[package]]
name = "system-configuration-sys"
version = "0.5.0"
source = "registry+https://github.com/rust-lang/crates.io-index"
checksum = "a75fb188eb626b924683e3b95e3a48e63551fcfb51949de2f06a9d91dbee93c9"
dependencies = [
"core-foundation-sys",
"libc",
]
[[package]] [[package]]
name = "termcolor" name = "termcolor"
version = "1.3.0" version = "1.3.0"
@ -1523,22 +1482,22 @@ checksum = "222a222a5bfe1bba4a77b45ec488a741b3cb8872e5e499451fd7d0129c9c7c3d"
[[package]] [[package]]
name = "thiserror" name = "thiserror"
version = "1.0.50" version = "1.0.49"
source = "registry+https://github.com/rust-lang/crates.io-index" source = "registry+https://github.com/rust-lang/crates.io-index"
checksum = "f9a7210f5c9a7156bb50aa36aed4c95afb51df0df00713949448cf9e97d382d2" checksum = "1177e8c6d7ede7afde3585fd2513e611227efd6481bd78d2e82ba1ce16557ed4"
dependencies = [ dependencies = [
"thiserror-impl", "thiserror-impl",
] ]
[[package]] [[package]]
name = "thiserror-impl" name = "thiserror-impl"
version = "1.0.50" version = "1.0.49"
source = "registry+https://github.com/rust-lang/crates.io-index" source = "registry+https://github.com/rust-lang/crates.io-index"
checksum = "266b2e40bc00e5a6c09c3584011e08b06f123c00362c92b975ba9843aaaa14b8" checksum = "10712f02019e9288794769fba95cd6847df9874d49d871d062172f9dd41bc4cc"
dependencies = [ dependencies = [
"proc-macro2", "proc-macro2",
"quote", "quote",
"syn 2.0.39", "syn 2.0.37",
] ]
[[package]] [[package]]
@ -1558,9 +1517,9 @@ checksum = "1f3ccbac311fea05f86f61904b462b55fb3df8837a366dfc601a0161d0532f20"
[[package]] [[package]]
name = "tokio" name = "tokio"
version = "1.34.0" version = "1.32.0"
source = "registry+https://github.com/rust-lang/crates.io-index" source = "registry+https://github.com/rust-lang/crates.io-index"
checksum = "d0c014766411e834f7af5b8f4cf46257aab4036ca95e9d2c144a10f59ad6f5b9" checksum = "17ed6077ed6cd6c74735e21f37eb16dc3935f96878b1fe961074089cc80893f9"
dependencies = [ dependencies = [
"backtrace", "backtrace",
"bytes", "bytes",
@ -1570,21 +1529,20 @@ dependencies = [
"parking_lot", "parking_lot",
"pin-project-lite", "pin-project-lite",
"signal-hook-registry", "signal-hook-registry",
"socket2 0.5.5", "socket2 0.5.4",
"tokio-macros", "tokio-macros",
"tracing",
"windows-sys", "windows-sys",
] ]
[[package]] [[package]]
name = "tokio-macros" name = "tokio-macros"
version = "2.2.0" version = "2.1.0"
source = "registry+https://github.com/rust-lang/crates.io-index" source = "registry+https://github.com/rust-lang/crates.io-index"
checksum = "5b8a1e28f2deaa14e508979454cb3a223b10b938b45af148bc0986de36f1923b" checksum = "630bdcf245f78637c13ec01ffae6187cca34625e8c63150d424b59e55af2675e"
dependencies = [ dependencies = [
"proc-macro2", "proc-macro2",
"quote", "quote",
"syn 2.0.39", "syn 2.0.37",
] ]
[[package]] [[package]]
@ -1622,9 +1580,9 @@ dependencies = [
[[package]] [[package]]
name = "tokio-util" name = "tokio-util"
version = "0.7.10" version = "0.7.9"
source = "registry+https://github.com/rust-lang/crates.io-index" source = "registry+https://github.com/rust-lang/crates.io-index"
checksum = "5419f34732d9eb6ee4c3578b7989078579b7f039cbbb9ca2c4da015749371e15" checksum = "1d68074620f57a0b21594d9735eb2e98ab38b17f80d3fcb189fca266771ca60d"
dependencies = [ dependencies = [
"bytes", "bytes",
"futures-core", "futures-core",
@ -1651,10 +1609,11 @@ checksum = "b6bc1c9ce2b5135ac7f93c72918fc37feb872bdc6a5533a8b85eb4b86bfdae52"
[[package]] [[package]]
name = "tracing" name = "tracing"
version = "0.1.40" version = "0.1.37"
source = "registry+https://github.com/rust-lang/crates.io-index" source = "registry+https://github.com/rust-lang/crates.io-index"
checksum = "c3523ab5a71916ccf420eebdf5521fcef02141234bbc0b8a49f2fdc4544364ef" checksum = "8ce8c33a8d48bd45d624a6e523445fd21ec13d3653cd51f681abf67418f54eb8"
dependencies = [ dependencies = [
"cfg-if",
"log", "log",
"pin-project-lite", "pin-project-lite",
"tracing-core", "tracing-core",
@ -1662,9 +1621,9 @@ dependencies = [
[[package]] [[package]]
name = "tracing-core" name = "tracing-core"
version = "0.1.32" version = "0.1.31"
source = "registry+https://github.com/rust-lang/crates.io-index" source = "registry+https://github.com/rust-lang/crates.io-index"
checksum = "c06d3da6113f116aaee68e4d601191614c9053067f9ab7f6edbcb161237daa54" checksum = "0955b8137a1df6f1a2e9a37d8a6656291ff0297c1a97c24e0d8425fe2312f79a"
dependencies = [ dependencies = [
"once_cell", "once_cell",
] ]
@ -1732,9 +1691,9 @@ dependencies = [
[[package]] [[package]]
name = "untrusted" name = "untrusted"
version = "0.9.0" version = "0.7.1"
source = "registry+https://github.com/rust-lang/crates.io-index" source = "registry+https://github.com/rust-lang/crates.io-index"
checksum = "8ecb6da28b8a351d773b68d5825ac39017e680750f980f3a1a85cd8dd28a47c1" checksum = "a156c684c91ea7d62626509bce3cb4e1d9ed5c4d978f7b4352658f96a4c26b4a"
[[package]] [[package]]
name = "url" name = "url"
@ -1755,9 +1714,9 @@ checksum = "09cc8ee72d2a9becf2f2febe0205bbed8fc6615b7cb429ad062dc7b7ddd036a9"
[[package]] [[package]]
name = "uuid" name = "uuid"
version = "1.5.0" version = "1.4.1"
source = "registry+https://github.com/rust-lang/crates.io-index" source = "registry+https://github.com/rust-lang/crates.io-index"
checksum = "88ad59a7560b41a70d191093a945f0b87bc1deeda46fb237479708a1d6b6cdfc" checksum = "79daa5ed5740825c40b389c5e50312b9c86df53fccd33f281df655642b43869d"
dependencies = [ dependencies = [
"getrandom", "getrandom",
] ]
@ -1835,15 +1794,15 @@ dependencies = [
"once_cell", "once_cell",
"proc-macro2", "proc-macro2",
"quote", "quote",
"syn 2.0.39", "syn 2.0.37",
"wasm-bindgen-shared", "wasm-bindgen-shared",
] ]
[[package]] [[package]]
name = "wasm-bindgen-futures" name = "wasm-bindgen-futures"
version = "0.4.37" version = "0.4.36"
source = "registry+https://github.com/rust-lang/crates.io-index" source = "registry+https://github.com/rust-lang/crates.io-index"
checksum = "c02dbc21516f9f1f04f187958890d7e6026df8d16540b7ad9492bc34a67cea03" checksum = "2d1985d03709c53167ce907ff394f5316aa22cb4e12761295c5dc57dacb6297e"
dependencies = [ dependencies = [
"cfg-if", "cfg-if",
"js-sys", "js-sys",
@ -1869,7 +1828,7 @@ checksum = "54681b18a46765f095758388f2d0cf16eb8d4169b639ab575a8f5693af210c7b"
dependencies = [ dependencies = [
"proc-macro2", "proc-macro2",
"quote", "quote",
"syn 2.0.39", "syn 2.0.37",
"wasm-bindgen-backend", "wasm-bindgen-backend",
"wasm-bindgen-shared", "wasm-bindgen-shared",
] ]
@ -1882,9 +1841,9 @@ checksum = "ca6ad05a4870b2bf5fe995117d3728437bd27d7cd5f06f13c17443ef369775a1"
[[package]] [[package]]
name = "web-sys" name = "web-sys"
version = "0.3.64" version = "0.3.63"
source = "registry+https://github.com/rust-lang/crates.io-index" source = "registry+https://github.com/rust-lang/crates.io-index"
checksum = "9b85cbef8c220a6abc02aefd892dfc0fc23afb1c6a426316ec33253a3877249b" checksum = "3bdd9ef4e984da1187bf8110c5cf5b845fbc87a23602cdf912386a76fcd3a7c2"
dependencies = [ dependencies = [
"js-sys", "js-sys",
"wasm-bindgen", "wasm-bindgen",
@ -1928,10 +1887,10 @@ source = "registry+https://github.com/rust-lang/crates.io-index"
checksum = "712e227841d057c1ee1cd2fb22fa7e5a5461ae8e48fa2ca79ec42cfc1931183f" checksum = "712e227841d057c1ee1cd2fb22fa7e5a5461ae8e48fa2ca79ec42cfc1931183f"
[[package]] [[package]]
name = "windows-core" name = "windows"
version = "0.51.1" version = "0.48.0"
source = "registry+https://github.com/rust-lang/crates.io-index" source = "registry+https://github.com/rust-lang/crates.io-index"
checksum = "f1f8cf84f35d2db49a46868f947758c7a1138116f7fac3bc844f43ade1292e64" checksum = "e686886bc078bc1b0b600cac0147aadb815089b6e4da64016cbd754b6342700f"
dependencies = [ dependencies = [
"windows-targets", "windows-targets",
] ]

View File

@ -12,7 +12,3 @@ lto = true
opt-level = 's' opt-level = 's'
# Issue with const-generics # Issue with const-generics
incremental = false incremental = false
[patch."https://git.nubo.sh/hulthe/lighter.git"]
lighter_manager = { path = "../lighter/manager" }
lighter_lib = { path = "../lighter/lib" }

View File

@ -1,6 +1,6 @@
[package] [package]
name = "hemma" name = "hemma"
version = "0.2.3" version = "0.2.2"
edition = "2021" edition = "2021"
[dependencies] [dependencies]
@ -19,7 +19,6 @@ toml = "0.5.9"
serde = { version = "1.0.138", features = ["derive"] } serde = { version = "1.0.138", features = ["derive"] }
futures = "0.3.21" futures = "0.3.21"
chrono = { version = "0.4.20", features = ["serde"] } chrono = { version = "0.4.20", features = ["serde"] }
rand = "0.8.5"
[dependencies.common] [dependencies.common]
path = "../common" path = "../common"

View File

@ -1,7 +1,6 @@
mod collector; mod collector;
mod persistence; mod persistence;
mod tasks; mod tasks;
mod util;
use clap::Parser; use clap::Parser;
use collector::CollectorConfig; use collector::CollectorConfig;

View File

@ -1,22 +1,22 @@
use std::collections::HashMap; use std::collections::HashMap;
use common::{BulbPrefs, ClientMessage, ScriptId, ServerMessage}; use chrono::{DateTime, Datelike, Local, NaiveTime, Weekday};
use lighter_lib::BulbId; use common::{ClientMessage, ServerMessage};
use lighter_lib::{BulbColor, BulbId};
use lighter_manager::manager::{BulbCommand, BulbManager, BulbSelector}; use lighter_manager::manager::{BulbCommand, BulbManager, BulbSelector};
use lighter_manager::provider::mqtt::BulbsMqtt;
use serde::{Deserialize, Serialize}; use serde::{Deserialize, Serialize};
use std::time::Duration;
use tokio::select; use tokio::select;
use tokio::sync::{broadcast, mpsc};
use tokio::task::{spawn, JoinHandle};
use tokio::time::sleep;
use crate::persistence::PersistenceFile; use crate::persistence::PersistenceFile;
use crate::State; use crate::{ClientRequest, State};
use self::scripts::{LightScript, Party, Waker};
pub mod scripts;
#[derive(Default, Clone, PartialEq, Eq, Serialize, Deserialize)] #[derive(Default, Clone, PartialEq, Eq, Serialize, Deserialize)]
struct LightsState { struct LightsState {
script_prefs: HashMap<ScriptId, HashMap<BulbId, BulbPrefs>>, wake_schedule: HashMap<BulbId, HashMap<Weekday, NaiveTime>>,
} }
pub async fn lights_task(state: &State) { pub async fn lights_task(state: &State) {
@ -29,43 +29,36 @@ pub async fn lights_task(state: &State) {
.await .await
.expect("Failed to open lights config"); .expect("Failed to open lights config");
let provider = BulbsMqtt::new(config.bulbs.clone(), config.mqtt.clone()); let (cmd, bulb_states) = BulbManager::launch(config.bulbs.clone(), config.mqtt.clone())
let manager = BulbManager::launch(config.bulbs.clone(), provider)
.await .await
.expect("Failed to launch bulb manager"); .expect("Failed to launch bulb manager");
let mut scripts: HashMap<ScriptId, Box<dyn LightScript + Send>> = Default::default(); let mut wake_tasks: HashMap<(BulbId, Weekday), JoinHandle<()>> = lights_state
scripts.insert( .get()
"waker".to_string(), .wake_schedule
Box::new(Waker::create(manager.clone())), .iter()
); .flat_map(|(bulb, schedule)| schedule.iter().map(move |(day, time)| (bulb, day, time)))
scripts.insert( .map(|(bulb, day, time)| {
"party".to_string(), let handle = spawn(wake_task(
Box::new(Party::create(manager.clone())), state.client_message.clone(),
); cmd.clone(),
bulb.clone(),
*day,
*time,
));
for (script, prefs) in &lights_state.get().script_prefs { ((bulb.clone(), *day), handle)
let Some(script) = scripts.get_mut(script) else { })
continue;
};
for (bulb, prefs) in prefs {
for (name, value) in &prefs.kvs {
script.set_param(bulb, name, value.clone())
}
}
}
loop {
select! {
_ = manager.notify_on_change() => {
for (id, mode) in manager.bulbs().await.clone().into_iter() {
let prefs = scripts.iter_mut()
.map(|(script, prefs)|
(script.clone(), prefs.get_params(&id)))
.collect(); .collect();
let msg = ServerMessage::BulbState { id, mode, prefs }; loop {
let notify = bulb_states.notify_on_change();
select! {
_ = notify => {
let lights_state = lights_state.get();
for (id, mode) in bulb_states.bulbs().await.clone().into_iter() {
let wake_schedule = lights_state.wake_schedule.get(&id).cloned().unwrap_or_default();
let msg = ServerMessage::BulbState { id, mode, wake_schedule };
if let Err(e) = server_message.send(msg) { if let Err(e) = server_message.send(msg) {
error!("broadcast channel error: {e}"); error!("broadcast channel error: {e}");
return; return;
@ -80,42 +73,58 @@ pub async fn lights_task(state: &State) {
match request.message { match request.message {
ClientMessage::SetBulbColor { id, color } => { ClientMessage::SetBulbColor { id, color } => {
manager.send_command(BulbCommand::SetColor(BulbSelector::Id(id), color)).await; if let Err(e) = cmd.send(BulbCommand::SetColor(BulbSelector::Id(id), color)).await {
error!("bulb manager error: {e}");
}
} }
ClientMessage::SetBulbPower { id, power } => { ClientMessage::SetBulbPower { id, power } => {
manager.send_command(BulbCommand::SetPower(BulbSelector::Id(id), power)).await; if let Err(e) = cmd.send(BulbCommand::SetPower(BulbSelector::Id(id), power)).await {
error!("bulb manager error: {e}");
}
} }
ClientMessage::GetBulbs => { ClientMessage::GetBulbs => {
if let Err(e) = request.response.send(ServerMessage::BulbMap(config.bulb_map.clone())).await { if let Err(e) = request.response.send(ServerMessage::BulbMap(config.bulb_map.clone())).await {
error!("GetBulbs response channel error: {e}"); error!("GetBulbs response channel error: {e}");
return; return;
} }
for (id, mode) in manager.bulbs().await.clone().into_iter() { let lights_state = lights_state.get();
let prefs = scripts.iter_mut() for (id, mode) in bulb_states.bulbs().await.clone().into_iter() {
.map(|(script, prefs)| let wake_schedule = lights_state.wake_schedule.get(&id).cloned().unwrap_or_default();
(script.clone(), prefs.get_params(&id))) let msg = ServerMessage::BulbState { id, mode, wake_schedule };
.collect();
let msg = ServerMessage::BulbState { id, mode, prefs };
if let Err(e) = request.response.send(msg).await { if let Err(e) = request.response.send(msg).await {
error!("GetBulbs response channel error: {e}"); error!("GetBulbs response channel error: {e}");
return; return;
} }
} }
} }
ClientMessage::SetBulbPref { bulb, script, name, value } => { ClientMessage::SetBulbWakeTime { id, day, time } => {
let Some(s) = scripts.get_mut(&script) else { if let Err(e) = lights_state.update(|lights_state| {
continue; let schedule = lights_state.wake_schedule.entry(id.clone()).or_default();
if let Some(time) = time {
schedule.insert(day, time);
}
else {
schedule.remove(&day);
}
}).await {
error!("Failed to save wake schedule: {e}");
}; };
s.set_param(&bulb, &name, value.clone());
// TODO handle error if let Some(time) = time {
lights_state.update(move |state| { let handle = spawn(wake_task(
state.script_prefs state.client_message.clone(),
.entry(script).or_default() cmd.clone(),
.entry(bulb).or_default() id.clone(),
.kvs.insert(name, value); day,
}).await.expect("failed to persist lights state"); time,
));
if let Some(old_handle) = wake_tasks.insert((id, day), handle) {
old_handle.abort();
}
} else if let Some(old_handle) = wake_tasks.remove(&(id, day)) {
old_handle.abort();
}
} }
_ => {} _ => {}
} }
@ -123,3 +132,112 @@ pub async fn lights_task(state: &State) {
} }
} }
} }
async fn wake_task(
client_messages: broadcast::Sender<ClientRequest>,
cmd: mpsc::Sender<BulbCommand>,
id: BulbId,
day: Weekday,
time: NaiveTime,
) {
let mut alarm = next_alarm(Local::now(), day, time);
loop {
info!("sleeping until {alarm}");
sleep((alarm - Local::now()).to_std().unwrap()).await;
// slowly turn up brightness of bulb
for brightness in (1..=75).map(|i| (i as f32) * 0.01) {
select! {
// abort if the client pokes the bulb
_ = wait_for_bulb_command(&id, client_messages.subscribe()) => break,
_ = sleep(Duration::from_secs(12)) => {}
};
if cmd
.send(BulbCommand::SetColor(
BulbSelector::Id(id.clone()),
BulbColor::Kelvin {
t: 0.0,
b: brightness,
},
))
.await
.is_err()
{
return;
};
}
alarm = next_alarm(Local::now(), day, time);
}
}
/// Get the next alarm, from a weekday+time schedule.
fn next_alarm(now: DateTime<Local>, day: Weekday, time: NaiveTime) -> DateTime<Local> {
let day_of_alarm = day.num_days_from_monday() as i64;
let day_now = now.weekday().num_days_from_monday() as i64;
let alarm = now + chrono::Duration::days(day_of_alarm - day_now);
let mut alarm = alarm
.date_naive()
.and_time(time)
.and_local_timezone(Local)
.unwrap();
if alarm <= now {
alarm += chrono::Duration::weeks(1);
}
alarm
}
/// Wait until we receive a client request that mutates the given bulb
async fn wait_for_bulb_command(
bulb_id: &BulbId,
mut client_messages: broadcast::Receiver<ClientRequest>,
) {
loop {
match client_messages.recv().await {
Err(_) => return,
Ok(request) => match request.message {
ClientMessage::SetBulbColor { id, .. }
| ClientMessage::SetBulbPower { id, .. }
| ClientMessage::SetBulbWakeTime { id, .. }
if &id == bulb_id =>
{
break
}
_ => continue,
},
}
}
}
#[cfg(test)]
mod test {
use chrono::{offset::TimeZone, Local, NaiveTime, Weekday};
use super::next_alarm;
#[test]
fn test_alarm_date() {
const FMT: &str = "%Y-%m-%d %H:%M";
let now = Local.datetime_from_str("2022-10-18 15:30", FMT).unwrap();
let test_values = [
(Weekday::Tue, (16, 30), "2022-10-18 16:30"),
(Weekday::Tue, (14, 30), "2022-10-25 14:30"),
(Weekday::Wed, (15, 30), "2022-10-19 15:30"),
(Weekday::Mon, (15, 30), "2022-10-24 15:30"),
];
for (day, (hour, min), expected) in test_values {
let expected = Local.datetime_from_str(expected, FMT).unwrap();
assert_eq!(
next_alarm(now, day, NaiveTime::from_hms(hour, min, 0)),
expected
);
}
}
}

View File

@ -1,12 +0,0 @@
use common::{BulbPrefs, Param};
use lighter_lib::BulbId;
mod party;
mod waker;
pub use party::Party;
pub use waker::Waker;
pub trait LightScript {
fn get_params(&mut self, bulb: &BulbId) -> BulbPrefs;
fn set_param(&mut self, bulb: &BulbId, name: &str, value: Param);
}

View File

@ -1,79 +0,0 @@
use std::{collections::HashMap, time::Duration};
use common::{BulbPrefs, Param};
use lighter_lib::{BulbColor, BulbId};
use lighter_manager::manager::{BulbCommand, BulbManager, BulbSelector};
use rand::random;
use tokio::{spawn, time::sleep};
use crate::util::DeadMansHandle;
use super::LightScript;
pub struct Party {
manager: BulbManager,
party_tasks: HashMap<BulbId, DeadMansHandle>,
}
impl Party {
pub fn create(manager: BulbManager) -> Self {
Party {
manager,
party_tasks: Default::default(),
}
}
}
impl LightScript for Party {
fn get_params(&mut self, bulb: &BulbId) -> BulbPrefs {
let enabled = self.party_tasks.get(bulb).is_some();
BulbPrefs {
kvs: [("Party".to_string(), Param::Toggle(enabled))]
.into_iter()
.collect(),
}
}
fn set_param(&mut self, bulb: &BulbId, name: &str, param: Param) {
if name != "Party" {
error!("invalit param name");
return;
}
// TODO: should be toggle
let Param::Toggle(enabled) = param else {
error!("invalit param kind");
return;
};
if !enabled {
self.party_tasks.remove(bulb);
} else {
let task = spawn(party_task(self.manager.clone(), bulb.clone()));
self.party_tasks
.insert(bulb.clone(), DeadMansHandle(task.abort_handle()));
}
}
}
async fn party_task(manager: BulbManager, id: BulbId) {
manager
.until_interrupted(id.clone(), async {
let mut h: f32 = random();
loop {
sleep(Duration::from_millis(50)).await;
h += 0.01;
if h > 1.0 {
h = 0.0;
}
let color = BulbColor::HSB { h, s: 1.0, b: 1.0 };
manager
.send_command(BulbCommand::SetColor(BulbSelector::Id(id.clone()), color))
.await;
}
})
.await;
}

View File

@ -1,188 +0,0 @@
use std::{collections::HashMap, time::Duration};
use chrono::{DateTime, Datelike, Local, NaiveTime, Weekday};
use common::{BulbPrefs, Param};
use lighter_lib::{BulbColor, BulbId};
use lighter_manager::manager::{BulbCommand, BulbManager, BulbSelector};
use tokio::{spawn, time::sleep};
use crate::util::DeadMansHandle;
use super::LightScript;
pub struct Waker {
manager: BulbManager,
wake_times: HashMap<BulbId, HashMap<Weekday, NaiveTime>>,
wake_tasks: HashMap<(BulbId, Weekday), DeadMansHandle>,
}
impl Waker {
pub fn create(manager: BulbManager) -> Self {
Waker {
manager,
wake_times: Default::default(),
wake_tasks: Default::default(),
}
}
}
const TIME_FMT: &str = "%H:%M";
impl LightScript for Waker {
fn get_params(&mut self, bulb: &BulbId) -> BulbPrefs {
let settings = self.wake_times.entry(bulb.clone()).or_default();
let kvs = DAYS_OF_WEEK
.iter()
.map(|day| {
let time = match settings.get(day) {
Some(time) => time.format(TIME_FMT).to_string(),
None => String::new(),
};
(format!("{day:?}"), Param::String(time))
})
.collect();
BulbPrefs { kvs }
}
fn set_param(&mut self, bulb: &BulbId, name: &str, time: super::Param) {
let settings = self.wake_times.entry(bulb.clone()).or_default();
let Param::String(time) = time else {
error!("invalit param kind");
return;
};
let time = NaiveTime::parse_from_str(&time, TIME_FMT)
.map(Some)
.unwrap_or(None);
let weekday = match name {
"Mon" => Weekday::Mon,
"Tue" => Weekday::Tue,
"Wed" => Weekday::Wed,
"Thu" => Weekday::Thu,
"Fri" => Weekday::Fri,
"Sat" => Weekday::Sat,
"Sun" => Weekday::Sun,
_ => {
error!("invalit param name");
return;
}
};
let Some(time) = time else {
settings.remove(&weekday);
self.wake_tasks.remove(&(bulb.clone(), weekday));
return;
};
settings.insert(weekday, time);
let task = spawn(wake_task(self.manager.clone(), bulb.clone(), weekday, time));
self.wake_tasks
.insert((bulb.clone(), weekday), DeadMansHandle(task.abort_handle()));
}
}
const DAYS_OF_WEEK: &[Weekday] = &[
Weekday::Mon,
Weekday::Tue,
Weekday::Wed,
Weekday::Thu,
Weekday::Fri,
Weekday::Sat,
Weekday::Sun,
];
async fn wake_task(manager: BulbManager, id: BulbId, day: Weekday, time: NaiveTime) {
let mut alarm = next_alarm(Local::now(), day, time);
loop {
info!("waking lamp {id:?} at {alarm}");
sleep((alarm - Local::now()).to_std().unwrap()).await;
if let Some(bulb) = manager.bulbs().await.get(&id) {
// don't wake the bulb if it's already turned on
if bulb.power {
continue;
}
} else {
warn!("bulb {id:?} does not exist");
return;
};
info!("waking lamp {id:?}");
let r = manager
.until_interrupted(id.clone(), async {
// slowly turn up brightness of bulb
for brightness in (1..=75).map(|i| (i as f32) * 0.01) {
//sleep(Duration::from_secs(12)).await;
sleep(Duration::from_millis(500)).await;
manager
.send_command(BulbCommand::SetColor(
BulbSelector::Id(id.clone()),
BulbColor::Kelvin {
t: 0.0,
b: brightness,
},
))
.await
}
})
.await;
if r.is_none() {
info!("interrupted waking lamp {id:?}");
}
alarm = next_alarm(Local::now(), day, time);
}
}
/// Get the next alarm, from a weekday+time schedule.
fn next_alarm(now: DateTime<Local>, day: Weekday, time: NaiveTime) -> DateTime<Local> {
let day_of_alarm = day.num_days_from_monday() as i64;
let day_now = now.weekday().num_days_from_monday() as i64;
let alarm = now + chrono::Duration::days(day_of_alarm - day_now);
let mut alarm = alarm
.date_naive()
.and_time(time)
.and_local_timezone(Local)
.unwrap();
if alarm <= now {
alarm += chrono::Duration::weeks(1);
}
alarm
}
#[cfg(test)]
mod test {
use super::next_alarm;
use chrono::{offset::TimeZone, Local, NaiveTime, Weekday};
#[test]
fn test_alarm_date() {
const FMT: &str = "%Y-%m-%d %H:%M";
let now = Local.datetime_from_str("2022-10-18 15:30", FMT).unwrap();
let test_values = [
(Weekday::Tue, (16, 30), "2022-10-18 16:30"),
(Weekday::Tue, (14, 30), "2022-10-25 14:30"),
(Weekday::Wed, (15, 30), "2022-10-19 15:30"),
(Weekday::Mon, (15, 30), "2022-10-24 15:30"),
];
for (day, (hour, min), expected) in test_values {
let expected = Local.datetime_from_str(expected, FMT).unwrap();
assert_eq!(
next_alarm(now, day, NaiveTime::from_hms(hour, min, 0)),
expected
);
}
}
}

View File

@ -1,15 +0,0 @@
use tokio::task::AbortHandle;
pub struct DeadMansHandle(pub AbortHandle);
impl From<AbortHandle> for DeadMansHandle {
fn from(abort: AbortHandle) -> Self {
DeadMansHandle(abort)
}
}
impl Drop for DeadMansHandle {
fn drop(&mut self) {
self.0.abort();
}
}

View File

@ -1,6 +1,6 @@
[package] [package]
name = "common" name = "common"
version = "0.2.3" version = "0.2.2"
edition = "2021" edition = "2021"
[dependencies] [dependencies]

View File

@ -1,5 +1,6 @@
use std::collections::BTreeMap; use std::collections::HashMap;
use chrono::{NaiveTime, Weekday};
use lighter_lib::{BulbColor, BulbId, BulbMode}; use lighter_lib::{BulbColor, BulbId, BulbMode};
use serde::{Deserialize, Serialize}; use serde::{Deserialize, Serialize};
@ -14,7 +15,7 @@ pub enum ServerMessage {
BulbState { BulbState {
id: BulbId, id: BulbId,
mode: BulbMode, mode: BulbMode,
prefs: BTreeMap<ScriptId, BulbPrefs>, wake_schedule: HashMap<Weekday, NaiveTime>,
}, },
BulbMap(BulbMap), BulbMap(BulbMap),
@ -34,11 +35,10 @@ pub enum ClientMessage {
id: BulbId, id: BulbId,
power: bool, power: bool,
}, },
SetBulbPref { SetBulbWakeTime {
bulb: BulbId, id: BulbId,
script: ScriptId, day: Weekday,
name: String, time: Option<NaiveTime>,
value: Param,
}, },
} }
@ -78,16 +78,3 @@ impl BulbGroupShape {
} }
} }
} }
pub type ScriptId = String;
#[derive(Clone, Debug, PartialEq, Eq, Serialize, Deserialize)]
pub enum Param {
String(String),
Toggle(bool),
}
#[derive(Clone, Debug, Default, PartialEq, Eq, Serialize, Deserialize)]
pub struct BulbPrefs {
pub kvs: BTreeMap<String, Param>,
}

View File

@ -1,6 +1,6 @@
[package] [package]
name = "hemma_web" name = "hemma_web"
version = "0.2.3" version = "0.2.2"
authors = ["Joakim Hulthe <joakim@hulthe.net"] authors = ["Joakim Hulthe <joakim@hulthe.net"]
edition = "2021" edition = "2021"

View File

@ -12,8 +12,10 @@
<link rel="stylesheet" href="https://fonts.googleapis.com/css?family=Ubuntu|Ubuntu+Mono&display=swap"> <link rel="stylesheet" href="https://fonts.googleapis.com/css?family=Ubuntu|Ubuntu+Mono&display=swap">
<!-- pwa manifest --> <!-- pwa manifest -->
<!--
<link data-trunk rel="copy-file" href="/static/manifest.json"> <link data-trunk rel="copy-file" href="/static/manifest.json">
<link rel="manifest" href="/manifest.json"> <link rel="manifest" href="/static/manifest.json">
-->
<!-- copy image directory --> <!-- copy image directory -->
<link data-trunk rel="copy-dir" href="/static/images"> <link data-trunk rel="copy-dir" href="/static/images">
@ -24,7 +26,7 @@
<link rel="preload" href="/images/penguin3.svg" as="image"> <link rel="preload" href="/images/penguin3.svg" as="image">
<!-- icon --> <!-- icon -->
<link rel="icon" type="image/png" href="/images/penguin2.svg"> <link rel="icon" type="image/png" href="/images/icon.png">
<title>hemma</title> <title>hemma</title>
<meta name="description" content="Home automation and information"> <meta name="description" content="Home automation and information">

View File

@ -1,24 +1,31 @@
use crate::components::color_picker::{ColorPicker, ColorPickerMsg}; use crate::components::color_picker::{ColorPicker, ColorPickerMsg};
use crate::css::C; use crate::css::C;
use common::{BulbGroup, BulbGroupShape, BulbMap, BulbPrefs, ClientMessage, Param, ServerMessage}; use chrono::{NaiveTime, Weekday};
use common::{BulbGroup, BulbGroupShape, BulbMap, ClientMessage, ServerMessage};
use lighter_lib::{BulbId, BulbMode}; use lighter_lib::{BulbId, BulbMode};
use seed::{attrs, button, div, empty, h2, input, table, td, tr, C}; use seed::{attrs, button, div, h1, h2, h3, input, label, span, table, td, tr, C};
use seed::{prelude::*, IF}; use seed::{prelude::*, IF};
use seed_router::Page; use seed_router::Page;
use std::collections::{BTreeMap, HashSet}; use std::collections::{BTreeMap, HashMap, HashSet};
use std::fmt::Write; use std::fmt::Write;
use std::iter::repeat;
/// /lights page /// /lights page
#[derive(Default)] #[derive(Default)]
pub struct Model { pub struct Model {
bulb_states: BTreeMap<BulbId, BulbState>, bulb_states: BTreeMap<BulbId, BulbState>,
select_mode: SelectMode,
bulb_groups: BTreeMap<String, Vec<BulbId>>,
bulb_map: BulbMap, bulb_map: BulbMap,
/// the currently selected bulb map groups /// the currently selected bulbs on the map
selected_groups: HashSet<usize>, selected_groups: HashSet<usize>,
/// the currently selected bulbs on the list
selected_bulbs: HashSet<BulbId>,
/// whether the currently selected map groups have been interacted with /// whether the currently selected map groups have been interacted with
groups_interacted: bool, groups_interacted: bool,
@ -28,7 +35,7 @@ pub struct Model {
#[derive(Default, Clone)] #[derive(Default, Clone)]
struct BulbState { struct BulbState {
mode: BulbMode, mode: BulbMode,
prefs: BTreeMap<String, BulbPrefs>, wake_schedule: HashMap<Weekday, NaiveTime>,
} }
#[derive(Debug)] #[derive(Debug)]
@ -37,15 +44,20 @@ pub enum Msg {
SelectGroup(usize), SelectGroup(usize),
DeselectGroups, DeselectGroups,
SelectBulb(BulbId),
ColorPicker(ColorPickerMsg), ColorPicker(ColorPickerMsg),
SetBulbPower(bool), SetBulbPower(bool),
LightTime(String, Weekday),
SetSelectMode(SelectMode),
}
/// Set a script parameter value for all selected bulbs. #[derive(Debug, Clone, Default, PartialEq, Eq)]
SetParam { pub enum SelectMode {
script: String, #[default]
name: String, Map,
value: Param, List,
},
} }
impl Page for Model { impl Page for Model {
@ -64,14 +76,12 @@ impl Page for Model {
ServerMessage::BulbState { ServerMessage::BulbState {
id, id,
mode: new_mode, mode: new_mode,
prefs, wake_schedule,
} => { } => {
*self.bulb_states.entry(id).or_default() = BulbState { *self.bulb_states.entry(id).or_default() = BulbState {
mode: new_mode, mode: new_mode,
prefs, wake_schedule,
}; };
//color_picker.set_color(mode.color);
} }
ServerMessage::BulbMap(bulb_map) => { ServerMessage::BulbMap(bulb_map) => {
self.bulb_map = bulb_map; self.bulb_map = bulb_map;
@ -106,6 +116,11 @@ impl Page for Model {
} }
} }
} }
Msg::SelectBulb(bulb) => {
if !self.selected_bulbs.remove(&bulb) {
self.selected_bulbs.insert(bulb);
}
}
Msg::ColorPicker(ColorPickerMsg::SetColor(color)) => { Msg::ColorPicker(ColorPickerMsg::SetColor(color)) => {
self.groups_interacted = true; self.groups_interacted = true;
self.for_selected_bulbs(|id, _| { self.for_selected_bulbs(|id, _| {
@ -130,56 +145,34 @@ impl Page for Model {
orders.notify(message); orders.notify(message);
}); });
} }
Msg::SetParam { Msg::LightTime(time, day) => {
script, if time.is_empty() {
name, self.for_selected_bulbs(|id, _| {
value, let message = ClientMessage::SetBulbWakeTime {
} => { id: id.clone(),
self.for_selected_bulbs(|id, bulb| { day,
bulb.prefs time: None,
.get_mut(&script) };
.unwrap() //TOD orders.notify(message);
.kvs });
.insert(name.clone(), value.clone()); } else if let Ok(time) = NaiveTime::parse_from_str(&time, "%H:%M") {
let message = ClientMessage::SetBulbPref { self.for_selected_bulbs(|id, _| {
bulb: id.clone(), let message = ClientMessage::SetBulbWakeTime {
script: script.clone(), id: id.clone(),
name: name.clone(), day,
value: value.clone(), time: Some(time),
}; };
orders.notify(message); orders.notify(message);
}); });
} }
} }
Msg::SetSelectMode(mode) => {
self.select_mode = mode;
}
}
} }
fn view(&self) -> Node<Self::Msg> { fn view(&self) -> Node<Self::Msg> {
//let view_bulb = |(id, (mode, color_picker)): (&BulbId, &(BulbMode, ColorPicker))| {
// div![
// C![C.bulb_box],
// h1![id],
// div![
// C![C.bulb_controls],
// {
// let id = id.clone();
// color_picker.view().map_msg(|msg| Msg::ColorPicker(id, msg))
// },
// button![
// if mode.power {
// C![C.bulb_power_button, C.bulb_power_button_on]
// } else {
// C![C.bulb_power_button]
// },
// {
// let id = id.clone();
// let power = !mode.power;
// ev(Ev::Click, move |_| Msg::SetBulbPower(id, power))
// },
// ],
// ],
// ]
//};
let bulb_map_width = self let bulb_map_width = self
.bulb_map .bulb_map
.groups .groups
@ -196,7 +189,7 @@ impl Page for Model {
.max() .max()
.unwrap_or(0); .unwrap_or(0);
let view_bulb_group = |(i, group): (usize, &BulbGroup)| { let bulb_group_map = |(i, group): (usize, &BulbGroup)| {
let (w, h) = (group.shape.width(), group.shape.height()); let (w, h) = (group.shape.width(), group.shape.height());
let mut style = String::new(); let mut style = String::new();
write!( write!(
@ -227,64 +220,100 @@ impl Page for Model {
] ]
}; };
let selected_bulb = self let bulb_group_list = |(_i, group): (usize, &BulbGroup)| {
.selected_groups div![
C![C.bulb_list_group],
h1![&group.name],
group.bulbs.iter().map(|bulb| {
let select_ev = || {
let bulb = bulb.clone();
ev(Ev::Click, |_| Msg::SelectBulb(bulb))
};
button![
C![C.bulb_list_bulb],
select_ev(),
div![
C![C.bulb_list_checkbox],
label![
C![C.container],
input![
attrs! { At::Type => "checkbox" },
IF!(self.selected_bulbs.contains(bulb) => attrs! { At::Checked => true }),
select_ev(),
],
div![C![C.checkmark]],
],
],
span![bulb],
]
}),
]
};
// pick one (arbitrary) selected bulb to pull values for the controls from
let selected_bulb = if let SelectMode::Map = self.select_mode {
self.selected_groups
.iter() .iter()
.next() .next()
.and_then(|&index| self.bulb_map.groups.get(index)) .and_then(|&index| self.bulb_map.groups.get(index))
.and_then(|group| group.bulbs.first()) .and_then(|group| group.bulbs.first())
.and_then(|id| self.bulb_states.get(id)); .and_then(|id| self.bulb_states.get(id))
let script_param = |script: &str, name: &str, value: &Param| {
let name = name.to_string();
let script = script.to_string();
match value {
Param::String(value) => tr![
C![C.pref_line],
td![&name],
td![input![
C![C.pref_input],
attrs! {At::Placeholder => &script},
attrs! {At::Value => value},
input_ev(Ev::Input, move |input| Msg::SetParam {
script,
name,
value: Param::String(input),
})
]]
],
&Param::Toggle(value) => {
tr![
C![C.pref_line],
button![
if value {
C![C.pref_button_enabled]
} else { } else {
C![C.pref_button] self.selected_bulbs
}, .iter()
&name, .next()
input_ev(Ev::Click, move |_| Msg::SetParam { .and_then(|id| self.bulb_states.get(id))
script, };
name,
value: Param::Toggle(!value), let calendar_day = |day: Weekday| {
}) let time = selected_bulb
.and_then(|b| b.wake_schedule.get(&day))
.map(|t| t.to_string())
.unwrap_or_default();
tr![
C![C.calendar_day],
td![day.to_string()],
td![input![
C![C.calendar_time_input],
attrs! {At::Placeholder => time},
input_ev(Ev::Input, move |input| Msg::LightTime(input, day))
]],
] ]
]
}
}
}; };
div![ div![
C![C.bulb_box], C![C.bulb_box],
div![ div![
C![C.selector_selector],
button![
"Map",
ev(Ev::Click, move |_| Msg::SetSelectMode(SelectMode::Map))
],
div![
C![C.selector_selector_arrow],
IF!(self.select_mode == SelectMode::Map =>
attrs! { At::Style => "transform: rotateY(180deg);"}),
],
button![
"List",
ev(Ev::Click, move |_| Msg::SetSelectMode(SelectMode::List))
],
],
match self.select_mode {
SelectMode::Map => div![
C![C.bulb_map], C![C.bulb_map],
attrs! { attrs! {
At::Style => format!("min-width: {}rem; height: {}rem;", bulb_map_width, bulb_map_height), At::Style => format!("min-width: {}rem; height: {}rem;", bulb_map_width, bulb_map_height),
}, },
ev(Ev::Click, |_| Msg::DeselectGroups), ev(Ev::Click, |_| Msg::DeselectGroups),
self.bulb_map.groups.iter().enumerate().map(view_bulb_group), self.bulb_map.groups.iter().enumerate().map(bulb_group_map),
], ],
SelectMode::List => div![
C![C.bulb_list],
self.bulb_map.groups.iter().enumerate().map(bulb_group_list),
],
},
div![ div![
C![C.bulb_controls], C![C.bulb_controls],
IF!(selected_bulb.is_none() => C![C.cross_out]), IF!(selected_bulb.is_none() => C![C.cross_out]),
@ -307,35 +336,37 @@ impl Page for Model {
], ],
], ],
div![ div![
C![C.prefs_box], C![C.calendar_box],
IF!(selected_bulb.is_none() => C![C.cross_out]), IF!(selected_bulb.is_none() => C![C.cross_out]),
h2!["Settings"], h2!["Wake Schedule"],
if let Some(selected_bulb) = selected_bulb { table![
table![selected_bulb calendar_day(Weekday::Mon),
.prefs calendar_day(Weekday::Tue),
.iter() calendar_day(Weekday::Wed),
.flat_map(|(script, prefs)| repeat(script).zip(prefs.kvs.iter())) calendar_day(Weekday::Thu),
.map(|(script, (name, value))| script_param(script, name, value))] calendar_day(Weekday::Fri),
} else { calendar_day(Weekday::Sat),
empty![] calendar_day(Weekday::Sun),
}, ],
], ],
] ]
} }
} }
impl Model { impl Model {
fn for_selected_bulbs(&mut self, mut f: impl FnMut(&BulbId, &mut BulbState)) { fn for_selected_bulbs(&self, mut f: impl FnMut(&BulbId, &BulbState)) {
for &index in &self.selected_groups { if let SelectMode::Map = self.select_mode {
let Some(group) = self.bulb_map.groups.get(index) else { self.selected_groups
continue; .iter()
}; .filter_map(|&index| self.bulb_map.groups.get(index))
.flat_map(|group| group.bulbs.iter())
for id in group.bulbs.iter() { .filter_map(|id| self.bulb_states.get(id).map(|bulb| (id, bulb)))
if let Some(bulb) = self.bulb_states.get_mut(id) { .for_each(|(id, bulb)| f(id, bulb));
f(id, bulb); } else {
} self.selected_bulbs
} .iter()
.filter_map(|id| self.bulb_states.get(id).map(|bulb| (id, bulb)))
.for_each(|(id, bulb)| f(id, bulb));
} }
} }
} }

View File

@ -0,0 +1,5 @@
<?xml version="1.0" encoding="utf-8"?>
<svg viewBox="0 0 500 500" xmlns="http://www.w3.org/2000/svg" xmlns:bx="https://boxy-svg.com">
<ellipse style="vector-effect: non-scaling-stroke; stroke-width: 0px; stroke: rgb(245, 222, 179); fill: rgb(245, 222, 179);" cx="250" cy="250" rx="250" ry="250"/>
<path d="M 59.4 209.201 H 308.253 L 274.16 131.459 L 447.051 254.953 L 274.16 378.446 L 308.253 300.704 H 59.4 V 209.201 Z" style="transform-origin: 447.051px 254.952px; stroke-width: 16px; stroke: rgb(193, 168, 123);" bx:shape="arrow 59.4 131.459 387.651 246.987 91.503 172.891 34.093 1@d4e47a6f"/>
</svg>

After

Width:  |  Height:  |  Size: 607 B

View File

@ -1,52 +0,0 @@
<?xml version="1.0" encoding="UTF-8" standalone="no"?>
<svg
width="160"
height="160"
viewBox="0 0 42.333333 42.333333"
version="1.1"
id="svg8"
xmlns="http://www.w3.org/2000/svg"
xmlns:svg="http://www.w3.org/2000/svg"
xmlns:rdf="http://www.w3.org/1999/02/22-rdf-syntax-ns#"
xmlns:cc="http://creativecommons.org/ns#"
xmlns:dc="http://purl.org/dc/elements/1.1/">
<defs
id="defs2" />
<metadata
id="metadata5">
<rdf:RDF>
<cc:Work
rdf:about="">
<dc:format>image/svg+xml</dc:format>
<dc:type
rdf:resource="http://purl.org/dc/dcmitype/StillImage" />
</cc:Work>
</rdf:RDF>
</metadata>
<rect
style="fill:#302f3b;fill-opacity:1;stroke:none;stroke-width:13.5876;stroke-linecap:round"
id="rect1"
width="42.333332"
height="42.333332"
x="0"
y="0" />
<g
id="layer1"
style="display:inline;fill:#ffffff"
transform="translate(5.2916666,4.9872409)">
<path
style="fill:#ffffff;stroke-width:0.177246"
d="m 13.134179,31.651166 c -1.367874,-0.18043 -3.4872278,-0.85238 -4.780367,-1.51563 -1.871747,-0.96002 -4.179215,-3.22966 -5.0074297,-4.92534 -1.5914865,-3.25839 -1.6801158,-7.72336 -0.2278948,-11.48085 1.0247424,-2.65144 2.7098602,-4.5706201 5.4768881,-6.2376401 4.4640374,-2.6894 6.9208324,-4.59636 8.5218534,-6.61464 0.435944,-0.54955 0.851411,-0.9404 0.923263,-0.86855 0.34663,0.34663 0.709996,2.45556 0.596276,3.46071 l -0.118698,1.04918 0.543199,-0.3868 c 0.298763,-0.21273 0.754695,-0.66407 1.013185,-1.00297 0.258491,-0.3389 0.531184,-0.55268 0.605988,-0.47507 0.277608,0.28804 0.872923,2.3693 0.872923,3.05181 0,0.78189 -0.07309,0.70941 2.140938,2.12277 3.360595,2.14527 5.28622,5.2741001 5.845846,9.4985401 0.238089,1.79727 0.119928,4.12317 -0.289284,5.69424 -0.438918,1.68512 -1.295306,3.20011 -2.596637,4.59356 -2.715779,2.90803 -6.119638,4.1954 -10.928887,4.13338 -1.132683,-0.0146 -2.298705,-0.0581 -2.591161,-0.0967 z m 5.683631,-1.1265 c 5.074026,-0.89873 8.492767,-3.70496 9.49005,-7.7898 0.358508,-1.46844 0.317005,-5.28368 -0.07569,-6.95754 -0.594746,-2.53514 -2.005266,-4.78931 -3.64922,-5.8318801 -1.428352,-0.90583 -1.561881,-0.82384 -2.840659,1.7442101 -0.615739,1.23654 -1.777129,3.21756 -2.580868,4.40229 l -1.461342,2.15404 0.927607,0.3153 c 1.188141,0.40386 2.476979,1.20634 2.848748,1.77373 0.272049,0.4152 0.269021,0.4806 -0.04735,1.02231 -0.778356,1.33273 -2.272203,1.79512 -5.849412,1.81056 l -2.340153,0.0101 -2.489801,2.46697 c -2.6276133,2.60352 -2.8788341,3.03045 -2.0880964,3.54856 1.8126654,1.18771 7.0732674,1.8772 10.1561944,1.33115 z m 3.183004,-13.17071 c -0.205126,-0.14999 -0.329285,-0.4602 -0.329285,-0.8227 0,-0.96498 1.087198,-1.43355 1.715448,-0.73934 0.872429,0.96402 -0.338235,2.3283 -1.386163,1.56204 z m -3.186586,4.78402 c 1.133944,-0.30198 1.619925,-0.56299 1.85054,-0.9939 0.246861,-0.46126 -0.269147,-0.94676 -1.770094,-1.66543 -1.062457,-0.50872 -1.296906,-0.55176 -3.013183,-0.55311 -1.794444,-0.001 -1.910137,0.0225 -3.231141,0.66815 -1.860639,0.90936 -2.118197,1.48499 -0.948717,2.12031 1.182601,0.64245 5.357705,0.89133 7.112595,0.42398 z m -5.26747,-0.96936 c -1.113796,-0.13246 -1.303724,-0.23853 -1.149022,-0.64168 0.08921,-0.23246 0.582443,-0.27351 3.286452,-0.27351 1.749822,0 3.307658,0.0484 3.461858,0.10758 0.350902,0.13466 0.365077,0.53097 0.02367,0.66198 -0.432127,0.16582 -4.555272,0.2726 -5.622968,0.14563 z m -3.7845902,-3.81466 c 0.7343882,-0.537 0.2478022,-1.88618 -0.6802563,-1.88618 -0.5030742,0 -0.9992445,0.51278 -0.9992445,1.03268 0,0.90987 0.9453857,1.39029 1.6795008,0.8535 z"
id="path865" />
<path
style="fill:#ffffff;fill-opacity:1;stroke:#000000;stroke-width:0;stroke-linecap:butt;stroke-linejoin:miter;stroke-miterlimit:4;stroke-dasharray:none;stroke-opacity:1"
d="m 7.5967544,-6.2400058 c 0,0 -0.041418,0.1031026 -0.02862,0.2093299 0.012798,0.1062273 0.084435,0.1741091 0.084435,0.1741091 l -0.083147,0.088222 c 0,0 -0.1053512,-0.138166 -0.073877,-0.2774823 0.031474,-0.1393166 0.1012092,-0.1941783 0.101209,-0.1941787 z"
id="path1039" />
</g>
<g
id="layer2"
style="display:none" />
<g
id="layer3"
style="display:none" />
</svg>

Before

Width:  |  Height:  |  Size: 4.1 KiB

Binary file not shown.

Before

Width:  |  Height:  |  Size: 4.7 KiB

Binary file not shown.

Before

Width:  |  Height:  |  Size: 5.3 KiB

Binary file not shown.

Before

Width:  |  Height:  |  Size: 7.2 KiB

Binary file not shown.

Before

Width:  |  Height:  |  Size: 20 KiB

Binary file not shown.

Before

Width:  |  Height:  |  Size: 2.6 KiB

View File

@ -1,76 +0,0 @@
<?xml version="1.0" encoding="UTF-8" standalone="no"?>
<svg
width="900px"
height="900px"
viewBox="0 0 900 900"
version="1.1"
xml:space="preserve"
id="SVGRoot"
inkscape:version="1.3.1 (91b66b0783, 2023-11-16, custom)"
sodipodi:docname="light.svg"
xmlns:inkscape="http://www.inkscape.org/namespaces/inkscape"
xmlns:sodipodi="http://sodipodi.sourceforge.net/DTD/sodipodi-0.dtd"
xmlns="http://www.w3.org/2000/svg"
xmlns:svg="http://www.w3.org/2000/svg"><defs
id="defs2" />
<sodipodi:namedview
pagecolor="#302f3b"
bordercolor="#292929"
borderopacity="1"
inkscape:showpageshadow="2"
inkscape:pageopacity="0.0"
inkscape:pagecheckerboard="0"
inkscape:deskcolor="#232323"
id="namedview1"
inkscape:zoom="0.64016282"
inkscape:cx="414.73824"
inkscape:cy="449.88555"
inkscape:window-width="1684"
inkscape:window-height="1010"
inkscape:window-x="0"
inkscape:window-y="0"
inkscape:window-maximized="1"
inkscape:current-layer="SVGRoot" />
<style
type="text/css"
id="style1">
g.prefab path {
vector-effect:non-scaling-stroke;
-inkscape-stroke:hairline;
fill: none;
fill-opacity: 1;
stroke-opacity: 1;
stroke: #00349c;
}
</style>
<circle
style="fill:#000000;fill-opacity:0.00697072;stroke:#ffffff;stroke-opacity:1;stroke-width:48;stroke-dasharray:none"
id="path3"
cx="450"
cy="450"
r="120" /><path
style="fill:#000000;fill-opacity:0.00697069;stroke:#ffffff;stroke-width:51.2769;stroke-dasharray:none;stroke-opacity:1;stroke-linecap:round"
d="M 450,252 V 52"
id="path4" /><path
style="fill:#000000;fill-opacity:0.00697069;stroke:#ffffff;stroke-width:51.2769;stroke-dasharray:none;stroke-opacity:1;stroke-linecap:round"
d="m 450.00045,848.81135 v -200"
id="path4-6" /><path
style="fill:#000000;fill-opacity:0.00697069;stroke:#ffffff;stroke-width:51.2769;stroke-dasharray:none;stroke-opacity:1;stroke-linecap:round"
d="m 648.4059,450.40545 h 200"
id="path5" /><path
style="fill:#000000;fill-opacity:0.00697069;stroke:#ffffff;stroke-width:51.2769;stroke-dasharray:none;stroke-opacity:1;stroke-linecap:round"
d="m 51.59455,450.4059 h 200"
id="path6" /><path
style="fill:#000000;fill-opacity:0.00697069;stroke:#ffffff;stroke-width:51.2769;stroke-dasharray:none;stroke-opacity:1;stroke-linecap:round"
d="M 590.29406,310.11152 731.71542,168.69016"
id="path7" /><path
style="fill:#000000;fill-opacity:0.00697069;stroke:#ffffff;stroke-width:51.2769;stroke-dasharray:none;stroke-opacity:1;stroke-linecap:round"
d="M 168.28503,732.12119 309.70639,590.69983"
id="path8" /><path
style="fill:#000000;fill-opacity:0.00697069;stroke:#ffffff;stroke-width:51.2769;stroke-dasharray:none;stroke-opacity:1;stroke-linecap:round"
d="M 590.29438,590.69951 731.71574,732.12087"
id="path9" /><path
style="fill:#000000;fill-opacity:0.00697069;stroke:#ffffff;stroke-width:51.2769;stroke-dasharray:none;stroke-opacity:1;stroke-linecap:round"
d="M 168.28471,168.69048 309.70607,310.11184"
id="path10" /></svg>

Before

Width:  |  Height:  |  Size: 3.0 KiB

View File

@ -1,17 +0,0 @@
{
"name": "Hemma",
"short_name": "Hemma",
"start_url": "/lights",
"display": "standalone",
"background_color": "#302f3b",
"description": "Styr lampor",
"icons": [
{ "src": "/images/icon_x72.png", "sizes": "72x72", "type": "image/png", "purpose": "maskable" },
{ "src": "/images/icon_x128.png", "sizes": "128x128", "type": "image/png", "purpose": "maskable" },
{ "src": "/images/icon_x144.png", "sizes": "144x144", "type": "image/png", "purpose": "maskable" },
{ "src": "/images/icon_x192.png", "sizes": "192x192", "type": "image/png", "purpose": "maskable" },
{ "src": "/images/icon_x512.png", "sizes": "512x512", "type": "image/png", "purpose": "maskable" },
{ "src": "/images/icon.svg", "sizes": "513x512", "purpose": "maskable" }
]
}

View File

@ -102,6 +102,42 @@ body {
margin-bottom: 1.5rem; margin-bottom: 1.5rem;
} }
/* lol i'm so funny */
.selector_selector {
margin-bottom: 0;
display: flex;
justify-content: center;
//background: #534f44;
}
.selector_selector > button {
width: 10rem;
border: solid 0.1rem wheat;
background-color: #3a3743;
color: white;
font-size: 1.5rem;
border-left: solid white 0.1rem;
border-right: solid white 0.1rem;
}
.selector_selector > button:hover {
background-color: #4c4858;
}
.selector_selector > button:active {
background-color: #312e38;
}
.selector_selector > button:first-child {
border-top-left-radius: 0.5rem;
}
.selector_selector > button:last-child {
border-top-right-radius: 0.5rem;
}
.selector_selector_arrow {
position: absolute;
width: 2.15rem;
height: 2.15rem;
background: url("/images/circle-arrow.svg");
transition: transform 0.5s ease-in-out;
}
.bulb_controls { .bulb_controls {
display: flex; display: flex;
flex-direction: row; flex-direction: row;
@ -150,6 +186,47 @@ body {
} }
@keyframes to_width_90 { to { width: 90%; } } @keyframes to_width_90 { to { width: 90%; } }
.bulb_list {
display: flex;
flex-direction: column;
}
.bulb_list_group {
display: flex;
flex-direction: column;
}
.bulb_list_group > h1 {
margin-top: 0.6em;
margin-bottom: 0;
font-size: 1.3em;
border-bottom: solid 1px;
}
.bulb_list_bulb {
font-family: Ubuntu Mono;
display: flex;
font-size: 0.8em;
padding-top: 0.5em;
padding-bottom: 0.5em;
margin-top: 0.3em;
background-color: #3a3743;
border: solid 0.2em #45374f;
border-radius: 0.5em;
color: wheat;
}
.bulb_list_bulb:hover {
background-color: #4c4858;
}
.bulb_list_bulb:active {
background-color: #312e38;
}
.bulb_list_bulb > span {
margin: auto;
flex-grow: 1;
padding-right: 1em;
}
.bulb_map { .bulb_map {
background: url(images/blueprint_bg.png); background: url(images/blueprint_bg.png);
background-size: auto; background-size: auto;
@ -304,16 +381,14 @@ body {
transition: margin 0.1s ease-out; transition: margin 0.1s ease-out;
} }
.calendar_day {
.pref_line {
display: flex; display: flex;
flex-direction: row; flex-direction: row;
justify-content: space-between; justify-content: space-between;
margin-top: .3em; margin-top: .3em;
} }
.pref_input { .calendar_time_input {
background: #453f4b; background: #453f4b;
border: solid 0.35em #5b3f63; border: solid 0.35em #5b3f63;
border-radius: .3em; border-radius: .3em;
@ -325,49 +400,79 @@ body {
margin-left: .5em; margin-left: .5em;
} }
.pref_button {} .calendar_box {
.pref_button, .pref_button_enabled {
position: relative;
width: 100%;
font-size: large;
font-weight: bold;
color: white;
text-shadow: 0.1rem 0.1rem 0.3rem black;
padding: 1rem;
border: solid 0.35em #5b3f63;
border-radius: 0.3em;
background: transparent;
overflow: hidden;
}
.pref_button_enabled::before {
content: "";
z-index: -1;
width: 20rem;
height: 20rem;
background-size: 100% 100%;
background-image: url(/images/hsb.png);
position: absolute;
transform: translate(-8.5rem, -2.5rem);
animation: infinite linear 3s button_rainbow;
}
@keyframes button_rainbow {
from { transform: translate(-8.5rem, -2.5rem) rotate( 0deg); }
to { transform: translate(-8.5rem, -2.5rem) rotate(360deg); }
}
.prefs_box {
display: flex; display: flex;
justify-content: center; justify-content: center;
} }
.prefs_box > h2 { .calendar_box > h2 {
writing-mode: sideways-lr; writing-mode: sideways-lr;
margin-top: auto; margin-top: auto;
margin-bottom: auto; margin-bottom: auto;
} }
.prefs_box > * { .calendar_box > * {
flex-shrink: 1; flex-shrink: 1;
} }
.bulb_list_checkbox {}
.bulb_list_checkbox input[type="checkbox"] {
visibility: hidden;
display: none;
}
.bulb_list_checkbox *,
.bulb_list_checkbox ::after,
.bulb_list_checkbox ::before {
box-sizing: border-box;
}
.bulb_list_checkbox .container {
display: block;
position: relative;
cursor: pointer;
font-size: 25px;
user-select: none;
}
/* Create a custom checkbox */
.bulb_list_checkbox .checkmark {
position: relative;
top: 0;
left: 0;
height: 1.3em;
width: 1.3em;
background: black;
border-radius: 50px;
transition: all 0.7s;
--spread: 10px;
}
/* When the checkbox is checked, add a blue background */
.bulb_list_checkbox .container input:checked ~ .checkmark {
background: black;
/* spawn a bunch of colored balls and blur them together */
box-shadow: -5px -5px var(--spread) 0px #5B51D8, 0 -5px var(--spread) 0px #833AB4, 5px -5px var(--spread) 0px #E1306C, 5px 0 var(--spread) 0px #FD1D1D, 5px 5px var(--spread) 0px #F77737, 0 5px var(--spread) 0px #FCAF45, -5px 5px var(--spread) 0px #FFDC80;
}
/* Create the checkmark/indicator (hidden when not checked) */
.bulb_list_checkbox .checkmark::after {
content: "";
position: absolute;
display: none;
}
/* Show the checkmark when checked */
.bulb_list_checkbox .container input:checked ~ .checkmark::after {
display: block;
}
/* Style the checkmark/indicator */
.bulb_list_checkbox .container .checkmark::after {
left: 0.5em;
top: 0.34em;
width: 0.25em;
height: 0.5em;
border: solid wheat;
border-width: 0 0.15em 0.15em 0;
transform: rotate(45deg);
}