45 lines
675 B
Go
45 lines
675 B
Go
package global
|
|
|
|
import (
|
|
"github.com/gorilla/websocket"
|
|
"github.com/pkg/sftp"
|
|
"next-terminal/pkg/guacd"
|
|
"sync"
|
|
)
|
|
|
|
type Tun struct {
|
|
Tunnel *guacd.Tunnel
|
|
SftpClient *sftp.Client
|
|
WebSocket *websocket.Conn
|
|
}
|
|
|
|
type Observable struct {
|
|
Subject *Tun
|
|
Observers []Tun
|
|
}
|
|
|
|
type TunStore struct {
|
|
m sync.Map
|
|
}
|
|
|
|
func (s *TunStore) Set(k string, v *Observable) {
|
|
s.m.Store(k, v)
|
|
}
|
|
|
|
func (s *TunStore) Del(k string) {
|
|
s.m.Delete(k)
|
|
}
|
|
|
|
func (s *TunStore) Get(k string) (item *Observable, ok bool) {
|
|
value, ok := s.m.Load(k)
|
|
if ok {
|
|
return value.(*Observable), true
|
|
}
|
|
return item, false
|
|
}
|
|
|
|
func NewStore() *TunStore {
|
|
store := TunStore{sync.Map{}}
|
|
return &store
|
|
}
|