//
// You should have received a copy of the GNU Affero General Public License
// along with this program.  If not, see <http://www.gnu.org/licenses/>.

package config

import (
	"bytes"
	"context"
	"crypto/rand"
	"encoding/binary"
	"errors"
	"fmt"
	"io"

	jsoniter "github.com/json-iterator/go"
	"github.com/minio/minio/internal/kms"
	"github.com/secure-io/sio-go"

            // Structure Size (2 bytes) - must be 60
            SMBUtil.writeInt2(60, buffer, bufferIndex);
            // Flags (2 bytes)
            SMBUtil.writeInt2(SMB2_CLOSE_FLAG_POSTQUERY_ATTIB, buffer, bufferIndex + 2);
            // Reserved (4 bytes)
            SMBUtil.writeInt4(0, buffer, bufferIndex + 4);
            // Creation Time (8 bytes)

        // status (2 bytes)
        SMBUtil.writeInt2(0, buffer, bufferIndex);
        bufferIndex += 2;
        // converter (2 bytes)
        SMBUtil.writeInt2(100, buffer, bufferIndex);
        bufferIndex += 2;
        // numEntries (2 bytes)
        SMBUtil.writeInt2(3, buffer, bufferIndex);
        bufferIndex += 2;
        // totalAvailableEntries (2 bytes)

    }

    /**
     * Sets the minimum number of bytes that must be read for the operation to succeed
     *
     * @param minimumCount
     *            the minimumCount to set
     */
    public void setMinimumCount(final int minimumCount) {
        this.minimumCount = minimumCount;
    }

    /**
     * Sets the number of bytes remaining to be read after this request
     *

        while (this[mid + end] != '\n'.code.toByte()) {
          end++
        }
        val publicSuffixLength = mid + end - mid

        // Compare the bytes. Note that the file stores UTF-8 encoded bytes, so we must compare the
        // unsigned bytes.
        var compareResult: Int
        var currentLabelIndex = labelIndex
        var currentLabelByteIndex = 0
        var publicSuffixByteIndex = 0

    public Smb2WriteResponse(final Configuration config) {
        super(config);
    }

    /**
     * Returns the number of bytes written.
     *
     * @return the count
     */
    public final int getCount() {
        return this.count;
    }

    /**
     * Returns the number of bytes remaining to be written.
     *
     * @return the remaining
     */
    public final int getRemaining() {

        byte[] buffer = new byte[24];

        // Mock allocation size (8 bytes)
        for (int i = 0; i < 8; i++) {
            buffer[i] = (byte) i;
        }

        // Mock end of file (8 bytes)
        for (int i = 8; i < 16; i++) {
            buffer[i] = (byte) (i * 2);
        }

        // Mock number of links (4 bytes)
        buffer[16] = 0x01;
        buffer[17] = 0x00;

        return Stream.of(
                // 0 bytes
                Arguments.of(0L, null, "0 B"),
                Arguments.of(0L, ScaleUnit.BYTE, "0 B"),
                Arguments.of(0L, ScaleUnit.KILOBYTE, "0 kB"),
                Arguments.of(0L, ScaleUnit.MEGABYTE, "0 MB"),
                Arguments.of(0L, ScaleUnit.GIGABYTE, "0 GB"),

                // 5 bytes
                Arguments.of(5L, null, "5 B"),

  }

  @Override public void onMessage(WebSocket webSocket, String text) {
    System.out.println("MESSAGE: " + text);
  }

  @Override public void onMessage(WebSocket webSocket, ByteString bytes) {
    System.out.println("MESSAGE: " + bytes.hex());
  }

  @Override public void onClosing(WebSocket webSocket, int code, String reason) {
    webSocket.close(1000, null);
    System.out.println("CLOSE: " + code + " " + reason);
  }

            int bytesWritten = request.writeBytesWireFormat(buffer, 0);

            // Should only copy first 16 bytes
            assertArrayEquals(Arrays.copyOfRange(longFileId, 0, 16), Arrays.copyOfRange(buffer, 16, 32));
        }

        @Test
        @DisplayName("Should handle file ID shorter than 16 bytes")
        void testShortFileId() {
            byte[] shortFileId = new byte[8];