diff --git a/Cargo.lock b/Cargo.lock index 67b0d67..b9cefe0 100644 --- a/Cargo.lock +++ b/Cargo.lock @@ -23,7 +23,7 @@ version = "0.8.11" source = "registry+https://github.com/rust-lang/crates.io-index" checksum = "e89da841a80418a9b391ebaea17f5c112ffaaa96f621d2c285b5174da76b9011" dependencies = [ - "cfg-if", + "cfg-if 1.0.0", "once_cell", "version_check", "zerocopy", @@ -59,6 +59,15 @@ dependencies = [ "libc", ] +[[package]] +name = "ansi_term" +version = "0.12.1" +source = "registry+https://github.com/rust-lang/crates.io-index" +checksum = "d52a9bb7ec0cf484c551830a7ce27bd20d67eac647e1befb56b0be4ee39a55d2" +dependencies = [ + "winapi", +] + [[package]] name = "anstream" version = "0.6.18" @@ -133,7 +142,7 @@ checksum = "c7c24de15d275a1ecfd47a380fb4d5ec9bfe0933f309ed5e705b775596a3574d" dependencies = [ "proc-macro2", "quote", - "syn", + "syn 2.0.95", ] [[package]] @@ -144,7 +153,7 @@ checksum = "1b1244b10dcd56c92219da4e14caa97e312079e185f04ba3eea25061561dc0a0" dependencies = [ "proc-macro2", "quote", - "syn", + "syn 2.0.95", ] [[package]] @@ -222,7 +231,7 @@ source = "registry+https://github.com/rust-lang/crates.io-index" checksum = "8d82cb332cdfaed17ae235a638438ac4d4839913cc2af585c3c6746e8f8bee1a" dependencies = [ "addr2line", - "cfg-if", + "cfg-if 1.0.0", "libc", "miniz_oxide", "object", @@ -298,6 +307,12 @@ dependencies = [ "shlex", ] +[[package]] +name = "cfg-if" +version = "0.1.10" +source = "registry+https://github.com/rust-lang/crates.io-index" +checksum = "4785bdd1c96b2a846b2bd7cc02e86b6b3dbf14e7e53446c4f54c92a361040822" + [[package]] name = "cfg-if" version = "1.0.0" @@ -310,6 +325,12 @@ version = "0.2.1" source = "registry+https://github.com/rust-lang/crates.io-index" checksum = "613afe47fcd5fac7ccf1db93babcb082c5994d996f20b8b159f2ad1658eb5724" +[[package]] +name = "chainerror" +version = "0.7.1" +source = "registry+https://github.com/rust-lang/crates.io-index" +checksum = "0ce1bb7fb0c258a6600d699950da347a7a9dad66c3ce815769b5f11cf8fce78e" + [[package]] name = "chrono" version = "0.4.39" @@ -355,7 +376,7 @@ dependencies = [ "heck", "proc-macro2", "quote", - "syn", + "syn 2.0.95", ] [[package]] @@ -441,7 +462,7 @@ version = "1.4.2" source = "registry+https://github.com/rust-lang/crates.io-index" checksum = "a97769d94ddab943e4510d138150169a2758b5ef3eb191a9ee688de3e23ef7b3" dependencies = [ - "cfg-if", + "cfg-if 1.0.0", ] [[package]] @@ -522,7 +543,7 @@ version = "2.0.0" source = "registry+https://github.com/rust-lang/crates.io-index" checksum = "b98cf8ebf19c3d1b223e151f99a4f9f0690dca41414773390fc824184ac833e1" dependencies = [ - "cfg-if", + "cfg-if 1.0.0", "dirs-sys-next", ] @@ -545,7 +566,7 @@ checksum = "97369cbbc041bc366949bc74d34658d6cda5621039731c6310521892a3a20ae0" dependencies = [ "proc-macro2", "quote", - "syn", + "syn 2.0.95", ] [[package]] @@ -616,7 +637,7 @@ dependencies = [ "semver", "serde", "serde_tokenstream", - "syn", + "syn 2.0.95", ] [[package]] @@ -640,7 +661,7 @@ version = "0.8.35" source = "registry+https://github.com/rust-lang/crates.io-index" checksum = "75030f3c4f45dafd7586dd6780965a8c7e8e285a5ecb86713e63a79c5b2766f3" dependencies = [ - "cfg-if", + "cfg-if 1.0.0", ] [[package]] @@ -665,7 +686,7 @@ version = "0.8.0" source = "registry+https://github.com/rust-lang/crates.io-index" checksum = "136d1b5283a1ab77bd9257427ffd09d8667ced0570b6f938942bc7568ed5b943" dependencies = [ - "cfg-if", + "cfg-if 1.0.0", "home", "windows-sys 0.48.0", ] @@ -811,7 +832,7 @@ checksum = "162ee34ebcb7c64a8abebc059ce0fee27c2262618d7b60ed8faf72fef13c3650" dependencies = [ "proc-macro2", "quote", - "syn", + "syn 2.0.95", ] [[package]] @@ -854,13 +875,22 @@ dependencies = [ "version_check", ] +[[package]] +name = "getopts" +version = "0.2.21" +source = "registry+https://github.com/rust-lang/crates.io-index" +checksum = "14dbbfd5c71d70241ecf9e6f13737f7b5ce823821063188d7e46c41d371eebd5" +dependencies = [ + "unicode-width", +] + [[package]] name = "getrandom" version = "0.2.15" source = "registry+https://github.com/rust-lang/crates.io-index" checksum = "c4567c8db10ae91089c99af84c68c38da3ec2f087c3f82960bcdbf3656b6f4d7" dependencies = [ - "cfg-if", + "cfg-if 1.0.0", "js-sys", "libc", "wasi", @@ -979,6 +1009,16 @@ dependencies = [ "windows-sys 0.59.0", ] +[[package]] +name = "hostd" +version = "0.2.0" +dependencies = [ + "anyhow", + "tokio", + "varlink", + "varlink_generator", +] + [[package]] name = "hostname" version = "0.3.1" @@ -996,7 +1036,7 @@ version = "0.4.0" source = "registry+https://github.com/rust-lang/crates.io-index" checksum = "f9c7c7c8ac16c798734b8a24560c1362120597c40d5e1459f09498f8f6c8f2ba" dependencies = [ - "cfg-if", + "cfg-if 1.0.0", "libc", "windows", ] @@ -1272,7 +1312,7 @@ checksum = "1ec89e9337638ecdc08744df490b221a7399bf8d164eb52a665454e60e075ad6" dependencies = [ "proc-macro2", "quote", - "syn", + "syn 2.0.95", ] [[package]] @@ -1488,7 +1528,7 @@ version = "0.10.6" source = "registry+https://github.com/rust-lang/crates.io-index" checksum = "d89e7ee0cfbedfc4da3340218492196241d89eefb6dab27de5df917a6d2e78cf" dependencies = [ - "cfg-if", + "cfg-if 1.0.0", "digest", ] @@ -1498,6 +1538,15 @@ version = "2.7.4" source = "registry+https://github.com/rust-lang/crates.io-index" checksum = "78ca9ab1a0babb1e7d5695e3530886289c18cf2f87ec19a575a0abdce112e3a3" +[[package]] +name = "memoffset" +version = "0.9.1" +source = "registry+https://github.com/rust-lang/crates.io-index" +checksum = "488016bfae457b036d996092f6cb448677611ce4449e970ceaf42695203f218a" +dependencies = [ + "autocfg", +] + [[package]] name = "mime" version = "0.3.17" @@ -1663,7 +1712,7 @@ source = "registry+https://github.com/rust-lang/crates.io-index" checksum = "6174bc48f102d208783c2c84bf931bb75927a617866870de8a4ea85597f871f5" dependencies = [ "bitflags", - "cfg-if", + "cfg-if 1.0.0", "foreign-types", "libc", "once_cell", @@ -1679,7 +1728,7 @@ checksum = "a948666b637a0f465e8564c73e89d4dde00d72d4d473cc972f390fc3dcee7d9c" dependencies = [ "proc-macro2", "quote", - "syn", + "syn 2.0.95", ] [[package]] @@ -1825,7 +1874,7 @@ version = "0.9.10" source = "registry+https://github.com/rust-lang/crates.io-index" checksum = "1e401f977ab385c9e4e3ab30627d6f26d00e2c73eef317493c4ec6d468726cf8" dependencies = [ - "cfg-if", + "cfg-if 1.0.0", "libc", "redox_syscall", "smallvec", @@ -1876,6 +1925,33 @@ dependencies = [ "uuid", ] +[[package]] +name = "peg" +version = "0.6.3" +source = "registry+https://github.com/rust-lang/crates.io-index" +checksum = "9f76678828272f177ac33b7e2ac2e3e73cc6c1cd1e3e387928aa69562fa51367" +dependencies = [ + "peg-macros", + "peg-runtime", +] + +[[package]] +name = "peg-macros" +version = "0.6.3" +source = "registry+https://github.com/rust-lang/crates.io-index" +checksum = "636d60acf97633e48d266d7415a9355d4389cea327a193f87df395d88cd2b14d" +dependencies = [ + "peg-runtime", + "proc-macro2", + "quote", +] + +[[package]] +name = "peg-runtime" +version = "0.6.3" +source = "registry+https://github.com/rust-lang/crates.io-index" +checksum = "9555b1514d2d99d78150d3c799d4c357a3e2c2a8062cd108e93a06d9057629c5" + [[package]] name = "pem-rfc7468" version = "0.7.0" @@ -1908,7 +1984,7 @@ checksum = "3c0f5fad0874fc7abcd4d750e76917eaebbecaa2c20bde22e1dbeeba8beb758c" dependencies = [ "proc-macro2", "quote", - "syn", + "syn 2.0.95", ] [[package]] @@ -2016,7 +2092,7 @@ dependencies = [ "schemars", "serde", "serde_json", - "syn", + "syn 2.0.95", "thiserror 1.0.69", "typify", "unicode-ident", @@ -2037,7 +2113,7 @@ dependencies = [ "serde_json", "serde_tokenstream", "serde_yaml", - "syn", + "syn 2.0.95", ] [[package]] @@ -2060,7 +2136,7 @@ dependencies = [ "itertools", "proc-macro2", "quote", - "syn", + "syn 2.0.95", ] [[package]] @@ -2286,7 +2362,7 @@ source = "registry+https://github.com/rust-lang/crates.io-index" checksum = "c17fa4cb658e3583423e915b9f3acc01cceaee1860e33d59ebae66adc3a2dc0d" dependencies = [ "cc", - "cfg-if", + "cfg-if 1.0.0", "getrandom", "libc", "spin", @@ -2453,7 +2529,7 @@ dependencies = [ "proc-macro2", "quote", "serde_derive_internals", - "syn", + "syn 2.0.95", ] [[package]] @@ -2524,7 +2600,7 @@ checksum = "5a9bf7cf98d04a2b28aead066b7496853d4779c9cc183c440dbac457641e19a0" dependencies = [ "proc-macro2", "quote", - "syn", + "syn 2.0.95", ] [[package]] @@ -2535,7 +2611,7 @@ checksum = "18d26a20a969b9e3fdf2fc2d9f21eda6c40e2de84c9408bb5d3b05d499aae711" dependencies = [ "proc-macro2", "quote", - "syn", + "syn 2.0.95", ] [[package]] @@ -2578,7 +2654,7 @@ dependencies = [ "proc-macro2", "quote", "serde", - "syn", + "syn 2.0.95", ] [[package]] @@ -2612,7 +2688,7 @@ version = "0.10.6" source = "registry+https://github.com/rust-lang/crates.io-index" checksum = "e3bf829a2d51ab4a5ddf1352d8470c140cadc8301b2ae1789db023f01cedd6ba" dependencies = [ - "cfg-if", + "cfg-if 1.0.0", "cpufeatures", "digest", ] @@ -2623,7 +2699,7 @@ version = "0.10.8" source = "registry+https://github.com/rust-lang/crates.io-index" checksum = "793db75ad2bcafc3ffa7c68b215fee268f537982cd901d132f89c6343f3a3dc8" dependencies = [ - "cfg-if", + "cfg-if 1.0.0", "cpufeatures", "digest", ] @@ -2825,7 +2901,7 @@ dependencies = [ "quote", "sqlx-core", "sqlx-macros-core", - "syn", + "syn 2.0.95", ] [[package]] @@ -2848,7 +2924,7 @@ dependencies = [ "sqlx-mysql", "sqlx-postgres", "sqlx-sqlite", - "syn", + "syn 2.0.95", "tempfile", "tokio", "url", @@ -2991,6 +3067,17 @@ version = "2.6.1" source = "registry+https://github.com/rust-lang/crates.io-index" checksum = "13c2bddecc57b384dee18652358fb23172facb8a2c51ccc10d74c157bdea3292" +[[package]] +name = "syn" +version = "1.0.109" +source = "registry+https://github.com/rust-lang/crates.io-index" +checksum = "72b64191b275b66ffe2469e8af2c1cfe3bafa67b529ead792a6d0160888b4237" +dependencies = [ + "proc-macro2", + "quote", + "unicode-ident", +] + [[package]] name = "syn" version = "2.0.95" @@ -3019,7 +3106,7 @@ checksum = "c8af7666ab7b6390ab78131fb5b0fce11d6b7a6951602017c35fa82800708971" dependencies = [ "proc-macro2", "quote", - "syn", + "syn 2.0.95", ] [[package]] @@ -3055,7 +3142,7 @@ version = "3.15.0" source = "registry+https://github.com/rust-lang/crates.io-index" checksum = "9a8a559c81686f576e8cd0290cd2a24a2a9ad80c98b3478856500fcbd7acd704" dependencies = [ - "cfg-if", + "cfg-if 1.0.0", "fastrand", "getrandom", "once_cell", @@ -3110,7 +3197,7 @@ checksum = "4fee6c4efc90059e10f81e6d42c60a18f76588c3d74cb83a0b242a2b6c7504c1" dependencies = [ "proc-macro2", "quote", - "syn", + "syn 2.0.95", ] [[package]] @@ -3121,7 +3208,7 @@ checksum = "7b50fa271071aae2e6ee85f842e2e28ba8cd2c5fb67f11fcb1fd70b276f9e7d4" dependencies = [ "proc-macro2", "quote", - "syn", + "syn 2.0.95", ] [[package]] @@ -3130,7 +3217,7 @@ version = "1.1.8" source = "registry+https://github.com/rust-lang/crates.io-index" checksum = "8b9ef9bad013ada3808854ceac7b46812a6465ba368859a37e2100283d2d719c" dependencies = [ - "cfg-if", + "cfg-if 1.0.0", "once_cell", ] @@ -3218,7 +3305,7 @@ checksum = "693d596312e88961bc67d7f1f97af8a70227d9f90c31bba5806eec004978d752" dependencies = [ "proc-macro2", "quote", - "syn", + "syn 2.0.95", ] [[package]] @@ -3400,7 +3487,7 @@ dependencies = [ "http", "proc-macro2", "quote", - "syn", + "syn 2.0.95", "tracing", ] @@ -3424,7 +3511,7 @@ checksum = "395ae124c09f9e6918a2310af6038fba074bcf474ac352496d5910dd59a2226d" dependencies = [ "proc-macro2", "quote", - "syn", + "syn 2.0.95", ] [[package]] @@ -3528,7 +3615,7 @@ dependencies = [ "semver", "serde", "serde_json", - "syn", + "syn 2.0.95", "thiserror 1.0.69", "unicode-ident", ] @@ -3546,10 +3633,21 @@ dependencies = [ "serde", "serde_json", "serde_tokenstream", - "syn", + "syn 2.0.95", "typify-impl", ] +[[package]] +name = "uds_windows" +version = "1.1.0" +source = "registry+https://github.com/rust-lang/crates.io-index" +checksum = "89daebc3e6fd160ac4aa9fc8b3bf71e1f74fbf92367ae71fb83a037e8bf164b9" +dependencies = [ + "memoffset", + "tempfile", + "winapi", +] + [[package]] name = "unicode-bidi" version = "0.3.18" @@ -3577,6 +3675,22 @@ version = "0.1.3" source = "registry+https://github.com/rust-lang/crates.io-index" checksum = "e70f2a8b45122e719eb623c01822704c4e0907e7e426a05927e1a1cfff5b75d0" +[[package]] +name = "unicode-width" +version = "0.1.14" +source = "registry+https://github.com/rust-lang/crates.io-index" +checksum = "7dd6e30e90baa6f72411720665d41d89b9a3d039dc45b8faea1ddd07f617f6af" + +[[package]] +name = "unix_socket" +version = "0.5.0" +source = "registry+https://github.com/rust-lang/crates.io-index" +checksum = "6aa2700417c405c38f5e6902d699345241c28c0b7ade4abaad71e35a87eb1564" +dependencies = [ + "cfg-if 0.1.10", + "libc", +] + [[package]] name = "unsafe-libyaml" version = "0.2.11" @@ -3634,6 +3748,47 @@ version = "0.1.0" source = "registry+https://github.com/rust-lang/crates.io-index" checksum = "830b7e5d4d90034032940e4ace0d9a9a057e7a45cd94e6c007832e39edb82f6d" +[[package]] +name = "varlink" +version = "11.0.1" +source = "registry+https://github.com/rust-lang/crates.io-index" +checksum = "409e275987d74665c23610c0959c133360cafd761c1a6ddb1ca6d0685c8cef5d" +dependencies = [ + "libc", + "serde", + "serde_derive", + "serde_json", + "tempfile", + "uds_windows", + "unix_socket", + "winapi", +] + +[[package]] +name = "varlink_generator" +version = "10.1.0" +source = "registry+https://github.com/rust-lang/crates.io-index" +checksum = "2d8ff746c5b65d4bfb3a50f630b85cfb6a9d59f18720126e3ebd6bc98527fa51" +dependencies = [ + "chainerror", + "getopts", + "proc-macro2", + "quote", + "syn 1.0.109", + "varlink_parser", +] + +[[package]] +name = "varlink_parser" +version = "4.2.0" +source = "registry+https://github.com/rust-lang/crates.io-index" +checksum = "35fb9f3c1e8ccb33cdb6c84a4477ef3f3884ce6f4b70514ef1fbf7686eae921e" +dependencies = [ + "ansi_term", + "chainerror", + "peg", +] + [[package]] name = "vcpkg" version = "0.2.15" @@ -3682,7 +3837,7 @@ version = "0.2.99" source = "registry+https://github.com/rust-lang/crates.io-index" checksum = "a474f6281d1d70c17ae7aa6a613c87fce69a127e2624002df63dcb39d6cf6396" dependencies = [ - "cfg-if", + "cfg-if 1.0.0", "once_cell", "wasm-bindgen-macro", ] @@ -3697,7 +3852,7 @@ dependencies = [ "log", "proc-macro2", "quote", - "syn", + "syn 2.0.95", "wasm-bindgen-shared", ] @@ -3707,7 +3862,7 @@ version = "0.4.49" source = "registry+https://github.com/rust-lang/crates.io-index" checksum = "38176d9b44ea84e9184eff0bc34cc167ed044f816accfe5922e54d84cf48eca2" dependencies = [ - "cfg-if", + "cfg-if 1.0.0", "js-sys", "once_cell", "wasm-bindgen", @@ -3732,7 +3887,7 @@ checksum = "30d7a95b763d3c45903ed6c81f156801839e5ee968bb07e534c44df0fcd330c2" dependencies = [ "proc-macro2", "quote", - "syn", + "syn 2.0.95", "wasm-bindgen-backend", "wasm-bindgen-shared", ] @@ -4065,7 +4220,7 @@ checksum = "2380878cad4ac9aac1e2435f3eb4020e8374b5f13c296cb75b4620ff8e229154" dependencies = [ "proc-macro2", "quote", - "syn", + "syn 2.0.95", "synstructure", ] @@ -4087,7 +4242,7 @@ checksum = "fa4f8080344d4671fb4e831a13ad1e68092748387dfc4f55e356242fae12ce3e" dependencies = [ "proc-macro2", "quote", - "syn", + "syn 2.0.95", ] [[package]] @@ -4107,7 +4262,7 @@ checksum = "595eed982f7d355beb85837f651fa22e90b3c044842dc7f2c2842c086f295808" dependencies = [ "proc-macro2", "quote", - "syn", + "syn 2.0.95", "synstructure", ] @@ -4136,7 +4291,7 @@ checksum = "6eafa6dfb17584ea3e2bd6e76e0cc15ad7af12b09abdd1ca55961bed9b1063c6" dependencies = [ "proc-macro2", "quote", - "syn", + "syn 2.0.95", ] [[package]] diff --git a/Cargo.toml b/Cargo.toml index ca5b5c1..653c291 100644 --- a/Cargo.toml +++ b/Cargo.toml @@ -4,6 +4,7 @@ members = [ "agent", "controller", "instrumentation", + "hostd", "trace-request", "xtask", ] diff --git a/hostd/.gitignore b/hostd/.gitignore new file mode 100644 index 0000000..ea8c4bf --- /dev/null +++ b/hostd/.gitignore @@ -0,0 +1 @@ +/target diff --git a/hostd/Cargo.toml b/hostd/Cargo.toml new file mode 100644 index 0000000..f6d79cc --- /dev/null +++ b/hostd/Cargo.toml @@ -0,0 +1,12 @@ +[package] +name = "hostd" +version.workspace = true +edition.workspace = true + +[dependencies] +anyhow.workspace = true +tokio.workspace = true +varlink = "11.0.1" + +[build-dependencies] +varlink_generator = "10.1.0" diff --git a/hostd/build.rs b/hostd/build.rs new file mode 100644 index 0000000..c12279a --- /dev/null +++ b/hostd/build.rs @@ -0,0 +1,6 @@ +extern crate varlink_generator; + +fn main() { + varlink_generator::cargo_build_tosource("src/io.systemd.Hostname.varlink", true); + varlink_generator::cargo_build_tosource("src/io.patagia.Hostd.varlink", true); +} diff --git a/hostd/src/io.patagia.Hostd.varlink b/hostd/src/io.patagia.Hostd.varlink new file mode 100644 index 0000000..46123a8 --- /dev/null +++ b/hostd/src/io.patagia.Hostd.varlink @@ -0,0 +1,27 @@ +interface io.patagia.Hostd + +type Label ( + key: string, + value: string +) + +type PatagiaAgentConfig ( + url: string, + extraMounts: [string]string +) + +type Machine( + machineId: string, + nodeLabels: ?[]Label, + patagiaAgent: ?PatagiaAgentConfig +) + +method Describe() -> ( + machine: Machine +) + +method Apply( + machine: Machine +) -> () + +error InvalidMachineConfig() diff --git a/hostd/src/io.systemd.Hostname.varlink b/hostd/src/io.systemd.Hostname.varlink new file mode 100644 index 0000000..be4cf01 --- /dev/null +++ b/hostd/src/io.systemd.Hostname.varlink @@ -0,0 +1,32 @@ +interface io.systemd.Hostname + +method Describe() -> ( + Hostname: string, + StaticHostname: ?string, + PrettyHostname: ?string, + DefaultHostname: ?string, + HostnameSource: string, + IconName: ?string, + Chassis: ?string, + Deployment: ?string, + Location: ?string, + KernelName: string, + KernelRelease: string, + KernelVersion: string, + OperatingSystemPrettyName: ?string, + OperatingSystemCPEName: ?string, + OperatingSystemHomeURL: ?string, + OperatingSystemSupportEnd: ?int, + OperatingSystemReleaseData: ?[]string, + MachineInformationData: ?[]string, + HardwareVendor: ?string, + HardwareModel: ?string, + HardwareSerial: ?string, + FirmwareVersion: ?string, + FirmwareVendor: ?string, + FirmwareDate: ?int, + MachineID: string, + BootID: string, + ProductUUID: ?string, + VSockCID: ?int +) diff --git a/hostd/src/io_patagia_Hostd.rs b/hostd/src/io_patagia_Hostd.rs new file mode 100644 index 0000000..a2de13d --- /dev/null +++ b/hostd/src/io_patagia_Hostd.rs @@ -0,0 +1,264 @@ +#![doc = "This file was automatically generated by the varlink rust generator"] +#![allow(non_camel_case_types)] +#![allow(non_snake_case)] +use serde_derive::{Deserialize, Serialize}; +use std::io::BufRead; +use std::sync::{Arc, RwLock}; +use varlink::{self, CallTrait}; +#[allow(dead_code)] +#[derive(Clone, PartialEq, Debug)] +#[allow(clippy::enum_variant_names)] +pub enum ErrorKind { + Varlink_Error, + VarlinkReply_Error, + InvalidMachineConfig(Option), +} +impl ::std::fmt::Display for ErrorKind { + fn fmt(&self, f: &mut ::std::fmt::Formatter) -> ::std::fmt::Result { + match self { + ErrorKind::Varlink_Error => write!(f, "Varlink Error"), + ErrorKind::VarlinkReply_Error => write!(f, "Varlink error reply"), + ErrorKind::InvalidMachineConfig(v) => { + write!(f, "io.patagia.Hostd.InvalidMachineConfig: {:#?}", v) + } + } + } +} +pub struct Error( + pub ErrorKind, + pub Option>, + pub Option<&'static str>, +); +impl Error { + #[allow(dead_code)] + pub fn kind(&self) -> &ErrorKind { + &self.0 + } +} +impl From for Error { + fn from(e: ErrorKind) -> Self { + Error(e, None, None) + } +} +impl std::error::Error for Error { + fn source(&self) -> Option<&(dyn std::error::Error + 'static)> { + self.1 + .as_ref() + .map(|e| e.as_ref() as &(dyn std::error::Error + 'static)) + } +} +impl std::fmt::Display for Error { + fn fmt(&self, f: &mut std::fmt::Formatter) -> std::fmt::Result { + std::fmt::Display::fmt(&self.0, f) + } +} +impl std::fmt::Debug for Error { + fn fmt(&self, f: &mut std::fmt::Formatter) -> std::fmt::Result { + use std::error::Error as StdError; + if let Some(ref o) = self.2 { + std::fmt::Display::fmt(o, f)?; + } + std::fmt::Debug::fmt(&self.0, f)?; + if let Some(e) = self.source() { + std::fmt::Display::fmt("\nCaused by:\n", f)?; + std::fmt::Debug::fmt(&e, f)?; + } + Ok(()) + } +} +#[allow(dead_code)] +pub type Result = std::result::Result; +impl From for Error { + fn from(e: varlink::Error) -> Self { + match e.kind() { + varlink::ErrorKind::VarlinkErrorReply(r) => Error( + ErrorKind::from(r), + Some(Box::from(e)), + Some(concat!(file!(), ":", line!(), ": ")), + ), + _ => Error( + ErrorKind::Varlink_Error, + Some(Box::from(e)), + Some(concat!(file!(), ":", line!(), ": ")), + ), + } + } +} +#[allow(dead_code)] +impl Error { + pub fn source_varlink_kind(&self) -> Option<&varlink::ErrorKind> { + use std::error::Error as StdError; + let mut s: &dyn StdError = self; + while let Some(c) = s.source() { + let k = self + .source() + .and_then(|e| e.downcast_ref::()) + .map(|e| e.kind()); + if k.is_some() { + return k; + } + s = c; + } + None + } +} +impl From<&varlink::Reply> for ErrorKind { + #[allow(unused_variables)] + fn from(e: &varlink::Reply) -> Self { + match e { + varlink::Reply { + error: Some(ref t), .. + } if t == "io.patagia.Hostd.InvalidMachineConfig" => match e { + varlink::Reply { + parameters: Some(p), + .. + } => match serde_json::from_value(p.clone()) { + Ok(v) => ErrorKind::InvalidMachineConfig(v), + Err(_) => ErrorKind::InvalidMachineConfig(None), + }, + _ => ErrorKind::InvalidMachineConfig(None), + }, + _ => ErrorKind::VarlinkReply_Error, + } + } +} +pub trait VarlinkCallError: varlink::CallTrait { + fn reply_invalid_machine_config(&mut self) -> varlink::Result<()> { + self.reply_struct(varlink::Reply::error( + "io.patagia.Hostd.InvalidMachineConfig", + None, + )) + } +} +impl<'a> VarlinkCallError for varlink::Call<'a> {} +#[derive(Serialize, Deserialize, Debug, PartialEq, Clone)] +pub struct r#Label { + pub r#key: String, + pub r#value: String, +} +#[derive(Serialize, Deserialize, Debug, PartialEq, Clone)] +pub struct r#Machine { + pub r#machineId: String, + pub r#nodeLabels: Option>, + pub r#patagiaAgent: Option, +} +#[derive(Serialize, Deserialize, Debug, PartialEq, Clone)] +pub struct r#PatagiaAgentConfig { + pub r#url: String, + pub r#extraMounts: varlink::StringHashMap, +} +#[derive(Serialize, Deserialize, Debug, PartialEq, Clone)] +pub struct InvalidMachineConfig_Args {} +#[derive(Serialize, Deserialize, Debug, PartialEq, Clone)] +pub struct Apply_Reply {} +impl varlink::VarlinkReply for Apply_Reply {} +#[derive(Serialize, Deserialize, Debug, PartialEq, Clone)] +pub struct Apply_Args { + pub r#machine: Machine, +} +pub trait Call_Apply: VarlinkCallError { + fn reply(&mut self) -> varlink::Result<()> { + self.reply_struct(varlink::Reply::parameters(None)) + } +} +impl<'a> Call_Apply for varlink::Call<'a> {} +#[derive(Serialize, Deserialize, Debug, PartialEq, Clone)] +pub struct Describe_Reply { + pub r#machine: Machine, +} +impl varlink::VarlinkReply for Describe_Reply {} +#[derive(Serialize, Deserialize, Debug, PartialEq, Clone)] +pub struct Describe_Args {} +pub trait Call_Describe: VarlinkCallError { + fn reply(&mut self, r#machine: Machine) -> varlink::Result<()> { + self.reply_struct(Describe_Reply { r#machine }.into()) + } +} +impl<'a> Call_Describe for varlink::Call<'a> {} +pub trait VarlinkInterface { + fn apply(&self, call: &mut dyn Call_Apply, r#machine: Machine) -> varlink::Result<()>; + fn describe(&self, call: &mut dyn Call_Describe) -> varlink::Result<()>; + fn call_upgraded( + &self, + _call: &mut varlink::Call, + _bufreader: &mut dyn BufRead, + ) -> varlink::Result> { + Ok(Vec::new()) + } +} +pub trait VarlinkClientInterface { + fn apply(&mut self, r#machine: Machine) -> varlink::MethodCall; + fn describe(&mut self) -> varlink::MethodCall; +} +#[allow(dead_code)] +pub struct VarlinkClient { + connection: Arc>, +} +impl VarlinkClient { + #[allow(dead_code)] + pub fn new(connection: Arc>) -> Self { + VarlinkClient { connection } + } +} +impl VarlinkClientInterface for VarlinkClient { + fn apply(&mut self, r#machine: Machine) -> varlink::MethodCall { + varlink::MethodCall::::new( + self.connection.clone(), + "io.patagia.Hostd.Apply", + Apply_Args { r#machine }, + ) + } + fn describe(&mut self) -> varlink::MethodCall { + varlink::MethodCall::::new( + self.connection.clone(), + "io.patagia.Hostd.Describe", + Describe_Args {}, + ) + } +} +#[allow(dead_code)] +pub struct VarlinkInterfaceProxy { + inner: Box, +} +#[allow(dead_code)] +pub fn new(inner: Box) -> VarlinkInterfaceProxy { + VarlinkInterfaceProxy { inner } +} +impl varlink::Interface for VarlinkInterfaceProxy { + fn get_description(&self) -> &'static str { + "interface io.patagia.Hostd\n\ntype Label (\n key: string,\n value: string\n)\n\ntype PatagiaAgentConfig (\n url: string,\n extraMounts: [string]string\n)\n\ntype Machine(\n machineId: string,\n nodeLabels: ?[]Label,\n patagiaAgent: ?PatagiaAgentConfig\n)\n\nmethod Describe() -> (\n machine: Machine\n)\n\nmethod Apply(\n machine: Machine\n) -> ()\n\nerror InvalidMachineConfig()\n" + } + fn get_name(&self) -> &'static str { + "io.patagia.Hostd" + } + fn call_upgraded( + &self, + call: &mut varlink::Call, + bufreader: &mut dyn BufRead, + ) -> varlink::Result> { + self.inner.call_upgraded(call, bufreader) + } + fn call(&self, call: &mut varlink::Call) -> varlink::Result<()> { + let req = call.request.unwrap(); + match req.method.as_ref() { + "io.patagia.Hostd.Apply" => { + if let Some(args) = req.parameters.clone() { + let args: Apply_Args = match serde_json::from_value(args) { + Ok(v) => v, + Err(e) => { + let es = format!("{}", e); + let _ = call.reply_invalid_parameter(es.clone()); + return Err(varlink::context!(varlink::ErrorKind::SerdeJsonDe(es))); + } + }; + self.inner + .apply(call as &mut dyn Call_Apply, args.r#machine) + } else { + call.reply_invalid_parameter("parameters".into()) + } + } + "io.patagia.Hostd.Describe" => self.inner.describe(call as &mut dyn Call_Describe), + m => call.reply_method_not_found(String::from(m)), + } + } +} diff --git a/hostd/src/io_systemd_Hostname.rs b/hostd/src/io_systemd_Hostname.rs new file mode 100644 index 0000000..e9fa185 --- /dev/null +++ b/hostd/src/io_systemd_Hostname.rs @@ -0,0 +1,295 @@ +#![doc = "This file was automatically generated by the varlink rust generator"] +#![allow(non_camel_case_types)] +#![allow(non_snake_case)] +use serde_derive::{Deserialize, Serialize}; +use std::io::BufRead; +use std::sync::{Arc, RwLock}; +use varlink::{self, CallTrait}; +#[allow(dead_code)] +#[derive(Clone, PartialEq, Debug)] +#[allow(clippy::enum_variant_names)] +pub enum ErrorKind { + Varlink_Error, + VarlinkReply_Error, +} +impl ::std::fmt::Display for ErrorKind { + fn fmt(&self, f: &mut ::std::fmt::Formatter) -> ::std::fmt::Result { + match self { + ErrorKind::Varlink_Error => write!(f, "Varlink Error"), + ErrorKind::VarlinkReply_Error => write!(f, "Varlink error reply"), + } + } +} +pub struct Error( + pub ErrorKind, + pub Option>, + pub Option<&'static str>, +); +impl Error { + #[allow(dead_code)] + pub fn kind(&self) -> &ErrorKind { + &self.0 + } +} +impl From for Error { + fn from(e: ErrorKind) -> Self { + Error(e, None, None) + } +} +impl std::error::Error for Error { + fn source(&self) -> Option<&(dyn std::error::Error + 'static)> { + self.1 + .as_ref() + .map(|e| e.as_ref() as &(dyn std::error::Error + 'static)) + } +} +impl std::fmt::Display for Error { + fn fmt(&self, f: &mut std::fmt::Formatter) -> std::fmt::Result { + std::fmt::Display::fmt(&self.0, f) + } +} +impl std::fmt::Debug for Error { + fn fmt(&self, f: &mut std::fmt::Formatter) -> std::fmt::Result { + use std::error::Error as StdError; + if let Some(ref o) = self.2 { + std::fmt::Display::fmt(o, f)?; + } + std::fmt::Debug::fmt(&self.0, f)?; + if let Some(e) = self.source() { + std::fmt::Display::fmt("\nCaused by:\n", f)?; + std::fmt::Debug::fmt(&e, f)?; + } + Ok(()) + } +} +#[allow(dead_code)] +pub type Result = std::result::Result; +impl From for Error { + fn from(e: varlink::Error) -> Self { + match e.kind() { + varlink::ErrorKind::VarlinkErrorReply(r) => Error( + ErrorKind::from(r), + Some(Box::from(e)), + Some(concat!(file!(), ":", line!(), ": ")), + ), + _ => Error( + ErrorKind::Varlink_Error, + Some(Box::from(e)), + Some(concat!(file!(), ":", line!(), ": ")), + ), + } + } +} +#[allow(dead_code)] +impl Error { + pub fn source_varlink_kind(&self) -> Option<&varlink::ErrorKind> { + use std::error::Error as StdError; + let mut s: &dyn StdError = self; + while let Some(c) = s.source() { + let k = self + .source() + .and_then(|e| e.downcast_ref::()) + .map(|e| e.kind()); + if k.is_some() { + return k; + } + s = c; + } + None + } +} +impl From<&varlink::Reply> for ErrorKind { + #[allow(unused_variables)] + fn from(e: &varlink::Reply) -> Self { + match e { + _ => ErrorKind::VarlinkReply_Error, + } + } +} +pub trait VarlinkCallError: varlink::CallTrait {} +impl<'a> VarlinkCallError for varlink::Call<'a> {} +#[derive(Serialize, Deserialize, Debug, PartialEq, Clone)] +pub struct Describe_Reply { + pub r#Hostname: String, + #[serde(skip_serializing_if = "Option::is_none")] + pub r#StaticHostname: Option, + #[serde(skip_serializing_if = "Option::is_none")] + pub r#PrettyHostname: Option, + #[serde(skip_serializing_if = "Option::is_none")] + pub r#DefaultHostname: Option, + pub r#HostnameSource: String, + #[serde(skip_serializing_if = "Option::is_none")] + pub r#IconName: Option, + #[serde(skip_serializing_if = "Option::is_none")] + pub r#Chassis: Option, + #[serde(skip_serializing_if = "Option::is_none")] + pub r#Deployment: Option, + #[serde(skip_serializing_if = "Option::is_none")] + pub r#Location: Option, + pub r#KernelName: String, + pub r#KernelRelease: String, + pub r#KernelVersion: String, + #[serde(skip_serializing_if = "Option::is_none")] + pub r#OperatingSystemPrettyName: Option, + #[serde(skip_serializing_if = "Option::is_none")] + pub r#OperatingSystemCPEName: Option, + #[serde(skip_serializing_if = "Option::is_none")] + pub r#OperatingSystemHomeURL: Option, + #[serde(skip_serializing_if = "Option::is_none")] + pub r#OperatingSystemSupportEnd: Option, + #[serde(skip_serializing_if = "Option::is_none")] + pub r#OperatingSystemReleaseData: Option>, + #[serde(skip_serializing_if = "Option::is_none")] + pub r#MachineInformationData: Option>, + #[serde(skip_serializing_if = "Option::is_none")] + pub r#HardwareVendor: Option, + #[serde(skip_serializing_if = "Option::is_none")] + pub r#HardwareModel: Option, + #[serde(skip_serializing_if = "Option::is_none")] + pub r#HardwareSerial: Option, + #[serde(skip_serializing_if = "Option::is_none")] + pub r#FirmwareVersion: Option, + #[serde(skip_serializing_if = "Option::is_none")] + pub r#FirmwareVendor: Option, + #[serde(skip_serializing_if = "Option::is_none")] + pub r#FirmwareDate: Option, + pub r#MachineID: String, + pub r#BootID: String, + #[serde(skip_serializing_if = "Option::is_none")] + pub r#ProductUUID: Option, + #[serde(skip_serializing_if = "Option::is_none")] + pub r#VSockCID: Option, +} +impl varlink::VarlinkReply for Describe_Reply {} +#[derive(Serialize, Deserialize, Debug, PartialEq, Clone)] +pub struct Describe_Args {} +pub trait Call_Describe: VarlinkCallError { + fn reply( + &mut self, + r#Hostname: String, + r#StaticHostname: Option, + r#PrettyHostname: Option, + r#DefaultHostname: Option, + r#HostnameSource: String, + r#IconName: Option, + r#Chassis: Option, + r#Deployment: Option, + r#Location: Option, + r#KernelName: String, + r#KernelRelease: String, + r#KernelVersion: String, + r#OperatingSystemPrettyName: Option, + r#OperatingSystemCPEName: Option, + r#OperatingSystemHomeURL: Option, + r#OperatingSystemSupportEnd: Option, + r#OperatingSystemReleaseData: Option>, + r#MachineInformationData: Option>, + r#HardwareVendor: Option, + r#HardwareModel: Option, + r#HardwareSerial: Option, + r#FirmwareVersion: Option, + r#FirmwareVendor: Option, + r#FirmwareDate: Option, + r#MachineID: String, + r#BootID: String, + r#ProductUUID: Option, + r#VSockCID: Option, + ) -> varlink::Result<()> { + self.reply_struct( + Describe_Reply { + r#Hostname, + r#StaticHostname, + r#PrettyHostname, + r#DefaultHostname, + r#HostnameSource, + r#IconName, + r#Chassis, + r#Deployment, + r#Location, + r#KernelName, + r#KernelRelease, + r#KernelVersion, + r#OperatingSystemPrettyName, + r#OperatingSystemCPEName, + r#OperatingSystemHomeURL, + r#OperatingSystemSupportEnd, + r#OperatingSystemReleaseData, + r#MachineInformationData, + r#HardwareVendor, + r#HardwareModel, + r#HardwareSerial, + r#FirmwareVersion, + r#FirmwareVendor, + r#FirmwareDate, + r#MachineID, + r#BootID, + r#ProductUUID, + r#VSockCID, + } + .into(), + ) + } +} +impl<'a> Call_Describe for varlink::Call<'a> {} +pub trait VarlinkInterface { + fn describe(&self, call: &mut dyn Call_Describe) -> varlink::Result<()>; + fn call_upgraded( + &self, + _call: &mut varlink::Call, + _bufreader: &mut dyn BufRead, + ) -> varlink::Result> { + Ok(Vec::new()) + } +} +pub trait VarlinkClientInterface { + fn describe(&mut self) -> varlink::MethodCall; +} +#[allow(dead_code)] +pub struct VarlinkClient { + connection: Arc>, +} +impl VarlinkClient { + #[allow(dead_code)] + pub fn new(connection: Arc>) -> Self { + VarlinkClient { connection } + } +} +impl VarlinkClientInterface for VarlinkClient { + fn describe(&mut self) -> varlink::MethodCall { + varlink::MethodCall::::new( + self.connection.clone(), + "io.systemd.Hostname.Describe", + Describe_Args {}, + ) + } +} +#[allow(dead_code)] +pub struct VarlinkInterfaceProxy { + inner: Box, +} +#[allow(dead_code)] +pub fn new(inner: Box) -> VarlinkInterfaceProxy { + VarlinkInterfaceProxy { inner } +} +impl varlink::Interface for VarlinkInterfaceProxy { + fn get_description(&self) -> &'static str { + "interface io.systemd.Hostname\n\nmethod Describe() -> (\n\tHostname: string,\n\tStaticHostname: ?string,\n\tPrettyHostname: ?string,\n\tDefaultHostname: ?string,\n\tHostnameSource: string,\n\tIconName: ?string,\n\tChassis: ?string,\n\tDeployment: ?string,\n\tLocation: ?string,\n\tKernelName: string,\n\tKernelRelease: string,\n\tKernelVersion: string,\n\tOperatingSystemPrettyName: ?string,\n\tOperatingSystemCPEName: ?string,\n\tOperatingSystemHomeURL: ?string,\n\tOperatingSystemSupportEnd: ?int,\n\tOperatingSystemReleaseData: ?[]string,\n\tMachineInformationData: ?[]string,\n\tHardwareVendor: ?string,\n\tHardwareModel: ?string,\n\tHardwareSerial: ?string,\n\tFirmwareVersion: ?string,\n\tFirmwareVendor: ?string,\n\tFirmwareDate: ?int,\n\tMachineID: string,\n\tBootID: string,\n\tProductUUID: ?string,\n\tVSockCID: ?int\n)\n" + } + fn get_name(&self) -> &'static str { + "io.systemd.Hostname" + } + fn call_upgraded( + &self, + call: &mut varlink::Call, + bufreader: &mut dyn BufRead, + ) -> varlink::Result> { + self.inner.call_upgraded(call, bufreader) + } + fn call(&self, call: &mut varlink::Call) -> varlink::Result<()> { + let req = call.request.unwrap(); + match req.method.as_ref() { + "io.systemd.Hostname.Describe" => self.inner.describe(call as &mut dyn Call_Describe), + m => call.reply_method_not_found(String::from(m)), + } + } +} diff --git a/hostd/src/main.rs b/hostd/src/main.rs new file mode 100644 index 0000000..47ad8c6 --- /dev/null +++ b/hostd/src/main.rs @@ -0,0 +1,3 @@ +fn main() { + println!("Hello World!"); +}