| 123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347 | /******************************************************************************* copyright: Copyright (c) 2004 Kris Bell. All rights reserved license: BSD style: $(LICENSE) version: Initial release: April 2004 author: Kris *******************************************************************************/ module tango.net.http.HttpHeaders; private import tango.time.Time; private import tango.io.stream.Lines; private import tango.io.model.IConduit; public import tango.net.http.HttpConst; private import tango.net.http.HttpTokens; /****************************************************************************** Exposes freachable HttpHeader instances ******************************************************************************/ struct HeaderElement { HttpHeaderName name; const(char)[] value; } /****************************************************************************** Maintains a set of input headers. These are placed into an input buffer and indexed via a HttpStack. ******************************************************************************/ class HttpHeadersView : HttpTokens { // tell compiler to used super.parse() also alias HttpTokens.parse parse; private Lines!(char) line; private bool preserve; /********************************************************************** Construct this set of headers, using a HttpStack based upon a ':' delimiter **********************************************************************/ this () { // separator is a ':', and specify we want it included as // part of the name whilst iterating super (':', true); // construct a line tokenizer for later usage line = new Lines!(char); } /********************************************************************** Clone a source set of HttpHeaders **********************************************************************/ this (HttpHeadersView source) { super (source); this.preserve = source.preserve; } /********************************************************************** Clone this set of HttpHeadersView **********************************************************************/ HttpHeadersView clone () { return new HttpHeadersView (this); } /*********************************************************************** Control whether headers are duplicated or not. Default behaviour is aliasing instead of copying, avoiding any allocatation overhead. However, the default won't preserve those headers once additional content has been read. To retain headers across arbitrary buffering, you should set this option true ***********************************************************************/ HttpHeadersView retain (bool yes = true) { preserve = yes; return this; } /********************************************************************** Read all header lines. Everything is mapped rather than being allocated & copied **********************************************************************/ override void parse (InputBuffer input) { setParsed (true); line.set (input); while (line.next && line.get().length) stack.push (preserve ? line.get().dup : line.get()); } /********************************************************************** Return the value of the provided header, or null if the header does not exist **********************************************************************/ const(char)[] get (HttpHeaderName name, const(char)[] def = null) { return super.get (name.value, def); } /********************************************************************** Return the integer value of the provided header, or -1 if the header does not exist **********************************************************************/ int getInt (const(HttpHeaderName) name, int def = -1) { return super.getInt (name.value, def); } /********************************************************************** Return the date value of the provided header, or Time.epoch if the header does not exist **********************************************************************/ Time getDate (HttpHeaderName name, Time def = Time.epoch) { return super.getDate (name.value, def); } /********************************************************************** Iterate over the set of headers. This is a shell around the superclass, where we can convert the HttpToken into a HeaderElement instead. **********************************************************************/ int opApply (scope int delegate(ref HeaderElement) dg) { HeaderElement element; int result = 0; foreach (HttpToken token; super) { element.name.value = token.name; element.value = token.value; result = dg (element); if (result) break; } return result; } /********************************************************************** Create a filter for iterating of a set of named headers. We have to create a filter since we can't pass additional arguments directly to an opApply() method. **********************************************************************/ FilteredHeaders createFilter (HttpHeaderName header) { return new FilteredHeaders (this, header); } /********************************************************************** Filter class for isolating a set of named headers. **********************************************************************/ private static class FilteredHeaders : FilteredTokens { /************************************************************** Construct a filter upon the specified headers, for the given header name. **************************************************************/ this (HttpHeadersView headers, HttpHeaderName header) { super (headers, header.value); } /************************************************************** Iterate over all headers matching the given name. This wraps the HttpToken iterator to convert the output into a HeaderElement instead. **************************************************************/ int opApply (scope int delegate(ref HeaderElement) dg) { HeaderElement element; int result = 0; foreach (HttpToken token; super) { element.name.value = token.name; element.value = token.value; result = dg (element); if (result) break; } return result; } } } /****************************************************************************** Maintains a set of output headers. These are held in an output buffer, and indexed via a HttpStack. Deleting a header could be supported by setting the HttpStack entry to null, and ignoring such values when it's time to write the headers. ******************************************************************************/ class HttpHeaders : HttpHeadersView { /********************************************************************** Construct output headers **********************************************************************/ this () { } /********************************************************************** Clone a source set of HttpHeaders **********************************************************************/ this (HttpHeaders source) { super (source); } /********************************************************************** Clone this set of HttpHeaders **********************************************************************/ override HttpHeaders clone () { return new HttpHeaders (this); } /********************************************************************** Add the specified header, and use a callback to provide the content. **********************************************************************/ void add (HttpHeaderName name, scope void delegate(OutputBuffer) dg) { super.add (name.value, dg); } /********************************************************************** Add the specified header and text **********************************************************************/ void add (HttpHeaderName name, const(char)[] value) { super.add (name.value, value); } /********************************************************************** Add the specified header and integer value **********************************************************************/ void addInt (HttpHeaderName name, size_t value) { super.addInt (name.value, value); } /********************************************************************** Add the specified header and long/date value **********************************************************************/ void addDate (HttpHeaderName name, Time value) { super.addDate (name.value, value); } /********************************************************************** Remove the specified header header. Returns false if not found. **********************************************************************/ bool remove (HttpHeaderName name) { return super.remove (name.value); } } |