import org.apache.archiva.metadata.model.ArtifactMetadata;
import org.apache.archiva.metadata.repository.MetadataRepository;
import org.apache.archiva.metadata.repository.MetadataRepositoryException;
+import org.apache.archiva.metadata.repository.RepositorySession;
+import org.apache.archiva.metadata.repository.RepositorySessionFactory;
import org.apache.archiva.metadata.repository.storage.RepositoryPathTranslator;
import org.apache.archiva.reports.RepositoryProblemFacet;
import org.apache.commons.collections.CollectionUtils;
*/
private FileTypes filetypes;
+ /**
+ * FIXME: can be of other types
+ *
+ * @plexus.requirement
+ */
+ private RepositorySessionFactory repositorySessionFactory;
+
private List<String> includes = new ArrayList<String>();
private File repositoryDir;
private String repoId;
- /**
- * @plexus.requirement
- */
- private MetadataRepository metadataRepository;
-
/**
* FIXME: needs to be selected based on the repository in question
*
*/
private RepositoryPathTranslator pathTranslator;
+ private RepositorySession repositorySession;
+
public String getId()
{
return id;
{
repoId = repo.getId();
this.repositoryDir = new File( repo.getLocation() );
+ repositorySession = repositorySessionFactory.createSession();
}
public void beginScan( ManagedRepositoryConfiguration repo, Date whenGathered, boolean executeOnEntireRepo )
throw new ConsumerException( e.getMessage(), e );
}
+ MetadataRepository metadataRepository = repositorySession.getRepository();
+
List<ArtifactMetadata> results;
try
{
public void completeScan()
{
- // nothing to do
+ repositorySession.close();
}
public void completeScan( boolean executeOnEntireRepo )
import org.apache.archiva.metadata.model.ArtifactMetadata;
import org.apache.archiva.metadata.model.MetadataFacet;
import org.apache.archiva.metadata.repository.MetadataRepository;
+import org.apache.archiva.metadata.repository.RepositorySession;
+import org.apache.archiva.metadata.repository.RepositorySessionFactory;
import org.apache.archiva.metadata.repository.storage.RepositoryPathTranslator;
import org.apache.archiva.reports.RepositoryProblemFacet;
import org.apache.maven.archiva.configuration.ManagedRepositoryConfiguration;
config.setId( TEST_REPO );
config.setLocation( getTestFile( "target/test-repository" ).getAbsolutePath() );
- metadataRepository = (MetadataRepository) lookup( MetadataRepository.class );
+ metadataRepository = mock( MetadataRepository.class );
+
+ RepositorySession session = mock( RepositorySession.class );
+ when( session.getRepository() ).thenReturn( metadataRepository );
+
+ RepositorySessionFactory factory = (RepositorySessionFactory) lookup( RepositorySessionFactory.class );
+ when( factory.createSession() ).thenReturn( session );
pathTranslator = (RepositoryPathTranslator) lookup( RepositoryPathTranslator.class, "maven2" );
when( pathTranslator.getArtifactForPath( TEST_REPO, TEST_FILE ) ).thenReturn( TEST_METADATA );
<beans xmlns="http://www.springframework.org/schema/beans"
xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
xsi:schemaLocation="http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans.xsd">
- <bean id="metadataRepositoryFactory" class="org.apache.archiva.reports.consumers.MockitoFactory"
- name="metadataRepository">
- <constructor-arg value="org.apache.archiva.metadata.repository.MetadataRepository"/>
+ <bean id="repositorySessionFactoryFactory" class="org.apache.archiva.reports.consumers.MockitoFactory"
+ name="repositorySessionFactory">
+ <constructor-arg value="org.apache.archiva.metadata.repository.RepositorySessionFactory"/>
</bean>
<bean id="repositoryPathTranslatorFactory" class="org.apache.archiva.reports.consumers.MockitoFactory"
name="repositoryPathTranslator#maven2">