Solana Weather Function

solana_weather_function.rs

pub use switchboard_solana::get_ixn_discriminator;
pub use switchboard_solana::prelude::*;
pub use switchboard_utils::protos::http::http_task;
pub use switchboard_utils::reqwest;

#[tokio::main(worker_threads = 12)]
async fn main() {
    println!("Hello, world!");

    let runner = FunctionRunner::from_env(None).unwrap();

    let result = http_task(
        "https://api.weather.gov/gridpoints/MFL/111,50/forecast",
        Some("$.properties.periods.0.temperature"),
    )
    .await
    .unwrap();

    // Here, serialize the result into your ixn params. You may need to add the ixn discriminator
    // to the front of the serialized bytes.
    let mut ixn_data = get_ixn_discriminator("your_ixn_name").to_vec();
    ixn_data.extend(result.as_f64().unwrap().try_to_vec().unwrap());

    let ixn: Instruction = Instruction {
        program_id: Pubkey::default(),
        accounts: vec![AccountMeta::new(Pubkey::default(), false)],
        data: ixn_data,
    };

    runner.emit(vec![ixn]).await.unwrap();
}