fix(tests): added tests for Mutex (#2)

.github/workflows/tests.yml

@@ -25,7 +25,7 @@ jobs:
         with:
           go-version: ^1.22
       - name: golangci-lint
-        uses: golangci/golangci-lint-action@v3
+        uses: golangci/golangci-lint-action@v4
         with:
           version: v1.54
   unit-tests:

.gitignore

@@ -10,7 +10,7 @@
 
 # Test binary, built with `go test -c`
 *.test
-.db
+*.db
 snapshots
 
 # Output of the go coverage tool, specifically when used with LiteIDE

go.mod

@@ -4,6 +4,7 @@ go 1.18
 
 require (
 	github.com/mattn/go-sqlite3 v1.14.22
+	github.com/pkg/errors v0.9.1
 	github.com/stretchr/testify v1.9.0
 	github.com/yaitoo/async v1.0.4
 	github.com/yaitoo/sqle v1.3.1

go.sum

@@ -17,6 +17,7 @@ github.com/mattn/go-isatty v0.0.20 h1:xfD0iDuEKnDkl03q4limB+vH+GxLEtL/jb4xVJSWWE
 github.com/mattn/go-isatty v0.0.20/go.mod h1:W+V8PltTTMOvKvAeJH7IuucS94S2C6jfK/D7dTCTo3Y=
 github.com/mattn/go-sqlite3 v1.14.22 h1:2gZY6PC6kBnID23Tichd1K+Z0oS6nE/XwU+Vz/5o4kU=
 github.com/mattn/go-sqlite3 v1.14.22/go.mod h1:Uh1q+B4BYcTPb+yiD3kU8Ct7aC0hY9fxUwlHK0RXw+Y=
+github.com/pkg/errors v0.9.1 h1:FEBLx1zS214owpjy7qsBeixbURkuhQAwrK5UwLGTwt4=
 github.com/pkg/errors v0.9.1/go.mod h1:bwawxfHBFNV+L2hUp1rHADufV3IMtnDRdf1r5NINEl0=
 github.com/pmezard/go-difflib v1.0.0 h1:4DBwDE0NGyQoBHbLQYPwSUPoCMWR5BEzIk/f1lZbAQM=
 github.com/pmezard/go-difflib v1.0.0/go.mod h1:iKH77koFhYxTK1pcRnkKkqfTogsbg7gZNVY4sRDYZ/4=

lease.go

@@ -19,6 +19,14 @@ type Lease struct {
 	ExpiresOn time.Time `json:"-"`
 }
 
+// IsLive check if lease is live on node side
 func (l *Lease) IsLive() bool {
 	return time.Now().Before(time.Unix(l.Since, 0).Add(l.TTL.Duration()))
 }
+
+// IsExpired check if lease expires on mutex side
+func (l *Lease) IsExpired(start time.Time) bool {
+	now := time.Now()
+	l.ExpiresOn = now.Add(l.TTL.Duration() - time.Until(start))
+	return !now.Before(l.ExpiresOn)
+}