blob: 6c1350c4462e99315ca3f931894a1cc3403f1ab7 (
plain) (
blame)
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
|
package org.openslx.imagemaster;
import java.io.FileInputStream;
import java.io.IOException;
import java.io.InputStream;
import java.net.ConnectException;
import junit.framework.Test;
import junit.framework.TestCase;
import junit.framework.TestSuite;
import org.apache.commons.net.ftp.FTP;
import org.apache.commons.net.ftp.FTPClient;
import org.apache.commons.net.ftp.FTPReply;
import org.apache.thrift.TException;
import org.apache.thrift.protocol.TBinaryProtocol;
import org.apache.thrift.protocol.TProtocol;
import org.apache.thrift.transport.TSocket;
import org.apache.thrift.transport.TTransport;
import org.apache.thrift.transport.TTransportException;
import org.openslx.imagemaster.thrift.iface.ImageServer.Client;
import org.openslx.imagemaster.thrift.iface.SessionData;
import org.openslx.imagemaster.thrift.iface.UserInfo;
/**
* Unit test for simple App.
*/
public class AppTest
extends TestCase
{
/**
* Create the test case
*
* @param testName name of the test case
*/
public AppTest( String testName )
{
super( testName );
}
/**
* @return the suite of tests being tested
*/
public static Test suite()
{
return new TestSuite( AppTest.class );
}
/**
* Rigourous Test :-)
*/
public void testApp()
{
assertTrue( true );
}
/**
* Test the authentication
*/
public void testAuthentication() {
TTransport transport = new TSocket("localhost", 9090);
try {
transport.open();
} catch (TTransportException e) {
assertTrue("Could not connect", false);
}
TProtocol protocol = new TBinaryProtocol(transport);
Client client = new Client(protocol);
try {
assertTrue("Could not ping server", client.ping());
} catch (TException e) {
assertTrue("Could not ping server", false);
}
try {
SessionData sessionData = client.authenticate("ns202", "xxxxxxxxxxxx");
UserInfo userInfo = client.getUserFromToken(sessionData.getAuthToken());
System.out.println("User info: " + userInfo);
System.out.println("Server address from MySQL: " + sessionData.serverAddress);
} catch (TException e) {
e.printStackTrace();
assertTrue("Could not login", false);
}
}
/**
* Test FTP connection
*/
public void testFtpConnection() {
FTPClient client = new FTPClient();
String host = "localhost";
int port = 2221;
String user = "admin";
String password = "SI*HoZCC!]V)p>B2";
String fileName = "/home/nils/file_to_upload.bin";
try {
client.connect(host, port);
System.out.println("Connected to " + host + ":" + port + ". Reply code: " + client.getReplyCode());
if ( !FTPReply.isPositiveCompletion( client.getReplyCode() ) ) {
ConnectException ce = new ConnectException("No positive reply code.");
throw ce;
}
if ( !client.login(user, password) ) {
ConnectException ce = new ConnectException("Could not login.");
throw ce;
}
System.out.println("Logged in with user: " + user);
client.setFileType(FTP.BINARY_FILE_TYPE);
client.enterLocalPassiveMode();
System.out.println("Entered PASSIVE MODE");
InputStream input = new FileInputStream(fileName);
client.makeDirectory("myFolder");
System.out.println("Made directory 'myFolder'");
System.out.print("Starting file upload ... ");
client.storeFile("myFolder/myFile.txt", input);
System.out.println("done.");
client.noop();
} catch (IOException e) {
e.printStackTrace();
} finally {
if (client.isConnected()) {
try {
client.logout();
client.disconnect();
} catch (IOException e) {
e.printStackTrace();
}
}
}
}
}
|
