Classes in this Package | Line Coverage | Branch Coverage | Complexity | ||||||||
LineDelimiterInspector |
|
| 1.6428571428571428;1,643 |
1 | /** |
|
2 | * Redistribution and use in source and binary forms, with or without |
|
3 | * modification, are permitted provided that the following conditions are |
|
4 | * met : |
|
5 | * |
|
6 | * . Redistributions of source code must retain the above copyright |
|
7 | * notice, this list of conditions and the following disclaimer. |
|
8 | * |
|
9 | * . Redistributions in binary form must reproduce the above copyright |
|
10 | * notice, this list of conditions and the following disclaimer in the |
|
11 | * documentation and/or other materials provided with the distribution. |
|
12 | * |
|
13 | * . The name of the author may not be used to endorse or promote products |
|
14 | * derived from this software without specific prior written permission. |
|
15 | * |
|
16 | * THIS SOFTWARE IS PROVIDED BY THE AUTHOR ``AS IS'' AND ANY EXPRESS OR |
|
17 | * IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE IMPLIED |
|
18 | * WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE ARE |
|
19 | * DISCLAIMED. IN NO EVENT SHALL THE AUTHOR BE LIABLE FOR ANY DIRECT, |
|
20 | * INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES |
|
21 | * (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR |
|
22 | * SERVICES; LOSS OF USE, DATA, OR PROFITS; OR BUSINESS INTERRUPTION) |
|
23 | * HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY, WHETHER IN CONTRACT, |
|
24 | * STRICT LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN |
|
25 | * ANY WAY OUT OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF THE |
|
26 | * POSSIBILITY OF SUCH DAMAGE. |
|
27 | * |
|
28 | * $Id$ |
|
29 | */ |
|
30 | ||
31 | package palmed.edit.text; |
|
32 | ||
33 | import java.io.IOException; |
|
34 | import java.io.InputStream; |
|
35 | import java.io.OutputStream; |
|
36 | ||
37 | /** |
|
38 | * This class wraps an InputStream in order to detect the line delimiter type. |
|
39 | * |
|
40 | * @author Mathieu Champlon |
|
41 | * @version $Revision$ $Date$ |
|
42 | */ |
|
43 | public final class LineDelimiterInspector extends InputStream |
|
44 | { |
|
45 | /** |
|
46 | * The line feed delimiter. |
|
47 | */ |
|
48 | private static final String LF = "\n"; |
|
49 | /** |
|
50 | * The carriage return delimiter. |
|
51 | */ |
|
52 | private static final String CR = "\r"; |
|
53 | /** |
|
54 | * The carriage return/line feed delimiter. |
|
55 | */ |
|
56 | private static final String CR_LF = "\r\n"; |
|
57 | /** |
|
58 | * The wrapped stream. |
|
59 | */ |
|
60 | private final InputStream stream_; |
|
61 | /** |
|
62 | * The delimiter. |
|
63 | */ |
|
64 | private String delimiter_; |
|
65 | /** |
|
66 | * Whether the previous read byte was a carriage return or not. |
|
67 | */ |
|
68 | private boolean wasCarriageReturn_; |
|
69 | /** |
|
70 | * Whether to skip the rest of the stream or not. |
|
71 | */ |
|
72 | private boolean hasLineDelimiterBeenFound_; |
|
73 | ||
74 | /** |
|
75 | * Create a line delimiter inspector. |
|
76 | * |
|
77 | * @param stream the stream to wrap |
|
78 | */ |
|
79 | public LineDelimiterInspector( final InputStream stream ) |
|
80 | 315 | { |
81 | 315 | if( stream == null ) |
82 | 5 | throw new IllegalArgumentException( "parameter 'stream' is null" ); |
83 | 310 | stream_ = stream; |
84 | 310 | delimiter_ = CR_LF; |
85 | 310 | wasCarriageReturn_ = false; |
86 | 310 | hasLineDelimiterBeenFound_ = false; |
87 | 310 | } |
88 | ||
89 | /** |
|
90 | * Create a default line delimiter. |
|
91 | */ |
|
92 | public LineDelimiterInspector() |
|
93 | 540 | { |
94 | 540 | stream_ = null; |
95 | 540 | delimiter_ = CR_LF; |
96 | 540 | } |
97 | ||
98 | /** |
|
99 | * {@inheritDoc} |
|
100 | */ |
|
101 | public int read() throws IOException |
|
102 | { |
|
103 | 0 | final int b = stream_.read(); |
104 | 0 | if( hasLineDelimiterBeenFound_ ) |
105 | 0 | return b; |
106 | 0 | return inspect( b ); |
107 | } |
|
108 | ||
109 | /** |
|
110 | * {@inheritDoc} |
|
111 | */ |
|
112 | public int read( final byte[] b ) throws IOException |
|
113 | { |
|
114 | 575 | return read( b, 0, b.length ); |
115 | } |
|
116 | ||
117 | /** |
|
118 | * {@inheritDoc} |
|
119 | */ |
|
120 | public int read( final byte[] b, final int off, final int len ) throws IOException |
|
121 | { |
|
122 | 595 | final int size = stream_.read( b, off, len ); |
123 | 4075 | for( int i = off; i < size && !hasLineDelimiterBeenFound_; ++i ) |
124 | 3480 | inspect( b[i] ); |
125 | 595 | return size; |
126 | } |
|
127 | ||
128 | private int inspect( final int b ) |
|
129 | { |
|
130 | 3480 | if( b == '\r' ) |
131 | { |
|
132 | 30 | delimiter_ = CR; |
133 | 30 | wasCarriageReturn_ = true; |
134 | 30 | } |
135 | else |
|
136 | { |
|
137 | 3450 | if( b == '\n' ) |
138 | { |
|
139 | 120 | if( wasCarriageReturn_ ) |
140 | 15 | delimiter_ = CR_LF; |
141 | else |
|
142 | 105 | delimiter_ = LF; |
143 | 120 | hasLineDelimiterBeenFound_ = true; |
144 | 120 | } |
145 | 3330 | else if( wasCarriageReturn_ ) |
146 | 10 | hasLineDelimiterBeenFound_ = true; |
147 | } |
|
148 | 3480 | return b; |
149 | } |
|
150 | ||
151 | /** |
|
152 | * Write the delimiter to an output stream. |
|
153 | * |
|
154 | * @param stream the stream to write into |
|
155 | * @throws IOException an io exception occurs |
|
156 | */ |
|
157 | public void write( final OutputStream stream ) throws IOException |
|
158 | { |
|
159 | 190 | stream.write( delimiter_.getBytes() ); |
160 | 190 | } |
161 | ||
162 | /** |
|
163 | * {@inheritDoc} |
|
164 | */ |
|
165 | public int available() throws IOException |
|
166 | { |
|
167 | 0 | return stream_.available(); |
168 | } |
|
169 | ||
170 | /** |
|
171 | * {@inheritDoc} |
|
172 | */ |
|
173 | public void close() throws IOException |
|
174 | { |
|
175 | 0 | stream_.close(); |
176 | 0 | } |
177 | ||
178 | /** |
|
179 | * {@inheritDoc} |
|
180 | */ |
|
181 | public void mark( final int readlimit ) |
|
182 | { |
|
183 | 0 | stream_.mark( readlimit ); |
184 | 0 | } |
185 | ||
186 | /** |
|
187 | * {@inheritDoc} |
|
188 | */ |
|
189 | public boolean markSupported() |
|
190 | { |
|
191 | 0 | return stream_.markSupported(); |
192 | } |
|
193 | ||
194 | /** |
|
195 | * {@inheritDoc} |
|
196 | */ |
|
197 | public void reset() throws IOException |
|
198 | { |
|
199 | 0 | stream_.reset(); |
200 | 0 | } |
201 | ||
202 | /** |
|
203 | * {@inheritDoc} |
|
204 | */ |
|
205 | public long skip( final long n ) throws IOException |
|
206 | { |
|
207 | 0 | return stream_.skip( n ); |
208 | } |
|
209 | ||
210 | /** |
|
211 | * {@inheritDoc} |
|
212 | */ |
|
213 | public String toString() |
|
214 | { |
|
215 | 0 | return delimiter_; |
216 | } |
|
217 | } |