64 lines
1.1 KiB
Go
64 lines
1.1 KiB
Go
package util
|
|
|
|
import "sync"
|
|
|
|
type AuthCollection struct {
|
|
mu sync.Mutex
|
|
paramC chan<- Param
|
|
vehicles map[string]*AuthProvider
|
|
}
|
|
|
|
func NewAuthCollection(paramC chan<- Param) *AuthCollection {
|
|
return &AuthCollection{
|
|
paramC: paramC,
|
|
vehicles: make(map[string]*AuthProvider),
|
|
}
|
|
}
|
|
|
|
func (ac *AuthCollection) Register(title, baseURI string) *AuthProvider {
|
|
ap := &AuthProvider{
|
|
ac: ac,
|
|
Uri: baseURI,
|
|
}
|
|
|
|
ac.mu.Lock()
|
|
ac.vehicles[title] = ap
|
|
ac.mu.Unlock()
|
|
|
|
return ap
|
|
}
|
|
|
|
// publish routes and status
|
|
func (ac *AuthCollection) Publish() {
|
|
ac.mu.Lock()
|
|
defer ac.mu.Unlock()
|
|
|
|
val := struct {
|
|
Vehicles map[string]*AuthProvider `json:"vehicles"`
|
|
}{
|
|
Vehicles: ac.vehicles,
|
|
}
|
|
|
|
ac.paramC <- Param{Key: "auth", Val: val}
|
|
}
|
|
|
|
type AuthProvider struct {
|
|
ac *AuthCollection
|
|
Uri string `json:"uri"`
|
|
Authenticated bool `json:"authenticated"`
|
|
}
|
|
|
|
func (ap *AuthProvider) Handler() chan<- bool {
|
|
c := make(chan bool)
|
|
|
|
go func() {
|
|
for auth := range c {
|
|
ap.ac.mu.Lock()
|
|
ap.Authenticated = auth
|
|
ap.ac.mu.Unlock()
|
|
ap.ac.Publish()
|
|
}
|
|
}()
|
|
|
|
return c
|
|
}
|