Compare commits

..

21 Commits

Author SHA1 Message Date
3875ee994f Delete .github/workflows/security-audit.yml
Some checks failed
CI / Rust checks (push) Has been cancelled
2025-03-01 21:23:48 +00:00
ae7111ac33 Fix facilities rgData
Some checks failed
CI / Rust checks (push) Failing after 53s
Security / Audit (push) Failing after 29s
2024-10-22 12:31:35 +02:00
6f1c647687 object send+sync, probably a bad idea
Some checks failed
CI / Rust checks (push) Failing after 59s
Security / Audit (push) Successful in 24s
2024-10-21 14:06:12 +02:00
4088df3d5e get object id
Some checks failed
CI / Rust checks (push) Failing after 38s
2024-10-21 13:46:57 +02:00
cfc5e4ad87 more visible
Some checks failed
CI / Rust checks (push) Failing after 38s
2024-10-21 13:40:06 +02:00
aa439c16ca inherit visibility
Some checks failed
CI / Rust checks (push) Failing after 48s
2024-10-21 13:11:13 +02:00
277f86a04b sendsyncmaybe
Some checks failed
CI / Rust checks (push) Failing after 48s
Security / Audit (push) Successful in 16s
2024-10-20 20:02:23 +02:00
54f84ed7af this kinda works
Some checks failed
CI / Rust checks (push) Failing after 1m17s
Security / Audit (push) Failing after 7m24s
2024-10-20 19:44:04 +02:00
c50bb6c344 we don't need this right now
All checks were successful
CI / Rust checks (push) Successful in 2m2s
2024-10-20 13:13:22 +02:00
3a74467bb5 allow unused in lib
Some checks failed
CI / Rust checks (push) Failing after 1m0s
2024-10-20 12:22:24 +02:00
9d9192bc51 rust-cargo-make is broken
Some checks failed
CI / Rust checks (push) Failing after 1m3s
2024-10-20 12:10:17 +02:00
bee3553d9e Updated SDK
Some checks failed
CI / Rust checks (push) Failing after 6s
2024-10-20 12:01:48 +02:00
Mihai Dinculescu
856656e23b Update crates 2023-05-01 19:13:42 +01:00
Mihai Dinculescu
d89fa524c2 Rework events and add proper support for client events
Added

- Client events are now implemented through `SimConnect::subscribe_to_client_event`, `SimConnect::unsubscribe_from_client_event` and `SimConnect::unsubscribe_from_all_client_events`.
- `subscribe_to_client_events.rs` example has been added.
- `SimConnectError::EventAlreadySubscribedTo` and `SimConnectError::EventNotSubscribedTo` error variants have been added.

Changed

- A second call to `SimConnect::subscribe_to_system_event` for the same event will now return an error of type `SimConnectError::EventAlreadySubscribedTo` instead of `SimConnectError::SimConnectException`.
- The call to `SimConnect::unsubscribe_from_system_event` is now a NOOP when the system event is not subscribed to.
- `SimConnectError::UnimplementedMessageType` has been renamed to `SimConnectError::UnimplementedNotification`.

Removed

- `SimConnect::register_event` has been replaced by the new client event functions.
- `NotificationGroup` has been removed in favor of an internally managed notification group.
2023-05-01 19:13:30 +01:00
Mihai Dinculescu
85e5341599 Announce v0.2.2 2023-02-22 19:11:21 +00:00
Mihai Dinculescu
651aadd70f Update crates 2023-02-22 18:41:51 +00:00
Mihai Dinculescu
93ab001d48 Automatically clean up request_facilities_list requests once completed 2023-02-22 18:41:01 +00:00
Mihai Dinculescu
e074d708d8 Updated to MSFS SDK v0.20.5.0 2023-02-09 10:34:45 +00:00
Mihai Dinculescu
88d9f78e59 Update crates 2023-02-09 10:34:40 +00:00
dependabot[bot]
9f569d49fa Bump bindgen from 0.61.0 to 0.62.0
Bumps [bindgen](https://github.com/rust-lang/rust-bindgen) from 0.61.0 to 0.62.0.
- [Release notes](https://github.com/rust-lang/rust-bindgen/releases)
- [Changelog](https://github.com/rust-lang/rust-bindgen/blob/master/CHANGELOG.md)
- [Commits](https://github.com/rust-lang/rust-bindgen/compare/v0.61.0...v0.62.0)

---
updated-dependencies:
- dependency-name: bindgen
  dependency-type: direct:production
  update-type: version-update:semver-minor
...

Signed-off-by: dependabot[bot] <support@github.com>
2022-11-19 19:37:28 +00:00
Mihai Dinculescu
63086c5b9b Announce v0.2.1 2022-10-29 15:52:37 +01:00
42 changed files with 1875 additions and 732 deletions

View File

@@ -18,7 +18,6 @@ jobs:
with:
toolchain: stable
override: true
- uses: davidB/rust-cargo-make@v1
- uses: actions/checkout@v3
- name: Run format
run: cargo make format

View File

@@ -16,7 +16,6 @@ jobs:
profile: minimal
toolchain: stable
override: true
- uses: davidB/rust-cargo-make@v1
- name: Run build
run: cargo build --release --verbose
- name: Run cargo login

View File

@@ -1,30 +0,0 @@
name: Security
on:
push:
branches:
- main
paths:
- "**/Cargo.toml"
- "**/Cargo.lock"
pull_request:
branches:
- main
paths:
- "**/Cargo.toml"
- "**/Cargo.lock"
schedule:
- cron: "0 0 * * *"
jobs:
security_audit:
name: Audit
runs-on: windows-latest
steps:
- uses: actions/checkout@v3
- uses: actions-rs/toolchain@v1
with:
profile: minimal
toolchain: stable
override: true
- uses: actions-rs/audit-check@v1
with:
token: ${{ secrets.GITHUB_TOKEN }}

View File

@@ -8,6 +8,34 @@ file. This change log follows the conventions of
### Added
- Client events are now implemented through `SimConnect::subscribe_to_client_event`, `SimConnect::unsubscribe_from_client_event` and `SimConnect::unsubscribe_from_all_client_events`.
- `subscribe_to_client_events.rs` example has been added.
- `SimConnectError::EventAlreadySubscribedTo` and `SimConnectError::EventNotSubscribedTo` error variants have been added.
### Changed
- A second call to `SimConnect::subscribe_to_system_event` for the same event will now return an error of type `SimConnectError::EventAlreadySubscribedTo` instead of `SimConnectError::SimConnectException`.
- The call to `SimConnect::unsubscribe_from_system_event` is now a NOOP when the system event is not subscribed to.
- `SimConnectError::UnimplementedMessageType` has been renamed to `SimConnectError::UnimplementedNotification`.
### Removed
- `SimConnect::register_event` has been replaced by the new client event functions.
- `NotificationGroup` has been removed in favor of an internally managed notification group.
## [v0.2.2] - 2023-02-22
### Changed
- Updated to MSFS SDK v0.20.5.0.
- `SimConnect::get_next_dispatch` now takes a `&mut self` in order to be able to clean up requests that have returned all the results they ever will.
### Fixed
- `SimConnect::request_facilities_list` calls now automatically clean up the request after all the data is received.
## [v0.2.1] - 2022-10-29
### Added
- `#[derive(PartialEq)]` has been added to `Condition`, `DataType`, `FacilityType`, `NotificationGroup`, `Period`, `ViewType`, `ClientEvent`, `SystemEventRequest` and `SystemEvent`.
- `#[derive(Eq)]` has been added to `Condition`, `DataType`, `FacilityType`, `NotificationGroup`, `Period`, `ViewType`, `ClientEvent` and `SystemEventRequest`.
@@ -61,6 +89,8 @@ file. This change log follows the conventions of
### Initial Release of simconnect-sdk
[unreleased]: https://github.com/mihai-dinculescu/simconnect-sdk-rs
[v0.2.2]: https://github.com/mihai-dinculescu/simconnect-sdk-rs/tree/v0.2.2
[v0.2.1]: https://github.com/mihai-dinculescu/simconnect-sdk-rs/tree/v0.2.1
[v0.2.0]: https://github.com/mihai-dinculescu/simconnect-sdk-rs/tree/v0.2.0
[v0.1.3]: https://github.com/mihai-dinculescu/simconnect-sdk-rs/tree/v0.1.3
[v0.1.2]: https://github.com/mihai-dinculescu/simconnect-sdk-rs/tree/v0.1.2

View File

@@ -5,9 +5,9 @@ If you're thinking to create a PR with large feature/change, please first discus
## Releases
- Update version in `examples/Cargo.toml`
- Update version in `simconnect-sdk/Cargo.toml` (crate + `simconnect-sdk-derive`)
- Update version in `simconnect-sdk-derive/Cargo.toml`
- Update version in `simconnect-sdk/Cargo.toml` (crate + `simconnect-sdk-derive`)
- Update version in `examples/Cargo.toml`
- Update CHANGELOG.md
- Commit
- Add tag

387
Cargo.lock generated
View File

@@ -3,24 +3,46 @@
version = 3
[[package]]
name = "bindgen"
version = "0.61.0"
name = "anyhow"
version = "1.0.90"
source = "registry+https://github.com/rust-lang/crates.io-index"
checksum = "8a022e58a142a46fea340d68012b9201c094e93ec3d033a944a24f8fd4a4f09a"
checksum = "37bf3594c4c988a53154954629820791dde498571819ae4ca50ca811e060cc95"
[[package]]
name = "autocfg"
version = "1.1.0"
source = "registry+https://github.com/rust-lang/crates.io-index"
checksum = "d468802bab17cbc0cc575e9b053f41e72aa36bfa6b7f55e3529ffa43161b97fa"
[[package]]
name = "basic-toml"
version = "0.1.2"
source = "registry+https://github.com/rust-lang/crates.io-index"
checksum = "5c0de75129aa8d0cceaf750b89013f0e08804d6ec61416da787b35ad0d7cddf1"
dependencies = [
"bitflags",
"serde",
]
[[package]]
name = "bindgen"
version = "0.65.1"
source = "registry+https://github.com/rust-lang/crates.io-index"
checksum = "cfdf7b466f9a4903edc73f95d6d2bcd5baf8ae620638762244d3f60143643cc5"
dependencies = [
"bitflags 1.3.2",
"cexpr",
"clang-sys",
"lazy_static",
"lazycell",
"log",
"peeking_take_while",
"prettyplease",
"proc-macro2",
"quote",
"regex",
"rustc-hash",
"shlex",
"syn",
"syn 2.0.15",
"which",
]
@@ -30,6 +52,12 @@ version = "1.3.2"
source = "registry+https://github.com/rust-lang/crates.io-index"
checksum = "bef38d45163c2f1dde094a7dfd33ccf595c92905c8f8f4fdc18d06fb1037718a"
[[package]]
name = "bitflags"
version = "2.6.0"
source = "registry+https://github.com/rust-lang/crates.io-index"
checksum = "b048fb63fd8b5923fc5aa7b340d8e156aec7ec02f0c78fa8a6ddc2613f6f71de"
[[package]]
name = "cexpr"
version = "0.6.0"
@@ -46,10 +74,16 @@ source = "registry+https://github.com/rust-lang/crates.io-index"
checksum = "baf1de4339761588bc0619e3cbc0120ee582ebb74b53b4efbf79117bd2da40fd"
[[package]]
name = "clang-sys"
version = "1.4.0"
name = "cfg_aliases"
version = "0.2.1"
source = "registry+https://github.com/rust-lang/crates.io-index"
checksum = "fa2e27ae6ab525c3d369ded447057bca5438d86dc3a68f6faafb8269ba82ebf3"
checksum = "613afe47fcd5fac7ccf1db93babcb082c5994d996f20b8b159f2ad1658eb5724"
[[package]]
name = "clang-sys"
version = "1.6.1"
source = "registry+https://github.com/rust-lang/crates.io-index"
checksum = "c688fc74432808e3eb684cae8830a86be1d66a2bd58e1f248ed0960a590baf6f"
dependencies = [
"glob",
"libc",
@@ -57,28 +91,54 @@ dependencies = [
]
[[package]]
name = "dissimilar"
version = "1.0.4"
name = "ctrlc"
version = "3.4.5"
source = "registry+https://github.com/rust-lang/crates.io-index"
checksum = "8c97b9233581d84b8e1e689cdd3a47b6f69770084fc246e86a7f78b0d9c1d4a5"
checksum = "90eeab0aa92f3f9b4e87f258c72b139c207d251f9cbc1080a0086b86a8870dd3"
dependencies = [
"nix",
"windows-sys",
]
[[package]]
name = "dissimilar"
version = "1.0.6"
source = "registry+https://github.com/rust-lang/crates.io-index"
checksum = "210ec60ae7d710bed8683e333e9d2855a8a56a3e9892b38bad3bb0d4d29b0d5e"
[[package]]
name = "either"
version = "1.8.0"
version = "1.8.1"
source = "registry+https://github.com/rust-lang/crates.io-index"
checksum = "90e5c1c8368803113bf0c9584fc495a58b86dc8a29edbf8fe877d21d9507e797"
checksum = "7fcaabb2fef8c910e7f4c7ce9f67a1283a1715879a7c230ca9d6d1ae31f16d91"
[[package]]
name = "glob"
version = "0.3.0"
version = "0.3.1"
source = "registry+https://github.com/rust-lang/crates.io-index"
checksum = "9b919933a397b79c37e33b77bb2aa3dc8eb6e165ad809e58ff75bc7db2e34574"
checksum = "d2fabcfbdc87f4758337ca535fb41a6d701b65693ce38287d856d1674551ec9b"
[[package]]
name = "hashbrown"
version = "0.12.3"
source = "registry+https://github.com/rust-lang/crates.io-index"
checksum = "8a9ee70c43aaf417c914396645a0fa852624801b24ebb7ae78fe8272889ac888"
[[package]]
name = "indexmap"
version = "1.9.3"
source = "registry+https://github.com/rust-lang/crates.io-index"
checksum = "bd070e393353796e801d209ad339e89596eb4c8d430d18ede6a1cced8fafbd99"
dependencies = [
"autocfg",
"hashbrown",
]
[[package]]
name = "itoa"
version = "1.0.4"
version = "1.0.6"
source = "registry+https://github.com/rust-lang/crates.io-index"
checksum = "4217ad341ebadf8d8e724e264f13e593e0648f5b3e94b3896a5df283be015ecc"
checksum = "453ad9f582a441959e5f0d088b02ce04cfe8d51a8eaf077f12ac6d3e94164ca6"
[[package]]
name = "lazy_static"
@@ -94,15 +154,15 @@ checksum = "830d08ce1d1d941e6b30645f1a0eb5643013d835ce3779a5fc208261dbe10f55"
[[package]]
name = "libc"
version = "0.2.137"
version = "0.2.161"
source = "registry+https://github.com/rust-lang/crates.io-index"
checksum = "fc7fcc620a3bff7cdd7a365be3376c97191aeaccc2a603e600951e452615bf89"
checksum = "8e9489c2807c139ffd9c1794f4af0ebe86a828db53ecdc7fea2111d0fed085d1"
[[package]]
name = "libloading"
version = "0.7.3"
version = "0.7.4"
source = "registry+https://github.com/rust-lang/crates.io-index"
checksum = "efbc0f03f9a775e9f6aed295c6a1ba2253c5757a9e03d55c6caa46a681abcddd"
checksum = "b67380fd3b2fbe7527a606e18729d21c6f3951633d0500574c4dc22d2d638b9f"
dependencies = [
"cfg-if",
"winapi",
@@ -139,10 +199,22 @@ source = "registry+https://github.com/rust-lang/crates.io-index"
checksum = "68354c5c6bd36d73ff3feceb05efa59b6acb7626617f4962be322a825e61f79a"
[[package]]
name = "nom"
version = "7.1.1"
name = "nix"
version = "0.29.0"
source = "registry+https://github.com/rust-lang/crates.io-index"
checksum = "a8903e5a29a317527874d0402f867152a3d21c908bb0b933e416c65e301d4c36"
checksum = "71e2746dc3a24dd78b3cfcb7be93368c6de9963d30f43a6a73998a9cf4b17b46"
dependencies = [
"bitflags 2.6.0",
"cfg-if",
"cfg_aliases",
"libc",
]
[[package]]
name = "nom"
version = "7.1.3"
source = "registry+https://github.com/rust-lang/crates.io-index"
checksum = "d273983c5a657a70a3e8f2a01329822f3b8c8172b73826411a55751e404a0a4a"
dependencies = [
"memchr",
"minimal-lexical",
@@ -160,30 +232,30 @@ dependencies = [
[[package]]
name = "num_enum"
version = "0.5.7"
version = "0.6.1"
source = "registry+https://github.com/rust-lang/crates.io-index"
checksum = "cf5395665662ef45796a4ff5486c5d41d29e0c09640af4c5f17fd94ee2c119c9"
checksum = "7a015b430d3c108a207fd776d2e2196aaf8b1cf8cf93253e3a097ff3085076a1"
dependencies = [
"num_enum_derive",
]
[[package]]
name = "num_enum_derive"
version = "0.5.7"
version = "0.6.1"
source = "registry+https://github.com/rust-lang/crates.io-index"
checksum = "3b0498641e53dd6ac1a4f22547548caa6864cc4933784319cd1775271c5a46ce"
checksum = "96667db765a921f7b295ffee8b60472b686a51d4f21c2ee4ffdb94c7013b65a6"
dependencies = [
"proc-macro-crate",
"proc-macro2",
"quote",
"syn",
"syn 2.0.15",
]
[[package]]
name = "once_cell"
version = "1.16.0"
version = "1.17.1"
source = "registry+https://github.com/rust-lang/crates.io-index"
checksum = "86f0b0d4bf799edbc74508c1e8bf170ff5f41238e5f8225603ca7caaae2b7860"
checksum = "b7e5500299e16ebb147ae15a00a942af264cf3688f47923b8fc2cd5858f23ad3"
[[package]]
name = "overload"
@@ -204,41 +276,50 @@ source = "registry+https://github.com/rust-lang/crates.io-index"
checksum = "e0a7ae3ac2f1173085d398531c705756c94a4c56843785df85a60c1a0afac116"
[[package]]
name = "proc-macro-crate"
version = "1.2.1"
name = "prettyplease"
version = "0.2.4"
source = "registry+https://github.com/rust-lang/crates.io-index"
checksum = "eda0fc3b0fb7c975631757e14d9049da17374063edb6ebbcbc54d880d4fe94e9"
checksum = "1ceca8aaf45b5c46ec7ed39fff75f57290368c1846d33d24a122ca81416ab058"
dependencies = [
"proc-macro2",
"syn 2.0.15",
]
[[package]]
name = "proc-macro-crate"
version = "1.3.1"
source = "registry+https://github.com/rust-lang/crates.io-index"
checksum = "7f4c021e1093a56626774e81216a4ce732a735e5bad4868a03f3ed65ca0c3919"
dependencies = [
"once_cell",
"thiserror",
"toml",
"toml_edit",
]
[[package]]
name = "proc-macro2"
version = "1.0.47"
version = "1.0.88"
source = "registry+https://github.com/rust-lang/crates.io-index"
checksum = "5ea3d908b0e36316caf9e9e2c4625cdde190a7e6f440d794667ed17a1855e725"
checksum = "7c3a7fc5db1e57d5a779a352c8cdb57b29aa4c40cc69c3a68a7fedc815fbf2f9"
dependencies = [
"unicode-ident",
]
[[package]]
name = "quote"
version = "1.0.21"
version = "1.0.26"
source = "registry+https://github.com/rust-lang/crates.io-index"
checksum = "bbe448f377a7d6961e30f5955f9b8d106c3f5e449d493ee1b125c1d43c2b5179"
checksum = "4424af4bf778aae2051a77b60283332f386554255d722233d09fbfc7e30da2fc"
dependencies = [
"proc-macro2",
]
[[package]]
name = "regex"
version = "1.6.0"
version = "1.8.1"
source = "registry+https://github.com/rust-lang/crates.io-index"
checksum = "4c4eb3267174b8c6c2f654116623910a0fef09c4753f8dd83db29c48a0df988b"
checksum = "af83e617f331cc6ae2da5443c602dfa5af81e517212d9d611a5b3ba1777b5370"
dependencies = [
"regex-syntax",
"regex-syntax 0.7.1",
]
[[package]]
@@ -247,14 +328,20 @@ version = "0.1.10"
source = "registry+https://github.com/rust-lang/crates.io-index"
checksum = "6c230d73fb8d8c1b9c0b3135c5142a8acee3a0558fb8db5cf1cb65f8d7862132"
dependencies = [
"regex-syntax",
"regex-syntax 0.6.29",
]
[[package]]
name = "regex-syntax"
version = "0.6.27"
version = "0.6.29"
source = "registry+https://github.com/rust-lang/crates.io-index"
checksum = "a3f87b73ce11b1619a3c6332f45341e0047173771e8b8b73f87bfeefb7b56244"
checksum = "f162c6dd7b008981e4d40210aca20b4bd0f9b60ca9271061b07f78537722f2e1"
[[package]]
name = "regex-syntax"
version = "0.7.1"
source = "registry+https://github.com/rust-lang/crates.io-index"
checksum = "a5996294f19bd3aae0453a862ad728f60e6600695733dd5df01da90c54363a3c"
[[package]]
name = "rustc-hash"
@@ -264,32 +351,32 @@ checksum = "08d43f7aa6b08d49f382cde6a7982047c3426db949b1424bc4b7ec9ae12c6ce2"
[[package]]
name = "ryu"
version = "1.0.11"
version = "1.0.13"
source = "registry+https://github.com/rust-lang/crates.io-index"
checksum = "4501abdff3ae82a1c1b477a17252eb69cee9e66eb915c1abaa4f44d873df9f09"
checksum = "f91339c0467de62360649f8d3e185ca8de4224ff281f66000de5eb2a77a79041"
[[package]]
name = "serde"
version = "1.0.147"
version = "1.0.160"
source = "registry+https://github.com/rust-lang/crates.io-index"
checksum = "d193d69bae983fc11a79df82342761dfbf28a99fc8d203dca4c3c1b590948965"
checksum = "bb2f3770c8bce3bcda7e149193a069a0f4365bda1fa5cd88e03bca26afc1216c"
[[package]]
name = "serde_derive"
version = "1.0.147"
version = "1.0.160"
source = "registry+https://github.com/rust-lang/crates.io-index"
checksum = "4f1d362ca8fc9c3e3a7484440752472d68a6caa98f1ab81d99b5dfe517cec852"
checksum = "291a097c63d8497e00160b166a967a4a79c64f3facdd01cbd7502231688d77df"
dependencies = [
"proc-macro2",
"quote",
"syn",
"syn 2.0.15",
]
[[package]]
name = "serde_json"
version = "1.0.87"
version = "1.0.96"
source = "registry+https://github.com/rust-lang/crates.io-index"
checksum = "6ce777b7b150d76b9cf60d28b55f5847135a003f7d7350c6be7a773508ce7d45"
checksum = "057d394a50403bcac12672b2b18fb387ab6d289d957dab67dd201875391e52f1"
dependencies = [
"itoa",
"ryu",
@@ -313,7 +400,7 @@ checksum = "43b2853a4d09f215c24cc5489c992ce46052d359b5109343cbafbf26bc62f8a3"
[[package]]
name = "simconnect-sdk"
version = "0.2.0"
version = "0.2.2"
dependencies = [
"bindgen",
"num_enum",
@@ -324,19 +411,19 @@ dependencies = [
[[package]]
name = "simconnect-sdk-derive"
version = "0.2.0"
version = "0.2.2"
dependencies = [
"once_cell",
"proc-macro2",
"quote",
"simconnect-sdk",
"syn",
"syn 1.0.109",
"trybuild",
]
[[package]]
name = "simconnect-sdk-examples"
version = "0.2.0"
version = "0.2.2"
dependencies = [
"simconnect-sdk",
"tracing",
@@ -351,9 +438,20 @@ checksum = "a507befe795404456341dfab10cef66ead4c041f62b8b11bbb92bffe5d0953e0"
[[package]]
name = "syn"
version = "1.0.103"
version = "1.0.109"
source = "registry+https://github.com/rust-lang/crates.io-index"
checksum = "a864042229133ada95abf3b54fdc62ef5ccabe9515b64717bcb9a1919e59445d"
checksum = "72b64191b275b66ffe2469e8af2c1cfe3bafa67b529ead792a6d0160888b4237"
dependencies = [
"proc-macro2",
"quote",
"unicode-ident",
]
[[package]]
name = "syn"
version = "2.0.15"
source = "registry+https://github.com/rust-lang/crates.io-index"
checksum = "a34fcf3e8b60f57e6a14301a2e916d323af98b0ea63c599441eec8558660c822"
dependencies = [
"proc-macro2",
"quote",
@@ -362,58 +460,77 @@ dependencies = [
[[package]]
name = "termcolor"
version = "1.1.3"
version = "1.2.0"
source = "registry+https://github.com/rust-lang/crates.io-index"
checksum = "bab24d30b911b2376f3a13cc2cd443142f0c81dda04c118693e35b3835757755"
checksum = "be55cf8942feac5c765c2c993422806843c9a9a45d4d5c407ad6dd2ea95eb9b6"
dependencies = [
"winapi-util",
]
[[package]]
name = "testapp"
version = "0.1.0"
dependencies = [
"anyhow",
"ctrlc",
"simconnect-sdk",
"tracing",
"tracing-subscriber",
]
[[package]]
name = "thiserror"
version = "1.0.37"
version = "1.0.40"
source = "registry+https://github.com/rust-lang/crates.io-index"
checksum = "10deb33631e3c9018b9baf9dcbbc4f737320d2b576bac10f6aefa048fa407e3e"
checksum = "978c9a314bd8dc99be594bc3c175faaa9794be04a5a5e153caba6915336cebac"
dependencies = [
"thiserror-impl",
]
[[package]]
name = "thiserror-impl"
version = "1.0.37"
version = "1.0.40"
source = "registry+https://github.com/rust-lang/crates.io-index"
checksum = "982d17546b47146b28f7c22e3d08465f6b8903d0ea13c1660d9d84a6e7adcdbb"
checksum = "f9456a42c5b0d803c8cd86e73dd7cc9edd429499f37a3550d286d5e86720569f"
dependencies = [
"proc-macro2",
"quote",
"syn",
"syn 2.0.15",
]
[[package]]
name = "thread_local"
version = "1.1.4"
version = "1.1.7"
source = "registry+https://github.com/rust-lang/crates.io-index"
checksum = "5516c27b78311c50bf42c071425c560ac799b11c30b31f87e3081965fe5e0180"
checksum = "3fdd6f064ccff2d6567adcb3873ca630700f00b5ad3f060c25b5dcfd9a4ce152"
dependencies = [
"cfg-if",
"once_cell",
]
[[package]]
name = "toml"
version = "0.5.9"
name = "toml_datetime"
version = "0.6.1"
source = "registry+https://github.com/rust-lang/crates.io-index"
checksum = "8d82e1a7758622a465f8cee077614c73484dac5b836c02ff6a40d5d1010324d7"
checksum = "3ab8ed2edee10b50132aed5f331333428b011c99402b5a534154ed15746f9622"
[[package]]
name = "toml_edit"
version = "0.19.8"
source = "registry+https://github.com/rust-lang/crates.io-index"
checksum = "239410c8609e8125456927e6707163a3b1fdb40561e4b803bc041f466ccfdc13"
dependencies = [
"serde",
"indexmap",
"toml_datetime",
"winnow",
]
[[package]]
name = "tracing"
version = "0.1.37"
version = "0.1.40"
source = "registry+https://github.com/rust-lang/crates.io-index"
checksum = "8ce8c33a8d48bd45d624a6e523445fd21ec13d3653cd51f681abf67418f54eb8"
checksum = "c3523ab5a71916ccf420eebdf5521fcef02141234bbc0b8a49f2fdc4544364ef"
dependencies = [
"cfg-if",
"pin-project-lite",
"tracing-attributes",
"tracing-core",
@@ -421,20 +538,20 @@ dependencies = [
[[package]]
name = "tracing-attributes"
version = "0.1.23"
version = "0.1.27"
source = "registry+https://github.com/rust-lang/crates.io-index"
checksum = "4017f8f45139870ca7e672686113917c71c7a6e02d4924eda67186083c03081a"
checksum = "34704c8d6ebcbc939824180af020566b01a7c01f80641264eba0999f6c2b6be7"
dependencies = [
"proc-macro2",
"quote",
"syn",
"syn 2.0.15",
]
[[package]]
name = "tracing-core"
version = "0.1.30"
version = "0.1.32"
source = "registry+https://github.com/rust-lang/crates.io-index"
checksum = "24eb03ba0eab1fd845050058ce5e616558e8f8d8fca633e6b163fe25c797213a"
checksum = "c06d3da6113f116aaee68e4d601191614c9053067f9ab7f6edbcb161237daa54"
dependencies = [
"once_cell",
"valuable",
@@ -442,20 +559,20 @@ dependencies = [
[[package]]
name = "tracing-log"
version = "0.1.3"
version = "0.2.0"
source = "registry+https://github.com/rust-lang/crates.io-index"
checksum = "78ddad33d2d10b1ed7eb9d1f518a5674713876e97e5bb9b7345a7984fbb4f922"
checksum = "ee855f1f400bd0e5c02d150ae5de3840039a3f54b025156404e34c23c03f47c3"
dependencies = [
"lazy_static",
"log",
"once_cell",
"tracing-core",
]
[[package]]
name = "tracing-subscriber"
version = "0.3.16"
version = "0.3.18"
source = "registry+https://github.com/rust-lang/crates.io-index"
checksum = "a6176eae26dd70d0c919749377897b54a9276bd7061339665dd68777926b5a70"
checksum = "ad0f048c97dbd9faa9b7df56362b8ebcaa52adb06b498c050d2f4e32f90a7a8b"
dependencies = [
"matchers",
"nu-ansi-term",
@@ -471,10 +588,11 @@ dependencies = [
[[package]]
name = "trybuild"
version = "1.0.71"
version = "1.0.80"
source = "registry+https://github.com/rust-lang/crates.io-index"
checksum = "ea496675d71016e9bc76aa42d87f16aefd95447cc5818e671e12b2d7e269075d"
checksum = "501dbdbb99861e4ab6b60eb6a7493956a9defb644fd034bc4a5ef27c693c8a3a"
dependencies = [
"basic-toml",
"dissimilar",
"glob",
"once_cell",
@@ -482,14 +600,13 @@ dependencies = [
"serde_derive",
"serde_json",
"termcolor",
"toml",
]
[[package]]
name = "unicode-ident"
version = "1.0.5"
version = "1.0.8"
source = "registry+https://github.com/rust-lang/crates.io-index"
checksum = "6ceab39d59e4c9499d4e5a8ee0e2735b891bb7308ac83dfb4e80cad195c9f6f3"
checksum = "e5464a87b239f13a63a501f2701565754bae92d243d4bb7eb12f6d57d2269bf4"
[[package]]
name = "valuable"
@@ -499,9 +616,9 @@ checksum = "830b7e5d4d90034032940e4ace0d9a9a057e7a45cd94e6c007832e39edb82f6d"
[[package]]
name = "which"
version = "4.3.0"
version = "4.4.0"
source = "registry+https://github.com/rust-lang/crates.io-index"
checksum = "1c831fbbee9e129a8cf93e7747a82da9d95ba8e16621cae60ec2cdc849bacb7b"
checksum = "2441c784c52b289a054b7201fc93253e288f094e2f4be9058343127c4226a269"
dependencies = [
"either",
"libc",
@@ -538,3 +655,85 @@ name = "winapi-x86_64-pc-windows-gnu"
version = "0.4.0"
source = "registry+https://github.com/rust-lang/crates.io-index"
checksum = "712e227841d057c1ee1cd2fb22fa7e5a5461ae8e48fa2ca79ec42cfc1931183f"
[[package]]
name = "windows-sys"
version = "0.59.0"
source = "registry+https://github.com/rust-lang/crates.io-index"
checksum = "1e38bc4d79ed67fd075bcc251a1c39b32a1776bbe92e5bef1f0bf1f8c531853b"
dependencies = [
"windows-targets",
]
[[package]]
name = "windows-targets"
version = "0.52.6"
source = "registry+https://github.com/rust-lang/crates.io-index"
checksum = "9b724f72796e036ab90c1021d4780d4d3d648aca59e491e6b98e725b84e99973"
dependencies = [
"windows_aarch64_gnullvm",
"windows_aarch64_msvc",
"windows_i686_gnu",
"windows_i686_gnullvm",
"windows_i686_msvc",
"windows_x86_64_gnu",
"windows_x86_64_gnullvm",
"windows_x86_64_msvc",
]
[[package]]
name = "windows_aarch64_gnullvm"
version = "0.52.6"
source = "registry+https://github.com/rust-lang/crates.io-index"
checksum = "32a4622180e7a0ec044bb555404c800bc9fd9ec262ec147edd5989ccd0c02cd3"
[[package]]
name = "windows_aarch64_msvc"
version = "0.52.6"
source = "registry+https://github.com/rust-lang/crates.io-index"
checksum = "09ec2a7bb152e2252b53fa7803150007879548bc709c039df7627cabbd05d469"
[[package]]
name = "windows_i686_gnu"
version = "0.52.6"
source = "registry+https://github.com/rust-lang/crates.io-index"
checksum = "8e9b5ad5ab802e97eb8e295ac6720e509ee4c243f69d781394014ebfe8bbfa0b"
[[package]]
name = "windows_i686_gnullvm"
version = "0.52.6"
source = "registry+https://github.com/rust-lang/crates.io-index"
checksum = "0eee52d38c090b3caa76c563b86c3a4bd71ef1a819287c19d586d7334ae8ed66"
[[package]]
name = "windows_i686_msvc"
version = "0.52.6"
source = "registry+https://github.com/rust-lang/crates.io-index"
checksum = "240948bc05c5e7c6dabba28bf89d89ffce3e303022809e73deaefe4f6ec56c66"
[[package]]
name = "windows_x86_64_gnu"
version = "0.52.6"
source = "registry+https://github.com/rust-lang/crates.io-index"
checksum = "147a5c80aabfbf0c7d901cb5895d1de30ef2907eb21fbbab29ca94c5b08b1a78"
[[package]]
name = "windows_x86_64_gnullvm"
version = "0.52.6"
source = "registry+https://github.com/rust-lang/crates.io-index"
checksum = "24d5b23dc417412679681396f2b49f3de8c1473deb516bd34410872eff51ed0d"
[[package]]
name = "windows_x86_64_msvc"
version = "0.52.6"
source = "registry+https://github.com/rust-lang/crates.io-index"
checksum = "589f6da84c646204747d1270a2a5661ea66ed1cced2631d546fdfb155959f9ec"
[[package]]
name = "winnow"
version = "0.4.4"
source = "registry+https://github.com/rust-lang/crates.io-index"
checksum = "5617da7e1f97bf363947d767b91aaf3c2bbc19db7fda9c65af1278713d58e0a2"
dependencies = [
"memchr",
]

View File

@@ -1,6 +1,5 @@
[workspace]
members = [
"examples",
"simconnect-sdk",
"simconnect-sdk-derive",
]
resolver = "2"
members = ["examples", "simconnect-sdk", "simconnect-sdk-derive", "testapp"]
default-members = ["testapp"]

View File

@@ -3,34 +3,34 @@
## General
| Feature | Status | Comment |
| --------------------------------------- | ------- | ------- |
| --------------------------------------- | ------- | -------------------------------------------- |
| DispatchProc | | |
| SimConnect_Open | &check; | |
| SimConnect_Close | &check; | |
| SimConnect_CallDispatch | | |
| SimConnect_GetNextDispatch | &check; | |
| SimConnect_RequestSystemState | | |
| SimConnect_MapClientEventToSimEvent | - | WIP |
| SimConnect_MapClientEventToSimEvent | &check; | Encapsulated by `subscribe_to_client_event`. |
| SimConnect_SubscribeToSystemEvent | &check; | |
| SimConnect_SetSystemEventState | | |
| SimConnect_UnsubscribeFromSystemEvent | &check; | |
| SimConnect_SetNotificationGroupPriority | - | WIP |
| SimConnect_SetNotificationGroupPriority | &check; | Encapsulated by `subscribe_to_client_event`. |
## Events And Data
| Feature | Status | Comment |
| -------------------------------------------- | ------- | ----------------------------------- |
| SimConnect_RequestDataOnSimObject | &check; | Only for SIMCONNECT_OBJECT_ID_USER |
| -------------------------------------------- | ------- | -------------------------------------------------------------------------------------------------- |
| SimConnect_RequestDataOnSimObject | &check; | Only for `SIMCONNECT_OBJECT_ID_USER`. |
| SimConnect_RequestDataOnSimObjectType | | |
| SimConnect_AddClientEventToNotificationGroup | - | WIP |
| SimConnect_RemoveClientEvent | | |
| SimConnect_AddClientEventToNotificationGroup | &check; | Encapsulated by `subscribe_to_client_event`. |
| SimConnect_RemoveClientEvent | &check; | |
| SimConnect_TransmitClientEvent | | |
| SimConnect_TransmitClientEvent_EX1 | | |
| SimConnect_MapClientDataNameToID | | |
| SimConnect_RequestClientData | | |
| SimConnect_CreateClientData | | |
| SimConnect_AddToClientDataDefinition | | |
| SimConnect_AddToDataDefinition | &check; | Supports `f64`, `bool` and `String` |
| SimConnect_AddToDataDefinition | &check; | Encapsulated by `register_object` and the `simconnect` macro. Supports `f64`, `bool` and `String`. |
| SimConnect_SetClientData | | |
| SimConnect_SetDataOnSimObject | | |
| SimConnect_ClearClientDataDefinition | | |
@@ -38,7 +38,7 @@
| SimConnect_MapInputEventToClientEvent | | |
| SimConnect_RequestNotificationGroup | | |
| SimConnect_ClearInputGroup | | |
| SimConnect_ClearNotificationGroup | | |
| SimConnect_ClearNotificationGroup | &check; | Implemented by `unsubscribe_from_all_client_events`. |
| SimConnect_RequestReservedKey | | |
| SimConnect_SetInputGroupPriority | | |
| SimConnect_SetInputGroupState | | |

6
TODO.md Normal file
View File

@@ -0,0 +1,6 @@
# TODO
- SimConnect_RequestDataOnSimObjectType
- add support to request other object ids
- rename request_id to object_id
- type exceptions

View File

@@ -1,10 +1,12 @@
[package]
name = "simconnect-sdk-examples"
version = "0.2.0"
authors = ["Mihai Dinculescu <mihai.dinculescu@outlook.com>"]
version = "0.2.2"
edition = "2021"
description = "SimConnect SDK Examples"
license = "MIT"
authors = ["Mihai Dinculescu <mihai.dinculescu@outlook.com>"]
description = "SimConnect SDK Examples"
readme = "README.md"
repository = "https://github.com/mihai-dinculescu/simconnect-sdk-rs"
publish = false
[[bin]]
@@ -28,8 +30,12 @@ name = "facilities"
path = "src/facilities.rs"
[[bin]]
name = "system_events"
path = "src/system_events.rs"
name = "subscribe_to_client_events"
path = "src/subscribe_to_client_events.rs"
[[bin]]
name = "subscribe_to_system_events"
path = "src/subscribe_to_system_events.rs"
[dependencies]
tracing = "0.1"

View File

@@ -45,8 +45,14 @@ cargo run --bin data_multiple_objects
cargo run --bin facilities
```
## Receiving system events
## Subscribe to client events
```bash
cargo run --bin system_events
cargo run --bin subscribe_to_client_events
```
## Subscribe to system events
```bash
cargo run --bin subscribe_to_system_events
```

View File

@@ -1,76 +1,76 @@
use simconnect_sdk::{FacilityType, Notification, SimConnect};
// use simconnect_sdk::{FacilityType, Notification, SimConnect};
fn main() -> Result<(), Box<dyn std::error::Error>> {
let client = SimConnect::new("Facilities example");
// let client = SimConnect::new("Facilities example");
match client {
Ok(mut client) => loop {
let notification = client.get_next_dispatch()?;
// match client {
// Ok(mut client) => loop {
// let notification = client.get_next_dispatch()?;
match notification {
Some(Notification::Open) => {
println!("Connection opened.");
// match notification {
// Some(Notification::Open) => {
// println!("Connection opened.");
// After the connection is successfully open
// // After the connection is successfully open
// We request the existing list of airports in the facilities cache
client.request_facilities_list(FacilityType::Airport)?;
// // We request the existing list of airports in the facilities cache
// client.request_facilities_list(FacilityType::Airport)?;
// We subscribe to the current list and future additions of waypoints, NDBs and VORs
client.subscribe_to_facilities(FacilityType::Waypoint)?;
client.subscribe_to_facilities(FacilityType::NDB)?;
client.subscribe_to_facilities(FacilityType::VOR)?;
}
Some(Notification::AirportList(data)) => {
for record in data {
// The returned list is quite large, so we look for a particular record
if record.icao == "EGSC" {
println!("{record:?}");
// we've got the entry we're interesting in - we can unsubscribe now
client.unsubscribe_to_facilities(FacilityType::Airport)?;
}
}
}
Some(Notification::WaypointList(data)) => {
for record in data {
// The returned list is quite large, so we look for a particular record
if record.icao == "BRAIN" {
println!("{record:?}");
// we've got the entry we're interesting in - we can unsubscribe now
client.unsubscribe_to_facilities(FacilityType::Waypoint)?;
}
}
}
Some(Notification::NdbList(data)) => {
for record in data {
// The returned list is quite large, so we look for a particular record
if record.icao == "CAM" {
println!("{record:?}");
// we've got the entry we're interesting in - we can unsubscribe now
client.unsubscribe_to_facilities(FacilityType::NDB)?;
}
}
}
Some(Notification::VorList(data)) => {
for record in data {
// The returned list is quite large, so we look for a particular record
if record.icao == "LON" {
println!("{record:?}");
// we've got the entry we're interesting in - we can unsubscribe now
client.unsubscribe_to_facilities(FacilityType::VOR)?;
}
}
}
_ => (),
}
// // We subscribe to the current list and future additions of waypoints, NDBs and VORs
// client.subscribe_to_facilities(FacilityType::Waypoint)?;
// client.subscribe_to_facilities(FacilityType::NDB)?;
// client.subscribe_to_facilities(FacilityType::VOR)?;
// }
// Some(Notification::AirportList(data)) => {
// for record in data {
// // The returned list is quite large, so we look for a particular record
// // if record.icao == "EGSC" {
// // println!("{record:?}");
// // // there's no need to unsubscribe
// // // because this is a one-off request, not a subscription
// // }
// }
// }
// Some(Notification::WaypointList(data)) => {
// for record in data {
// // The returned list is quite large, so we look for a particular record
// // if record.icao == "BRAIN" {
// // println!("{record:?}");
// // // we've got the entry we're interesting in - we can unsubscribe now
// // client.unsubscribe_to_facilities(FacilityType::Waypoint)?;
// // }
// }
// }
// Some(Notification::NdbList(data)) => {
// for record in data {
// // The returned list is quite large, so we look for a particular record
// // if record.icao == "CAM" {
// // println!("{record:?}");
// // // we've got the entry we're interesting in - we can unsubscribe now
// // client.unsubscribe_to_facilities(FacilityType::NDB)?;
// // }
// }
// }
// Some(Notification::VorList(data)) => {
// for record in data {
// // The returned list is quite large, so we look for a particular record
// // if record.icao == "LON" {
// // println!("{record:?}");
// // // we've got the entry we're interesting in - we can unsubscribe now
// // client.unsubscribe_to_facilities(FacilityType::VOR)?;
// // }
// }
// }
// _ => (),
// }
// sleep for about a frame to reduce CPU usage
std::thread::sleep(std::time::Duration::from_millis(16));
},
Err(e) => {
println!("Error: {e:?}")
}
}
// // sleep for about a frame to reduce CPU usage
// std::thread::sleep(std::time::Duration::from_millis(16));
// },
// Err(e) => {
// println!("Error: {e:?}")
// }
// }
Ok(())
}

View File

@@ -0,0 +1,62 @@
use simconnect_sdk::{ClientEvent, ClientEventRequest, Notification, SimConnect};
fn main() -> Result<(), Box<dyn std::error::Error>> {
let client = SimConnect::new("Client Events example");
let mut throttle_events_received = 0;
let mut elevator_events_received = 0;
match client {
Ok(mut client) => loop {
let notification = client.get_next_dispatch()?;
match notification {
Some(Notification::Open) => {
println!("Connection opened.");
// After the connection is successfully open
// We subscribe to the client events we're interested in
client.subscribe_to_client_event(ClientEventRequest::Throttle1Set)?;
client.subscribe_to_client_event(ClientEventRequest::AxisElevatorSet)?;
}
Some(Notification::ClientEvent(event)) => match event {
ClientEvent::Throttle1Set { value } => {
println!("Throttle1Set: {value}");
throttle_events_received += 1;
if throttle_events_received >= 9 {
// We unsubscribe from the client event after we receive 10 of them
// This might run multiple times if there are more events queued up
println!("Unsubscribing from Throttle1Set...");
client
.unsubscribe_from_client_event(ClientEventRequest::Throttle1Set)?;
}
}
ClientEvent::AxisElevatorSet { value } => {
println!("AxisElevatorSet: {value}");
elevator_events_received += 1;
if elevator_events_received >= 9 {
// We unsubscribe from the client event after we receive 10 of them
// This might run multiple times if there are more events queued up
println!("Unsubscribing from AxisElevatorSet...");
client.unsubscribe_from_client_event(
ClientEventRequest::AxisElevatorSet,
)?;
}
}
_ => {}
},
_ => (),
}
// sleep for about a frame to reduce CPU usage
std::thread::sleep(std::time::Duration::from_millis(16));
},
Err(e) => {
println!("Error: {e:?}")
}
}
Ok(())
}

View File

@@ -1,7 +1,7 @@
use simconnect_sdk::{Notification, SimConnect, SystemEvent, SystemEventRequest};
fn main() -> Result<(), Box<dyn std::error::Error>> {
let client = SimConnect::new("System events example");
let client = SimConnect::new("System Events example");
match client {
Ok(mut client) => loop {

View File

@@ -1,6 +1,6 @@
[package]
name = "simconnect-sdk-derive"
version = "0.2.0"
version = "0.2.2"
edition = "2021"
license = "MIT"
authors = ["Mihai Dinculescu <mihai.dinculescu@outlook.com>"]
@@ -23,7 +23,7 @@ path = "tests/run.rs"
proc-macro2 = "1.0"
quote = "1.0"
syn = "1.0"
once_cell = "1.7"
once_cell = "1.17"
[dev-dependencies]
simconnect-sdk = { path = "../simconnect-sdk" }

View File

@@ -50,8 +50,9 @@ mod helpers;
pub fn derive(input: TokenStream) -> TokenStream {
let ast = parse_macro_input!(input as DeriveInput);
let vis = &ast.vis;
let name_ident = &ast.ident;
let packed_ident = syn::Ident::new(&format!("{}CPacked", name_ident), name_ident.span());
let packed_ident = syn::Ident::new(&format!("{name_ident}CPacked"), name_ident.span());
let fields = if let syn::Data::Struct(syn::DataStruct {
fields: syn::Fields::Named(syn::FieldsNamed { ref named, .. }),
@@ -97,8 +98,8 @@ pub fn derive(input: TokenStream) -> TokenStream {
// put everything together
let expanded = quote! {
#[repr(C, packed)]
struct #packed_ident {
#(#packed_fields,)*
#vis struct #packed_ident {
#(#vis #packed_fields,)*
}
impl simconnect_sdk::SimConnectObjectExt for #name_ident {
fn register(client: &mut simconnect_sdk::SimConnect, id: u32) -> Result<(), simconnect_sdk::SimConnectError> {
@@ -192,6 +193,11 @@ fn build_sc_definition(
client.add_to_data_definition(id, #name, #unit, simconnect_sdk::DataType::String)?;
}
}
Some(value) if value == "[i8; 256]" => {
quote! {
client.add_to_data_definition(id, #name, #unit, simconnect_sdk::DataType::String)?;
}
}
_ => {
// this error is already caught in `parse_field_attributes`
mk_err(path, error_message)

View File

@@ -1,6 +1,6 @@
[package]
name = "simconnect-sdk"
version = "0.2.0"
version = "0.2.2"
edition = "2021"
license = "MIT"
authors = ["Mihai Dinculescu <mihai.dinculescu@outlook.com>"]
@@ -16,13 +16,13 @@ default = []
derive = ["simconnect-sdk-derive"]
[build-dependencies]
bindgen = "0.61"
bindgen = "0.65"
[dependencies]
num_enum = "0.5"
num_enum = "0.6"
tracing = "0.1"
thiserror = "1.0"
simconnect-sdk-derive = { version = "=0.2.0", path = "../simconnect-sdk-derive", optional = true }
simconnect-sdk-derive = { version = "=0.2.2", path = "../simconnect-sdk-derive", optional = true }
[package.metadata.docs.rs]
features = ["derive"]

View File

@@ -25,11 +25,14 @@ fn main() {
.allowlist_function("SimConnect_AddToDataDefinition")
.allowlist_function("SimConnect_CallDispatch")
.allowlist_function("SimConnect_ClearDataDefinition")
.allowlist_function("SimConnect_ClearNotificationGroup")
.allowlist_function("SimConnect_Close")
.allowlist_function("SimConnect_GetNextDispatch")
.allowlist_function("SimConnect_MapClientEventToSimEvent")
.allowlist_function("SimConnect_Open")
.allowlist_function("SimConnect_RemoveClientEvent")
.allowlist_function("SimConnect_RequestDataOnSimObject")
.allowlist_function("SimConnect_SetDataOnSimObject")
.allowlist_function("SimConnect_RequestFacilitiesList")
.allowlist_function("SimConnect_SetNotificationGroupPriority")
.allowlist_function("SimConnect_SubscribeToFacilities")
@@ -52,6 +55,11 @@ fn main() {
.allowlist_type("SIMCONNECT_RECV_WAYPOINT_LIST")
.allowlist_type("SIMCONNECT_RECV")
.allowlist_var("SIMCONNECT_DATA_REQUEST_FLAG_CHANGED")
.allowlist_var("SIMCONNECT_GROUP_PRIORITY_DEFAULT")
.allowlist_var("SIMCONNECT_GROUP_PRIORITY_HIGHEST_MASKABLE")
.allowlist_var("SIMCONNECT_GROUP_PRIORITY_HIGHEST")
.allowlist_var("SIMCONNECT_GROUP_PRIORITY_LOWEST")
.allowlist_var("SIMCONNECT_GROUP_PRIORITY_STANDARD")
.allowlist_var("SIMCONNECT_OBJECT_ID_USER")
.allowlist_var("SIMCONNECT_RECV_ID_VOR_LIST_HAS_DME")
.allowlist_var("SIMCONNECT_RECV_ID_VOR_LIST_HAS_GLIDE_SLOPE")

View File

@@ -3,21 +3,20 @@
// Copyright (c) Microsoft Corporation. All Rights Reserved.
//
//-----------------------------------------------------------------------------
#pragma once
#ifndef _SIMCONNECT_H_
#define _SIMCONNECT_H_
#pragma once
// <ASOBO-MOD - GM - now in 64 bit
#ifndef SIMCONNECT_H_NOMANIFEST
#if _MSC_FULL_VER >= 140040130
#if defined(_M_IX86) || defined(_M_X64)
//#pragma comment(linker,"/manifestdependency:\"type='win32' " \
// "name='" "Microsoft..SimConnect" "' " \
// "name='" "Microsoft.FlightSimulator.SimConnect" "' " \
// "version='" "" "' " \
// "processorArchitecture='amd64' " \
// "publicKeyToken='" "" "'\"")
// "publicKeyToken='" "dd3546d27f3ecf37" "'\"")
#endif // #if defined(_M_IX86) || defined(_M_X64)
#endif // #if _MSC_FULL_VER >= 140040130
#endif // #ifndef SIMCONNECT_H_NOMANIFEST
@@ -42,6 +41,7 @@ static const float SIMCONNECT_CAMERA_IGNORE_FIELD = FLT_MAX; // Used to tell the
static const DWORD SIMCONNECT_CLIENTDATA_MAX_SIZE = 8192; // maximum value for SimConnect_CreateClientData dwSize parameter
// Notification Group priority values
static const DWORD SIMCONNECT_GROUP_PRIORITY_HIGHEST = 1; // highest priority
static const DWORD SIMCONNECT_GROUP_PRIORITY_HIGHEST_MASKABLE = 10000000; // highest priority that allows events to be masked
@@ -92,7 +92,8 @@ static const DWORD SIMCONNECT_OPEN_CONFIGINDEX_LOCAL = -1; // ignore SimConnect.
#define SIMCONNECT_USER_ENUM typedef DWORD
// Receive data types
SIMCONNECT_ENUM SIMCONNECT_RECV_ID{
SIMCONNECT_ENUM SIMCONNECT_RECV_ID
{
SIMCONNECT_RECV_ID_NULL,
SIMCONNECT_RECV_ID_EXCEPTION,
SIMCONNECT_RECV_ID_OPEN,
@@ -126,10 +127,19 @@ SIMCONNECT_ENUM SIMCONNECT_RECV_ID{
SIMCONNECT_RECV_ID_EVENT_EX1,
SIMCONNECT_RECV_ID_FACILITY_DATA,
SIMCONNECT_RECV_ID_FACILITY_DATA_END,
SIMCONNECT_RECV_ID_FACILITY_MINIMAL_LIST,
SIMCONNECT_RECV_ID_JETWAY_DATA,
SIMCONNECT_RECV_ID_CONTROLLERS_LIST,
SIMCONNECT_RECV_ID_ACTION_CALLBACK,
SIMCONNECT_RECV_ID_ENUMERATE_INPUT_EVENTS,
SIMCONNECT_RECV_ID_GET_INPUT_EVENT,
SIMCONNECT_RECV_ID_SUBSCRIBE_INPUT_EVENT,
SIMCONNECT_RECV_ID_ENUMERATE_INPUT_EVENT_PARAMS,
};
// Data data types
SIMCONNECT_ENUM SIMCONNECT_DATATYPE{
SIMCONNECT_ENUM SIMCONNECT_DATATYPE
{
SIMCONNECT_DATATYPE_INVALID, // invalid data type
SIMCONNECT_DATATYPE_INT32, // 32-bit integer number
SIMCONNECT_DATATYPE_INT64, // 64-bit integer number
@@ -153,7 +163,8 @@ SIMCONNECT_ENUM SIMCONNECT_DATATYPE{
};
// Exception error types
SIMCONNECT_ENUM SIMCONNECT_EXCEPTION{
SIMCONNECT_ENUM SIMCONNECT_EXCEPTION
{
SIMCONNECT_EXCEPTION_NONE,
SIMCONNECT_EXCEPTION_ERROR,
@@ -193,10 +204,17 @@ SIMCONNECT_ENUM SIMCONNECT_EXCEPTION{
SIMCONNECT_EXCEPTION_OBJECT_AI,
SIMCONNECT_EXCEPTION_OBJECT_ATC,
SIMCONNECT_EXCEPTION_OBJECT_SCHEDULE,
SIMCONNECT_EXCEPTION_JETWAY_DATA,
SIMCONNECT_EXCEPTION_ACTION_NOT_FOUND,
SIMCONNECT_EXCEPTION_NOT_AN_ACTION,
SIMCONNECT_EXCEPTION_INCORRECT_ACTION_PARAMS,
SIMCONNECT_EXCEPTION_GET_INPUT_EVENT_FAILED,
SIMCONNECT_EXCEPTION_SET_INPUT_EVENT_FAILED,
};
// Object types
SIMCONNECT_ENUM SIMCONNECT_SIMOBJECT_TYPE{
SIMCONNECT_ENUM SIMCONNECT_SIMOBJECT_TYPE
{
SIMCONNECT_SIMOBJECT_TYPE_USER,
SIMCONNECT_SIMOBJECT_TYPE_ALL,
SIMCONNECT_SIMOBJECT_TYPE_AIRCRAFT,
@@ -206,13 +224,15 @@ SIMCONNECT_ENUM SIMCONNECT_SIMOBJECT_TYPE{
};
// EventState values
SIMCONNECT_ENUM SIMCONNECT_STATE{
SIMCONNECT_ENUM SIMCONNECT_STATE
{
SIMCONNECT_STATE_OFF,
SIMCONNECT_STATE_ON,
};
// Object Data Request Period values
SIMCONNECT_ENUM SIMCONNECT_PERIOD{
SIMCONNECT_ENUM SIMCONNECT_PERIOD
{
SIMCONNECT_PERIOD_NEVER,
SIMCONNECT_PERIOD_ONCE,
SIMCONNECT_PERIOD_VISUAL_FRAME,
@@ -220,13 +240,16 @@ SIMCONNECT_ENUM SIMCONNECT_PERIOD{
SIMCONNECT_PERIOD_SECOND,
};
SIMCONNECT_ENUM SIMCONNECT_MISSION_END{
SIMCONNECT_ENUM SIMCONNECT_MISSION_END
{
SIMCONNECT_MISSION_FAILED,
SIMCONNECT_MISSION_CRASHED,
SIMCONNECT_MISSION_SUCCEEDED};
SIMCONNECT_MISSION_SUCCEEDED
};
// ClientData Request Period values
SIMCONNECT_ENUM SIMCONNECT_CLIENT_DATA_PERIOD{
SIMCONNECT_ENUM SIMCONNECT_CLIENT_DATA_PERIOD
{
SIMCONNECT_CLIENT_DATA_PERIOD_NEVER,
SIMCONNECT_CLIENT_DATA_PERIOD_ONCE,
SIMCONNECT_CLIENT_DATA_PERIOD_VISUAL_FRAME,
@@ -234,7 +257,8 @@ SIMCONNECT_ENUM SIMCONNECT_CLIENT_DATA_PERIOD{
SIMCONNECT_CLIENT_DATA_PERIOD_SECOND,
};
SIMCONNECT_ENUM SIMCONNECT_TEXT_TYPE{
SIMCONNECT_ENUM SIMCONNECT_TEXT_TYPE
{
SIMCONNECT_TEXT_TYPE_SCROLL_BLACK,
SIMCONNECT_TEXT_TYPE_SCROLL_WHITE,
SIMCONNECT_TEXT_TYPE_SCROLL_RED,
@@ -254,7 +278,8 @@ SIMCONNECT_ENUM SIMCONNECT_TEXT_TYPE{
SIMCONNECT_TEXT_TYPE_MENU = 0x0200,
};
SIMCONNECT_ENUM SIMCONNECT_TEXT_RESULT{
SIMCONNECT_ENUM SIMCONNECT_TEXT_RESULT
{
SIMCONNECT_TEXT_RESULT_MENU_SELECT_1,
SIMCONNECT_TEXT_RESULT_MENU_SELECT_2,
SIMCONNECT_TEXT_RESULT_MENU_SELECT_3,
@@ -272,14 +297,16 @@ SIMCONNECT_ENUM SIMCONNECT_TEXT_RESULT{
SIMCONNECT_TEXT_RESULT_TIMEOUT,
};
SIMCONNECT_ENUM SIMCONNECT_WEATHER_MODE{
SIMCONNECT_ENUM SIMCONNECT_WEATHER_MODE
{
SIMCONNECT_WEATHER_MODE_THEME,
SIMCONNECT_WEATHER_MODE_RWW,
SIMCONNECT_WEATHER_MODE_CUSTOM,
SIMCONNECT_WEATHER_MODE_GLOBAL,
};
SIMCONNECT_ENUM SIMCONNECT_FACILITY_LIST_TYPE{
SIMCONNECT_ENUM SIMCONNECT_FACILITY_LIST_TYPE
{
SIMCONNECT_FACILITY_LIST_TYPE_AIRPORT,
SIMCONNECT_FACILITY_LIST_TYPE_WAYPOINT,
SIMCONNECT_FACILITY_LIST_TYPE_NDB,
@@ -287,7 +314,8 @@ SIMCONNECT_ENUM SIMCONNECT_FACILITY_LIST_TYPE{
SIMCONNECT_FACILITY_LIST_TYPE_COUNT // invalid
};
SIMCONNECT_ENUM SIMCONNECT_FACILITY_DATA_TYPE{
SIMCONNECT_ENUM SIMCONNECT_FACILITY_DATA_TYPE
{
SIMCONNECT_FACILITY_DATA_AIRPORT,
SIMCONNECT_FACILITY_DATA_RUNWAY,
SIMCONNECT_FACILITY_DATA_START,
@@ -311,6 +339,15 @@ SIMCONNECT_ENUM SIMCONNECT_FACILITY_DATA_TYPE{
SIMCONNECT_FACILITY_DATA_NDB,
SIMCONNECT_FACILITY_DATA_WAYPOINT,
SIMCONNECT_FACILITY_DATA_ROUTE,
SIMCONNECT_FACILITY_DATA_PAVEMENT,
SIMCONNECT_FACILITY_DATA_APPROACH_LIGHTS,
SIMCONNECT_FACILITY_DATA_VASI,
};
SIMCONNECT_ENUM SIMCONNECT_INPUT_EVENT_TYPE : DWORD
{
SIMCONNECT_INPUT_EVENT_TYPE_DOUBLE,
SIMCONNECT_INPUT_EVENT_TYPE_STRING
};
SIMCONNECT_ENUM_FLAGS SIMCONNECT_VOR_FLAGS; // flags for SIMCONNECT_RECV_ID_VOR_LIST
@@ -372,7 +409,8 @@ static const DWORD SIMCONNECT_SOUND_SYSTEM_EVENT_DATA_MASTER = 0x00000001; // So
#ifdef ENABLE_SIMCONNECT_EXPERIMENTAL
SIMCONNECT_ENUM_FLAGS SIMCONNECT_PICK_FLAGS{
SIMCONNECT_ENUM_FLAGS SIMCONNECT_PICK_FLAGS
{
SIMCONNECT_PICK_GROUND = 0x01, // pick ground/ pick result item is ground location
SIMCONNECT_PICK_AI = 0x02, // pick AI / pick result item is AI, (dwSimObjectID is valid)
SIMCONNECT_PICK_SCENERY = 0x04, // pick scenery/ pick result item is scenery object (hSceneryObject is valid)
@@ -395,6 +433,7 @@ SIMCONNECT_USER_ENUM SIMCONNECT_CLIENT_EVENT_ID; // client-defined cli
SIMCONNECT_USER_ENUM SIMCONNECT_CLIENT_DATA_ID; //client-defined client data ID
SIMCONNECT_USER_ENUM SIMCONNECT_CLIENT_DATA_DEFINITION_ID; //client-defined client data definition ID
//----------------------------------------------------------------------------
// Struct definitions
//----------------------------------------------------------------------------
@@ -528,10 +567,12 @@ SIMCONNECT_REFSTRUCT SIMCONNECT_RECV_SIMOBJECT_DATA : public SIMCONNECT_RECV //
};
SIMCONNECT_REFSTRUCT SIMCONNECT_RECV_SIMOBJECT_DATA_BYTYPE : public SIMCONNECT_RECV_SIMOBJECT_DATA // when dwID == SIMCONNECT_RECV_ID_SIMOBJECT_DATA_BYTYPE
{};
{
};
SIMCONNECT_REFSTRUCT SIMCONNECT_RECV_CLIENT_DATA : public SIMCONNECT_RECV_SIMOBJECT_DATA // when dwID == SIMCONNECT_RECV_ID_CLIENT_DATA
{};
{
};
SIMCONNECT_REFSTRUCT SIMCONNECT_RECV_WEATHER_OBSERVATION : public SIMCONNECT_RECV // when dwID == SIMCONNECT_RECV_ID_WEATHER_OBSERVATION
{
@@ -576,7 +617,8 @@ SIMCONNECT_REFSTRUCT SIMCONNECT_RECV_CUSTOM_ACTION : public SIMCONNECT_RECV_EVEN
SIMCONNECT_STRINGV( szPayLoad); // Variable length string payload associated with the mission action.
};
SIMCONNECT_REFSTRUCT SIMCONNECT_RECV_EVENT_WEATHER_MODE : public SIMCONNECT_RECV_EVENT{
SIMCONNECT_REFSTRUCT SIMCONNECT_RECV_EVENT_WEATHER_MODE : public SIMCONNECT_RECV_EVENT
{
// No event specific data - the new weather mode is in the base structure dwData member.
};
@@ -589,10 +631,19 @@ SIMCONNECT_REFSTRUCT SIMCONNECT_RECV_FACILITIES_LIST : public SIMCONNECT_RECV
DWORD dwOutOf; // total number of transmissions the list is chopped into
};
SIMCONNECT_REFSTRUCT SIMCONNECT_RECV_LIST_TEMPLATE : public SIMCONNECT_RECV
{
DWORD dwRequestID;
DWORD dwArraySize;
DWORD dwEntryNumber; // when the array of items is too big for one send, which send this is (0..dwOutOf-1)
DWORD dwOutOf; // total number of transmissions the list is chopped into
};
// SIMCONNECT_DATA_FACILITY_AIRPORT
SIMCONNECT_REFSTRUCT SIMCONNECT_DATA_FACILITY_AIRPORT
{
SIMCONNECT_STRING(Icao, 9); // ICAO of the object
SIMCONNECT_STRING(Ident, 6); // ICAO of the object
SIMCONNECT_STRING(Region, 3); // ICAO of the object
double Latitude; // degrees
double Longitude; // degrees
double Altitude; // meters
@@ -604,6 +655,7 @@ SIMCONNECT_REFSTRUCT SIMCONNECT_RECV_AIRPORT_LIST : public SIMCONNECT_RECV_FACIL
SIMCONNECT_FIXEDTYPE_DATAV(SIMCONNECT_DATA_FACILITY_AIRPORT, rgData, dwArraySize, U1 /*member of UnmanagedType enum*/, SIMCONNECT_DATA_FACILITY_AIRPORT /*cli type*/);
};
// SIMCONNECT_DATA_FACILITY_WAYPOINT
SIMCONNECT_REFSTRUCT SIMCONNECT_DATA_FACILITY_WAYPOINT : public SIMCONNECT_DATA_FACILITY_AIRPORT
{
@@ -662,6 +714,40 @@ SIMCONNECT_REFSTRUCT SIMCONNECT_RECV_FACILITY_DATA_END : public SIMCONNECT_RECV
DWORD RequestId;
};
SIMCONNECT_STRUCT SIMCONNECT_ICAO
{
char Type;
SIMCONNECT_STRING(Ident, 5 + 1);
SIMCONNECT_STRING(Region, 2 + 1);
SIMCONNECT_STRING(Airport, 4 + 1);
};
// SIMCONNECT_DATA_LATLONALT
SIMCONNECT_STRUCT SIMCONNECT_DATA_LATLONALT
{
double Latitude;
double Longitude;
double Altitude;
};
SIMCONNECT_STRUCT SIMCONNECT_DATA_PBH
{
float Pitch;
float Bank;
float Heading;
};
SIMCONNECT_REFSTRUCT SIMCONNECT_FACILITY_MINIMAL
{
SIMCONNECT_ICAO icao;
SIMCONNECT_DATA_LATLONALT lla;
};
SIMCONNECT_REFSTRUCT SIMCONNECT_RECV_FACILITY_MINIMAL_LIST : public SIMCONNECT_RECV_LIST_TEMPLATE
{
SIMCONNECT_FIXEDTYPE_DATAV(SIMCONNECT_FACILITY_MINIMAL, rgData, dwArraySize, U1 /*member of UnmanagedType enum*/, SIMCONNECT_FACILITY_MINIMAL /*cli type*/);
};
#ifdef ENABLE_SIMCONNECT_EXPERIMENTAL
SIMCONNECT_REFSTRUCT SIMCONNECT_RECV_PICK : public SIMCONNECT_RECV // when dwID == SIMCONNECT_RECV_ID_RESERVED_KEY
@@ -681,6 +767,7 @@ SIMCONNECT_REFSTRUCT SIMCONNECT_RECV_PICK : public SIMCONNECT_RECV // when dwID
#endif //ENABLE_SIMCONNECT_EXPERIMENTAL
// SIMCONNECT_DATATYPE_INITPOSITION
SIMCONNECT_STRUCT SIMCONNECT_DATA_INITPOSITION
{
@@ -694,6 +781,7 @@ SIMCONNECT_STRUCT SIMCONNECT_DATA_INITPOSITION
DWORD Airspeed; // knots
};
// SIMCONNECT_DATATYPE_MARKERSTATE
SIMCONNECT_STRUCT SIMCONNECT_DATA_MARKERSTATE
{
@@ -712,14 +800,6 @@ SIMCONNECT_STRUCT SIMCONNECT_DATA_WAYPOINT
double percentThrottle;
};
// SIMCONNECT_DATA_LATLONALT
SIMCONNECT_STRUCT SIMCONNECT_DATA_LATLONALT
{
double Latitude;
double Longitude;
double Altitude;
};
// SIMCONNECT_DATA_XYZ
SIMCONNECT_STRUCT SIMCONNECT_DATA_XYZ
{
@@ -728,16 +808,100 @@ SIMCONNECT_STRUCT SIMCONNECT_DATA_XYZ
double z;
};
SIMCONNECT_REFSTRUCT SIMCONNECT_JETWAY_DATA
{
SIMCONNECT_STRING(AirportIcao, 8);
int ParkingIndex;
SIMCONNECT_DATA_LATLONALT Lla;
SIMCONNECT_DATA_PBH Pbh;
int Status;
int Door;
SIMCONNECT_DATA_XYZ ExitDoorRelativePos;
SIMCONNECT_DATA_XYZ MainHandlePos;
SIMCONNECT_DATA_XYZ SecondaryHandle;
SIMCONNECT_DATA_XYZ WheelGroundLock;
DWORD JetwayObjectId;
DWORD AttachedObjectId;
};
SIMCONNECT_REFSTRUCT SIMCONNECT_RECV_JETWAY_DATA : public SIMCONNECT_RECV_LIST_TEMPLATE
{
SIMCONNECT_FIXEDTYPE_DATAV(SIMCONNECT_JETWAY_DATA, rgData, dwArraySize, U1 /*member of UnmanagedType enum*/, SIMCONNECT_JETWAY_DATA /*cli type*/);
};
SIMCONNECT_REFSTRUCT SIMCONNECT_RECV_ACTION_CALLBACK : public SIMCONNECT_RECV // when dwID == SIMCONNECT_RECV_ID_ACTION_CALLBACK
{
SIMCONNECT_STRING(szActionID, MAX_PATH);
DWORD cbRequestId;
};
SIMCONNECT_REFSTRUCT SIMCONNECT_INPUT_EVENT_DESCRIPTOR
{
SIMCONNECT_STRING(Name, 64); // Input event name
unsigned __int64 Hash; // Hash
SIMCONNECT_INPUT_EVENT_TYPE eType;
};
SIMCONNECT_REFSTRUCT SIMCONNECT_RECV_ENUMERATE_INPUT_EVENTS : public SIMCONNECT_RECV_LIST_TEMPLATE
{
SIMCONNECT_FIXEDTYPE_DATAV(SIMCONNECT_INPUT_EVENT_DESCRIPTOR, rgData, dwArraySize, U1 /*member of UnmanagedType enum*/, SIMCONNECT_INPUT_EVENT_DESCRIPTOR /*cli type*/);
};
SIMCONNECT_REFSTRUCT SIMCONNECT_RECV_GET_INPUT_EVENT : public SIMCONNECT_RECV // when dwID == SIMCONNECT_RECV_ID_GET_INPUT_EVENT
{
DWORD dwRequestID;
SIMCONNECT_INPUT_EVENT_TYPE eType;
SIMCONNECT_DATAV(Value, eType,);
};
SIMCONNECT_REFSTRUCT SIMCONNECT_RECV_SUBSCRIBE_INPUT_EVENT : public SIMCONNECT_RECV
{
UINT64 Hash;
SIMCONNECT_INPUT_EVENT_TYPE eType;
SIMCONNECT_DATAV(Value, eType,);
};
SIMCONNECT_REFSTRUCT SIMCONNECT_RECV_ENUMERATE_INPUT_EVENT_PARAMS : public SIMCONNECT_RECV
{
UINT64 Hash;
SIMCONNECT_STRING(Value, MAX_PATH);
};
SIMCONNECT_REFSTRUCT SIMCONNECT_VERSION_BASE_TYPE
{
unsigned short Major;
unsigned short Minor;
unsigned short Revision;
unsigned short Build;
};
SIMCONNECT_REFSTRUCT SIMCONNECT_CONTROLLER_ITEM
{
SIMCONNECT_STRING(DeviceName, 256);
unsigned int DeviceId;
unsigned int ProductId;
unsigned int CompositeID;
SIMCONNECT_VERSION_BASE_TYPE HardwareVersion;
};
SIMCONNECT_REFSTRUCT SIMCONNECT_RECV_CONTROLLERS_LIST : public SIMCONNECT_RECV_LIST_TEMPLATE
{
SIMCONNECT_FIXEDTYPE_DATAV(SIMCONNECT_CONTROLLER_ITEM, rgData, dwArraySize, U1 /*member of UnmanagedType enum*/, SIMCONNECT_CONTROLLER_ITEM /*cli type*/);
};
#pragma pack(pop)
//----------------------------------------------------------------------------
// End of Struct definitions
//----------------------------------------------------------------------------
#if !defined(SIMCONNECTAPI)
#define SIMCONNECTAPI extern "C" HRESULT __stdcall
#endif
typedef void (CALLBACK *DispatchProc)(SIMCONNECT_RECV* pData, DWORD cbData, void* pContext);
SIMCONNECTAPI SimConnect_MapClientEventToSimEvent(HANDLE hSimConnect, SIMCONNECT_CLIENT_EVENT_ID EventID, const char * EventName = "");
@@ -818,5 +982,19 @@ SIMCONNECTAPI SimConnect_RequestFacilityData(HANDLE hSimConnect, SIMCONNECT_DATA
SIMCONNECTAPI SimConnect_SubscribeToFacilities_EX1(HANDLE hSimConnect, SIMCONNECT_FACILITY_LIST_TYPE type, SIMCONNECT_DATA_REQUEST_ID newElemInRangeRequestID, SIMCONNECT_DATA_REQUEST_ID oldElemOutRangeRequestID);
SIMCONNECTAPI SimConnect_UnsubscribeToFacilities_EX1(HANDLE hSimConnect, SIMCONNECT_FACILITY_LIST_TYPE type, bool bUnsubscribeNewInRange, bool bUnsubscribeOldOutRange);
SIMCONNECTAPI SimConnect_RequestFacilitiesList_EX1(HANDLE hSimConnect, SIMCONNECT_FACILITY_LIST_TYPE type, SIMCONNECT_DATA_REQUEST_ID RequestID);
SIMCONNECTAPI SimConnect_RequestFacilityData_EX1(HANDLE hSimConnect, SIMCONNECT_DATA_DEFINITION_ID DefineID, SIMCONNECT_DATA_REQUEST_ID RequestID, const char * ICAO, const char * Region = "", char Type = 0);
SIMCONNECTAPI SimConnect_RequestJetwayData(HANDLE hSimConnect, const char * AirportIcao, DWORD ArrayCount, int * Indexes);
SIMCONNECTAPI SimConnect_EnumerateControllers(HANDLE hSimConnect);
SIMCONNECTAPI SimConnect_MapInputEventToClientEvent_EX1(HANDLE hSimConnect, SIMCONNECT_INPUT_GROUP_ID GroupID, const char * szInputDefinition, SIMCONNECT_CLIENT_EVENT_ID DownEventID, DWORD DownValue = 0, SIMCONNECT_CLIENT_EVENT_ID UpEventID = (SIMCONNECT_CLIENT_EVENT_ID)SIMCONNECT_UNUSED, DWORD UpValue = 0, BOOL bMaskable = FALSE);
SIMCONNECTAPI SimConnect_ExecuteAction(HANDLE hSimConnect, DWORD cbRequestID, const char * szActionID, DWORD cbUnitSize, void * pParamValues);
SIMCONNECTAPI SimConnect_EnumerateInputEvents(HANDLE hSimConnect, SIMCONNECT_DATA_REQUEST_ID RequestID);
SIMCONNECTAPI SimConnect_GetInputEvent(HANDLE hSimConnect, SIMCONNECT_DATA_REQUEST_ID RequestID, UINT64 Hash);
SIMCONNECTAPI SimConnect_SetInputEvent(HANDLE hSimConnect, UINT64 Hash, DWORD cbUnitSize, void * Value);
SIMCONNECTAPI SimConnect_SubscribeInputEvent(HANDLE hSimConnect, UINT64 Hash);
SIMCONNECTAPI SimConnect_UnsubscribeInputEvent(HANDLE hSimConnect, UINT64 Hash);
SIMCONNECTAPI SimConnect_EnumerateInputEventParams(HANDLE hSimConnect, UINT64 Hash);
SIMCONNECTAPI SimConnect_AddFacilityDataDefinitionFilter(HANDLE hSimConnect, SIMCONNECT_DATA_DEFINITION_ID DefineID, const char * szFilterPath, DWORD cbUnitSize, void * pFilterData);
SIMCONNECTAPI SimConnect_ClearAllFacilityDataDefinitionFilters(HANDLE hSimConnect, SIMCONNECT_DATA_DEFINITION_ID DefineID);
#endif // _SIMCONNECT_H_

Binary file not shown.

Binary file not shown.

View File

@@ -1 +1 @@
0.19.3.0
0.24.3.0

View File

@@ -0,0 +1,194 @@
use std::os::raw::c_char;
use crate::{bindings, SimConnectError};
// System Events start from 0 so we have to stagger the values to avoid collisions.
pub(crate) const CLIENT_EVENT_DISCRIMINANT_START: u32 = 1024;
/// SimConnect Client Event Request.
///
/// Defined by <https://www.prepar3d.com/SDKv5/sdk/references/variables/event_ids.html>.
/// Extended by <https://docs.flightsimulator.com/html/Programming_Tools/Event_IDs/Event_IDs.htm>.
#[derive(Debug, Copy, Clone, PartialEq, Eq, num_enum::TryFromPrimitive)]
#[repr(u32)]
#[non_exhaustive]
pub enum ClientEventRequest {
// ---------------
// Aircraft Engine
// ---------------
/// Set throttle 1 exactly (0 to 16383).
Throttle1Set = CLIENT_EVENT_DISCRIMINANT_START,
/// Set throttle 2 exactly (0 to 16383).
Throttle2Set,
/// Set throttle 3 exactly (0 to 16383).
Throttle3Set,
/// Set throttle 4 exactly (0 to 16383).
Throttle4Set,
// ---------------
// Aircraft Flight Controls
// ---------------
/// Sets elevator position (-16383 - +16383).
AxisElevatorSet,
// ---------------
// Aircraft Miscellaneous Systems
// ---------------
/// Increment brake pressure. Note: These are simulated spring-loaded toe brakes, which will bleed back to zero over time.
Brakes,
/// Increments left brake pressure. Note: This is a simulated spring-loaded toe brake, which will bleed back to zero over time.
BrakesLeft,
/// Increments right brake pressure. Note: This is a simulated spring-loaded toe brake, which will bleed back to zero over time.
BrakesRight,
/// Sets left brake position from axis controller (e.g. joystick). -16383 (0 brakes) to +16383 (max brakes).
AxisLeftBrakeSet,
/// Sets right brake position from axis controller (e.g. joystick). -16383 (0 brakes) to +16383 (max brakes).
AxisRightBrakeSet,
/// Toggles parking brake on/off.
ParkingBrakes,
}
impl ClientEventRequest {
pub(crate) fn into_c_char(self) -> *const c_char {
match self {
// Aircraft Engine
Self::Throttle1Set => "THROTTLE1_SET\0".as_ptr() as *const c_char,
Self::Throttle2Set => "THROTTLE2_SET\0".as_ptr() as *const c_char,
Self::Throttle3Set => "THROTTLE3_SET\0".as_ptr() as *const c_char,
Self::Throttle4Set => "THROTTLE4_SET\0".as_ptr() as *const c_char,
// Aircraft Flight Controls
Self::AxisElevatorSet => "AXIS_ELEVATOR_SET\0".as_ptr() as *const c_char,
// Aircraft Miscellaneous Systems
Self::Brakes => "BRAKES\0".as_ptr() as *const c_char,
Self::BrakesLeft => "BRAKES_LEFT\0".as_ptr() as *const c_char,
Self::BrakesRight => "BRAKES_RIGHT\0".as_ptr() as *const c_char,
Self::AxisLeftBrakeSet => "AXIS_LEFT_BRAKE_SET\0".as_ptr() as *const c_char,
Self::AxisRightBrakeSet => "AXIS_RIGHT_BRAKE_SET\0".as_ptr() as *const c_char,
Self::ParkingBrakes => "PARKING_BRAKES\0".as_ptr() as *const c_char,
}
}
}
/// SimConnect Client Event.
///
/// Defined by <https://www.prepar3d.com/SDKv5/sdk/references/variables/event_ids.html>.
/// Extended by <https://docs.flightsimulator.com/html/Programming_Tools/Event_IDs/Event_IDs.htm>.
#[derive(Debug, Copy, Clone, PartialEq, Eq)]
#[non_exhaustive]
pub enum ClientEvent {
// ---------------
// Aircraft Engine
// ---------------
/// Set throttle 1 exactly (0 to 16383).
Throttle1Set {
/// -16383 (0 throttle) to +16383 (max throttle).
value: i32,
},
/// Set throttle 2 exactly (0 to 16383).
Throttle2Set {
/// -16383 (0 throttle) to +16383 (max throttle).
value: i32,
},
/// Set throttle 3 exactly (0 to 16383).
Throttle3Set {
/// -16383 (0 throttle) to +16383 (max throttle).
value: i32,
},
/// Set throttle 4 exactly (0 to 16383).
Throttle4Set {
/// -16383 (0 throttle) to +16383 (max throttle).
value: i32,
},
// ---------------
// Aircraft Flight Controls
// ---------------
/// Sets elevator position (-16383 - +16383).
AxisElevatorSet {
/// -16383 (full down) to +16383 (full up).
value: i32,
},
// ---------------
// Aircraft Miscellaneous Systems
// ---------------
/// Increment brake pressure. Note: These are simulated spring-loaded toe brakes, which will bleed back to zero over time.
Brakes,
/// Increments left brake pressure. Note: This is a simulated spring-loaded toe brake, which will bleed back to zero over time.
BrakesLeft,
/// Increments right brake pressure. Note: This is a simulated spring-loaded toe brake, which will bleed back to zero over time.
BrakesRight,
/// Sets left brake position from axis controller (e.g. joystick). -16383 (0 brakes) to +16383 (max brakes).
AxisLeftBrakeSet {
/// -16383 (0 brakes) to +16383 (max brakes).
value: i32,
},
/// Sets right brake position from axis controller (e.g. joystick). -16383 (0 brakes) to +16383 (max brakes).
AxisRightBrakeSet {
/// -16383 (0 brakes) to +16383 (max brakes).
value: i32,
},
/// Toggles parking brake on/off.
ParkingBrakes,
}
impl TryFrom<&bindings::SIMCONNECT_RECV_EVENT> for ClientEvent {
type Error = SimConnectError;
fn try_from(event: &bindings::SIMCONNECT_RECV_EVENT) -> Result<Self, Self::Error> {
let request = ClientEventRequest::try_from(event.uEventID)
.map_err(|_| SimConnectError::UnimplementedEventType(event.uEventID))?;
match request {
// Aircraft Engine
ClientEventRequest::Throttle1Set => Ok(Self::Throttle1Set {
value: event.dwData as i32,
}),
ClientEventRequest::Throttle2Set => Ok(Self::Throttle2Set {
value: event.dwData as i32,
}),
ClientEventRequest::Throttle3Set => Ok(Self::Throttle3Set {
value: event.dwData as i32,
}),
ClientEventRequest::Throttle4Set => Ok(Self::Throttle4Set {
value: event.dwData as i32,
}),
// Aircraft Flight Controls
ClientEventRequest::AxisElevatorSet => Ok(Self::AxisElevatorSet {
value: event.dwData as i32,
}),
// Aircraft Miscellaneous Systems
ClientEventRequest::Brakes => Ok(Self::Brakes),
ClientEventRequest::BrakesLeft => Ok(Self::BrakesLeft),
ClientEventRequest::BrakesRight => Ok(Self::BrakesRight),
ClientEventRequest::AxisLeftBrakeSet => Ok(Self::AxisLeftBrakeSet {
value: event.dwData as i32,
}),
ClientEventRequest::AxisRightBrakeSet => Ok(Self::AxisRightBrakeSet {
value: event.dwData as i32,
}),
ClientEventRequest::ParkingBrakes => Ok(Self::ParkingBrakes),
}
}
}
impl From<ClientEvent> for (ClientEventRequest, i32) {
fn from(event: ClientEvent) -> Self {
match event {
// Aircraft Engine
ClientEvent::Throttle1Set { value } => (ClientEventRequest::Throttle1Set, value),
ClientEvent::Throttle2Set { value } => (ClientEventRequest::Throttle2Set, value),
ClientEvent::Throttle3Set { value } => (ClientEventRequest::Throttle3Set, value),
ClientEvent::Throttle4Set { value } => (ClientEventRequest::Throttle4Set, value),
// Aircraft Flight Controls
ClientEvent::AxisElevatorSet { value } => (ClientEventRequest::AxisElevatorSet, value),
// Aircraft Miscellaneous Systems
ClientEvent::Brakes => (ClientEventRequest::Brakes, 0),
ClientEvent::BrakesLeft => (ClientEventRequest::BrakesLeft, 0),
ClientEvent::BrakesRight => (ClientEventRequest::BrakesRight, 0),
ClientEvent::AxisLeftBrakeSet { value } => {
(ClientEventRequest::AxisLeftBrakeSet, value)
}
ClientEvent::AxisRightBrakeSet { value } => {
(ClientEventRequest::AxisRightBrakeSet, value)
}
ClientEvent::ParkingBrakes => (ClientEventRequest::ParkingBrakes, 0),
}
}
}

View File

@@ -44,8 +44,10 @@ impl FacilityType {
/// Information on a single airport in the facilities cache.
#[derive(Debug, Clone)]
pub struct Airport {
/// ICAO of the facility.
pub icao: String,
/// Ident of the facility.
pub ident: String,
/// Region of the facility.
pub region: String,
/// Latitude of the airport in facility.
pub lat: f64,
/// Longitude of the airport in facility.
@@ -57,8 +59,10 @@ pub struct Airport {
/// Information on a single waypoint in the facilities cache.
#[derive(Debug, Clone)]
pub struct Waypoint {
/// ICAO of the facility.
pub icao: String,
/// Ident of the facility.
pub ident: String,
/// Region of the facility.
pub region: String,
/// Latitude of the airport in facility.
pub lat: f64,
/// Longitude of the airport in facility.
@@ -72,8 +76,10 @@ pub struct Waypoint {
/// Information on a single NDB station in the facilities cache.
#[derive(Debug, Clone)]
pub struct NDB {
/// ICAO of the facility.
pub icao: String,
/// Ident of the facility.
pub ident: String,
/// Region of the facility.
pub region: String,
/// Latitude of the airport in facility.
pub lat: f64,
/// Longitude of the airport in facility.
@@ -89,8 +95,10 @@ pub struct NDB {
/// Information on a single VOR station in the facilities cache.
#[derive(Debug, Clone)]
pub struct VOR {
/// ICAO of the facility.
pub icao: String,
/// Ident of the facility.
pub ident: String,
/// Region of the facility.
pub region: String,
/// Latitude of the airport in facility.
pub lat: f64,
/// Longitude of the airport in facility.

View File

@@ -1,15 +1,15 @@
mod client_event;
mod condition;
mod data_type;
mod events;
mod facilities;
mod notification;
mod notification_group;
mod period;
mod system_event;
pub use client_event::*;
pub use condition::*;
pub use data_type::*;
pub use events::*;
pub use facilities::*;
pub use notification::*;
pub use notification_group::*;
pub use period::*;
pub use system_event::*;

View File

@@ -33,6 +33,9 @@ pub struct Object {
pub(crate) data_addr: *const u32,
}
unsafe impl Send for Object {}
unsafe impl Sync for Object {}
impl Object {
/// Try and transmute this SimConnect object as a `T` struct.
///

View File

@@ -1,6 +0,0 @@
/// SimConnect event notification group.
#[derive(Debug, Copy, Clone, PartialEq, Eq)]
#[repr(u32)]
pub enum NotificationGroup {
Group0,
}

View File

@@ -268,38 +268,3 @@ impl TryFrom<&bindings::SIMCONNECT_RECV_EVENT_FRAME> for SystemEvent {
}
}
}
pub(crate) const CLIENT_EVENT_START: u32 = 128;
/// SimConnect Client Event.
///
/// WIP. As defined by <https://www.prepar3d.com/SDKv5/sdk/references/variables/event_ids.html>.
#[derive(Debug, Copy, Clone, PartialEq, Eq, num_enum::TryFromPrimitive)]
#[repr(u32)]
#[non_exhaustive]
pub enum ClientEvent {
// Aircraft Engine
/// Set throttles max.
ThrottleFull = CLIENT_EVENT_START,
// ---------------
// Aircraft Miscellaneous Systems
/// Increment brake pressure. Note: These are simulated spring-loaded toe brakes, which will bleed back to zero over time.
Brakes,
/// Increments left brake pressure. Note: This is a simulated spring-loaded toe brake, which will bleed back to zero over time.
BrakesLeft,
/// Sets left brake position from axis controller (e.g. joystick). -16383 (0 brakes) to +16383 (max brakes).
AxisLeftBrakeSet,
}
impl ClientEvent {
pub(crate) fn into_c_char(self) -> *const c_char {
match self {
// Aircraft Engine
ClientEvent::ThrottleFull => "THROTTLE_FULL\0".as_ptr() as *const c_char,
// Aircraft Miscellaneous Systems
ClientEvent::Brakes => "BRAKES\0".as_ptr() as *const c_char,
ClientEvent::BrakesLeft => "BRAKES_LEFT\0".as_ptr() as *const c_char,
ClientEvent::AxisLeftBrakeSet => "AXIS_LEFT_BRAKE_SET\0".as_ptr() as *const c_char,
}
}
}

View File

@@ -13,15 +13,19 @@ pub enum SimConnectError {
/// An unimplemented event type has been received by the SDK.
#[error("Unimplemented event in the SDK: {0}")]
UnimplementedEventType(u32),
/// An unimplemented message type has been received by the SDK.
/// An unimplemented notification has been received by the SDK.
#[error("Unimplemented notification in the SDK: {0}")]
UnimplementedMessageType(i32),
UnimplementedNotification(i32),
/// Object already registered with the client instance.
#[error("Object `{0}` has already been registered")]
ObjectAlreadyRegistered(String),
/// Object already registered with the client instance.
#[error("Object `{0}` has not been registered")]
ObjectNotRegistered(String),
#[error("Event `{0}` has already been subscribed to")]
EventAlreadySubscribedTo(String),
#[error("Event `{0}` has not been subscribed to")]
EventNotSubscribedTo(String),
/// Object mismatch.
#[error("Tried to convert object of type {actual} to {expected}")]
ObjectMismatch { actual: String, expected: String },

View File

@@ -79,6 +79,10 @@
//!
//! See [more examples](https://github.com/mihai-dinculescu/simconnect-sdk-rs/tree/main/examples).
// We're a library, we don't _need_ to use everythi... actually, tests.... tests need to use them
// for now though, fuck it
#![allow(unused_imports)]
mod bindings;
mod domain;
mod errors;

View File

@@ -1,12 +1,19 @@
use std::ops::{Deref, DerefMut};
use std::{collections::HashMap, ffi::c_void};
use tracing::{error, span, trace, warn, Level};
use crate::{
as_c_string, bindings, helpers::fixed_c_str_to_string, ok_if_fail, success, Airport,
ClientEvent, Notification, Object, SimConnectError, SystemEvent, Waypoint, CLIENT_EVENT_START,
NDB, VOR,
use crate::bindings::{
SIMCONNECT_DATA_FACILITY_AIRPORT, SIMCONNECT_DATA_FACILITY_NDB, SIMCONNECT_DATA_FACILITY_VOR,
SIMCONNECT_DATA_FACILITY_WAYPOINT,
};
use crate::domain::{
Airport, ClientEvent, ClientEventRequest, Notification, Object, SystemEvent,
SystemEventRequest, Waypoint, CLIENT_EVENT_DISCRIMINANT_START, NDB, VOR,
};
use crate::helpers::fixed_c_str_to_string;
use crate::simconnect::EventRegister;
use crate::{as_c_string, bindings, ok_if_fail, success, SimConnectError};
/// SimConnect SDK Client.
///
@@ -81,22 +88,55 @@ use crate::{
/// Ok(())
/// }
/// ```
#[derive(Debug)]
pub struct SimConnect {
pub(super) handle: std::ptr::NonNull<c_void>,
pub(super) next_request_id: u32,
pub(super) registered_objects: HashMap<String, u32>,
pub(crate) handle: SimConnectHandle,
pub(crate) next_request_id: u32,
pub(crate) registered_objects: HashMap<String, RegisteredObject>,
pub(crate) system_event_register: EventRegister<SystemEventRequest>,
pub(crate) client_event_register: EventRegister<ClientEventRequest>,
}
/// A struct that represents a registered object.
#[derive(Debug)]
pub(crate) struct RegisteredObject {
pub id: u32,
pub transient: bool,
}
impl RegisteredObject {
pub(crate) fn new(id: u32, transient: bool) -> Self {
Self { id, transient }
}
}
pub struct SimConnectHandle(std::ptr::NonNull<c_void>);
impl DerefMut for SimConnectHandle {
fn deref_mut(&mut self) -> &mut Self::Target {
&mut self.0
}
}
impl Deref for SimConnectHandle {
type Target = std::ptr::NonNull<c_void>;
fn deref(&self) -> &Self::Target {
&self.0
}
}
unsafe impl Send for SimConnectHandle {}
unsafe impl Sync for SimConnectHandle {}
impl SimConnect {
/// Create a new SimConnect SDK client.
#[tracing::instrument(name = "SimConnect::new", level = "debug")]
pub fn new(name: &str) -> Result<Self, SimConnectError> {
let mut handle = std::ptr::null_mut();
let mut g = std::ptr::null_mut();
success!(unsafe {
bindings::SimConnect_Open(
&mut handle,
&mut g,
as_c_string!(name),
std::ptr::null_mut(),
0,
@@ -106,13 +146,15 @@ impl SimConnect {
})?;
Ok(Self {
handle: std::ptr::NonNull::new(handle).ok_or_else(|| {
handle: SimConnectHandle(std::ptr::NonNull::new(g).ok_or_else(|| {
SimConnectError::UnexpectedError(
"SimConnect_Open returned null pointer on success".to_string(),
)
})?,
})?),
next_request_id: 0,
registered_objects: HashMap::new(),
system_event_register: EventRegister::new(),
client_event_register: EventRegister::new(),
})
}
@@ -121,7 +163,7 @@ impl SimConnect {
/// # Remarks
/// This is a non-blocking function. If there are no messages to receive, it will return None immediately.
/// When called in a loop, it is recommended to use a short sleep time.
pub fn get_next_dispatch(&self) -> Result<Option<Notification>, SimConnectError> {
pub fn get_next_dispatch(&mut self) -> Result<Option<Notification>, SimConnectError> {
let mut data_buf: *mut bindings::SIMCONNECT_RECV = std::ptr::null_mut();
let mut size_buf: bindings::DWORD = 32;
let size_buf_pointer: *mut bindings::DWORD = &mut size_buf;
@@ -129,7 +171,7 @@ impl SimConnect {
unsafe {
ok_if_fail!(
bindings::SimConnect_GetNextDispatch(
self.handle.as_ptr(),
self.handle.0.as_ptr(),
&mut data_buf,
size_buf_pointer
),
@@ -159,9 +201,8 @@ impl SimConnect {
let event: &bindings::SIMCONNECT_RECV_EVENT =
unsafe { &*(data_buf as *const bindings::SIMCONNECT_RECV_EVENT) };
if event.uEventID >= CLIENT_EVENT_START {
let event = ClientEvent::try_from(event.uEventID)
.map_err(|_| SimConnectError::UnimplementedEventType(event.uEventID))?;
if event.uEventID >= CLIENT_EVENT_DISCRIMINANT_START {
let event = ClientEvent::try_from(event)?;
Ok(Some(Notification::ClientEvent(event)))
} else {
@@ -212,17 +253,28 @@ impl SimConnect {
let event: &bindings::SIMCONNECT_RECV_AIRPORT_LIST =
unsafe { &*(data_buf as *const bindings::SIMCONNECT_RECV_AIRPORT_LIST) };
let data = (0..event._base.dwArraySize as usize)
.map(|i| {
// `rgData` is defined as a 1-element array, but it is actually a variable-length array.
let record = unsafe { event.rgData.get_unchecked(i) };
self.unregister_potential_transient_request(
event._base.dwEntryNumber,
event._base.dwOutOf,
event._base.dwRequestID,
);
Airport {
icao: fixed_c_str_to_string(&record.Icao),
let as_pointer = event.rgData.as_ptr();
let s = unsafe {
core::slice::from_raw_parts(
as_pointer as *mut SIMCONNECT_DATA_FACILITY_AIRPORT,
event._base.dwArraySize as usize,
)
};
let data = s
.iter()
.map(|record| Airport {
ident: fixed_c_str_to_string(&record.Ident),
region: fixed_c_str_to_string(&record.Region),
lat: record.Latitude,
lon: record.Longitude,
alt: record.Altitude,
}
})
.collect::<Vec<_>>();
@@ -234,18 +286,29 @@ impl SimConnect {
let event: &bindings::SIMCONNECT_RECV_WAYPOINT_LIST =
unsafe { &*(data_buf as *const bindings::SIMCONNECT_RECV_WAYPOINT_LIST) };
let data = (0..event._base.dwArraySize as usize)
.map(|i| {
// `rgData` is defined as a 1-element array, but it is actually a variable-length array.
let record = unsafe { event.rgData.get_unchecked(i) };
self.unregister_potential_transient_request(
event._base.dwEntryNumber,
event._base.dwOutOf,
event._base.dwRequestID,
);
Waypoint {
icao: fixed_c_str_to_string(&record._base.Icao),
let as_pointer = event.rgData.as_ptr();
let s = unsafe {
core::slice::from_raw_parts(
as_pointer as *mut SIMCONNECT_DATA_FACILITY_WAYPOINT,
event._base.dwArraySize as usize,
)
};
let data = s
.iter()
.map(|record| Waypoint {
ident: fixed_c_str_to_string(&record._base.Ident),
region: fixed_c_str_to_string(&record._base.Region),
lat: record._base.Latitude,
lon: record._base.Longitude,
alt: record._base.Altitude,
mag_var: record.fMagVar,
}
})
.collect::<Vec<_>>();
@@ -257,19 +320,30 @@ impl SimConnect {
let event: &bindings::SIMCONNECT_RECV_NDB_LIST =
unsafe { &*(data_buf as *const bindings::SIMCONNECT_RECV_NDB_LIST) };
let data = (0..event._base.dwArraySize as usize)
.map(|i| {
// `rgData` is defined as a 1-element array, but it is actually a variable-length array.
let record = unsafe { event.rgData.get_unchecked(i) };
self.unregister_potential_transient_request(
event._base.dwEntryNumber,
event._base.dwOutOf,
event._base.dwRequestID,
);
NDB {
icao: fixed_c_str_to_string(&record._base._base.Icao),
let as_pointer = event.rgData.as_ptr();
let s = unsafe {
core::slice::from_raw_parts(
as_pointer as *mut SIMCONNECT_DATA_FACILITY_NDB,
event._base.dwArraySize as usize,
)
};
let data = s
.iter()
.map(|record| NDB {
ident: fixed_c_str_to_string(&record._base._base.Ident),
region: fixed_c_str_to_string(&record._base._base.Region),
lat: record._base._base.Latitude,
lon: record._base._base.Longitude,
alt: record._base._base.Altitude,
mag_var: record._base.fMagVar,
frequency: record.fFrequency,
}
})
.collect::<Vec<_>>();
@@ -281,11 +355,23 @@ impl SimConnect {
let event: &bindings::SIMCONNECT_RECV_VOR_LIST =
unsafe { &*(data_buf as *const bindings::SIMCONNECT_RECV_VOR_LIST) };
let data = (0..event._base.dwArraySize as usize)
.map(|i| {
// `rgData` is defined as a 1-element array, but it is actually a variable-length array.
let record = unsafe { event.rgData.get_unchecked(i) };
self.unregister_potential_transient_request(
event._base.dwEntryNumber,
event._base.dwOutOf,
event._base.dwRequestID,
);
let as_pointer = event.rgData.as_ptr();
let s = unsafe {
core::slice::from_raw_parts(
as_pointer as *mut SIMCONNECT_DATA_FACILITY_VOR,
event._base.dwArraySize as usize,
)
};
let data = s
.iter()
.map(|record| {
let has_nav_signal = record.Flags
& bindings::SIMCONNECT_RECV_ID_VOR_LIST_HAS_NAV_SIGNAL
== bindings::SIMCONNECT_RECV_ID_VOR_LIST_HAS_NAV_SIGNAL;
@@ -300,7 +386,8 @@ impl SimConnect {
== bindings::SIMCONNECT_RECV_ID_VOR_LIST_HAS_DME;
VOR {
icao: fixed_c_str_to_string(&record._base._base._base.Icao),
ident: fixed_c_str_to_string(&record._base._base._base.Ident),
region: fixed_c_str_to_string(&record._base._base._base.Region),
lat: record._base._base._base.Latitude,
lon: record._base._base._base.Longitude,
alt: record._base._base._base.Altitude,
@@ -356,7 +443,7 @@ impl SimConnect {
bindings::SIMCONNECT_RECV_ID_SIMCONNECT_RECV_ID_NULL => Ok(None),
id => {
error!("Received unhandled notification ID: {}", id);
Err(SimConnectError::UnimplementedMessageType(id))
Err(SimConnectError::UnimplementedNotification(id))
}
}
}
@@ -364,7 +451,11 @@ impl SimConnect {
/// Register a Request ID in the internal state so that the user doesn't have to manually manage Request IDs.
#[tracing::instrument(name = "SimConnect::new_request_id", level = "trace", skip(self))]
pub(super) fn new_request_id(&mut self, type_name: String) -> Result<u32, SimConnectError> {
pub(crate) fn new_request_id(
&mut self,
type_name: String,
transient: bool,
) -> Result<u32, SimConnectError> {
if self.registered_objects.contains_key(&type_name) {
return Err(SimConnectError::ObjectAlreadyRegistered(type_name));
}
@@ -374,12 +465,17 @@ impl SimConnect {
// when `next_request_id` overflows some ids might still be in use
// so we need to find the next available one
while self.registered_objects.values().any(|id| *id == request_id) {
while self
.registered_objects
.values()
.any(|obj| obj.id == request_id)
{
request_id = self.next_request_id;
self.next_request_id += 1;
}
self.registered_objects.insert(type_name, request_id);
self.registered_objects
.insert(type_name, RegisteredObject::new(request_id, transient));
Ok(request_id)
}
@@ -390,8 +486,8 @@ impl SimConnect {
level = "trace",
skip(self)
)]
pub(super) fn unregister_request_id_by_type_name(&mut self, type_name: &str) -> Option<u32> {
self.registered_objects.remove(type_name)
pub(crate) fn unregister_request_id_by_type_name(&mut self, type_name: &str) -> Option<u32> {
self.registered_objects.remove(type_name).map(|obj| obj.id)
}
/// Get the Type Name of a Request ID.
@@ -400,12 +496,54 @@ impl SimConnect {
level = "trace",
skip(self)
)]
pub(super) fn get_type_name_by_request_id(&self, request_id: u32) -> Option<String> {
pub(crate) fn get_type_name_by_request_id(&self, request_id: u32) -> Option<String> {
self.registered_objects
.iter()
.find(|(_, v)| **v == request_id)
.find(|(_, v)| v.id == request_id)
.map(|(k, _)| k.clone())
}
/// Get the Type Name of a Request ID.
#[tracing::instrument(name = "SimConnect::is_transient_request", level = "trace", skip(self))]
pub(crate) fn is_transient_request(&self, request_id: u32) -> Option<bool> {
self.registered_objects
.iter()
.find(|(_, v)| v.id == request_id)
.map(|(_, v)| v.transient)
}
/// Checks if the request is
/// 1) the last entry in the list and
/// 2) transient
/// and if yes, it gets unregistered.
#[tracing::instrument(
name = "SimConnect::unregister_potential_transient_request",
level = "trace",
fields(type_name, transient),
skip(self)
)]
pub(crate) fn unregister_potential_transient_request(
&mut self,
entry_number: u32,
out_of: u32,
request_id: u32,
) {
if entry_number + 1 >= out_of {
// This is the last entry, so we can clear the request if it's transient.
let transient = self.is_transient_request(request_id);
tracing::Span::current().record("transient", transient);
if self.is_transient_request(request_id) == Some(true) {
let type_name = self.get_type_name_by_request_id(request_id);
if let Some(ref type_name) = type_name {
tracing::Span::current().record("type_name", type_name);
trace!("Clearing");
self.unregister_request_id_by_type_name(type_name);
}
}
}
}
}
impl Drop for SimConnect {

View File

@@ -0,0 +1,48 @@
use crate::SimConnectError;
#[derive(Debug)]
pub(crate) struct EventRegister<T>
where
T: std::fmt::Debug + std::cmp::PartialEq,
{
items: Vec<T>,
}
impl<T> EventRegister<T>
where
T: std::fmt::Debug + std::cmp::PartialEq,
{
pub fn new() -> Self {
Self { items: Vec::new() }
}
pub fn is_registered(&self, item: T) -> bool {
self.items.contains(&item)
}
pub fn register(&mut self, item: T) -> Result<(), SimConnectError> {
if self.items.contains(&item) {
return Err(SimConnectError::EventAlreadySubscribedTo(format!(
"{item:?}"
)));
}
self.items.push(item);
Ok(())
}
pub fn unregister(&mut self, item: T) -> Result<(), SimConnectError> {
if !self.items.contains(&item) {
return Err(SimConnectError::EventNotSubscribedTo(format!("{item:?}")));
}
self.items.retain(|i| *i != item);
Ok(())
}
pub fn clear(&mut self) {
self.items.clear();
}
}

View File

@@ -1,18 +1,68 @@
use crate::{
bindings, success, ClientEvent, NotificationGroup, SimConnect, SimConnectError,
SystemEventRequest,
bindings, success, ClientEventRequest, SimConnect, SimConnectError, SystemEventRequest,
};
// In order to simplify the usage we're using a single notification group for all client events.
const NOTIFICATION_GROUP_ID: u32 = 0;
impl SimConnect {
/// Associates a client defined event with a Microsoft Flight Simulator event name.
///
/// WIP
#[tracing::instrument(name = "SimConnect::register_event", level = "debug", skip(self))]
pub fn register_event(
&self,
event: ClientEvent,
notification_group: NotificationGroup,
/// Request that a specific system event is notified.
#[tracing::instrument(
name = "SimConnect::subscribe_to_system_event",
level = "debug",
skip(self)
)]
pub fn subscribe_to_system_event(
&mut self,
event: SystemEventRequest,
) -> Result<(), SimConnectError> {
self.system_event_register.register(event)?;
success!(unsafe {
bindings::SimConnect_SubscribeToSystemEvent(
self.handle.as_ptr(),
event as u32,
event.into_c_char(),
)
})?;
Ok(())
}
/// Request that notifications are no longer received for the specified system event.
/// If the system event is not subscribed to, this function does nothing.
#[tracing::instrument(
name = "SimConnect::unsubscribe_from_system_event",
level = "debug",
skip(self)
)]
pub fn unsubscribe_from_system_event(
&mut self,
event: SystemEventRequest,
) -> Result<(), SimConnectError> {
if self.system_event_register.is_registered(event) {
success!(unsafe {
bindings::SimConnect_UnsubscribeFromSystemEvent(self.handle.as_ptr(), event as u32)
})?;
self.system_event_register.clear();
}
Ok(())
}
/// Request that a specific client event is notified.
#[tracing::instrument(
name = "SimConnect::subscribe_to_client_event",
level = "debug",
skip(self)
)]
pub fn subscribe_to_client_event(
&mut self,
event: ClientEventRequest,
) -> Result<(), SimConnectError> {
self.client_event_register.register(event)?;
success!(unsafe {
bindings::SimConnect_MapClientEventToSimEvent(
self.handle.as_ptr(),
@@ -24,7 +74,7 @@ impl SimConnect {
success!(unsafe {
bindings::SimConnect_AddClientEventToNotificationGroup(
self.handle.as_ptr(),
notification_group as u32,
NOTIFICATION_GROUP_ID,
event as u32,
0,
)
@@ -33,43 +83,53 @@ impl SimConnect {
success!(unsafe {
bindings::SimConnect_SetNotificationGroupPriority(
self.handle.as_ptr(),
notification_group as u32,
1,
NOTIFICATION_GROUP_ID,
bindings::SIMCONNECT_GROUP_PRIORITY_HIGHEST,
)
})
})?;
Ok(())
}
/// Request that a specific system event is notified to the client.
/// Request that notifications are no longer received for the specified client event.
/// If the client event is not subscribed to, this function does nothing.
#[tracing::instrument(
name = "SimConnect::subscribe_to_system_event",
name = "SimConnect::unsubscribe_from_client_event",
level = "debug",
skip(self)
)]
pub fn subscribe_to_system_event(
pub fn unsubscribe_from_client_event(
&mut self,
event: SystemEventRequest,
event: ClientEventRequest,
) -> Result<(), SimConnectError> {
if self.client_event_register.is_registered(event) {
success!(unsafe {
bindings::SimConnect_SubscribeToSystemEvent(
bindings::SimConnect_RemoveClientEvent(
self.handle.as_ptr(),
NOTIFICATION_GROUP_ID,
event as u32,
event.into_c_char(),
)
})
})?;
self.client_event_register.unregister(event)?;
}
/// Request that notifications are no longer received for the specified system event.
Ok(())
}
/// Request that notifications are no longer received for any client event.
#[tracing::instrument(
name = "SimConnect::unsubscribe_from_system_event",
name = "SimConnect::unsubscribe_from_all_client_events",
level = "debug",
skip(self)
)]
pub fn unsubscribe_from_system_event(
&mut self,
event: SystemEventRequest,
) -> Result<(), SimConnectError> {
pub fn unsubscribe_from_all_client_events(&mut self) -> Result<(), SimConnectError> {
success!(unsafe {
bindings::SimConnect_UnsubscribeFromSystemEvent(self.handle.as_ptr(), event as u32)
})
bindings::SimConnect_ClearNotificationGroup(self.handle.as_ptr(), NOTIFICATION_GROUP_ID)
})?;
self.client_event_register.clear();
Ok(())
}
}

View File

@@ -4,7 +4,7 @@ impl SimConnect {
/// Request a list of all the facilities of a given type currently held in the facilities cache.
///
/// # Errors
/// - [`crate::SimConnectError::ObjectAlreadyRegistered`] -- Only one request or subscription per facility type is allowed. If you wish to create a new one, unsubscribe first using [`crate::SimConnect::unsubscribe_to_facilities`].
/// - [`crate::SimConnectError::ObjectAlreadyRegistered`] -- Only one request per facility type is supported.
///
/// # Remarks
/// The simulation keeps a facilities cache of all the airports, waypoints, NDB and VOR stations within a certain radius of the user aircraft.
@@ -20,7 +20,7 @@ impl SimConnect {
facility_type: FacilityType,
) -> Result<(), SimConnectError> {
let type_name = facility_type.to_type_name();
let request_id = self.new_request_id(type_name)?;
let request_id = self.new_request_id(type_name, true)?;
success!(unsafe {
bindings::SimConnect_RequestFacilitiesList(
@@ -38,7 +38,7 @@ impl SimConnect {
/// To terminate these notifications use the [`crate::SimConnect::unsubscribe_to_facilities`] function.
///
/// # Errors
/// - [`crate::SimConnectError::ObjectAlreadyRegistered`] -- Only one subscription or request per facility type is allowed. If you wish to create a new one, unsubscribe first using [`crate::SimConnect::unsubscribe_to_facilities`].
/// - [`crate::SimConnectError::ObjectAlreadyRegistered`] -- Only one subscription per facility type is supported. If you wish to create a new one, unsubscribe first using [`crate::SimConnect::unsubscribe_to_facilities`].
///
/// # Remarks
/// The simulation keeps a facilities cache of all the airports, waypoints, NDB and VOR stations within a certain radius of the user aircraft.
@@ -54,7 +54,7 @@ impl SimConnect {
facility_type: FacilityType,
) -> Result<(), SimConnectError> {
let type_name = facility_type.to_type_name();
let request_id = self.new_request_id(type_name)?;
let request_id = self.new_request_id(type_name, false)?;
success!(unsafe {
bindings::SimConnect_SubscribeToFacilities(
@@ -68,7 +68,7 @@ impl SimConnect {
/// Request that notifications of additions to the facilities cache are not longer sent.
///
/// # Remarks
/// This is used to terminate notifications generated by the [`crate::SimConnect::request_facilities_list`] or [`crate::SimConnect::subscribe_to_facilities`] functions.
/// This is used to terminate notifications generated by the [`crate::SimConnect::subscribe_to_facilities`] function.
#[tracing::instrument(
name = "SimConnect::unsubscribe_to_facilities",
level = "debug",

View File

@@ -1,8 +1,11 @@
mod base;
mod event_register;
mod events;
mod facilities;
mod objects;
pub(crate) use event_register::*;
pub use base::*;
pub use events::*;
pub use facilities::*;

View File

@@ -9,7 +9,7 @@ impl SimConnect {
pub fn register_object<T: SimConnectObjectExt>(&mut self) -> Result<u32, SimConnectError> {
let type_name: String = std::any::type_name::<T>().into();
let id = self.new_request_id(type_name)?;
let id = self.new_request_id(type_name, false)?;
T::register(self, id)?;
@@ -27,13 +27,23 @@ impl SimConnect {
.ok_or_else(|| SimConnectError::ObjectNotRegistered(type_name.clone()))?;
success!(unsafe {
bindings::SimConnect_ClearDataDefinition(self.handle.as_ptr(), *request_id)
bindings::SimConnect_ClearDataDefinition(self.handle.as_ptr(), request_id.id)
})?;
self.unregister_request_id_by_type_name(&type_name)
.ok_or(SimConnectError::ObjectNotRegistered(type_name))
}
pub fn get_object_id<T: SimConnectObjectExt>(&self) -> Result<u32, SimConnectError> {
let type_name: String = std::any::type_name::<T>().into();
Ok(self
.registered_objects
.get(&type_name)
.ok_or_else(|| SimConnectError::ObjectNotRegistered(type_name.clone()))?
.id)
}
/// Add a Microsoft Flight Simulator simulation variable name to a client defined object definition.
///
/// # Remarks
@@ -109,4 +119,47 @@ impl SimConnect {
)
})
}
pub fn set_data_on_sim_object<T>(&self, obj: &mut T) -> Result<(), SimConnectError> {
let type_name: String = std::any::type_name::<T>().into();
let request_id = self
.registered_objects
.get(&type_name)
.ok_or_else(|| SimConnectError::ObjectNotRegistered(type_name.clone()))?;
success!(unsafe {
bindings::SimConnect_SetDataOnSimObject(
self.handle.as_ptr(),
request_id.id,
bindings::SIMCONNECT_OBJECT_ID_USER,
Condition::None.into(),
0,
size_of::<T>().try_into().unwrap(),
obj as *mut _ as *mut std::ffi::c_void,
)
})
}
pub fn set_data_on_sim_object_with_id<T>(
&self,
request_id: u32,
obj: &mut T,
) -> Result<(), SimConnectError> {
// Strings require to be something specific, so until we can figure out how to
// convert the strings "on-the-fly"
// we'll use the packed variant of the struct, but it'll need a custom request_id
success!(unsafe {
bindings::SimConnect_SetDataOnSimObject(
self.handle.as_ptr(),
request_id,
bindings::SIMCONNECT_OBJECT_ID_USER,
Condition::None.into(),
0,
size_of::<T>().try_into().unwrap(),
obj as *mut _ as *mut std::ffi::c_void,
)
})
}
}

12
testapp/Cargo.toml Normal file
View File

@@ -0,0 +1,12 @@
[package]
name = "testapp"
version = "0.1.0"
edition = "2021"
[dependencies]
anyhow = "1.0.90"
ctrlc = "3.4.5"
# simconnect-rs = { path = "../simconnect-rs" }
simconnect-sdk = { path = "../simconnect-sdk", features = ["derive"] }
tracing = "0.1.40"
tracing-subscriber = "0.3.18"

28
testapp/src/ctrl_c.rs Normal file
View File

@@ -0,0 +1,28 @@
use std::sync::{
atomic::{AtomicU8, Ordering},
Arc,
};
pub struct CtrlC {
counter: Arc<AtomicU8>,
}
impl CtrlC {
pub fn new() -> Self {
let counter: Arc<AtomicU8> = Default::default();
let c = counter.clone();
ctrlc::set_handler(move || {
c.fetch_add(1, Ordering::SeqCst);
if c.load(Ordering::SeqCst) >= 3 {
std::process::exit(1);
}
})
.unwrap();
Self { counter }
}
pub fn count(&self) -> u8 {
self.counter.load(Ordering::SeqCst)
}
}

114
testapp/src/main.rs Normal file
View File

@@ -0,0 +1,114 @@
mod ctrl_c;
mod models;
use std::{
borrow::Cow,
ffi::{CStr, CString},
thread::sleep,
time::Duration,
};
use ctrl_c::CtrlC;
use models::{AtcID, AtcIDCPacked, Fuel};
// use simconnect_rs::SimConnect;
use simconnect_sdk::{Notification, SimConnect, SystemEventRequest};
fn main() -> Result<(), anyhow::Error> {
use tracing::Level;
use tracing_subscriber::layer::SubscriberExt;
use tracing_subscriber::util::SubscriberInitExt;
use tracing_subscriber::Layer;
let fmt = tracing_subscriber::fmt::layer().with_filter(tracing_subscriber::filter::filter_fn(
|metadata| metadata.level() < &Level::TRACE,
));
tracing_subscriber::registry().with(fmt).init();
let Ok(mut simconnect) = SimConnect::new("Avii's Virtual Airline Manager") else {
panic!("Game not running, gotta wait for it here");
};
// .subscribe(SomeEvent);
let ctrl_c = CtrlC::new();
loop {
if let Ok(Some(event)) = simconnect.get_next_dispatch() {
match event {
Notification::Open => {
simconnect.subscribe_to_system_event(SystemEventRequest::FlightLoaded)?;
let id = simconnect.register_object::<AtcID>()?;
simconnect.register_object::<Fuel>()?;
let cs = CString::new("ITWORKS")?;
let mut buffer = [0i8; 256];
for (i, b) in cs.to_bytes_with_nul().iter().enumerate() {
buffer[i] = *b as i8;
}
simconnect
.set_data_on_sim_object_with_id(id, &mut AtcIDCPacked { value: buffer })?;
tracing::info!("ATC_ID set");
simconnect.set_data_on_sim_object(&mut Fuel {
ft1: 0.0,
wt1: 10.0,
wt2: 0.0,
et1: 0.0,
et2: 0.0,
et3: 0.0,
ft2: 0.0,
})?;
tracing::info!("FUEL set");
}
Notification::Object(object) => {
// if let Ok(fuel) = Fuel::try_from(&object) {
// // dbg!(fuel);
// continue;
// }
}
Notification::SystemEvent(system_event) => {
if let simconnect_sdk::SystemEvent::FlightLoaded { .. } = system_event {
let cs = CString::new("ITWORKS")?;
let mut buffer = [0i8; 256];
for (i, b) in cs.to_bytes_with_nul().iter().enumerate() {
buffer[i] = *b as i8;
}
let id = simconnect.get_object_id::<AtcID>()?;
simconnect.set_data_on_sim_object_with_id(
id,
&mut AtcIDCPacked { value: buffer },
)?;
tracing::info!("ATC_ID set");
simconnect.set_data_on_sim_object(&mut Fuel {
ft1: 0.0,
wt1: 10.0,
wt2: 0.0,
et1: 0.0,
et2: 0.0,
et3: 0.0,
ft2: 0.0,
})?;
tracing::info!("FUEL set");
}
}
Notification::Quit => panic!("Sim Quit"),
_ => todo!(),
}
}
sleep(Duration::from_millis(1000));
if ctrl_c.count() > 0 {
break;
}
}
drop(simconnect);
Ok(())
}

47
testapp/src/models.rs Normal file
View File

@@ -0,0 +1,47 @@
use simconnect_sdk::SimConnectObject;
#[derive(Debug, Clone, SimConnectObject)]
#[simconnect(period = "second")]
pub(super) struct AtcID {
#[simconnect(name = "ATC ID")]
pub value: String,
}
// #[derive(Debug, Clone, SimConnectObject)]
// #[simconnect(period = "second")]
// #[allow(dead_code)]
// struct AirplaneData {
// #[simconnect(name = "TITLE")]
// title: String,
// #[simconnect(name = "ATC ID")]
// atc_id: String,
// #[simconnect(name = "CATEGORY")]
// category: String,
// #[simconnect(name = "PLANE LATITUDE", unit = "degrees")]
// lat: f64,
// #[simconnect(name = "PLANE LONGITUDE", unit = "degrees")]
// lon: f64,
// #[simconnect(name = "PLANE ALTITUDE", unit = "feet")]
// alt: f64,
// #[simconnect(name = "SIM ON GROUND")]
// sim_on_ground: bool,
// }
#[derive(Debug, Clone, SimConnectObject)]
#[simconnect(period = "second")]
pub(super) struct Fuel {
#[simconnect(name = "FUEL TANK CENTER QUANTITY", unit = "gallons")]
pub ft1: f64,
#[simconnect(name = "FUEL TANK LEFT MAIN QUANTITY", unit = "gallons")]
pub wt1: f64,
#[simconnect(name = "FUEL TANK RIGHT MAIN QUANTITY", unit = "gallons")]
pub wt2: f64,
#[simconnect(name = "FUEL TANK EXTERNAL1 QUANTITY", unit = "gallons")]
pub et1: f64,
#[simconnect(name = "FUEL TANK EXTERNAL2 QUANTITY", unit = "gallons")]
pub et2: f64,
#[simconnect(name = "FUEL TANK CENTER3 QUANTITY", unit = "gallons")]
pub et3: f64,
#[simconnect(name = "FUEL TANK CENTER2 QUANTITY", unit = "gallons")]
pub ft2: f64,
}