@Test
    @DisplayName("readn should handle EOF correctly")
    void testReadnEOF() throws IOException {
        byte[] buffer = new byte[10];
        ByteArrayInputStream bais = new ByteArrayInputStream(new byte[0]);

        int bytesRead = SessionServicePacket.readn(bais, buffer, 0, 5);

        assertEquals(0, bytesRead);
    }

    @Test
    @DisplayName("readn should handle multiple read calls")

        ASN1EncodableVector authVector = new ASN1EncodableVector();
        ASN1EncodableVector elementVector = new ASN1EncodableVector();
        elementVector.add(new DERTaggedObject(0, new ASN1Integer(1))); // authType
        elementVector.add(new DERTaggedObject(1, new DEROctetString(new byte[] { 0x01, 0x02 }))); // authData
        authVector.add(new DERSequence(elementVector));

        byte[] token = new DERSequence(authVector).getEncoded();

        });

        ComponentUtil.register(new KeyMatchHelper() {
            @Override
            public void update() {
                // Mock update
            }
        }, "keyMatchHelper");

        crawlJob.webConfigIds(new String[] { "web1", "web2" });
        crawlJob.fileConfigIds(new String[] { "file1" });
        crawlJob.dataConfigIds(new String[] { "data1", "data2", "data3" });

    void multipleWriteBodyWireFormat_shouldProduceSameResult() {
        // Arrange
        Name realName = new Name(mockConfig, "SERVER", 0x20, "domain.local");
        nodeStatusRequest = new NodeStatusRequest(mockConfig, realName);
        byte[] dst1 = new byte[100];
        byte[] dst2 = new byte[100];

        // Act
        int result1 = nodeStatusRequest.writeBodyWireFormat(dst1, 0);

        StopwordsItem item1 = new StopwordsItem(1, "test");
        StopwordsItem item2 = new StopwordsItem(1, "test");
        StopwordsItem item3 = new StopwordsItem(2, "test");
        StopwordsItem item4 = new StopwordsItem(1, "different");

        // Same input should have same hashCode regardless of id
        assertEquals(item1.hashCode(), item2.hashCode());
        assertEquals(item1.hashCode(), item3.hashCode());

        queryCommand = new WildcardQueryCommand();
        queryCommand.register();
    }

    public void test_convertWildcardQuery_defaultField() throws Exception {
        // Test with default field
        QueryContext queryContext = new QueryContext("test*", false);
        WildcardQuery wildcardQuery = new WildcardQuery(new Term(Constants.DEFAULT_FIELD, "test*"));

  @GwtIncompatible // Iterables.filter(Iterable, Class)
  public void testFilterByType_iterator() throws Exception {
    HasBoth hasBoth = new HasBoth();
    Iterable<TypeA> alist = Lists.newArrayList(new TypeA(), new TypeA(), hasBoth, new TypeA());
    Iterable<TypeB> blist = filter(alist, TypeB.class);
    assertThat(blist).containsExactly(hasBoth).inOrder();
  }

        assertEquals(new BigDecimal("100"), BigDecimalConversionUtil.toBigDecimal(Integer.valueOf(100)));
        assertEquals(new BigDecimal("1000"), BigDecimalConversionUtil.toBigDecimal(Long.valueOf(1000L)));

        assertEquals(0, new BigDecimal("0.1").compareTo(BigDecimalConversionUtil.toBigDecimal(Float.valueOf(0.1F))));

        switch (previous) {
          case NEW:
            snapshot = new StateSnapshot(TERMINATED);
            enqueueTerminatedEvent(NEW);
            break;
          case STARTING:
            snapshot = new StateSnapshot(STARTING, true, null);
            enqueueStoppingEvent(STARTING);
            doCancelStart();
            break;
          case RUNNING:
            snapshot = new StateSnapshot(STOPPING);

public class ActivityHelperTest extends UnitFessTestCase {

    private ActivityHelper activityHelper;

    private ThreadLocal<String> localLogMsg = new ThreadLocal<>();

    @Override
    public void setUp() throws Exception {
        super.setUp();
        activityHelper = new ActivityHelper() {
            @Override
            protected void printByLtsv(final Map<String, String> valueMap) {
                valueMap.remove("time");