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 this( System.out );
45 }
46
47 public Debug( PrintStream out )
48 {
49 this.out = out;
50 }
51
52
53
54
55 public void sessionOpening( final SessionEvent sessionEvent )
56 {
57
58 }
59
60
61
62
63 public void sessionOpened( final SessionEvent sessionEvent )
64 {
65 out.println( sessionEvent.getWagon().getRepository().getUrl() + " - Session: Opened " );
66 }
67
68
69
70
71 public void sessionDisconnecting( final SessionEvent sessionEvent )
72 {
73 out.println( sessionEvent.getWagon().getRepository().getUrl() + " - Session: Disconnecting " );
74
75 }
76
77
78
79
80 public void sessionDisconnected( final SessionEvent sessionEvent )
81 {
82 out.println( sessionEvent.getWagon().getRepository().getUrl() + " - Session: Disconnected" );
83 }
84
85
86
87
88 public void sessionConnectionRefused( final SessionEvent sessionEvent )
89 {
90 out.println( sessionEvent.getWagon().getRepository().getUrl() + " - Session: Connection refused" );
91
92 }
93
94
95
96
97 public void sessionLoggedIn( final SessionEvent sessionEvent )
98 {
99 out.println( sessionEvent.getWagon().getRepository().getUrl() + " - Session: Logged in" );
100
101 }
102
103
104
105
106 public void sessionLoggedOff( final SessionEvent sessionEvent )
107 {
108 out.println( sessionEvent.getWagon().getRepository().getUrl() + " - Session: Logged off" );
109
110 }
111
112
113
114
115 public void debug( final String message )
116 {
117 out.println( message );
118
119 }
120
121 public void transferInitiated( TransferEvent transferEvent )
122 {
123
124 }
125
126
127
128
129 public void transferStarted( final TransferEvent transferEvent )
130 {
131 timestamp = transferEvent.getTimestamp();
132
133 transfer = 0;
134
135 if ( transferEvent.getRequestType() == TransferEvent.REQUEST_GET )
136 {
137 final String message = "Downloading: " + transferEvent.getResource().getName() + " from "
138 + transferEvent.getWagon().getRepository().getUrl();
139
140 out.println( message );
141
142 out.println( "" );
143 }
144 else
145 {
146 final String message = "Uploading: " + transferEvent.getResource().getName() + " to "
147 + transferEvent.getWagon().getRepository().getUrl();
148
149 out.println( message );
150
151 out.println( "" );
152
153 }
154 }
155
156
157
158
159 public void transferProgress( final TransferEvent transferEvent, byte[] buffer, int length )
160 {
161
162 out.print( "#" );
163
164
165 transfer += length;
166 }
167
168
169
170
171 public void transferCompleted( final TransferEvent transferEvent )
172 {
173 final double duration = (double) ( transferEvent.getTimestamp() - timestamp ) / 1000;
174
175 out.println();
176
177 final String message = "Transfer finished. " + transfer + " bytes copied in " + duration + " seconds";
178
179 out.println( message );
180
181 }
182
183
184
185
186 public void transferError( final TransferEvent transferEvent )
187 {
188 out.println( " Transfer error: " + transferEvent.getException() );
189
190 }
191
192
193
194
195 public void sessionError( final SessionEvent sessionEvent )
196 {
197 out.println( " Session error: " + sessionEvent.getException() );
198
199 }
200
201 public PrintStream getOut()
202 {
203 return out;
204 }
205
206 }