fix JSON parse error; add schedule for notify

Author: glazec

index.js

@@ -6,6 +6,8 @@ const util = require('hexo-util');
 const fs = require('hexo-fs');
 const fetch = require("node-fetch");
 const url = require("url")
+var request = require('request');
+var moment = require('moment');
 
 // triggered after hexo generate.
 // this output the newPost.json into public/.
@@ -27,7 +29,8 @@ hexo.on('generateAfter', async function (post) {
 
 //triggered before hexo deploy.
 //it compare the newPost.json from your site and local to decide whether push the notification.
-hexo.on("deployBefore", async function (post) {
+// DeployAfter event has encode issue
+hexo.on("deployAfter", async function (post) {
     // Get newPost.json from your site.
     var newPostOnlineSite = await fetch(url.resolve(hexo.config.url, "newPost.json"));
     var newPostOnlineSite = await newPostOnlineSite.json();
@@ -46,28 +49,56 @@ hexo.on("deployBefore", async function (post) {
         var payload = {
             title: newPostLocal.title,
             message: newPostLocal.summary,
-            target_url: new URL(newPostLocal.url).pathname
+            target_url: new URL(newPostLocal.url).pathname,
+            // segment: [4205],
+            send_at: moment().add(10, 'minutes').format()
+            // sid: '4557611'
         };
-        console.log(payload)
-        const response = await fetch(
-            "https://app.webpushr.com/api/v1/notification/send/all",
-            {
-                method: "POST",
-                headers: {
-                    webpushrKey: hexo.config.webPushNotification.webpushrKey,
-                    webpushrAuthToken: hexo.config.webPushNotification.webpushrAuthToken,
-                    "Content-Type": "application/json"
-                },
-                body: JSON.stringify(payload)
+        var headers = {
+            webpushrKey: hexo.config.webPushNotification.webpushrKey,
+            webpushrAuthToken: hexo.config.webPushNotification.webpushrAuthToken,
+            "Content-Type": "application/json"
+        };
+        var options = {
+            url: 'https://api.webpushr.com/v1/notification/send/all',
+            method: 'POST',
+            headers: headers,
+            body: JSON.stringify(payload)
+        };
+        function callback(error, response, body) {
+            if (!error && response.statusCode == 200) {
+                hexo.log.info("Successfully send notifications");
+                hexo.log.info(body);
+                
+            }
+            else {
+                hexo.log.error("Fail to send notifications");
+                hexo.log.error(body);
             }
-        );
-        const data = await response.json();
-        if (!response.ok) {
-            // NOT res.status >= 200 && res.status < 300
-            hexo.log.error("Push Notification failed " + JSON.stringify(data));
-        } else {
-            hexo.log.info("Successfully push notification");
         }
+        hexo.log.info(JSON.stringify(payload))
+        request(options, callback);
+
+        // const response = await fetch(
+        //     "https://app.webpushr.com/api/v1/notification/send/segment",
+        //     {
+        //         method: "POST",
+        //         headers: {
+        //             webpushrKey: hexo.config.webPushNotification.webpushrKey,
+        //             webpushrAuthToken: hexo.config.webPushNotification.webpushrAuthToken,
+        //             "Content-Type": "application/json"
+        //         },
+        //         body: JSON.stringify(payload)
+        //     }
+        // );
+        // // const data = await response.json();
+        // console.log(response.status)
+        // if (!response.ok) {
+        //     // NOT res.status >= 200 && res.status < 300
+        //     hexo.log.error("Push Notification failed " + response.status.toString()+' '+response.statusText);
+        // } else {
+        //     hexo.log.info("Successfully push notification");
+        // }
     } else {
         hexo.log.info("No New Post detected.");
     }