Merge pull request #2 from tigi44/feature/update

Feature/update

Author: tigi44

.gitignore

@@ -1,3 +1,7 @@
+# Logs
+logs
+*.log
+
 # Runtime data
 pids
 *.pid
@@ -26,6 +30,7 @@ node_modules
 npm-debug.log
 
 # apns .pem
-apns/keys/cert.pem
-apns/keys/key.pem
-apns/keys/*
+apns/keys/cert/*
+apns/keys/key/*
+!apns/keys/cert/test_cert.pem
+!apns/keys/key/test_key.pem

Class/DataLayer/APNsDataSource.js

@@ -0,0 +1,72 @@
+const apn    = require('apn')
+const Logger = require('../../Modules/Logger')
+
+const sandboxGateway = 'gateway.sandbox.push.apple.com';
+const gateway        = 'gateway.push.apple.com';
+
+class APNsDataSource {
+
+  options = {
+    // token: {
+    //   key: "path/to/APNsAuthKey_XXXXXXXXXX.p8",
+    //   keyId: "key-id",
+    //   teamId: "developer-team-id"
+    // },
+    // proxy: {
+    //   host: "192.168.10.92",
+    //   port: 8080
+    // },
+
+    cert: './apns/keys/cert/cert.pem',
+    key: './apns/keys/ket/key.pem',
+    production: false
+  }
+
+  sendPush(certPemFilePath, keyPemFilePath, isProduction, appId, token, jsonData) {
+    console.log(certPemFilePath)
+    console.log(keyPemFilePath)
+    console.log(isProduction)
+    console.log(appId)
+    console.log(token)
+    console.log(jsonData)
+    if (!certPemFilePath || !keyPemFilePath || !appId || !token || jsonData == null || jsonData.aps == null) {
+      return Promise.reject(new Error('Error : send push parameter'));
+    }
+
+    var options = this.options;
+
+    options.production = isProduction ? true : false;
+    options.cert       = certPemFilePath
+    options.key        = keyPemFilePath
+
+    var apnProvider  = new apn.Provider(options);
+    var notification = new apn.Notification();
+
+    notification.badge    = jsonData.aps.badge;
+    notification.sound    = jsonData.aps.sound;
+    notification.alert    = jsonData.aps.alert;
+    notification.threadId = jsonData.aps["thread-id"];
+    notification.category = jsonData.aps["category"];
+
+    delete jsonData.aps;
+    notification.payload  = jsonData;
+    notification.topic    = appId;
+
+    Logger.debug("=== Start APNs Push ====");
+    Logger.debug("gateway : " + (options.production ? gateway : sandboxGateway));
+    Logger.debug("production : " + options.production);
+    Logger.debug("appId : " + appId);
+    Logger.debug("token : " + token);
+    Logger.debug("notification : " + JSON.stringify(notification));
+
+    return apnProvider.send(notification, token).then( (result) => {
+      if (result.failed.length > 0) {
+        Logger.debug("=== Error Fail to send push : " + JSON.stringify(result));
+        throw new Error(JSON.stringify(result.failed));
+      }
+      Logger.debug("=== End APNs Push ====");
+    });
+  }
+}
+
+module.exports = APNsDataSource;

Class/DataLayer/APNsRepository.js

@@ -0,0 +1,10 @@
+const APNsRepositoryInterface = require('../DomainLayer/RepositoryInterface/APNsRepositoryInterface')
+
+class APNsRepository extends APNsRepositoryInterface {
+
+  sendPush(certPemFilePath, keyPemFilePath, isProduction, appId, token, jsonData) {
+    return this.dataSource.sendPush(certPemFilePath, keyPemFilePath, isProduction, appId, token, jsonData)
+  }
+}
+
+module.exports = APNsRepository;

Class/DataLayer/FileDataSource.js

@@ -0,0 +1,29 @@
+const fs   = require('fs');
+const path = require('path');
+
+class FileDataSource {
+  findPemFile(dirPath) {
+
+    if (!fs.existsSync(dirPath)){
+      fs.mkdirSync(dirPath, { recursive: true })
+    }
+
+    var pemFileName
+    let files = fs.readdirSync(dirPath);
+
+    files.sort(function(a, b) {
+      return fs.statSync(dirPath + b).mtime.getTime() - fs.statSync(dirPath + a).mtime.getTime();
+    });
+
+    for (var file of files) {
+      if (path.extname(file) === '.pem') {
+        pemFileName = file
+        break
+      }
+    }
+
+    return pemFileName
+  }
+}
+
+module.exports = FileDataSource;

Class/DataLayer/FileRepository.js

@@ -0,0 +1,10 @@
+const FileRepositoryInterface = require('../DomainLayer/RepositoryInterface/FileRepositoryInterface')
+
+class FileRepository extends FileRepositoryInterface {
+
+  findPemFile(dirPath) {
+    return Promise.resolve(this.dataSource.findPemFile(dirPath))
+  }
+}
+
+module.exports = FileRepository;

Class/DomainLayer/GetPemFilePathUseCase.js

@@ -0,0 +1,13 @@
+const UseCase = require('./UseCase')
+
+class GetPemFilePathUseCase extends UseCase {
+
+  execute(dirPath) {
+
+    return this.repository.findPemFile(dirPath).then(pemFile => {
+      return dirPath + pemFile
+    })
+  }
+}
+
+module.exports = GetPemFilePathUseCase

Class/DomainLayer/RepositoryInterface/APNsRepositoryInterface.js

@@ -0,0 +1,10 @@
+class APNsRepositoryInterface {
+
+  constructor(dataSource) {
+    this.dataSource = dataSource;
+  }
+
+  sendPush(certPemFilePath, keyPemFilePath, isProduction, appId, token, jsonData) {}
+}
+
+module.exports = APNsRepositoryInterface;

Class/DomainLayer/RepositoryInterface/FileRepositoryInterface.js

@@ -0,0 +1,10 @@
+class FileRepositoryInterface {
+
+  constructor(dataSource) {
+    this.dataSource = dataSource;
+  }
+
+  findPemFile(dirPath) {}
+}
+
+module.exports = FileRepositoryInterface;

Class/DomainLayer/SendPushUseCase.js

@@ -0,0 +1,11 @@
+const UseCase = require('./UseCase')
+
+class SendPushUseCase extends UseCase {
+
+  execute(certPemFilePath, keyPemFilePath, isProduction, appId, token, jsonData) {
+
+    return this.repository.sendPush(certPemFilePath, keyPemFilePath, isProduction, appId, token, jsonData)
+  }
+}
+
+module.exports = SendPushUseCase

Class/DomainLayer/UseCase.js

@@ -0,0 +1,10 @@
+class UseCase {
+
+  constructor(repository) {
+    this.repository = repository;
+  }
+
+  execute() {}
+}
+
+module.exports = UseCase;