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

Compare commits

base: nikita:feature/operation_impl
Branches Tags
nikita:master
nikita:develop
nikita:feature/text_report_impl
nikita:feature/node_impl
nikita:feature/channel_impl
nikita:feature/factory_impl
nikita:feature/pool_parser_impl
nikita:feature/scenario_impl
nikita:feature/operation_impl
..
compare: nikita:master
Branches Tags
nikita:develop
nikita:feature/text_report_impl
nikita:feature/node_impl
nikita:feature/channel_impl
nikita:feature/factory_impl
nikita:feature/pool_parser_impl
nikita:feature/scenario_impl
nikita:feature/operation_impl
nikita:master

No commits in common. "feature/operation_impl" and "master" have entirely different histories.
feature/op ... master

56 changed files with 0 additions and 1104 deletions
Show Stats Expand all files Collapse all files

4
.gitignore vendored
View File

@ -1,4 +0,0 @@
.idea
target
*.idb

BIN
EAR diagrams/FoodChain.eap
View File

Binary file not shown.

BIN
EAR diagrams/FoodChain.ldb
View File

Binary file not shown.

2
FoodChain.iml
View File

@ -1,2 +0,0 @@
<?xml version="1.0" encoding="UTF-8"?>
<module type="JAVA_MODULE" version="4" />

23
pom.xml
View File

@ -1,23 +0,0 @@
<?xml version="1.0" encoding="UTF-8"?>
<project xmlns="http://maven.apache.org/POM/4.0.0"
xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
<modelVersion>4.0.0</modelVersion>
<groupId>cz.cvut.fel.sit.omo.foodchain</groupId>
<artifactId>FoodChain</artifactId>
<version>1.0-SNAPSHOT</version>
<dependencies>
<dependency>
<groupId>javax.money</groupId>
<artifactId>money-api</artifactId>
<version>1.0</version>
</dependency>
</dependencies>
<properties>
<maven.compiler.target>12</maven.compiler.target>
<maven.compiler.source>12</maven.compiler.source>
</properties>
</project>

16
src/main/java/cz/cvut/fel/sit/omo/foodchain/FoodChain.java
View File

@ -1,16 +0,0 @@
package cz.cvut.fel.sit.omo.foodchain;
import cz.cvut.fel.sit.omo.foodchain.factory.FactoryManager;
public class FoodChain {
private static FactoryManager factoryManager;
public static void main(String[] args) {
}
public static FactoryManager getFactoryManager() {
return factoryManager;
}
}

89
src/main/java/cz/cvut/fel/sit/omo/foodchain/channel/ChannelBase.java
View File

@ -1,89 +0,0 @@
package cz.cvut.fel.sit.omo.foodchain.channel;
import cz.cvut.fel.sit.omo.foodchain.operation.Transaction;
import cz.cvut.fel.sit.omo.foodchain.product.ProductType;
import cz.cvut.fel.sit.omo.foodchain.requirement.Requirement;
import cz.cvut.fel.sit.omo.foodchain.util.ChannelObserver;
import cz.cvut.fel.sit.omo.foodchain.util.Observable;
import java.util.PriorityQueue;
import java.util.Queue;
import java.util.Set;
public abstract class ChannelBase implements Observable {
protected ProductType productType;
protected Queue<Requirement> requirements;
protected Queue<Transaction> transactions;
private Set<ChannelObserver> subscribers;
public ChannelBase(ProductType type)
{
this.requirements = new PriorityQueue<>();
this.transactions = new PriorityQueue<>();
this.productType = type;
}
public ChannelBase()
{
this.requirements = new PriorityQueue<>();
this.transactions = new PriorityQueue<>();
this.productType = ProductType.OTHER;
}
public Queue<Transaction> getTransactions()
{
return this.transactions;
}
public Queue<Requirement> getCurrentRequirements()
{
return this.requirements;
}
/**
* Adds new requirement to the requirement Queue
* @param requirement requirement
*/
public void addRequirement(Requirement requirement)
{
this.requirements.add(requirement);
notifyAllObservers();
}
@Override
public void notifyAllObservers(){
subscribers.forEach(subscriber -> subscriber.update(requirements.peek()));
}
@Override
public void attach(ChannelObserver observer){
subscribers.add(observer);
}
@Override
public void detach(ChannelObserver observer){
subscribers.remove(observer);
}
/**
* Adds new transaction to the transaction Queue
* @param transaction transaction
*/
public void addTransaction(Transaction transaction)
{
this.transactions.add(transaction);
}
/**
* Clears all requirements from this channel
*/
public void clearRequirements()
{
this.requirements.clear();
}
public ProductType getProductType() {
return productType;
}
}

11
src/main/java/cz/cvut/fel/sit/omo/foodchain/channel/FruitChannel.java
View File

@ -1,11 +0,0 @@
package cz.cvut.fel.sit.omo.foodchain.channel;
import cz.cvut.fel.sit.omo.foodchain.product.ProductType;
public class FruitChannel extends ChannelBase
{
public FruitChannel()
{
super(ProductType.FRUIT);
}
}

11
src/main/java/cz/cvut/fel/sit/omo/foodchain/channel/MeatChannel.java
View File

@ -1,11 +0,0 @@
package cz.cvut.fel.sit.omo.foodchain.channel;
import cz.cvut.fel.sit.omo.foodchain.product.ProductType;
public class MeatChannel extends ChannelBase
{
public MeatChannel()
{
super(ProductType.MEAT);
}
}

11
src/main/java/cz/cvut/fel/sit/omo/foodchain/channel/OtherChannel.java
View File

@ -1,11 +0,0 @@
package cz.cvut.fel.sit.omo.foodchain.channel;
import cz.cvut.fel.sit.omo.foodchain.product.ProductType;
public class OtherChannel extends ChannelBase
{
public OtherChannel()
{
super();
}
}

11
src/main/java/cz/cvut/fel/sit/omo/foodchain/channel/VegetableChannel.java
View File

@ -1,11 +0,0 @@
package cz.cvut.fel.sit.omo.foodchain.channel;
import cz.cvut.fel.sit.omo.foodchain.product.ProductType;
public class VegetableChannel extends ChannelBase
{
public VegetableChannel()
{
super(ProductType.VEGETABLE);
}
}

4
src/main/java/cz/cvut/fel/sit/omo/foodchain/factory/ChannelFactory.java
View File

@ -1,4 +0,0 @@
package cz.cvut.fel.sit.omo.foodchain.factory;
public class ChannelFactory {
}

55
src/main/java/cz/cvut/fel/sit/omo/foodchain/factory/FactoryManager.java
View File

@ -1,55 +0,0 @@
package cz.cvut.fel.sit.omo.foodchain.factory;
import cz.cvut.fel.sit.omo.foodchain.pool.PoolDatabase;
import cz.cvut.fel.sit.omo.foodchain.util.Singleton;
import java.lang.reflect.InvocationTargetException;
public class FactoryManager {
public NodeFactory getNodeFactoryInstance() {
try {
return Singleton.getInstance(NodeFactory.class);
} catch (IllegalAccessException | InstantiationException | NoSuchMethodException | InvocationTargetException e) {
e.printStackTrace();
}
return null;
}
public ChannelFactory getChannelFactoryInstance() {
try {
return Singleton.getInstance(ChannelFactory.class);
} catch (IllegalAccessException | InstantiationException | NoSuchMethodException | InvocationTargetException e) {
e.printStackTrace();
}
return null;
}
public ScenarioFactory getScenarioFactoryInstance() {
try {
return Singleton.getInstance(ScenarioFactory.class);
} catch (IllegalAccessException | InstantiationException | NoSuchMethodException | InvocationTargetException e) {
e.printStackTrace();
}
return null;
}
public ProductFactory getProductFactoryInstance() {
try {
return Singleton.getInstance(ProductFactory.class);
} catch (IllegalAccessException | InstantiationException | NoSuchMethodException | InvocationTargetException e) {
e.printStackTrace();
}
return null;
}
public PoolDatabase getPoolDatabaseInstance() {
try {
return Singleton.getInstance(PoolDatabase.class);
} catch (IllegalAccessException | InstantiationException | NoSuchMethodException | InvocationTargetException e) {
e.printStackTrace();
}
return null;
}
}

4
src/main/java/cz/cvut/fel/sit/omo/foodchain/factory/NodeFactory.java
View File

@ -1,4 +0,0 @@
package cz.cvut.fel.sit.omo.foodchain.factory;
public class NodeFactory {
}

4
src/main/java/cz/cvut/fel/sit/omo/foodchain/factory/ProductFactory.java
View File

@ -1,4 +0,0 @@
package cz.cvut.fel.sit.omo.foodchain.factory;
public class ProductFactory {
}

4
src/main/java/cz/cvut/fel/sit/omo/foodchain/factory/ScenarioFactory.java
View File

@ -1,4 +0,0 @@
package cz.cvut.fel.sit.omo.foodchain.factory;
public class ScenarioFactory {
}

15
src/main/java/cz/cvut/fel/sit/omo/foodchain/node/BuyerNodeBase.java
View File

@ -1,15 +0,0 @@
package cz.cvut.fel.sit.omo.foodchain.node;
import cz.cvut.fel.sit.omo.foodchain.product.Product;
public class BuyerNodeBase extends NodeBase implements IBuyerNode {
@Override
public void sellProduct(Product product) {
}
@Override
public void addMargin(Product product) {
}
}

4
src/main/java/cz/cvut/fel/sit/omo/foodchain/node/Customer.java
View File

@ -1,4 +0,0 @@
package cz.cvut.fel.sit.omo.foodchain.node;
public class Customer extends BuyerNodeBase {
}

4
src/main/java/cz/cvut/fel/sit/omo/foodchain/node/Distributor.java
View File

@ -1,4 +0,0 @@
package cz.cvut.fel.sit.omo.foodchain.node;
public class Distributor extends RetailerNodeBase {
}

4
src/main/java/cz/cvut/fel/sit/omo/foodchain/node/Farmer.java
View File

@ -1,4 +0,0 @@
package cz.cvut.fel.sit.omo.foodchain.node;
public class Farmer extends SellerNodeBase {
}

10
src/main/java/cz/cvut/fel/sit/omo/foodchain/node/IBuyerNode.java
View File

@ -1,10 +0,0 @@
package cz.cvut.fel.sit.omo.foodchain.node;
import cz.cvut.fel.sit.omo.foodchain.product.Product;
public interface IBuyerNode {
void sellProduct(Product product);
void addMargin(Product product);
}

8
src/main/java/cz/cvut/fel/sit/omo/foodchain/node/ISellerNode.java
View File

@ -1,8 +0,0 @@
package cz.cvut.fel.sit.omo.foodchain.node;
import cz.cvut.fel.sit.omo.foodchain.product.Product;
public interface ISellerNode {
void buyProduct(Product product);
}

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

@ -1,118 +0,0 @@
package cz.cvut.fel.sit.omo.foodchain.node;
import cz.cvut.fel.sit.omo.foodchain.channel.ChannelBase;
import cz.cvut.fel.sit.omo.foodchain.operation.*;
import cz.cvut.fel.sit.omo.foodchain.product.Product;
import cz.cvut.fel.sit.omo.foodchain.product.ProductType;
import cz.cvut.fel.sit.omo.foodchain.requirement.Requirement;
import cz.cvut.fel.sit.omo.foodchain.signature.Signature;
import javax.money.MonetaryAmount;
import java.util.LinkedList;
import java.util.List;
public class NodeBase {
private final List<ChannelBase> subscribedChannels;
private final List<Product> products;
public NodeBase(){
subscribedChannels = new LinkedList<>();
products = new LinkedList<>();
}
public void sendTransaction(Product product, NodeBase node) {
Transaction transaction = new ProductTransaction(this, node, TransactionType.SALE, product); //TODO wrong constructor
subscribedChannels.stream()
.filter(ch -> ch.getProductType().equals(product.getProductType()))
.findAny().ifPresent(channel -> channel.addTransaction(transaction));
}
public void sendTransaction(MonetaryAmount amount, NodeBase node) {
}
public void receiveTransaction(ProductTransaction transaction) {
}
public void receiveTransaction(FinancialTransaction transaction) {
}
public void refuseTransaction(ProductTransaction transaction) {
}
public void refuseTransaction(FinancialTransaction transaction) {
}
//TODO another way to read transaction
public Transaction readNextTransaction(ChannelBase channel) {
return channel.getNextTransaction();
}
public Requirement readNextRequirement(ChannelBase channel) {
return channel.getNextRequirement();
}
public void acceptRequirement(Requirement requirement) {
}
public void subscribeToChannel(ChannelBase channel) {
subscribedChannels.add(channel);
}
public void unsubscribeFromChannel(ChannelBase channel) {
subscribedChannels.remove(channel);
}
public void doAction(ProductOperationType action, Product product) {
//create new action
}
public void doAction(ProductOperationType action) {
//create new action
}
public void storeProduct(Product product) {
}
public void storeProducts(List<Product> products) {
}
public Product getProductFromStorage(String name, ProductType type) {
return null;
}
public Signature generateSignature(Transaction transaction) {
return null;
}
public boolean validateSignature(Signature signature) {
return false;
}
}

4
src/main/java/cz/cvut/fel/sit/omo/foodchain/node/Processor.java
View File

@ -1,4 +0,0 @@
package cz.cvut.fel.sit.omo.foodchain.node;
public class Processor extends RetailerNodeBase {
}

20
src/main/java/cz/cvut/fel/sit/omo/foodchain/node/RetailerNodeBase.java
View File

@ -1,20 +0,0 @@
package cz.cvut.fel.sit.omo.foodchain.node;
import cz.cvut.fel.sit.omo.foodchain.product.Product;
public class RetailerNodeBase extends NodeBase implements IBuyerNode, ISellerNode {
@Override
public void sellProduct(Product product) {
}
@Override
public void addMargin(Product product) {
}
@Override
public void buyProduct(Product product) {
}
}

4
src/main/java/cz/cvut/fel/sit/omo/foodchain/node/Seller.java
View File

@ -1,4 +0,0 @@
package cz.cvut.fel.sit.omo.foodchain.node;
public class Seller extends RetailerNodeBase {
}

10
src/main/java/cz/cvut/fel/sit/omo/foodchain/node/SellerNodeBase.java
View File

@ -1,10 +0,0 @@
package cz.cvut.fel.sit.omo.foodchain.node;
import cz.cvut.fel.sit.omo.foodchain.product.Product;
public class SellerNodeBase extends NodeBase implements ISellerNode {
@Override
public void buyProduct(Product product) {
}
}

44
src/main/java/cz/cvut/fel/sit/omo/foodchain/operation/Action.java
View File

@ -1,44 +0,0 @@
package cz.cvut.fel.sit.omo.foodchain.operation;
import cz.cvut.fel.sit.omo.foodchain.node.NodeBase;
import cz.cvut.fel.sit.omo.foodchain.product.Product;
public class Action extends OperationBase {
private final OperationBase lastOperation;
private final Product product;
private final ProductOperationType type;
private int duration;
Action(NodeBase node, Product product, ProductOperationType type) {
super(node);
this.product = product;
this.type = type;
lastOperation = product.getCurrentOperation();
duration = type.getDuration();
product.setCurrentOperation(this);
product.setStateToReadyForDispatch();
}
private void endAction() {
this.setTimeEnd();
product.setStateToAvailable();
}
public void tick() {
if (duration == 0) endAction();
else duration--;
}
public OperationBase getLastOperation() {
return lastOperation;
}
public Product getProduct() {
return product;
}
public ProductOperationType getType() {
return type;
}
}

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

@ -1,25 +0,0 @@
package cz.cvut.fel.sit.omo.foodchain.operation;
import cz.cvut.fel.sit.omo.foodchain.node.NodeBase;
import javax.money.MonetaryAmount;
public class FinancialTransaction extends Transaction {
private final MonetaryAmount amount;
private final ProductTransaction transactionPaid;
FinancialTransaction(NodeBase creator, NodeBase receiver, TransactionType type, MonetaryAmount amount, ProductTransaction transactionPaid) {
super(creator, receiver, type);
this.amount = amount;
this.transactionPaid = transactionPaid;
}
public MonetaryAmount getAmount() {
return amount;
}
public ProductTransaction getTransactionPaid() {
return transactionPaid;
}
}

34
src/main/java/cz/cvut/fel/sit/omo/foodchain/operation/OperationBase.java
View File

@ -1,34 +0,0 @@
package cz.cvut.fel.sit.omo.foodchain.operation;
import cz.cvut.fel.sit.omo.foodchain.node.NodeBase;
import java.time.LocalDateTime;
public class OperationBase {
private final LocalDateTime timeStart;
private LocalDateTime timeEnd;
private final NodeBase nodeCreator;
OperationBase(NodeBase node) {
nodeCreator = node;
timeStart = LocalDateTime.now();
}
public LocalDateTime getTimeStart() {
return timeStart;
}
public LocalDateTime getTimeEnd() {
return timeEnd;
}
public void setTimeEnd() {
this.timeEnd = LocalDateTime.now();
}
public NodeBase getNodeCreator() {
return nodeCreator;
}
}

22
src/main/java/cz/cvut/fel/sit/omo/foodchain/operation/ProductOperationType.java
View File

@ -1,22 +0,0 @@
package cz.cvut.fel.sit.omo.foodchain.operation;
public enum ProductOperationType {
STORE_MEAT(10, -8);
private final int duration;
private final int temperature;
ProductOperationType(int duration, int temperature) {
this.duration = duration;
this.temperature = temperature;
}
public int getDuration() {
return duration;
}
public int getTemperature() {
return temperature;
}
}

38
src/main/java/cz/cvut/fel/sit/omo/foodchain/operation/ProductTransaction.java
View File

@ -1,38 +0,0 @@
package cz.cvut.fel.sit.omo.foodchain.operation;
import cz.cvut.fel.sit.omo.foodchain.node.NodeBase;
import cz.cvut.fel.sit.omo.foodchain.product.Product;
public class ProductTransaction extends Transaction {
private final OperationBase lastOperation;
private final Product product;
private final ProductOperationType type;
public ProductTransaction(NodeBase creator, NodeBase receiver, TransactionType transactionType, Product product) {
super(creator, receiver, transactionType);
this.product = product;
type = null;
lastOperation = product.getCurrentOperation();
product.setCurrentOperation(this);
product.setStateToReadyForDispatch();
}
@Override
public void endTransaction() {
super.endTransaction();
product.setStateToAvailable();
}
public OperationBase getLastOperation() {
return lastOperation;
}
public Product getProduct() {
return product;
}
public ProductOperationType getType() {
return type;
}
}

35
src/main/java/cz/cvut/fel/sit/omo/foodchain/operation/Transaction.java
View File

@ -1,35 +0,0 @@
package cz.cvut.fel.sit.omo.foodchain.operation;
import cz.cvut.fel.sit.omo.foodchain.node.NodeBase;
import cz.cvut.fel.sit.omo.foodchain.signature.Signature;
import cz.cvut.fel.sit.omo.foodchain.signature.SignatureManager;
public abstract class Transaction extends OperationBase {
private final TransactionType transactionType;
private final Signature signature;
private final NodeBase nodeReceiver;
Transaction(NodeBase creator, NodeBase receiver, TransactionType type) {
super(creator);
transactionType = type;
nodeReceiver = receiver;
signature = SignatureManager.signTransaction(this);
}
public void endTransaction() {
this.setTimeEnd();
}
public TransactionType getTransactionType() {
return transactionType;
}
public Signature getSignature() {
return signature;
}
public NodeBase getNodeReceiver() {
return nodeReceiver;
}
}

6
src/main/java/cz/cvut/fel/sit/omo/foodchain/operation/TransactionType.java
View File

@ -1,6 +0,0 @@
package cz.cvut.fel.sit.omo.foodchain.operation;
public enum TransactionType {
SALE, PURCHASE
}

4
src/main/java/cz/cvut/fel/sit/omo/foodchain/parser/ConfigurationParser.java
View File

@ -1,4 +0,0 @@
package cz.cvut.fel.sit.omo.foodchain.parser;
public class ConfigurationParser {
}

4
src/main/java/cz/cvut/fel/sit/omo/foodchain/parser/ConsoleParser.java
View File

@ -1,4 +0,0 @@
package cz.cvut.fel.sit.omo.foodchain.parser;
public class ConsoleParser {
}

6
src/main/java/cz/cvut/fel/sit/omo/foodchain/pool/ChannelPool.java
View File

@ -1,6 +0,0 @@
package cz.cvut.fel.sit.omo.foodchain.pool;
import cz.cvut.fel.sit.omo.foodchain.channel.ChannelBase;
public class ChannelPool extends PoolListBase<ChannelBase> {
}

15
src/main/java/cz/cvut/fel/sit/omo/foodchain/pool/IPool.java
View File

@ -1,15 +0,0 @@
package cz.cvut.fel.sit.omo.foodchain.pool;
import java.util.Collection;
public interface IPool<T> {
Collection<T> findAll();
void add(T element);
void remove(T element);
void clear();
boolean contains(T element);
}

6
src/main/java/cz/cvut/fel/sit/omo/foodchain/pool/NodePool.java
View File

@ -1,6 +0,0 @@
package cz.cvut.fel.sit.omo.foodchain.pool;
import cz.cvut.fel.sit.omo.foodchain.node.NodeBase;
public class NodePool extends PoolListBase<NodeBase> {
}

44
src/main/java/cz/cvut/fel/sit/omo/foodchain/pool/PoolDatabase.java
View File

@ -1,44 +0,0 @@
package cz.cvut.fel.sit.omo.foodchain.pool;
import cz.cvut.fel.sit.omo.foodchain.util.Singleton;
import java.lang.reflect.InvocationTargetException;
public class PoolDatabase {
public ChannelPool getChannelPoolInstance() {
try {
return Singleton.getInstance(ChannelPool.class);
} catch (IllegalAccessException | InstantiationException | NoSuchMethodException | InvocationTargetException e) {
e.printStackTrace();
}
return null;
}
public NodePool getNodePoolInstance() {
try {
return Singleton.getInstance(NodePool.class);
} catch (IllegalAccessException | InstantiationException | NoSuchMethodException | InvocationTargetException e) {
e.printStackTrace();
}
return null;
}
public ProductPool getProductPoolInstance() {
try {
return Singleton.getInstance(ProductPool.class);
} catch (IllegalAccessException | InstantiationException | NoSuchMethodException | InvocationTargetException e) {
e.printStackTrace();
}
return null;
}
public ScenarioPool getScenarioPoolInstance() {
try {
return Singleton.getInstance(ScenarioPool.class);
} catch (IllegalAccessException | InstantiationException | NoSuchMethodException | InvocationTargetException e) {
e.printStackTrace();
}
return null;
}
}

33
src/main/java/cz/cvut/fel/sit/omo/foodchain/pool/PoolListBase.java
View File

@ -1,33 +0,0 @@
package cz.cvut.fel.sit.omo.foodchain.pool;
import java.util.Collection;
import java.util.LinkedList;
import java.util.List;
public abstract class PoolListBase<T> implements IPool<T> {
List<T> pool;
public PoolListBase() {
pool = new LinkedList<T>();
}
public Collection<T> findAll() {
return pool;
}
public void add(T element) {
pool.add(element);
}
public void remove(T element) {
pool.remove(element);
}
public void clear() {
pool.clear();
}
public boolean contains(T element) {
return pool.contains(element);
}
}

6
src/main/java/cz/cvut/fel/sit/omo/foodchain/pool/ProductPool.java
View File

@ -1,6 +0,0 @@
package cz.cvut.fel.sit.omo.foodchain.pool;
import cz.cvut.fel.sit.omo.foodchain.product.Product;
public class ProductPool extends PoolListBase<Product> {
}

6
src/main/java/cz/cvut/fel/sit/omo/foodchain/pool/ScenarioPool.java
View File

@ -1,6 +0,0 @@
package cz.cvut.fel.sit.omo.foodchain.pool;
import cz.cvut.fel.sit.omo.foodchain.scenario.Scenario;
public class ScenarioPool extends PoolListBase<Scenario> {
}

124
src/main/java/cz/cvut/fel/sit/omo/foodchain/product/Product.java
View File

@ -1,124 +0,0 @@
package cz.cvut.fel.sit.omo.foodchain.product;
import cz.cvut.fel.sit.omo.foodchain.operation.OperationBase;
public class Product
{
private ProductState productState;
private ProductType productType;
private OperationBase currentOperation;
private String name;
/**
* Creates Product with default state AVAILABLE
* @param name name of product
* @param productType type of product
*/
public Product(String name, ProductType productType)
{
this.name = name;
this.productType = productType;
this.productState = ProductState.AVAILABLE;
}
/**
* Creates Product
* @param name name of product
* @param productType type of product
* @param productState state of product
*/
public Product(String name, ProductType productType, ProductState productState)
{
this.name = name;
this.productType = productType;
this.productState = productState;
}
// "State machine methods"
/**
* Set current product state to AVAILABLE
*/
public void setStateToAvailable()
{
this.productState = ProductState.AVAILABLE;
}
/**
* Set current product state to READY_FOR_DISPATCH. Throws IllegalStateException if the product is not AVAILABLE.
*/
public void setStateToReadyForDispatch()
{
if(this.productState.equals(ProductState.AVAILABLE))
this.productState = ProductState.READY_FOR_DISPATCH;
else
throw new IllegalStateException("Cannot set state READY_FOR_DISPATCH. Product is not AVAILABLE!");
}
/**
* Set current product state to IN_TRANSIT. Throws IllegalStateException if the product is not READY_FOR_DISPATCH.
*/
public void setStateToInTransit()
{
if(this.productState.equals(ProductState.READY_FOR_DISPATCH))
this.productState = ProductState.IN_TRANSIT;
else
throw new IllegalStateException("Cannot set state IN_TRANSIT. Product is not READY_FOR_DISPATCH!");
}
/**
* Set current product state to READY_FOR_RECEPTION. Throws IllegalStateException if the product is not READY_FOR_RECEPTION.
*/
public void setStateToReadyForReception()
{
if(this.productState.equals(ProductState.IN_TRANSIT))
this.productState = ProductState.READY_FOR_RECEPTION;
else
throw new IllegalStateException("Cannot set state READY_FOR_RECEPTION. Product has not been in transit!");
}
/*
public void setProductState(ProductState productState)
{
this.productState = productState;
}*/
//Getters & Setters
public ProductState getProductState()
{
return productState;
}
public ProductType getProductType()
{
return productType;
}
public void setProductType(ProductType productType)
{
this.productType = productType;
}
public String getName()
{
return name;
}
public void setName(String name)
{
this.name = name;
}
public OperationBase getCurrentOperation()
{
return currentOperation;
}
public void setCurrentOperation(OperationBase currentOperation)
{
this.currentOperation = currentOperation;
}
}

6
src/main/java/cz/cvut/fel/sit/omo/foodchain/product/ProductState.java
View File

@ -1,6 +0,0 @@
package cz.cvut.fel.sit.omo.foodchain.product;
public enum ProductState
{
AVAILABLE, READY_FOR_DISPATCH, IN_TRANSIT, READY_FOR_RECEPTION;
}

6
src/main/java/cz/cvut/fel/sit/omo/foodchain/product/ProductType.java
View File

@ -1,6 +0,0 @@
package cz.cvut.fel.sit.omo.foodchain.product;
public enum ProductType
{
MEAT, FRUIT, VEGETABLE, OTHER;
}

19
src/main/java/cz/cvut/fel/sit/omo/foodchain/reporting/ReportTextFileVisitor.java
View File

@ -1,19 +0,0 @@
package cz.cvut.fel.sit.omo.foodchain.reporting;
import cz.cvut.fel.sit.omo.foodchain.channel.ChannelBase;
import cz.cvut.fel.sit.omo.foodchain.node.NodeBase;
import cz.cvut.fel.sit.omo.foodchain.operation.OperationBase;
public class ReportTextFileVisitor {
public void visit(NodeBase node){
}
public void visit(OperationBase operationBase){
}
public void visit(ChannelBase channel){
}
}

4
src/main/java/cz/cvut/fel/sit/omo/foodchain/reporting/ReportingManager.java
View File

@ -1,4 +0,0 @@
package cz.cvut.fel.sit.omo.foodchain.reporting;
public class ReportingManager {
}

40
src/main/java/cz/cvut/fel/sit/omo/foodchain/requirement/Requirement.java
View File

@ -1,40 +0,0 @@
package cz.cvut.fel.sit.omo.foodchain.requirement;
import cz.cvut.fel.sit.omo.foodchain.node.NodeBase;
import cz.cvut.fel.sit.omo.foodchain.operation.TransactionType;
import cz.cvut.fel.sit.omo.foodchain.product.ProductType;
public class Requirement {
private final NodeBase creator;
private final TransactionType transactionType;
private final ProductType productType;
private int TTL;
public Requirement(NodeBase creator, TransactionType transactionType, ProductType productType) {
this.creator = creator;
this.transactionType = transactionType;
this.productType = productType;
TTL = 2;
}
public void tick() {
TTL--;
}
public NodeBase getCreator() {
return creator;
}
public TransactionType getTransactionType() {
return transactionType;
}
public ProductType getProductType() {
return productType;
}
public int getTTL() {
return TTL;
}
}

4
src/main/java/cz/cvut/fel/sit/omo/foodchain/scenario/Scenario.java
View File

@ -1,4 +0,0 @@
package cz.cvut.fel.sit.omo.foodchain.scenario;
public class Scenario {
}

39
src/main/java/cz/cvut/fel/sit/omo/foodchain/signature/Signature.java
View File

@ -1,39 +0,0 @@
package cz.cvut.fel.sit.omo.foodchain.signature;
import cz.cvut.fel.sit.omo.foodchain.operation.Transaction;
import java.time.LocalDateTime;
import java.util.UUID;
public class Signature {
private final String managerCode;
private final Transaction transaction;
private final LocalDateTime signedDate;
private final UUID uuid;
public Signature(String code, Transaction transaction) {
managerCode = code;
this.transaction = transaction;
signedDate = LocalDateTime.now();
uuid = UUID.randomUUID();
}
public Transaction getTransaction(String code) {
if (code.equals(managerCode))
return transaction;
return null;
}
public LocalDateTime getSignedDate(String code) {
if (code.equals(managerCode))
return signedDate;
return null;
}
public UUID getUuid(String code) {
if (code.equals(managerCode))
return uuid;
return null;
}
}

17
src/main/java/cz/cvut/fel/sit/omo/foodchain/signature/SignatureManager.java
View File

@ -1,17 +0,0 @@
package cz.cvut.fel.sit.omo.foodchain.signature;
import cz.cvut.fel.sit.omo.foodchain.operation.Transaction;
public class SignatureManager {
private static final String MANAGER_CODE = "iW91AJWNOCmX1pbpLlW0";
public static Signature signTransaction(Transaction transaction) {
return new Signature(MANAGER_CODE, transaction);
}
public static boolean validateSignature(Transaction transaction) {
return transaction.equals(transaction.getSignature().getTransaction(MANAGER_CODE))
&& transaction.getSignature().getUuid(MANAGER_CODE).equals(transaction.getSignature().getTransaction(MANAGER_CODE).getSignature().getUuid(MANAGER_CODE));
}
}

7
src/main/java/cz/cvut/fel/sit/omo/foodchain/util/ChannelObserver.java
View File

@ -1,7 +0,0 @@
package cz.cvut.fel.sit.omo.foodchain.util;
import cz.cvut.fel.sit.omo.foodchain.requirement.Requirement;
public interface ChannelObserver {
void update(Requirement requirement);
}

7
src/main/java/cz/cvut/fel/sit/omo/foodchain/util/Observable.java
View File

@ -1,7 +0,0 @@
package cz.cvut.fel.sit.omo.foodchain.util;
public interface Observable {
void attach(ChannelObserver channelObserver);
void detach(ChannelObserver channelObserver);
void notifyAllObservers();
}

27
src/main/java/cz/cvut/fel/sit/omo/foodchain/util/Singleton.java
View File

@ -1,27 +0,0 @@
package cz.cvut.fel.sit.omo.foodchain.util;
import java.lang.reflect.Constructor;
import java.lang.reflect.InvocationTargetException;
import java.util.HashMap;
import java.util.Map;
public class Singleton {
private static final Singleton instance = new Singleton();
@SuppressWarnings("rawtypes")
private final Map<Class, Object> mapHolder = new HashMap<>();
private Singleton() {
}
public static <T> T getInstance(Class<T> tClass) throws NoSuchMethodException, InvocationTargetException, IllegalAccessException, InstantiationException {
if (!instance.mapHolder.containsKey(tClass)) {
Constructor<T> cons = tClass.getConstructor();
Object object = cons.newInstance();
instance.mapHolder.put(tClass, object);
}
return (T) instance.mapHolder.get(tClass);
}
}

26
src/main/java/cz/cvut/fel/sit/omo/foodchain/util/Ticker.java
View File

@ -1,26 +0,0 @@
package cz.cvut.fel.sit.omo.foodchain.util;
import cz.cvut.fel.sit.omo.foodchain.FoodChain;
import cz.cvut.fel.sit.omo.foodchain.pool.PoolDatabase;
import javax.swing.*;
public class Ticker {
private static Timer timer;
public static void start() {
timer = new Timer(500, actionEvent -> {
PoolDatabase db = FoodChain.getFactoryManager().getPoolDatabaseInstance();
db.getChannelPoolInstance().findAll().forEach(ch -> ch.tick()); // change TTL of requirements
db.getNodePoolInstance().findAll().forEach(ch -> ch.tick()); // do next step in scenario
db.getProductPoolInstance().findAll().forEach(ch -> ch.tick()); // change duration of action
db.getScenarioPoolInstance().findAll().forEach(ch -> ch.tick()); // maybe unnecessary
});
timer.start();
}
public static void stop() {
timer.stop();
}
}