refactor: websocket client and closure variable

- update comments
- move `Done` variable to vars.go
- move `Connected()` method

🤖
This commit is contained in:
Sebastian Mark 2024-11-21 12:25:45 +01:00
parent 2266b94b7c
commit 3763e3cce2
3 changed files with 10 additions and 7 deletions

View file

@ -8,7 +8,8 @@ import (
ChronoTomato "git.smsvc.net/pomodoro/ChronoTomato/pkg/models" ChronoTomato "git.smsvc.net/pomodoro/ChronoTomato/pkg/models"
) )
type Client ChronoTomato.GoTomatoClient // New websocket client // New websocket client
type Client ChronoTomato.GoTomatoClient
// Connects to websocket // Connects to websocket
func Connect(url string) Client { func Connect(url string) Client {
@ -17,10 +18,6 @@ func Connect(url string) Client {
return Client{Conn: conn, Server: url, LastErr: err} return Client{Conn: conn, Server: url, LastErr: err}
} }
func (c Client) Connected() bool {
return c.Conn != nil
}
// Disconnects from websocket // Disconnects from websocket
func (c Client) Disconnect() { func (c Client) Disconnect() {
// Cleanly close the connection by sending a close message and then // Cleanly close the connection by sending a close message and then
@ -34,3 +31,7 @@ func (c Client) Disconnect() {
} }
return return
} }
func (c Client) Connected() bool {
return c.Conn != nil
}

View file

@ -9,8 +9,6 @@ import (
GoTomato "git.smsvc.net/pomodoro/GoTomato/pkg/models" GoTomato "git.smsvc.net/pomodoro/GoTomato/pkg/models"
) )
var Done = make(chan struct{})
// Receives websocket messages and writes them to a channel. // Receives websocket messages and writes them to a channel.
// Closes the channel if websocket closes. // Closes the channel if websocket closes.
func (c *Client) ProcessServerMessages(channel chan<- GoTomato.ServerMessage) { func (c *Client) ProcessServerMessages(channel chan<- GoTomato.ServerMessage) {

View file

@ -0,0 +1,4 @@
package websocket
// Websocket closure
var Done = make(chan struct{})