Function postgres_roundtrip

crates/database/src/auction.rs:129–172

()

    #[tokio::test]
    #[ignore]
    async fn postgres_roundtrip() {
        let mut db = PgConnection::connect("postgresql://").await.unwrap();
        let mut db = db.begin().await.unwrap();
        crate::clear_DANGER_(&mut db).await.unwrap();

        let value = JsonValue::Number(1.into());
        let id = get_next_auction_id(&mut db).await.unwrap();
        let value_str = serde_json::to_string(&value).unwrap();
        insert_auction_with_id(&mut db, id, &value_str)
            .await
            .unwrap();
        let (id_, value_) = load_most_recent(&mut db).await.unwrap().unwrap();
        assert_eq!(id, id_);
        assert_eq!(value, value_);

        let value = JsonValue::Number(2.into());
        let id_ = get_next_auction_id(&mut db).await.unwrap();
        assert_eq!(id + 1, id_);
        let value_str = serde_json::to_string(&value).unwrap();
        insert_auction_with_id(&mut db, id_, &value_str)
            .await
            .unwrap();
        let (id, value_) = load_most_recent(&mut db).await.unwrap().unwrap();
        assert_eq!(value, value_);
        assert_eq!(id_, id);

        // let's assume the second auction contains a valid competition data so it's
        // meaningful to save it into `competition_auctions` table as well
        let auction = Auction {
            id: id_,
            block: 1,
            deadline: 2,
            order_uids: vec![ByteArray([1u8; 56]), ByteArray([2u8; 56])],
            price_tokens: vec![ByteArray([1u8; 20])],
            price_values: vec![BigDecimal::from(1)],
            surplus_capturing_jit_order_owners: vec![ByteArray([1u8; 20])],
        };
        save(&mut db, auction.clone()).await.unwrap();
        let auction_ = fetch(&mut db, id_).await.unwrap().unwrap();
        assert_eq!(auction, auction_);

        let order_uids = get_order_uids(&mut db, id_).await.unwrap().unwrap();
        assert_eq!(auction.order_uids, order_uids);
    }
}