Mercurial > projects > ldc

comparison tango/tango/io/stream/DigestStream.d @ 132:1700239cab2e trunk

Find changesets by keywords (author, files, the commit message), revision number or hash, or revset expression.
[svn r136] MAJOR UNSTABLE UPDATE!!! Initial commit after moving to Tango instead of Phobos. Lots of bugfixes... This build is not suitable for most things.
author lindquist
date Fri, 11 Jan 2008 17:57:40 +0100
parents
children
comparison
equal deleted inserted replaced
131:5825d48b27d1 132:1700239cab2e
1 /*******************************************************************************
2
3 copyright: Copyright (c) 2007 Kris Bell. All rights reserved
4
5 license: BSD style: $(LICENSE)
6
7 version: Initial release: Oct 2007
8
9 author: Kris
10
11 *******************************************************************************/
12
13 module tango.io.stream.DigestStream;
14
15 private import tango.io.Conduit;
16
17 private import tango.io.digest.Digest;
18
19 /*******************************************************************************
20
21 Inject a digest filter into an input stream, updating the digest
22 as information flows through it
23
24 *******************************************************************************/
25
26 class DigestInput : InputFilter
27 {
28 private Digest filter;
29
30 /***********************************************************************
31
32 Accepts any input stream, and any digest derivation
33
34 ***********************************************************************/
35
36 this (InputStream stream, Digest digest)
37 {
38 super (stream);
39 filter = digest;
40 }
41
42 /***********************************************************************
43
44 Read from conduit into a target array. The provided dst
45 will be populated with content from the conduit.
46
47 Returns the number of bytes read, which may be less than
48 requested in dst (or IOStream.Eof for end-of-flow)
49
50 ***********************************************************************/
51
52 final override uint read (void[] dst)
53 {
54 auto len = host.read (dst);
55 if (len != Eof)
56 filter.update (dst [0 .. len]);
57 return len;
58 }
59
60 /********************************************************************
61
62 Return the Digest instance we were created with. Use this
63 to access the resultant binary or hex digest value
64
65 *********************************************************************/
66
67 final Digest digest()
68 {
69 return filter;
70 }
71 }
72
73
74 /*******************************************************************************
75
76 Inject a digest filter into an output stream, updating the digest
77 as information flows through it. Here's an example where we calculate
78 an MD5 digest as a side-effect of copying a file:
79 ---
80 auto output = new DigestOutput(new FileOutput("output"), new Md5);
81 output.copy (new FileInput("input"));
82
83 Stdout.formatln ("hex digest: {}", output.digest.hexDigest);
84 ---
85
86 *******************************************************************************/
87
88 class DigestOutput : OutputFilter
89 {
90 private Digest filter;
91
92 /***********************************************************************
93
94 Accepts any output stream, and any digest derivation
95
96 ***********************************************************************/
97
98 this (OutputStream stream, Digest digest)
99 {
100 super (stream);
101 filter = digest;
102 }
103
104 /***********************************************************************
105
106 Write to conduit from a source array. The provided src
107 content will be written to the conduit.
108
109 Returns the number of bytes written from src, which may
110 be less than the quantity provided
111
112 ***********************************************************************/
113
114 final override uint write (void[] src)
115 {
116 auto len = host.write (src);
117 if (len != Eof)
118 filter.update (src[0 .. len]);
119 return len;
120 }
121
122 /********************************************************************
123
124 Return the Digest instance we were created with. Use this
125 to access the resultant binary or hex digest value
126
127 *********************************************************************/
128
129 final Digest digest()
130 {
131 return filter;
132 }
133 }
134
135
136 /*******************************************************************************
137
138 *******************************************************************************/
139
140 debug (DigestStream)
141 {
142 import tango.io.Stdout;
143 import tango.io.GrowBuffer;
144 import tango.io.digest.Md5;
145 import tango.io.stream.FileStream;
146
147 void main()
148 {
149 auto output = new DigestOutput(new GrowBuffer, new Md5);
150 output.copy (new FileInput("digeststream.d"));
151
152 Stdout.formatln ("hex digest:{}", output.digest.hexDigest);
153 }
154 }