1 package org.apache.archiva.repository.scanner;
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.admin.model.beans.ManagedRepository;
23 import org.apache.archiva.consumers.AbstractMonitoredConsumer;
24 import org.apache.archiva.consumers.ConsumerException;
25 import org.apache.archiva.consumers.InvalidRepositoryContentConsumer;
26 import org.slf4j.Logger;
27 import org.slf4j.LoggerFactory;
28 import org.springframework.context.annotation.Scope;
29 import org.springframework.stereotype.Service;
30
31 import java.util.ArrayList;
32 import java.util.Date;
33 import java.util.List;
34
35
36
37
38
39
40 public class InvalidScanConsumer
41 extends AbstractMonitoredConsumer
42 implements InvalidRepositoryContentConsumer
43 {
44
45
46
47 private String id = "unset-id";
48
49 private Logger logger = LoggerFactory.getLogger( getClass() );
50
51 private int processCount = 0;
52
53 private List<String> paths = new ArrayList<>( );
54
55 @Override
56 public void beginScan( ManagedRepository repository, Date whenGathered )
57 throws ConsumerException
58 {
59
60 }
61
62 @Override
63 public void beginScan( ManagedRepository repository, Date whenGathered, boolean executeOnEntireRepo )
64 throws ConsumerException
65 {
66 beginScan( repository, whenGathered );
67 }
68
69 @Override
70 public void completeScan()
71 {
72
73 }
74
75 @Override
76 public void completeScan( boolean executeOnEntireRepo )
77 {
78 completeScan();
79 }
80
81 @Override
82 public List<String> getExcludes()
83 {
84 return null;
85 }
86
87 @Override
88 public List<String> getIncludes()
89 {
90 return null;
91 }
92
93 @Override
94 public void processFile( String path )
95 throws ConsumerException
96 {
97 logger.info( "processFile: {}", path );
98 paths.add( path );
99 processCount++;
100 }
101
102 @Override
103 public void processFile( String path, boolean executeOnEntireRepo )
104 throws ConsumerException
105 {
106 processFile( path );
107 }
108
109 @Override
110 public String getDescription()
111 {
112 return "Bad Content Scan Consumer (for testing)";
113 }
114
115 @Override
116 public String getId()
117 {
118 return id;
119 }
120
121 public int getProcessCount()
122 {
123 return processCount;
124 }
125
126 public void setProcessCount( int processCount )
127 {
128 this.processCount = processCount;
129 }
130
131 public void setId( String id )
132 {
133 this.id = id;
134 }
135
136 public List<String> getPaths()
137 {
138 return paths;
139 }
140 }