Package org.sonatype.nexus.proxy.repository

Examples of org.sonatype.nexus.proxy.repository.ProxyRepository

95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
  @Test
  public void deleteNonCollection()
      throws Exception
  {
    final ProxyRepository repo1 = getRepositoryRegistry().getRepositoryWithFacet("repo1", ProxyRepository.class);
    repo1.retrieveItem(new ResourceStoreRequest("/spoof/spoof/1.0/spoof-1.0.txt"));
    repo1.retrieveItem(new ResourceStoreRequest("/spoof/maven-metadata.xml"));

    // install listener
    final DeleteEventsListener listener = new DeleteEventsListener();
    eventBus().register(listener);

    // perform delete
    repo1.deleteItem(new ResourceStoreRequest("/spoof/maven-metadata.xml"));

    // 1 events: the actual non-collection being deleted, no recursion happens
    assertThat(listener.getDeleteEvents().size(), equalTo(1));
    assertThat(listener.getDeleteEvents().get(0).getClass().getName(),
        equalTo(RepositoryItemEventDeleteRoot.class.getName()));
View Full Code Here
71
72
73
74
75
76
77
78
79
80
81
82
83
      throws Exception
  {
    final HttpClientRemoteStorage underTest =
        new HttpClientRemoteStorage(Providers.of(mock(SystemStatus.class)),
            mock(MimeSupport.class), mock(QueryStringBuilder.class), mock(HttpClientManager.class));
    final ProxyRepository proxyMock = mock(ProxyRepository.class);
    when(proxyMock.getId()).thenReturn("id");
    when(proxyMock.getRemoteStorageContext()).thenReturn(new DefaultRemoteStorageContext(null));

    thrown.expect(RemoteItemNotFoundException.class);
    thrown.expectMessage("not found in remote storage of repository");

    underTest.retrieveItem(proxyMock, new ResourceStoreRequest("bar/"), "http://foo.com");
View Full Code Here
92
93
94
95
96
97
98
99
100
101
102
103
104
      throws Exception
  {
    final HttpClientRemoteStorage underTest =
        new HttpClientRemoteStorage(Providers.of(mock(SystemStatus.class)),
            mock(MimeSupport.class), mock(QueryStringBuilder.class), mock(HttpClientManager.class));
    final ProxyRepository proxyMock = mock(ProxyRepository.class);
    when(proxyMock.getId()).thenReturn("id");
    when(proxyMock.getRemoteStorageContext()).thenReturn(new DefaultRemoteStorageContext(null));

    thrown.expect(RemoteItemNotFoundException.class);
    thrown.expectMessage("not found in remote storage of repository");

    underTest.retrieveItem(proxyMock, new ResourceStoreRequest("bar/?param=x/"),
View Full Code Here
114
115
116
117
118
119
120
121
122
123
124
125
126
      throws Exception
  {
    final HttpClientRemoteStorage underTest =
        new HttpClientRemoteStorage(Providers.of(mock(SystemStatus.class)),
            mock(MimeSupport.class), mock(QueryStringBuilder.class), mock(HttpClientManager.class));
    final ProxyRepository proxyMock = mock(ProxyRepository.class);
    when(proxyMock.getId()).thenReturn("id");
    when(proxyMock.getRemoteStorageContext()).thenReturn(new DefaultRemoteStorageContext(null));

    thrown.expect(RemoteItemNotFoundException.class);
    thrown.expectMessage("not found in remote storage of repository");

    underTest.retrieveItem(proxyMock, new ResourceStoreRequest("bar/?param=x"),
View Full Code Here
152
153
154
155
156
157
158
159
160
161
162
            when(httpResponse.getEntity()).thenReturn(mock(HttpEntity.class));
            return httpResponse;
          }
        };

    final ProxyRepository proxyMock = mock(ProxyRepository.class);
    when(proxyMock.getId()).thenReturn("foo");
    when(proxyMock.getRemoteStorageContext()).thenReturn(new DefaultRemoteStorageContext(null));

    underTest.retrieveItem(proxyMock, new ResourceStoreRequest("bar?param=x"), "http://foo.com");
  }
View Full Code Here
194
195
196
197
198
199
200
201
202
203
204
205
206
207
          new HttpClientRemoteStorage(Providers.of(mock(SystemStatus.class)),
              mock(MimeSupport.class), mock(QueryStringBuilder.class), new HttpClientManagerImpl(httpClientFactory));

      // a mock proxy repository with some mocks to make RRS work
      final RemoteStorageContext proxyContext = new DefaultRemoteStorageContext(globalRemoteStorageContext);
      final ProxyRepository repository = mock(ProxyRepository.class);
      when(repository.getId()).thenReturn("foo");
      when(repository.getName()).thenReturn("foo");
      when(repository.getRemoteStorageContext()).thenReturn(proxyContext);

      // a mock remote server that will simply "hang" to occupy the request socket
      final Server server =
          Server.withPort(0).serve("/").withBehaviours(Behaviours.pause(Time.days(1))).start();
      // the URL we will try to connect to
View Full Code Here
273
274
275
276
277
278
279
280
281
282
283
284
285
            when(httpResponse.getEntity()).thenReturn(mock(HttpEntity.class));
            return httpResponse;
          }
        };

    final ProxyRepository proxyMock = mock(ProxyRepository.class);
    when(proxyMock.getId()).thenReturn("foo");
    when(proxyMock.getRemoteUrl()).thenReturn("http://repo1.maven.org/maven2/");
    when(proxyMock.getRemoteStorageContext()).thenReturn(new DefaultRemoteStorageContext(null));
   
    assertThat(underTest.checkRemoteAvailability(0, proxyMock, new ResourceStoreRequest("/"), false), is(true));
    assertThat(underTest.checkRemoteAvailability(System.currentTimeMillis(), proxyMock, new ResourceStoreRequest("/"), false), is(false));
  }
View Full Code Here
124
125
126
127
128
129
130
131
132
133
134
135
136
137
      // old way
      remotePath = storageItem.getRequestPath().substring(1);
    }

    try {
      ProxyRepository proxyRepository = getUnprotectedRepositoryRegistry().getRepositoryWithFacet(id,
          ProxyRepository.class);
      HttpClient client = httpClientProvider.create(
          new RemoteStorageContextCustomizer(proxyRepository.getRemoteStorageContext()));

      MavenRepositoryReader mr = new MavenRepositoryReader(client, queryStringBuilder);
      MavenRepositoryReaderResponse data = new MavenRepositoryReaderResponse();
      // FIXME: Sort this out, NEXUS-4058 was closed about a year go (orig: we really should not do the encoding here, but this is work around until NEXUS-4058 is fixed).
      String localUrl = createRemoteResourceReference(request, id, "").toString(false, false);
View Full Code Here
59
60
61
62
63
64
65
66
67
68
69
70
    final Repository repository = uid.getRepository();
    final ResourceStoreRequest request = new ResourceStoreRequest(uid.getPath());

    if (repository.getRepositoryKind().isFacetAvailable(ProxyRepository.class)) {
      final ProxyRepository proxyRepository = repository.adaptToFacet(ProxyRepository.class);
      final RemoteRepositoryStorage storage = proxyRepository.getRemoteStorage();
      if (storage != null) {
        return storage.getAbsoluteUrlFromBase(proxyRepository, request);
      }
      // locally hosted proxy repository, so drop through...
    }
View Full Code Here
113
114
115
116
117
118
119
120
121
122
123
124
125
  @Test
  public void verifyProcessAfterProxy()
      throws Exception
  {
    ProxyRepository repository = mock(ProxyRepository.class);
    mockRepository(repository, "repo5");
    when(repository.getRemoteUrl()).thenReturn("http://localhost:8082/nexus/content/repositories/thirdparty");

    MetadataProcessor.processProxiedMetadata(repository);

    ArgumentCaptor<ResourceStoreRequest> deleteRequests = ArgumentCaptor.forClass(ResourceStoreRequest.class);
    verify(repository).deleteItem(eq(false), deleteRequests.capture());
View Full Code Here
TOP

Related Classes of org.sonatype.nexus.proxy.repository.ProxyRepository

  • com.sonatype.nexus.ssl.plugin.internal.rest.CertificatesResource
  • org.sonatype.nexus.index.DefaultIndexerManager
  • org.sonatype.nexus.index.DefaultIndexerManagerIT
  • org.sonatype.nexus.obr.metadata.ManagedObrSite
  • org.sonatype.nexus.plugins.p2.repository.proxy.P2ProxyRepositoryConfigurator
  • org.sonatype.nexus.plugins.rrb.MavenRepositoryReaderIT
  • org.sonatype.nexus.plugins.rrb.RemoteBrowserResource
  • org.sonatype.nexus.proxy.DeleteEventsTest
  • org.sonatype.nexus.proxy.maven.AbstractMavenRepositoryConfigurator
  • org.sonatype.nexus.proxy.storage.remote.httpclient.HttpClientRemoteStorageTest
    • Copyright © 2018 www.massapicom. All rights reserved.
    All source code are property of their respective owners. Java is a trademark of Sun Microsystems, Inc and owned by ORACLE Inc. Contact coftware#gmail.com.