Method serverList

control/methods.go:212–252

(writer http.ResponseWriter, request *http.Request )

var cacheControlRegex = regexp.MustCompile( "[[:space:]]*max-age[[:space:]]*=[[:space:]]*([[:digit:]]+)" )

func ( s *Server ) serverList(writer http.ResponseWriter, request *http.Request ) {
	if request.Method != "GET" { http.Error( writer, http.StatusText( http.StatusNotFound ), http.StatusNotFound ); return }
	select {
		case s.connectionOpsLock<-struct{}{}: defer func() { <-s.connectionOpsLock }(); break
		case <-time.NewTimer( time.Second ).C: http.Error( writer, http.StatusText( http.StatusConflict ), http.StatusConflict ); return
	}
	
	if slb := s.serverListBytes.Load(); slb != nil { writer.Header().Add( "content-type", "application/json" ); writer.Write( *slb ); log.Println( "sLst: ServerList sent" ); return }
	
	s.connection.Lock(); defer s.connection.Unlock()
	
	client := rest.New( s.connection.Config.Rest )																										// Create a REST client ( must be a new one since FetchServerList changes client's configuration )
	
	dohResolver := doh.New( s.connection.Config.DoH )																									// Create a DoH resolver
	dohResolver.Init()
	client.SetDohResolver(dohResolver)
	
	plainResolver := plain.New( s.connection.Config.Plain )																								// Create a Plain resolver
	if err := plainResolver.Init(); err != nil { log.Println( "sLst: [ERR] Plain resolver init failed", err ); http.Error( writer, err.Error(), http.StatusBadGateway ); return }
	client.SetPlainResolver(plainResolver)
	
	ctx, cancel := context.WithTimeout( context.Background(), s.connection.Config.Rest.RestTimeout )
	defer cancel()
	
	response, headers, err := client.FetchServerList( ctx )
	if err != nil { log.Println( "sLst: [ERR] Server list fetch failed:", err ); http.Error( writer, err.Error(), http.StatusBadGateway ); return }
	
	if maxAgeMatches := cacheControlRegex.FindStringSubmatch( headers.Get( "cache-control" ) ); len( maxAgeMatches ) > 1 {
		if maxAge, err := strconv.ParseInt( maxAgeMatches[1], 10, 64 ); err == nil {
			s.serverListBytes.Store( &response )
			ttl := time.Duration( maxAge ) * time.Second
			time.AfterFunc( ttl, func() { s.serverListBytes.Store( nil ); log.Println( "sLst: Server list expired" ) } )
			log.Println( "sLst: Caching server list for", ttl )
		}
	}

	writer.Header().Add( "content-type", "application/json" )
	writer.Write( response )
	
	log.Println( "sLst: ServerList sent" )
}

func ( s *Server ) externalIps(writer http.ResponseWriter, request *http.Request ) {
	if request.Method != "GET" { http.Error( writer, http.StatusText( http.StatusNotFound ), http.StatusNotFound ); return }