Ensure we read the full TLV stream length when maybe-reading `None`
[rust-lightning] / lightning / src / lib.rs
1 // This file is Copyright its original authors, visible in version control
2 // history.
3 //
4 // This file is licensed under the Apache License, Version 2.0 <LICENSE-APACHE
5 // or http://www.apache.org/licenses/LICENSE-2.0> or the MIT license
6 // <LICENSE-MIT or http://opensource.org/licenses/MIT>, at your option.
7 // You may not use this file except in accordance with one or both of these
8 // licenses.
9
10 #![crate_name = "lightning"]
11
12 //! Rust-Lightning, not Rusty's Lightning!
13 //!
14 //! A full-featured but also flexible lightning implementation, in library form. This allows the
15 //! user (you) to decide how they wish to use it instead of being a fully self-contained daemon.
16 //! This means there is no built-in threading/execution environment and it's up to the user to
17 //! figure out how best to make networking happen/timers fire/things get written to disk/keys get
18 //! generated/etc. This makes it a good candidate for tight integration into an existing wallet
19 //! instead of having a rather-separate lightning appendage to a wallet.
20 //!
21 //! `default` features are:
22 //!
23 //! * `std` - enables functionalities which require `std`, including `std::io` trait implementations and things which utilize time
24 //! * `grind_signatures` - enables generation of [low-r bitcoin signatures](https://bitcoin.stackexchange.com/questions/111660/what-is-signature-grinding),
25 //! which saves 1 byte per signature in 50% of the cases (see [bitcoin PR #13666](https://github.com/bitcoin/bitcoin/pull/13666))
26 //!
27 //! Available features are:
28 //!
29 //! * `std`
30 //! * `grind_signatures`
31 //! * `no-std ` - exposes write trait implementations from the `core2` crate (at least one of `no-std` or `std` are required)
32 //! * Skip logging of messages at levels below the given log level:
33 //!     * `max_level_off`
34 //!     * `max_level_error`
35 //!     * `max_level_warn`
36 //!     * `max_level_info`
37 //!     * `max_level_debug`
38 //!     * `max_level_trace`
39
40 #![cfg_attr(not(any(test, fuzzing, feature = "_test_utils")), deny(missing_docs))]
41 #![cfg_attr(not(any(test, feature = "_test_utils")), forbid(unsafe_code))]
42
43 #![deny(rustdoc::broken_intra_doc_links)]
44 #![deny(rustdoc::private_intra_doc_links)]
45
46 // In general, rust is absolutely horrid at supporting users doing things like,
47 // for example, compiling Rust code for real environments. Disable useless lints
48 // that don't do anything but annoy us and cant actually ever be resolved.
49 #![allow(bare_trait_objects)]
50 #![allow(ellipsis_inclusive_range_patterns)]
51
52 #![cfg_attr(docsrs, feature(doc_auto_cfg))]
53
54 #![cfg_attr(all(not(feature = "std"), not(test)), no_std)]
55
56 #[cfg(not(any(feature = "std", feature = "no-std")))]
57 compile_error!("at least one of the `std` or `no-std` features must be enabled");
58
59 #[cfg(all(fuzzing, test))]
60 compile_error!("Tests will always fail with cfg=fuzzing");
61
62 #[macro_use]
63 extern crate alloc;
64 extern crate bitcoin;
65 #[cfg(any(test, feature = "std"))]
66 extern crate core;
67
68 extern crate hex;
69 #[cfg(any(test, feature = "_test_utils"))] extern crate regex;
70
71 #[cfg(not(feature = "std"))] extern crate core2;
72 #[cfg(not(feature = "std"))] extern crate libm;
73
74 #[cfg(ldk_bench)] extern crate criterion;
75
76 #[macro_use]
77 pub mod util;
78 pub mod chain;
79 pub mod ln;
80 pub mod offers;
81 pub mod routing;
82 pub mod sign;
83 pub mod onion_message;
84 pub mod blinded_path;
85 pub mod events;
86
87 pub(crate) mod crypto;
88
89 #[cfg(feature = "std")]
90 /// Re-export of either `core2::io` or `std::io`, depending on the `std` feature flag.
91 pub use std::io;
92 #[cfg(not(feature = "std"))]
93 /// Re-export of either `core2::io` or `std::io`, depending on the `std` feature flag.
94 pub use core2::io;
95
96 #[cfg(not(feature = "std"))]
97 #[doc(hidden)]
98 /// IO utilities public only for use by in-crate macros. These should not be used externally
99 pub mod io_extras {
100         use core2::io::{self, Read, Write};
101
102         /// A writer which will move data into the void.
103         pub struct Sink {
104                 _priv: (),
105         }
106
107         /// Creates an instance of a writer which will successfully consume all data.
108         pub const fn sink() -> Sink {
109                 Sink { _priv: () }
110         }
111
112         impl core2::io::Write for Sink {
113                 #[inline]
114                 fn write(&mut self, buf: &[u8]) -> core2::io::Result<usize> {
115                         Ok(buf.len())
116                 }
117
118                 #[inline]
119                 fn flush(&mut self) -> core2::io::Result<()> {
120                         Ok(())
121                 }
122         }
123
124         pub fn copy<R: ?Sized, W: ?Sized>(reader: &mut R, writer: &mut W) -> Result<u64, io::Error>
125                 where
126                 R: Read,
127                 W: Write,
128         {
129                 let mut count = 0;
130                 let mut buf = [0u8; 64];
131
132                 loop {
133                         match reader.read(&mut buf) {
134                                 Ok(0) => break,
135                                 Ok(n) => { writer.write_all(&buf[0..n])?; count += n as u64; },
136                                 Err(ref e) if e.kind() == io::ErrorKind::Interrupted => {},
137                                 Err(e) => return Err(e.into()),
138                         };
139                 }
140                 Ok(count)
141         }
142
143         pub fn read_to_end<D: io::Read>(mut d: D) -> Result<alloc::vec::Vec<u8>, io::Error> {
144                 let mut result = vec![];
145                 let mut buf = [0u8; 64];
146                 loop {
147                         match d.read(&mut buf) {
148                                 Ok(0) => break,
149                                 Ok(n) => result.extend_from_slice(&buf[0..n]),
150                                 Err(ref e) if e.kind() == io::ErrorKind::Interrupted => {},
151                                 Err(e) => return Err(e.into()),
152                         };
153                 }
154                 Ok(result)
155         }
156 }
157
158 #[cfg(feature = "std")]
159 #[doc(hidden)]
160 /// IO utilities public only for use by in-crate macros. These should not be used externally
161 mod io_extras {
162         pub fn read_to_end<D: ::std::io::Read>(mut d: D) -> Result<Vec<u8>, ::std::io::Error> {
163                 let mut buf = Vec::new();
164                 d.read_to_end(&mut buf)?;
165                 Ok(buf)
166         }
167
168         pub use std::io::{copy, sink};
169 }
170
171 mod prelude {
172         pub use alloc::{vec, vec::Vec, string::String, collections::VecDeque, boxed::Box};
173
174         pub use alloc::borrow::ToOwned;
175         pub use alloc::string::ToString;
176
177         pub(crate) use crate::util::hash_tables::*;
178 }
179
180 #[cfg(all(not(ldk_bench), feature = "backtrace", feature = "std", test))]
181 extern crate backtrace;
182
183 mod sync;