mirror of https://github.com/fatedier/frp
You can not select more than 25 topics
Topics must start with a letter or number, can include dashes ('-') and can be up to 35 characters long.
115 lines
1.9 KiB
115 lines
1.9 KiB
package vhost
|
|
|
|
import (
|
|
"sort"
|
|
"strings"
|
|
"sync"
|
|
)
|
|
|
|
type VhostRouters struct {
|
|
RouterByDomain map[string][]*VhostRouter
|
|
mutex sync.RWMutex
|
|
}
|
|
|
|
type VhostRouter struct {
|
|
domain string
|
|
location string
|
|
listener *Listener
|
|
}
|
|
|
|
func NewVhostRouters() *VhostRouters {
|
|
return &VhostRouters{
|
|
RouterByDomain: make(map[string][]*VhostRouter),
|
|
}
|
|
}
|
|
|
|
func (r *VhostRouters) Add(domain, location string, l *Listener) {
|
|
r.mutex.Lock()
|
|
defer r.mutex.Unlock()
|
|
|
|
vrs, found := r.RouterByDomain[domain]
|
|
if !found {
|
|
vrs = make([]*VhostRouter, 0, 1)
|
|
}
|
|
|
|
vr := &VhostRouter{
|
|
domain: domain,
|
|
location: location,
|
|
listener: l,
|
|
}
|
|
vrs = append(vrs, vr)
|
|
|
|
sort.Sort(sort.Reverse(ByLocation(vrs)))
|
|
r.RouterByDomain[domain] = vrs
|
|
}
|
|
|
|
func (r *VhostRouters) Del(domain, location string) {
|
|
r.mutex.Lock()
|
|
defer r.mutex.Unlock()
|
|
|
|
vrs, found := r.RouterByDomain[domain]
|
|
if !found {
|
|
return
|
|
}
|
|
|
|
for i, vr := range vrs {
|
|
if vr.location == location {
|
|
if len(vrs) > i+1 {
|
|
r.RouterByDomain[domain] = append(vrs[:i], vrs[i+1:]...)
|
|
} else {
|
|
r.RouterByDomain[domain] = vrs[:i]
|
|
}
|
|
}
|
|
}
|
|
}
|
|
|
|
func (r *VhostRouters) Get(host, path string) (vr *VhostRouter, exist bool) {
|
|
r.mutex.RLock()
|
|
defer r.mutex.RUnlock()
|
|
|
|
vrs, found := r.RouterByDomain[host]
|
|
if !found {
|
|
return
|
|
}
|
|
|
|
// can't support load balance, will to do
|
|
for _, vr = range vrs {
|
|
if strings.HasPrefix(path, vr.location) {
|
|
return vr, true
|
|
}
|
|
}
|
|
|
|
return
|
|
}
|
|
|
|
func (r *VhostRouters) Exist(host, path string) (vr *VhostRouter, exist bool) {
|
|
r.mutex.RLock()
|
|
defer r.mutex.RUnlock()
|
|
|
|
vrs, found := r.RouterByDomain[host]
|
|
if !found {
|
|
return
|
|
}
|
|
|
|
for _, vr = range vrs {
|
|
if path == vr.location {
|
|
return vr, true
|
|
}
|
|
}
|
|
|
|
return
|
|
}
|
|
|
|
// sort by location
|
|
type ByLocation []*VhostRouter
|
|
|
|
func (a ByLocation) Len() int {
|
|
return len(a)
|
|
}
|
|
func (a ByLocation) Swap(i, j int) {
|
|
a[i], a[j] = a[j], a[i]
|
|
}
|
|
func (a ByLocation) Less(i, j int) bool {
|
|
return strings.Compare(a[i].location, a[j].location) < 0
|
|
}
|