TugasBesar2_2017/WebService/src/main/webapp/WEB-INF/web.xml

+<?xml version="1.0" encoding="UTF-8"?>
+<web-app
+        xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
+        xmlns="http://java.sun.com/xml/ns/j2ee"
+        xsi:schemaLocation="http://java.sun.com/xml/ns/j2ee http://xmlns.jcp.org/xml/ns/javaee/web-app_4_0.xsd"
+        version="4.0">
+
+    <listener>
+        <listener-class>
+            com.sun.xml.ws.transport.http.servlet.WSServletContextListener
+        </listener-class>
+    </listener>
+
+    <servlet>
+        <servlet-name>web-jaxws</servlet-name>
+        <servlet-class>com.sun.xml.ws.transport.http.servlet.WSServlet</servlet-class>
+    </servlet>
+    <servlet-mapping>
+        <servlet-name>web-jaxws</servlet-name>
+        <url-pattern>/</url-pattern>
+    </servlet-mapping>
+</web-app>

TugasBesar2_2017/build.gradle

+plugins {
+    id 'org.akhikhl.gretty' version '2.0.0'
+}
+
+dependencies {
+    // https://mvnrepository.com/artifact/com.sun.xml.ws/jaxws-ri
+    gretty 'com.sun.xml.ws:jaxws-ri:2.3.0'
+    // https://mvnrepository.com/artifact/mysql/mysql-connector-java
+    gretty 'mysql:mysql-connector-java:5.1.44'
+}
+
+allprojects {
+    repositories {
+        jcenter()
+
+        maven {
+            url 'http://download.eclipse.org/rt/eclipselink/maven.repo'
+        }
+    }
+}
+
+task clean(type: Delete) {
+    delete rootProject.buildDir
+}

TugasBesar2_2017/gradle/wrapper/gradle-wrapper.properties

+#Tue Nov 07 15:12:14 ICT 2017
+distributionBase=GRADLE_USER_HOME
+distributionPath=wrapper/dists
+zipStoreBase=GRADLE_USER_HOME
+zipStorePath=wrapper/dists
+distributionUrl=https\://services.gradle.org/distributions/gradle-4.3-all.zip

TugasBesar2_2017/gradlew

+#!/usr/bin/env sh
+
+##############################################################################
+##
+##  Gradle start up script for UN*X
+##
+##############################################################################
+
+# Attempt to set APP_HOME
+# Resolve links: $0 may be a link
+PRG="$0"
+# Need this for relative symlinks.
+while [ -h "$PRG" ] ; do
+    ls=`ls -ld "$PRG"`
+    link=`expr "$ls" : '.*-> \(.*\)$'`
+    if expr "$link" : '/.*' > /dev/null; then
+        PRG="$link"
+    else
+        PRG=`dirname "$PRG"`"/$link"
+    fi
+done
+SAVED="`pwd`"
+cd "`dirname \"$PRG\"`/" >/dev/null
+APP_HOME="`pwd -P`"
+cd "$SAVED" >/dev/null
+
+APP_NAME="Gradle"
+APP_BASE_NAME=`basename "$0"`
+
+# Add default JVM options here. You can also use JAVA_OPTS and GRADLE_OPTS to pass JVM options to this script.
+DEFAULT_JVM_OPTS=""
+
+# Use the maximum available, or set MAX_FD != -1 to use that value.
+MAX_FD="maximum"
+
+warn () {
+    echo "$*"
+}
+
+die () {
+    echo
+    echo "$*"
+    echo
+    exit 1
+}
+
+# OS specific support (must be 'true' or 'false').
+cygwin=false
+msys=false
+darwin=false
+nonstop=false
+case "`uname`" in
+  CYGWIN* )
+    cygwin=true
+    ;;
+  Darwin* )
+    darwin=true
+    ;;
+  MINGW* )
+    msys=true
+    ;;
+  NONSTOP* )
+    nonstop=true
+    ;;
+esac
+
+CLASSPATH=$APP_HOME/gradle/wrapper/gradle-wrapper.jar
+
+# Determine the Java command to use to start the JVM.
+if [ -n "$JAVA_HOME" ] ; then
+    if [ -x "$JAVA_HOME/jre/sh/java" ] ; then
+        # IBM's JDK on AIX uses strange locations for the executables
+        JAVACMD="$JAVA_HOME/jre/sh/java"
+    else
+        JAVACMD="$JAVA_HOME/bin/java"
+    fi
+    if [ ! -x "$JAVACMD" ] ; then
+        die "ERROR: JAVA_HOME is set to an invalid directory: $JAVA_HOME
+
+Please set the JAVA_HOME variable in your environment to match the
+location of your Java installation."
+    fi
+else
+    JAVACMD="java"
+    which java >/dev/null 2>&1 || die "ERROR: JAVA_HOME is not set and no 'java' command could be found in your PATH.
+
+Please set the JAVA_HOME variable in your environment to match the
+location of your Java installation."
+fi
+
+# Increase the maximum file descriptors if we can.
+if [ "$cygwin" = "false" -a "$darwin" = "false" -a "$nonstop" = "false" ] ; then
+    MAX_FD_LIMIT=`ulimit -H -n`
+    if [ $? -eq 0 ] ; then
+        if [ "$MAX_FD" = "maximum" -o "$MAX_FD" = "max" ] ; then
+            MAX_FD="$MAX_FD_LIMIT"
+        fi
+        ulimit -n $MAX_FD
+        if [ $? -ne 0 ] ; then
+            warn "Could not set maximum file descriptor limit: $MAX_FD"
+        fi
+    else
+        warn "Could not query maximum file descriptor limit: $MAX_FD_LIMIT"
+    fi
+fi
+
+# For Darwin, add options to specify how the application appears in the dock
+if $darwin; then
+    GRADLE_OPTS="$GRADLE_OPTS \"-Xdock:name=$APP_NAME\" \"-Xdock:icon=$APP_HOME/media/gradle.icns\""
+fi
+
+# For Cygwin, switch paths to Windows format before running java
+if $cygwin ; then
+    APP_HOME=`cygpath --path --mixed "$APP_HOME"`
+    CLASSPATH=`cygpath --path --mixed "$CLASSPATH"`
+    JAVACMD=`cygpath --unix "$JAVACMD"`
+
+    # We build the pattern for arguments to be converted via cygpath
+    ROOTDIRSRAW=`find -L / -maxdepth 1 -mindepth 1 -type d 2>/dev/null`
+    SEP=""
+    for dir in $ROOTDIRSRAW ; do
+        ROOTDIRS="$ROOTDIRS$SEP$dir"
+        SEP="|"
+    done
+    OURCYGPATTERN="(^($ROOTDIRS))"
+    # Add a user-defined pattern to the cygpath arguments
+    if [ "$GRADLE_CYGPATTERN" != "" ] ; then
+        OURCYGPATTERN="$OURCYGPATTERN|($GRADLE_CYGPATTERN)"
+    fi
+    # Now convert the arguments - kludge to limit ourselves to /bin/sh
+    i=0
+    for arg in "$@" ; do
+        CHECK=`echo "$arg"|egrep -c "$OURCYGPATTERN" -`
+        CHECK2=`echo "$arg"|egrep -c "^-"`                                 ### Determine if an option
+
+        if [ $CHECK -ne 0 ] && [ $CHECK2 -eq 0 ] ; then                    ### Added a condition
+            eval `echo args$i`=`cygpath --path --ignore --mixed "$arg"`
+        else
+            eval `echo args$i`="\"$arg\""
+        fi
+        i=$((i+1))
+    done
+    case $i in
+        (0) set -- ;;
+        (1) set -- "$args0" ;;
+        (2) set -- "$args0" "$args1" ;;
+        (3) set -- "$args0" "$args1" "$args2" ;;
+        (4) set -- "$args0" "$args1" "$args2" "$args3" ;;
+        (5) set -- "$args0" "$args1" "$args2" "$args3" "$args4" ;;
+        (6) set -- "$args0" "$args1" "$args2" "$args3" "$args4" "$args5" ;;
+        (7) set -- "$args0" "$args1" "$args2" "$args3" "$args4" "$args5" "$args6" ;;
+        (8) set -- "$args0" "$args1" "$args2" "$args3" "$args4" "$args5" "$args6" "$args7" ;;
+        (9) set -- "$args0" "$args1" "$args2" "$args3" "$args4" "$args5" "$args6" "$args7" "$args8" ;;
+    esac
+fi
+
+# Escape application args
+save () {
+    for i do printf %s\\n "$i" | sed "s/'/'\\\\''/g;1s/^/'/;\$s/\$/' \\\\/" ; done
+    echo " "
+}
+APP_ARGS=$(save "$@")
+
+# Collect all arguments for the java command, following the shell quoting and substitution rules
+eval set -- $DEFAULT_JVM_OPTS $JAVA_OPTS $GRADLE_OPTS "\"-Dorg.gradle.appname=$APP_BASE_NAME\"" -classpath "\"$CLASSPATH\"" org.gradle.wrapper.GradleWrapperMain "$APP_ARGS"
+
+# by default we should be in the correct project dir, but when run from Finder on Mac, the cwd is wrong
+if [ "$(uname)" = "Darwin" ] && [ "$HOME" = "$PWD" ]; then
+  cd "$(dirname "$0")"
+fi
+
+exec "$JAVACMD" "$@"

TugasBesar2_2017/gradlew.bat

+@if "%DEBUG%" == "" @echo off
+@rem ##########################################################################
+@rem
+@rem  Gradle startup script for Windows
+@rem
+@rem ##########################################################################
+
+@rem Set local scope for the variables with windows NT shell
+if "%OS%"=="Windows_NT" setlocal
+
+set DIRNAME=%~dp0
+if "%DIRNAME%" == "" set DIRNAME=.
+set APP_BASE_NAME=%~n0
+set APP_HOME=%DIRNAME%
+
+@rem Add default JVM options here. You can also use JAVA_OPTS and GRADLE_OPTS to pass JVM options to this script.
+set DEFAULT_JVM_OPTS=
+
+@rem Find java.exe
+if defined JAVA_HOME goto findJavaFromJavaHome
+
+set JAVA_EXE=java.exe
+%JAVA_EXE% -version >NUL 2>&1
+if "%ERRORLEVEL%" == "0" goto init
+
+echo.
+echo ERROR: JAVA_HOME is not set and no 'java' command could be found in your PATH.
+echo.
+echo Please set the JAVA_HOME variable in your environment to match the
+echo location of your Java installation.
+
+goto fail
+
+:findJavaFromJavaHome
+set JAVA_HOME=%JAVA_HOME:"=%
+set JAVA_EXE=%JAVA_HOME%/bin/java.exe
+
+if exist "%JAVA_EXE%" goto init
+
+echo.
+echo ERROR: JAVA_HOME is set to an invalid directory: %JAVA_HOME%
+echo.
+echo Please set the JAVA_HOME variable in your environment to match the
+echo location of your Java installation.
+
+goto fail
+
+:init
+@rem Get command-line arguments, handling Windows variants
+
+if not "%OS%" == "Windows_NT" goto win9xME_args
+
+:win9xME_args
+@rem Slurp the command line arguments.
+set CMD_LINE_ARGS=
+set _SKIP=2
+
+:win9xME_args_slurp
+if "x%~1" == "x" goto execute
+
+set CMD_LINE_ARGS=%*
+
+:execute
+@rem Setup the command line
+
+set CLASSPATH=%APP_HOME%\gradle\wrapper\gradle-wrapper.jar
+
+@rem Execute Gradle
+"%JAVA_EXE%" %DEFAULT_JVM_OPTS% %JAVA_OPTS% %GRADLE_OPTS% "-Dorg.gradle.appname=%APP_BASE_NAME%" -classpath "%CLASSPATH%" org.gradle.wrapper.GradleWrapperMain %CMD_LINE_ARGS%
+
+:end
+@rem End local scope for the variables with windows NT shell
+if "%ERRORLEVEL%"=="0" goto mainEnd
+
+:fail
+rem Set variable GRADLE_EXIT_CONSOLE if you need the _script_ return code instead of
+rem the _cmd.exe /c_ return code!
+if  not "" == "%GRADLE_EXIT_CONSOLE%" exit 1
+exit /b 1
+
+:mainEnd
+if "%OS%"=="Windows_NT" endlocal
+
+:omega

TugasBesar2_2017/misc/wbd_idservice.sql

+-- phpMyAdmin SQL Dump
+-- version 4.7.0
+-- https://www.phpmyadmin.net/
+--
+-- Host: localhost
+-- Generation Time: Nov 16, 2017 at 03:40 AM
+-- Server version: 10.1.25-MariaDB
+-- PHP Version: 7.1.7
+
+SET SQL_MODE = "NO_AUTO_VALUE_ON_ZERO";
+SET AUTOCOMMIT = 0;
+START TRANSACTION;
+SET time_zone = "+00:00";
+
+
+/*!40101 SET @OLD_CHARACTER_SET_CLIENT=@@CHARACTER_SET_CLIENT */;
+/*!40101 SET @OLD_CHARACTER_SET_RESULTS=@@CHARACTER_SET_RESULTS */;
+/*!40101 SET @OLD_COLLATION_CONNECTION=@@COLLATION_CONNECTION */;
+/*!40101 SET NAMES utf8mb4 */;
+
+--
+-- Database: `wbd_idservice`
+--
+
+-- --------------------------------------------------------
+
+--
+-- Table structure for table `users`
+--
+
+CREATE TABLE `users` (
+  `id` int(11) UNSIGNED NOT NULL,
+  `name` varchar(50) NOT NULL DEFAULT '',
+  `email` varchar(50) NOT NULL DEFAULT '',
+  `username` varchar(20) NOT NULL DEFAULT '',
+  `password` varchar(255) NOT NULL DEFAULT '',
+  `phone_number` varchar(12) NOT NULL DEFAULT '',
+  `last_token` varchar(255) DEFAULT NULL,
+  `token_expire` timestamp NULL DEFAULT NULL
+) ENGINE=InnoDB DEFAULT CHARSET=utf8;
+
+--
+-- Dumping data for table `users`
+--
+
+INSERT INTO `users` (`id`, `name`, `email`, `username`, `password`, `phone_number`, `last_token`, `token_expire`) VALUES
+(1, 'Kenneth', 'kanisiuskenneth@gmail.com', 'kenneth', 'kenneth', '081320067157', 'mNlDVF4Y0Vv5OtnciEipm18+FjWyUnrC9D8QrQ03y+0DNyHZI5mFX8pfK1HYMNFGmlu4yRD7ilmSWxqnT8r6l7xELoPRxL0TUEBB8+0sjQtp6Reow1EmznfRRA56CT/W', '2017-11-22 17:15:07'),
+(2, 'JohnDoe', 'johndoe@gmail.com', 'john', 'john', '081320067156', 'QNBCPrrHYR2FQFh3O9d0vGVoPNOAow7G4FUes5lYtqQGfI9xL5lY6RPdVuRCMbMfOGm+bIOkmK1Xuu6iEm+xxkOCsEljkyKDOxC9v44OpUS7E4jFZpRLSduFCMYBl/EI', NULL),
+(19, 'Irene Edria', 'ireneedriadr@gmail.com', 'ireneedria', '12345', '087878522470', NULL, NULL),
+(20, 'Edria', 'edria@gmail.com', 'edriairene', '12345', '087878522471', NULL, NULL),
+(21, 'Kenneth', 'kanisius@gmail.com', 'kanisius', '12345', '087878522472', NULL, NULL),
+(22, 'Wenny', 'wennyyustalim@hotmail.com', 'wenny', '12345', '087878522477', NULL, NULL),
+(23, 'Shiro', 'shiro@gmail.com', 'shiro', '12345', '087878522473', NULL, NULL),
+(24, 'Irene Edria', 'micin@gmail.com', 'micin', '12345', '081320067157', NULL, NULL),
+(25, 'Ojek Pribadi', 'ojek@gmail.com', 'ojek', '12345', '098678556789', NULL, NULL),
+(26, 'Ojek', 'ojekojek@gmail.com', 'ojekojek', '12345', '087347805034', NULL, NULL),
+(27, 'pengemudi', 'pribadi@gmail.com', 'ojekpribadi', '12345', '098638494045', NULL, NULL),
+(28, 'asdf', 'asdf', 'asdf', 'asdf', 'asdf', NULL, NULL),
+(29, '123', 'asd', 'asd', 'asd', 'asd', NULL, NULL);
+
+--
+-- Indexes for dumped tables
+--
+
+--
+-- Indexes for table `users`
+--
+ALTER TABLE `users`
+  ADD PRIMARY KEY (`id`),
+  ADD UNIQUE KEY `username` (`username`),
+  ADD UNIQUE KEY `token` (`last_token`);
+
+--
+-- AUTO_INCREMENT for dumped tables
+--
+
+--
+-- AUTO_INCREMENT for table `users`
+--
+ALTER TABLE `users`
+  MODIFY `id` int(11) UNSIGNED NOT NULL AUTO_INCREMENT, AUTO_INCREMENT=30;COMMIT;
+
+/*!40101 SET CHARACTER_SET_CLIENT=@OLD_CHARACTER_SET_CLIENT */;
+/*!40101 SET CHARACTER_SET_RESULTS=@OLD_CHARACTER_SET_RESULTS */;
+/*!40101 SET COLLATION_CONNECTION=@OLD_COLLATION_CONNECTION */;

TugasBesar2_2017/settings.gradle

+rootProject.name = 'TugasBesar2_2017'
+
+include ':SharedLibrary'
+include ':WebApp', ':IdentityService', ':WebService'

app/api/chat.js

+/*
+ * Tugas Besar 3 WBD - AMEN
+ */
+
+'use strict'
+
+const express = require('express')
+
+const cloud = require('../service/cloud')
+const relay = require('../service/relay')
+
+let app = express.Router()
+
+// Administration.
+
+app.post('/init', function (req, res) {
+  let id = req.params.id
+  let token = req.body.token
+
+  cloud.register(id, token)
+
+  res.json({})
+})
+
+app.delete('/', function (req, res) {
+  let id = req.params.id
+
+  cloud.unregister(id)
+  relay.disassociate(id)
+
+  res.json({})
+})
+
+// Messaging.
+
+app.post('/', async function (req, res, next) {
+  let id = req.params.id
+  let message = req.body.message
+
+  try {
+    await relay.sendAsync(id, message)
+
+    res.json({})
+  } catch (e) {
+    next(e)
+  }
+})
+
+module.exports = app

app/api/driver.js

+/*
+ * Tugas Besar 3 WBD - AMEN
+ */
+
+'use strict'
+
+const express = require('express')
+
+const chat = require('./chat')
+const hub = require('../service/hub')
+const relay = require('../service/relay')
+
+let app = express.Router()
+
+// Mount chat controller.
+app.use('/chat', chat)
+
+// Administrations.
+
+app.post('/wait', async function (req, res, next) {
+  let id = req.params.id
+
+  try {
+    let userId = await hub.waitAsync(id, function (reject) {
+      req.connection.on('close', () => reject(new Error('Aborted')))
+    })
+
+    res.json({
+      'user_id': userId
+    })
+  } catch (e) {
+    next(e)
+  }
+})
+
+app.post('/pick', function (req, res) {
+  let id = req.params.id
+  let userId = req.body.user_id
+
+  // Pick driver by user.
+  hub.pick(id, userId)
+
+  // Associate user with driver.
+  relay.associate(userId, id)
+
+  res.json({})
+})
+
+// Queries.
+
+app.get('/', function (req, res) {
+  let id = req.params.id
+
+  // Check if driver exists.
+  hub.check(id)
+
+  res.json({})
+})
+
+module.exports = app

app/api/index.js

+/*
+ * Tugas Besar 3 WBD - AMEN
+ */
+
+'use strict'
+
+const cors = require('cors')
+const express = require('express')
+const bodyParser = require('body-parser')
+
+const driver = require('./driver')
+
+let app = express.Router()
+
+app.use(cors())
+app.use(bodyParser.json())
+
+app.use('/driver/:id', driver)
+
+app.use(function (err, req, res, next) {
+  res.status(500).json({
+    error: err.message
+  })
+})
+
+module.exports = app

app/index.js

+/*
+ * Tugas Besar 3 WBD - AMEN
+ */
+
+'use strict'
+
+// Load config. file early.
+require('dotenv').config({ path: 'data/env.conf' })
+
+const express = require('express')
+const http = require('http')
+const morgan = require('morgan')
+
+const api = require('./api')
+
+let app = express()
+
+app.use(morgan('dev'))
+app.use('/', api)
+
+// Begin serving.
+
+let httpServer = http.createServer(app)
+let port = process.env.CHAT_PORT || 8081
+
+httpServer.listen(port, function (err) {
+  if (err) {
+    console.log(err)
+  } else {
+    console.log('Server is listening on ' + port)
+  }
+})

app/service/cloud.js

+/*
+ * Tugas Besar 3 WBD - AMEN
+ */
+
+'use strict'
+
+const admin = require('firebase-admin')
+
+// Initialize Firebase.
+let serviceAccount = require(`../../${process.env.FIREBASE_CERT}`)
+admin.initializeApp({ credential: admin.credential.cert(serviceAccount) })
+
+let messaging = admin.messaging()
+
+let db = {}
+
+module.exports = {
+  register (id, token) {
+    db[id] = token
+  },
+
+  unregister (id) {
+    delete db[id]
+  },
+
+  async sendAsync (id, message) {
+    await messaging.sendToDevice(db[id], {
+      notification: {
+        title: 'PR-OJEK',
+        body: "You've got a message from driver."
+      },
+      data: {
+        message: message
+      }
+    })
+  }
+}

app/service/hub.js

+/*
+ * Tugas Besar 3 WBD - AMEN
+ */
+
+'use strict'
+
+let drivers = {}
+
+module.exports = {
+  async waitAsync (id, rejectFunc) {
+    let promise = new Promise((resolve, reject) => {
+      drivers[id] = {
+        resolve: resolve,
+        reject: reject
+      }
+
+      // Pass reject function.
+      if (rejectFunc) {
+        rejectFunc(reject)
+      }
+    })
+
+    try {
+      return await promise
+    } finally {
+      delete drivers[id]
+    }
+  },
+
+  check (id) {
+    let handle = drivers[id]
+
+    if (!handle) {
+      throw new Error(`Driver ID ${id} is not connected`)
+    }
+  },
+
+  pick (id, userId) {
+    let handle = drivers[id]
+
+    if (!handle) {
+      throw new Error(`Driver ID ${id} is not connected`)
+    }
+
+    handle.resolve(userId)
+  },
+
+  reject (id, reason) {
+    let handle = drivers[id]
+
+    if (!handle) {
+      throw new Error(`Driver ID ${id} is not connected`)
+    }
+
+    handle.reject(reason)
+  }
+}

app/service/relay.js

+/*
+ * Tugas Besar 3 WBD - AMEN
+ */
+
+'use strict'
+
+const cloud = require('./cloud')
+
+let db = {}
+
+module.exports = {
+  associate (id, driverId) {
+    db[driverId] = id
+    db[id] = driverId
+  },
+
+  disassociate (id) {
+    let pairId = db[id]
+
+    delete db[id]
+    delete db[pairId]
+  },
+
+  async sendAsync (id, message) {
+    await cloud.sendAsync(db[id], message)
+  }
+}

data/.gitignore

+/env.conf
+/firebase.json
+

data/env.conf.example

+CHAT_PORT=8081
+FIREBASE_CERT=data/firebase.json