main.rs 4.6 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145
  1. mod client_lib;
  2. use client_lib::*;
  3. mod client_net;
  4. use client_net::HyperNet;
  5. use curve25519_dalek::scalar::Scalar;
  6. use getopts::Options;
  7. use lox::bridge_table::BridgeLine;
  8. use lox::IssuerPubKey;
  9. use serde::Serialize;
  10. use std::env::args;
  11. use std::fs::File;
  12. use std::io::Write;
  13. use std::path::Path;
  14. // Prints the argument details for this program
  15. fn print_usage(program: &str, opts: Options) {
  16. let brief = format!("Usage: {} [options]", program);
  17. print!("{}", opts.usage(&brief));
  18. }
  19. // Helper function to save serializable objects to files
  20. fn save_object<T: Serialize>(obj: T, filename: &str) {
  21. let mut outfile = File::create(filename).expect(&("Failed to create ".to_string() + filename));
  22. write!(outfile, "{}", serde_json::to_string(&obj).unwrap())
  23. .expect(&("Failed to write to ".to_string() + filename));
  24. }
  25. #[tokio::main]
  26. async fn main() {
  27. let args: Vec<String> = args().collect();
  28. let mut opts = Options::new();
  29. opts.optflag("h", "help", "print this help menu");
  30. opts.optflag("L", "level-up", "increase trust level");
  31. opts.optflag("N", "new-lox-cred", "get a new Lox Credential");
  32. opts.optopt(
  33. "",
  34. "server",
  35. "Lox Auth server address [http://localhost:8001]",
  36. "ADDR",
  37. );
  38. let matches = match opts.parse(&args[1..]) {
  39. Ok(m) => m,
  40. Err(f) => {
  41. panic!("{}", f.to_string())
  42. }
  43. };
  44. if matches.opt_present("h") {
  45. print_usage(&args[0], opts);
  46. return;
  47. }
  48. let net = if matches.opt_present("server") {
  49. HyperNet {
  50. hostname: matches.opt_str("server").unwrap(),
  51. }
  52. } else {
  53. HyperNet {
  54. hostname: "http://localhost:8001".to_string(),
  55. }
  56. };
  57. // Get Lox Authority public keys
  58. // TODO: Make this filename configurable
  59. let lox_auth_pubkeys_filename = "lox_auth_pubkeys.json";
  60. let lox_auth_pubkeys: Vec<IssuerPubKey> = if Path::new(lox_auth_pubkeys_filename).exists() {
  61. // read in file
  62. let lox_auth_pubkeys_infile = File::open(lox_auth_pubkeys_filename).unwrap();
  63. serde_json::from_reader(lox_auth_pubkeys_infile).unwrap()
  64. } else {
  65. // download from Lox Auth
  66. let pubkeys = get_lox_auth_keys(&net).await;
  67. // save to file for next time
  68. save_object(&pubkeys, &lox_auth_pubkeys_filename);
  69. pubkeys
  70. };
  71. // Get Lox Credential and BridgeLine
  72. let lox_cred_filename = "lox_cred.json";
  73. let bridgeline_filename = "bridgeline.json";
  74. let (lox_cred, bridgeline) = if matches.opt_present("N")
  75. || !Path::new(lox_cred_filename).exists()
  76. || !Path::new(bridgeline_filename).exists()
  77. {
  78. // get new Lox Credential
  79. let open_invite = get_open_invitation(&net).await;
  80. let (cred, bl) =
  81. get_lox_credential(&net, &open_invite, get_lox_pub(&lox_auth_pubkeys)).await;
  82. // save to files for next time
  83. save_object(&cred, &lox_cred_filename);
  84. save_object(&bl, &bridgeline_filename);
  85. (cred, bl)
  86. } else {
  87. // Read existing Lox Credential and BridgeLine from files
  88. let cred = serde_json::from_reader(File::open(lox_cred_filename).unwrap()).unwrap();
  89. let bl = serde_json::from_reader(File::open(bridgeline_filename).unwrap()).unwrap();
  90. (cred, bl)
  91. };
  92. let lox_cred = if matches.opt_present("L") {
  93. let old_level = get_cred_trust_level(&lox_cred);
  94. // If trust level is 0, do trust promotion, otherwise level up.
  95. let cred = if old_level == 0 {
  96. let migration_cred =
  97. trust_promotion(&net, &lox_cred, get_lox_pub(&lox_auth_pubkeys)).await;
  98. let cred = trust_migration(
  99. &net,
  100. &lox_cred,
  101. &migration_cred,
  102. get_lox_pub(&lox_auth_pubkeys),
  103. get_migration_pub(&lox_auth_pubkeys),
  104. )
  105. .await;
  106. cred
  107. } else {
  108. let encbuckets = get_reachability_credential(&net).await;
  109. let cred = level_up(
  110. &net,
  111. &lox_cred,
  112. &encbuckets,
  113. get_lox_pub(&lox_auth_pubkeys),
  114. get_reachability_pub(&lox_auth_pubkeys),
  115. )
  116. .await;
  117. cred
  118. };
  119. save_object(&cred, &lox_cred_filename);
  120. let new_level = get_cred_trust_level(&cred);
  121. if new_level > old_level {
  122. println!("Old level: {}\nNew level: {}", old_level, new_level);
  123. } else if new_level == old_level {
  124. println!("Unable to level up. Current level: {}", new_level);
  125. }
  126. cred
  127. } else {
  128. lox_cred
  129. };
  130. }