tangled
alpha
login
or
join now
smokesignal.events
/
smokesignal
51
fork
atom
The smokesignal.events web application
51
fork
atom
overview
issues
7
pulls
pipelines
bug: language case caused missing template
Nick Gerakines
1 month ago
8cc15145
52ab35d7
+29
-8
2 changed files
expand all
collapse all
unified
split
src
http
handle_admin_tap.rs
handle_share_rsvp_bluesky.rs
+18
-3
src/http/handle_admin_tap.rs
···
134
path: &str,
135
) -> Option<T> {
136
let url = format!("{}{}", base_url, path);
137
-
match client.get(&url).timeout(Duration::from_secs(30)).send().await {
0
0
0
0
0
138
Ok(response) if response.status().is_success() => response.json::<T>().await.ok(),
139
Ok(response) => {
140
tracing::debug!(url = %url, status = %response.status(), "TAP stats request failed");
···
177
let subject = form.subject.trim();
178
179
// Resolve the subject (handle or DID) to a DID
180
-
let document = match admin_ctx.web_context.identity_resolver.resolve(subject).await {
0
0
0
0
0
181
Ok(doc) => doc,
182
Err(err) => {
183
return contextual_error!(
···
302
let subject = form.subject.trim();
303
304
// Resolve the subject (handle or DID) to a DID
305
-
let document = match admin_ctx.web_context.identity_resolver.resolve(subject).await {
0
0
0
0
0
306
Ok(doc) => doc,
307
Err(err) => {
308
return contextual_error!(
···
134
path: &str,
135
) -> Option<T> {
136
let url = format!("{}{}", base_url, path);
137
+
match client
138
+
.get(&url)
139
+
.timeout(Duration::from_secs(30))
140
+
.send()
141
+
.await
142
+
{
143
Ok(response) if response.status().is_success() => response.json::<T>().await.ok(),
144
Ok(response) => {
145
tracing::debug!(url = %url, status = %response.status(), "TAP stats request failed");
···
182
let subject = form.subject.trim();
183
184
// Resolve the subject (handle or DID) to a DID
185
+
let document = match admin_ctx
186
+
.web_context
187
+
.identity_resolver
188
+
.resolve(subject)
189
+
.await
190
+
{
191
Ok(doc) => doc,
192
Err(err) => {
193
return contextual_error!(
···
312
let subject = form.subject.trim();
313
314
// Resolve the subject (handle or DID) to a DID
315
+
let document = match admin_ctx
316
+
.web_context
317
+
.identity_resolver
318
+
.resolve(subject)
319
+
.await
320
+
{
321
Ok(doc) => doc,
322
Err(err) => {
323
return contextual_error!(
+11
-5
src/http/handle_share_rsvp_bluesky.rs
···
21
},
22
storage::event::{event_get, extract_event_details, rsvp_get_by_event_and_did},
23
};
24
-
use atproto_client::com::atproto::repo::{CreateRecordRequest, CreateRecordResponse, create_record};
0
0
25
26
#[derive(Deserialize)]
27
pub(crate) struct ShareRsvpBlueskyRequest {
···
38
let current_handle = auth.require("/rsvp")?;
39
let session = auth.session().ok_or(CommonError::NotAuthorized)?;
40
41
-
let render_template = format!("{}/share_rsvp_bluesky.partial.html", language);
0
0
0
42
43
// Fetch event details
44
let event = event_get(&web_context.pool, &request.event_aturi)
···
48
})?;
49
50
// Verify the user has a "going" RSVP to this event
51
-
let rsvp = rsvp_get_by_event_and_did(&web_context.pool, &request.event_aturi, ¤t_handle.did)
52
-
.await?
53
-
.ok_or(ShareBlueskyError::NoGoingRsvp)?;
0
54
55
if rsvp.status != "going" {
56
return Err(ShareBlueskyError::NoGoingRsvp.into());
···
21
},
22
storage::event::{event_get, extract_event_details, rsvp_get_by_event_and_did},
23
};
24
+
use atproto_client::com::atproto::repo::{
25
+
CreateRecordRequest, CreateRecordResponse, create_record,
26
+
};
27
28
#[derive(Deserialize)]
29
pub(crate) struct ShareRsvpBlueskyRequest {
···
40
let current_handle = auth.require("/rsvp")?;
41
let session = auth.session().ok_or(CommonError::NotAuthorized)?;
42
43
+
let render_template = format!(
44
+
"{}/share_rsvp_bluesky.partial.html",
45
+
language.to_string().to_lowercase()
46
+
);
47
48
// Fetch event details
49
let event = event_get(&web_context.pool, &request.event_aturi)
···
53
})?;
54
55
// Verify the user has a "going" RSVP to this event
56
+
let rsvp =
57
+
rsvp_get_by_event_and_did(&web_context.pool, &request.event_aturi, ¤t_handle.did)
58
+
.await?
59
+
.ok_or(ShareBlueskyError::NoGoingRsvp)?;
60
61
if rsvp.status != "going" {
62
return Err(ShareBlueskyError::NoGoingRsvp.into());