Skip to content

fix: Add a default Asteria and don't filter Tokens #142

New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Merged
gonzalezzfelipe merged 2 commits into from
Mar 10, 2026
Merged

fix: Add a default Asteria and don't filter Tokens #142

Changes from all commits
Commits
Show all changes
2 commits
Select commit Hold shift + click to select a range
c67a714
fix: Add a default Asteria and don't filter Tokens
gonzalezzfelipe Mar 10, 2026
8218908
Remove dbg statementes
gonzalezzfelipe Mar 10, 2026
File filter

Filter by extension

Filter by extension
Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
37 changes: 23 additions & 14 deletions backend/src/main.rs
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -305,8 +305,7 @@ impl TryFrom<(TokenInput, AddressUtxoContentInner)> for Token {
let position_y = datum_int(&datum_json, 1)?;
let spacetime_policy = datum_bytes(&datum_json, 2)?;

let unit = format!("{}{}", token.policy_id, token.asset_name);
let raw_amount = asset_amount_for_unit(&utxo.amount, &unit)?;
let raw_amount = asset_amount_for_unit(&utxo.amount, &token.policy_id)?;
let scaled_amount = scale_token_amount(raw_amount, token.decimals)?;

Ok(Token {
Expand Down Expand Up @@ -353,7 +352,7 @@ pub struct Data {
pub asteria: Asteria,
}

#[derive(Clone, SimpleObject)]
#[derive(Clone, SimpleObject, Debug)]
pub struct Asset {
pub policy_id: String,
pub name: String,
Expand Down Expand Up @@ -425,7 +424,7 @@ pub struct AsteriaState {
reward: i64,
}

#[derive(Clone, SimpleObject)]
#[derive(Clone, SimpleObject, Debug)]
pub struct Token {
id: ID,
amount: i32,
Expand All @@ -439,13 +438,13 @@ pub struct Token {
assets: Vec<Asset>,
}

#[derive(Clone, SimpleObject)]
#[derive(Clone, SimpleObject, Debug)]
pub struct Position {
x: i32,
y: i32,
}

#[derive(Clone, SimpleObject)]
#[derive(Clone, SimpleObject, Debug)]
pub struct PolicyId {
id: ID,
}
Expand Down Expand Up @@ -551,6 +550,7 @@ impl QueryRoot {
.map_err(|e| Error::new(e.message))?;

let mut map_objects = Vec::new();
let mut has_asteria = false;

for utxo in fetch_utxos_by_policy(api, &spacetime_address, &spacetime_policy_id).await? {
let ship =
Expand Down Expand Up @@ -595,6 +595,18 @@ impl QueryRoot {
}

map_objects.push(PositionalInterface::Asteria(asteria));
has_asteria = true;
}

if !has_asteria {
map_objects.push(PositionalInterface::Asteria(Asteria {
id: ID::from("fallback-asteria"),
position: Position { x: 0, y: 0 },
total_rewards: 0,
class: "Asteria".to_string(),
datum: "{}".to_string(),
assets: vec![],
}));
}

if let Some(tokens) = tokens {
Expand Down Expand Up @@ -806,15 +818,12 @@ async fn rocket() -> _ {
std::collections::HashMap::from([("dmtr-api-key".to_string(), dmtr_api_key)]);
}

let project_id = std::env::var("BLOCKFROST_PROJECT_ID")
.unwrap_or("asteria-backend".to_string());
let project_id =
std::env::var("BLOCKFROST_PROJECT_ID").unwrap_or("asteria-backend".to_string());

let client = BlockfrostAPI::new_with_client(
&project_id,
settings,
Client::builder().use_rustls_tls(),
)
.expect("failed to create Blockfrost client");
let client =
BlockfrostAPI::new_with_client(&project_id, settings, Client::builder().use_rustls_tls())
.expect("failed to create Blockfrost client");

let schema = Schema::build(QueryRoot, EmptyMutation, EmptySubscription)
.register_output_type::<PositionalInterface>()
Expand Down
Loading