assertEquals("Boolean value should match", original, deserialized);
    }

    // ========== Security Tests ==========

    /**
     * Security test: Verify that unregistered classes are rejected during serialization.
     * This test ensures that the Kryo registration requirement is working correctly.
     * Unregistered classes should throw an exception to prevent potential RCE attacks.
     */
    @Test

   * will silently add the missing nodes to the graph, then add the edge connecting them. We are not
   * using the proxy methods here as we want to test {@code addEdge} when the end-points are not
   * elements of the graph.
   */
  @Test
  public void addEdge_nodesNotInGraph() {
    assume().that(graphIsMutable()).isTrue();

@NullUnmarked
public class AbstractNonStreamingHashFunctionTest extends TestCase {
  /**
   * Constructs two trivial HashFunctions (output := input), one streaming and one non-streaming,
   * and checks that their results are identical, no matter which newHasher version we used.
   */
  public void testExhaustive() {
    List<Hasher> hashers =
        ImmutableList.of(
            new StreamingVersion().newHasher(),

 */
@NullUnmarked
public class MessageDigestHashFunctionTest extends TestCase {
  private static final ImmutableSet<String> INPUTS = ImmutableSet.of("", "Z", "foobar");

  // From "How Provider Implementations Are Requested and Supplied" from
  // https://docs.oracle.com/en/java/javase/25/security/java-cryptography-architecture-jca-reference-guide.html#:~:text=How%20Provider%20Implementations%20Are%20Requested%20and%20Supplied

                        + " <plugin-group-id>:<plugin-artifact-id>[:<plugin-version>]:<goal>."
                        + " Available lifecycle phases are: " + defaultLifeCycles.getLifecyclePhaseList() + ".");
            }

            if (logger.isDebugEnabled()) {
                lifecycleDebugLogger.debugReactorPlan(projectBuilds);
            }

                }
                this.passwordLength = this.password.length;
            } else if (this.ctx.getConfig().isDisablePlainTextPasswords()) {
                throw new RuntimeCIFSException("Plain text passwords are disabled");
            } else {
                // plain text
                this.password = new byte[(pwAuth.getPassword().length() + 1) * 2];

    private Map<String, MojoExecution> mergeMojos(Map<String, MojoExecution> l1, Map<String, MojoExecution> l2) {
        l2.forEach(l1::putIfAbsent);
        return l1;
    }

    // gather artifactIds which are not unique so that the respective thread names can be extended with the groupId
    public Set<String> duplicateIds() {
        if (duplicateIds == null) {
            synchronized (this) {

   *
   * <p>This method always throws an exception. The {@code RuntimeException} return type allows
   * client code to signal to the compiler that statements after the call are unreachable. Example
   * usage:
   *
   * <pre>
   * T doSomething() {
   *   try {
   *     return someMethodThatCouldThrowAnything();
   *   } catch (IKnowWhatToDoWithThisException e) {

            // After checking SMB code, directories are deleted using SmbComDelete with ATTR_DIRECTORY
            when(mockTreeHandle.send(any(SmbComDelete.class), any(SmbComBlankResponse.class))).thenReturn(mock(SmbComBlankResponse.class));

            // Act
            smbFile.delete();

            // Assert - directories are actually deleted using SmbComDelete with the directory attribute

    }

    /**
     * Loads the available searcher names from system properties.
     * Parses the "rank.fusion.searchers" system property to determine which searchers
     * are available for use in rank fusion processing.
     */
    protected void load() {
        final String value = System.getProperty("rank.fusion.searchers");
        if (StringUtil.isBlank(value)) {