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('/:id/token', function (req, res) {
+  let id = req.params.id
+  let token = req.body.token
+
+  cloud.register(id, token)
+
+  res.json({ status: 'ok' })
+})
+
+app.delete('/:id', function (req, res) {
+  let id = req.params.id
+
+  cloud.unregister(id)
+  relay.disassociate(id)
+
+  res.json({ status: 'ok' })
+})
+
+// Messaging.
+
+app.post('/:id/message', async function (req, res) {
+  let id = req.params.id
+  let message = req.body.message
+
+  try {
+    await relay.sendAsync(id, message)
+
+    res.json({ status: 'ok' })
+  } catch (e) {
+    console.log(e)
+
+    res.json({
+      status: 'error',
+      message: e.message
+    })
+  }
+})
+
+module.exports = app

app/api/driver.js

+/*
+ * Tugas Besar 3 WBD - AMEN
+ */
+
+'use strict'
+
+const express = require('express')
+
+const hub = require('../service/hub')
+const relay = require('../service/relay')
+
+let app = express.Router()
+
+app.get('/find', function (req, res) {
+  let location = req.query.location
+
+  res.json({
+    'driver_ids': hub.filter(location)
+  })
+})
+
+app.post('/', async function (req, res) {
+  let id = req.body.driver_id
+  let locations = req.body.locations
+
+  try {
+    let userId = await hub.waitAsync(id, locations, function (reject) {
+      req.connection.on('close', () => reject(new Error('Aborted')))
+    })
+
+    res.json({
+      'user_id': userId
+    })
+  } catch (e) {
+    console.log(e)
+  }
+})
+
+app.post('/pick', function (req, res) {
+  let driverId = req.body.driver_id
+  let userId = req.body.user_id
+
+  try {
+    // Pick driver by user.
+    hub.pick(driverId, userId)
+
+    // Associate user with driver.
+    relay.associate(userId, driverId)
+
+    res.json({ 'status': 'ok' })
+  } catch (e) {
+    res.status(500).json({ 'status': 'error' })
+  }
+})
+
+module.exports = app

app/api/index.js

+/*
+ * Tugas Besar 3 WBD - AMEN
+ */
+
+'use strict'
+
+const express = require('express')
+const bodyParser = require('body-parser')
+
+const chat = require('./chat')
+const driver = require('./driver')
+
+let app = express.Router()
+
+app.use(bodyParser.json())
+
+app.use('/chat', chat)
+app.use('/driver', driver)
+
+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 api = require('./api')
+
+let app = express()
+
+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: {
+        body: message
+      }
+    })
+  }
+}

app/service/hub.js

+/*
+ * Tugas Besar 3 WBD - AMEN
+ */
+
+'use strict'
+
+// Utilities.
+
+let index = function (id, locations) {
+  for (let location of locations) {
+    let ids = this.locations[location]
+
+    if (!ids) {
+      ids = new Set()
+      this.locations[location] = ids
+    }
+
+    ids.add(id)
+  }
+}
+
+let unindex = function (id, locations) {
+  for (let location of locations) {
+    let ids = this.locations[location]
+
+    if (ids) {
+      ids.delete(id)
+    }
+  }
+}
+
+// Main routine.
+
+class Hub {
+  constructor () {
+    this.drivers = {}
+    this.locations = {}
+
+    let indexLambda = index.bind(this)
+    let unindexLambda = unindex.bind(this)
+
+    this.waitAsync = async (id, locations, rejectFunc) => {
+      let promise = new Promise((resolve, reject) => {
+        this.drivers[id] = {
+          resolve: resolve,
+          reject: reject
+        }
+
+        // Pass reject function.
+        if (rejectFunc) {
+          rejectFunc(reject)
+        }
+
+        // Index locations.
+        indexLambda(id, locations)
+      })
+
+      try {
+        return await promise
+      } finally {
+        // Remove indexed locations.
+        unindexLambda(id, locations)
+
+        delete this.drivers[id]
+      }
+    }
+  }
+
+  filter (location) {
+    return [...this.locations[location] || []]
+  }
+
+  pick (id, userId) {
+    let handle = this.drivers[id]
+
+    if (handle) {
+      handle.resolve(userId)
+      return true
+    }
+
+    return false
+  }
+
+  reject (id, reason) {
+    let handle = this.drivers[id]
+
+    if (handle) {
+      handle.reject(reason)
+      return true
+    }
+
+    return false
+  }
+}
+
+module.exports = new Hub()

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