Merge pull request #346 from fastly/jake/erl-test

⏫ Bump up the Fastly SDK to latest version and uncomment the test for the Edge Rate Limiting API

lib/Cargo.toml

@@ -29,7 +29,7 @@ bytesize = "^1.1.0"
 cfg-if = "^1.0"
 clap = { workspace = true }
 cranelift-entity = "^0.88.1"
-fastly-shared = "^0.9.3"
+fastly-shared = "^0.9.11"
 flate2 = "^1.0.24"
 futures = { workspace = true }
 http = "^0.2.8"

test-fixtures/Cargo.toml

@@ -9,9 +9,9 @@ publish = false
 
 [dependencies]
 base64 = "0.21.2"
-fastly = "^0.9.7"
-fastly-shared = "^0.9.7"
-fastly-sys = "^0.9.8"
+fastly = "0.9.11"
+fastly-shared = "0.9.11"
+fastly-sys = "0.9.11"
 bytes = "1.0.0"
 http = "0.2.9"
 rustls-pemfile = "1.0.3"

test-fixtures/src/bin/edge-rate-limiting.rs

@@ -1,33 +1,33 @@
 //! A guest program to test that edge-rate-limiting API is implemented.
 
-//use std::time::Duration;
+use std::time::Duration;
 
-//use fastly::erl::{CounterDuration, Penaltybox, RateCounter, RateWindow, ERL};
+use fastly::erl::{CounterDuration, Penaltybox, RateCounter, RateWindow, ERL};
 
 fn main() {
-//    let entry = "entry";
+   let entry = "entry";
 
-//    let rc = RateCounter::open("rc");
-//    let pb = Penaltybox::open("pb");
-//    let erl = ERL::open(rc, pb);
+   let rc = RateCounter::open("rc");
+   let pb = Penaltybox::open("pb");
+   let erl = ERL::open(rc, pb);
 
-//    let not_blocked = erl
-//        .check_rate(entry, 1, RateWindow::TenSecs, 100, Duration::from_secs(300))
-//        .unwrap();
-//    assert_eq!(not_blocked, false);
+   let not_blocked = erl
+       .check_rate(entry, 1, RateWindow::TenSecs, 100, Duration::from_secs(300))
+       .unwrap();
+   assert_eq!(not_blocked, false);
 
-//    let rc2 = RateCounter::open("rc");
-//    let rate_1 = rc2.lookup_rate(entry, RateWindow::OneSec).unwrap();
-//    assert_eq!(rate_1, 0);
+   let rc2 = RateCounter::open("rc");
+   let rate_1 = rc2.lookup_rate(entry, RateWindow::OneSec).unwrap();
+   assert_eq!(rate_1, 0);
 
-//    let count10 = rc2.lookup_count(entry, CounterDuration::TenSec).unwrap();
-//    assert_eq!(count10, 0);
+   let count10 = rc2.lookup_count(entry, CounterDuration::TenSec).unwrap();
+   assert_eq!(count10, 0);
 
-//    assert!(rc2.increment(entry, 600).is_ok());
+   assert!(rc2.increment(entry, 600).is_ok());
 
-//    let pb2 = Penaltybox::open("pb");
-//    let not_in_pb = pb2.has(entry).unwrap();
-//    assert_eq!(not_in_pb, false);
+   let pb2 = Penaltybox::open("pb");
+   let not_in_pb = pb2.has(entry).unwrap();
+   assert_eq!(not_in_pb, false);
 
-//    assert!(pb2.add(entry, Duration::from_secs(300)).is_ok());
+   assert!(pb2.add(entry, Duration::from_secs(300)).is_ok());
 }