return 0;
    }

    @Override
    protected int writeDataWireFormat(final byte[] dst, final int dstIndex) {
        if (dst.length - dstIndex < this.pipeDataLen) {
            log.debug("TransCallNamedPipe data too long for buffer");
            return 0;
        }
        System.arraycopy(this.pipeData, this.pipeDataOff, dst, dstIndex, this.pipeDataLen);
        return this.pipeDataLen;
    }

    @Override

        return 0;
    }

    @Override
    protected int writeDataWireFormat(final byte[] dst, final int dstIndex) {
        if (dst.length - dstIndex < this.pipeDataLen) {
            log.debug("TransTransactNamedPipe data too long for buffer");
            return 0;
        }
        System.arraycopy(this.pipeData, this.pipeDataOff, dst, dstIndex, this.pipeDataLen);
        return this.pipeDataLen;
    }

    @Override

        });
    }

    @Test
    @DisplayName("Should handle buffer underflow during decode")
    void testBufferUnderflowDecode() {
        // Given
        byte[] shortBuffer = new byte[20]; // Too short for transform header

        // When/Then
        assertThrows(Exception.class, () -> {
            Smb2TransformHeader.decode(shortBuffer, 0);
        });
    }

    @Test

     */
    protected void setupListCondition(final JobLogCB cb, final JobLogPager jobLogPager) {
        if (jobLogPager.id != null) {
            cb.query().docMeta().setId_Equal(jobLogPager.id);
        }
        // TODO Long, Integer, String supported only.

        // setup condition
        cb.query().addOrderBy_StartTime_Desc();
        cb.query().addOrderBy_EndTime_Desc();

        // search

    }

    /**

     * </p>
     */
    public DataSerializer() {
        kryoThreadLocal = ThreadLocal.withInitial(() -> {
            final Kryo kryo = new Kryo();
            // TODO use kryo.register for security
            // SECURITY WARNING: setRegistrationRequired(false) allows deserialization of arbitrary classes
            // which could potentially lead to remote code execution vulnerabilities.

 * This job removes old crawling sessions, search logs, job logs, and user info logs
 * based on configured retention periods. It helps maintain system performance by
 * preventing log tables from growing too large.
 */
public class PurgeLogJob {

    /** Logger instance for this class */
    private static final Logger logger = LogManager.getLogger(PurgeLogJob.class);

    /**
     * Default constructor for PurgeLogJob.

    }

    @Test
    @DisplayName("Should throw exception when buffer too small")
    void testWriteBytesWireFormatBufferTooSmall() {
        // Given
        Configuration mockConfig = mock(Configuration.class);
        Smb2TreeDisconnectRequest request = new Smb2TreeDisconnectRequest(mockConfig);
        byte[] buffer = new byte[3]; // Too small for 4 bytes

        // When & Then

        // Then
        assertEquals(4, bytesRead);
    }

    @Test
    @DisplayName("Should throw exception when buffer too small for reading")
    void testReadBytesWireFormatBufferTooSmall() {
        // Given
        byte[] buffer = new byte[1]; // Too small to read structure size

        // When & Then
        assertThrows(ArrayIndexOutOfBoundsException.class, () -> {

    }

    @Test
    @DisplayName("Test invalid buffer size for decoding")
    public void testInvalidBufferSize() {
        byte[] smallBuffer = new byte[4]; // Too small

        assertThrows(SMBProtocolDecodingException.class, () -> {
            context.decode(smallBuffer, 0, smallBuffer.length);
        });
    }

    @Test
    @DisplayName("Test algorithm name resolution")

            this.path = filename;
        } else {
            this.path = filename + "\\";
        }
        this.wildcard = wildcard;
        this.searchAttributes = searchAttributes & 0x37; /* generally ignored tho */
        command = SMB_COM_TRANSACTION2;
        subCommand = TRANS2_FIND_FIRST2;

        flags = 0x00;
        informationLevel = SMB_FILE_BOTH_DIRECTORY_INFO;

        totalDataCount = 0;