bdware/front-base
2
0
Fork 0
mirror of https://gitee.com/BDWare/front-base synced 2025-04-27 14:22:15 +00:00
Code Issues Packages Projects Releases Wiki Activity

Compare commits

base: bdware:v1.6.6
Branches Tags
bdware:master
bdware:feat/consistency-sdk
bdware:v1.6.6
...
compare: bdware:master
Branches Tags
bdware:master
bdware:feat/consistency-sdk
bdware:v1.6.6

11 Commits
v1.6.6 ... master

Author SHA1 Message Date
CaiHQ
1785426e53 merge update 2024-05-23 20:13:33 +08:00
Frank.R.Wu
dffcadd116
build: fixes a bug in build.gradle 2023-12-25 15:41:17 +08:00
CaiHQ
d4e76259db update file handler 2023-12-15 16:50:18 +08:00
Frank.R.Wu
6dfe551a1d build: config spotless plugin and reformat code 2023-06-15 11:08:02 +08:00
CaiHQ
912ecc21fc add public support 2023-04-24 18:58:17 +08:00
CaiHQ
27e47f4142 update cmdconf 2023-03-30 23:56:13 +08:00
CaiHQ
4122cc0128 optimize http result callback 2022-09-02 21:24:29 +08:00
CaiHQ
e7f7b80152 front: support startMulitipoint with args 
fix: ContractClient missing arguments error
update: @Router arguments format
fix: ContractStatusRecorder null exception
 2022-06-26 17:54:30 +08:00
CaiHQ
19a033c699 feat: support createParam 
feat: docker script
 2022-04-21 10:18:48 +08:00
CaiHQ
87ddb79d83 support ledgerparams 
add startContract at cmconfig.json
add docker scripts
 2022-03-22 23:52:02 +08:00
汪旭鑫
a99c4e9af4 refactor: sdk for consensus algorithm 2022-02-15 14:44:16 +08:00
35 changed files with 832 additions and 645 deletions
Show Stats Expand all files Collapse all files

86
build.gradle
View File

@ -1,7 +1,10 @@
plugins {
id 'java'
id 'java-library'
id 'maven-publish'
id 'signing'
}
apply from: '../spotless.gradle'
sourceSets {
main {
@ -23,8 +26,87 @@ sourceSets {
}
dependencies {
api project (":common")
api 'io.netty:netty-tcnative-boringssl-static:2.0.46.Final'
api 'io.netty:netty-tcnative-boringssl-static:2.0.59.Final'
api 'com.google.code.gson:gson:2.8.8'
testImplementation 'junit:junit:4.13.2'
}
version = "1.0.1"
task classJar(type: Jar, dependsOn: classes) {
classifier = "jar"
}
task sourceJar(type: Jar, dependsOn: classes) {
archiveClassifier = "sources"
classifier = "sources"
from sourceSets.main.allSource
duplicatesStrategy = DuplicatesStrategy.EXCLUDE
}
tasks.withType(Javadoc) {
options.addStringOption('Xdoclint:none', '-quiet')
}
task javadocJar(type: Jar, dependsOn: javadoc) {
archiveClassifier = 'javadoc'
classifier = "javadoc"
exclude {
details -> details.file.getAbsolutePath().contains("/gm/")
}
from javadoc.destinationDir
}
publishing {
publications {
mavenJava(MavenPublication) {
groupId project.group
artifactId "front-base"
version "${version}"
from components.java
artifact sourceJar
artifact javadocJar
artifact classJar
pom {
name = "bdware-front-base"
description = "front-base"
url = "https://gitee.com/BDWare/front-base"
licenses {
license {
name = "Mulan PSL v2"
url = "http://license.coscl.org.cn/MulanPSL2"
}
}
developers {
developer {
id = "dataware"
email = "caihq@pku.edu.cn"
}
}
scm {
connection = "scm:git:https://gitee.com/BDWare/front-base.git"
developerConnection = "scm:git:https://gitee.com/BDWare/front-base.git"
url = "https://gitee.com/BDWare/front-base"
}
}
}
}
repositories {
maven {
name 'bdwareSnapshot'
url 'https://oss.sonatype.org/content/repositories/snapshots'
credentials {
username = "${NEXUS_USERNAME}"
password = "${NEXUS_PASSWORD}"
}
}
maven {
name 'bdware'
url 'https://oss.sonatype.org/service/local/staging/deploy/maven2'
credentials {
username = "${NEXUS_USERNAME}"
password = "${NEXUS_PASSWORD}"
}
}
}
}
signing {
sign publishing.publications.mavenJava
}

3
src/main/src/org/bdware/server/ByteHexUtil.java
View File

@ -4,8 +4,7 @@ public class ByteHexUtil {
protected static final char[] hexArray = "0123456789ABCDEF".toCharArray();
// lower ascii only
private static final int[] HEX_TO_INT =
new int[]{
-1, -1, -1, -1, -1, -1, -1, -1, -1, -1, -1, -1, -1, -1, -1, -1, // 0-15
new int[] {-1, -1, -1, -1, -1, -1, -1, -1, -1, -1, -1, -1, -1, -1, -1, -1, // 0-15
-1, -1, -1, -1, -1, -1, -1, -1, -1, -1, -1, -1, -1, -1, -1, -1, // 16-31
-1, -1, -1, -1, -1, -1, -1, -1, -1, -1, -1, -1, -1, -1, -1, -1, // 32-47
0, 1, 2, 3, 4, 5, 6, 7, 8, 9, -1, -1, -1, -1, -1, -1, // 48-63

15
src/main/src/org/bdware/server/CMDConf.java
View File

@ -1,5 +1,6 @@
package org.bdware.server;
import com.google.gson.JsonArray;
import org.apache.logging.log4j.LogManager;
import org.apache.logging.log4j.Logger;
import org.bdware.sc.util.JsonUtil;
@ -17,16 +18,15 @@ public class CMDConf {
public String cmi = "";
public String debug = "";
public boolean disableDoRepo = false;
public boolean disableLocalLhs = false;
public String doipCertPath = "";
public String doipLhsAddress = "";
public String repoDoid = "";
public String lhsAddress = "";
public String repoName;
public int doipPort = -1;
public String doipUserHandle = "";
public boolean enableEventPersistence = false;
public String enableSsl = "./ssl/chained.pem:./ssl/domain.pem";
public String ip = "127.0.0.1";
public boolean isLAN = true;
public boolean overwrite = false;
public int servicePort = 18005;
public String textFileSuffixes = ".yjs,.json,.txt,.css,.js,.html,.md,.conf,.csv";
@ -37,6 +37,9 @@ public class CMDConf {
public String clientToAgentPlugins = "";
public String clientToClusterPlugins = "";
public String tcpPlugins = "";
public String consistencyPlugins = "";
public JsonArray startContract = null;
public String datachainConf = null;
public static CMDConf parseFile(String confPath) {
CMDConf ret = null;

21
src/main/src/org/bdware/server/Entry.java
View File

@ -5,7 +5,7 @@ import java.io.InputStreamReader;
public class Entry {
//release 地址：47.93.86.250 root:i1235813
// release 地址：47.93.86.250 root:i1235813
public static void main(String[] args) {
try {
if (args == null || args.length < 2) {
@ -19,7 +19,7 @@ public class Entry {
@Override
public void run() {
try {
// JavaContractServiceGrpcServer.init();
// JavaContractServiceGrpcServer.init();
} catch (Exception e) {
// TODO Auto-generated catch block
e.printStackTrace();
@ -36,8 +36,10 @@ public class Entry {
Thread.sleep(1000);
Process p = Runtime.getRuntime().exec("./bdledger_go");
BufferedReader stdInput = new BufferedReader(new InputStreamReader(p.getInputStream()));
BufferedReader stdError = new BufferedReader(new InputStreamReader(p.getErrorStream()));
BufferedReader stdInput = new BufferedReader(
new InputStreamReader(p.getInputStream()));
BufferedReader stdError = new BufferedReader(
new InputStreamReader(p.getErrorStream()));
// read the output from the command
System.out.println("Here is the standard output of the command:\n");
@ -46,7 +48,8 @@ public class Entry {
}
// read any errors from the attempted command
System.out.println("Here is the standard error of the command (if any):\n");
System.out.println(
"Here is the standard error of the command (if any):\n");
while ((s = stdError.readLine()) != null) {
System.out.println(s);
}
@ -57,14 +60,14 @@ public class Entry {
}
});
t2.start();
//CMHttpServer.start(getPort(args));
// CMHttpServer.start(getPort(args));
break;
case "NC":
case "NodeCenter":
//NodeCenterServer.start(getPort(args));
// NodeCenterServer.start(getPort(args));
break;
case "Index":
// IndexServer.start(getPort(args));
// IndexServer.start(getPort(args));
default:
printUsage();
}
@ -96,4 +99,4 @@ public class Entry {
}
return -1;
}
}
}

29
src/main/src/org/bdware/server/action/ActionExecutor.java
View File

@ -20,7 +20,7 @@ public class ActionExecutor<T, U> {
// ---------- use for profiling
static Map<String, Map<String, AtomicInteger>> allData = new ConcurrentHashMap<>();
public ExecutorService executor;
// private Profiler profiler = new Profiler();
// private Profiler profiler = new Profiler();
public long permission;
Map<String, AtomicInteger> staticData;
private Map<String, Pair<Method, Object>> handlers;
@ -84,11 +84,8 @@ public class ActionExecutor<T, U> {
handlers.put(method.getName(), new Pair<>(method, obj));
if (!method.getReturnType().equals(Void.TYPE)
|| method.getParameterCount() != 2) {
LOGGER.error(
"action ret is not void:"
+ obj.getClass().getCanonicalName()
+ "-->"
+ method.getName());
LOGGER.error("action ret is not void:"
+ obj.getClass().getCanonicalName() + "-->" + method.getName());
System.exit(0);
}
@ -97,11 +94,9 @@ public class ActionExecutor<T, U> {
handlers.put(a, new Pair<>(method, obj));
if (!method.getReturnType().equals(Void.TYPE)
|| method.getParameterCount() != 2) {
LOGGER.error(
"action ret is not void:"
+ obj.getClass().getCanonicalName()
+ "-->"
+ method.getName());
LOGGER.error("action ret is not void:"
+ obj.getClass().getCanonicalName() + "-->"
+ method.getName());
System.exit(0);
}
@ -116,8 +111,8 @@ public class ActionExecutor<T, U> {
public void handle(String action, final U args, final T callback)
throws IllegalAccessException, IllegalArgumentException, InvocationTargetException {
// LOGGER.info("handling " + action + "...");
// LOGGER.debug("handle : " + action + " ->" + JsonUtil.toJson(args));
// LOGGER.info("handling " + action + "...");
// LOGGER.info("handle : " + action + " ->" + JsonUtil.toJson(args));
if (null != action) {
if (staticData.containsKey(action)) {
@ -135,7 +130,7 @@ public class ActionExecutor<T, U> {
final Pair<Method, Object> pair = handlers.get(action);
Action actionAnnotations = pair.first.getAnnotation(Action.class);
if (!checkPermission(actionAnnotations, args, permission)) {
LOGGER.info("unauthorised action " + action);
LOGGER.info("unauthorised action " + action + " -> " + JsonUtil.toJson(args));
throw new IllegalArgumentException("unauthorised action " + action);
}
@ -144,10 +139,8 @@ public class ActionExecutor<T, U> {
try {
pair.first.invoke(pair.second, args, callback);
} catch (Exception e) {
LOGGER.debug(
pair.first.getDeclaringClass().getCanonicalName()
+ "->"
+ pair.first.getName());
LOGGER.debug(pair.first.getDeclaringClass().getCanonicalName() + "->"
+ pair.first.getName());
e.printStackTrace();
}
});

15
src/main/src/org/bdware/server/action/HttpResultCallback.java
View File

@ -49,17 +49,19 @@ public class HttpResultCallback extends ResultCallback implements Runnable {
bytes = ret.getBytes();
}
assert bytes != null;
response = new DefaultFullHttpResponse(HttpVersion.HTTP_1_1, OK, Unpooled.wrappedBuffer(bytes));
response = new DefaultFullHttpResponse(HttpVersion.HTTP_1_1, OK,
Unpooled.wrappedBuffer(bytes));
for (String key : extraHeaders.keySet())
response.headers().add(key, extraHeaders.get(key));
ctxField.channel().eventLoop().execute(this);
} // Just ignore
} // Just ignore
}
public void addHeader(String key, String val) {
public HttpResultCallback addHeader(String key, String val) {
extraHeaders.put(key, val);
return this;
}
@Override
@ -73,10 +75,3 @@ public class HttpResultCallback extends ResultCallback implements Runnable {
decodeAsB64 = true;
}
}
/*
scp ./libs/front-base-0.80.jar dev@023.node.internetapi.cn:./
scp ./libs/front-base-0.80.jar dev@021.node.internetapi.cn:./
scp ./libs/front-base-0.80.jar dev@024.node.internetapi.cn:./
* */

89
src/main/src/org/bdware/server/action/HttpServerSentEventResultCallback.java Normal file
View File

@ -0,0 +1,89 @@
package org.bdware.server.action;
import io.netty.buffer.ByteBuf;
import io.netty.buffer.Unpooled;
import io.netty.channel.ChannelHandlerContext;
import io.netty.handler.codec.http.*;
import org.apache.logging.log4j.LogManager;
import org.apache.logging.log4j.Logger;
import java.io.Closeable;
import java.io.IOException;
import java.nio.charset.StandardCharsets;
import java.util.concurrent.Executors;
import java.util.concurrent.ScheduledExecutorService;
import java.util.concurrent.ScheduledFuture;
import java.util.concurrent.TimeUnit;
public class HttpServerSentEventResultCallback extends HttpResultCallback implements Closeable {
public static ScheduledExecutorService scheduledThreadPool =
Executors.newScheduledThreadPool(1);
private ScheduledFuture<?> currentScheduler;
private long lastUpdate;
public HttpServerSentEventResultCallback(ChannelHandlerContext ctx, String jsonCallback) {
super(ctx, jsonCallback);
ctxField = ctx;
}
public void writeInitialHead() {
HttpResponse response =
new DefaultHttpResponse(HttpVersion.HTTP_1_1, HttpResponseStatus.OK);
for (String key : extraHeaders.keySet())
response.headers().add(key, extraHeaders.get(key));
ctxField.writeAndFlush(response);
currentScheduler = scheduledThreadPool.schedule(this, 10, TimeUnit.SECONDS);
final ByteBuf buffer = Unpooled.copiedBuffer("\n", StandardCharsets.UTF_8);
ctxField.writeAndFlush(new DefaultHttpContent(buffer));
}
boolean closed = false;
@Override
public void onResult(String ret) {
ByteBuf event = Unpooled.copiedBuffer("event: onResult\n", StandardCharsets.UTF_8);
ctxField.writeAndFlush(new DefaultHttpContent(event));
ByteBuf buffer = Unpooled.copiedBuffer("data: " + ret + "\n\n", StandardCharsets.UTF_8);
ctxField.writeAndFlush(new DefaultHttpContent(buffer));
lastUpdate = System.currentTimeMillis();
if (ret.contains("\"onDistributeFinish\"")) {
lastUpdate = 0;
currentScheduler.cancel(true);
try {
close();
} catch (Exception e) {
}
}
}
static Logger LOGGER = LogManager.getLogger(HttpServerSentEventResultCallback.class);
@Override
public void run() {
try {
if (System.currentTimeMillis() - lastUpdate < 10000L) {
// reschedule
LOGGER.info("Reschedule time out");
currentScheduler = scheduledThreadPool.schedule(this, 10, TimeUnit.SECONDS);
return;
}
if (!closed) {
final ByteBuf buffer = Unpooled.copiedBuffer(
"{\"action\":\"onDistributeFinish\",\"progress\":\"-1\",\"data\":\"timeout\"}"
+ "\n\n",
StandardCharsets.UTF_8);
ctxField.writeAndFlush(new DefaultHttpContent(buffer));
}
close();
} catch (IOException e) {
}
}
@Override
public synchronized void close() throws IOException {
closed = true;
ctxField.close();
}
}

7
src/main/src/org/bdware/server/action/ReplyUtil.java
View File

@ -15,10 +15,11 @@ public class ReplyUtil {
resultCallback.onResult(ret);
}
public static void replyWithStatus(ResultCallback resultCallback, String action, boolean status,Object data) {
public static void replyWithStatus(ResultCallback resultCallback, String action, boolean status,
Object data) {
Map<String, Object> ret = new HashMap<>();
ret.put("action", action);
ret.put("status",status);
ret.put("status", status);
ret.put("data", data);
resultCallback.onResult(ret);
}
@ -27,4 +28,4 @@ public class ReplyUtil {
if (json.has("requestID"))
response.responseID = json.get("requestID").getAsString();
}
}
}

23
src/main/src/org/bdware/server/action/SyncResult.java
View File

@ -19,33 +19,28 @@ import java.util.concurrent.Executors;
import java.util.concurrent.TimeUnit;
public class SyncResult {
public static final HashedWheelTimer timer = new HashedWheelTimer(
Executors.defaultThreadFactory(),
5,
TimeUnit.MILLISECONDS,
2);
public static final HashedWheelTimer timer =
new HashedWheelTimer(Executors.defaultThreadFactory(), 5, TimeUnit.MILLISECONDS, 2);
private static final Logger LOGGER = LogManager.getLogger(SyncResult.class);
public Map<String, ResultCallback> waitObj = new ConcurrentHashMap<>();
public synchronized void wakeUp(String requestID, String result) {
ResultCallback ob = waitObj.get(requestID);
// TODO 难怪之前这是注释的。
// TODO 难怪之前这是注释的。
waitObj.remove(requestID);
// cancel timeout
// cancel timeout
if (ob != null) {
ob.cancelTimeOut();
ob.onResult(result);
}
}
public void instrumentWakeUp(
String requestID,
InstrumentedResultCallback instrumentedResultCallback,
JsonObject result) {
public void instrumentWakeUp(String requestID,
InstrumentedResultCallback instrumentedResultCallback, JsonObject result) {
ResultCallback ob = waitObj.get(requestID);
// TODO 难怪之前这是注释的。
// TODO 难怪之前这是注释的。
waitObj.remove(requestID);
// cancel timeout
// cancel timeout
if (ob != null) {
ob.cancelTimeOut();
instrumentedResultCallback.onResult(ob, result);
@ -61,7 +56,7 @@ public class SyncResult {
if (!waitObj.containsKey(requestID)) {
CancelTask tt = new CancelTask(requestID);
Timeout timeout = timer.newTimeout(tt, timeOut, TimeUnit.SECONDS);
// logger.debug("reqID:" + requestID + " createTimeout:" + timeout);
// logger.debug("reqID:" + requestID + " createTimeout:" + timeout);
cb.setTimeOut(timeout);
waitObj.put(requestID, cb);
} else {

100
src/main/src/org/bdware/server/http/ArgParser.java Normal file
View File

@ -0,0 +1,100 @@
package org.bdware.server.http;
import com.google.gson.JsonElement;
import com.google.gson.JsonObject;
import com.google.gson.JsonParser;
import io.netty.buffer.ByteBuf;
import io.netty.buffer.ByteBufInputStream;
import io.netty.handler.codec.http.FullHttpRequest;
import io.netty.handler.codec.http.QueryStringDecoder;
import org.apache.logging.log4j.LogManager;
import org.apache.logging.log4j.Logger;
import org.bdware.sc.util.ExceptionUtil;
import org.bouncycastle.crypto.params.ECPublicKeyParameters;
import org.bouncycastle.pqc.math.linearalgebra.ByteUtils;
import org.zz.gmhelper.BCECUtil;
import org.zz.gmhelper.SM2Util;
import java.io.InputStreamReader;
import java.net.URLDecoder;
import java.util.List;
import java.util.Map;
public class ArgParser {
public interface VerifiedCallback {
void onResult(boolean verified, JsonObject param);
}
private static final Logger LOGGER = LogManager.getLogger(ArgParser.class);
public static JsonObject parseGetAndVerify(FullHttpRequest msg, VerifiedCallback cb)
throws Exception {
QueryStringDecoder decoderQuery = new QueryStringDecoder(msg.uri());
Map<String, List<String>> parameters = decoderQuery.parameters();
JsonObject transformedParam = new JsonObject();
for (String key : parameters.keySet()) {
List<String> val = parameters.get(key);
if (null != val) {
transformedParam.addProperty(key, val.get(0));
}
}
// 匿名用户权限为0
transformedParam.addProperty("permission", 0);
transformedParam.remove("verifiedPubKey");
// 验签 有pubKey就必须有sign
String uri = URLDecoder.decode(msg.uri(), "UTF-8").split("\\?")[1];
int index = uri.lastIndexOf('&');
if (index >= 0)
verifyParam(transformedParam, uri.substring(0, index), cb);
return transformedParam;
}
private static void verifyParam(JsonObject transformedParam, String toVerifyStr,
VerifiedCallback cb) {
boolean verify = false;
if (transformedParam.has("pubKey")) {
LOGGER.info("before verifying: " + toVerifyStr);
try {
ECPublicKeyParameters pubKey = BCECUtil.createECPublicKeyFromStrParameters(
transformedParam.get("pubKey").getAsString(), SM2Util.CURVE,
SM2Util.DOMAIN_PARAMS);
verify = SM2Util.verify(pubKey, toVerifyStr.getBytes(),
ByteUtils.fromHexString(transformedParam.get("sign").getAsString()));
} catch (Exception e) {
LOGGER.error(e.getMessage());
LOGGER.debug(ExceptionUtil.exceptionToString(e));
}
}
if (cb != null)
cb.onResult(verify, transformedParam);
return;
}
public static JsonObject parsePostAndVerify(FullHttpRequest msg, VerifiedCallback cb)
throws Exception {
ByteBuf content = msg.content();
JsonObject map =
JsonParser.parseReader(new InputStreamReader(new ByteBufInputStream(content)))
.getAsJsonObject();
StringBuilder toSign = new StringBuilder();
boolean isFirst = true;
for (String key : map.keySet()) {
if (!key.equals("sign")) {
if (!isFirst)
toSign.append("&");
isFirst = false;
toSign.append(key).append("=");
JsonElement je = map.get(key);
if (je.isJsonPrimitive())
toSign.append(je.getAsString());
else
toSign.append(je.toString());
}
}
verifyParam(map, toSign.toString(), cb);
return map;
}
}

12
src/main/src/org/bdware/server/http/FileDownloaderCallback.java
View File

@ -24,7 +24,8 @@ public class FileDownloaderCallback extends HttpResultCallback {
public void onResult(final String filePath) {
try {
final RandomAccessFile file = new RandomAccessFile(filePath, "r");
HttpResponse response = new DefaultHttpResponse(HttpVersion.HTTP_1_1, HttpResponseStatus.OK);
HttpResponse response =
new DefaultHttpResponse(HttpVersion.HTTP_1_1, HttpResponseStatus.OK);
// 设置文件格式内容
response.headers().set(HttpHeaderNames.CONTENT_TYPE, "application/x-msdownload");
response.headers().set(HttpHeaderNames.CONTENT_DISPOSITION,
@ -33,13 +34,14 @@ public class FileDownloaderCallback extends HttpResultCallback {
HttpUtil.setContentLength(response, file.length());
LOGGER.debug("FileLength:" + file.length());
ctxField.write(response);
ChannelFuture future = ctxField.write(new DefaultFileRegion(file.getChannel(), 0, file.length()),
ctxField.newProgressivePromise());
ChannelFuture future =
ctxField.write(new DefaultFileRegion(file.getChannel(), 0, file.length()),
ctxField.newProgressivePromise());
ctxField.writeAndFlush(LastHttpContent.EMPTY_LAST_CONTENT);
future.addListener(new ChannelProgressiveFutureListener() {
@Override
public void operationProgressed(ChannelProgressiveFuture future, long progress, long total) {
}
public void operationProgressed(ChannelProgressiveFuture future, long progress,
long total) {}
@Override
public void operationComplete(ChannelProgressiveFuture future) throws Exception {

22
src/main/src/org/bdware/server/http/HttpFileHandleAdapter.java
View File

@ -24,12 +24,8 @@ public class HttpFileHandleAdapter extends SimpleChannelInboundHandler<FullHttpR
}
public static void sendError(ChannelHandlerContext ctx, HttpResponseStatus status) {
FullHttpResponse response =
new DefaultFullHttpResponse(
HTTP_1_1,
status,
Unpooled.wrappedBuffer(
("Failure: " + status + "\r\n").getBytes()));
FullHttpResponse response = new DefaultFullHttpResponse(HTTP_1_1, status,
Unpooled.wrappedBuffer(("Failure: " + status + "\r\n").getBytes()));
response.headers().set(HttpHeaderNames.CONTENT_TYPE, "text/plain; charset=UTF-8");
ctx.writeAndFlush(response).addListener(ChannelFutureListener.CLOSE);
}
@ -44,7 +40,9 @@ public class HttpFileHandleAdapter extends SimpleChannelInboundHandler<FullHttpR
} else if (path.endsWith(".ico")) {
headers.set(HttpHeaderNames.CONTENT_TYPE, "image/x-icon;");
} else if (path.endsWith(".svg")) {
headers.set(HttpHeaderNames.CONTENT_TYPE, "text/xml;charset=utf-8");
headers.set(HttpHeaderNames.CONTENT_TYPE, "image/svg+xml;charset=utf-8");
} else if (path.endsWith(".ypk")) {
headers.set(HttpHeaderNames.CONTENT_TYPE, "application/ypk");
}
}
@ -59,11 +57,11 @@ public class HttpFileHandleAdapter extends SimpleChannelInboundHandler<FullHttpR
throws Exception {
// 获取URI
request.retain();
// System.out.println("[HttpFileHandlerAdapter]request.uri:" + request.uri());
// String[] hoString = request.duplicate().toString().split("\n");
// if (request.uri().equals("/favicon.ico")) {
// request.setUri("/SCIDE/favicon.ico");
// }
// System.out.println("[HttpFileHandlerAdapter]request.uri:" + request.uri());
// String[] hoString = request.duplicate().toString().split("\n");
// if (request.uri().equals("/favicon.ico")) {
// request.setUri("/SCIDE/favicon.ico");
// }
String uri = request.uri();
if (uri.contains("..")) {

10
src/main/src/org/bdware/server/http/HttpMethod.java
View File

@ -1,15 +1,7 @@
package org.bdware.server.http;
public enum HttpMethod {
OPTIONS,
GET,
HEAD,
POST,
PUT,
PATCH,
DELETE,
TRACE,
CONNECT;
OPTIONS, GET, HEAD, POST, PUT, PATCH, DELETE, TRACE, CONNECT;
io.netty.handler.codec.http.HttpMethod get() {
switch (this) {

50
src/main/src/org/bdware/server/http/URIHandler.java
View File

@ -17,7 +17,7 @@ import static io.netty.handler.codec.http.HttpVersion.HTTP_1_1;
public class URIHandler {
private static final Logger LOGGER = LogManager.getLogger(URIHandler.class);
Map<io.netty.handler.codec.http.HttpMethod, List<Tuple<String, Method, Object>>> handlers;
private Map<io.netty.handler.codec.http.HttpMethod, List<Tuple<String, Method, Object>>> handlers;
public URIHandler() {
handlers = new HashMap<>();
@ -59,15 +59,27 @@ public class URIHandler {
});
}
public Tuple<String, Method, Object> findHandler(FullHttpRequest msg) {
List<Tuple<String, Method, Object>> handlerList = handlers.get(msg.method());
for (Tuple<String, Method, Object> t : handlerList)
if (msg.uri().startsWith(t.t)) {
return t;
}
return null;
}
public void handle(ChannelHandlerContext ctx, FullHttpRequest msg) {
Tuple<String, Method, Object> t = findHandler(msg);
handle(ctx, msg, t);
}
public void handle(ChannelHandlerContext ctx, FullHttpRequest msg,
Tuple<String, Method, Object> t) {
try {
List<Tuple<String, Method, Object>> handlerList = handlers.get(msg.method());
for (Tuple<String, Method, Object> t : handlerList)
if (msg.uri().startsWith(t.t)) {
t.u.invoke(t.s, ctx, msg);
return;
}
sendUnsupported(ctx);
if (t != null)
t.u.invoke(t.s, ctx, msg);
else
sendUnsupported(ctx);
} catch (Exception e) {
e.printStackTrace();
}
@ -80,29 +92,25 @@ public class URIHandler {
for (Tuple<String, Method, Object> t : handlers.get(m)) {
String className = t.u.getDeclaringClass().getSimpleName();
sbl.append("\t\t").append(t.t.isEmpty() ? "<null>" : t.t).append(" --> ")
.append(className.isEmpty() ? "null" : className)
.append(".").append(t.u.getName()).append("\n");
.append(className.isEmpty() ? "null" : className).append(".")
.append(t.u.getName()).append("\n");
}
}
LOGGER.info(sbl.substring(0, sbl.length() - 1));
}
private void sendUnsupported(ChannelHandlerContext ctx) {
FullHttpResponse response =
new DefaultFullHttpResponse(
HTTP_1_1,
HttpResponseStatus.BAD_REQUEST,
Unpooled.wrappedBuffer(
("Failure: " + HttpResponseStatus.BAD_REQUEST + "\r\n")
.getBytes()));
FullHttpResponse response = new DefaultFullHttpResponse(HTTP_1_1,
HttpResponseStatus.BAD_REQUEST, Unpooled.wrappedBuffer(
("Failure: " + HttpResponseStatus.BAD_REQUEST + "\r\n").getBytes()));
response.headers().set(HttpHeaderNames.CONTENT_TYPE, "text/plain; charset=UTF-8");
ctx.writeAndFlush(response).addListener(ChannelFutureListener.CLOSE);
}
static class Tuple<T, U, S> {
T t;
U u;
S s;
public static class Tuple<T, U, S> {
public T t;
public U u;
public S s;
Tuple(T t, U u, S s) {
this.t = t;

1
src/main/src/org/bdware/server/http/URIPath.java
View File

@ -9,5 +9,6 @@ import java.lang.annotation.Target;
@Target(ElementType.METHOD)
public @interface URIPath {
String[] value() default {""};
HttpMethod method() default HttpMethod.GET;
}

10
src/main/src/org/bdware/server/nodecenter/Response.java
View File

@ -1,9 +1,9 @@
package org.bdware.server.nodecenter;
public class Response {
public String responseID;
public String action;
public Object data;
public long executeTime;
public boolean isPrivate;
public String responseID;
public String action;
public Object data;
public long executeTime;
public boolean isPrivate;
}

17
src/main/src/org/bdware/server/nodecenter/client/CMNodeBean.java
View File

@ -22,9 +22,9 @@ public class CMNodeBean {
// TODO nodeMangerPubkey
public void updateContract(Map<String, String> json) {
String jsonStr = json.get("contracts");
contracts = JsonUtil.fromJson(jsonStr, new TypeToken<List<ContractDesp>>() {
}.getType());
// KeyValueDBUtil.instance.setValue(NCTables.NodesDB.toString(), pubKey, JsonUtil.toJson(this));
contracts = JsonUtil.fromJson(jsonStr, new TypeToken<List<ContractDesp>>() {}.getType());
// KeyValueDBUtil.instance.setValue(NCTables.NodesDB.toString(), pubKey,
// JsonUtil.toJson(this));
}
@ -33,7 +33,8 @@ public class CMNodeBean {
public String formatContractName(String contractIDOrName) {
if (null != contracts) {
for (ContractDesp desp : contracts) {
if (desp.contractID.equals(contractIDOrName) || desp.contractName.equals(contractIDOrName)) {
if (desp.contractID.equals(contractIDOrName)
|| desp.contractName.equals(contractIDOrName)) {
return desp.contractName;
}
}
@ -44,7 +45,8 @@ public class CMNodeBean {
public boolean containsContract(String contractIDOrName) {
if (null != contracts) {
for (ContractDesp desp : contracts) {
if (desp.contractID.equals(contractIDOrName) || desp.contractName.equals(contractIDOrName))
if (desp.contractID.equals(contractIDOrName)
|| desp.contractName.equals(contractIDOrName))
return true;
}
}
@ -54,7 +56,8 @@ public class CMNodeBean {
public boolean containsEvent(String contractIDOrName, String event) {
if (null != contracts) {
for (ContractDesp desp : contracts) {
if (desp.contractID.equals(contractIDOrName) || desp.contractName.equals(contractIDOrName)) {
if (desp.contractID.equals(contractIDOrName)
|| desp.contractName.equals(contractIDOrName)) {
if (desp.events.containsKey(event))
return true;
}
@ -82,4 +85,4 @@ public class CMNodeBean {
}
}
}

90
src/main/src/org/bdware/server/permission/Permission.java
View File

@ -1,60 +1,54 @@
package org.bdware.server.permission;
public enum Permission {
// GetSessionID(0), GetRole(0), Login(0), // 默认权限设置为0
// ApplyRole(1 << 0), // 匿名用户申请成为节点管理员（NodePortal）角色
// NodeStateList(1 << 1), // 中心节点查看节点管理员的所管理所有节点的状态
// AuthNodeManager(1 << 2), // 授权节点管理员
// DeleteNodeManager(1 << 3), // 从网络中删除某个节点管理员
// ListAllUsers(1 << 4), // ListAllUser
// ListApplyUser(1 << 5), // ListApplyUser
// ListTrustCluster(1 << 6), // 查看可信执行集群列表
// AssignTrustedCluster(1 << 7), // 分配可信执行集群
//
// // ==================NodePotral===============
// //ApplyNodeRole(1<<6),//申请节点角色
// AuthNodeRole(1 << 8), // 授权角色
// DeleteRole(1 << 9), // 从用户角色中删除某一种角色
// ListAllAuthUsers(1 << 10), // 查看已授权用户
// ListUnAuthUsers(1 << 11), // 查看未授权用户
//
// StartContract(1 << 12), ExecuteContract(1 << 13), StopContract(1 << 14), // stop和kill一样
// UploadContract(1 << 15), // 上传合约代码（修改代码、更新合约代码、保存代码)
// DownloadContract(1 << 16), // 下载合约代码
// DeleteContract(1 << 17), // 删除合约代码
//
// ContractCodeStatisticsList(1 << 18), // 查看合约代码统计数据（合约文件大小)
// StaticAnalysis(1 << 19), // 静态分析
// ConfigureContractPermission(1 << 20), // 配置合约权限
// ContractProgressList(1L << 22L), // 查看合约进程(listContractProcess)
//
// QueryActionLog(1L << 24L), // 增加listLog(时间戳)
// QueryUserStateLog(1L << 25L), // 查看节点日志
// ListLocalNodeStatus(1L << 26L), // 节点状态(此节点)
// ListContractLog(1L << 27L), // 合约日志
//
// TimeTravel(1L << 28L), ManualDump(1L << 29L), // 手动dump
// ForkContractStatus(1L << 30L), // 合约状态从别处迁移到自己本地
// ConfigureNode(1L << 31L), // 配置节点信息
// listProjects(1L << 32L),// 合约提供者
// GetSessionID(0), GetRole(0), Login(0), // 默认权限设置为0
// ApplyRole(1 << 0), // 匿名用户申请成为节点管理员（NodePortal）角色
// NodeStateList(1 << 1), // 中心节点查看节点管理员的所管理所有节点的状态
// AuthNodeManager(1 << 2), // 授权节点管理员
// DeleteNodeManager(1 << 3), // 从网络中删除某个节点管理员
// ListAllUsers(1 << 4), // ListAllUser
// ListApplyUser(1 << 5), // ListApplyUser
// ListTrustCluster(1 << 6), // 查看可信执行集群列表
// AssignTrustedCluster(1 << 7), // 分配可信执行集群
//
// // ==================NodePotral===============
// //ApplyNodeRole(1<<6),//申请节点角色
// AuthNodeRole(1 << 8), // 授权角色
// DeleteRole(1 << 9), // 从用户角色中删除某一种角色
// ListAllAuthUsers(1 << 10), // 查看已授权用户
// ListUnAuthUsers(1 << 11), // 查看未授权用户
//
// StartContract(1 << 12), ExecuteContract(1 << 13), StopContract(1 << 14), // stop和kill一样
// UploadContract(1 << 15), // 上传合约代码（修改代码、更新合约代码、保存代码)
// DownloadContract(1 << 16), // 下载合约代码
// DeleteContract(1 << 17), // 删除合约代码
//
// ContractCodeStatisticsList(1 << 18), // 查看合约代码统计数据（合约文件大小)
// StaticAnalysis(1 << 19), // 静态分析
// ConfigureContractPermission(1 << 20), // 配置合约权限
// ContractProgressList(1L << 22L), // 查看合约进程(listContractProcess)
//
// QueryActionLog(1L << 24L), // 增加listLog(时间戳)
// QueryUserStateLog(1L << 25L), // 查看节点日志
// ListLocalNodeStatus(1L << 26L), // 节点状态(此节点)
// ListContractLog(1L << 27L), // 合约日志
//
// TimeTravel(1L << 28L), ManualDump(1L << 29L), // 手动dump
// ForkContractStatus(1L << 30L), // 合约状态从别处迁移到自己本地
// ConfigureNode(1L << 31L), // 配置节点信息
// listProjects(1L << 32L),// 合约提供者
// 新加的一些权限
// listLicence(1L<<33L)//证书列表 updateLicence权限也写成这个了，有没有必要分开
// listLicence(1L<<33L)//证书列表 updateLicence权限也写成这个了，有没有必要分开
// TODO: 20205/20 需要整理权限就权限和最新的权限
// CenterManager (其他部分代码中出现的，暂未合并整理)
ApplyRole(1 << 0),
NodeStateList(1 << 1),
AuthNodeManager(1 << 2),
ListAllUsers(1 << 3),
ListApplyUser(1 << 4),
DeleteNodeManager(1 << 5),
ListTrustCluster(1 << 6),
AssignTrustedCluster(1 << 7),
QueryActionLog(1 << 8),
QueryUserStateLog(1 << 9),
ApplyRole(1 << 0), NodeStateList(1 << 1), AuthNodeManager(1 << 2), ListAllUsers(
1 << 3), ListApplyUser(1 << 4), DeleteNodeManager(1 << 5), ListTrustCluster(
1 << 6), AssignTrustedCluster(
1 << 7), QueryActionLog(1 << 8), QueryUserStateLog(1 << 9),
// Node
ConfigureNode(1 << 10), // 其他地方代码中的权限
@ -90,4 +84,4 @@ public enum Permission {
public long getValue() {
return value;
}
}
}

9
src/main/src/org/bdware/server/permission/Role.java
View File

@ -1,13 +1,8 @@
package org.bdware.server.permission;
public enum Role {
CenterManager(0x3ffL),
NodeManager(0xe41L),
Node(0x1L),
ContractProvider(0x3f000L),
ContractInstanceManager(0x7ff10c0L),
ContractUser(0x5c0000L),
Anonymous(0);
CenterManager(0x3ffL), NodeManager(0xe41L), Node(0x1L), ContractProvider(
0x3f000L), ContractInstanceManager(0x7ff10c0L), ContractUser(0x5c0000L), Anonymous(0);
long value;

16
src/main/src/org/bdware/server/ws/DelimiterBasedFrameEncoder.java
View File

@ -5,13 +5,13 @@ import io.netty.channel.ChannelHandlerContext;
import io.netty.handler.codec.MessageToByteEncoder;
public class DelimiterBasedFrameEncoder extends MessageToByteEncoder<ByteBuf> {
static byte[] delimiter = "wonbifoodie".getBytes();
static byte[] delimiter = "wonbifoodie".getBytes();
@Override
protected void encode(ChannelHandlerContext arg0, ByteBuf in, ByteBuf out) throws Exception {
// System.out.println("[DelimiterBasedFrameEncoder] write:" +
// in.readableBytes());
out.writeBytes(in);
out.writeBytes(delimiter);
}
@Override
protected void encode(ChannelHandlerContext arg0, ByteBuf in, ByteBuf out) throws Exception {
// System.out.println("[DelimiterBasedFrameEncoder] write:" +
// in.readableBytes());
out.writeBytes(in);
out.writeBytes(delimiter);
}
}

8
src/main/src/org/bdware/server/ws/DelimiterCodec.java
View File

@ -5,13 +5,11 @@ import io.netty.buffer.Unpooled;
import io.netty.channel.CombinedChannelDuplexHandler;
import io.netty.handler.codec.DelimiterBasedFrameDecoder;
public class DelimiterCodec
extends CombinedChannelDuplexHandler<
DelimiterBasedFrameDecoder, DelimiterBasedFrameEncoder> {
public class DelimiterCodec extends
CombinedChannelDuplexHandler<DelimiterBasedFrameDecoder, DelimiterBasedFrameEncoder> {
public DelimiterCodec() {
ByteBuf buf = Unpooled.wrappedBuffer(DelimiterBasedFrameEncoder.delimiter);
init(
new DelimiterBasedFrameDecoder(10 * 1024 * 1024, buf),
init(new DelimiterBasedFrameDecoder(10 * 1024 * 1024, buf),
new DelimiterBasedFrameEncoder());
}
}

134
src/main/src/org/bdware/server/ws/WebSocketIndexPageHandler.java
View File

@ -25,76 +25,78 @@ import static io.netty.handler.codec.http.HttpResponseStatus.*;
*/
public class WebSocketIndexPageHandler extends SimpleChannelInboundHandler<FullHttpRequest> {
private final String websocketPath;
private final String websocketPath;
public WebSocketIndexPageHandler(String websocketPath) {
this.websocketPath = websocketPath;
}
public WebSocketIndexPageHandler(String websocketPath) {
this.websocketPath = websocketPath;
}
@SuppressWarnings("deprecation")
@Override
protected void channelRead0(ChannelHandlerContext ctx, FullHttpRequest req) throws Exception {
// Handle a bad request.
if (!req.getUri().startsWith("/SCIDE/SCExecutor")) {
sendHttpResponse(ctx, req,
new DefaultFullHttpResponse(req.protocolVersion(), NOT_FOUND, ctx.alloc().buffer(0)));
return;
}
if (!req.decoderResult().isSuccess()) {
sendHttpResponse(ctx, req,
new DefaultFullHttpResponse(req.protocolVersion(), BAD_REQUEST, ctx.alloc().buffer(0)));
return;
}
@SuppressWarnings("deprecation")
@Override
protected void channelRead0(ChannelHandlerContext ctx, FullHttpRequest req) throws Exception {
// Handle a bad request.
if (!req.getUri().startsWith("/SCIDE/SCExecutor")) {
sendHttpResponse(ctx, req, new DefaultFullHttpResponse(req.protocolVersion(), NOT_FOUND,
ctx.alloc().buffer(0)));
return;
}
if (!req.decoderResult().isSuccess()) {
sendHttpResponse(ctx, req, new DefaultFullHttpResponse(req.protocolVersion(),
BAD_REQUEST, ctx.alloc().buffer(0)));
return;
}
// Allow only GET methods.
if (!GET.equals(req.method())) {
sendHttpResponse(ctx, req,
new DefaultFullHttpResponse(req.protocolVersion(), FORBIDDEN, ctx.alloc().buffer(0)));
return;
}
// Allow only GET methods.
if (!GET.equals(req.method())) {
sendHttpResponse(ctx, req, new DefaultFullHttpResponse(req.protocolVersion(), FORBIDDEN,
ctx.alloc().buffer(0)));
return;
}
// Send the index page
if ("/SCIDE/SCExecutor/".equals(req.uri()) || "/SCIDE/SCExecutor/index.html".equals(req.uri())) {
String webSocketLocation = getWebSocketLocation(ctx.pipeline(), req, websocketPath);
ByteBuf content = WebSocketServerIndexPage.getContent(webSocketLocation);
FullHttpResponse res = new DefaultFullHttpResponse(req.protocolVersion(), OK, content);
res.headers().set(CONTENT_TYPE, "text/html; charset=UTF-8");
HttpUtil.setContentLength(res, content.readableBytes());
sendHttpResponse(ctx, req, res);
} else {
sendHttpResponse(ctx, req,
new DefaultFullHttpResponse(req.protocolVersion(), NOT_FOUND, ctx.alloc().buffer(0)));
}
}
// Send the index page
if ("/SCIDE/SCExecutor/".equals(req.uri())
|| "/SCIDE/SCExecutor/index.html".equals(req.uri())) {
String webSocketLocation = getWebSocketLocation(ctx.pipeline(), req, websocketPath);
ByteBuf content = WebSocketServerIndexPage.getContent(webSocketLocation);
FullHttpResponse res = new DefaultFullHttpResponse(req.protocolVersion(), OK, content);
res.headers().set(CONTENT_TYPE, "text/html; charset=UTF-8");
HttpUtil.setContentLength(res, content.readableBytes());
sendHttpResponse(ctx, req, res);
} else {
sendHttpResponse(ctx, req, new DefaultFullHttpResponse(req.protocolVersion(), NOT_FOUND,
ctx.alloc().buffer(0)));
}
}
@Override
public void exceptionCaught(ChannelHandlerContext ctx, Throwable cause) {
cause.printStackTrace();
ctx.close();
}
@Override
public void exceptionCaught(ChannelHandlerContext ctx, Throwable cause) {
cause.printStackTrace();
ctx.close();
}
private static void sendHttpResponse(ChannelHandlerContext ctx, FullHttpRequest req, FullHttpResponse res) {
// Generate an error page if response getStatus code is not OK (200).
HttpResponseStatus responseStatus = res.status();
if (responseStatus.code() != 200) {
ByteBufUtil.writeUtf8(res.content(), responseStatus.toString());
HttpUtil.setContentLength(res, res.content().readableBytes());
}
// Send the response and close the connection if necessary.
boolean keepAlive = HttpUtil.isKeepAlive(req) && responseStatus.code() == 200;
HttpUtil.setKeepAlive(res, keepAlive);
ChannelFuture future = ctx.writeAndFlush(res);
if (!keepAlive) {
future.addListener(ChannelFutureListener.CLOSE);
}
}
private static void sendHttpResponse(ChannelHandlerContext ctx, FullHttpRequest req,
FullHttpResponse res) {
// Generate an error page if response getStatus code is not OK (200).
HttpResponseStatus responseStatus = res.status();
if (responseStatus.code() != 200) {
ByteBufUtil.writeUtf8(res.content(), responseStatus.toString());
HttpUtil.setContentLength(res, res.content().readableBytes());
}
// Send the response and close the connection if necessary.
boolean keepAlive = HttpUtil.isKeepAlive(req) && responseStatus.code() == 200;
HttpUtil.setKeepAlive(res, keepAlive);
ChannelFuture future = ctx.writeAndFlush(res);
if (!keepAlive) {
future.addListener(ChannelFutureListener.CLOSE);
}
}
private static String getWebSocketLocation(ChannelPipeline cp, HttpRequest req, String path) {
String protocol = "ws";
if (cp.get(SslHandler.class) != null) {
// SSL in use so use Secure WebSockets
protocol = "wss";
}
return protocol + "://" + req.headers().get(HttpHeaderNames.HOST) + path;
}
}
private static String getWebSocketLocation(ChannelPipeline cp, HttpRequest req, String path) {
String protocol = "ws";
if (cp.get(SslHandler.class) != null) {
// SSL in use so use Secure WebSockets
protocol = "wss";
}
return protocol + "://" + req.headers().get(HttpHeaderNames.HOST) + path;
}
}

114
src/main/src/org/bdware/server/ws/WebSocketServerIndexPage.java
View File

@ -9,93 +9,33 @@ public final class WebSocketServerIndexPage {
private static final String NEWLINE = "\r\n";
public static ByteBuf getContent(String webSocketLocation) {
String str =
"<html><head><title>Web Socket Test</title></head>"
+ NEWLINE
+ "<body>"
+ NEWLINE
+ "<script type=\"text/javascript\">"
+ NEWLINE
+ "var socket;"
+ NEWLINE
+ "if (!window.WebSocket) {"
+ NEWLINE
+ " window.WebSocket = window.MozWebSocket;"
+ NEWLINE
+ '}'
+ NEWLINE
+ "if (window.WebSocket) {"
+ NEWLINE
+ " socket = new WebSocket(\""
+ webSocketLocation
+ "\");"
+ NEWLINE
+ " socket.onmessage = function(event) {"
+ NEWLINE
+ " var ta = document.getElementById('responseText');"
+ NEWLINE
+ " ta.value = ta.value + '\\n' + event.data"
+ NEWLINE
+ " };"
+ NEWLINE
+ " socket.onopen = function(event) {"
+ NEWLINE
+ " var ta = document.getElementById('responseText');"
+ NEWLINE
+ " ta.value = \"Web Socket opened!\";"
+ NEWLINE
+ " };"
+ NEWLINE
+ " socket.onclose = function(event) {"
+ NEWLINE
+ " var ta = document.getElementById('responseText');"
+ NEWLINE
+ " ta.value = ta.value + \"Web Socket closed\"; "
+ NEWLINE
+ " };"
+ NEWLINE
+ "} else {"
+ NEWLINE
+ " alert(\"Your browser does not support Web Socket.\");"
+ NEWLINE
+ '}'
+ NEWLINE
+ NEWLINE
+ "function send(message) {"
+ NEWLINE
+ " if (!window.WebSocket) { return; }"
+ NEWLINE
+ " if (socket.readyState == WebSocket.OPEN) {"
+ NEWLINE
+ " socket.send(message);"
+ NEWLINE
+ " } else {"
+ NEWLINE
+ " alert(\"The socket is not open.\");"
+ NEWLINE
+ " }"
+ NEWLINE
+ '}'
+ NEWLINE
+ "</script>"
+ NEWLINE
+ "<form onsubmit=\"return false;\">"
+ NEWLINE
+ "<input type=\"text\" name=\"message\" value=\"Hello, World!\"/>"
+ "<input type=\"button\" value=\"Send Web Socket Data\""
+ NEWLINE
+ " onclick=\"send(this.form.message.value)\" />"
+ NEWLINE
+ "<h3>Output</h3>"
+ NEWLINE
+ "<textarea id=\"responseText\" style=\"width:500px;height:300px;\"></textarea>"
+ NEWLINE
+ "</form>"
+ NEWLINE
+ "</body>"
+ NEWLINE
+ "</html>"
+ NEWLINE;
String str = "<html><head><title>Web Socket Test</title></head>" + NEWLINE + "<body>"
+ NEWLINE + "<script type=\"text/javascript\">" + NEWLINE + "var socket;" + NEWLINE
+ "if (!window.WebSocket) {" + NEWLINE + " window.WebSocket = window.MozWebSocket;"
+ NEWLINE + '}' + NEWLINE + "if (window.WebSocket) {" + NEWLINE
+ " socket = new WebSocket(\"" + webSocketLocation + "\");" + NEWLINE
+ " socket.onmessage = function(event) {" + NEWLINE
+ " var ta = document.getElementById('responseText');" + NEWLINE
+ " ta.value = ta.value + '\\n' + event.data" + NEWLINE + " };" + NEWLINE
+ " socket.onopen = function(event) {" + NEWLINE
+ " var ta = document.getElementById('responseText');" + NEWLINE
+ " ta.value = \"Web Socket opened!\";" + NEWLINE + " };" + NEWLINE
+ " socket.onclose = function(event) {" + NEWLINE
+ " var ta = document.getElementById('responseText');" + NEWLINE
+ " ta.value = ta.value + \"Web Socket closed\"; " + NEWLINE + " };" + NEWLINE
+ "} else {" + NEWLINE + " alert(\"Your browser does not support Web Socket.\");"
+ NEWLINE + '}' + NEWLINE + NEWLINE + "function send(message) {" + NEWLINE
+ " if (!window.WebSocket) { return; }" + NEWLINE
+ " if (socket.readyState == WebSocket.OPEN) {" + NEWLINE
+ " socket.send(message);" + NEWLINE + " } else {" + NEWLINE
+ " alert(\"The socket is not open.\");" + NEWLINE + " }" + NEWLINE + '}'
+ NEWLINE + "</script>" + NEWLINE + "<form onsubmit=\"return false;\">" + NEWLINE
+ "<input type=\"text\" name=\"message\" value=\"Hello, World!\"/>"
+ "<input type=\"button\" value=\"Send Web Socket Data\"" + NEWLINE
+ " onclick=\"send(this.form.message.value)\" />" + NEWLINE
+ "<h3>Output</h3>" + NEWLINE
+ "<textarea id=\"responseText\" style=\"width:500px;height:300px;\"></textarea>"
+ NEWLINE + "</form>" + NEWLINE + "</body>" + NEWLINE + "</html>" + NEWLINE;
return Unpooled.wrappedBuffer(str.getBytes());
}

5
src/main/thirdparty/org/bdware/server/IndexServer.java vendored
View File

@ -22,7 +22,7 @@ public class IndexServer {
}
public static void main(String[] args) throws Exception {
// NodeCenterServer.start(18001);
// NodeCenterServer.start(18001);
start(1614);
}
@ -44,7 +44,8 @@ public class IndexServer {
.childHandler(new ChannelInitializer<SocketChannel>() {
@Override
protected void initChannel(SocketChannel arg0) throws Exception {
arg0.pipeline().addLast(new HttpServerCodec()).addLast(new HttpObjectAggregator(65536))
arg0.pipeline().addLast(new HttpServerCodec())
.addLast(new HttpObjectAggregator(65536))
.addLast(new ChunkedWriteHandler()).addLast(serverHandler);
}
});

12
src/main/thirdparty/org/bdware/server/action/IndexAction.java vendored
View File

@ -20,8 +20,7 @@ public class IndexAction {
static final String MISSING_ARGUMENT = "{\"status\":\"Errorr\",\"data\":\"missing arguments\"}";
static Map<String, LenVarTimeSerialIndex2> fileMap = new HashMap<>();
public IndexAction() {
}
public IndexAction() {}
@Action(async = true)
public void createFile(JsonObject args, final ResultCallback resultCallback) {
@ -41,9 +40,9 @@ public class IndexAction {
for (int i = 0; i < dataLength; i++)
fout.write(1);
fout.close();
// LenVarTimeSerialIndex2 index = getIndexFile(fileName);
resultCallback.onResult(
"{\"status\":\"Success\",\"dataLength\":" + dataLength + ",\".datasize\":" + f.length() + "}");
// LenVarTimeSerialIndex2 index = getIndexFile(fileName);
resultCallback.onResult("{\"status\":\"Success\",\"dataLength\":" + dataLength
+ ",\".datasize\":" + f.length() + "}");
} catch (Exception e) {
ByteArrayOutputStream bo = new ByteArrayOutputStream();
@ -85,7 +84,8 @@ public class IndexAction {
try {
LenVarTimeSerialIndex2 index = getIndexFile(args.get("file").getAsString());
resultCallback.onResult("{\"dataSize\":" + index.dataSize + ",\"fileSize\":" + index.fileSize + "}");
resultCallback.onResult(
"{\"dataSize\":" + index.dataSize + ",\"fileSize\":" + index.fileSize + "}");
} catch (Exception e) {
ByteArrayOutputStream bo = new ByteArrayOutputStream();

16
src/main/thirdparty/org/bdware/server/http/IndexHttpHandler.java vendored
View File

@ -34,11 +34,10 @@ public class IndexHttpHandler extends SimpleChannelInboundHandler<HttpObject> {
private static final String UNSUPPORTED_HTTP_METHOD = "{\"msg\":\"unsupported http method\"}";
private static final String UNSUPPORTED_ACTION = "{\"msg\":\"unsupported action\"}";
private static final Logger LOGGER = LogManager.getLogger(IndexHttpHandler.class);
private static ActionExecutor<ResultCallback, JsonObject> actionExecutor = new ActionExecutor<>(
Executors.newFixedThreadPool(5), new IndexAction());
private static ActionExecutor<ResultCallback, JsonObject> actionExecutor =
new ActionExecutor<>(Executors.newFixedThreadPool(5), new IndexAction());
public IndexHttpHandler() {
}
public IndexHttpHandler() {}
@Override
public void channelReadComplete(ChannelHandlerContext ctx) {
@ -58,8 +57,9 @@ public class IndexHttpHandler extends SimpleChannelInboundHandler<HttpObject> {
private void handleHttpRequest(ChannelHandlerContext ctx, FullHttpRequest msg) {
if (!msg.uri().startsWith("/SCIDE/Index")) {
try {
DefaultFullHttpResponse fullResponse = new DefaultFullHttpResponse(msg.getProtocolVersion(), OK,
Unpooled.wrappedBuffer(UNSUPPORTED_HTTP_METHOD.getBytes()));
DefaultFullHttpResponse fullResponse =
new DefaultFullHttpResponse(msg.getProtocolVersion(), OK,
Unpooled.wrappedBuffer(UNSUPPORTED_HTTP_METHOD.getBytes()));
ChannelFuture f = ctx.write(fullResponse);
f.addListener(ChannelFutureListener.CLOSE);
} catch (Exception e) {
@ -109,8 +109,8 @@ public class IndexHttpHandler extends SimpleChannelInboundHandler<HttpObject> {
String action = null;
if (!map.has("action")) {
ret = UNSUPPORTED_ACTION.getBytes();
DefaultFullHttpResponse response = new DefaultFullHttpResponse(HttpVersion.HTTP_1_1, OK,
Unpooled.wrappedBuffer(ret));
DefaultFullHttpResponse response = new DefaultFullHttpResponse(HttpVersion.HTTP_1_1,
OK, Unpooled.wrappedBuffer(ret));
ChannelFuture f = ctx.write(response);
f.addListener(ChannelFutureListener.CLOSE);
return;

16
src/test/java/org/bdware/server/http/URIHandlerTest.java
View File

@ -14,30 +14,22 @@ public class URIHandlerTest {
handler.register(this);
}
@URIPath(
method = HttpMethod.OPTIONS,
value = {"/"})
@URIPath(method = HttpMethod.OPTIONS, value = {"/"})
public void h1(ChannelHandlerContext ctx, FullHttpRequest request) {
return;
}
@URIPath(
method = HttpMethod.GET,
value = {"/SCIDE/ABC/", "/SCIDE/CEEEE"})
@URIPath(method = HttpMethod.GET, value = {"/SCIDE/ABC/", "/SCIDE/CEEEE"})
public void h2(ChannelHandlerContext ctx, FullHttpRequest request) {
return;
}
@URIPath(
method = HttpMethod.GET,
value = {"/"})
@URIPath(method = HttpMethod.GET, value = {"/"})
public void h3(ChannelHandlerContext ctx, FullHttpRequest request) {
return;
}
@URIPath(
method = HttpMethod.GET,
value = {"/client"})
@URIPath(method = HttpMethod.GET, value = {"/client"})
public void h4(ChannelHandlerContext ctx, FullHttpRequest request) {
return;
}

8
src/test/java/org/bdware/server/permission/test/PermissionTest.java
View File

@ -35,11 +35,12 @@ public class PermissionTest {
setNodeManager.add(ManageNode);
setNodeManager.add(GetNodeInfo);
setCenterManager.add(TakeScreenShot);
long NodeManager = 0L;//2248150849
long NodeManager = 0L;// 2248150849
for (Permission p : setNodeManager) {
NodeManager |= p.getValue();
}
System.out.println("[NodeManager]" + String.format("0x%xL", NodeManager) + " " + NodeManager);
System.out
.println("[NodeManager]" + String.format("0x%xL", NodeManager) + " " + NodeManager);
EnumSet<Permission> setContractProvider = EnumSet.noneOf(Permission.class);
// 合约提供者
@ -74,7 +75,8 @@ public class PermissionTest {
for (Permission p : ContractInstanceManager) {
ContractInstanceManagerVAL |= p.getValue();
}
System.out.println("[ContractInstanceManager]" + String.format("0x%xL", ContractInstanceManagerVAL));
System.out.println(
"[ContractInstanceManager]" + String.format("0x%xL", ContractInstanceManagerVAL));
EnumSet<Permission> ContractUser = EnumSet.noneOf(Permission.class);
// 合约使用者

24
src/test/java/org/bdware/server/test/BDLedgerClient.java
View File

@ -42,14 +42,9 @@ public class BDLedgerClient {
public void send() {
String mockedFrom = "0xb60e8dd61c5d32be8058bb8eb970870f07233155";
LedgerProto.SendTransactionResponse ret2 =
client.sendTransactionSync(
"default",
CommonProto.TransactionType.MESSAGE,
mockedFrom,
random.nextLong(),
mockedFrom,
"Hellooooo".getBytes(StandardCharsets.UTF_8));
LedgerProto.SendTransactionResponse ret2 = client.sendTransactionSync("default",
CommonProto.TransactionType.MESSAGE, mockedFrom, random.nextLong(), mockedFrom,
"Hellooooo".getBytes(StandardCharsets.UTF_8));
ByteString hash = ret2.getHash();
System.out.println("[BDLedgerClient] hash:" + byteArray2Str(hash.toByteArray(), 0));
}
@ -60,9 +55,7 @@ public class BDLedgerClient {
// "ea508a07b79afc03c94a84ff190ca29f1153ef75"
// cb304919522a4acd8f2b23fadf993829ac40795a
QueryProto.GetBlocksResponse blocks =
client.getBlocksSync(
"default",
System.currentTimeMillis() - 23L * 3600L * 1000L,
client.getBlocksSync("default", System.currentTimeMillis() - 23L * 3600L * 1000L,
QueryProto.IncludeTransactions.FULL);
System.out.println("BlockCount:" + blocks.getBlocksCount());
// GetTransactionByHashResponse result = client.getTransactionByHashSync("test",
@ -73,11 +66,10 @@ public class BDLedgerClient {
@Test
public void queryTransaction() {
// test2 31b50daa8d607c673af5ef449a4d78c70bf952d4
// bdcontract cb304919522a4acd8f2b23fadf993829ac40795a
QueryProto.GetTransactionByHashResponse result =
client.getTransactionByHashSync(
"default", "78bf9fb27963b26bf2f8d558f20bf44559178b67");
// test2 31b50daa8d607c673af5ef449a4d78c70bf952d4
// bdcontract cb304919522a4acd8f2b23fadf993829ac40795a
QueryProto.GetTransactionByHashResponse result = client.getTransactionByHashSync("default",
"78bf9fb27963b26bf2f8d558f20bf44559178b67");
ByteString bytes = result.getTransaction().getData();
System.out.println(new String(bytes.toByteArray()));
}

155
src/test/java/org/bdware/server/test/CMHttpTest.java
View File

@ -11,86 +11,87 @@ import java.util.Scanner;
import com.google.gson.Gson;
public class CMHttpTest {
public static void main(String[] args) {
// ManagerActionsTest();
CMActionTest();
}
public static void main(String[] args) {
// ManagerActionsTest();
CMActionTest();
}
private static void CMActionTest() {
//http_load
String host = "http://127.0.0.1:18000/SCIDE/CMManager?action=";
String url1 = host + "ping";
System.out.println(httpGet(url1));
url1 = host + "listContractProcess";
System.out.println(httpGet(url1));
url1 = host + "writeDyjs&target=test1120.dyjs&contractID=123&content=empty";
System.out.println(httpGet(url1));
url1 = host + "executeContract&contractID=BDCoin&operation=totalSupply&arg=en";
System.out.println(httpGet(url1));
url1 = host + "getCodeByID&contractID=DORepo";
System.out.println(httpGet(url1));
url1 = host + "getPublicKey";
System.out.println(httpGet(url1));
url1 = host + "dumpContract&contractID=DORepo&target=dumTest.dyjs";
System.out.println(httpGet(url1));
url1 = host + "loadMemory&contractID=DORepo&target=dumTest.dyjs";
System.out.println(httpGet(url1));
url1 = host + "killContractProcess&contractID=abc";
System.out.println(httpGet(url1));
url1 = host + "killAllContract";
System.out.println(httpGet(url1));
url1 = host + "startContractBatched&fileList=" + URLEncoder.encode("[\"algorithmExample.yjs\",\"AAA.yjs\"]");
System.out.println(httpGet(url1));
// url1 = host + "startContractInTempZips";
// System.out.println(httpGet(url1));
}
private static void CMActionTest() {
// http_load
String host = "http://127.0.0.1:18000/SCIDE/CMManager?action=";
String url1 = host + "ping";
System.out.println(httpGet(url1));
url1 = host + "listContractProcess";
System.out.println(httpGet(url1));
url1 = host + "writeDyjs&target=test1120.dyjs&contractID=123&content=empty";
System.out.println(httpGet(url1));
url1 = host + "executeContract&contractID=BDCoin&operation=totalSupply&arg=en";
System.out.println(httpGet(url1));
url1 = host + "getCodeByID&contractID=DORepo";
System.out.println(httpGet(url1));
url1 = host + "getPublicKey";
System.out.println(httpGet(url1));
url1 = host + "dumpContract&contractID=DORepo&target=dumTest.dyjs";
System.out.println(httpGet(url1));
url1 = host + "loadMemory&contractID=DORepo&target=dumTest.dyjs";
System.out.println(httpGet(url1));
url1 = host + "killContractProcess&contractID=abc";
System.out.println(httpGet(url1));
url1 = host + "killAllContract";
System.out.println(httpGet(url1));
url1 = host + "startContractBatched&fileList="
+ URLEncoder.encode("[\"algorithmExample.yjs\",\"AAA.yjs\"]");
System.out.println(httpGet(url1));
// url1 = host + "startContractInTempZips";
// System.out.println(httpGet(url1));
private static void ManagerActionsTest() {
String host = "http://127.0.0.1:18000/SCIDE/CMManager?action=";
String url1 = host + "getEncodedUUID";
System.out.println(httpGet(url1));
url1 = host + "downloadUUID";
System.out.println(httpGet(url1));
url1 = host + "updateConfig&key=projectDir&val="
+ URLEncoder.encode("/Users/huaqiancai/java_workspace/SmartContract/contractExamples");
System.out.println(httpGet(url1));
url1 = host + "loadConfig";
System.out.println(httpGet(url1));
url1 = host + "getLicenceExpiredDate";
System.out.println(httpGet(url1));
url1 = host + "generatePrivateKey";
System.out.println(httpGet(url1));
}
}
private static void ManagerActionsTest() {
String host = "http://127.0.0.1:18000/SCIDE/CMManager?action=";
String url1 = host + "getEncodedUUID";
System.out.println(httpGet(url1));
url1 = host + "downloadUUID";
System.out.println(httpGet(url1));
url1 = host + "updateConfig&key=projectDir&val=" + URLEncoder
.encode("/Users/huaqiancai/java_workspace/SmartContract/contractExamples");
System.out.println(httpGet(url1));
url1 = host + "loadConfig";
System.out.println(httpGet(url1));
url1 = host + "getLicenceExpiredDate";
System.out.println(httpGet(url1));
url1 = host + "generatePrivateKey";
System.out.println(httpGet(url1));
static class Result {
int resposeCode;
String response;
}
}
public static String httpGet(String str) {
System.out.println("JavaScriptEntry httpGet:" + str);
Result r = new Result();
try {
URL url = new URL(str);
HttpURLConnection connection = (HttpURLConnection) url.openConnection();
r.resposeCode = connection.getResponseCode();
InputStream input = connection.getInputStream();
Scanner sc = new Scanner(input);
StringBuilder sb = new StringBuilder();
for (; sc.hasNextLine();) {
sb.append(sc.nextLine()).append("\n");
}
sc.close();
r.response = sb.toString();
return new Gson().toJson(r);
} catch (Throwable e) {
r.resposeCode = 505;
ByteArrayOutputStream bo = new ByteArrayOutputStream();
e.printStackTrace(new PrintStream(bo));
r.response = bo.toString();
return new Gson().toJson(r);
}
}
static class Result {
int resposeCode;
String response;
}
public static String httpGet(String str) {
System.out.println("JavaScriptEntry httpGet:" + str);
Result r = new Result();
try {
URL url = new URL(str);
HttpURLConnection connection = (HttpURLConnection) url.openConnection();
r.resposeCode = connection.getResponseCode();
InputStream input = connection.getInputStream();
Scanner sc = new Scanner(input);
StringBuilder sb = new StringBuilder();
for (; sc.hasNextLine();) {
sb.append(sc.nextLine()).append("\n");
}
sc.close();
r.response = sb.toString();
return new Gson().toJson(r);
} catch (Throwable e) {
r.resposeCode = 505;
ByteArrayOutputStream bo = new ByteArrayOutputStream();
e.printStackTrace(new PrintStream(bo));
r.response = bo.toString();
return new Gson().toJson(r);
}
}
}

16
src/test/java/org/bdware/server/test/GsonParseTest.java
View File

@ -10,12 +10,12 @@ import com.google.gson.reflect.TypeToken;
import org.bdware.sc.bean.ContractDesp;
public class GsonParseTest {
public static void main(String[] args) {
String jsonStr = "{\"action\":\"updateContract\",\"contracts\":\"[{\\\"contractID\\\":\\\"-1306108766\\\",\\\"contractName\\\":\\\"EventSuberAtCHQ\\\",\\\"events\\\":[\\\"def\\\"],\\\"exportedFunctions\\\":[{\\\"annotations\\\":[{\\\"type\\\":\\\"LogType\\\",\\\"args\\\":[\\\"\\\\\\\"Arg\\\\\\\"\\\"]}],\\\"functionName\\\":\\\"init\\\"},{\\\"annotations\\\":[{\\\"type\\\":\\\"LogType\\\",\\\"args\\\":[\\\"\\\\\\\"Arg\\\\\\\"\\\"]}],\\\"functionName\\\":\\\"handler\\\"}]}]\"}\n";
JsonObject jo = new JsonParser().parse(jsonStr).getAsJsonObject();
List<ContractDesp> contracts = new Gson().fromJson(jo.get("contracts").getAsString(),
new TypeToken<List<ContractDesp>>() {
}.getType());
System.out.println(new GsonBuilder().setPrettyPrinting().create().toJson(contracts));
}
public static void main(String[] args) {
String jsonStr =
"{\"action\":\"updateContract\",\"contracts\":\"[{\\\"contractID\\\":\\\"-1306108766\\\",\\\"contractName\\\":\\\"EventSuberAtCHQ\\\",\\\"events\\\":[\\\"def\\\"],\\\"exportedFunctions\\\":[{\\\"annotations\\\":[{\\\"type\\\":\\\"LogType\\\",\\\"args\\\":[\\\"\\\\\\\"Arg\\\\\\\"\\\"]}],\\\"functionName\\\":\\\"init\\\"},{\\\"annotations\\\":[{\\\"type\\\":\\\"LogType\\\",\\\"args\\\":[\\\"\\\\\\\"Arg\\\\\\\"\\\"]}],\\\"functionName\\\":\\\"handler\\\"}]}]\"}\n";
JsonObject jo = new JsonParser().parse(jsonStr).getAsJsonObject();
List<ContractDesp> contracts = new Gson().fromJson(jo.get("contracts").getAsString(),
new TypeToken<List<ContractDesp>>() {}.getType());
System.out.println(new GsonBuilder().setPrettyPrinting().create().toJson(contracts));
}
}

176
src/test/java/org/bdware/server/test/HttpPostFormTest.java
View File

@ -12,100 +12,102 @@ import java.util.Map;
public class HttpPostFormTest {
public static void postForm(String url, Map<String, String> params) {
public static void postForm(String url, Map<String, String> params) {
String responseMessage = "";
StringBuffer response = new StringBuffer();
HttpURLConnection httpConnection = null;
OutputStreamWriter out = null;
BufferedReader reader = null;
try {
URL urlPost = new URL(url);
httpConnection = (HttpURLConnection) urlPost.openConnection();
httpConnection.setDoOutput(true);
httpConnection.setDoInput(true);
httpConnection.setRequestMethod("POST");
httpConnection.setUseCaches(false);
httpConnection.setInstanceFollowRedirects(true);
httpConnection.setRequestProperty("Connection", "Keep-Alive");
httpConnection.setRequestProperty("Charset", "UTF-8");
// 设置边界
String BOUNDARY = "----------" + System.currentTimeMillis();
// httpConnection.setRequestProperty("Content-Type", "multipart/form-data;
// boundary=" + BOUNDARY);
httpConnection.setRequestProperty("Content-Type", "application/x-www-form-urlencoded;boundary=" + BOUNDARY);
String responseMessage = "";
StringBuffer response = new StringBuffer();
HttpURLConnection httpConnection = null;
OutputStreamWriter out = null;
BufferedReader reader = null;
try {
URL urlPost = new URL(url);
httpConnection = (HttpURLConnection) urlPost.openConnection();
httpConnection.setDoOutput(true);
httpConnection.setDoInput(true);
httpConnection.setRequestMethod("POST");
httpConnection.setUseCaches(false);
httpConnection.setInstanceFollowRedirects(true);
httpConnection.setRequestProperty("Connection", "Keep-Alive");
httpConnection.setRequestProperty("Charset", "UTF-8");
// 设置边界
String BOUNDARY = "----------" + System.currentTimeMillis();
// httpConnection.setRequestProperty("Content-Type", "multipart/form-data;
// boundary=" + BOUNDARY);
httpConnection.setRequestProperty("Content-Type",
"application/x-www-form-urlencoded;boundary=" + BOUNDARY);
// 连接，从postUrl.openConnection()至此的配置必须要在connect之前完成，
// 要注意的是connection.getOutputStream会隐含的进行connect。
// 实际上只是建立了一个与服务器的tcp连接，并没有实际发送http请求。
// 连接，从postUrl.openConnection()至此的配置必须要在connect之前完成，
// 要注意的是connection.getOutputStream会隐含的进行connect。
// 实际上只是建立了一个与服务器的tcp连接，并没有实际发送http请求。
httpConnection.connect();
out = new OutputStreamWriter(httpConnection.getOutputStream(), "UTF-8");
httpConnection.connect();
out = new OutputStreamWriter(httpConnection.getOutputStream(), "UTF-8");
StringBuffer sb = new StringBuffer();
int count = params.size();
for (String key : params.keySet()) {
sb.append(key + "=" + URLEncoder.encode(params.get(key)));
count--;
if (count > 0)
sb.append("&");
}
out.write(sb.toString());
System.out.println("send_url:" + url);
System.out.println("send_data:" + sb.toString());
// flush and close
out.flush();
StringBuffer sb = new StringBuffer();
int count = params.size();
for (String key : params.keySet()) {
sb.append(key + "=" + URLEncoder.encode(params.get(key)));
count--;
if (count > 0)
sb.append("&");
}
out.write(sb.toString());
System.out.println("send_url:" + url);
System.out.println("send_data:" + sb.toString());
// flush and close
out.flush();
} catch (Exception e) {
e.printStackTrace();
} finally {
try {
if (null != out) {
out.close();
}
if (null != reader) {
reader.close();
}
if (null != httpConnection) {
httpConnection.disconnect();
}
} catch (Exception e2) {
e2.printStackTrace();
}
}
} catch (Exception e) {
e.printStackTrace();
} finally {
try {
if (null != out) {
out.close();
}
if (null != reader) {
reader.close();
}
if (null != httpConnection) {
httpConnection.disconnect();
}
} catch (Exception e2) {
e2.printStackTrace();
}
}
try {
reader = new BufferedReader(new InputStreamReader(httpConnection.getInputStream(), "UTF-8"));
while ((responseMessage = reader.readLine()) != null) {
response.append(responseMessage);
response.append("\n");
}
try {
reader = new BufferedReader(
new InputStreamReader(httpConnection.getInputStream(), "UTF-8"));
while ((responseMessage = reader.readLine()) != null) {
response.append(responseMessage);
response.append("\n");
}
if (!"failure".equals(response.toString())) {
System.out.println("success");
} else {
System.out.println("failue");
}
// 将该url的配置信息缓存起来
System.out.println(response.toString());
System.out.println(httpConnection.getResponseCode());
} catch (IOException e) {
e.printStackTrace();
}
}
if (!"failure".equals(response.toString())) {
System.out.println("success");
} else {
System.out.println("failue");
}
// 将该url的配置信息缓存起来
System.out.println(response.toString());
System.out.println(httpConnection.getResponseCode());
} catch (IOException e) {
e.printStackTrace();
}
}
public static void main(String[] args) {
String url = "http://47.106.38.23:13081/register";
public static void main(String[] args) {
String url = "http://47.106.38.23:13081/register";
Map<String, String> params = new HashMap<String, String>();
String sucFix = System.currentTimeMillis() + "_ContractLog";
params.put("DOI", "86.5000.470/" + sucFix);
params.put("Description", "Contract Log");
params.put("Interface", "");
params.put("Address", "");
params.put("PublicKey", "");
params.put("Signature", "");
// http://47.106.38.23:8080/idsystem/doDetail.html?doi=86.5000.470/1570626378959_ContractLog
postForm(url, params);
}
Map<String, String> params = new HashMap<String, String>();
String sucFix = System.currentTimeMillis() + "_ContractLog";
params.put("DOI", "86.5000.470/" + sucFix);
params.put("Description", "Contract Log");
params.put("Interface", "");
params.put("Address", "");
params.put("PublicKey", "");
params.put("Signature", "");
// http://47.106.38.23:8080/idsystem/doDetail.html?doi=86.5000.470/1570626378959_ContractLog
postForm(url, params);
}
}

8
src/test/java/org/bdware/server/test/LongParseTest.java
View File

@ -1,8 +1,8 @@
package org.bdware.server.test;
public class LongParseTest {
public static void main(String[] args) {
String str = "6151".toUpperCase();
Long.parseUnsignedLong(str, 16);
}
public static void main(String[] args) {
String str = "6151".toUpperCase();
Long.parseUnsignedLong(str, 16);
}
}

127
src/test/java/org/bdware/server/test/NCHttpTest.java
View File

@ -11,74 +11,75 @@ import java.util.Scanner;
import com.google.gson.Gson;
public class NCHttpTest {
public static void main(String[] args) {
// ManagerActionsTest();
CMActionTest();
}
public static void main(String[] args) {
// ManagerActionsTest();
CMActionTest();
}
private static void CMActionTest() {
String host = "http://127.0.0.1:18001/SCIDE/NodeCenter?action=";
String url1 = host + "ping";
System.out.println(httpGet(url1));
url1 = host + "setNodeID";
System.out.println(httpGet(url1));
url1 = host + "listCMInfo";
System.out.println(httpGet(url1));
url1 = host + "updateContract";
System.out.println(httpGet(url1));
private static void CMActionTest() {
String host = "http://127.0.0.1:18001/SCIDE/NodeCenter?action=";
String url1 = host + "ping";
System.out.println(httpGet(url1));
url1 = host + "setNodeID";
System.out.println(httpGet(url1));
url1 = host + "listCMInfo";
System.out.println(httpGet(url1));
url1 = host + "updateContract";
System.out.println(httpGet(url1));
url1 = host + "executeContractOnOtherNodes&requestID=33333&contractRequest={\"contractID\":\"BDCoin\",\"action\":\"totalSupply\",\"arg\":\"n\"}";
System.out.println(httpGet(url1));
// url1 = host + "startContractInTempZips";
// System.out.println(httpGet(url1));
url1 = host
+ "executeContractOnOtherNodes&requestID=33333&contractRequest={\"contractID\":\"BDCoin\",\"action\":\"totalSupply\",\"arg\":\"n\"}";
System.out.println(httpGet(url1));
// url1 = host + "startContractInTempZips";
// System.out.println(httpGet(url1));
}
}
private static void ManagerActionsTest() {
String host = "http://127.0.0.1:18000/SCIDE/CMManager?action=";
String url1 = host + "getEncodedUUID";
System.out.println(httpGet(url1));
url1 = host + "downloadUUID";
System.out.println(httpGet(url1));
url1 = host + "updateConfig&key=projectDir&val="
+ URLEncoder.encode("/Users/huaqiancai/java_workspace/SmartContract/contractExamples");
System.out.println(httpGet(url1));
url1 = host + "loadConfig";
System.out.println(httpGet(url1));
url1 = host + "getLicenceExpiredDate";
System.out.println(httpGet(url1));
url1 = host + "generatePrivateKey";
System.out.println(httpGet(url1));
private static void ManagerActionsTest() {
String host = "http://127.0.0.1:18000/SCIDE/CMManager?action=";
String url1 = host + "getEncodedUUID";
System.out.println(httpGet(url1));
url1 = host + "downloadUUID";
System.out.println(httpGet(url1));
url1 = host + "updateConfig&key=projectDir&val=" + URLEncoder
.encode("/Users/huaqiancai/java_workspace/SmartContract/contractExamples");
System.out.println(httpGet(url1));
url1 = host + "loadConfig";
System.out.println(httpGet(url1));
url1 = host + "getLicenceExpiredDate";
System.out.println(httpGet(url1));
url1 = host + "generatePrivateKey";
System.out.println(httpGet(url1));
}
}
static class Result {
int resposeCode;
String response;
}
static class Result {
int resposeCode;
String response;
}
public static String httpGet(String str) {
System.out.println("JavaScriptEntry httpGet:" + str);
Result r = new Result();
try {
URL url = new URL(str);
HttpURLConnection connection = (HttpURLConnection) url.openConnection();
r.resposeCode = connection.getResponseCode();
InputStream input = connection.getInputStream();
Scanner sc = new Scanner(input);
StringBuilder sb = new StringBuilder();
for (; sc.hasNextLine();) {
sb.append(sc.nextLine()).append("\n");
}
sc.close();
r.response = sb.toString();
return new Gson().toJson(r);
} catch (Throwable e) {
r.resposeCode = 505;
ByteArrayOutputStream bo = new ByteArrayOutputStream();
e.printStackTrace(new PrintStream(bo));
r.response = bo.toString();
return new Gson().toJson(r);
}
}
public static String httpGet(String str) {
System.out.println("JavaScriptEntry httpGet:" + str);
Result r = new Result();
try {
URL url = new URL(str);
HttpURLConnection connection = (HttpURLConnection) url.openConnection();
r.resposeCode = connection.getResponseCode();
InputStream input = connection.getInputStream();
Scanner sc = new Scanner(input);
StringBuilder sb = new StringBuilder();
for (; sc.hasNextLine();) {
sb.append(sc.nextLine()).append("\n");
}
sc.close();
r.response = sb.toString();
return new Gson().toJson(r);
} catch (Throwable e) {
r.resposeCode = 505;
ByteArrayOutputStream bo = new ByteArrayOutputStream();
e.printStackTrace(new PrintStream(bo));
r.response = bo.toString();
return new Gson().toJson(r);
}
}
}

33
src/test/java/org/bdware/server/test/StringTest.java
View File

@ -1,19 +1,22 @@
package org.bdware.server.test;
public class StringTest {
public static void main(String[] arg) {
// String str = "\\manifest.json\\dadad\\daaa";
// System.out.println(str.replaceAll("\\\\", (byte)"/"));
byte[] arr = new byte[] { (byte) 0x1, (byte) 0x0, (byte) 0x0, (byte) 0x0, (byte) 0x2, (byte) 0xff, (byte) 0xff,
(byte) 0xff, (byte) 0xff, (byte) 0xff, (byte) 0x89, (byte) 0x7f, (byte) 0x51, (byte) 0x8c, (byte) 0x50,
(byte) 0xbb, (byte) 0xd0, (byte) 0x7f, (byte) 0xff, (byte) 0xff, (byte) 0xe9, (byte) 0xf4, (byte) 0xf8,
(byte) 0xfc, (byte) 0x0, (byte) 0x0, (byte) 0x0, (byte) 0x4, (byte) 0xff, (byte) 0xff, (byte) 0xff,
(byte) 0xff, (byte) 0xff, (byte) 0x89, (byte) 0x7f, (byte) 0x51, (byte) 0x8c, (byte) 0x3e, (byte) 0xf4,
(byte) 0x8, (byte) 0x40, (byte) 0x9f, (byte) 0x84, (byte) 0x50, (byte) 0xbb, (byte) 0xd0, (byte) 0x7f,
(byte) 0xff, (byte) 0xff, (byte) 0xe9, (byte) 0xf4, (byte) 0xf8, (byte) 0xfc, (byte) 0xf8, (byte) 0xfc,
(byte) 0x0 };
System.out.println(new String(arr));
String str = "042668227e8283cc132863cf7b83489f81056c87a19f878515d6787db7f86da7145ae05926b8e8053e59f93afdddc8705d7e17a5293b60a124a2e842d3c77cf74f";
System.out.println(str.hashCode());
}
public static void main(String[] arg) {
// String str = "\\manifest.json\\dadad\\daaa";
// System.out.println(str.replaceAll("\\\\", (byte)"/"));
byte[] arr = new byte[] {(byte) 0x1, (byte) 0x0, (byte) 0x0, (byte) 0x0, (byte) 0x2,
(byte) 0xff, (byte) 0xff, (byte) 0xff, (byte) 0xff, (byte) 0xff, (byte) 0x89,
(byte) 0x7f, (byte) 0x51, (byte) 0x8c, (byte) 0x50, (byte) 0xbb, (byte) 0xd0,
(byte) 0x7f, (byte) 0xff, (byte) 0xff, (byte) 0xe9, (byte) 0xf4, (byte) 0xf8,
(byte) 0xfc, (byte) 0x0, (byte) 0x0, (byte) 0x0, (byte) 0x4, (byte) 0xff,
(byte) 0xff, (byte) 0xff, (byte) 0xff, (byte) 0xff, (byte) 0x89, (byte) 0x7f,
(byte) 0x51, (byte) 0x8c, (byte) 0x3e, (byte) 0xf4, (byte) 0x8, (byte) 0x40,
(byte) 0x9f, (byte) 0x84, (byte) 0x50, (byte) 0xbb, (byte) 0xd0, (byte) 0x7f,
(byte) 0xff, (byte) 0xff, (byte) 0xe9, (byte) 0xf4, (byte) 0xf8, (byte) 0xfc,
(byte) 0xf8, (byte) 0xfc, (byte) 0x0};
System.out.println(new String(arr));
String str =
"042668227e8283cc132863cf7b83489f81056c87a19f878515d6787db7f86da7145ae05926b8e8053e59f93afdddc8705d7e17a5293b60a124a2e842d3c77cf74f";
System.out.println(str.hashCode());
}
}