bdware/cp
2
0
Fork 0
mirror of https://gitee.com/BDWare/cp.git synced 2025-01-10 09:54:07 +00:00
Code Issues Packages Projects Releases Wiki Activity

feat: add JavaScriptEntry.subscribe

Browse Source 
add JavaScriptEntry.subscribe(String, String, ScriptFunction) to allow contract process to subscribe local event
This commit is contained in:
Frank.R.Wu 2021-11-05 14:10:30 +08:00
parent a70d1ca14e
commit 47ed2656dd
2 changed files with 19 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
src/main/java/org/bdware/sc/ContractProcess.java
View File

@ -456,7 +456,7 @@ public class ContractProcess {
JavaScriptEntry.random.setSeed(Integer.parseInt(contract.getID())); JavaScriptEntry.random.setSeed(Integer.parseInt(contract.getID()));
JavaScriptEntry.numOfCopies = this.contract.getNumOfCopies(); JavaScriptEntry.numOfCopies = this.contract.getNumOfCopies();
JavaScriptEntry.shardingID = JavaScriptEntry.shardingID =
this.contract.getShardingId(); // 设置javaScriptEntry中的shadingID this.contract.getShardingId(); // 设置javaScriptEntry中的shardingID
// JavaScriptEntry // JavaScriptEntry
String zipPath = contract.getScriptStr(); String zipPath = contract.getScriptStr();
if (isArchiveFile(new File(zipPath))) { if (isArchiveFile(new File(zipPath))) {

19
src/main/java/org/bdware/sc/boundry/JavaScriptEntry.java
View File

@ -59,7 +59,7 @@ public class JavaScriptEntry {
public static int numOfCopies; public static int numOfCopies;
public static boolean isDebug; public static boolean isDebug;
public static List<REvent> msgList; public static List<REvent> msgList;
public static int shadingId; public static int shardingID;
// private static SM2KeyPair keyPair = new SM2().generateKeyPair(); // TODO ？？ 本地服务器的,39上运行39的 // private static SM2KeyPair keyPair = new SM2().generateKeyPair(); // TODO ？？ 本地服务器的,39上运行39的
// public static String privKey; // public static String privKey;
// public static String pubKey; // public static String pubKey;
@ -594,6 +594,23 @@ public class JavaScriptEntry {
topic_handlers.put(topic, fun); topic_handlers.put(topic, fun);
} }
/**
* subscribe a local event
*
* @param contractID contractID
* @param event local event topic
* @param fun related handler function
* @author Kaidong Wu
*/
public static void subscribe(String contractID, String event, ScriptFunction fun) {
String topic = HashUtil.sha3(contractID, event);
subscribe(topic, fun, false);
if (topic_handlers.containsKey(topic)) {
ContractProcess.instance.unSubscribe(topic_handlers.get(topic).getName());
}
topic_handlers.put(topic, fun);
}
private static void subscribe(String topic, ScriptFunction fun, boolean fromPreSub) { private static void subscribe(String topic, ScriptFunction fun, boolean fromPreSub) {
String reqID = String reqID =
String.format( String.format(