1 | |
package org.apache.maven.wagon.observers; |
2 | |
|
3 | |
|
4 | |
|
5 | |
|
6 | |
|
7 | |
|
8 | |
|
9 | |
|
10 | |
|
11 | |
|
12 | |
|
13 | |
|
14 | |
|
15 | |
|
16 | |
|
17 | |
|
18 | |
|
19 | |
|
20 | |
|
21 | |
|
22 | |
import org.apache.maven.wagon.events.SessionEvent; |
23 | |
import org.apache.maven.wagon.events.SessionListener; |
24 | |
import org.apache.maven.wagon.events.TransferEvent; |
25 | |
import org.apache.maven.wagon.events.TransferListener; |
26 | |
|
27 | |
import java.io.PrintStream; |
28 | |
|
29 | |
|
30 | |
|
31 | |
|
32 | |
|
33 | |
public class Debug |
34 | |
implements SessionListener, TransferListener |
35 | |
{ |
36 | |
private PrintStream out; |
37 | |
|
38 | |
long timestamp; |
39 | |
|
40 | |
long transfer; |
41 | |
|
42 | |
public Debug() |
43 | |
{ |
44 | 0 | this( System.out ); |
45 | 0 | } |
46 | |
|
47 | |
public Debug( PrintStream out ) |
48 | 0 | { |
49 | 0 | this.out = out; |
50 | 0 | } |
51 | |
|
52 | |
|
53 | |
|
54 | |
|
55 | |
public void sessionOpening( final SessionEvent sessionEvent ) |
56 | |
{ |
57 | |
|
58 | 0 | } |
59 | |
|
60 | |
|
61 | |
|
62 | |
|
63 | |
public void sessionOpened( final SessionEvent sessionEvent ) |
64 | |
{ |
65 | 0 | out.println( sessionEvent.getWagon().getRepository().getUrl() + " - Session: Opened " ); |
66 | 0 | } |
67 | |
|
68 | |
|
69 | |
|
70 | |
|
71 | |
public void sessionDisconnecting( final SessionEvent sessionEvent ) |
72 | |
{ |
73 | 0 | out.println( sessionEvent.getWagon().getRepository().getUrl() + " - Session: Disconnecting " ); |
74 | |
|
75 | 0 | } |
76 | |
|
77 | |
|
78 | |
|
79 | |
|
80 | |
public void sessionDisconnected( final SessionEvent sessionEvent ) |
81 | |
{ |
82 | 0 | out.println( sessionEvent.getWagon().getRepository().getUrl() + " - Session: Disconnected" ); |
83 | 0 | } |
84 | |
|
85 | |
|
86 | |
|
87 | |
|
88 | |
public void sessionConnectionRefused( final SessionEvent sessionEvent ) |
89 | |
{ |
90 | 0 | out.println( sessionEvent.getWagon().getRepository().getUrl() + " - Session: Connection refused" ); |
91 | |
|
92 | 0 | } |
93 | |
|
94 | |
|
95 | |
|
96 | |
|
97 | |
public void sessionLoggedIn( final SessionEvent sessionEvent ) |
98 | |
{ |
99 | 0 | out.println( sessionEvent.getWagon().getRepository().getUrl() + " - Session: Logged in" ); |
100 | |
|
101 | 0 | } |
102 | |
|
103 | |
|
104 | |
|
105 | |
|
106 | |
public void sessionLoggedOff( final SessionEvent sessionEvent ) |
107 | |
{ |
108 | 0 | out.println( sessionEvent.getWagon().getRepository().getUrl() + " - Session: Logged off" ); |
109 | |
|
110 | 0 | } |
111 | |
|
112 | |
|
113 | |
|
114 | |
|
115 | |
public void debug( final String message ) |
116 | |
{ |
117 | 0 | out.println( message ); |
118 | |
|
119 | 0 | } |
120 | |
|
121 | |
public void transferInitiated( TransferEvent transferEvent ) |
122 | |
{ |
123 | |
|
124 | 0 | } |
125 | |
|
126 | |
|
127 | |
|
128 | |
|
129 | |
public void transferStarted( final TransferEvent transferEvent ) |
130 | |
{ |
131 | 0 | timestamp = transferEvent.getTimestamp(); |
132 | |
|
133 | 0 | transfer = 0; |
134 | |
|
135 | 0 | if ( transferEvent.getRequestType() == TransferEvent.REQUEST_GET ) |
136 | |
{ |
137 | 0 | final String message = "Downloading: " + transferEvent.getResource().getName() + " from " |
138 | |
+ transferEvent.getWagon().getRepository().getUrl(); |
139 | |
|
140 | 0 | out.println( message ); |
141 | |
|
142 | 0 | out.println( "" ); |
143 | 0 | } |
144 | |
else |
145 | |
{ |
146 | 0 | final String message = "Uploading: " + transferEvent.getResource().getName() + " to " |
147 | |
+ transferEvent.getWagon().getRepository().getUrl(); |
148 | |
|
149 | 0 | out.println( message ); |
150 | |
|
151 | 0 | out.println( "" ); |
152 | |
|
153 | |
} |
154 | 0 | } |
155 | |
|
156 | |
|
157 | |
|
158 | |
|
159 | |
public void transferProgress( final TransferEvent transferEvent, byte[] buffer, int length ) |
160 | |
{ |
161 | |
|
162 | 0 | out.print( "#" ); |
163 | |
|
164 | |
|
165 | 0 | transfer += length; |
166 | 0 | } |
167 | |
|
168 | |
|
169 | |
|
170 | |
|
171 | |
public void transferCompleted( final TransferEvent transferEvent ) |
172 | |
{ |
173 | 0 | final double duration = (double) ( transferEvent.getTimestamp() - timestamp ) / 1000; |
174 | |
|
175 | 0 | out.println(); |
176 | |
|
177 | 0 | final String message = "Transfer finished. " + transfer + " bytes copied in " + duration + " seconds"; |
178 | |
|
179 | 0 | out.println( message ); |
180 | |
|
181 | 0 | } |
182 | |
|
183 | |
|
184 | |
|
185 | |
|
186 | |
public void transferError( final TransferEvent transferEvent ) |
187 | |
{ |
188 | 0 | out.println( " Transfer error: " + transferEvent.getException() ); |
189 | |
|
190 | 0 | } |
191 | |
|
192 | |
|
193 | |
|
194 | |
|
195 | |
public void sessionError( final SessionEvent sessionEvent ) |
196 | |
{ |
197 | 0 | out.println( " Session error: " + sessionEvent.getException() ); |
198 | |
|
199 | 0 | } |
200 | |
|
201 | |
public PrintStream getOut() |
202 | |
{ |
203 | 0 | return out; |
204 | |
} |
205 | |
|
206 | |
} |