org.spearce.jgit/src/org/spearce/jgit/lib/ObjectReader.java

   1 package org.spearce.jgit.lib;
   2
   3 import java.io.BufferedReader;
   4 import java.io.IOException;
   5 import java.io.InputStream;
   6 import java.io.InputStreamReader;
   7 import java.io.UnsupportedEncodingException;
   8 import java.util.zip.InflaterInputStream;
   9
  10 public class ObjectReader {
  11     private static final int TYPESZ = 16;
  12
  13     private final ObjectId objectId;
  14
  15     private final String objectType;
  16
  17     private final int objectSize;
  18
  19     private InflaterInputStream inflater;
  20
  21     public ObjectReader(final ObjectId id, final InputStream src)
  22             throws IOException {
  23         objectId = id;
  24         inflater = new InflaterInputStream(src);
  25
  26         final StringBuffer tempType = new StringBuffer(TYPESZ);
  27         int tempSize = 0;
  28         int c;
  29
  30         for (;;) {
  31             c = inflater.read();
  32             if (' ' == c) {
  33                 break;
  34             }
  35             if (c < 'a' || c > 'z' || tempType.length() >= 16) {
  36                 throw new CorruptObjectException(id, "bad type in header");
  37             }
  38             tempType.append((char) c);
  39         }
  40         objectType = tempType.toString();
  41
  42         for (;;) {
  43             c = inflater.read();
  44             if (0 == c) {
  45                 break;
  46             }
  47             if (c < '0' || c > '9') {
  48                 throw new CorruptObjectException(id, "bad length in header");
  49             }
  50             tempSize *= 10;
  51             tempSize += c - '0';
  52         }
  53         objectSize = tempSize;
  54     }
  55
  56     public ObjectId getId() {
  57         return objectId;
  58     }
  59
  60     public String getType() {
  61         return objectType;
  62     }
  63
  64     public int getSize() {
  65         return objectSize;
  66     }
  67
  68     public InputStream getInputStream() {
  69         if (inflater == null) {
  70             throw new IllegalStateException("Already closed.");
  71         }
  72         return inflater;
  73     }
  74
  75     public BufferedReader getBufferedReader()
  76             throws UnsupportedEncodingException {
  77         return new BufferedReader(new InputStreamReader(getInputStream(),
  78                 "UTF-8"));
  79     }
  80
  81     public void close() throws IOException {
  82         if (inflater != null) {
  83             inflater.close();
  84             inflater = null;
  85         }
  86     }
  87 }