2cf86703a3
* Initial Webserver Draft for Version Controlling * Rename type to avoid confusion * Move Function Calls into Version Package * Fix Linting and Language Typos * Fix Linting and Spelling Mistakes * Include Copyright * Include Copyright * Adjust Version-Control Server to return list of Versions * Linting * Improve Request Handling and Readability * Add Configuration File Option Add Systemd Service file * Add Logging to File * Smaller Changes * Add Semantic Versioning and refuses outdated Software from Startup (#1612) * implements internal Semantic Version library * adds version logging + reporting to process * Advance SemVer struct for easier handling * Add Accepted Version Store * Fix Function * Restructure * Type Conversion * Handle Version String properly * Add Note about array index * Set temporary Default Version * Add Copyright * Adding Version to Dashboard * Adding Version Info Log * Renaming and adding CheckerProcess * Iteration Sync * Iteration V2 * linting * made LogAndReportVersion a go routine * Refactor to Go Routine * Add Context to Go Routine and allow Operation if Lookup to Control Server fails * Handle Unmarshal properly * Linting * Relocate Version Checks * Relocating Version Check and specified default Version for now * Linting Error Prevention * Refuse Startup on outdated Version * Add Startup Check Function * Straighten Logging * Dont force Shutdown if --dev flag is set * Create full Service/Peer Structure for ControlServer * Linting * Straighting Naming * Finish VersionControl Service Layout * Improve Error Handling * Change Listening Address * Move Checker Function * Remove VersionControl Peer * Linting * Linting * Create VersionClient Service * Renaming * Add Version Client to Peer Definitions * Linting and Renaming * Linting * Remove Transport Checks for now * Move to Client Side Flag * Remove check * Linting * Transport Client Version Intro * Adding Version Client to Transport Client * Add missing parameter * Adding Version Check, to set Allowed = true * Set Default to true, testing * Restructuring Code * Uplink Changes * Add more proper Defaults * Renaming of Version struct * Dont pass Service use Pointer * Set Defaults for Versioning Checks * Put HTTP Server in go routine * Add Versioncontrol to Storj-Sim * Testplanet Fixes * Linting * Add Error Handling and new Server Struct * Move Lock slightly * Reduce Race Potentials * Remove unnecessary files * Linting * Add Proper Transport Handling * small fixes * add fence for allowed check * Add Startup Version Check and Service Naming * make errormessage private * Add Comments about VersionedClient * Linting * Remove Checks that refuse outgoing connections * Remove release cmd * Add Release Script * Linting * Update to use correct Values * Move vars private and set minimum default versions for testing builds * Remove VersionedClient * Better Error Handling and naked return removal * Straighten the Regex and string conversion * Change Check to allows testplanet and storj-sim to run without the need to pass an LDFlag * Cosmetic Change to Dashboard * Cleanup Returns and remove commented code * Remove Version Check if no build options are passed in * Pass in Config Values instead of Pointers * Handle missed Error * Update Endpoint URL * Change Type of Release Flag * Add additional Logging * Remove Versions Logging of other Services * minor fixes Change-Id: I5cc04a410ea6b2008d14dffd63eb5f36dd348a8b
147 lines
4.1 KiB
Go
147 lines
4.1 KiB
Go
// Copyright (C) 2019 Storj Labs, Inc.
|
|
// See LICENSE for copying information.
|
|
|
|
package versioncontrol
|
|
|
|
import (
|
|
"context"
|
|
"encoding/json"
|
|
"net"
|
|
"net/http"
|
|
"strings"
|
|
|
|
"github.com/zeebo/errs"
|
|
"go.uber.org/zap"
|
|
"golang.org/x/sync/errgroup"
|
|
|
|
"storj.io/storj/internal/version"
|
|
)
|
|
|
|
// Config is all the configuration parameters for a Version Control Server
|
|
type Config struct {
|
|
Address string `user:"true" help:"public address to listen on" default:":8080"`
|
|
Versions ServiceVersions
|
|
}
|
|
|
|
// ServiceVersions provides a list of allowed Versions per Service
|
|
type ServiceVersions struct {
|
|
Bootstrap string `user:"true" help:"Allowed Bootstrap Versions" default:"v0.0.1"`
|
|
Satellite string `user:"true" help:"Allowed Satellite Versions" default:"v0.0.1"`
|
|
Storagenode string `user:"true" help:"Allowed Storagenode Versions" default:"v0.0.1"`
|
|
Uplink string `user:"true" help:"Allowed Uplink Versions" default:"v0.0.1"`
|
|
Gateway string `user:"true" help:"Allowed Gateway Versions" default:"v0.0.1"`
|
|
}
|
|
|
|
// Peer is the representation of a VersionControl Server.
|
|
type Peer struct {
|
|
// core dependencies
|
|
Log *zap.Logger
|
|
|
|
// Web server
|
|
Server struct {
|
|
Endpoint http.Server
|
|
Listener net.Listener
|
|
}
|
|
Versions version.AllowedVersions
|
|
|
|
// response contains the byte version of current allowed versions
|
|
response []byte
|
|
}
|
|
|
|
func ignoreCancel(err error) error {
|
|
if err == context.Canceled || err == http.ErrServerClosed {
|
|
return nil
|
|
}
|
|
return err
|
|
}
|
|
|
|
// HandleGet contains the request handler for the version control web server
|
|
func (peer *Peer) HandleGet(w http.ResponseWriter, r *http.Request) {
|
|
// Only handle GET Requests
|
|
if r.Method != http.MethodGet {
|
|
http.Error(w, "method not allowed", http.StatusMethodNotAllowed)
|
|
return
|
|
}
|
|
|
|
var xfor string
|
|
if xfor = r.Header.Get("X-Forwarded-For"); xfor == "" {
|
|
xfor = r.RemoteAddr
|
|
}
|
|
zap.S().Debugf("Request from: %s for %s", r.RemoteAddr, xfor)
|
|
|
|
w.Header().Set("Content-Type", "application/json")
|
|
_, err := w.Write(peer.response)
|
|
if err != nil {
|
|
zap.S().Errorf("error writing response to client: %v", err)
|
|
}
|
|
}
|
|
|
|
// New creates a new VersionControl Server.
|
|
func New(log *zap.Logger, config *Config) (peer *Peer, err error) {
|
|
peer = &Peer{
|
|
Log: log,
|
|
}
|
|
|
|
// Convert each Service's Version String to List of SemVer
|
|
bootstrapVersions := strings.Split(config.Versions.Bootstrap, ",")
|
|
peer.Versions.Bootstrap, err = version.StrToSemVerList(bootstrapVersions)
|
|
|
|
satelliteVersions := strings.Split(config.Versions.Satellite, ",")
|
|
peer.Versions.Satellite, err = version.StrToSemVerList(satelliteVersions)
|
|
|
|
storagenodeVersions := strings.Split(config.Versions.Storagenode, ",")
|
|
peer.Versions.Storagenode, err = version.StrToSemVerList(storagenodeVersions)
|
|
|
|
uplinkVersions := strings.Split(config.Versions.Uplink, ",")
|
|
peer.Versions.Uplink, err = version.StrToSemVerList(uplinkVersions)
|
|
|
|
gatewayVersions := strings.Split(config.Versions.Gateway, ",")
|
|
peer.Versions.Gateway, err = version.StrToSemVerList(gatewayVersions)
|
|
|
|
peer.response, err = json.Marshal(peer.Versions)
|
|
|
|
if err != nil {
|
|
peer.Log.Sugar().Fatalf("Error marshalling version info: %v", err)
|
|
}
|
|
|
|
peer.Log.Sugar().Debugf("setting version info to: %v", string(peer.response))
|
|
|
|
mux := http.NewServeMux()
|
|
mux.HandleFunc("/", peer.HandleGet)
|
|
peer.Server.Endpoint = http.Server{
|
|
Handler: mux,
|
|
}
|
|
|
|
peer.Server.Listener, err = net.Listen("tcp", config.Address)
|
|
if err != nil {
|
|
return nil, errs.Combine(err, peer.Close())
|
|
}
|
|
return peer, nil
|
|
}
|
|
|
|
// Run runs versioncontrol server until it's either closed or it errors.
|
|
func (peer *Peer) Run(ctx context.Context) (err error) {
|
|
|
|
ctx, cancel := context.WithCancel(ctx)
|
|
var group errgroup.Group
|
|
|
|
group.Go(func() error {
|
|
<-ctx.Done()
|
|
return ignoreCancel(peer.Server.Endpoint.Shutdown(ctx))
|
|
})
|
|
group.Go(func() error {
|
|
defer cancel()
|
|
peer.Log.Sugar().Infof("Versioning server started on %s", peer.Addr())
|
|
return ignoreCancel(peer.Server.Endpoint.Serve(peer.Server.Listener))
|
|
})
|
|
return group.Wait()
|
|
}
|
|
|
|
// Close closes all the resources.
|
|
func (peer *Peer) Close() (err error) {
|
|
return peer.Server.Endpoint.Close()
|
|
}
|
|
|
|
// Addr returns the public address.
|
|
func (peer *Peer) Addr() string { return peer.Server.Listener.Addr().String() }
|