seedfaker-core 0.4.0-alpha.1

Core library for seedfaker — deterministic synthetic generator for realistic, correlated, and noisy test records
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99

// RFC 3986 — https://www.rfc-editor.org/rfc/rfc3986

use std::fmt::Write;

use crate::ctx::GenContext;

const DOMAINS: &[&str] = &[
    "api.example.com",
    "app.internal.io",
    "service.prod.net",
    "data.platform.dev",
    "cdn.assets.io",
    "portal.corp.net",
    "gateway.cloud.dev",
    "auth.identity.io",
];

const PATHS: &[&str] = &[
    "users",
    "orders",
    "products",
    "events",
    "metrics",
    "reports",
    "auth/token",
    "search",
    "upload",
    "export",
    "webhooks",
];

const VERSIONS: &[&str] = &["v1", "v2", "v3"];

pub fn gen(ctx: &mut GenContext<'_>, buf: &mut String) {
    let domain = DOMAINS[ctx.rng.urange(0, DOMAINS.len() - 1)];
    let ver = VERSIONS[ctx.rng.urange(0, VERSIONS.len() - 1)];
    let path = PATHS[ctx.rng.urange(0, PATHS.len() - 1)];

    match ctx.modifier {
        "http" => {
            buf.reserve(7 + domain.len() + 1 + ver.len() + 1 + path.len());
            buf.push_str("http://");
            buf.push_str(domain);
            buf.push('/');
            buf.push_str(ver);
            buf.push('/');
            buf.push_str(path);
        }
        "ftp" => {
            let dirs = ["pub", "data", "incoming", "archive", "releases"];
            let dir = dirs[ctx.rng.urange(0, dirs.len() - 1)];
            buf.reserve(6 + domain.len() + 1 + dir.len() + 1 + 8 + 7);
            buf.push_str("ftp://");
            buf.push_str(domain);
            buf.push('/');
            buf.push_str(dir);
            buf.push('/');
            ctx.rng.push_alnum(buf, 8);
            buf.push('.');
            let arr = ["tar.gz", "zip", "csv", "dat"];
            let ext = arr[ctx.rng.urange(0, arr.len() - 1)];
            buf.push_str(ext);
        }
        "ws" => {
            buf.reserve(5 + domain.len() + 1 + ver.len() + 1 + path.len());
            buf.push_str("ws://");
            buf.push_str(domain);
            buf.push('/');
            buf.push_str(ver);
            buf.push('/');
            buf.push_str(path);
        }
        "wss" => {
            buf.reserve(6 + domain.len() + 1 + ver.len() + 1 + path.len());
            buf.push_str("wss://");
            buf.push_str(domain);
            buf.push('/');
            buf.push_str(ver);
            buf.push('/');
            buf.push_str(path);
        }
        "ssh" => {
            let users = ["deploy", "admin", "ci", "root", "git"];
            let user = users[ctx.rng.urange(0, users.len() - 1)];
            let port = ctx.rng.range(22, 2222);
            buf.reserve(6 + user.len() + 1 + domain.len() + 6);
            let _ = write!(buf, "ssh://{user}@{domain}:{port}");
        }
        _ => {
            buf.reserve(8 + domain.len() + 1 + ver.len() + 1 + path.len());
            buf.push_str("https://");
            buf.push_str(domain);
            buf.push('/');
            buf.push_str(ver);
            buf.push('/');
            buf.push_str(path);
        }
    }
}