UmputunandGitHub
34ea4c3e83
* migrate golangci-lint to v2 and update go version - migrated .golangci.yml to version 2 format - updated go.mod from 1.23.0 to 1.24 - removed deprecated run.timeout configuration * update to go 1.25 and baseimage v1.17.0 - updated go.mod to go 1.25 - updated Dockerfile to use buildgo-v1.17.0 (go 1.25.0) - updated Dockerfile to use app-v1.17.0 * fix flaky tests with proper synchronization - use assert.Eventually instead of fixed sleep in TestService_Many - wait for webhook before shutdown in TestMain_WithWebhook - fixes race conditions exposed by Go 1.25 scheduler changes * fix data race in MockDest.closed field - add IsClosed() method with proper locking - add locking to String() method - use IsClosed() in tests instead of direct field access - fixes race condition detected by go test -race * update example go.mod to go 1.25 * update golangci-lint to v2.6.0 for go 1.25 support * fix linter issue and update CLAUDE.md - merge conditional assignment in example accessor/data.go - add reminder in CLAUDE.md to always test and lint examples before committing * update example Dockerfile to baseimage v1.17.0 for go 1.25
81 lines
1.7 KiB
Go
81 lines
1.7 KiB
Go
package notify
|
|
|
|
import (
|
|
"context"
|
|
"fmt"
|
|
"sync"
|
|
"time"
|
|
|
|
log "github.com/go-pkgz/lgr"
|
|
)
|
|
|
|
// MockDest is a destination mock
|
|
type MockDest struct {
|
|
data []Request
|
|
verificationData []VerificationRequest
|
|
id int
|
|
closed bool
|
|
lock sync.Mutex
|
|
}
|
|
|
|
// Send mock
|
|
func (m *MockDest) Send(ctx context.Context, r Request) error {
|
|
m.lock.Lock()
|
|
defer m.lock.Unlock()
|
|
select {
|
|
case <-time.After(10 * time.Millisecond):
|
|
m.data = append(m.data, r)
|
|
log.Printf("sent %s -> %d", r.Comment.ID, m.id)
|
|
case <-ctx.Done():
|
|
log.Printf("ctx closed %d", m.id)
|
|
m.closed = true
|
|
}
|
|
return nil
|
|
}
|
|
|
|
// SendVerification mock
|
|
func (m *MockDest) SendVerification(ctx context.Context, v VerificationRequest) error {
|
|
m.lock.Lock()
|
|
defer m.lock.Unlock()
|
|
select {
|
|
case <-time.After(10 * time.Millisecond):
|
|
m.verificationData = append(m.verificationData, v)
|
|
log.Printf("sent verification %s -> %d", v.User, m.id)
|
|
case <-ctx.Done():
|
|
log.Printf("verification ctx closed %d", m.id)
|
|
m.closed = true
|
|
}
|
|
return nil
|
|
}
|
|
|
|
// Get mock
|
|
func (m *MockDest) Get() []Request {
|
|
m.lock.Lock()
|
|
defer m.lock.Unlock()
|
|
res := make([]Request, len(m.data))
|
|
copy(res, m.data)
|
|
return res
|
|
}
|
|
|
|
// GetVerify mock
|
|
func (m *MockDest) GetVerify() []VerificationRequest {
|
|
m.lock.Lock()
|
|
defer m.lock.Unlock()
|
|
res := make([]VerificationRequest, len(m.verificationData))
|
|
copy(res, m.verificationData)
|
|
return res
|
|
}
|
|
|
|
// IsClosed returns closed status safely
|
|
func (m *MockDest) IsClosed() bool {
|
|
m.lock.Lock()
|
|
defer m.lock.Unlock()
|
|
return m.closed
|
|
}
|
|
|
|
func (m *MockDest) String() string {
|
|
m.lock.Lock()
|
|
defer m.lock.Unlock()
|
|
return fmt.Sprintf("mock id=%d, closed=%v", m.id, m.closed)
|
|
}
|