mirror of
https://gitlab.com/veilid/veilid.git
synced 2025-12-16 08:14:26 -05:00
fix compilation, add changelog
This commit is contained in:
parent
8b5f77f264
commit
65b0463d38
5 changed files with 10 additions and 17 deletions
|
|
@ -30,6 +30,8 @@
|
||||||
- Added 'tick lag' detection to check for missed watch updates
|
- Added 'tick lag' detection to check for missed watch updates
|
||||||
- Added 'DHT Widening', separates consensus width (server side dht operation acceptance) from consensus count (client side), fixes [#435](https://gitlab.com/veilid/veilid/-/issues/435)
|
- Added 'DHT Widening', separates consensus width (server side dht operation acceptance) from consensus count (client side), fixes [#435](https://gitlab.com/veilid/veilid/-/issues/435)
|
||||||
- Deprecation of WSS protocol, closes [#487](https://gitlab.com/veilid/veilid/-/issues/487)
|
- Deprecation of WSS protocol, closes [#487](https://gitlab.com/veilid/veilid/-/issues/487)
|
||||||
|
- Move node id and public key init to routing table
|
||||||
|
- VeilidConfig is now read-only and no longer requires a lock [#485](https://gitlab.com/veilid/veilid/-/issues/485)
|
||||||
|
|
||||||
- veilid-python:
|
- veilid-python:
|
||||||
- Migrated to 'uv' from 'poetry'
|
- Migrated to 'uv' from 'poetry'
|
||||||
|
|
|
||||||
|
|
@ -137,9 +137,7 @@ impl Network {
|
||||||
|
|
||||||
self.record_dial_info_failure(dial_info.clone(), async move {
|
self.record_dial_info_failure(dial_info.clone(), async move {
|
||||||
let data_len = data.len();
|
let data_len = data.len();
|
||||||
let timeout_ms = self
|
let timeout_ms = self.config().network.connection_initial_timeout_ms;
|
||||||
.config()
|
|
||||||
.with(|c| c.network.connection_initial_timeout_ms);
|
|
||||||
|
|
||||||
if self
|
if self
|
||||||
.network_manager()
|
.network_manager()
|
||||||
|
|
@ -204,9 +202,7 @@ impl Network {
|
||||||
|
|
||||||
self.record_dial_info_failure(dial_info.clone(), async move {
|
self.record_dial_info_failure(dial_info.clone(), async move {
|
||||||
let data_len = data.len();
|
let data_len = data.len();
|
||||||
let connect_timeout_ms = self
|
let connect_timeout_ms = self.config().network.connection_initial_timeout_ms;
|
||||||
.config()
|
|
||||||
.with(|c| c.network.connection_initial_timeout_ms);
|
|
||||||
|
|
||||||
if self
|
if self
|
||||||
.network_manager()
|
.network_manager()
|
||||||
|
|
@ -382,15 +378,14 @@ impl Network {
|
||||||
// get protocol config
|
// get protocol config
|
||||||
let protocol_config = {
|
let protocol_config = {
|
||||||
let config = self.config();
|
let config = self.config();
|
||||||
let c = config.get();
|
|
||||||
let inbound = ProtocolTypeSet::new();
|
let inbound = ProtocolTypeSet::new();
|
||||||
let mut outbound = ProtocolTypeSet::new();
|
let mut outbound = ProtocolTypeSet::new();
|
||||||
|
|
||||||
if c.network.protocol.ws.connect {
|
if config.network.protocol.ws.connect {
|
||||||
outbound.insert(ProtocolType::WS);
|
outbound.insert(ProtocolType::WS);
|
||||||
}
|
}
|
||||||
#[cfg(feature = "enable-protocol-wss")]
|
#[cfg(feature = "enable-protocol-wss")]
|
||||||
if c.network.protocol.wss.connect {
|
if config.network.protocol.wss.connect {
|
||||||
outbound.insert(ProtocolType::WSS);
|
outbound.insert(ProtocolType::WSS);
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|
@ -406,7 +401,7 @@ impl Network {
|
||||||
PUBLIC_INTERNET_CAPABILITIES
|
PUBLIC_INTERNET_CAPABILITIES
|
||||||
.iter()
|
.iter()
|
||||||
.copied()
|
.copied()
|
||||||
.filter(|cap| !c.capabilities.disable.contains(cap))
|
.filter(|cap| !config.capabilities.disable.contains(cap))
|
||||||
.collect::<Vec<VeilidCapability>>()
|
.collect::<Vec<VeilidCapability>>()
|
||||||
};
|
};
|
||||||
|
|
||||||
|
|
|
||||||
|
|
@ -52,10 +52,7 @@ impl WebsocketNetworkConnection {
|
||||||
instrument(level = "trace", err, skip(self))
|
instrument(level = "trace", err, skip(self))
|
||||||
)]
|
)]
|
||||||
pub async fn close(&self) -> io::Result<NetworkResult<()>> {
|
pub async fn close(&self) -> io::Result<NetworkResult<()>> {
|
||||||
let timeout_ms = self
|
let timeout_ms = self.config().network.connection_initial_timeout_ms;
|
||||||
.registry
|
|
||||||
.config()
|
|
||||||
.with(|c| c.network.connection_initial_timeout_ms);
|
|
||||||
|
|
||||||
#[allow(unused_variables)]
|
#[allow(unused_variables)]
|
||||||
let x = match timeout(timeout_ms, self.inner.ws_meta.close()).await {
|
let x = match timeout(timeout_ms, self.inner.ws_meta.close()).await {
|
||||||
|
|
|
||||||
|
|
@ -16,8 +16,7 @@ impl TableStoreDriver {
|
||||||
|
|
||||||
fn get_namespaced_table_name(&self, table: &str) -> String {
|
fn get_namespaced_table_name(&self, table: &str) -> String {
|
||||||
let config = self.registry().config();
|
let config = self.registry().config();
|
||||||
let c = config.get();
|
let namespace = config.namespace.clone();
|
||||||
let namespace = c.namespace.clone();
|
|
||||||
if namespace.is_empty() {
|
if namespace.is_empty() {
|
||||||
table.to_owned()
|
table.to_owned()
|
||||||
} else {
|
} else {
|
||||||
|
|
|
||||||
2
veilid-wasm/tests/package-lock.json
generated
2
veilid-wasm/tests/package-lock.json
generated
|
|
@ -21,7 +21,7 @@
|
||||||
},
|
},
|
||||||
"../pkg": {
|
"../pkg": {
|
||||||
"name": "veilid-wasm",
|
"name": "veilid-wasm",
|
||||||
"version": "0.4.7",
|
"version": "0.4.8",
|
||||||
"dev": true,
|
"dev": true,
|
||||||
"license": "MPL-2.0"
|
"license": "MPL-2.0"
|
||||||
},
|
},
|
||||||
|
|
|
||||||
Loading…
Add table
Add a link
Reference in a new issue