Added Event to import and export JSON database following the same for…

src/main/scala/model/TodoServer.scala

@@ -14,6 +14,8 @@ class TodoServer() {
     new Database
   }
 
+  var socketToTasks: Map[SocketIOClient, List[Int]] = Map()//maps socket to a list of task ids created by said socket
+
   setNextId()
 
   var usernameToSocket: Map[String, SocketIOClient] = Map()
@@ -29,22 +31,45 @@ class TodoServer() {
   server.addConnectListener(new ConnectionListener(this))
   server.addEventListener("add_task", classOf[String], new AddTaskListener(this))
   server.addEventListener("complete_task", classOf[String], new CompleteTaskListener(this))
+  server.addEventListener("import_task", classOf[String], new importTaskListener(this))
+  server.addEventListener("export_task", classOf[Nothing], new exportTaskListener(this))
 
   server.start()
 
-  def tasksJSON(): String = {
+  def tasksJSON(socket: SocketIOClient): String = {
     val tasks: List[Task] = database.getTasks
-    val tasksJSON: List[JsValue] = tasks.map((entry: Task) => entry.asJsValue())
+    val pTasks: List[Task] = tasks.filter((value: Task) => socketToTasks.getOrElse(socket,List()).contains(value.id.toInt))
+    val tasksJSON: List[JsValue] = pTasks.map((entry: Task) => entry.asJsValue())
     Json.stringify(Json.toJson(tasksJSON))
   }
 
+  /*def tasksJSONALL(): String = {
+    val tasks: List[Task] = database.getTasks
+    val tasksJSON: List[JsValue] = tasks.map((entry: Task) => entry.asJsValue())
+    Json.stringify(Json.toJson(tasksJSON))
+  }*/
+
   def setNextId(): Unit = {
     val tasks = database.getTasks
     if (tasks.nonEmpty) {
       Task.nextId = tasks.map(_.id.toInt).max + 1
     }
   }
 
+  def importTasks(taskJson: String, socket: SocketIOClient): Unit = {
+    val tasks: List[JsValue] = Json.parse(taskJson).as[List[JsValue]]
+    for(task <- tasks){
+      database.addTask(makeTask(task))
+      socketToTasks += socket -> (database.getLastTaskId() :: socketToTasks.getOrElse(socket,List()))
+    }
+  }
+
+  def makeTask(task: JsValue): Task = {
+    val title: String = (task \ "title").as[String]
+    val description: String = (task \ "description").as[String]
+    Task(title, description)
+  }
+
 }
 
 object TodoServer {
@@ -57,21 +82,32 @@ object TodoServer {
 class ConnectionListener(server: TodoServer) extends ConnectListener {
 
   override def onConnect(socket: SocketIOClient): Unit = {
-    socket.sendEvent("all_tasks", server.tasksJSON())
+    socket.sendEvent("all_tasks", server.tasksJSON(socket))
   }
 
 }
 
+class importTaskListener(server: TodoServer) extends DataListener[String]{//expects the client to emit a signal of "import_task" with a value of JSON string, will add the tasks into the current database
+  override def onData(socket: SocketIOClient, taskJSON: String, ackRequest: AckRequest): Unit = {
+    server.importTasks(taskJSON,socket)
+    socket.sendEvent("all_tasks", server.tasksJSON(socket))
+  }
+}
+
+class exportTaskListener(server: TodoServer) extends DataListener[Nothing]{//expects the client to emit a signal of "export_task", will convert all in the database into a JSON string and send it to the socket requesting
+  override def onData(socket: SocketIOClient, nothing: Nothing, ackRequest: AckRequest): Unit ={
+    socket.sendEvent("exported_task", server.tasksJSON(socket))
+  }
+}
 
 class AddTaskListener(server: TodoServer) extends DataListener[String] {
 
   override def onData(socket: SocketIOClient, taskJSON: String, ackRequest: AckRequest): Unit = {
-    val task: JsValue = Json.parse(taskJSON)
-    val title: String = (task \ "title").as[String]
-    val description: String = (task \ "description").as[String]
+    server.database.addTask(server.makeTask(Json.parse(taskJSON)))
+    server.socketToTasks += socket -> (server.database.getLastTaskId() :: server.socketToTasks.getOrElse(socket,List()))
+    //server.server.getBroadcastOperations.sendEvent("all_tasks", server.tasksJSONALL())
+    socket.sendEvent("all_tasks", server.tasksJSON(socket))
 
-    server.database.addTask(Task(title, description))
-    server.server.getBroadcastOperations.sendEvent("all_tasks", server.tasksJSON())
   }
 
 }
@@ -80,8 +116,11 @@ class AddTaskListener(server: TodoServer) extends DataListener[String] {
 class CompleteTaskListener(server: TodoServer) extends DataListener[String] {
 
   override def onData(socket: SocketIOClient, taskId: String, ackRequest: AckRequest): Unit = {
+
     server.database.completeTask(taskId)
-    server.server.getBroadcastOperations.sendEvent("all_tasks", server.tasksJSON())
+    server.socketToTasks += socket -> server.socketToTasks(socket).filter(_!=taskId.toInt)
+    socket.sendEvent("all_tasks", server.tasksJSON(socket))
+
   }
 
 }

src/main/scala/model/database/Database.scala

@@ -40,6 +40,11 @@ class Database extends DatabaseAPI{
     statement.execute()
   }
 
+  override def getLastTaskId: Int = {
+    val statement = connection.prepareStatement("SELECT LAST() FROM tasks")
+    val result: ResultSet = statement.executeQuery()
+    result.getString("id").toInt
+  }
 
   override def getTasks: List[Task] = {
     val statement = connection.prepareStatement("SELECT * FROM tasks")

src/main/scala/model/database/DatabaseAPI.scala

@@ -6,6 +6,7 @@ trait DatabaseAPI {
 
   def addTask(task: Task): Unit
   def completeTask(taskId: String): Unit
+  def getLastTaskId(): Int
   def getTasks: List[Task]
 
 }

src/main/scala/model/database/TestingDatabase.scala

@@ -11,6 +11,16 @@ class TestingDatabase extends DatabaseAPI {
     data ::= task
   }
 
+  override def getLastTaskId(): Int = {
+    var id = 0
+    for(task <- data){
+      if(task.id.toInt > id){
+        id = task.id.toInt
+      }
+    }
+    id
+  }
+
 
   override def completeTask(taskId: String): Unit = {
     data = data.filter(_.id != taskId)