Skip to content

Commit fbe2b31

Browse files
committed
feat: finish Transtaction Vote Actuator.
1 parent 9236416 commit fbe2b31

6 files changed

Lines changed: 25 additions & 16 deletions

File tree

Lines changed: 4 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -1,14 +1,15 @@
11
package org.tron.core.db.actuator;
22

33
import org.tron.core.capsule.TransactionCapsule;
4-
import org.tron.core.db.TronDatabase;
4+
import org.tron.core.db.Manager;
55

66
public abstract class AbstractTransactionActuator implements Actuator {
77

88
protected TransactionCapsule transactionCapsule;
9-
protected TronDatabase tronDatabase;
9+
protected Manager dbManager;
1010

11-
AbstractTransactionActuator(TransactionCapsule transactionCapsule, TronDatabase tronDatabase) {
11+
AbstractTransactionActuator(TransactionCapsule transactionCapsule, Manager dbManager) {
1212
this.transactionCapsule = transactionCapsule;
13+
this.dbManager = dbManager;
1314
}
1415
}

src/main/java/org/tron/core/db/actuator/ActuatorFactory.java

Lines changed: 9 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -1,10 +1,13 @@
11
package org.tron.core.db.actuator;
22

3+
import org.slf4j.Logger;
4+
import org.slf4j.LoggerFactory;
35
import org.tron.core.capsule.TransactionCapsule;
46
import org.tron.core.db.Manager;
57

68
public class ActuatorFactory {
79

10+
private static final Logger logger = LoggerFactory.getLogger("ActuatorFactory");
811
public static final ActuatorFactory INSTANCE = new ActuatorFactory();
912

1013
private ActuatorFactory() {
@@ -17,13 +20,18 @@ public static ActuatorFactory getInstance() {
1720
public static Actuator createActuator(TransactionCapsule transactionCapsule,
1821
Manager manager) {
1922
if (null == transactionCapsule || null == transactionCapsule.getTransaction()) {
23+
logger.info("transactionCapsule or Transaction is null");
24+
return null;
25+
}
26+
if (null == manager) {
27+
logger.info("manager is null");
2028
return null;
2129
}
2230
switch (transactionCapsule.getTransaction().getType()) {
2331
case Transfer:
2432
break;
2533
case VoteWitess:
26-
return new TransactionVoteActuator(transactionCapsule, manager.getWitnessStore());
34+
return new TransactionVoteActuator(transactionCapsule, manager);
2735
case CreateAccount:
2836
break;
2937
case DeployContract:

src/main/java/org/tron/core/db/actuator/TransactionCreateAccountActuator.java

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -1,14 +1,14 @@
11
package org.tron.core.db.actuator;
22

33
import org.tron.core.capsule.TransactionCapsule;
4-
import org.tron.core.db.TronDatabase;
4+
import org.tron.core.db.Manager;
55

66
public class TransactionCreateAccountActuator extends AbstractTransactionActuator {
77

88

99
TransactionCreateAccountActuator(TransactionCapsule transactionCapsule,
10-
TronDatabase tronDatabase) {
11-
super(transactionCapsule, tronDatabase);
10+
Manager dbManager) {
11+
super(transactionCapsule, dbManager);
1212
}
1313

1414
@Override

src/main/java/org/tron/core/db/actuator/TransactionTransferActuator.java

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -1,14 +1,14 @@
11
package org.tron.core.db.actuator;
22

33
import org.tron.core.capsule.TransactionCapsule;
4-
import org.tron.core.db.TronDatabase;
4+
import org.tron.core.db.Manager;
55

66
public class TransactionTransferActuator extends AbstractTransactionActuator {
77

88

99
TransactionTransferActuator(TransactionCapsule transactionCapsule,
10-
TronDatabase tronDatabase) {
11-
super(transactionCapsule, tronDatabase);
10+
Manager dbManager) {
11+
super(transactionCapsule, dbManager);
1212
}
1313

1414
@Override

src/main/java/org/tron/core/db/actuator/TransactionVoteActuator.java

Lines changed: 5 additions & 6 deletions
Original file line numberDiff line numberDiff line change
@@ -5,8 +5,7 @@
55
import org.slf4j.Logger;
66
import org.slf4j.LoggerFactory;
77
import org.tron.core.capsule.TransactionCapsule;
8-
import org.tron.core.db.TronDatabase;
9-
import org.tron.core.db.WitnessStore;
8+
import org.tron.core.db.Manager;
109
import org.tron.protos.Contract.VoteWitnessContract;
1110
import org.tron.protos.Protocal.Transaction;
1211

@@ -15,8 +14,8 @@ public class TransactionVoteActuator extends AbstractTransactionActuator {
1514
private static final Logger logger = LoggerFactory.getLogger("TransactionVoteActuator");
1615

1716
TransactionVoteActuator(TransactionCapsule transactionCapsule,
18-
TronDatabase tronDatabase) {
19-
super(transactionCapsule, tronDatabase);
17+
Manager dbManager) {
18+
super(transactionCapsule, dbManager);
2019
}
2120

2221

@@ -40,8 +39,8 @@ private boolean voteWitnessCount(Transaction trx) {
4039
int voteAdd = voteContract.getCount();
4140
if (voteAdd > 0) {
4241
voteContract.getVoteAddressList().forEach(voteAddress -> {
43-
if (tronDatabase instanceof WitnessStore) {
44-
((WitnessStore) tronDatabase).countvoteWitness(voteAddress, voteAdd);
42+
if (null != dbManager) {
43+
dbManager.getWitnessStore().countvoteWitness(voteAddress, voteAdd);
4544
}
4645
});
4746
}

src/main/resources/logback.xml

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -78,6 +78,7 @@
7878
<logger name="TransactionUtil" level="INFO"/>
7979
<logger name="TransactionVoteActuator" level="INFO"/>
8080
<logger name="WitnessStore" level="INFO"/>
81+
<logger name="ActuatorFactory" level="INFO"/>
8182

8283
</configuration>
8384

0 commit comments

Comments
 (0)