Delete pending requests upon disconnect

lorenzodonini · lorenzodonini · commit 3f543b51de0d · 2020-06-06T10:54:56.000+02:00
Signed-off-by: Lorenzo Donini &lt;lorenzo.donini@motius.de&gt;
diff --git a/ocppj/server.go b/ocppj/server.go
@@ -73,6 +73,7 @@ func (s *Server) Start(listenPort int, listenPath string) {
 		}
 	})
 	s.server.SetDisconnectedClientHandler(func(ws ws.Channel) {
+		delete(s.clientPendingMessages, ws.GetID())
 		if s.disconnectedClientHandler != nil {
 			s.disconnectedClientHandler(ws.GetID())
 		}

Original file line number	Diff line number	Diff line change
`@@ -73,6 +73,7 @@ func (s *Server) Start(listenPort int, listenPath string) {`
`73`	`73`	`}`
`74`	`74`	`})`
`75`	`75`	`s.server.SetDisconnectedClientHandler(func(ws ws.Channel) {`
	`76`	`+ delete(s.clientPendingMessages, ws.GetID())`
`76`	`77`	`if s.disconnectedClientHandler != nil {`
`77`	`78`	`s.disconnectedClientHandler(ws.GetID())`
`78`	`79`	`}`