Compare commits

..

18 commits
v0.3.0 ... main

Author SHA1 Message Date
ef37747b9d chore: update module git.smsvc.net/pomodoro/gotomato to v0.5.0 2024-11-22 07:47:32 +00:00
09452b8c9c feat(Taskfile): add task to install latest published version 2024-11-21 23:14:49 +01:00
9b7dc19935 feat: introduce vars.go for websocket package
- update comments
- move `Done` variable to vars.go
- move `Connected()` method

🤖
2024-11-21 20:07:08 +01:00
342ecde6bb refactor: update reconnect code for better understanding 2024-11-21 12:28:36 +01:00
c4c787a782 chore: update module github.com/charmbracelet/bubbletea to v1.2.3 2024-11-21 12:28:36 +01:00
46c3a4c0b1 fix: remove unused variable prevMessage
- update logic to send current serverMessage instead of prevMessage
- simplify message processing for improved clarity

🤖
2024-11-21 12:28:32 +01:00
74ee5f3693 feat(Taskfile): add check for clean working tree before release
- add a precondition to ensure the working tree is clean before releasing

🤖
2024-11-18 19:36:09 +01:00
a121f01371 feat: update terminology from "Work" to "Focus"
- change "Work" to "Focus" in all occurences
- update GoTomato version to v0.4.0
2024-11-18 19:24:03 +01:00
646f460e6a chore: update module github.com/charmbracelet/bubbletea to v1.2.2 2024-11-13 19:54:39 +01:00
b7fc646cc0 fix: better error display in TUI
- always show `client.LasErr` if not `nil`
2024-11-13 19:54:39 +01:00
d25ce3eead feat: add read timeout for server messages 2024-11-13 19:54:39 +01:00
b494c2782e refactor: merge client/helper package to client
- remove helper package and move functions to client package
- merge `terminalOutput()` to `view.go`
- move `desktopNotifications()` to `cmd/client`

🤖
2024-11-13 19:54:39 +01:00
74f41f0e56 fix: replace timer icon
- change timer icon from hourglass to stopwatch

🤖
2024-11-13 19:54:36 +01:00
6b90db0d6c feat: add progress bar to timer
- add progress package for visual feedback
- implement calc_percentage function for duration calculation
- update TerminalOutput to include progress percentage and view

🤖
2024-11-13 17:14:13 +01:00
94e7b41421 fix: preserve client password during reconnection process 2024-11-13 17:14:13 +01:00
c30829392d chore: update module git.smsvc.net/pomodoro/gotomato to v0.3.1 2024-11-10 17:02:50 +00:00
c832aecd81 fix: update module github.com/charmbracelet/bubbletea to v1.2.1 2024-11-10 16:04:40 +00:00
fb502c1423 fix(renovate): make Go deps always a "chore"
- add package rules to set semantic commit type for gomod
2024-11-10 17:04:04 +01:00
11 changed files with 132 additions and 99 deletions

View file

@ -2,5 +2,11 @@
"$schema": "https://docs.renovatebot.com/renovate-schema.json", "$schema": "https://docs.renovatebot.com/renovate-schema.json",
"extends": [ "extends": [
"local>infrastructure/renovate-config" "local>infrastructure/renovate-config"
],
"packageRules": [
{
"matchManagers": ["gomod"],
"semanticCommitType": "chore"
}
] ]
} }

View file

@ -15,7 +15,7 @@ The configuration is loaded from `~/config/ChronoTomato.yml`, here is an example
url: ws://localhost:8080/ws url: ws://localhost:8080/ws
password: "" password: ""
config: config:
work: 1500 focus: 1500
shortbreak: 300 shortbreak: 300
longbreak: 600 longbreak: 600
sessions: 4 sessions: 4

View file

@ -21,6 +21,8 @@ tasks:
preconditions: preconditions:
- sh: test "{{.BRANCH}}" == "main" - sh: test "{{.BRANCH}}" == "main"
msg: "You must be on the main branch to release" msg: "You must be on the main branch to release"
- sh: test -z "$(git status --porcelain)"
msg: "You must have a clean working tree to release"
prompt: Create new release {{.RELEASE}} from {{.COMMIT}}@{{.BRANCH}}? prompt: Create new release {{.RELEASE}} from {{.COMMIT}}@{{.BRANCH}}?
cmds: cmds:
- git tag {{.RELEASE}} - git tag {{.RELEASE}}
@ -32,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

@ -1,51 +0,0 @@
package helper
import (
"fmt"
"github.com/alecthomas/colour"
GoTomato "git.smsvc.net/pomodoro/GoTomato/pkg/models"
)
// Return terminal output based on the passed ServerMessage
func TerminalOutput(pomodoro GoTomato.ServerMessage) string {
var (
output string
modePrefix string
timerOutput string
)
// header
output += colour.Sprintf("^D^4Work: %d ◊ Break: %d ◊ Longbreak: %d^R\n\n",
pomodoro.Settings.Work/60,
pomodoro.Settings.ShortBreak/60,
pomodoro.Settings.LongBreak/60,
)
//body
switch pomodoro.Mode {
case "Idle":
modePrefix = " "
timerOutput = ""
default:
modePrefix = " "
if pomodoro.Paused {
modePrefix = " "
}
minutes := pomodoro.TimeLeft / 60
seconds := pomodoro.TimeLeft % 60
timerOutput = fmt.Sprintf("⏳ %02d:%02d", minutes, seconds)
}
output += fmt.Sprintf("Session: %d/%d\n",
pomodoro.Session,
pomodoro.Settings.Sessions,
)
output += fmt.Sprintf("%s %s\n", modePrefix, pomodoro.Mode)
output += fmt.Sprintf(timerOutput)
return output
}

View file

@ -1,4 +1,4 @@
package helper package client
import ( import (
"fmt" "fmt"
@ -8,7 +8,7 @@ import (
) )
// Send desktop notifications on the start of each segment // Send desktop notifications on the start of each segment
func DesktopNotifications(pomodoro GoTomato.ServerMessage) { func desktopNotifications(pomodoro GoTomato.ServerMessage) {
var ( var (
duration int duration int
notification string notification string
@ -19,8 +19,8 @@ func DesktopNotifications(pomodoro GoTomato.ServerMessage) {
sessions := pomodoro.Settings.Sessions sessions := pomodoro.Settings.Sessions
switch mode { switch mode {
case "Work": case "Focus":
duration = pomodoro.Settings.Work duration = pomodoro.Settings.Focus
notification = fmt.Sprintf("Session %d/%d: %s %0.f minutes", session, sessions, mode, float32(duration)/60) notification = fmt.Sprintf("Session %d/%d: %s %0.f minutes", session, sessions, mode, float32(duration)/60)
case "ShortBreak": case "ShortBreak":
duration = pomodoro.Settings.ShortBreak duration = pomodoro.Settings.ShortBreak

View file

@ -1,31 +1,93 @@
package client package client
import ( import (
"fmt"
"strings" "strings"
"github.com/alecthomas/colour" "github.com/alecthomas/colour"
"git.smsvc.net/pomodoro/ChronoTomato/cmd/client/helper"
GoTomato "git.smsvc.net/pomodoro/GoTomato/pkg/models" GoTomato "git.smsvc.net/pomodoro/GoTomato/pkg/models"
"github.com/charmbracelet/bubbles/progress"
) )
var progressBar = progress.New(progress.WithDefaultGradient(), progress.WithoutPercentage())
func (a app) View() string { func (a app) View() string {
var body string var body string
var serverStatus string var serverStatus string
body = "Waiting for server message..." body = "Waiting for server message..."
if a.pomodoro != (GoTomato.ServerMessage{}) { if a.pomodoro != (GoTomato.ServerMessage{}) {
body = helper.TerminalOutput(a.pomodoro) body = terminalOutput(a.pomodoro)
helper.DesktopNotifications(a.pomodoro) desktopNotifications(a.pomodoro)
} }
serverStatus = colour.Sprintf("^D^1disconnected: %v^R\n", client.LastErr) serverStatus = colour.Sprintf("^D^1%v^R\n", client.LastErr)
if client.Connected() { if client.Connected() && client.LastErr == nil {
serverStatus = colour.Sprintf("^D^2connected to %s^R\n", client.Server) serverStatus = colour.Sprintf("^D^2connected to %s^R\n", client.Server)
} }
helpView := a.help.View(a.keys) helpView := a.help.View(a.keys)
height := 8 - strings.Count(body, "\n") - strings.Count(serverStatus, "\n") - strings.Count(helpView, "\n") height := 10 - strings.Count(body, "\n") - strings.Count(serverStatus, "\n") - strings.Count(helpView, "\n")
return body + strings.Repeat("\n", height) + serverStatus + helpView return body + strings.Repeat("\n", height) + serverStatus + helpView
} }
// Return terminal output based on the passed ServerMessage
func terminalOutput(pomodoro GoTomato.ServerMessage) string {
var (
output string
modePrefix string
timerOutput string
)
// header
output += colour.Sprintf("^D^4Focus: %d ◊ Break: %d ◊ Longbreak: %d^R\n\n",
pomodoro.Settings.Focus/60,
pomodoro.Settings.ShortBreak/60,
pomodoro.Settings.LongBreak/60,
)
//body
switch pomodoro.Mode {
case "Idle":
modePrefix = " "
timerOutput = ""
default:
modePrefix = " "
if pomodoro.Paused {
modePrefix = " "
}
minutes := pomodoro.TimeLeft / 60
seconds := pomodoro.TimeLeft % 60
timerOutput = fmt.Sprintf("⏱ %02d:%02d", minutes, seconds) + "\n"
timerOutput += progressBar.ViewAs(calc_percentage(pomodoro))
}
output += fmt.Sprintf("Session: %d/%d\n",
pomodoro.Session,
pomodoro.Settings.Sessions,
)
output += fmt.Sprintf("%s %s\n", modePrefix, pomodoro.Mode) + "\n"
output += timerOutput
return output
}
func calc_percentage(message GoTomato.ServerMessage) float64 {
var duration float64
switch message.Mode {
case "Focus":
duration = float64(message.Settings.Focus)
case "ShortBreak":
duration = float64(message.Settings.ShortBreak)
case "LongBreak", "End":
duration = float64(message.Settings.LongBreak)
}
timeLeft := float64(message.TimeLeft)
return 1.0 - (timeLeft / duration)
}

15
go.mod
View file

@ -3,10 +3,10 @@ module git.smsvc.net/pomodoro/ChronoTomato
go 1.23.1 go 1.23.1
require ( require (
git.smsvc.net/pomodoro/GoTomato v0.0.8 git.smsvc.net/pomodoro/GoTomato v0.5.0
github.com/alecthomas/colour v0.1.0 github.com/alecthomas/colour v0.1.0
github.com/charmbracelet/bubbles v0.20.0 github.com/charmbracelet/bubbles v0.20.0
github.com/charmbracelet/bubbletea v1.1.2 github.com/charmbracelet/bubbletea v1.2.3
github.com/charmbracelet/log v0.4.0 github.com/charmbracelet/log v0.4.0
github.com/gen2brain/beeep v0.0.0-20240516210008-9c006672e7f4 github.com/gen2brain/beeep v0.0.0-20240516210008-9c006672e7f4
github.com/gorilla/websocket v1.5.3 github.com/gorilla/websocket v1.5.3
@ -15,9 +15,10 @@ require (
require ( require (
github.com/aymanbagabas/go-osc52/v2 v2.0.1 // indirect github.com/aymanbagabas/go-osc52/v2 v2.0.1 // indirect
github.com/charmbracelet/lipgloss v0.13.0 // indirect github.com/charmbracelet/harmonica v0.2.0 // indirect
github.com/charmbracelet/x/ansi v0.4.0 // indirect github.com/charmbracelet/lipgloss v1.0.0 // indirect
github.com/charmbracelet/x/term v0.2.0 // indirect github.com/charmbracelet/x/ansi v0.4.5 // indirect
github.com/charmbracelet/x/term v0.2.1 // indirect
github.com/erikgeiser/coninput v0.0.0-20211004153227-1c3628e74d0f // indirect github.com/erikgeiser/coninput v0.0.0-20211004153227-1c3628e74d0f // indirect
github.com/go-logfmt/logfmt v0.6.0 // indirect github.com/go-logfmt/logfmt v0.6.0 // indirect
github.com/go-toast/toast v0.0.0-20190211030409-01e6764cf0a4 // indirect github.com/go-toast/toast v0.0.0-20190211030409-01e6764cf0a4 // indirect
@ -34,8 +35,8 @@ require (
github.com/rivo/uniseg v0.4.7 // indirect github.com/rivo/uniseg v0.4.7 // indirect
github.com/tadvi/systray v0.0.0-20190226123456-11a2b8fa57af // indirect github.com/tadvi/systray v0.0.0-20190226123456-11a2b8fa57af // indirect
golang.org/x/exp v0.0.0-20231006140011-7918f672742d // indirect golang.org/x/exp v0.0.0-20231006140011-7918f672742d // indirect
golang.org/x/sync v0.8.0 // indirect golang.org/x/sync v0.9.0 // indirect
golang.org/x/sys v0.26.0 // indirect golang.org/x/sys v0.27.0 // indirect
golang.org/x/text v0.3.8 // indirect golang.org/x/text v0.3.8 // indirect
gopkg.in/check.v1 v1.0.0-20190902080502-41f04d3bba15 // indirect gopkg.in/check.v1 v1.0.0-20190902080502-41f04d3bba15 // indirect
) )

30
go.sum
View file

@ -1,21 +1,23 @@
git.smsvc.net/pomodoro/GoTomato v0.0.8 h1:ePD6T14pFtrtXybHypabpDs4MURdOnPkm8nQzzEteVA= git.smsvc.net/pomodoro/GoTomato v0.5.0 h1:ni6v5iNnSac/Os3skmGobAwjyXP3uS76N+fhZDubqkU=
git.smsvc.net/pomodoro/GoTomato v0.0.8/go.mod h1:LaKrPdnFB5v4RpltExKasW67TmjJlmhDDvmoEYWv0P4= git.smsvc.net/pomodoro/GoTomato v0.5.0/go.mod h1:LaKrPdnFB5v4RpltExKasW67TmjJlmhDDvmoEYWv0P4=
github.com/alecthomas/colour v0.1.0 h1:nOE9rJm6dsZ66RGWYSFrXw461ZIt9A6+nHgL7FRrDUk= github.com/alecthomas/colour v0.1.0 h1:nOE9rJm6dsZ66RGWYSFrXw461ZIt9A6+nHgL7FRrDUk=
github.com/alecthomas/colour v0.1.0/go.mod h1:QO9JBoKquHd+jz9nshCh40fOfO+JzsoXy8qTHF68zU0= github.com/alecthomas/colour v0.1.0/go.mod h1:QO9JBoKquHd+jz9nshCh40fOfO+JzsoXy8qTHF68zU0=
github.com/aymanbagabas/go-osc52/v2 v2.0.1 h1:HwpRHbFMcZLEVr42D4p7XBqjyuxQH5SMiErDT4WkJ2k= github.com/aymanbagabas/go-osc52/v2 v2.0.1 h1:HwpRHbFMcZLEVr42D4p7XBqjyuxQH5SMiErDT4WkJ2k=
github.com/aymanbagabas/go-osc52/v2 v2.0.1/go.mod h1:uYgXzlJ7ZpABp8OJ+exZzJJhRNQ2ASbcXHWsFqH8hp8= github.com/aymanbagabas/go-osc52/v2 v2.0.1/go.mod h1:uYgXzlJ7ZpABp8OJ+exZzJJhRNQ2ASbcXHWsFqH8hp8=
github.com/charmbracelet/bubbles v0.20.0 h1:jSZu6qD8cRQ6k9OMfR1WlM+ruM8fkPWkHvQWD9LIutE= github.com/charmbracelet/bubbles v0.20.0 h1:jSZu6qD8cRQ6k9OMfR1WlM+ruM8fkPWkHvQWD9LIutE=
github.com/charmbracelet/bubbles v0.20.0/go.mod h1:39slydyswPy+uVOHZ5x/GjwVAFkCsV8IIVy+4MhzwwU= github.com/charmbracelet/bubbles v0.20.0/go.mod h1:39slydyswPy+uVOHZ5x/GjwVAFkCsV8IIVy+4MhzwwU=
github.com/charmbracelet/bubbletea v1.1.2 h1:naQXF2laRxyLyil/i7fxdpiz1/k06IKquhm4vBfHsIc= github.com/charmbracelet/bubbletea v1.2.3 h1:d9MdMsANIYZB5pE1KkRqaUV6GfsiWm+/9z4fTuGVm9I=
github.com/charmbracelet/bubbletea v1.1.2/go.mod h1:9HIU/hBV24qKjlehyj8z1r/tR9TYTQEag+cWZnuXo8E= github.com/charmbracelet/bubbletea v1.2.3/go.mod h1:Qr6fVQw+wX7JkWWkVyXYk/ZUQ92a6XNekLXa3rR18MM=
github.com/charmbracelet/lipgloss v0.13.0 h1:4X3PPeoWEDCMvzDvGmTajSyYPcZM4+y8sCA/SsA3cjw= github.com/charmbracelet/harmonica v0.2.0 h1:8NxJWRWg/bzKqqEaaeFNipOu77YR5t8aSwG4pgaUBiQ=
github.com/charmbracelet/lipgloss v0.13.0/go.mod h1:nw4zy0SBX/F/eAO1cWdcvy6qnkDUxr8Lw7dvFrAIbbY= github.com/charmbracelet/harmonica v0.2.0/go.mod h1:KSri/1RMQOZLbw7AHqgcBycp8pgJnQMYYT8QZRqZ1Ao=
github.com/charmbracelet/lipgloss v1.0.0 h1:O7VkGDvqEdGi93X+DeqsQ7PKHDgtQfF8j8/O2qFMQNg=
github.com/charmbracelet/lipgloss v1.0.0/go.mod h1:U5fy9Z+C38obMs+T+tJqst9VGzlOYGj4ri9reL3qUlo=
github.com/charmbracelet/log v0.4.0 h1:G9bQAcx8rWA2T3pWvx7YtPTPwgqpk7D68BX21IRW8ZM= github.com/charmbracelet/log v0.4.0 h1:G9bQAcx8rWA2T3pWvx7YtPTPwgqpk7D68BX21IRW8ZM=
github.com/charmbracelet/log v0.4.0/go.mod h1:63bXt/djrizTec0l11H20t8FDSvA4CRZJ1KH22MdptM= github.com/charmbracelet/log v0.4.0/go.mod h1:63bXt/djrizTec0l11H20t8FDSvA4CRZJ1KH22MdptM=
github.com/charmbracelet/x/ansi v0.4.0 h1:NqwHA4B23VwsDn4H3VcNX1W1tOmgnvY1NDx5tOXdnOU= github.com/charmbracelet/x/ansi v0.4.5 h1:LqK4vwBNaXw2AyGIICa5/29Sbdq58GbGdFngSexTdRM=
github.com/charmbracelet/x/ansi v0.4.0/go.mod h1:dk73KoMTT5AX5BsX0KrqhsTqAnhZZoCBjs7dGWp4Ktw= github.com/charmbracelet/x/ansi v0.4.5/go.mod h1:dk73KoMTT5AX5BsX0KrqhsTqAnhZZoCBjs7dGWp4Ktw=
github.com/charmbracelet/x/term v0.2.0 h1:cNB9Ot9q8I711MyZ7myUR5HFWL/lc3OpU8jZ4hwm0x0= github.com/charmbracelet/x/term v0.2.1 h1:AQeHeLZ1OqSXhrAWpYUtZyX1T3zVxfpZuEQMIQaGIAQ=
github.com/charmbracelet/x/term v0.2.0/go.mod h1:GVxgxAbjUrmpvIINHIQnJJKpMlHiZ4cktEQCN6GWyF0= github.com/charmbracelet/x/term v0.2.1/go.mod h1:oQ4enTYFV7QN4m0i9mzHrViD7TQKvNEEkHUMCmsxdUg=
github.com/davecgh/go-spew v1.1.1 h1:vj9j/u1bqnvCEfJOwUhtlOARqs3+rkHYY13jYWTU97c= github.com/davecgh/go-spew v1.1.1 h1:vj9j/u1bqnvCEfJOwUhtlOARqs3+rkHYY13jYWTU97c=
github.com/davecgh/go-spew v1.1.1/go.mod h1:J7Y8YcW2NihsgmVo/mv3lAwl/skON4iLHjSsI+c5H38= github.com/davecgh/go-spew v1.1.1/go.mod h1:J7Y8YcW2NihsgmVo/mv3lAwl/skON4iLHjSsI+c5H38=
github.com/erikgeiser/coninput v0.0.0-20211004153227-1c3628e74d0f h1:Y/CXytFA4m6baUTXGLOoWe4PQhGxaX0KpnayAqC48p4= github.com/erikgeiser/coninput v0.0.0-20211004153227-1c3628e74d0f h1:Y/CXytFA4m6baUTXGLOoWe4PQhGxaX0KpnayAqC48p4=
@ -62,12 +64,12 @@ github.com/tadvi/systray v0.0.0-20190226123456-11a2b8fa57af h1:6yITBqGTE2lEeTPG0
github.com/tadvi/systray v0.0.0-20190226123456-11a2b8fa57af/go.mod h1:4F09kP5F+am0jAwlQLddpoMDM+iewkxxt6nxUQ5nq5o= github.com/tadvi/systray v0.0.0-20190226123456-11a2b8fa57af/go.mod h1:4F09kP5F+am0jAwlQLddpoMDM+iewkxxt6nxUQ5nq5o=
golang.org/x/exp v0.0.0-20231006140011-7918f672742d h1:jtJma62tbqLibJ5sFQz8bKtEM8rJBtfilJ2qTU199MI= golang.org/x/exp v0.0.0-20231006140011-7918f672742d h1:jtJma62tbqLibJ5sFQz8bKtEM8rJBtfilJ2qTU199MI=
golang.org/x/exp v0.0.0-20231006140011-7918f672742d/go.mod h1:ldy0pHrwJyGW56pPQzzkH36rKxoZW1tw7ZJpeKx+hdo= golang.org/x/exp v0.0.0-20231006140011-7918f672742d/go.mod h1:ldy0pHrwJyGW56pPQzzkH36rKxoZW1tw7ZJpeKx+hdo=
golang.org/x/sync v0.8.0 h1:3NFvSEYkUoMifnESzZl15y791HH1qU2xm6eCJU5ZPXQ= golang.org/x/sync v0.9.0 h1:fEo0HyrW1GIgZdpbhCRO0PkJajUS5H9IFUztCgEo2jQ=
golang.org/x/sync v0.8.0/go.mod h1:Czt+wKu1gCyEFDUtn0jG5QVvpJ6rzVqr5aXyt9drQfk= golang.org/x/sync v0.9.0/go.mod h1:Czt+wKu1gCyEFDUtn0jG5QVvpJ6rzVqr5aXyt9drQfk=
golang.org/x/sys v0.0.0-20210809222454-d867a43fc93e/go.mod h1:oPkhp1MJrh7nUepCBck5+mAzfO9JrbApNNgaTdGDITg= golang.org/x/sys v0.0.0-20210809222454-d867a43fc93e/go.mod h1:oPkhp1MJrh7nUepCBck5+mAzfO9JrbApNNgaTdGDITg=
golang.org/x/sys v0.6.0/go.mod h1:oPkhp1MJrh7nUepCBck5+mAzfO9JrbApNNgaTdGDITg= golang.org/x/sys v0.6.0/go.mod h1:oPkhp1MJrh7nUepCBck5+mAzfO9JrbApNNgaTdGDITg=
golang.org/x/sys v0.26.0 h1:KHjCJyddX0LoSTb3J+vWpupP9p0oznkqVk/IfjymZbo= golang.org/x/sys v0.27.0 h1:wBqf8DvsY9Y/2P8gAfPDEYNuS30J4lPHJxXSb/nJZ+s=
golang.org/x/sys v0.26.0/go.mod h1:/VUhepiaJMQUp4+oa/7Zr1D23ma6VTLIYjOOTFZPUcA= golang.org/x/sys v0.27.0/go.mod h1:/VUhepiaJMQUp4+oa/7Zr1D23ma6VTLIYjOOTFZPUcA=
golang.org/x/text v0.3.8 h1:nAL+RVCQ9uMn3vJZbV+MRnydTJFPf8qqY42YiA6MrqY= golang.org/x/text v0.3.8 h1:nAL+RVCQ9uMn3vJZbV+MRnydTJFPf8qqY42YiA6MrqY=
golang.org/x/text v0.3.8/go.mod h1:E6s5w1FMmriuDzIBO73fBruAKo1PCIq6d2Q6DHfQ8WQ= golang.org/x/text v0.3.8/go.mod h1:E6s5w1FMmriuDzIBO73fBruAKo1PCIq6d2Q6DHfQ8WQ=
gopkg.in/check.v1 v0.0.0-20161208181325-20d25e280405/go.mod h1:Co6ibVJAznAaIkqp8huTwlJQCZ016jof/cbN4VW5Yz0= gopkg.in/check.v1 v0.0.0-20161208181325-20d25e280405/go.mod h1:Co6ibVJAznAaIkqp8huTwlJQCZ016jof/cbN4VW5Yz0=

View file

@ -1,13 +1,15 @@
package websocket package websocket
import ( import (
"github.com/gorilla/websocket"
"time" "time"
"github.com/gorilla/websocket"
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 {
@ -16,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
@ -33,3 +31,7 @@ func (c Client) Disconnect() {
} }
return return
} }
func (c Client) Connected() bool {
return c.Conn != nil
}

View file

@ -9,32 +9,33 @@ 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) {
var serverMessage, prevMessage GoTomato.ServerMessage var serverMessage GoTomato.ServerMessage
defer close(Done) defer close(Done)
for { for {
c.Conn.SetReadDeadline(time.Now().Add(10 * time.Second))
_, message, err := c.Conn.ReadMessage() _, message, err := c.Conn.ReadMessage()
if err != nil { if err != nil {
c.LastErr = err
// On normal closure exit gracefully // On normal closure exit gracefully
if websocket.IsCloseError(err, websocket.CloseNormalClosure) { if websocket.IsCloseError(err, websocket.CloseNormalClosure) {
return return
} }
// Try to reconnect on unexpected disconnect // reset connection and reconnect
for { c.Conn = nil
channel <- prevMessage // send previous ServerMessage to update view pw := c.Password
for !c.Connected() {
channel <- serverMessage // send last known ServerMessage to update view
time.Sleep(time.Second) time.Sleep(time.Second)
*c = Connect(c.Server) *c = Connect(c.Server)
if c.Connected() {
break
}
} }
c.Password = pw
continue continue
} }
@ -42,6 +43,5 @@ func (c *Client) ProcessServerMessages(channel chan<- GoTomato.ServerMessage) {
c.LastErr = err c.LastErr = err
channel <- serverMessage channel <- serverMessage
prevMessage = serverMessage
} }
} }

View file

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