1 package org.apache.archiva.consumers.core.repository;
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22 import org.apache.archiva.metadata.repository.RepositorySession;
23 import org.apache.archiva.repository.events.RepositoryListener;
24 import org.apache.archiva.common.utils.VersionComparator;
25 import org.apache.archiva.common.utils.VersionUtil;
26 import org.apache.archiva.model.ArtifactReference;
27 import org.apache.archiva.model.VersionedReference;
28 import org.apache.archiva.repository.ContentNotFoundException;
29 import org.apache.archiva.repository.ManagedRepositoryContent;
30 import org.apache.archiva.repository.layout.LayoutException;
31
32 import java.io.File;
33 import java.util.ArrayList;
34 import java.util.Collections;
35 import java.util.List;
36 import java.util.Set;
37
38
39
40
41 public class RetentionCountRepositoryPurge
42 extends AbstractRepositoryPurge
43 {
44 private int retentionCount;
45
46 public RetentionCountRepositoryPurge( ManagedRepositoryContent repository, int retentionCount,
47 RepositorySession repositorySession, List<RepositoryListener> listeners )
48 {
49 super( repository, repositorySession, listeners );
50 this.retentionCount = retentionCount;
51 }
52
53 @Override
54 public void process( String path )
55 throws RepositoryPurgeException
56 {
57 try
58 {
59 File artifactFile = new File( repository.getRepoRoot(), path );
60
61 if ( !artifactFile.exists() )
62 {
63 return;
64 }
65
66 ArtifactReference artifact = repository.toArtifactReference( path );
67
68 if ( VersionUtil.isSnapshot( artifact.getVersion() ) )
69 {
70 VersionedReference reference = new VersionedReference();
71 reference.setGroupId( artifact.getGroupId() );
72 reference.setArtifactId( artifact.getArtifactId() );
73 reference.setVersion( artifact.getVersion() );
74
75 List<String> versions = new ArrayList<>( repository.getVersions( reference ) );
76
77 Collections.sort( versions, VersionComparator.getInstance() );
78
79 if ( retentionCount > versions.size() )
80 {
81
82 return;
83 }
84
85 int countToPurge = versions.size() - retentionCount;
86
87 for ( String version : versions )
88 {
89 if ( countToPurge-- <= 0 )
90 {
91 break;
92 }
93
94 doPurgeAllRelated( artifact, version );
95 }
96 }
97 }
98 catch ( LayoutException le )
99 {
100 throw new RepositoryPurgeException( le.getMessage(), le );
101 }
102 catch ( ContentNotFoundException e )
103 {
104
105
106 }
107 }
108
109 private void doPurgeAllRelated( ArtifactReference reference, String version )
110 throws LayoutException
111 {
112 ArtifactReference artifact = new ArtifactReference();
113 artifact.setGroupId( reference.getGroupId() );
114 artifact.setArtifactId( reference.getArtifactId() );
115 artifact.setVersion( version );
116 artifact.setClassifier( reference.getClassifier() );
117 artifact.setType( reference.getType() );
118
119 try
120 {
121 Set<ArtifactReference> related = repository.getRelatedArtifacts( artifact );
122 purge( related );
123 }
124 catch ( ContentNotFoundException e )
125 {
126
127
128 }
129 }
130 }