}

        if (isSearchField(field)) {
            context.addFieldLog(field, text);
            stream(texts).of(stream -> stream.forEach(t -> context.addHighlightedQuery(t)));
            return buildMatchPhraseQuery(field, text);
        }

        context.addFieldLog(Constants.DEFAULT_FIELD, text);

                int[] cipherArray = ciphers.stream().mapToInt(Integer::intValue).toArray();
                negoContexts.add(new EncryptionNegotiateContext(config, cipherArray));
            }

            // Add compression context for SMB3 compression support
            if (config.isCompressionEnabled()) {
                negoContexts.add(new CompressionNegotiateContext(config, new int[] { CompressionNegotiateContext.COMPRESSION_LZ77,

        final String field = getSearchField(context.getDefaultField(), term.field());

        if (Constants.DEFAULT_FIELD.equals(field)) {
            final String text = term.text();
            context.addFieldLog(field, text);
            context.addHighlightedQuery(text);
            return buildDefaultQueryBuilder(fessConfig, context,
                    (f, b) -> QueryBuilders.fuzzyQuery(f, text)

        dstIndex += 4;

        SMBUtil.writeInt2(4, dst, dstIndex); // NameOffset (from start of context)
        dstIndex += 2;

        SMBUtil.writeInt2(4, dst, dstIndex); // NameLength
        dstIndex += 2;

        SMBUtil.writeInt2(0, dst, dstIndex); // Reserved
        dstIndex += 2;

        SMBUtil.writeInt2(24, dst, dstIndex); // DataOffset (from start of context)

        assertTrue(context.supportsAlgorithm(CompressionNegotiateContext.COMPRESSION_LZ77));
        assertTrue(context.supportsAlgorithm(CompressionNegotiateContext.COMPRESSION_LZ77_HUFFMAN));
        assertTrue(context.supportsAlgorithm(CompressionNegotiateContext.COMPRESSION_LZNT1));
        assertFalse(context.supportsAlgorithm(CompressionNegotiateContext.COMPRESSION_PATTERN_V1));
    }

    @Test
    @DisplayName("Test context encoding")

     * @return The access context.
     */
    public AccessContext create(final AccessContextResource resource, final UserTypeSupplier userTypeSupplier,
            final UserBeanSupplier userBeanSupplier, final AppTypeSupplier appTypeSupplier) {
        final AccessContext context = new AccessContext();
        context.setAccessLocalDateTimeProvider(() -> timeManager.currentDateTime());

	Delete(ctx context.Context) (rowsAffected int, err error)
	Update(ctx context.Context, name string, value any) (rowsAffected int, err error)
	Updates(ctx context.Context, t T) (rowsAffected int, err error)
	Count(ctx context.Context, column string) (result int64, err error)
}

type ExecInterface[T any] interface {
	Scan(ctx context.Context, r interface{}) error
	First(context.Context) (T, error)

        assertFalse(context.hasDefaultCredentials());
    }

    @Test
    void testHasDefaultCredentials_withNull() {
        context = new TestAbstractCIFSContext(null); // Test with null credentials
        assertFalse(context.hasDefaultCredentials());
    }

    @Test
    void testRenewCredentials() {
        assertFalse(context.renewCredentials("someLocation", new Exception("someError")));
    }

    @Test

				shutdownLogIf(context.Background(), err)
			}
		}

		if objAPI := newObjectLayerFn(); objAPI != nil {
			shutdownLogIf(context.Background(), objAPI.Shutdown(context.Background()))
		}

		if globalBrowserEnabled {
			if srv := newConsoleServerFn(); srv != nil {
				shutdownLogIf(context.Background(), srv.Shutdown())
			}
		}

		if globalEventNotifier != nil {

    @Override
    public int size() {
        // Context header (16) + name length (4) + padding to 8-byte alignment + data (16)
        return 16 + 4 + 4 + STRUCTURE_SIZE;
    }

    @Override
    public int encode(byte[] dst, int dstIndex) {
        int start = dstIndex;

        // Write context header
        SMBUtil.writeInt4(0, dst, dstIndex); // Next (offset to next context, 0 for last)
        dstIndex += 4;