01: /*
02: * Licensed to the Apache Software Foundation (ASF) under one or more
03: * contributor license agreements. See the NOTICE file distributed with
04: * this work for additional information regarding copyright ownership.
05: * The ASF licenses this file to You under the Apache License, Version 2.0
06: * (the "License"); you may not use this file except in compliance with
07: * the License. You may obtain a copy of the License at
08: *
09: * http://www.apache.org/licenses/LICENSE-2.0
10: *
11: * Unless required by applicable law or agreed to in writing, software
12: * distributed under the License is distributed on an "AS IS" BASIS,
13: * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
14: * See the License for the specific language governing permissions and
15: * limitations under the License.
16: */
17: package org.apache.commons.vfs.provider.bzip2;
18:
19: //TODO: Revert to [compress]
20: //import org.apache.commons.compress.bzip2.CBZip2InputStream;
21: //import org.apache.commons.compress.bzip2.CBZip2OutputStream;
22: import org.apache.commons.vfs.FileName;
23: import org.apache.commons.vfs.FileObject;
24: import org.apache.commons.vfs.FileSystemException;
25: import org.apache.commons.vfs.provider.compressed.CompressedFileFileObject;
26: import org.apache.commons.vfs.provider.compressed.CompressedFileFileSystem;
27:
28: import java.io.IOException;
29: import java.io.InputStream;
30: import java.io.OutputStream;
31:
32: /**
33: * the bzip2 file
34: *
35: * @author <a href="mailto:imario@apache.org">Mario Ivankovits</a>
36: * @version $Revision: 480428 $ $Date: 2006-11-28 22:15:24 -0800 (Tue, 28 Nov 2006) $
37: */
38: public class Bzip2FileObject extends CompressedFileFileObject {
39: protected Bzip2FileObject(FileName name, FileObject container,
40: CompressedFileFileSystem fs) {
41: super (name, container, fs);
42: }
43:
44: protected InputStream doGetInputStream() throws Exception {
45: // check file
46: InputStream is = getContainer().getContent().getInputStream();
47: return wrapInputStream(getName().getURI(), is);
48: }
49:
50: public static InputStream wrapInputStream(final String name,
51: final InputStream is) throws IOException {
52: final int b1 = is.read();
53: final int b2 = is.read();
54: if (b1 != 'B' || b2 != 'Z') {
55: throw new FileSystemException(
56: "vfs.provider.compressedFile/not-a-compressedFile-file.error",
57: name);
58: }
59: return new CBZip2InputStream(is);
60: }
61:
62: protected OutputStream doGetOutputStream(boolean bAppend)
63: throws Exception {
64: OutputStream os = getContainer().getContent().getOutputStream(
65: false);
66: os.write('B');
67: os.write('Z');
68:
69: return new CBZip2OutputStream(os);
70: }
71: }
|