Merge pull request #9 from nanato12/feature/lib

[Parent] Add Library

Author: nanato12

Cargo.toml

@@ -9,7 +9,7 @@ edition = "2018"
 [dependencies]
 rocket = "0.4"
 rocket_contrib = { version = "0.4", features = ["json"] }
-surf = "1.0.3"
+reqwest = { version = "0.11.0", features = ["blocking", "json"] }
 serde = { version = "1.0", features = ["derive"] }
 async-std = { version = "1.5.0", features = ["attributes"] }
 serde_json = "1.0"

src/bot.rs

@@ -0,0 +1,48 @@
+use reqwest::blocking::{Client, Response};
+use reqwest::header::{HeaderMap, HeaderValue, AUTHORIZATION, CONTENT_TYPE};
+use reqwest::Error;
+use reqwest::Url;
+use serde_json::Value;
+
+static BASE_URL: &str = "https://api.line.me/v2/bot/";
+
+#[derive(Debug)]
+pub struct HttpClient {
+    client: Client,
+    headers: HeaderMap,
+    endpoint_base: String,
+}
+
+impl HttpClient {
+    pub fn new(channel_token: &str) -> HttpClient {
+        let mut headers = HeaderMap::new();
+        headers.insert(
+            AUTHORIZATION,
+            format!("Bearer {}", channel_token).parse().unwrap(),
+        );
+        headers.insert(CONTENT_TYPE, HeaderValue::from_static("application/json"));
+        HttpClient {
+            client: Client::new(),
+            headers: headers,
+            endpoint_base: String::from(BASE_URL),
+        }
+    }
+
+    pub fn get(&self, endpoint: &str, data: Value) -> Result<Response, Error> {
+        let uri = Url::parse(&format!("{}{}", self.endpoint_base, endpoint)).unwrap();
+        self.client
+            .get(uri)
+            .headers(self.headers.clone())
+            .json(&data)
+            .send()
+    }
+
+    pub fn post(&self, endpoint: &str, data: Value) -> Result<Response, Error> {
+        let uri = Url::parse(&format!("{}{}", self.endpoint_base, endpoint)).unwrap();
+        self.client
+            .post(uri)
+            .headers(self.headers.clone())
+            .json(&data)
+            .send()
+    }
+}

src/client.rs

@@ -0,0 +1,19 @@
+use crate::events::Source;
+
+use serde_derive::Deserialize;
+
+#[derive(Deserialize, Debug)]
+pub struct AccountLinkEvent {
+    #[serde(rename = "replyToken")]
+    pub reply_token: String,
+    pub mode: String,
+    pub timestamp: i64,
+    pub source: Source,
+    pub link: Link,
+}
+
+#[derive(Deserialize, Debug)]
+pub struct Link {
+    pub result: String,
+    pub nonce: String,
+}

src/events/account_link.rs

@@ -0,0 +1,20 @@
+use crate::events::Source;
+
+use serde_derive::Deserialize;
+
+#[derive(Deserialize, Debug)]
+pub struct BeaconEvent {
+    #[serde(rename = "replyToken")]
+    pub reply_token: String,
+    pub mode: String,
+    pub timestamp: i64,
+    pub source: Source,
+    pub beacon: Beacon,
+}
+
+#[derive(Deserialize, Debug)]
+pub struct Beacon {
+    pub hwid: String,
+    pub r#type: String,
+    pub dm: Option<String>,
+}

src/events/beacon.rs

@@ -0,0 +1,12 @@
+use crate::events::Source;
+
+use serde_derive::Deserialize;
+
+#[derive(Deserialize, Debug)]
+pub struct FollowEvent {
+    #[serde(rename = "replyToken")]
+    pub reply_token: Option<String>,
+    pub mode: String,
+    pub timestamp: i64,
+    pub source: Source,
+}

src/events/follow.rs

@@ -0,0 +1,12 @@
+use crate::events::Source;
+
+use serde_derive::Deserialize;
+
+#[derive(Deserialize, Debug)]
+pub struct JoinEvent {
+    #[serde(rename = "replyToken")]
+    pub reply_token: String,
+    pub mode: String,
+    pub timestamp: i64,
+    pub source: Source,
+}

src/events/join.rs

@@ -0,0 +1,10 @@
+use crate::events::Source;
+
+use serde_derive::Deserialize;
+
+#[derive(Deserialize, Debug)]
+pub struct LeaveEvent {
+    pub mode: String,
+    pub timestamp: i64,
+    pub source: Source,
+}

src/events/leave.rs

@@ -0,0 +1,8 @@
+use serde_derive::Deserialize;
+
+#[derive(Deserialize, Debug)]
+pub struct Member {
+    pub r#type: String,
+    #[serde(rename = "userId")]
+    pub user_id: String,
+}

src/events/member.rs

@@ -0,0 +1,19 @@
+use crate::events::Member;
+use crate::events::Source;
+
+use serde_derive::Deserialize;
+
+#[derive(Deserialize, Debug)]
+pub struct MemberJoinEvent {
+    #[serde(rename = "replyToken")]
+    pub reply_token: String,
+    pub mode: String,
+    pub timestamp: i64,
+    pub source: Source,
+    pub joined: Joined,
+}
+
+#[derive(Deserialize, Debug)]
+pub struct Joined {
+    pub members: Vec<Member>,
+}