Function notification_authorization

tests/integration/src/notification.rs:17–205

()

#[test]
fn notification_authorization() {
    let TestEnv {
        env, canister_ids, ..
    } = setup_new_env();

    // admin makes a failed request which triggers a notification
    let change_canister_operation_input = SystemUpgradeOperationInput {
        target: SystemUpgradeTargetDTO::UpgradeUpgrader,
        module: vec![],
        module_extra_chunks: None,
        arg: None,
        take_backup_snapshot: None,
    };
    let request_status = execute_request_with_extra_ticks(
        &env,
        WALLET_ADMIN_USER,
        canister_ids.station,
        RequestOperationInput::SystemUpgrade(change_canister_operation_input.clone()),
        10,
    )
    .unwrap_err()
    .unwrap();
    match request_status {
        RequestStatusDTO::Failed { .. } => (),
        _ => panic!("Unexpected request status: {request_status:?}"),
    };

    // admin user can list and update notifications
    let list_notifications_input = ListNotificationsInput {
        status: None,
        notification_type: None,
        from_dt: None,
        to_dt: None,
    };
    let res: (ApiResult<ListNotificationsResponse>,) = update_candid_as(
        &env,
        canister_ids.station,
        WALLET_ADMIN_USER,
        "list_notifications",
        (list_notifications_input.clone(),),
    )
    .unwrap();
    let notifications = res.0.unwrap().notifications;
    assert_eq!(notifications.len(), 1);
    let admin_notification = &notifications[0];
    let mark_notifications_read_input = MarkNotificationsReadInput {
        notification_ids: vec![admin_notification.id.clone()],
        read: true,
    };
    let res: (ApiResult<()>,) = update_candid_as(
        &env,
        canister_ids.station,
        WALLET_ADMIN_USER,
        "mark_notifications_read",
        (mark_notifications_read_input.clone(),),
    )
    .unwrap();
    res.0.unwrap();