TransferResource resource = event.getResource();
        transfers.put(
                new TransferResourceIdentifier(resource),
                new TransferResourceAndSize(resource, event.getTransferredBytes()));

        StringBuilder buffer = new StringBuilder(128);
        buffer.append("Progress (").append(transfers.size()).append("): ");

        synchronized (transfers) {

         */

        if (artifact.isSnapshot()) {
            Snapshot snapshot = new Snapshot();
            snapshot.setLocalCopy(true);
            artifact.addMetadata(new SnapshotArtifactRepositoryMetadata(artifact, snapshot));
        }

        Versioning versioning = new Versioning();
        // TODO Should this be changed for MNG-6754 too?
        versioning.updateTimestamp();

    /**
     * Test the readParameterWordsWireFormat method.
     */
    @Test
    void testReadParameterWordsWireFormat() {
        SmbComWriteAndXResponse response = new SmbComWriteAndXResponse();
        byte[] buffer = new byte[] { 0x0A, 0x00, 0x00, 0x00, 0x00, 0x00, 0x00, 0x00 }; // count = 10

        int bytesRead = response.readParameterWordsWireFormat(buffer, 0);

        // The count should be read from the buffer.

public class ServerResponseValidatorTest {

    private ServerResponseValidator validator;

    @BeforeEach
    public void setUp() {
        validator = new ServerResponseValidator();
    }

    @Test
    public void testValidBuffer() throws Exception {
        byte[] buffer = new byte[1024];
        validator.validateBuffer(buffer, 100, 2048);
        // Should pass without exception
    }

    @Test

  protected void checkCanCreate() {
    if (subjectGenerator == null) {
      throw new IllegalStateException("Call using() before createTestSuite().");
    }
    if (name == null) {
      throw new IllegalStateException("Call named() before createTestSuite().");
    }
    if (features == null) {
      throw new IllegalStateException("Call withFeatures() before createTestSuite().");
    }
  }

        // Given
        when(mockDelegate.hasNext()).thenReturn(false);
        CIFSException exception = new CIFSException("Test exception");
        doThrow(exception).when(mockDelegate).close();

        DirFileEntryAdapterIterator iterator = new DirFileEntryAdapterIterator(mockParent, mockDelegate, null) {
            @Override
            protected SmbResource adapt(FileEntry e) {

      return new GoodEquals(a, b);
    }

    // instance method ignored
    public Object badIgnored() {
      return new BadEquals();
    }

    // primitive ignored
    public int returnsInt() {
      throw new UnsupportedOperationException();
    }

    // void ignored
    public void voidMethod() {
      throw new UnsupportedOperationException();
    }

        if (mergedItems.length == 0) {
            return new SuggestWriterResult();
        }

        for (final SuggestItem item : mergedItems) {
            final GetResponse getResponse = client.prepareGet().setIndex(index).setId(item.getId()).get(settings.getIndexTimeout());
            if (update && getResponse.isExists()) {
                final IndexRequestBuilder indexRequestBuilder = new IndexRequestBuilder(client, IndexAction.INSTANCE, index);

    @BeforeEach
    void setUp() {
        response = new SrvRequestResumeKeyResponse();
    }

    @Test
    @DisplayName("Test successful decode with valid resume key")
    void testDecodeValidResumeKey() throws SMBProtocolDecodingException {
        // Prepare test data - 24 bytes for resume key + 4 bytes for context length
        byte[] buffer = new byte[28];

        // Fill resume key with test pattern

public final class CertificatePinning {
  private final OkHttpClient client = new OkHttpClient.Builder()
      .certificatePinner(
          new CertificatePinner.Builder()
              .add("publicobject.com", "sha256/Vjs8r4z+80wjNcr1YKepWQboSIRi63WsWXhIMN+eWys=")
              .build())
      .build();

  public void run() throws Exception {
    Request request = new Request.Builder()
        .url("https://publicobject.com/robots.txt")