X-Git-Url: https://gerrit.automotivelinux.org/gerrit/gitweb?a=blobdiff_plain;f=lib%2Fxdsserver%2Fapiv1-targets.go;fp=lib%2Fxdsserver%2Fapiv1-targets.go;h=a7048eb8a0b2d86827a15baaf30cbf8a18328192;hb=08095aa9a0d7b9b7636cdf36a5a5b6df2592bc05;hp=978dc75a4711ba3ad4593a51ac09b5b904bb45d1;hpb=17812a0a4388ab0c87084ef7e8118d87e8fadcf7;p=src%2Fxds%2Fxds-server.git

diff --git a/lib/xdsserver/apiv1-targets.go b/lib/xdsserver/apiv1-targets.go
index 978dc75..a7048eb 100644
--- a/lib/xdsserver/apiv1-targets.go
+++ b/lib/xdsserver/apiv1-targets.go
@@ -58,9 +58,16 @@ func (s *APIService) addTarget(c *gin.Context) {
 		return
 	}
 
+	// Retrieve session info
+	sess := s.sessions.Get(c)
+	if sess == nil {
+		common.APIError(c, "Unknown sessions")
+		return
+	}
+
 	s.Log.Debugln("Add target config: ", cfgArg)
 
-	newTgt, err := s.targets.Add(cfgArg)
+	newTgt, err := s.targets.Add(cfgArg, sess)
 	if err != nil {
 		common.APIError(c, err.Error())
 		return
@@ -77,9 +84,16 @@ func (s *APIService) delTarget(c *gin.Context) {
 		return
 	}
 
+	// Retrieve session info
+	sess := s.sessions.Get(c)
+	if sess == nil {
+		common.APIError(c, "Unknown sessions")
+		return
+	}
+
 	s.Log.Debugln("Delete target id ", id)
 
-	delEntry, err := s.targets.Delete(id)
+	delEntry, err := s.targets.Delete(id, sess)
 	if err != nil {
 		common.APIError(c, err.Error())
 		return
@@ -190,13 +204,8 @@ func (s *APIService) openTgtTerm(c *gin.Context) {
 		common.APIError(c, "Unknown sessions")
 		return
 	}
-	sock := sess.IOSocket
-	if sock == nil {
-		common.APIError(c, "Websocket not established")
-		return
-	}
 
-	term, err := s.targets.OpenTerminal(id, tid, sock, sess.ID)
+	term, err := s.targets.OpenTerminal(id, tid, sess)
 	if err != nil {
 		common.APIError(c, err.Error())
 		return
@@ -211,7 +220,15 @@ func (s *APIService) closeTgtTerm(c *gin.Context) {
 		common.APIError(c, err.Error())
 		return
 	}
-	term, err := s.targets.CloseTerminal(id, tid)
+
+	// Retrieve session info
+	sess := s.sessions.Get(c)
+	if sess == nil {
+		common.APIError(c, "Unknown sessions")
+		return
+	}
+
+	term, err := s.targets.CloseTerminal(id, tid, sess)
 	if err != nil {
 		common.APIError(c, err.Error())
 		return
@@ -233,7 +250,14 @@ func (s *APIService) resizeTgtTerm(c *gin.Context) {
 		return
 	}
 
-	term, err := s.targets.ResizeTerminal(id, tid, sizeArg.Cols, sizeArg.Rows)
+	// Retrieve session info
+	sess := s.sessions.Get(c)
+	if sess == nil {
+		common.APIError(c, "Unknown sessions")
+		return
+	}
+
+	term, err := s.targets.ResizeTerminal(id, tid, sizeArg.Cols, sizeArg.Rows, sess)
 	if err != nil {
 		common.APIError(c, err.Error())
 		return