vecna
/
lox
mirror of https://gitlab.torproject.org/vecna/lox.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

Make all requests POST requests to match server and browser handling

This commit is contained in:
onyinyang 2023-03-24 13:02:42 -04:00
parent 51afc526ec
commit b0038720e0
No known key found for this signature in database
GPG Key ID: 156A6435430C2036
2 changed files with 6 additions and 38 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

32
crates/lox-wasm/index.js
View File

@ -179,7 +179,7 @@ function requested_cred(command, requested) {
function request_open_invite() {
return new Promise((fulfill, reject) => {
loxServerGetRequest("/invite").then((response) => {
loxServerPostRequest("/invite", null).then((response) => {
console.log("Got invitation token: " + response.invite);
fulfill(response.invite);
return;
@ -192,7 +192,7 @@ function request_open_invite() {
function simple_request(requested) {
return new Promise((fulfill, reject) => {
loxServerGetRequest(requested).then((response) => {
loxServerPostRequest(requested, null).then((response) => {
fulfill(JSON.stringify(response));
return;
}).catch(() => {
@ -202,34 +202,6 @@ function simple_request(requested) {
});
}
function loxServerGetRequest(data) {
return new Promise((fulfill, reject) => {
const xhr = new XMLHttpRequest();
xhr.onreadystatechange = function() {
if (xhr.DONE !== xhr.readyState) {
return;
}
if (xhr.status !== 200) {
console.log("Error. Status code: "+xhr.status);
console.log(xhr);
reject();
return;
}
const response = JSON.parse(xhr.responseText);
fulfill(response);
return;
};
try {
xhr.open('GET', "http://localhost:8001"+data);
} catch (err) {
console.log("Error connecting to lox bridge db");
reject();
return;
}
xhr.send();
});
}
function loxServerPostRequest(data, payload) {
return new Promise((fulfill, reject) => {
const xhr = new XMLHttpRequest();

12
crates/lox-wasm/src/lib.rs
View File

@ -1,7 +1,5 @@
use chrono::{Duration, Utc, NaiveDate};
use std::sync::atomic::{AtomicI64, Ordering};
use chrono::{Duration, Utc};
use julianday::JulianDay;
use lazy_static::lazy_static;
use lox::bridge_table::{BridgeLine,from_scalar,BridgeTable, ENC_BUCKET_BYTES};
use lox::cred::{BucketReachability, Invitation, Lox, Migration};
use lox::proto::{open_invite, trust_promotion, migration, level_up,
@ -9,8 +7,6 @@ use lox::proto::{open_invite, trust_promotion, migration, level_up,
use lox::{IssuerPubKey, OPENINV_LENGTH, scalar_u32};
use serde::{Deserialize, Serialize};
use serde_with::{serde_as};
use serde_json;
//use serde_wasm_bindgen;
use std::array::TryFromSliceError;
use std::{panic};
use wasm_bindgen::prelude::*;
@ -141,8 +137,8 @@ pub fn open_invite(invite: &[u8]) -> Result<String, JsValue> {
};
let (request, state) = open_invite::request(&token);
let req_state = OpenReqState {
request: request,
state: state,
request,
state,
};
unsafe {
log(&format!(
@ -310,7 +306,7 @@ fn generate_reachability_cred(lox_cred: &Lox, encrypted_table: String) -> Bucket
let (id, key) = from_scalar(lox_cred.bucket).unwrap();
let enc_buckets: EncBridgeTable = serde_json::from_str(&encrypted_table).unwrap();
let bucket = BridgeTable::decrypt_bucket(id, &key, &enc_buckets.etable[id as usize]).unwrap();
return bucket.1.unwrap()
bucket.1.unwrap()
}
#[wasm_bindgen]