Compare commits

...

2 commits

Author SHA1 Message Date
98fcb3059a feat(Taskfile): add install task for local version installation 2024-11-21 12:28:56 +01:00
bcda687c5e refactor: websocket client and closure variable
- update comments
- move `Done` variable to vars.go
- move `Connected()` method

🤖
2024-11-21 12:28:36 +01:00
4 changed files with 15 additions and 7 deletions

View file

@ -34,3 +34,8 @@ tasks:
desc: Create a local snapshot release desc: Create a local snapshot release
cmds: cmds:
- goreleaser release --clean --snapshot - goreleaser release --clean --snapshot
install:
desc: Install the latest published version locally
cmds:
- go install git.smsvc.net/pomodoro/ChronoTomato@latest

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{})