public class CipherDataInputStream implements AutoCloseable,DataInput{
public CipherDataInputStream(InputStream in,byte[]pwd)
throws InvalidAlgorithmParameterException,InvalidKeyException,NoSuchAlgorithmException,NoSuchPaddingException{
this.in=in;
this.cipher=Cipher.getInstance("AES/CBC/PKCS5Padding");
this.cipher.init(Cipher.DECRYPT_MODE,new SecretKeySpec(pwd,"AES"),new IvParameterSpec(new byte[]{0,0,0,0,0,0,0,0,0,0,0,0,0,0,0,0}));
}
// --- Klassen --- //
// --- Methoden --- //
/** Gibt die Anzahl der zu lesenden Bytes an. **/
public int available()
throws IOException{
return this.in.available();
}
/** Schliesst den Stream. **/
@Override public void close()
throws IOException{
this.in.close();
return;
}
/** Liest Bytes, decrypted diese vorher und schreibt diese in den OutputStream. **/
public void read(OutputStream out)
throws IOException{
byte[]b=new byte[(this.readInt()/this.cipher.getBlockSize()+1)*this.cipher.getBlockSize()];
for(int i=0;i<b.length;i++){
b[i]=(byte)this.in.read();
}
try{
out.write(this.cipher.doFinal(b));
out.flush();
}catch(Exception exc){
throw new IOException(exc.getMessage());
}
return;
}
/** Liest ein Boolean und decrypted diesen vorher. **/
@Override public boolean readBoolean()
throws IOException{
byte[]b=new byte[(1/this.cipher.getBlockSize()+1)*this.cipher.getBlockSize()];
for(int i=0;i<b.length;i++){
b[i]=(byte)this.in.read();
}
try(DataInputStream in=new DataInputStream(new ByteArrayInputStream(this.cipher.doFinal(b)))){
return in.readBoolean();
}catch(Exception exc){
throw new IOException(exc.getMessage());
}
}
/** Liest ein Byte und entschluesselt diesen vorher. **/
@Override public byte readByte()
throws IOException{
byte[]b=new byte[(1/this.cipher.getBlockSize()+1)*this.cipher.getBlockSize()];
for(int i=0;i<b.length;i++){
b[i]=(byte)this.in.read();
}
try(DataInputStream in=new DataInputStream(new ByteArrayInputStream(this.cipher.doFinal(b)))){
return in.readByte();
}catch(Exception exc){
throw new IOException(exc.getMessage());
}
}
/** Liest einen Short und entschluesselt diesen vorher. **/
@Override public char readChar()
throws IOException{
byte[]b=new byte[(Character.BYTES/this.cipher.getBlockSize()+1)*this.cipher.getBlockSize()];
for(int i=0;i<b.length;i++){
b[i]=(byte)this.in.read();
}
try(DataInputStream in=new DataInputStream(new ByteArrayInputStream(this.cipher.doFinal(b)))){
return in.readChar();
}catch(Exception exc){
throw new IOException(exc.getMessage());
}
}
/** Liest einen Double und entschluesselt diesen vorher. **/
@Override public double readDouble()
throws IOException{
byte[]b=new byte[(Double.BYTES/this.cipher.getBlockSize()+1)*this.cipher.getBlockSize()];
for(int i=0;i<b.length;i++){
b[i]=(byte)this.in.read();
}
try(DataInputStream in=new DataInputStream(new ByteArrayInputStream(this.cipher.doFinal(b)))){
return in.readDouble();
}catch(Exception exc){
throw new IOException(exc.getMessage());
}
}
/** Liest einen Float und verschluesselt diesen vorher. **/
@Override public float readFloat()
throws IOException{
byte[]b=new byte[(Float.BYTES/this.cipher.getBlockSize()+1)*this.cipher.getBlockSize()];
for(int i=0;i<b.length;i++){
b[i]=(byte)this.in.read();
}
try(DataInputStream in=new DataInputStream(new ByteArrayInputStream(this.cipher.doFinal(b)))){
return in.readFloat();
}catch(Exception exc){
throw new IOException(exc.getMessage());
}
}
@Override public void readFully(byte[]b)
throws UnsupportedOperationException{
throw new UnsupportedOperationException("readFully(byte[]) is not supported.");
}
@Override public void readFully(byte[]b,int off,int len)
throws UnsupportedOperationException{
throw new UnsupportedOperationException("readFully(byte[],int,int) is not supported.");
}
/** Liest einen Integer und entschluesselt diesen vorher. **/
@Override public int readInt()
throws IOException{
byte[]b=new byte[(Integer.BYTES/this.cipher.getBlockSize()+1)*this.cipher.getBlockSize()];
for(int i=0;i<b.length;i++){
b[i]=(byte)this.in.read();
}
try(DataInputStream in=new DataInputStream(new ByteArrayInputStream(this.cipher.doFinal(b)))){
return in.readInt();
}catch(Exception exc){
throw new IOException(exc.getMessage());
}
}
@Override public String readLine()
throws UnsupportedOperationException{
throw new UnsupportedOperationException("readLine() is not supported.");
}
/** Liest einen Long und entschluesselt diesen vorher. **/
@Override public long readLong()
throws IOException{
byte[]b=new byte[(Long.BYTES/this.cipher.getBlockSize()+1)*this.cipher.getBlockSize()];
for(int i=0;i<b.length;i++){
b[i]=(byte)this.in.read();
}
try(DataInputStream in=new DataInputStream(new ByteArrayInputStream(this.cipher.doFinal(b)))){
return in.readLong();
}catch(Exception exc){
throw new IOException(exc.getMessage());
}
}
/** Liest einen Short und entschluesselt diesen vorher. **/
@Override public short readShort()
throws IOException{
byte[]b=new byte[(Short.BYTES/this.cipher.getBlockSize()+1)*this.cipher.getBlockSize()];
System.out.println("readShort():"+b.length);
for(int i=0;i<b.length;i++){
b[i]=(byte)this.in.read();
}
try(DataInputStream in=new DataInputStream(new ByteArrayInputStream(this.cipher.doFinal(b)))){
return in.readShort();
}catch(Exception exc){
throw new IOException(exc.getMessage());
}
}
/** Liest ein vorzeichenloses Byte und entschluesselt dieses vorher. **/
@Override public int readUnsignedByte()
throws IOException{
byte[]b=new byte[(Integer.BYTES/this.cipher.getBlockSize()+1)*this.cipher.getBlockSize()];
for(int i=0;i<b.length;i++){
b[i]=(byte)this.in.read();
}
try(DataInputStream in=new DataInputStream(new ByteArrayInputStream(this.cipher.doFinal(b)))){
return in.readUnsignedByte();
}catch(Exception exc){
throw new IOException(exc.getMessage());
}
}
/** Liest ein vorzeichenloses Short und entschluesselt dieses vorher. **/
@Override public int readUnsignedShort()
throws IOException{
byte[]b=new byte[(Integer.BYTES/this.cipher.getBlockSize()+1)*this.cipher.getBlockSize()];
for(int i=0;i<b.length;i++){
b[i]=(byte)this.in.read();
}
try(DataInputStream in=new DataInputStream(new ByteArrayInputStream(this.cipher.doFinal(b)))){
return in.readUnsignedShort();
}catch(Exception exc){
exc.printStackTrace();
throw new IOException(exc.getMessage());
}
}
/** Liest eine Zeichenkette und entschluesselt diese vorher. **/
@Override public String readUTF()
throws IOException{
try{
byte[]b=new byte[(this.readShort()/this.cipher.getBlockSize()+1)*this.cipher.getBlockSize()];
System.out.println("readUTF():"+b.length);
for(int i=0;i<b.length;i++){
b[i]=(byte)this.in.read();
}
System.out.println(new String(this.cipher.doFinal(b),StandardCharsets.ISO_8859_1));
return new String(this.cipher.doFinal(b),StandardCharsets.ISO_8859_1);
}catch(Exception exc){
exc.printStackTrace();
throw new IOException(exc.getMessage());
}
}
/** Ueberspringt eine Anzahl von Bytes. **/
@Override public int skipBytes(int count)
throws IOException{
return(int)this.in.skip(count);
}
// --- Variablen --- //
private Cipher cipher;
private InputStream in;
// --- Aufzaehlungen --- //
}
