sourceafBedSheet::HttpRequest.fan

using afIoc::Inject
using afIoc::Registry
using afIoc::ThreadStash
using afIoc::ThreadStashManager
using web::WebReq
using inet::IpAddr

** An injectable 'const' version of [WebReq]`web::WebReq`.
** 
** This class is proxied and will always refer to the current web request.
const mixin HttpRequest {

    ** Returns 'true' if an 'XMLHttpRequest', as specified by the 'X-Requested-With' HTTP header.
    abstract Bool isXmlHttpRequest()
    
    ** The HTTP version of the request.
    ** 
    ** @see `web::WebReq.version`
    abstract Version httpVersion
    
    ** The HTTP request method in uppercase. Example: GET, POST, PUT.
    ** 
    ** @see `web::WebReq.method`
    abstract Str httpMethod()

    ** The IP host address of the client socket making this request.
    ** 
    ** @see `web::WebReq.remoteAddr`
    abstract IpAddr remoteAddr()
    
    ** The IP port of the client socket making this request.
    ** 
    ** @see `web::WebReq.remotePort`
    abstract Int remotePort()

    ** The request URI including the query string relative to this authority. Also see `absUri`, 
    ** `modBase`, `modRel`, `routeBase` and `routeRel`.
    ** 
    ** @see `web::WebReq.uri`
    abstract Uri uri()

    ** The absolute request URI including the full authority and the query string.
    ** 
    ** @see `web::WebReq.absUri`
    abstract Uri absUri()
    
    ** Base uri of the current WebMod
    ** 
    ** @see `web::WebReq.modBase`
    abstract Uri modBase()

    ** The uri relative to `BedSheetWebMod`
    ** 
    ** @see `web::WebReq.modRel`
    abstract Uri modRel()
    
    ** Map of HTTP request headers. The map is readonly and case insensitive.
    ** 
    ** @see `web::WebReq.headers`
    ** 
    ** @see `http://en.wikipedia.org/wiki/List_of_HTTP_header_fields#Requests`
    abstract HttpRequestHeaders headers()
    
    ** Map of cookie values keyed by cookie name.  The cookies map is readonly and case insensitive.
    abstract Str:Str cookies()
    
    ** Get the key/value pairs of the form data.  The request content is read and parsed using 
    ** `sys::Uri.decodeQuery`.  
    ** 
    ** If the request content type is not "application/x-www-form-urlencoded" this method returns 
    ** 'null'.
    ** 
    ** @see `web::WebReq.form`
    abstract [Str:Str]? form()
    
    ** The accepted locales for this request based on the "Accept-Language" HTTP header. List is 
    ** sorted by preference, where 'locales.first' is best, and 'locales.last' is worst. This list 
    ** is guaranteed to contain Locale("en").
    ** 
    ** @see `web::WebReq.locales`
    abstract Locale[] locales()
    
    ** Get the stream to read request body.  See `WebUtil.makeContentInStream` to check under which 
    ** conditions request content is available. If request content is not available, then throw an 
    ** exception.
    **
    ** If the client specified the "Expect: 100-continue" header, then the first access of the 
    ** request input stream will automatically send the client a '100 Continue' response.
    **
    ** @see `web::WebReq.in`
    abstract InStream in()
    
}

** Wraps a given `HttpRequest`, delegating all its methods. 
** You may find it handy to use when contributing to the 'HttpRequest' delegate chain.
@NoDoc
const class HttpRequestWrapper : HttpRequest {
    const    HttpRequest req
    new      make(HttpRequest req)          { this.req = req        } 
    override Bool isXmlHttpRequest()        { req.isXmlHttpRequest  }
    override Version httpVersion { get          { req.httpVersion       } set { }}
    override Str httpMethod()               { req.httpMethod        }   
    override IpAddr remoteAddr()            { req.remoteAddr        }
    override Int remotePort()               { req.remotePort        }
    override Uri uri()                      { req.uri               }
    override Uri absUri()                   { req.absUri            }
    override Uri modBase()                  { req.modBase           }
    override Uri modRel()                   { req.modRel            }
    override HttpRequestHeaders headers()   { req.headers           }
    override [Str:Str]? form()              { req.form              }
    override Str:Str cookies()              { req.cookies           }
    override Locale[] locales()             { req.locales           }
    override InStream in()                  { req.in                }   
}

internal const class HttpRequestImpl : HttpRequest {
    
    @Inject
    private const Registry registry
    
    private const ThreadStash threadStash

    new make(ThreadStashManager threadStashManager, |This|in) { 
        in(this) 
        threadStash = threadStashManager.createStash("HttpRequest")
    }

    override Bool isXmlHttpRequest() {
        headers.get("X-Requested-With")?.equalsIgnoreCase("XMLHttpRequest") ?: false
    }

    override Version httpVersion { set{} get {
        webReq.version      
    }}
    
    override Str httpMethod() {
        webReq.method
    }   

    override IpAddr remoteAddr() {
        webReq.remoteAddr       
    }
    
    override Int remotePort() {
        webReq.remotePort       
    }

    override Uri uri() {
        webReq.uri
    }
    
    override Uri absUri() {
        webReq.absUri
    }
    
    override Uri modBase() {
        webReq.modBase
    }

    override Uri modRel() {
        webReq.modRel
    }
    
    override HttpRequestHeaders headers() {
        threadStash.get("headers") |->Obj| { HttpRequestHeaders(webReq.headers) }
    }
    
    override [Str:Str]? form() {
        webReq.form
    }

    override Str:Str cookies() {
        webReq.cookies
    }

    override Locale[] locales() {
        webReq.locales
    }

    override InStream in() {
        webReq.in
    }
    
    private WebReq webReq() {
        registry.dependencyByType(WebReq#)
    }
}