aleeve.dev
Scalable and distributed custom feed generator, ott - on that topic
Small adjustments towards working MVP
+14
-6
crates/ott-xrpc/src/main.rs
+14
-6
crates/ott-xrpc/src/main.rs
···
18
use ott_xrpc::{bsky::BskyClient, key::generate_key};
19
20
use tracing::info;
21
22
async fn handler(
23
ExtractServiceAuth(auth): ExtractServiceAuth,
···
43
44
#[tokio::main]
45
async fn main() {
46
let did_str = "did:web:ott.aleeve.dev";
47
let did = Did::new_static(did_str);
48
49
let verification_method = VerificationMethod {
50
-
id: "{did}#atproto".into(),
51
-
r#type: "Mutlikeybase".into(),
52
controller: Some("did:web:ott.aleeve.dev".into()),
53
public_key_multibase: Some(generate_key().into()),
54
extra_data: BTreeMap::default(),
55
};
56
57
let service = Service {
58
-
id: "".into(),
59
-
service_endpoint: Some("".into()),
60
-
r#type: "".into(),
61
extra_data: BTreeMap::default(),
62
};
63
···
78
.with_state(config)
79
.merge(did_web_router(did_doc));
80
81
-
let listener = tokio::net::TcpListener::bind("0.0.0.0:3000").await.unwrap();
82
axum::serve(listener, app).await.unwrap();
83
}
···
18
use ott_xrpc::{bsky::BskyClient, key::generate_key};
19
20
use tracing::info;
21
+
use tracing_subscriber::EnvFilter;
22
23
async fn handler(
24
ExtractServiceAuth(auth): ExtractServiceAuth,
···
44
45
#[tokio::main]
46
async fn main() {
47
+
tracing_subscriber::fmt()
48
+
.with_ansi(true) // Colors enabled (default)
49
+
.with_max_level(tracing::Level::INFO)
50
+
.init();
51
+
52
+
info!("Setup");
53
let did_str = "did:web:ott.aleeve.dev";
54
let did = Did::new_static(did_str);
55
56
let verification_method = VerificationMethod {
57
+
id: format!("{}#atproto", did_str).into(),
58
+
r#type: "Mutlikey".into(),
59
controller: Some("did:web:ott.aleeve.dev".into()),
60
public_key_multibase: Some(generate_key().into()),
61
extra_data: BTreeMap::default(),
62
};
63
64
let service = Service {
65
+
id: "#bsky_fg".into(),
66
+
service_endpoint: Some("https://ott.aleeve.dev/".into()),
67
+
r#type: "BskyFeedGenerator".into(),
68
extra_data: BTreeMap::default(),
69
};
70
···
85
.with_state(config)
86
.merge(did_web_router(did_doc));
87
88
+
let listener = tokio::net::TcpListener::bind("0.0.0.0:8080").await.unwrap();
89
+
info!("Starting service");
90
axum::serve(listener, app).await.unwrap();
91
}
+1
-1
helm/ott/templates/cloudflared_tunnel.yaml
+1
-1
helm/ott/templates/cloudflared_tunnel.yaml
+2
helm/ott/templates/pg_cluster.yaml
+2
helm/ott/templates/pg_cluster.yaml
+2
-7
helm/ott/templates/pg_migration.yaml
+2
-7
helm/ott/templates/pg_migration.yaml
···
28
key: password
29
- name: DATABASE_URL
30
value: "postgres://$(DATABASE_USER):$(DATABASE_PASSWORD)@postgres-rw.default.svc.cluster.local:5432/app"
31
-
- name: POSTGRES_URL
32
-
value: "postgres://$(DATABASE_USER):$(DATABASE_PASSWORD)@postgres-rw.default.svc.cluster.local:5432/postgres"
33
command:
34
- /bin/sh
35
- -c
36
- |
37
echo "Waiting for database to be ready..."
38
-
for i in {1..30}; do
39
-
if pg_isready -h $DATABASE_URL; then
40
echo "Database is ready!"
41
break
42
fi
43
echo "Attempt $i/30: Database not ready yet, waiting..."
44
sleep 10
45
done
46
-
47
-
echo "Making sure extensions are installed"
48
-
psql "$POSTGRES_URL" -c "CREATE EXTENSION IF NOT EXISTS pg_cron;"
49
50
echo "Setting up migration"
51
./app
···
28
key: password
29
- name: DATABASE_URL
30
value: "postgres://$(DATABASE_USER):$(DATABASE_PASSWORD)@postgres-rw.default.svc.cluster.local:5432/app"
31
command:
32
- /bin/sh
33
- -c
34
- |
35
echo "Waiting for database to be ready..."
36
+
for i in $(seq 1 30); do
37
+
if pg_isready -d $DATABASE_URL; then
38
echo "Database is ready!"
39
break
40
fi
41
echo "Attempt $i/30: Database not ready yet, waiting..."
42
sleep 10
43
done
44
45
echo "Setting up migration"
46
./app
+4
-4
helm/ott/values.yaml
+4
-4
helm/ott/values.yaml