tensamin/omega
Watch
6
0
Fork
You've already forked omega
 0
Code Issues Pull requests 1 Projects Releases Packages Wiki Activity Actions

[Fix] Changed to TTP, changed remote to fetch from git.methanium.net

Browse source
This commit is contained in:
Alex Emmet 2026-04-05 21:48:47 +02:00
commit 56d21b6d38
4 changed files with 164 additions and 144 deletions
Download patch file Download diff file Expand all files Collapse all files

8
src/transport/omikron_connection.rs
View file

@ -11,8 +11,6 @@ use crate::{
};
use base64::{Engine as _, engine::general_purpose::STANDARD};
use dashmap::DashMap;
use epsilon_core::{CommunicationType, CommunicationValue, DataTypes, DataValue};
use epsilon_native::{Host, Receiver, Sender};
use rand::{Rng, distributions::Alphanumeric};
use std::{
sync::Arc,
@ -22,6 +20,8 @@ use tokio::{
sync::{Mutex, RwLock},
time::interval,
};
use ttp_core::{CommunicationType, CommunicationValue, DataTypes, DataValue};
use ttp_native::{Host, Receiver, Sender};
use x448::PublicKey;
// ============================================================================
@ -92,7 +92,7 @@ impl AuthState {
}
// ============================================================================
// Omikron Connection (Epsilon/QUIC-based)
// Omikron Connection (ttp/QUIC-based)
// ============================================================================
pub struct OmikronConnection {
@ -1125,7 +1125,7 @@ pub async fn start(port: u16) -> Result<(), Box<dyn std::error::Error>> {
let key_pem = load_file_vec("certs", "transport_key.pem").expect("Error loading Keyfile");
let mut host: Host = epsilon_native::host(port, cert_pem, key_pem).await?;
let mut host: Host = ttp_native::host(port, cert_pem, key_pem).await?;
log!("OmikronServer listening on port {}", port);
while let Some((sender, mut receiver)) = host.next().await {

2
src/util/logger.rs
View file

@ -9,8 +9,8 @@ use std::{
};
use ansi_term::Color;
use epsilon_core::{CommunicationValue, DataTypes, DataValue};
use json::JsonValue;
use ttp_core::{CommunicationValue, DataTypes, DataValue};
static LOGGER: OnceLock<mpsc::Sender<LogMessage>> = OnceLock::new();