_ Git - rust-lightning/blob - 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 #![cfg_attr(not(any(test, fuzzing, feature = "_test_utils")), deny(missing_docs))]
  22 #![cfg_attr(not(any(test, fuzzing, feature = "_test_utils")), forbid(unsafe_code))]
  23 #![deny(broken_intra_doc_links)]
  24
  25 // In general, rust is absolutely horrid at supporting users doing things like,
  26 // for example, compiling Rust code for real environments. Disable useless lints
  27 // that don't do anything but annoy us and cant actually ever be resolved.
  28 #![allow(bare_trait_objects)]
  29 #![allow(ellipsis_inclusive_range_patterns)]
  30
  31 #![cfg_attr(all(not(feature = "std"), not(test)), no_std)]
  32
  33 #![cfg_attr(all(any(test, feature = "_test_utils"), feature = "_bench_unstable"), feature(test))]
  34 #[cfg(all(any(test, feature = "_test_utils"), feature = "_bench_unstable"))] extern crate test;
  35
  36 #[cfg(not(any(feature = "std", feature = "no-std")))]
  37 compile_error!("at least one of the `std` or `no-std` features must be enabled");
  38
  39 #[cfg(all(fuzzing, test))]
  40 compile_error!("Tests will always fail with cfg=fuzzing");
  41
  42 #[macro_use]
  43 extern crate alloc;
  44 extern crate bitcoin;
  45 #[cfg(any(test, feature = "std"))]
  46 extern crate core;
  47
  48 #[cfg(any(test, feature = "_test_utils"))] extern crate hex;
  49 #[cfg(any(test, fuzzing, feature = "_test_utils"))] extern crate regex;
  50
  51 #[cfg(not(feature = "std"))] extern crate core2;
  52
  53 #[macro_use]
  54 pub mod util;
  55 pub mod chain;
  56 pub mod ln;
  57 pub mod routing;
  58
  59 #[cfg(feature = "std")]
  60 use std::io;
  61 #[cfg(not(feature = "std"))]
  62 use core2::io;
  63
  64 #[cfg(not(feature = "std"))]
  65 mod io_extras {
  66         use core2::io::{self, Read, Write};
  67
  68         /// A writer which will move data into the void.
  69         pub struct Sink {
  70                 _priv: (),
  71         }
  72
  73         /// Creates an instance of a writer which will successfully consume all data.
  74         pub const fn sink() -> Sink {
  75                 Sink { _priv: () }
  76         }
  77
  78         impl core2::io::Write for Sink {
  79                 #[inline]
  80                 fn write(&mut self, buf: &[u8]) -> core2::io::Result<usize> {
  81                         Ok(buf.len())
  82                 }
  83
  84                 #[inline]
  85                 fn flush(&mut self) -> core2::io::Result<()> {
  86                         Ok(())
  87                 }
  88         }
  89
  90         pub fn copy<R: ?Sized, W: ?Sized>(reader: &mut R, writer: &mut W) -> Result<u64, io::Error>
  91                 where
  92                 R: Read,
  93                 W: Write,
  94         {
  95                 let mut count = 0;
  96                 let mut buf = [0u8; 64];
  97
  98                 loop {
  99                         match reader.read(&mut buf) {
 100                                 Ok(0) => break,
 101                                 Ok(n) => { writer.write_all(&buf[0..n])?; count += n as u64; },
 102                                 Err(ref e) if e.kind() == io::ErrorKind::Interrupted => {},
 103                                 Err(e) => return Err(e.into()),
 104                         };
 105                 }
 106                 Ok(count)
 107         }
 108
 109         pub fn read_to_end<D: io::Read>(mut d: D) -> Result<alloc::vec::Vec<u8>, io::Error> {
 110                 let mut result = vec![];
 111                 let mut buf = [0u8; 64];
 112                 loop {
 113                         match d.read(&mut buf) {
 114                                 Ok(0) => break,
 115                                 Ok(n) => result.extend_from_slice(&buf[0..n]),
 116                                 Err(ref e) if e.kind() == io::ErrorKind::Interrupted => {},
 117                                 Err(e) => return Err(e.into()),
 118                         };
 119                 }
 120                 Ok(result)
 121         }
 122 }
 123
 124 #[cfg(feature = "std")]
 125 mod io_extras {
 126         pub fn read_to_end<D: ::std::io::Read>(mut d: D) -> Result<Vec<u8>, ::std::io::Error> {
 127                 let mut buf = Vec::new();
 128                 d.read_to_end(&mut buf)?;
 129                 Ok(buf)
 130         }
 131
 132         pub use std::io::{copy, sink};
 133 }
 134
 135 mod prelude {
 136         #[cfg(feature = "hashbrown")]
 137         extern crate hashbrown;
 138
 139         pub use alloc::{vec, vec::Vec, string::String, collections::VecDeque, boxed::Box};
 140         #[cfg(not(feature = "hashbrown"))]
 141         pub use std::collections::{HashMap, HashSet, hash_map};
 142         #[cfg(feature = "hashbrown")]
 143         pub use self::hashbrown::{HashMap, HashSet, hash_map};
 144
 145         pub use alloc::borrow::ToOwned;
 146         pub use alloc::string::ToString;
 147 }
 148
 149 #[cfg(all(feature = "std", test))]
 150 mod debug_sync;
 151 #[cfg(all(feature = "backtrace", feature = "std", test))]
 152 extern crate backtrace;
 153
 154 #[cfg(feature = "std")]
 155 mod sync {
 156         #[cfg(test)]
 157         pub use debug_sync::*;
 158         #[cfg(not(test))]
 159         pub use ::std::sync::{Arc, Mutex, Condvar, MutexGuard, RwLock, RwLockReadGuard};
 160 }
 161
 162 #[cfg(not(feature = "std"))]
 163 mod sync;