1 package org.apache.archiva.remotedownload;
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21 import org.apache.archiva.admin.model.beans.ManagedRepository;
22 import org.apache.archiva.admin.model.beans.ProxyConnector;
23 import org.apache.archiva.admin.model.beans.RemoteRepository;
24 import org.apache.archiva.admin.model.beans.RepositoryGroup;
25 import org.apache.archiva.maven2.model.Artifact;
26 import org.apache.archiva.redback.integration.security.role.RedbackRoleConstants;
27 import org.apache.archiva.redback.rest.services.FakeCreateAdminService;
28 import org.apache.archiva.rest.api.model.SearchRequest;
29 import org.apache.archiva.rest.api.services.ManagedRepositoriesService;
30 import org.apache.archiva.rest.api.services.ProxyConnectorService;
31 import org.apache.archiva.rest.api.services.RepositoriesService;
32 import org.apache.archiva.rest.api.services.RepositoryGroupService;
33 import org.apache.archiva.rest.api.services.SearchService;
34 import org.apache.archiva.test.utils.ArchivaBlockJUnit4ClassRunner;
35 import org.apache.commons.io.FileUtils;
36 import org.junit.After;
37 import org.junit.AfterClass;
38 import org.junit.BeforeClass;
39 import org.junit.Test;
40 import org.junit.runner.RunWith;
41
42 import java.io.File;
43 import java.io.IOException;
44 import java.nio.file.Files;
45 import java.nio.file.Path;
46 import java.nio.file.Paths;
47 import java.util.Arrays;
48 import java.util.List;
49
50 import static org.assertj.core.api.Assertions.assertThat;
51
52
53
54
55 @RunWith( ArchivaBlockJUnit4ClassRunner.class )
56 public class DownloadMergedIndexTest
57 extends AbstractDownloadTest
58 {
59
60 @BeforeClass
61 public static void setAppServerBase()
62 throws IOException
63 {
64 previousAppServerBase = System.getProperty( "appserver.base" );
65 System.setProperty( "appserver.base",
66 new File( System.getProperty( "java.io.tmpdir" ) ).getCanonicalPath() + "/target/"
67 + DownloadMergedIndexTest.class.getName()
68 );
69 }
70
71 @AfterClass
72 public static void resetAppServerBase()
73 {
74 System.setProperty( "appserver.base", previousAppServerBase );
75 }
76
77 @Override
78 protected String getSpringConfigLocation()
79 {
80 return "classpath*:META-INF/spring-context.xml classpath*:spring-context-test-common.xml classpath*:spring-context-merge-index-download.xml";
81 }
82
83 @After
84 public void cleanup()
85 throws Exception
86 {
87 super.tearDown();
88 File tmpIndexDir = new File( System.getProperty( "java.io.tmpdir" ) + "/tmpIndex" );
89 if ( tmpIndexDir.exists() )
90 {
91 FileUtils.deleteDirectory( tmpIndexDir );
92 }
93 }
94
95
96 @Test
97 public void downloadMergedIndex()
98 throws Exception
99 {
100 Path tmpIndexDir = Paths.get( System.getProperty( "java.io.tmpdir" ), "tmpIndex" );
101 if ( Files.exists( tmpIndexDir ) )
102 {
103 FileUtils.deleteDirectory( tmpIndexDir.toFile() );
104 }
105 String id = Long.toString( System.currentTimeMillis() );
106 ManagedRepository managedRepository = new ManagedRepository();
107 managedRepository.setId( id );
108 managedRepository.setName( "name of " + id );
109 managedRepository.setLocation( System.getProperty( "basedir" ) + "/src/test/repositories/test-repo" );
110 managedRepository.setIndexDirectory( System.getProperty( "java.io.tmpdir" ) + "/tmpIndex/" + id );
111
112 ManagedRepositoriesService managedRepositoriesService = getManagedRepositoriesService();
113
114 if ( managedRepositoriesService.getManagedRepository( id ) != null )
115 {
116 managedRepositoriesService.deleteManagedRepository( id, false );
117 }
118
119 getManagedRepositoriesService().addManagedRepository( managedRepository );
120
121 RepositoriesService repositoriesService = getRepositoriesService();
122
123 repositoriesService.scanRepositoryNow( id, true );
124
125
126 int timeout = 20000;
127 while ( timeout > 0 && repositoriesService.alreadyScanning( id ) )
128 {
129 Thread.sleep( 500 );
130 timeout -= 500;
131 }
132
133 RepositoryGroupService repositoryGroupService = getRepositoryGroupService();
134
135 String repoGroupId = "test-group";
136
137 if ( repositoryGroupService.getRepositoryGroup( repoGroupId ) != null )
138 {
139 repositoryGroupService.deleteRepositoryGroup( repoGroupId );
140 }
141
142 RepositoryGroup repositoryGroup = new RepositoryGroup();
143 repositoryGroup.setId( repoGroupId );
144 repositoryGroup.setRepositories( Arrays.asList( id ) );
145
146 repositoryGroupService.addRepositoryGroup( repositoryGroup );
147
148
149 id = Long.toString( System.currentTimeMillis() );
150 managedRepository = new ManagedRepository();
151 managedRepository.setId( id );
152 managedRepository.setName( "name of " + id );
153 managedRepository.setLocation( System.getProperty( "basedir" ) + "/src/test/repositories/test-repo" );
154 managedRepository.setIndexDirectory( System.getProperty( "java.io.tmpdir" ) + "/tmpIndex/" + id );
155
156 if ( managedRepositoriesService.getManagedRepository( id ) != null )
157 {
158 managedRepositoriesService.deleteManagedRepository( id, false );
159 }
160
161 getManagedRepositoriesService().addManagedRepository( managedRepository );
162
163 RemoteRepository remoteRepository = new RemoteRepository();
164 remoteRepository.setId( "all-merged" );
165 remoteRepository.setName( "all-merged" );
166 remoteRepository.setDownloadRemoteIndex( true );
167 remoteRepository.setUrl( "http://localhost:" + port + "/repository/test-group" );
168 remoteRepository.setRemoteIndexUrl( "http://localhost:" + port + "/repository/test-group/.indexer" );
169 remoteRepository.setUserName( RedbackRoleConstants.ADMINISTRATOR_ACCOUNT_NAME );
170 remoteRepository.setPassword( FakeCreateAdminService.ADMIN_TEST_PWD );
171
172 if ( getRemoteRepositoriesService().getRemoteRepository( remoteRepository.getId() ) != null )
173 {
174 getRemoteRepositoriesService().deleteRemoteRepository( remoteRepository.getId() );
175 }
176
177 getRemoteRepositoriesService().addRemoteRepository( remoteRepository );
178
179 ProxyConnectorService proxyConnectorService = getProxyConnectorService();
180 ProxyConnector proxyConnector = new ProxyConnector();
181 proxyConnector.setProxyId( "foo-bar1" );
182 proxyConnector.setSourceRepoId( id );
183 proxyConnector.setTargetRepoId( "all-merged" );
184 proxyConnectorService.addProxyConnector( proxyConnector );
185
186 repositoriesService.scheduleDownloadRemoteIndex( "all-merged", true, true );
187
188
189 timeout = 20000;
190 while ( timeout > 0 )
191 {
192 Thread.sleep( 500 );
193 timeout -= 500;
194 }
195
196 SearchService searchService = getSearchService();
197
198 SearchRequest request = new SearchRequest();
199 request.setRepositories( Arrays.asList( id ) );
200 request.setGroupId( "org.apache.felix" );
201
202 List<Artifact> artifacts = searchService.searchArtifacts( request );
203 assertThat( artifacts ).isNotNull().isNotEmpty().hasSize( 1 );
204
205 }
206 }