gfwleak/zhangyang-libzt
Archived
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Unity3D .NET API and documentation update

Browse Source
This commit is contained in:
Joseph Henry
2016-08-25 17:08:48 -07:00
parent 18ad4c79b7
commit e8b840d7ce
22 changed files with 798 additions and 247 deletions
Download Patch File Download Diff File Expand all files Collapse all files

52
integrations/android/example_app/app/src/main/java/com/example/joseph/example_app/MainActivity.java
View File

@@ -37,7 +37,7 @@ public class MainActivity extends AppCompatActivity {
while(!zt.running()) { }
// client/server mode toggle
int mode = 2, err;
int mode = 4, err;
// Listen to incoming connections
if(mode==1)
@@ -46,38 +46,38 @@ public class MainActivity extends AppCompatActivity {
int sock = zt.socket(SDK.AF_INET, SDK.SOCK_STREAM, 0);
if((err = zt.bind(sock, "0.0.0.0", 8080, nwid)) < 0)
Log.d("ZT-TEST", "bind_err = " + err + "\n");
Log.d("ZTSDK", "bind_err = " + err + "\n");
if((err = zt.listen(sock,1)) < 0)
Log.d("ZT-TEST", "listen_err = " + err);
Log.d("ZTSDK", "listen_err = " + err);
if((err = zt.accept(sock,null)) < 0)
Log.d("ZT-TEST", "accept_err = " + err);
Log.d("ZTSDK", "accept_err = " + err);
Log.d("ZT-TEST", "Waiting to accept connection...");
Log.d("ZTSDK", "Waiting to accept connection...");
// ...
}
// TCP Echo ZT-TEST (CLIENT)
// TCP Echo ZTSDK (CLIENT)
if(mode==2)
{
Log.d("ZT-TEST", "\n\nStarting TCP Echo ZT-TEST\n\n");
Log.d("ZTSDK", "\n\nStarting TCP Echo ZTSDK\n\n");
zt.join_network(nwid);
int sock = zt.socket(SDK.AF_INET, SDK.SOCK_STREAM, 0);
String msg = "Welcome to the machine!";
err = zt.connect(sock, "28.206.65.211", 8099, nwid);
Log.d("ZT-TEST", "err = " + err + "\n");
Log.d("ZTSDK", "err = " + err + "\n");
return;
//return;
// ECHO
while(true)
{
// TX
if((err = zt.write(sock, msg.getBytes(), msg.length())) > 0) {
Log.d("ZT-TEST", "TX: " + msg + " --- " + err + " bytes");
Log.d("ZTSDK", "TX: " + msg + " --- " + err + " bytes");
}
// RX
@@ -85,14 +85,14 @@ public class MainActivity extends AppCompatActivity {
Arrays.fill(buffer, (byte)0);
if((err = zt.read(sock, buffer, buffer.length)) > 0) {
String bufStr = new String(buffer).substring(0, err);
Log.d("ZT-TEST", "RX: " + bufStr + " --- " + err + " bytes");
Log.d("ZTSDK", "RX: " + bufStr + " --- " + err + " bytes");
}
}
// zt.stop_service();
}
// SOCKS5 Proxy ZT-TEST
// SOCKS5 Proxy ZTSDK
if(mode==3)
{
zt.join_network(nwid);
@@ -102,18 +102,18 @@ public class MainActivity extends AppCompatActivity {
Log.d("ZTSDK", "Setting up connection to SDK proxy server");
SocketAddress proxyAddr = new InetSocketAddress("127.0.0.1", proxyPort);
Proxy proxy = new Proxy(Proxy.Type.SOCKS, proxyAddr);
Log.d("ZT-TEST", "toString() = " + proxy.toString());
Log.d("ZTSDK", "toString() = " + proxy.toString());
final Socket s = new Socket(proxy);
final SocketAddress remoteAddr = new InetSocketAddress("10.9.9.100", 8080);
// Wait for address to be assigned
ArrayList<String> addresses = zt.get_addresses(nwid);
for(int i=0; i<addresses.size(); i++) {
Log.d("ZT-TEST", "Address = " + addresses.get(i));
Log.d("ZTSDK", "Address = " + addresses.get(i));
}
while(addresses.size() > 0 && addresses.get(0).equals("-1.-1.-1.-1/-1")) {
try {
Log.d("ZT-TEST", "waiting for address");
Log.d("ZTSDK", "waiting for address");
Thread.sleep(100);
} catch (java.lang.InterruptedException e) {
}
@@ -127,36 +127,36 @@ public class MainActivity extends AppCompatActivity {
s.connect(remoteAddr, 1000);
}
catch(java.io.IOException e) {
Log.d("ZT-TEST", "Unable to establish connection to SOCKS5 Proxy server\n");
Log.d("ZTSDK", "Unable to establish connection to SOCKS5 Proxy server\n");
}
}
}).start();
}
// UDP Echo ZT-TEST
// UDP Echo ZTSDK
if(mode==4)
{
// Remote server address (will be populated by recvfrom()
ZTAddress remoteServer = new ZTAddress();
ZTAddress bindAddr = new ZTAddress("0.0.0.0", 8080);
Log.d("ZT-TEST", "\n\nStarting UDP Echo ZT-TEST\n\n");
Log.d("ZTSDK", "\n\nStarting UDP Echo ZTSDK\n\n");
nwid = "8056c2e21c000001";
zt.join_network(nwid);
int sock = zt.socket(SDK.AF_INET, SDK.SOCK_DGRAM, 0);
Log.d("ZT-TEST", "binding...");
Log.d("ZTSDK", "binding...");
if((err = zt.bind(sock, bindAddr, nwid)) < 0)
Log.d("ZT-TEST", "bind_err = " + err + "\n");
Log.d("ZTSDK", "bind_err = " + err + "\n");
if((err = zt.listen(sock, 0)) < 0)
Log.d("ZT-TEST", "listen_err = " + err);
Log.d("ZTSDK", "listen_err = " + err);
ArrayList<String> addresses = zt.get_addresses(nwid);
if(addresses.size() < 0) {
Log.d("ZT-TEST", "unable to obtain ZT address");
Log.d("ZTSDK", "unable to obtain ZT address");
return;
}
else {
Log.d("ZT-TEST", "IPV4 = " + addresses.get(0));
Log.d("ZTSDK", "App IP = " + addresses.get(0));
}
String bufStr;
@@ -170,16 +170,16 @@ public class MainActivity extends AppCompatActivity {
// RX
if((err = zt.recvfrom(sock, buffer, 32, 0, remoteServer)) > 0) {
bufStr = new String(buffer).substring(0, err);
Log.d("ZT-TEST", "read (" + err + ") bytes from " + remoteServer.Address() + " : " + remoteServer.Port() + ", msg = " + bufStr);
Log.d("ZTSDK", "read (" + err + ") bytes from " + remoteServer.Address() + " : " + remoteServer.Port() + ", msg = " + bufStr);
// TX
String msg = "Welcome response from android\n";
err = zt.sendto(sock, msg.getBytes(), msg.length(), 0, remoteServer);
if (err < 0)
Log.d("ZT-TEST", "sendto_err = " + err);
Log.d("ZTSDK", "sendto_err = " + err);
}
}
//Log.d("ZT-TEST", "leaving network");
//Log.d("ZTSDK", "leaving network");
//zt.leave_network(nwid);
}
}