"AdministrationService.deleteArtifact",
"AdministrationService.addManagedRepository",
"AdministrationService.deleteManagedRepository", "AdministrationService.getManagedRepository",
- "AdministrationService.merge");
+ "AdministrationService.merge",
+ "AdministrationService.deleteManagedRepositoryContent");
public static final List<String> SERVICE_METHODS_FOR_OPERATION_RUN_INDEXER =
Arrays.asList( "AdministrationService.executeRepositoryScanner" );
return Boolean.TRUE;
}
+ public Boolean deleteManagedRepositoryContent( String repoId )
+ throws Exception
+ {
+ Configuration config = archivaConfiguration.getConfiguration();
+
+ ManagedRepositoryConfiguration repository = config.findManagedRepositoryById( repoId );
+
+ if ( repository == null )
+ {
+ throw new Exception( "Repository Id : " + repoId + " not found." );
+ }
+
+ RepositorySession repositorySession = repositorySessionFactory.createSession();
+ try
+ {
+ MetadataRepository metadataRepository = repositorySession.getRepository();
+ metadataRepository.removeRepository( repository.getId() );
+ repositorySession.save();
+ }
+ finally
+ {
+ repositorySession.close();
+ }
+
+ File repoDir = new File( repository.getLocation() );
+ File[] children = repoDir.listFiles();
+
+ if ( children != null )
+ {
+ for ( File child : children )
+ {
+ FileUtils.deleteDirectory( child );
+ }
+ }
+
+ return Boolean.TRUE;
+ }
+
public ManagedRepository getManagedRepository( String repoId )
throws Exception
{
assertRemoteRepo( repos.get( 1 ), remoteRepos.get( 1 ) );
}
+ public void testDeleteInvalidRepositoryContent()
+ {
+ archivaConfigControl.expectAndReturn( archivaConfig.getConfiguration(), config );
+ configControl.expectAndReturn( config.findManagedRepositoryById( "invalid" ), null );
+
+ archivaConfigControl.replay();
+ configControl.replay();
+
+ try
+ {
+ service.deleteManagedRepositoryContent( "invalid" );
+ }
+ catch ( Exception e )
+ {
+ assertEquals( "Repository Id : invalid not found.", e.getMessage() );
+ }
+
+ archivaConfigControl.verify();
+ configControl.verify();
+ }
+
+ public void testDeleteRepositoryContent()
+ throws Exception
+ {
+ ManagedRepositoryConfiguration managedRepo = createManagedRepo( "default", "default-repo" );
+ assertTrue( new File( managedRepo.getLocation(), "org" ).exists() );
+
+ archivaConfigControl.expectAndReturn( archivaConfig.getConfiguration(), config );
+ configControl.expectAndReturn( config.findManagedRepositoryById( "internal" ), managedRepo );
+ metadataRepository.removeRepository( "internal" );
+
+ archivaConfigControl.replay();
+ configControl.replay();
+ metadataRepositoryControl.replay();
+
+ boolean success = service.deleteManagedRepositoryContent( "internal" );
+ assertTrue( success );
+
+ archivaConfigControl.verify();
+ configControl.verify();
+ metadataRepositoryControl.verify();
+
+ assertFalse( new File( managedRepo.getLocation(), "org" ).exists() );
+ assertTrue( new File( managedRepo.getLocation() ).exists() );
+ }
+
/* Merge method */
public void testMergeRepositoryWithInvalidRepository()