Update actix_web example

Author: kaz9120

examples/echobot_actix_web.rs

@@ -4,59 +4,49 @@ use dotenv::dotenv;
 use std::env;
 
 use line::bot::LineBot;
-use line::events::messages::MessageType as EventMessageType;
+use line::events::messages::MessageType;
 use line::events::{EventType, Events};
 use line::messages::{SendMessageType, TextMessage};
+use line::support::actix_support::Signature;
+use line::webhook::validate_signature;
 
-use actix_web::web::Bytes;
-use actix_web::{post, App, HttpRequest, HttpResponse, HttpServer, Responder};
+use actix_web::{post, web, App, HttpServer, Responder};
 
 #[post("/callback")]
-async fn callback(req: HttpRequest, bytes: Bytes) -> impl Responder {
-    let body: &str = &String::from_utf8(bytes.to_vec()).unwrap();
-    let signature: &str = req
-        .headers()
-        .get("x-line-signature")
-        .unwrap()
-        .to_str()
-        .unwrap();
-
+async fn callback(
+    signature: Signature,
+    data: web::Json<Events>,
+    bytes: web::Bytes,
+) -> impl Responder {
     // Get channel secret and access token by environment variable
     let channel_secret: &str =
-        &env::var("LINE_CHANNEL_RECRET").expect("Failed getting LINE_CHANNEL_RECRET");
+        &env::var("LINE_CHANNEL_SECRET").expect("Failed getting LINE_CHANNEL_SECRET");
     let access_token: &str =
         &env::var("LINE_CHANNEL_ACCESS_TOKEN").expect("Failed getting LINE_CHANNEL_ACCESS_TOKEN");
 
     // LineBot
     let bot = LineBot::new(channel_secret, access_token);
 
-    // Request body parse
-    let result: Result<Events, &'static str> = bot.parse_event_request(signature, body);
-
-    // Success parsing
-    if let Ok(res) = result {
-        for event in res.events {
-            // MessageEvent only
-            if let EventType::MessageEvent(message_event) = event.r#type {
-                // TextMessageEvent only
-                if let EventMessageType::TextMessage(text_message) = message_event.message.r#type {
-                    // Create TextMessage
-                    let message = SendMessageType::TextMessage(TextMessage {
-                        text: text_message.text,
-                        emojis: None,
-                    });
-                    // Reply message with reply_token
-                    let _res = bot.reply_message(&message_event.reply_token, vec![message]);
-                }
+    let body: &str = &String::from_utf8(bytes.to_vec()).unwrap();
+    validate_signature(&bot.channel_secret, &signature.key, &body);
+
+    for event in &data.events {
+        // MessageEvent only
+        if let EventType::MessageEvent(message_event) = &event.r#type {
+            // TextMessageEvent only
+            if let MessageType::TextMessage(text_message) = &message_event.message.r#type {
+                // Create TextMessage
+                let message = SendMessageType::TextMessage(TextMessage {
+                    text: text_message.text.to_string(),
+                    emojis: None,
+                });
+                // Reply message with reply_token
+                let _res = bot.reply_message(&message_event.reply_token, vec![message]);
             }
         }
-        return HttpResponse::Ok().body("OK");
-    }
-    // Failed parsing
-    else if let Err(msg) = result {
-        return HttpResponse::BadRequest().body(msg);
     }
-    HttpResponse::BadRequest().body("Internal Server Error")
+
+    "OK"
 }
 
 #[actix_rt::main]