microcosm.blue
Server tools to backfill, tail, mirror, and verify PLC logs
update docs for v0.3, forwarding writes upstream
bad-example.com
+1
-1
Cargo.lock
+1
-1
Cargo.lock
+1
-1
Cargo.toml
+1
-1
Cargo.toml
+11
-6
readme.md
+11
-6
readme.md
···
26
sudo allegedly mirror \
27
--upstream "https://plc.directory" \
28
--wrap "http://127.0.0.1:3000" \
29
--acme-domain "plc.wtf" \
30
--acme-cache-path ./acme-cache \
31
-
--acme-directory-url "https://acme-staging-v02.api.letsencrypt.org/directory"
32
```
33
34
···
68
69
### new things
70
71
-
- experimental: websocket version of /export
72
-
- experimental: accept writes by forwarding them upstream
73
-
- experimental: serve a tlog
74
-
- experimental: embed a log database directly for fast and efficient mirroring
75
-
- experimental: support multiple upstreams?
76
77
- [ ] new command todo: `zip` or `check` or `diff`: compare two plc logs over some time range
78
- [ ] new command to consider: `scatter` or something: broadcast plc writes to multiple upstreams
···
26
sudo allegedly mirror \
27
--upstream "https://plc.directory" \
28
--wrap "http://127.0.0.1:3000" \
29
+
--wrap-pg-cert "/opt/allegedly/postgres-cert.pem" \
30
--acme-domain "plc.wtf" \
31
+
--acme-domain "alt.plc.wtf" \
32
+
--experimental-acme-domain "experimental.plc.wtf" \
33
--acme-cache-path ./acme-cache \
34
+
--acme-directory-url "https://acme-staging-v02.api.letsencrypt.org/directory" \
35
+
--acme-ipv6 \
36
+
--experimental-write-upstream
37
```
38
39
···
73
74
### new things
75
76
+
- [ ] experimental: websocket version of /export
77
+
- [x] experimental: accept writes by forwarding them upstream
78
+
- [ ] experimental: serve a tlog
79
+
- [ ] experimental: embed a log database directly for fast and efficient mirroring
80
+
- [ ] experimental: support multiple upstreams?
81
82
- [ ] new command todo: `zip` or `check` or `diff`: compare two plc logs over some time range
83
- [ ] new command to consider: `scatter` or something: broadcast plc writes to multiple upstreams
+25
-4
src/mirror.rs
+25
-4
src/mirror.rs
···
25
}
26
27
#[handler]
28
-
fn hello(Data(State { upstream, .. }): Data<&State>) -> String {
29
format!(
30
r#"{}
31
···
45
- GET /* Proxies to wrapped server; see PLC API docs:
46
https://web.plc.directory/api/redoc
47
48
-
- POST /* Always rejected. This is a mirror.
49
50
-
51
-
tip: try `GET /{{did}}` to resolve an identity
52
53
54
Allegedly is a suite of open-source CLI tools from for working with PLC logs,
···
25
}
26
27
#[handler]
28
+
fn hello(
29
+
Data(State {
30
+
upstream,
31
+
experimental: exp,
32
+
..
33
+
}): Data<&State>,
34
+
req: &Request,
35
+
) -> String {
36
+
let post_info = match (exp.write_upstream, &exp.acme_domain, req.uri().host()) {
37
+
(false, _, _) => " - POST /* Always rejected. This is a mirror.".to_string(),
38
+
(_, None, _) => {
39
+
" - POST /:did Create a PLC op. Allegedly will forward it upstream.".to_string()
40
+
}
41
+
(_, Some(d), Some(f)) if f == d => {
42
+
" - POST /:did Create a PLC op. Allegedly will forward it upstream.".to_string()
43
+
}
44
+
(_, Some(d), _) => format!(
45
+
r#"\
46
+
- POST /* Rejected, but experimental upstream op forwarding is
47
+
available at `POST {d}/:did`!"#
48
+
),
49
+
};
50
+
51
format!(
52
r#"{}
53
···
67
- GET /* Proxies to wrapped server; see PLC API docs:
68
https://web.plc.directory/api/redoc
69
70
+
tip: try `GET /{{did}}` to resolve an identity
71
72
+
{post_info}
73
74
75
Allegedly is a suite of open-source CLI tools from for working with PLC logs,