path: root/state.go

package eduvpn

import (
	"github.com/jwijenbergh/eduvpn-common/internal/config"
	"github.com/jwijenbergh/eduvpn-common/internal/discovery"
	"github.com/jwijenbergh/eduvpn-common/internal/fsm"
	"github.com/jwijenbergh/eduvpn-common/internal/log"
	"github.com/jwijenbergh/eduvpn-common/internal/server"
	"github.com/jwijenbergh/eduvpn-common/internal/types"
)

type VPNState struct {
	// The chosen server
	Servers server.Servers `json:"servers"`

	// The list of servers and organizations from disco
	Discovery discovery.Discovery `json:"-"`

	// The fsm
	FSM fsm.FSM `json:"-"`

	// The logger
	Logger log.FileLogger `json:"-"`

	// The config
	Config config.Config `json:"-"`

	// Whether to enable debugging
	Debug bool `json:"-"`

	// Serialized connection identifier
	Identifier string `json:"identifier"`
}

func (state *VPNState) GetSavedServers() string {
	serversJSON, serversJSONErr := state.Servers.GetJSON()

	if serversJSONErr != nil {
		return ""
	}

	return serversJSON
}

func (state *VPNState) Register(name string, directory string, stateCallback func(string, string, string), debug bool) error {
	errorMessage := "failed to register with the GO library"
	if !state.FSM.InState(fsm.DEREGISTERED) {
		return &types.WrappedErrorMessage{Message: errorMessage, Err: fsm.DeregisteredError{}.CustomError()}
	}
	// Initialize the logger
	logLevel := log.LOG_WARNING

	if debug {
		logLevel = log.LOG_INFO
	}

	loggerErr := state.Logger.Init(logLevel, name, directory)
	if loggerErr != nil {
		return &types.WrappedErrorMessage{Message: errorMessage, Err: loggerErr}
	}

	// Initialize the FSM
	state.FSM.Init(name, stateCallback, &state.Logger, directory, debug)
	state.Debug = debug

	// Initialize the Config
	state.Config.Init(name, directory)

	// Initialize Discovery
	state.Discovery.Init(&state.FSM, &state.Logger)

	// Try to load the previous configuration
	if state.Config.Load(&state) != nil {
		// This error can be safely ignored, as when the config does not load, the struct will not be filled
		state.Logger.Log(log.LOG_INFO, "Previous configuration not found")
	}

	// Go to the No Server state with the saved servers
	state.FSM.GoTransitionWithData(fsm.NO_SERVER, state.GetSavedServers(), false)
	return nil
}

func (state *VPNState) Deregister() error {
	// Close the log file
	state.Logger.Close()

	// Save the config
	state.Config.Save(&state)

	// Empty out the state
	*state = VPNState{}
	return nil
}

func (state *VPNState) CancelOAuth() error {
	errorMessage := "failed to cancel OAuth"
	if !state.FSM.InState(fsm.OAUTH_STARTED) {
		return &types.WrappedErrorMessage{Message: errorMessage, Err: fsm.WrongStateError{Got: state.FSM.Current, Want: fsm.OAUTH_STARTED}.CustomError()}
	}

	currentServer, serverErr := state.Servers.GetCurrentServer()

	if serverErr != nil {
		return &types.WrappedErrorMessage{Message: errorMessage, Err: serverErr}
	}
	server.CancelOAuth(currentServer)
	return nil
}

func (state *VPNState) chooseServer(url string, isSecureInternet bool) (server.Server, error) {
	// New server chosen, ensure the server is fresh
	server, serverErr := state.Servers.EnsureServer(url, isSecureInternet, &state.FSM, &state.Logger)

	if serverErr != nil {
		return nil, &types.WrappedErrorMessage{Message: "failed to choose server", Err: serverErr}
	}

	// Make sure we are in the chosen state if available
	state.FSM.GoTransition(fsm.CHOSEN_SERVER)
	return server, nil
}

func (state *VPNState) getConfigWithOptions(url string, isSecureInternet bool, forceTCP bool) (string, string, error) {
	errorMessage := "failed to get a configuration for OpenVPN/Wireguard"
	if state.FSM.InState(fsm.DEREGISTERED) {
		return "", "", &types.WrappedErrorMessage{Message: errorMessage, Err: fsm.DeregisteredError{}.CustomError()}
	}

	// Go to no server if possible, else return an error
	if !state.FSM.InState(fsm.NO_SERVER) && !state.FSM.GoTransition(fsm.NO_SERVER) {
		return "", "", &types.WrappedErrorMessage{Message: errorMessage, Err: fsm.WrongStateTransitionError{Got: state.FSM.Current, Want: fsm.NO_SERVER}.CustomError()}
	}

	// Make sure the server is chosen
	chosenServer, serverErr := state.chooseServer(url, isSecureInternet)

	if serverErr != nil {
		return "", "", &types.WrappedErrorMessage{Message: errorMessage, Err: serverErr}
	}
	// Relogin with oauth
	// This moves the state to authorized
	if server.NeedsRelogin(chosenServer) {
		loginErr := server.Login(chosenServer)

		if loginErr != nil {
			// We are possibly in oauth started
			// So go to no server
			state.FSM.GoTransition(fsm.NO_SERVER)
			return "", "", &types.WrappedErrorMessage{Message: errorMessage, Err: loginErr}
		}
	} else { // OAuth was valid, ensure we are in the authorized state
		state.FSM.GoTransition(fsm.AUTHORIZED)
	}

	state.FSM.GoTransition(fsm.REQUEST_CONFIG)

	config, configType, configErr := server.GetConfig(chosenServer, forceTCP)

	if configErr != nil {
		// Go back to no server if possible
		state.FSM.GoTransition(fsm.NO_SERVER)
		return "", "", &types.WrappedErrorMessage{Message: errorMessage, Err: configErr}
	} else {
		state.FSM.GoTransition(fsm.HAS_CONFIG)
	}

	return config, configType, nil
}

func (state *VPNState) GetConfigInstituteAccess(url string, forceTCP bool) (string, string, error) {
	return state.getConfigWithOptions(url, false, forceTCP)
}

func (state *VPNState) GetConfigSecureInternet(url string, forceTCP bool) (string, string, error) {
	return state.getConfigWithOptions(url, true, forceTCP)
}

func (state *VPNState) GetDiscoOrganizations() (string, error) {
	if state.FSM.InState(fsm.DEREGISTERED) {
		return "", &types.WrappedErrorMessage{Message: "failed to get the organizations with Discovery", Err: fsm.DeregisteredError{}.CustomError()}
	}
	return state.Discovery.GetOrganizationsList()
}

func (state *VPNState) GetDiscoServers() (string, error) {
	if state.FSM.InState(fsm.DEREGISTERED) {
		return "", &types.WrappedErrorMessage{Message: "failed to get the servers with Discovery", Err: fsm.DeregisteredError{}.CustomError()}
	}
	return state.Discovery.GetServersList()
}

func (state *VPNState) SetProfileID(profileID string) error {
	errorMessage := "failed to set the profile ID for the current server"
	if !state.FSM.InState(fsm.ASK_PROFILE) {
		return &types.WrappedErrorMessage{Message: errorMessage, Err: fsm.WrongStateError{Got: state.FSM.Current, Want: fsm.ASK_PROFILE}.CustomError()}
	}

	server, serverErr := state.Servers.GetCurrentServer()
	if serverErr != nil {
		return &types.WrappedErrorMessage{Message: errorMessage, Err: serverErr}
	}

	base, baseErr := server.GetBase()

	if baseErr != nil {
		return &types.WrappedErrorMessage{Message: errorMessage, Err: baseErr}
	}
	base.Profiles.Current = profileID
	return nil
}

func (state *VPNState) GetIdentifier() string {
	return state.Identifier
}

func (state *VPNState) SetIdentifier(identifier string) {
	state.Identifier = identifier
}

func (state *VPNState) SetSearchServer() error {
	if !state.FSM.HasTransition(fsm.SEARCH_SERVER) {
		return &types.WrappedErrorMessage{Message: "failed to set search server", Err: fsm.WrongStateTransitionError{Got: state.FSM.Current, Want: fsm.CONNECTED}.CustomError()}
	}

	state.FSM.GoTransition(fsm.SEARCH_SERVER)
	return nil
}

func (state *VPNState) SetConnected() error {
	if !state.FSM.HasTransition(fsm.CONNECTED) {
		return &types.WrappedErrorMessage{Message: "failed to set connected", Err: fsm.WrongStateTransitionError{Got: state.FSM.Current, Want: fsm.CONNECTED}.CustomError()}
	}

	state.FSM.GoTransition(fsm.CONNECTED)
	return nil
}

func (state *VPNState) SetDisconnected() error {
	if !state.FSM.HasTransition(fsm.HAS_CONFIG) {
		return &types.WrappedErrorMessage{Message: "failed to set disconnected", Err: fsm.WrongStateTransitionError{Got: state.FSM.Current, Want: fsm.HAS_CONFIG}.CustomError()}
	}

	state.FSM.GoTransition(fsm.HAS_CONFIG)
	return nil
}

func (state *VPNState) GetErrorTraceback(err error) string {
	return types.GetErrorTraceback(err)
}

func (state *VPNState) GetErrorCause(err error) error {
	return types.GetErrorCause(err)
}