user: implement user factory

Co-Authored-By: Joshua M. Clulow <jmc@oxide.computer>

Author: emilyalbini

Cargo.lock

@@ -10,6 +10,7 @@ members = [
 	"download",
 	"factory/aws",
 	"factory/gimlet",
+	"factory/user",
 	"factory/lab",
 	"factory/propolis",
 	"github/client",
@@ -44,6 +45,7 @@ wrong_self_convention = "allow"
 [workspace.dependencies]
 ansi-to-html = { version = "0.2", features =  [ "lazy-init" ] }
 anyhow = "1"
+async-compression = { version = "0.4", features = ["gzip", "tokio"] }
 aws-config = "1"
 aws-credential-types = "1"
 aws-runtime = "1"
@@ -58,6 +60,7 @@ devinfo = { version = "0.1", features = [ "private" ] }
 dialoguer = { version = "0.12.0", default-features = false }
 dirs-next = "2"
 dropshot = "0.16"
+expect-test = "1"
 futures = "0.3"
 futures-core = "0.3"
 getopts = "0.2"
@@ -80,6 +83,7 @@ percent-encoding = "2.1"
 progenitor = { version = "0.11" }
 progenitor-client = { version = "0.11" }
 rand = "0.10"
+rand_pcg = "0.10"
 regex = "1"
 reqwest = { version = "0.12", features = [ "json", "stream" ] }
 rust-toolchain-file = "0.1"

Cargo.toml

@@ -16,6 +16,7 @@ chrono = { workspace = true }
 libc = { workspace = true }
 new_mime_guess = { workspace = true }
 rand = { workspace = true }
+rand_pcg = { workspace = true }
 regex = { workspace = true }
 rusty_ulid = { workspace = true }
 serde = { workspace = true }

common/Cargo.toml

@@ -12,7 +12,8 @@ use std::time::Duration;
 use anyhow::Result;
 use chrono::prelude::*;
 use rand::distr::Alphanumeric;
-use rand::{rng, RngExt as _};
+use rand::{rng, Rng, RngExt, SeedableRng as _};
+use rand_pcg::Pcg64;
 use regex::Regex;
 use rusty_ulid::Ulid;
 use serde::{Deserialize, Serialize};
@@ -63,6 +64,24 @@ pub fn make_log(name: &'static str) -> Logger {
     }
 }
 
+pub fn make_test_log() -> Logger {
+    let dec = slog_term::PlainSyncDecorator::new(slog_term::TestStdoutWriter);
+    let dr = slog_term::FullFormat::new(dec).build().fuse();
+    Logger::root(dr, o!())
+}
+
+pub fn make_test_rng() -> Pcg64 {
+    /*
+     * This is a deterministic rng that is guaranteed not to change behavior
+     * across version bumps.  We can rely on its outputs in assertions.
+     */
+    Pcg64::seed_from_u64(42)
+}
+
+pub fn make_test_ulid<R: Rng>(rng: &mut R) -> Ulid {
+    Ulid::from_timestamp_with_rng(0, rng)
+}
+
 fn bool_env(var: &str) -> bool {
     if let Ok(content) = std::env::var(var) {
         let lower = content.to_ascii_lowercase();

common/src/lib.rs

@@ -3,6 +3,7 @@
  */
 
 use anyhow::{anyhow, Result};
+use serde::{Deserialize, Serialize};
 use std::ffi::{CStr, CString};
 use std::io::{Error as IoError, ErrorKind};
 use std::path::PathBuf;
@@ -60,10 +61,16 @@ pub fn getuid() -> Uid {
     Uid(unsafe { libc::getuid() })
 }
 
-#[derive(Debug, Clone, Copy, PartialEq, Eq, PartialOrd, Ord)]
+#[derive(
+    Debug, Clone, Copy, PartialEq, Eq, PartialOrd, Ord, Serialize, Deserialize,
+)]
+#[serde(transparent)]
 pub struct Uid(pub u32);
 
-#[derive(Debug, Clone, Copy, PartialEq, Eq, PartialOrd, Ord)]
+#[derive(
+    Debug, Clone, Copy, PartialEq, Eq, PartialOrd, Ord, Serialize, Deserialize,
+)]
+#[serde(transparent)]
 pub struct Gid(pub u32);
 
 fn catch_errno<T, F: Fn() -> T>(f: F) -> Result<T, IoError> {

common/src/unix.rs

@@ -258,7 +258,6 @@ macro_rules! sqlite_ulid_new_type {
             PartialOrd,
             Ord,
             Hash,
-            Debug,
             serde::Serialize,
             serde::Deserialize,
             $($derives),*
@@ -311,6 +310,12 @@ macro_rules! sqlite_ulid_new_type {
             }
         }
 
+        impl std::fmt::Debug for $name {
+            fn fmt(&self, f: &mut std::fmt::Formatter<'_>) -> std::fmt::Result {
+                write!(f, "{}({})", stringify!($name), self.0.to_string())
+            }
+        }
+
         impl std::str::FromStr for $name {
             type Err = rusty_ulid::DecodingError;
 

database/src/lib.rs

@@ -0,0 +1,39 @@
+[package]
+name = "buildomat-factory-user"
+version.workspace = true
+edition.workspace = true
+license.workspace = true
+
+[lints]
+workspace = true
+
+[dependencies]
+buildomat-common = { path = "../../common" }
+buildomat-database = { path = "../../database" }
+buildomat-client = { path = "../../client" }
+buildomat-types = { path = "../../types" }
+
+anyhow = { workspace = true }
+async-compression = { workspace = true }
+base64 = { workspace = true }
+chrono = { workspace = true }
+getopts = { workspace = true }
+libc = { workspace = true }
+rand = { workspace = true }
+reqwest = { workspace = true } 
+rusty_ulid = { workspace = true }
+schemars = { workspace = true }
+sea-query = { workspace = true }
+serde = { workspace = true }
+serde_json = { workspace = true }
+slog = { workspace = true }
+slog-term = { workspace = true }
+smf = { workspace = true }
+strum = { workspace = true }
+tempfile = { workspace = true }
+tokio = { workspace = true }
+toml = { workspace = true }
+usdt = { workspace = true }
+
+[dev-dependencies]
+expect-test = { workspace = true }