import org.apache.archiva.metadata.model.CiManagement;
import org.apache.archiva.metadata.model.FacetedMetadata;
import org.apache.archiva.metadata.model.IssueManagement;
+import org.apache.archiva.metadata.model.License;
import org.apache.archiva.metadata.model.MailingList;
import org.apache.archiva.metadata.model.MetadataFacet;
import org.apache.archiva.metadata.model.MetadataFacetFactory;
private final ColumnFamilyTemplate<String, String> mailingListTemplate;
+ private final ColumnFamilyTemplate<String, String> licenseTemplate;
+
public CassandraMetadataRepository( Map<String, MetadataFacetFactory> metadataFacetFactories,
ArchivaConfiguration configuration,
CassandraArchivaManager cassandraArchivaManager )
//
StringSerializer.get(), //
StringSerializer.get() );
+
+ this.licenseTemplate = new ThriftColumnFamilyTemplate<String, String>( cassandraArchivaManager.getKeyspace(), //
+ cassandraArchivaManager.getLicenseFamilyName(),
+ //
+ StringSerializer.get(), //
+ StringSerializer.get() );
}
recordMailingList( key, versionMetadata.getMailingLists() );
}
+ recordLicenses( key, versionMetadata.getLicenses() );
+
MutationResult mutationResult = mutator.execute();
}
else
}
}
- if ( versionMetadata.getMailingLists() != null )
- {
- // update is a delete record
- removeMailingList( key );
- recordMailingList( key, versionMetadata.getMailingLists() );
- }
+ // update is a delete record
+ removeMailingList( key );
+ recordMailingList( key, versionMetadata.getMailingLists() );
+
+ removeLicenses( key );
+ recordLicenses( key, versionMetadata.getLicenses() );
projectVersionMetadataModelTemplate.update( updater );
}
}
projectVersionMetadata.setMailingLists( getMailingLists( key ) );
+ projectVersionMetadata.setLicenses( getLicenses( key ) );
// FIXME complete collections !!
// facets
for ( String columnName : columnFamilyResult.getColumnNames() )
{
- if (StringUtils.startsWith( columnName, "otherArchive." ))
+ if ( StringUtils.startsWith( columnName, "otherArchive." ) )
{
otherArchives.add( columnFamilyResult.getString( columnName ) );
}
return mailingLists;
}
+ protected void recordLicenses( String projectVersionMetadataKey, List<License> licenses )
+ {
+
+ if ( licenses == null || licenses.isEmpty() )
+ {
+ return;
+ }
+ Mutator<String> licenseMutator = this.licenseTemplate.createMutator();
+
+ for ( License license : licenses )
+ {
+ // we don't care about the key as the real used one with the projectVersionMetadata
+ String keyLicense = UUID.randomUUID().toString();
+ String cfLicense = cassandraArchivaManager.getLicenseFamilyName();
+
+ addInsertion( licenseMutator, keyLicense, cfLicense, "projectVersionMetadataModel.key",
+ projectVersionMetadataKey );
+
+ addInsertion( licenseMutator, keyLicense, cfLicense, "license.name", license.getName() );
+
+ addInsertion( licenseMutator, keyLicense, cfLicense, "license.url", license.getUrl() );
+
+ }
+ licenseMutator.execute();
+ }
+
+ protected void removeLicenses( String projectVersionMetadataKey )
+ {
+ StringSerializer ss = StringSerializer.get();
+ QueryResult<OrderedRows<String, String, String>> result =
+ HFactory.createRangeSlicesQuery( cassandraArchivaManager.getKeyspace(), ss, ss, ss ) //
+ .setColumnFamily( cassandraArchivaManager.getLicenseFamilyName() ) //
+ .setColumnNames( "name" ) //
+ .setRowCount( Integer.MAX_VALUE ) //
+ .addEqualsExpression( "projectVersionMetadataModel.key", projectVersionMetadataKey ) //
+ .execute();
+ for ( Row<String, String, String> row : result.get() )
+ {
+ this.licenseTemplate.deleteRow( row.getKey() );
+ }
+ }
+
+ protected List<License> getLicenses( String projectVersionMetadataKey )
+ {
+ List<License> licenses = new ArrayList<License>();
+
+ StringSerializer ss = StringSerializer.get();
+ QueryResult<OrderedRows<String, String, String>> result =
+ HFactory.createRangeSlicesQuery( cassandraArchivaManager.getKeyspace(), ss, ss, ss ) //
+ .setColumnFamily( cassandraArchivaManager.getLicenseFamilyName() ) //
+ .setColumnNames( "projectVersionMetadataModel.key" ) //
+ .setRowCount( Integer.MAX_VALUE ) //
+ .addEqualsExpression( "projectVersionMetadataModel.key", projectVersionMetadataKey ) //
+ .execute();
+
+ for ( Row<String, String, String> row : result.get() )
+ {
+ ColumnFamilyResult<String, String> columnFamilyResult = this.licenseTemplate.queryColumns( row.getKey() );
+
+ licenses.add( new License( columnFamilyResult.getString( "license.name" ),
+ columnFamilyResult.getString( "license.url" ) ) );
+ }
+
+ return licenses;
+ }
+
@Override
public void updateArtifact( String repositoryId, String namespaceId, String projectId, String projectVersion,
ArtifactMetadata artifactMeta )