mirroring bot - 2025/11/01

Author: updating-bot

svn_utils/src/org/appwork/exceptions/ErrorReporter.java

@@ -0,0 +1,84 @@
+/**
+ *
+ * ====================================================================================================================================================
+ *         "AppWork Utilities" License
+ *         The "AppWork Utilities" will be called [The Product] from now on.
+ * ====================================================================================================================================================
+ *         Copyright (c) 2009-2025, AppWork GmbH <e-mail@appwork.org>
+ *         Spalter Strasse 58
+ *         91183 Abenberg
+ *         e-mail@appwork.org
+ *         Germany
+ * === Preamble ===
+ *     This license establishes the terms under which the [The Product] Source Code & Binary files may be used, copied, modified, distributed, and/or redistributed.
+ *     The intent is that the AppWork GmbH is able to provide  their utilities library for free to non-commercial projects whereas commercial usage is only permitted after obtaining a commercial license.
+ *     These terms apply to all files that have the [The Product] License header (IN the file), a <filename>.license or <filename>.info (like mylib.jar.info) file that contains a reference to this license.
+ *
+ * === 3rd Party Licences ===
+ *     Some parts of the [The Product] use or reference 3rd party libraries and classes. These parts may have different licensing conditions. Please check the *.license and *.info files of included libraries
+ *     to ensure that they are compatible to your use-case. Further more, some *.java have their own license. In this case, they have their license terms in the java file header.
+ *
+ * === Definition: Commercial Usage ===
+ *     If anybody or any organization is generating income (directly or indirectly) by using [The Product] or if there's any commercial interest or aspect in what you are doing, we consider this as a commercial usage.
+ *     If your use-case is neither strictly private nor strictly educational, it is commercial. If you are unsure whether your use-case is commercial or not, consider it as commercial or contact as.
+ * === Dual Licensing ===
+ * === Commercial Usage ===
+ *     If you want to use [The Product] in a commercial way (see definition above), you have to obtain a paid license from AppWork GmbH.
+ *     Contact AppWork for further details: e-mail@appwork.org
+ * === Non-Commercial Usage ===
+ *     If there is no commercial usage (see definition above), you may use [The Product] under the terms of the
+ *     "GNU Affero General Public License" (http://www.gnu.org/licenses/agpl-3.0.en.html).
+ *
+ *     If the AGPL does not fit your needs, please contact us. We'll find a solution.
+ * ====================================================================================================================================================
+ * ==================================================================================================================================================== */
+package org.appwork.exceptions;
+
+import org.appwork.resources.IconRef;
+import org.appwork.utils.locale._AWU;
+import org.appwork.utils.swing.dialog.DialogIcon;
+
+/**
+ * @author thomas
+ * @date 31.10.2025
+ *
+ */
+public abstract class ErrorReporter {
+
+    private static ErrorReporter INSTANCE;
+
+    /**
+     * @return the iNSTANCE
+     */
+    public static ErrorReporter getInstance() {
+        return INSTANCE;
+    }
+
+    /**
+     * @param iNSTANCE
+     *            the iNSTANCE to set
+     */
+    public static void setInstance(ErrorReporter iNSTANCE) {
+        INSTANCE = iNSTANCE;
+    }
+
+    /**
+     * @param exceptionDialog
+     */
+    public abstract void report(Object context);
+
+    /**
+     * @return
+     */
+    public String getActionName() {
+        return _AWU.T.errorreport_action_name();
+    }
+
+    /**
+     * @return
+     */
+    public IconRef getActionIcon() {
+        return DialogIcon.DIALOG_WARNING;
+    }
+
+}

svn_utils/src/org/appwork/io/streams/signature/HandleStreamSignatureInputStream.java

@@ -1,6 +1,5 @@
 package org.appwork.io.streams.signature;
 
-import java.io.DataInputStream;
 import java.io.DataOutputStream;
 import java.io.EOFException;
 import java.io.IOException;
@@ -15,28 +14,23 @@
 import org.appwork.utils.IO;
 
 public class HandleStreamSignatureInputStream extends InputStream {
-
     private DigestInterface     digester;
     private long                remainingPayloadSize = 0;
     private long                payloadBytesRead     = 0;
-
     private byte[]              nonceBytes;
-
     /**
      * Holds the calculated signature after reading a chunk
      */
     private byte[]              calculatedSignature;
     private long                lastValidPayloadPosition;
     private final byte[]        single;
     private HoldBackInputStream in;
-
     private final int           signatureLength;
     /**
      * is used to read the expected signature from the stream
      */
     private final byte[]        expectedSignature;
     private long                streamVersion        = -1;
-    private DataInputStream     dataIn;
     private boolean             closed;
     private DataOutputStream    digesterStream;
 
@@ -57,23 +51,18 @@ public HandleStreamSignatureInputStream(final InputStream is, Mac mac, final byt
      *            - works only if the MAc or MessageDigest supports cloneing
      */
     public HandleStreamSignatureInputStream(final InputStream is, DigestInterface digester, final byte[] nonceBytes) {
-
         single = new byte[1];
         signatureLength = digester.getLength();
-
         // +1 to detect EOF if we read exactly the payload length
         in = new HoldBackInputStream(is, signatureLength, 1);
-        dataIn = new DataInputStream(in);
         expectedSignature = new byte[signatureLength];
         this.digester = digester;
         digesterStream = new DataOutputStream(new DigesterOutputStream(digester));
         this.nonceBytes = nonceBytes;
-
     }
 
     protected void initChunkDigester(long chunkSize) throws IOException {
         StreamSignatureCreatingOutputStream.initChunkDigesterStatic(digesterStream, streamVersion, chunkSize, nonceBytes, calculatedSignature);
-
     }
 
     @Override
@@ -104,17 +93,15 @@ public long readVersionNumber() throws IOException {
     }
 
     public synchronized void mark(int readlimit) {
-
     }
 
     /*
      * (non-Javadoc)
-     *
+     * 
      * @see java.io.InputStream#markSupported()
      */
     @Override
     public boolean markSupported() {
-
         return false;
     }
 
@@ -133,18 +120,14 @@ private final int internalRead(final byte[] b, final int off, final int len) thr
             if (streamVersion == 1) {
                 // ok 08.10.2021
             } else {
-
                 throw new IOException("Unknown Streamversion");
             }
         }
-
         if (remainingPayloadSize == 0) {
             // init next chunk
             remainingPayloadSize = readNextPayloadBlockSize();
-
             initChunkDigester(remainingPayloadSize);
         }
-
         final int toRead = (int) Math.min(remainingPayloadSize, len);
         int actuallyRead = in.read(b, off, toRead);
         if (actuallyRead >= 0) {
@@ -153,14 +136,11 @@ private final int internalRead(final byte[] b, final int off, final int len) thr
             digesterStream.write(b, off, actuallyRead);
         }
         if (in.getTail() != null) {
-
             byte[] tail = in.getTail();
             if (len == 0) {
-
                 // the first time tail is set, len must be >0, else we would not have read anything
                 throw new WTFException("not possible here");
             }
-
             validateSignature(tail, true);
             // no return. it is possible to receive the tail, but return read bytes
         } else if (remainingPayloadSize == 0) {
@@ -172,7 +152,6 @@ private final int internalRead(final byte[] b, final int off, final int len) thr
                 if (count < 0) {
                     if (n == 0) {
                         // end of stream. the current buffer is the tail
-
                         if (in.getTail() == null || in.getTail().length != expectedSignature.length) {
                             throw new WTFException("Invalid Tail");
                         }
@@ -187,11 +166,9 @@ private final int internalRead(final byte[] b, final int off, final int len) thr
                 }
             }
             validateSignature(expectedSignature, tail);
-
             if (!tail) {
                 if (in.getTail() != null) {
                     // we reached the EOF while reading the signature.
-
                     throw new EOFException("Unexpected End Of Stream");
                 }
             }
@@ -207,10 +184,8 @@ public boolean isClosed() {
     }
 
     protected void validateSignature(byte[] tail, boolean eof) throws SignatureMismatchException, StreamEndedUnexpectedException {
-
         if (eof) {
             DigestInterface cloneBeforeEndSalt = null;
-
             if (remainingPayloadSize == 0) {
                 // we need the "incomplete stream" check only if remaining ==0. only if the stream got cut exactly after a block, we need to
                 // check if the final signature failed, or is just not an end signature.
@@ -224,38 +199,31 @@ protected void validateSignature(byte[] tail, boolean eof) throws SignatureMisma
                     // not supported
                     // e.printStackTrace();
                 }
-
             }
             digester.update(StreamSignatureCreatingOutputStream.END_SIGNATURE_SALT);
             calculatedSignature = digester.doFinal();
-
             if (!Arrays.equals(tail, calculatedSignature)) {
                 if (cloneBeforeEndSalt != null && Arrays.equals(tail, cloneBeforeEndSalt.doFinal())) {
                     // stream is broken end ended before the final block
                     // all bytes so far are correct, but the stream ended before the final block was read
                     this.lastValidPayloadPosition = payloadBytesRead;
-
                     throw new StreamEndedUnexpectedException();
                 }
                 throw new SignatureMismatchException();
             } else {
                 this.lastValidPayloadPosition = payloadBytesRead;
-
             }
-
         } else {
             calculatedSignature = digester.doFinal();
             if (!Arrays.equals(tail, calculatedSignature)) {
                 throw new SignatureMismatchException();
             } else {
                 this.lastValidPayloadPosition = payloadBytesRead;
-
             }
         }
     }
 
     protected long readHeader() throws IOException {
-
         return IO.readLongOptimized(in);
     }
 
@@ -277,19 +245,18 @@ public long getPayloadBytesLoaded() {
 
     /*
      * (non-Javadoc)
-     *
+     * 
      * @see java.io.InputStream#close()
      */
     @Override
     public void close() throws IOException {
         this.closed = true;
         in.close();
-
     }
 
     /*
      * (non-Javadoc)
-     *
+     * 
      * @see java.io.InputStream#skip(long)
      */
     @Override
@@ -307,7 +274,6 @@ public long skip(long n) throws IOException {
             }
             remaining -= ret;
         }
-
         return n - remaining;
     }