Skip to content
Snippets Groups Projects
Commit dbb07084 authored by Tobias Ullerich's avatar Tobias Ullerich
Browse files

Add Project Remove Listener, mark old listener classes as deprecated

parent cd9d7522
No related branches found
No related tags found
No related merge requests found
...@@ -15,6 +15,7 @@ import scala.collection.{Map, mutable} ...@@ -15,6 +15,7 @@ import scala.collection.{Map, mutable}
/** /**
* Created by tobias on 13.02.17. * Created by tobias on 13.02.17.
*/ */
@Deprecated
@WebSocket class ProjectHandler(sessionDao: Dao[account.Session, Int], connection: Connection) { @WebSocket class ProjectHandler(sessionDao: Dao[account.Session, Int], connection: Connection) {
// TODO mutable.HashSet --> Set // TODO mutable.HashSet --> Set
......
...@@ -11,6 +11,7 @@ import scala.collection.JavaConverters ...@@ -11,6 +11,7 @@ import scala.collection.JavaConverters
/** /**
* Created by tobias on 18.02.17. * Created by tobias on 18.02.17.
*/ */
@Deprecated
class CollectionAddListener extends Listener { class CollectionAddListener extends Listener {
override def onChange(json: JsonObject, connection: Connection): Unit = { override def onChange(json: JsonObject, connection: Connection): Unit = {
val childClass = json.get("child_class").getAsString val childClass = json.get("child_class").getAsString
......
...@@ -8,6 +8,7 @@ import de.tobias.playpad.server.server.SqlHelper ...@@ -8,6 +8,7 @@ import de.tobias.playpad.server.server.SqlHelper
/** /**
* Created by tobias on 18.02.17. * Created by tobias on 18.02.17.
*/ */
@Deprecated
class CollectionRemoveListener extends Listener { class CollectionRemoveListener extends Listener {
override def onChange(json: JsonObject, connection: Connection): Unit = { override def onChange(json: JsonObject, connection: Connection): Unit = {
val childClass = json.get("child_class").getAsString val childClass = json.get("child_class").getAsString
......
...@@ -7,6 +7,7 @@ import com.google.gson.JsonObject ...@@ -7,6 +7,7 @@ import com.google.gson.JsonObject
/** /**
* Created by tobias on 18.02.17. * Created by tobias on 18.02.17.
*/ */
@Deprecated
trait Listener { trait Listener {
def onChange(json: JsonObject, connection: Connection): Unit def onChange(json: JsonObject, connection: Connection): Unit
......
...@@ -8,6 +8,7 @@ import de.tobias.playpad.server.server.SqlHelper ...@@ -8,6 +8,7 @@ import de.tobias.playpad.server.server.SqlHelper
/** /**
* Created by tobias on 18.02.17. * Created by tobias on 18.02.17.
*/ */
@Deprecated
class PropertyUpdateListener extends Listener { class PropertyUpdateListener extends Listener {
override def onChange(json: JsonObject, connection: Connection): Unit = { override def onChange(json: JsonObject, connection: Connection): Unit = {
json match { json match {
......
...@@ -6,7 +6,7 @@ import com.google.gson.{JsonObject, JsonParser} ...@@ -6,7 +6,7 @@ import com.google.gson.{JsonObject, JsonParser}
import com.j256.ormlite.dao.Dao import com.j256.ormlite.dao.Dao
import de.tobias.playpad.server.account import de.tobias.playpad.server.account
import de.tobias.playpad.server.account.Account import de.tobias.playpad.server.account.Account
import de.tobias.playpad.server.server.project.sync.listener.project.{ProjectAddListener, ProjectUpdateListener} import de.tobias.playpad.server.server.project.sync.listener.project.{ProjectAddListener, ProjectRemoveListener, ProjectUpdateListener}
import org.eclipse.jetty.websocket.api.Session import org.eclipse.jetty.websocket.api.Session
import org.eclipse.jetty.websocket.api.annotations.{OnWebSocketClose, OnWebSocketConnect, OnWebSocketMessage, WebSocket} import org.eclipse.jetty.websocket.api.annotations.{OnWebSocketClose, OnWebSocketConnect, OnWebSocketMessage, WebSocket}
...@@ -22,7 +22,8 @@ import scala.collection.{Map, mutable} ...@@ -22,7 +22,8 @@ import scala.collection.{Map, mutable}
private val listeners = Map( private val listeners = Map(
"pro-add" -> new ProjectAddListener(), "pro-add" -> new ProjectAddListener(),
"pro-update" -> new ProjectUpdateListener() "pro-update" -> new ProjectUpdateListener(),
"pro-rm" -> new ProjectRemoveListener()
) )
@OnWebSocketConnect def onConnect(serverSession: Session): Unit = { @OnWebSocketConnect def onConnect(serverSession: Session): Unit = {
......
package de.tobias.playpad.server.server.project.sync.listener.project
import java.sql.Connection
import java.util.UUID
import com.google.gson.JsonObject
import de.tobias.playpad.server.account.Session
import de.tobias.playpad.server.project.utils.SqlDef
import de.tobias.playpad.server.server.SqlHelper
import de.tobias.playpad.server.server.project.sync.listener.Listener
/**
* Created by tobias on 19.02.17.
*/
class ProjectRemoveListener extends Listener {
override def onChange(json: JsonObject, connection: Connection, session: Session): Unit = {
val projectId = UUID.fromString(json.get("id").getAsString)
SqlHelper.delete(connection, SqlDef.PROJECT, projectId)
}
}
0% Loading or .
You are about to add 0 people to the discussion. Proceed with caution.
Please register or to comment