skyfall/arcade-monitor
1
0
Fork 0
mirror of https://github.com/SkyfallWasTaken/arcade-monitor.git synced 2024-11-25 10:23:41 +00:00
Code Issues Projects Releases Packages Wiki Activity Actions

Start printing out items

Browse source
This commit is contained in:
SkyfallWasTaken 2024-06-29 13:09:42 +01:00
parent ab4ebcf521
commit 0db502e835
1 changed files with 12 additions and 18 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

30
src/lib.rs
View file

@ -10,9 +10,7 @@ pub async fn main(req: Request, env: Env, _ctx: worker::Context) -> Result<Respo
router
.on_async("/", |_req, ctx| async move {
let body = "Hello, World!";
run_scrape(ctx.env).await?;
let body = run_scrape(ctx.env).await?;
Response::ok(body)
})
@ -22,11 +20,8 @@ pub async fn main(req: Request, env: Env, _ctx: worker::Context) -> Result<Respo
#[derive(Serialize, Deserialize)]
struct ShopItem {
#[serde(rename = "Name")]
name: String,
#[serde(rename = "Small Name")]
small_name: Option<String>,
#[serde(rename = "Full Name")]
full_name: String,
#[serde(rename = "Description")]
description: Option<String>,
@ -38,7 +33,7 @@ struct ShopItem {
price: i32,
}
async fn run_scrape(env: Env) -> Result<()> {
async fn run_scrape(env: Env) -> Result<String> {
let shop_url = Url::parse(&env.var("ARCADE_SHOP_URL")?.to_string())?;
let mut response = Fetch::Url(shop_url).send().await?;
@ -54,16 +49,15 @@ async fn run_scrape(env: Env) -> Result<()> {
.clone(),
)?;
let mut result = Vec::new();
for item in available_items {
let item_name = item.small_name.unwrap_or(item.name.clone());
let item_description = item
.description
.unwrap_or(item.fulfillment_description.unwrap_or("".to_string()));
let item_price = item.price;
let message = format!("{}: {} - ${}", item_name, item_description, item_price);
console_debug!("{message}");
result.push(format!(
"`{full_name}` - {price} {}",
if item.price == 1 { "ticket" } else { "tickets" },
full_name = item.full_name.trim(),
price = item.price,
));
}
Ok(())
Ok(result.join("\n"))
}