wip: remove legacy connection modules

sandpolis/Cargo.toml

@@ -8,6 +8,9 @@ repository = "https:/fossable/sandpolis"
 rust-version = "1.74"
 version = "0.0.1"
 
+[build-dependencies]
+built = { version = "0.7", features = ["cargo-lock", "dependency-tree", "git2", "chrono", "semver"] }
+
 [dependencies]
 anyhow = "1.0.76"
 clap = { version = "4.4.7", features = ["derive", "string"] }

sandpolis/build.rs

@@ -0,0 +1,10 @@
+use std::{env, path::PathBuf};
+
+fn main() {
+ if built::write_built_file().is_err() {
+ let dest =
+ std::path::Path::new(&env::var("OUT_DIR").expect("OUT_DIR not set")).join("built.rs");
+ built::write_built_file_with_opts(Some(&PathBuf::from("..")), &dest)
+ .expect("Failed to acquire build-time information");
+ }
+}

sandpolis/src/agent/mod.rs

@@ -189,11 +189,8 @@
 //! The probe may attempt a spontaneous connection outside of the regular schedule
 //! at any time.
 
-pub mod connection;
-
 use anyhow::{bail, Result};
 use clap::Parser;
-use predicates::{prelude::*, Predicate};
 use std::collections::HashMap;
 use std::io::BufRead;
 use std::net::TcpStream;
@@ -274,11 +271,3 @@ fn connection_routine(config: &AgentConfig_LoopConfig) {
  thread::sleep(time::Duration::from_millis(config.cooldown as u64));
  }
 }
-
-fn dispatch_routine(connection: &mut Connection) {
- debug!("Starting command dispatch routine");
-
- loop {
- // TODO
- }
-}

sandpolis/src/client/ui/node.rs

@@ -15,14 +15,8 @@ pub struct Node {
  pub id: NodeId,
  pub collier: Collider,
  pub rigid_body: RigidBody,
- // /// User indication of whether an entity is visible
- pub visibility: Visibility,
  pub sprite: SpriteBundle,
- // // Inherited visibility of an entity.
- // pub inherited_visibility: InheritedVisibility,
  pub restitution: Restitution,
- // // Indication of whether an entity is visible in any view.
- // pub view_visibility: ViewVisibility,
 }
 
 pub fn spawn_node(
@@ -38,7 +32,6 @@ pub fn spawn_node(
  rigid_body: RigidBody::Dynamic,
  // visibility: todo!(),
  restitution: Restitution::coefficient(0.7),
- visibility: Visibility::Visible,
  sprite: SpriteBundle {
  texture: asset_server.load(get_os_image(os_type)),
  ..default()

sandpolis/src/core/database.rs

@@ -24,6 +24,31 @@ pub struct LocalMetadata {
  pub os_info: os_info::Info,
 }
 
+#[derive(Serialize, Deserialize, Clone, Debug)]
+pub enum ReplicationAuth {
+ #[serde(rename = "basic")]
+ Basic { username: String, password: String },
+}
+
+#[derive(Serialize, Deserialize, Clone, Debug)]
+pub struct ReplicationTarget {
+ pub url: String,
+ pub auth: ReplicationAuth,
+}
+
+#[derive(Serialize, Deserialize, Clone, Debug, CouchDocument)]
+pub struct ReplicationTask {
+ #[serde(skip_serializing_if = "String::is_empty")]
+ pub _id: DocumentId,
+ #[serde(skip_serializing_if = "String::is_empty")]
+ pub _rev: String,
+
+ pub source: String,
+ pub target: ReplicationTarget,
+ pub create_target: bool,
+ pub continuous: bool,
+}
+
 #[derive(Clone)]
 pub struct Database {
  address: String,
@@ -158,7 +183,24 @@ impl Database {
  .await?;
 
  // Setup replications
- // TODO
+ client
+ .db("_replicator")
+ .await?
+ .save(&mut ReplicationTask {
+ _id: "servers".into(),
+ _rev: "".into(),
+ source: "http://127.0.0.1:80/servers".into(),
+ target: ReplicationTarget {
+ url: "http://127.0.0.1:5984/servers".into(),
+ auth: ReplicationAuth::Basic {
+ username: "test".into(),
+ password: "test".into(),
+ },
+ },
+ create_target: true,
+ continuous: true,
+ })
+ .await?;
 
  debug!(server_id = ?metadata.id, "Connected to server successfully");