nikita/food-chain
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Some more fixes of NodeBase

Browse Source
This commit is contained in:
Nikita Iryupin 2020-12-25 12:30:21 +01:00
parent 6a7fc972fd
commit e73762eec4
2 changed files with 12 additions and 17 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

27
src/main/java/cz/cvut/fel/sit/omo/foodchain/node/NodeBase.java
View File

@ -19,9 +19,12 @@ public class NodeBase implements ChannelObserver {
private final List<Product> products; private final List<Product> products;
private MonetaryAmount money; private MonetaryAmount money;
private final List<Transaction> refusedTranslations;
public NodeBase() { public NodeBase() {
subscribedChannels = new LinkedList<>(); subscribedChannels = new LinkedList<>();
products = new LinkedList<>(); products = new LinkedList<>();
refusedTranslations = new LinkedList<>();
} }
@ -34,11 +37,11 @@ public class NodeBase implements ChannelObserver {
} }
public void sendTransaction(MonetaryAmount amount, NodeBase node) { public void sendTransaction(MonetaryAmount amount, NodeBase node, ProductTransaction prevTransaction) {
Transaction transaction = new FinancialTransaction(this, node, TransactionType.PURCHASE, amount, ); Transaction transaction = new FinancialTransaction(this, node, TransactionType.PURCHASE, amount, prevTransaction);
subscribedChannels.stream() subscribedChannels.stream()
.filter(ch -> ch.getProductType().equals(product.getProductType())) .filter(ch -> ch.getProductType().equals(prevTransaction.getProduct().getProductType()))
.findAny().ifPresent(channel -> channel.addTransaction(transaction)); .findAny().ifPresent(channel -> channel.addTransaction(transaction));
} }
@ -53,26 +56,18 @@ public class NodeBase implements ChannelObserver {
} }
public void refuseTransaction(ProductTransaction transaction) { public void refuseTransaction(Transaction transaction) {
transaction.endTransaction();
refusedTranslations.add(transaction); //TODO maybe need more work on it
} }
public void refuseTransaction(FinancialTransaction transaction) {
}
//TODO another way to read transaction
public Transaction readNextTransaction(ChannelBase channel) { public Transaction readNextTransaction(ChannelBase channel) {
return channel.getNextTransaction(); return channel.getNextTransaction();
} }
public Requirement readNextRequirement(ChannelBase channel) {
return channel.getNextRequirement();
}
public void acceptRequirement(Requirement requirement) { public void acceptRequirement(Requirement requirement) {

2
src/main/java/cz/cvut/fel/sit/omo/foodchain/operation/FinancialTransaction.java
View File

@ -9,7 +9,7 @@ public class FinancialTransaction extends Transaction {
private final MonetaryAmount amount; private final MonetaryAmount amount;
private final ProductTransaction transactionPaid; private final ProductTransaction transactionPaid;
FinancialTransaction(NodeBase creator, NodeBase receiver, TransactionType type, MonetaryAmount amount, ProductTransaction transactionPaid) { public FinancialTransaction(NodeBase creator, NodeBase receiver, TransactionType type, MonetaryAmount amount, ProductTransaction transactionPaid) {
super(creator, receiver, type); super(creator, receiver, type);
this.amount = amount; this.amount = amount;
this.transactionPaid = transactionPaid; this.transactionPaid = transactionPaid;