// ⚡️ Fiber is an Express inspired web framework written in Go with ☕️ // 🤖 Github Repository: https://github.com/gofiber/fiber // 📌 API Documentation: https://docs.gofiber.io package fiber import ( "bytes" "encoding/xml" "errors" "fmt" "io" "mime/multipart" "net/http" "path/filepath" "strconv" "strings" "sync" "text/template" "time" "github.com/gofiber/fiber/v2/internal/bytebufferpool" "github.com/gofiber/fiber/v2/internal/encoding/json" "github.com/gofiber/fiber/v2/internal/schema" "github.com/gofiber/fiber/v2/utils" "github.com/valyala/fasthttp" ) // maxParams defines the maximum number of parameters per route. const maxParams = 30 // Ctx represents the Context which hold the HTTP request and response. // It has methods for the request query string, parameters, body, HTTP headers and so on. type Ctx struct { app *App // Reference to *App route *Route // Reference to *Route indexRoute int // Index of the current route indexHandler int // Index of the current handler method string // HTTP method methodINT int // HTTP method INT equivalent path string // Prettified HTTP path -> string copy from pathBuffer pathBuffer []byte // Prettified HTTP path buffer treePath string // Path for the search in the tree pathOriginal string // Original HTTP path values [maxParams]string // Route parameter values fasthttp *fasthttp.RequestCtx // Reference to *fasthttp.RequestCtx matched bool // Non use route matched } // Range data for c.Range type Range struct { Type string Ranges []struct { Start int End int } } // Cookie data for c.Cookie type Cookie struct { Name string `json:"name"` Value string `json:"value"` Path string `json:"path"` Domain string `json:"domain"` Expires time.Time `json:"expires"` Secure bool `json:"secure"` HTTPOnly bool `json:"http_only"` SameSite string `json:"same_site"` } // Views is the interface that wraps the Render function. type Views interface { Load() error Render(io.Writer, string, interface{}, ...string) error } // AcquireCtx retrieves a new Ctx from the pool. func (app *App) AcquireCtx(fctx *fasthttp.RequestCtx) *Ctx { c := app.pool.Get().(*Ctx) // Set app reference c.app = app // Reset route and handler index c.indexRoute = -1 c.indexHandler = 0 // Reset matched flag c.matched = false // Set paths c.pathBuffer = append(c.pathBuffer[0:0], fctx.URI().PathOriginal()...) c.pathOriginal = getString(fctx.URI().PathOriginal()) // Set method c.method = getString(fctx.Request.Header.Method()) c.methodINT = methodInt(c.method) // Attach *fasthttp.RequestCtx to ctx c.fasthttp = fctx // Prettify path c.prettifyPath() return c } // ReleaseCtx releases the ctx back into the pool. func (app *App) ReleaseCtx(c *Ctx) { // Reset values c.route = nil c.fasthttp = nil app.pool.Put(c) } // Accepts checks if the specified extensions or content types are acceptable. func (c *Ctx) Accepts(offers ...string) string { if len(offers) == 0 { return "" } header := c.Get(HeaderAccept) if header == "" { return offers[0] } spec, commaPos := "", 0 for len(header) > 0 && commaPos != -1 { commaPos = strings.IndexByte(header, ',') if commaPos != -1 { spec = utils.Trim(header[:commaPos], ' ') } else { spec = header } if factorSign := strings.IndexByte(spec, ';'); factorSign != -1 { spec = spec[:factorSign] } for _, offer := range offers { mimetype := utils.GetMIME(offer) if len(spec) > 2 && spec[len(spec)-2:] == "/*" { if strings.HasPrefix(spec[:len(spec)-2], strings.Split(mimetype, "/")[0]) { return offer } else if spec == "*/*" { return offer } } else if strings.HasPrefix(spec, mimetype) { return offer } } if commaPos != -1 { header = header[commaPos+1:] } } return "" } // AcceptsCharsets checks if the specified charset is acceptable. func (c *Ctx) AcceptsCharsets(offers ...string) string { return getOffer(c.Get(HeaderAcceptCharset), offers...) } // AcceptsEncodings checks if the specified encoding is acceptable. func (c *Ctx) AcceptsEncodings(offers ...string) string { return getOffer(c.Get(HeaderAcceptEncoding), offers...) } // AcceptsLanguages checks if the specified language is acceptable. func (c *Ctx) AcceptsLanguages(offers ...string) string { return getOffer(c.Get(HeaderAcceptLanguage), offers...) } // App returns the *App reference to the instance of the Fiber application func (c *Ctx) App() *App { return c.app } // Append the specified value to the HTTP response header field. // If the header is not already set, it creates the header with the specified value. func (c *Ctx) Append(field string, values ...string) { if len(values) == 0 { return } h := getString(c.fasthttp.Response.Header.Peek(field)) originalH := h for _, value := range values { if len(h) == 0 { h = value } else if h != value && !strings.HasPrefix(h, value+",") && !strings.HasSuffix(h, " "+value) && !strings.Contains(h, " "+value+",") { h += ", " + value } } if originalH != h { c.Set(field, h) } } // Attachment sets the HTTP response Content-Disposition header field to attachment. func (c *Ctx) Attachment(filename ...string) { if len(filename) > 0 { fname := filepath.Base(filename[0]) c.Type(filepath.Ext(fname)) c.setCanonical(HeaderContentDisposition, `attachment; filename="`+quoteString(fname)+`"`) return } c.setCanonical(HeaderContentDisposition, "attachment") } // BaseURL returns (protocol + host + base path). func (c *Ctx) BaseURL() string { // TODO: Could be improved: 53.8 ns/op 32 B/op 1 allocs/op // Should work like https://codeigniter.com/user_guide/helpers/url_helper.html return c.Protocol() + "://" + c.Hostname() } // Body contains the raw body submitted in a POST request. // Returned value is only valid within the handler. Do not store any references. // Make copies or use the Immutable setting instead. func (c *Ctx) Body() []byte { return c.fasthttp.Request.Body() } // decoderPool helps to improve BodyParser's and QueryParser's performance var decoderPool = &sync.Pool{New: func() interface{} { var decoder = schema.NewDecoder() decoder.IgnoreUnknownKeys(true) return decoder }} // BodyParser binds the request body to a struct. // It supports decoding the following content types based on the Content-Type header: // application/json, application/xml, application/x-www-form-urlencoded, multipart/form-data func (c *Ctx) BodyParser(out interface{}) error { // Get decoder from pool schemaDecoder := decoderPool.Get().(*schema.Decoder) defer decoderPool.Put(schemaDecoder) // Get content-type ctype := getString(c.fasthttp.Request.Header.ContentType()) // Parse body accordingly if strings.HasPrefix(ctype, MIMEApplicationJSON) { schemaDecoder.SetAliasTag("json") return json.Unmarshal(c.fasthttp.Request.Body(), out) } else if strings.HasPrefix(ctype, MIMEApplicationForm) { schemaDecoder.SetAliasTag("form") data := make(map[string][]string) c.fasthttp.PostArgs().VisitAll(func(key []byte, val []byte) { data[getString(key)] = append(data[getString(key)], getString(val)) }) return schemaDecoder.Decode(out, data) } else if strings.HasPrefix(ctype, MIMEMultipartForm) { schemaDecoder.SetAliasTag("form") data, err := c.fasthttp.MultipartForm() if err != nil { return err } return schemaDecoder.Decode(out, data.Value) } else if strings.HasPrefix(ctype, MIMETextXML) || strings.HasPrefix(ctype, MIMEApplicationXML) { schemaDecoder.SetAliasTag("xml") return xml.Unmarshal(c.fasthttp.Request.Body(), out) } // No suitable content type found return fmt.Errorf("bodyparser: cannot parse content-type: %v", ctype) } // ClearCookie expires a specific cookie by key on the client side. // If no key is provided it expires all cookies that came with the request. func (c *Ctx) ClearCookie(key ...string) { if len(key) > 0 { for i := range key { c.fasthttp.Response.Header.DelClientCookie(key[i]) } return } c.fasthttp.Request.Header.VisitAllCookie(func(k, v []byte) { c.fasthttp.Response.Header.DelClientCookieBytes(k) }) } // Context returns *fasthttp.RequestCtx that carries a deadline // a cancellation signal, and other values across API boundaries. func (c *Ctx) Context() *fasthttp.RequestCtx { return c.fasthttp } // Cookie sets a cookie by passing a cookie struct. func (c *Ctx) Cookie(cookie *Cookie) { fcookie := fasthttp.AcquireCookie() fcookie.SetKey(cookie.Name) fcookie.SetValue(cookie.Value) fcookie.SetPath(cookie.Path) fcookie.SetDomain(cookie.Domain) fcookie.SetExpire(cookie.Expires) fcookie.SetSecure(cookie.Secure) fcookie.SetHTTPOnly(cookie.HTTPOnly) switch utils.ToLower(cookie.SameSite) { case "strict": fcookie.SetSameSite(fasthttp.CookieSameSiteStrictMode) case "none": fcookie.SetSameSite(fasthttp.CookieSameSiteNoneMode) default: fcookie.SetSameSite(fasthttp.CookieSameSiteLaxMode) } c.fasthttp.Response.Header.SetCookie(fcookie) fasthttp.ReleaseCookie(fcookie) } // Cookies is used for getting a cookie value by key. // Defaults to the empty string "" if the cookie doesn't exist. // If a default value is given, it will return that value if the cookie doesn't exist. // The returned value is only valid within the handler. Do not store any references. // Make copies or use the Immutable setting to use the value outside the Handler. func (c *Ctx) Cookies(key string, defaultValue ...string) string { return defaultString(getString(c.fasthttp.Request.Header.Cookie(key)), defaultValue) } // Download transfers the file from path as an attachment. // Typically, browsers will prompt the user for download. // By default, the Content-Disposition header filename= parameter is the filepath (this typically appears in the browser dialog). // Override this default with the filename parameter. func (c *Ctx) Download(file string, filename ...string) error { var fname string if len(filename) > 0 { fname = filename[0] } else { fname = filepath.Base(file) } c.setCanonical(HeaderContentDisposition, `attachment; filename="`+quoteString(fname)+`"`) return c.SendFile(file) } // Request return the *fasthttp.Request object // This allows you to use all fasthttp request methods // https://godoc.org/github.com/valyala/fasthttp#Request func (c *Ctx) Request() *fasthttp.Request { return &c.fasthttp.Request } // Response return the *fasthttp.Response object // This allows you to use all fasthttp response methods // https://godoc.org/github.com/valyala/fasthttp#Response func (c *Ctx) Response() *fasthttp.Response { return &c.fasthttp.Response } // Format performs content-negotiation on the Accept HTTP header. // It uses Accepts to select a proper format. // If the header is not specified or there is no proper format, text/plain is used. func (c *Ctx) Format(body interface{}) error { // Get accepted content type accept := c.Accepts("html", "json", "txt", "xml") // Set accepted content type c.Type(accept) // Type convert provided body var b string switch val := body.(type) { case string: b = val case []byte: b = getString(val) default: b = fmt.Sprintf("%v", val) } // Format based on the accept content type switch accept { case "html": return c.SendString("
" + b + "
") case "json": return c.JSON(body) case "txt": return c.SendString(b) case "xml": raw, err := xml.Marshal(body) if err != nil { return fmt.Errorf("error serializing xml: %v", body) } c.fasthttp.Response.SetBody(raw) return nil } return c.SendString(b) } // FormFile returns the first file by key from a MultipartForm. func (c *Ctx) FormFile(key string) (*multipart.FileHeader, error) { return c.fasthttp.FormFile(key) } // FormValue returns the first value by key from a MultipartForm. // Defaults to the empty string "" if the form value doesn't exist. // If a default value is given, it will return that value if the form value does not exist. // Returned value is only valid within the handler. Do not store any references. // Make copies or use the Immutable setting instead. func (c *Ctx) FormValue(key string, defaultValue ...string) string { return defaultString(getString(c.fasthttp.FormValue(key)), defaultValue) } // Fresh returns true when the response is still “fresh” in the client's cache, // otherwise false is returned to indicate that the client cache is now stale // and the full response should be sent. // When a client sends the Cache-Control: no-cache request header to indicate an end-to-end // reload request, this module will return false to make handling these requests transparent. // https://github.com/jshttp/fresh/blob/10e0471669dbbfbfd8de65bc6efac2ddd0bfa057/index.js#L33 func (c *Ctx) Fresh() bool { // fields var modifiedSince = c.Get(HeaderIfModifiedSince) var noneMatch = c.Get(HeaderIfNoneMatch) // unconditional request if modifiedSince == "" && noneMatch == "" { return false } // Always return stale when Cache-Control: no-cache // to support end-to-end reload requests // https://tools.ietf.org/html/rfc2616#section-14.9.4 cacheControl := c.Get(HeaderCacheControl) if cacheControl != "" && isNoCache(cacheControl) { return false } // if-none-match if noneMatch != "" && noneMatch != "*" { var etag = getString(c.fasthttp.Response.Header.Peek(HeaderETag)) if etag == "" { return false } if isEtagStale(etag, getBytes(noneMatch)) { return false } if modifiedSince != "" { var lastModified = getString(c.fasthttp.Response.Header.Peek(HeaderLastModified)) if lastModified != "" { lastModifiedTime, err := http.ParseTime(lastModified) if err != nil { return false } modifiedSinceTime, err := http.ParseTime(modifiedSince) if err != nil { return false } return lastModifiedTime.Before(modifiedSinceTime) } } } return true } // Get returns the HTTP request header specified by field. // Field names are case-insensitive // Returned value is only valid within the handler. Do not store any references. // Make copies or use the Immutable setting instead. func (c *Ctx) Get(key string, defaultValue ...string) string { return defaultString(getString(c.fasthttp.Request.Header.Peek(key)), defaultValue) } // Hostname contains the hostname derived from the Host HTTP header. // Returned value is only valid within the handler. Do not store any references. // Make copies or use the Immutable setting instead. func (c *Ctx) Hostname() string { return getString(c.fasthttp.Request.URI().Host()) } // IP returns the remote IP address of the request. func (c *Ctx) IP() string { if len(c.app.config.ProxyHeader) > 0 { return c.Get(c.app.config.ProxyHeader) } return c.fasthttp.RemoteIP().String() } // IPs returns an string slice of IP addresses specified in the X-Forwarded-For request header. func (c *Ctx) IPs() (ips []string) { header := c.fasthttp.Request.Header.Peek(HeaderXForwardedFor) if len(header) == 0 { return } ips = make([]string, bytes.Count(header, []byte(","))+1) var commaPos, i int for { commaPos = bytes.IndexByte(header, ',') if commaPos != -1 { ips[i] = utils.Trim(getString(header[:commaPos]), ' ') header, i = header[commaPos+1:], i+1 } else { ips[i] = utils.Trim(getString(header), ' ') return } } } // Is returns the matching content type, // if the incoming request's Content-Type HTTP header field matches the MIME type specified by the type parameter func (c *Ctx) Is(extension string) bool { extensionHeader := utils.GetMIME(extension) if extensionHeader == "" { return false } return strings.HasPrefix( utils.TrimLeft(utils.GetString(c.fasthttp.Request.Header.ContentType()), ' '), extensionHeader, ) } // JSON converts any interface or string to JSON. // This method also sets the content header to application/json. func (c *Ctx) JSON(data interface{}) error { raw, err := json.Marshal(data) if err != nil { return err } c.fasthttp.Response.SetBodyRaw(raw) c.fasthttp.Response.Header.SetContentType(MIMEApplicationJSON) return nil } // JSONP sends a JSON response with JSONP support. // This method is identical to JSON, except that it opts-in to JSONP callback support. // By default, the callback name is simply callback. func (c *Ctx) JSONP(data interface{}, callback ...string) error { raw, err := json.Marshal(data) if err != nil { return err } var result, cb string if len(callback) > 0 { cb = callback[0] } else { cb = "callback" } result = cb + "(" + getString(raw) + ");" c.setCanonical(HeaderXContentTypeOptions, "nosniff") c.fasthttp.Response.Header.SetContentType(MIMEApplicationJavaScriptCharsetUTF8) return c.SendString(result) } // Links joins the links followed by the property to populate the response's Link HTTP header field. func (c *Ctx) Links(link ...string) { if len(link) == 0 { return } bb := bytebufferpool.Get() for i := range link { if i%2 == 0 { _ = bb.WriteByte('<') _, _ = bb.WriteString(link[i]) _ = bb.WriteByte('>') } else { _, _ = bb.WriteString(`; rel="` + link[i] + `",`) } } c.setCanonical(HeaderLink, utils.TrimRight(getString(bb.Bytes()), ',')) bytebufferpool.Put(bb) } // Locals makes it possible to pass interface{} values under string keys scoped to the request // and therefore available to all following routes that match the request. func (c *Ctx) Locals(key string, value ...interface{}) (val interface{}) { if len(value) == 0 { return c.fasthttp.UserValue(key) } c.fasthttp.SetUserValue(key, value[0]) return value[0] } // Location sets the response Location HTTP header to the specified path parameter. func (c *Ctx) Location(path string) { c.setCanonical(HeaderLocation, path) } // Method contains a string corresponding to the HTTP method of the request: GET, POST, PUT and so on. func (c *Ctx) Method(override ...string) string { if len(override) > 0 { method := utils.ToUpper(override[0]) mINT := methodInt(method) if mINT == -1 { return c.method } c.method = method c.methodINT = mINT } return c.method } // MultipartForm parse form entries from binary. // This returns a map[string][]string, so given a key the value will be a string slice. func (c *Ctx) MultipartForm() (*multipart.Form, error) { return c.fasthttp.MultipartForm() } // Next executes the next method in the stack that matches the current route. func (c *Ctx) Next() (err error) { // Increment handler index c.indexHandler++ // Did we executed all route handlers? if c.indexHandler < len(c.route.Handlers) { // Continue route stack if err = c.route.Handlers[c.indexHandler](c); err != nil { if err = c.app.config.ErrorHandler(c, err); err != nil { _ = c.SendStatus(StatusInternalServerError) } return err } } else { // Continue handler stack _, err = c.app.next(c) } return } // OriginalURL contains the original request URL. // Returned value is only valid within the handler. Do not store any references. // Make copies or use the Immutable setting to use the value outside the Handler. func (c *Ctx) OriginalURL() string { return getString(c.fasthttp.Request.Header.RequestURI()) } // Params is used to get the route parameters. // Defaults to empty string "" if the param doesn't exist. // If a default value is given, it will return that value if the param doesn't exist. // Returned value is only valid within the handler. Do not store any references. // Make copies or use the Immutable setting to use the value outside the Handler. func (c *Ctx) Params(key string, defaultValue ...string) string { if key == "*" || key == "+" { key += "1" } for i := range c.route.Params { if len(key) != len(c.route.Params[i]) { continue } if c.route.Params[i] == key { // in case values are not here if len(c.values) <= i || len(c.values[i]) == 0 { break } return c.values[i] } } return defaultString("", defaultValue) } // Path returns the path part of the request URL. // Optionally, you could override the path. func (c *Ctx) Path(override ...string) string { if len(override) != 0 && c.path != override[0] { // Set new path to context c.pathBuffer = append(c.pathBuffer[0:0], override[0]...) c.pathOriginal = override[0] // c.path = override[0] // c.pathOriginal = c.path // Set new path to request context c.fasthttp.Request.URI().SetPath(c.pathOriginal) // Prettify path c.prettifyPath() } return c.pathOriginal } // Protocol contains the request protocol string: http or https for TLS requests. func (c *Ctx) Protocol() string { if c.fasthttp.IsTLS() { return "https" } scheme := "http" c.fasthttp.Request.Header.VisitAll(func(key, val []byte) { if len(key) < 12 { return // X-Forwarded- } else if bytes.HasPrefix(key, []byte("X-Forwarded-")) { if bytes.Equal(key, []byte(HeaderXForwardedProto)) { scheme = getString(val) } else if bytes.Equal(key, []byte(HeaderXForwardedProtocol)) { scheme = getString(val) } else if bytes.Equal(key, []byte(HeaderXForwardedSsl)) && bytes.Equal(val, []byte("on")) { scheme = "https" } } else if bytes.Equal(key, []byte(HeaderXUrlScheme)) { scheme = getString(val) } }) return scheme } // Query returns the query string parameter in the url. // Defaults to empty string "" if the query doesn't exist. // If a default value is given, it will return that value if the query doesn't exist. // Returned value is only valid within the handler. Do not store any references. // Make copies or use the Immutable setting to use the value outside the Handler. func (c *Ctx) Query(key string, defaultValue ...string) string { return defaultString(getString(c.fasthttp.QueryArgs().Peek(key)), defaultValue) } // QueryParser binds the query string to a struct. func (c *Ctx) QueryParser(out interface{}) error { if c.fasthttp.QueryArgs().Len() < 1 { return nil } // Get decoder from pool var decoder = decoderPool.Get().(*schema.Decoder) defer decoderPool.Put(decoder) // Set correct alias tag decoder.SetAliasTag("query") data := make(map[string][]string) c.fasthttp.QueryArgs().VisitAll(func(key []byte, val []byte) { data[getString(key)] = append(data[getString(key)], getString(val)) }) return decoder.Decode(out, data) } var ( ErrRangeMalformed = errors.New("range: malformed range header string") ErrRangeUnsatisfiable = errors.New("range: unsatisfiable range") ) // Range returns a struct containing the type and a slice of ranges. func (c *Ctx) Range(size int) (rangeData Range, err error) { rangeStr := c.Get(HeaderRange) if rangeStr == "" || !strings.Contains(rangeStr, "=") { err = ErrRangeMalformed return } data := strings.Split(rangeStr, "=") if len(data) != 2 { err = ErrRangeMalformed return } rangeData.Type = data[0] arr := strings.Split(data[1], ",") for i := 0; i < len(arr); i++ { item := strings.Split(arr[i], "-") if len(item) == 1 { err = ErrRangeMalformed return } start, startErr := strconv.Atoi(item[0]) end, endErr := strconv.Atoi(item[1]) if startErr != nil { // -nnn start = size - end end = size - 1 } else if endErr != nil { // nnn- end = size - 1 } if end > size-1 { // limit last-byte-pos to current length end = size - 1 } if start > end || start < 0 { continue } rangeData.Ranges = append(rangeData.Ranges, struct { Start int End int }{ start, end, }) } if len(rangeData.Ranges) < 1 { err = ErrRangeUnsatisfiable return } return } // Redirect to the URL derived from the specified path, with specified status. // If status is not specified, status defaults to 302 Found. func (c *Ctx) Redirect(location string, status ...int) error { c.setCanonical(HeaderLocation, location) if len(status) > 0 { c.Status(status[0]) } else { c.Status(StatusFound) } return nil } // Render a template with data and sends a text/html response. // We support the following engines: html, amber, handlebars, mustache, pug func (c *Ctx) Render(name string, bind interface{}, layouts ...string) error { var err error // Get new buffer from pool buf := bytebufferpool.Get() defer bytebufferpool.Put(buf) if c.app.config.Views != nil { // Render template from Views if err := c.app.config.Views.Render(buf, name, bind, layouts...); err != nil { return err } } else { // Render raw template using 'name' as filepath if no engine is set var tmpl *template.Template if _, err = readContent(buf, name); err != nil { return err } // Parse template if tmpl, err = template.New("").Parse(getString(buf.Bytes())); err != nil { return err } buf.Reset() // Render template if err = tmpl.Execute(buf, bind); err != nil { return err } } // Set Content-Type to text/html c.fasthttp.Response.Header.SetContentType(MIMETextHTMLCharsetUTF8) // Set rendered template to body c.fasthttp.Response.SetBody(buf.Bytes()) // Return err if exist return err } // Route returns the matched Route struct. func (c *Ctx) Route() *Route { if c.route == nil { // Fallback for fasthttp error handler return &Route{ path: c.pathOriginal, Path: c.pathOriginal, Method: c.method, Handlers: make([]Handler, 0), Params: make([]string, 0), } } return c.route } // SaveFile saves any multipart file to disk. func (c *Ctx) SaveFile(fileheader *multipart.FileHeader, path string) error { return fasthttp.SaveMultipartFile(fileheader, path) } // Secure returns a boolean property, that is true, if a TLS connection is established. func (c *Ctx) Secure() bool { return c.fasthttp.IsTLS() } // Send sets the HTTP response body without copying it. // From this point onward the body argument must not be changed. func (c *Ctx) Send(body []byte) error { // Write response body c.fasthttp.Response.SetBodyRaw(body) return nil } var sendFileOnce sync.Once var sendFileFS *fasthttp.FS var sendFileHandler fasthttp.RequestHandler // SendFile transfers the file from the given path. // The file is not compressed by default, enable this by passing a 'true' argument // Sets the Content-Type response HTTP header field based on the filenames extension. func (c *Ctx) SendFile(file string, compress ...bool) error { // https://github.com/valyala/fasthttp/blob/master/fs.go#L81 sendFileOnce.Do(func() { sendFileFS = &fasthttp.FS{ Root: "/", GenerateIndexPages: false, AcceptByteRange: true, Compress: true, CompressedFileSuffix: c.app.config.CompressedFileSuffix, CacheDuration: 10 * time.Second, IndexNames: []string{"index.html"}, PathNotFound: func(ctx *fasthttp.RequestCtx) { ctx.Response.SetStatusCode(StatusNotFound) }, } sendFileHandler = sendFileFS.NewRequestHandler() }) // Keep original path for mutable params c.pathOriginal = utils.ImmutableString(c.pathOriginal) // Disable compression if len(compress) <= 0 || !compress[0] { // https://github.com/valyala/fasthttp/blob/master/fs.go#L46 c.fasthttp.Request.Header.Del(HeaderAcceptEncoding) } // https://github.com/valyala/fasthttp/blob/master/fs.go#L85 if len(file) == 0 || file[0] != '/' { hasTrailingSlash := len(file) > 0 && file[len(file)-1] == '/' var err error if file, err = filepath.Abs(file); err != nil { return err } if hasTrailingSlash { file += "/" } } // Set new URI for fileHandler c.fasthttp.Request.SetRequestURI(file) // Save status code status := c.fasthttp.Response.StatusCode() // Serve file sendFileHandler(c.fasthttp) // Get the status code which is set by fasthttp fsStatus := c.fasthttp.Response.StatusCode() // Set the status code set by the user if it is different from the fasthttp status code and 200 if status != fsStatus && status != StatusOK { c.Status(status) } // Check for error if status != StatusNotFound && fsStatus == StatusNotFound { return fmt.Errorf("sendfile: file %s not found", file) } return nil } // SendStatus sets the HTTP status code and if the response body is empty, // it sets the correct status message in the body. func (c *Ctx) SendStatus(status int) error { c.Status(status) // Only set status body when there is no response body if len(c.fasthttp.Response.Body()) == 0 { return c.SendString(utils.StatusMessage(status)) } return nil } // SendString sets the HTTP response body for string types. // This means no type assertion, recommended for faster performance func (c *Ctx) SendString(body string) error { c.fasthttp.Response.SetBodyString(body) return nil } // SendStream sets response body stream and optional body size. func (c *Ctx) SendStream(stream io.Reader, size ...int) error { if len(size) > 0 && size[0] >= 0 { c.fasthttp.Response.SetBodyStream(stream, size[0]) } else { c.fasthttp.Response.SetBodyStream(stream, -1) c.setCanonical(HeaderContentLength, strconv.Itoa(len(c.fasthttp.Response.Body()))) } return nil } // Set sets the response's HTTP header field to the specified key, value. func (c *Ctx) Set(key string, val string) { c.fasthttp.Response.Header.Set(key, removeNewLines(val)) } func (c *Ctx) setCanonical(key string, val string) { c.fasthttp.Response.Header.SetCanonical(utils.GetBytes(key), utils.GetBytes(val)) } // Subdomains returns a string slice of subdomains in the domain name of the request. // The subdomain offset, which defaults to 2, is used for determining the beginning of the subdomain segments. func (c *Ctx) Subdomains(offset ...int) []string { o := 2 if len(offset) > 0 { o = offset[0] } subdomains := strings.Split(c.Hostname(), ".") l := len(subdomains) - o // Check index to avoid slice bounds out of range panic if l < 0 { l = len(subdomains) } subdomains = subdomains[:l] return subdomains } // Stale is not implemented yet, pull requests are welcome! func (c *Ctx) Stale() bool { return !c.Fresh() } // Status sets the HTTP status for the response. // This method is chainable. func (c *Ctx) Status(status int) *Ctx { c.fasthttp.Response.SetStatusCode(status) return c } // String returns unique string representation of the ctx. // // The returned value may be useful for logging. func (c *Ctx) String() string { return fmt.Sprintf( "#%016X - %s <-> %s - %s %s", c.fasthttp.ID(), c.fasthttp.LocalAddr(), c.fasthttp.RemoteAddr(), c.fasthttp.Request.Header.Method(), c.fasthttp.URI().FullURI(), ) } // Type sets the Content-Type HTTP header to the MIME type specified by the file extension. func (c *Ctx) Type(extension string, charset ...string) *Ctx { if len(charset) > 0 { c.fasthttp.Response.Header.SetContentType(utils.GetMIME(extension) + "; charset=" + charset[0]) } else { c.fasthttp.Response.Header.SetContentType(utils.GetMIME(extension)) } return c } // Vary adds the given header field to the Vary response header. // This will append the header, if not already listed, otherwise leaves it listed in the current location. func (c *Ctx) Vary(fields ...string) { c.Append(HeaderVary, fields...) } // Write writes p into response body. func (c *Ctx) Write(p []byte) (n int, err error) { c.fasthttp.Response.AppendBody(p) return len(p), nil } // XHR returns a Boolean property, that is true, if the request's X-Requested-With header field is XMLHttpRequest, // indicating that the request was issued by a client library (such as jQuery). func (c *Ctx) XHR() bool { return utils.EqualsFold(utils.GetBytes(c.Get(HeaderXRequestedWith)), []byte("xmlhttprequest")) } // prettifyPath ... func (c *Ctx) prettifyPath() { // If UnescapePath enabled, we decode the path if c.app.config.UnescapePath { c.pathBuffer = fasthttp.AppendUnquotedArg(c.pathBuffer[:0], c.pathBuffer) } // If CaseSensitive is disabled, we lowercase the original path if !c.app.config.CaseSensitive { c.pathBuffer = utils.ToLowerBytes(c.pathBuffer) } // If StrictRouting is disabled, we strip all trailing slashes if !c.app.config.StrictRouting && len(c.pathBuffer) > 1 && c.pathBuffer[len(c.pathBuffer)-1] == '/' { c.pathBuffer = utils.TrimRightBytes(c.pathBuffer, '/') } c.path = getString(c.pathBuffer) c.treePath = c.treePath[0:0] if len(c.path) >= 3 { c.treePath = c.path[:3] } }