[BUG] Durable Objects alarm not work

[und3fined]

Is there an existing issue for this?

• I have searched the existing issues

What version of workers-rs are you using?

0.5.0

What version of wrangler are you using?

3.107.3

Describe the bug

I try implement alert for Durable Object but not work

Code:

async fn fetch(&mut self, req: Request) -> Result<Response> {
        let env = self.env.clone();
        let router = Router::with_data(self);

        router
            .post_async("/alarm/:obj_id", |mut req, ctx| async move {
                let state = ctx.data.state.borrow();
                let mut storage = state.storage();
                let data = req.json::<model::Alarm>().await?;

                let mut resp_msg = "Alarm existed!".to_string();
                let prev_alarm = storage.get_alarm().await.unwrap();

                if prev_alarm.is_none() {
                    let dt = DateTime::from_timestamp(data.alert_time, 0).unwrap();
                    let scheduled_time = ScheduledTime::from(dt.timestamp_millis());

                    let mut opts = SetAlarmOptions::default();
                    opts.allow_unconfirmed = Some(true);

                    state.wait_until(async move {
                        match storage.set_alarm_with_options(scheduled_time, opts).await {
                            Ok(_) => console_log!("set_alarm_with_options: OK"),
                            Err(e) => console_log!("set_alarm_with_options: {:?}", e),
                        };
                    });

                    let scheduled_str = dt.format("%d/%m/%Y %H:%M:%S%.3f");
                    resp_msg = format!("Alarm set to {}", scheduled_str);
                } else {
                    // delete alarm if existed use for testing
                    storage.delete_alarm().await.unwrap();
                    storage.delete_all().await.unwrap();
                }

                console_debug!("[DEBUG] {}", resp_msg);

                Response::from_json(&model::DurablerResponse::new(200, resp_msg.as_str()))
            })
            .run(req, env)
            .await
    }

    async fn alarm(&mut self) -> Result<Response> {
        console_log!(">>>>>>>>>>>>>>>>>>>> Alarm triggered");
        let storage = self.state.storage();

        let vals = storage.list().await.unwrap();

        console_debug!("Vals: {:?}", vals);

        Response::from_json(&model::DurablerResponse::new(200, "Alarm triggered"))
    }

And log

Full source code: https://github.com/und3fined/worker-rs-alarm/tree/main

Steps To Reproduce

1. Use rust 1.85+
2. Run local development via pnpm or npm with script name wrangler:dev
3. Open scheduled test url: http://localhost:8877/__scheduled?cron=*+*+*+*+*
4. Wait looonngg time and no any log like >>>>>>>>>>>>>>>>>>>> Alarm triggered

[und3fined]

has bug in my code

Need replace ScheduledTime::from(dt.timestamp_millis()); to ScheduledTime::from(dt);

For any contribue / owner please add document for offset in this code. It's a milliseconds not timestamp or Duration

Code:

workers-rs/worker/src/durable.rs

Line 703 in 38af58a

fn from(offset: i64) -> Self {

[und3fined]

I has a pull request for update problem #708