// Copyright (c) 2015-2021 MinIO, Inc. // // This file is part of MinIO Object Storage stack // // This program is free software: you can redistribute it and/or modify // it under the terms of the GNU Affero General Public License as published by // the Free Software Foundation, either version 3 of the License, or // (at your option) any later version. // // This program is distributed in the hope that it will be useful // but WITHOUT ANY WARRANTY; without even the implied warranty of // MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the // GNU Affero General Public License for more details. // // You should have received a copy of the GNU Affero General Public License // along with this program. If not, see . package cmd import ( "net/http" "github.com/gorilla/mux" ) // Composed function registering routers for only distributed Erasure setup. func registerDistErasureRouters(router *mux.Router, endpointServerPools EndpointServerPools) { // Register storage REST router only if its a distributed setup. registerStorageRESTHandlers(router, endpointServerPools) // Register peer REST router only if its a distributed setup. registerPeerRESTHandlers(router) // Register bootstrap REST router for distributed setups. registerBootstrapRESTHandlers(router) // Register distributed namespace lock routers. registerLockRESTHandlers(router) } // List of some generic handlers which are applied for all incoming requests. var globalHandlers = []mux.MiddlewareFunc{ // Auth handler verifies incoming authorization headers and // routes them accordingly. Client receives a HTTP error for // invalid/unsupported signatures. // // Validates all incoming requests to have a valid date header. setAuthHandler, // Redirect some pre-defined browser request paths to a static location prefix. setBrowserRedirectHandler, // Adds 'crossdomain.xml' policy handler to serve legacy flash clients. setCrossDomainPolicy, // Limits all body and header sizes to a maximum fixed limit setRequestLimitHandler, // Network statistics setHTTPStatsHandler, // Validate all the incoming requests. setRequestValidityHandler, // set x-amz-request-id header. addCustomHeaders, // Add new handlers here. } // configureServer handler returns final handler for the http server. func configureServerHandler(endpointServerPools EndpointServerPools) (http.Handler, error) { // Initialize router. `SkipClean(true)` stops gorilla/mux from // normalizing URL path minio/minio#3256 router := mux.NewRouter().SkipClean(true).UseEncodedPath() // Initialize distributed NS lock. if globalIsDistErasure { registerDistErasureRouters(router, endpointServerPools) } // Add Admin router, all APIs are enabled in server mode. registerAdminRouter(router, true) // Add healthcheck router registerHealthCheckRouter(router) // Add server metrics router registerMetricsRouter(router) // Add STS router always. registerSTSRouter(router) // Add API router registerAPIRouter(router) // Enable bucket forwarding handler only if bucket federation is enabled. if globalDNSConfig != nil && globalBucketFederation { globalHandlers = append(globalHandlers, setBucketForwardingHandler) } router.Use(globalHandlers...) return router, nil }