Fxa fixes

autoendpoint/Cargo.toml

@@ -17,6 +17,7 @@ a2 = { git = "https://github.com/mozilla-services/a2.git", branch = "autoendpoin
 actix-web = "3.3"
 actix-rt = "1.1"   # 2.0+ requires futures 0.3+
 actix-cors = "0.5"
+actix-http = "3.0"
 again = { version = "0.1.2", default-features = false, features = ["log", "rand"] }
 async-trait = "0.1"
 autopush_common = { path = "../autopush-common" }

autoendpoint/src/db/client.rs

@@ -93,6 +93,7 @@ impl DbClientImpl {
         router_table: String,
         message_table: String,
     ) -> DbResult<Self> {
+        debug!("Tables: {} and {}", router_table, message_table);
         let ddb = if let Ok(endpoint) = env::var("AWS_LOCAL_DYNAMODB") {
             DynamoDbClient::new_with(
                 HttpClient::new().expect("TLS initialization error"),
@@ -205,6 +206,11 @@ impl DbClient for DbClientImpl {
     }
 
     async fn get_user(&self, uaid: Uuid) -> DbResult<Option<DynamoDbUser>> {
+        trace!(
+            "Looking up user: {:?} in {}",
+            uaid.as_simple().to_string(),
+            self.router_table.clone()
+        );
         let input = GetItemInput {
             table_name: self.router_table.clone(),
             consistent_read: Some(true),

autoendpoint/src/extractors/notification.rs

@@ -44,7 +44,10 @@ impl FromRequest for Notification {
             // Read data
             let data = web::Bytes::from_request(&req, &mut payload)
                 .await
-                .map_err(ApiErrorKind::PayloadError)?;
+                .map_err(|e| {
+                    debug!("▶▶ Request read payload error: {:?}", &e);
+                    ApiErrorKind::PayloadError(e)
+                })?;
 
             // Convert data to base64
             let data = if data.is_empty() {

autoendpoint/src/extractors/notification_headers.rs

@@ -299,12 +299,15 @@ mod tests {
     fn valid_topic() {
         let req = TestRequest::post()
             .header("TTL", "10")
-            .header("TOPIC", "test-topic")
+            .header("TOPIC", "a-test-topic-which-is-just-right")
             .to_http_request();
         let result = NotificationHeaders::from_request(&req, false);
 
         assert!(result.is_ok());
-        assert_eq!(result.unwrap().topic, Some("test-topic".to_string()));
+        assert_eq!(
+            result.unwrap().topic,
+            Some("a-test-topic-which-is-just-right".to_string())
+        );
     }
 
     /// Topic names which are too long return an error