diff --git a/src/main/java/de/hsh/inform/orientdb_project/repository/EthernetFrameRepository.java b/src/main/java/de/hsh/inform/orientdb_project/repository/EthernetFrameRepository.java new file mode 100644 index 0000000..83438d0 --- /dev/null +++ b/src/main/java/de/hsh/inform/orientdb_project/repository/EthernetFrameRepository.java @@ -0,0 +1,21 @@ +package de.hsh.inform.orientdb_project.repository; + +import java.util.List; + +import com.tinkerpop.blueprints.impls.orient.OrientGraphNoTx; + +import de.hsh.inform.orientdb_project.model.EthernetFrameModel; + +public class EthernetFrameRepository { + private OrientGraphNoTx ogf; + + public EthernetFrameRepository(OrientGraphNoTx ogf) { + this.ogf = ogf; + } + + public List findAllByRawData(byte[] content) { + // TODO! + return null; + } + +} diff --git a/src/main/java/de/hsh/inform/orientdb_project/repository/HostRepository.java b/src/main/java/de/hsh/inform/orientdb_project/repository/HostRepository.java new file mode 100644 index 0000000..f82822c --- /dev/null +++ b/src/main/java/de/hsh/inform/orientdb_project/repository/HostRepository.java @@ -0,0 +1,34 @@ +package de.hsh.inform.orientdb_project.repository; + +import java.util.List; + +import com.tinkerpop.blueprints.impls.orient.OrientGraphNoTx; + +import de.hsh.inform.orientdb_project.model.HostModel; + +public class HostRepository { + + private OrientGraphNoTx ogf; + + public HostRepository(OrientGraphNoTx ogf) { + this.ogf = ogf; + } + + public List findByConnectionsTo(String ipAddress, int port) { + // TODO! + return null; + } + + public List findAllByConnectionsToOutsideHosts() { + // TODO! + return null; + } + + + public List findByIncomingConnectionOnPort(int port) { + return null; + } + + + +} diff --git a/src/main/java/de/hsh/inform/orientdb_project/repository/TcpConnectionRepository.java b/src/main/java/de/hsh/inform/orientdb_project/repository/TcpConnectionRepository.java index 8a006aa..ff90cdf 100644 --- a/src/main/java/de/hsh/inform/orientdb_project/repository/TcpConnectionRepository.java +++ b/src/main/java/de/hsh/inform/orientdb_project/repository/TcpConnectionRepository.java @@ -1,5 +1,7 @@ package de.hsh.inform.orientdb_project.repository; +import java.util.List; + import com.tinkerpop.blueprints.GraphQuery; import com.tinkerpop.blueprints.Predicate; import com.tinkerpop.blueprints.Vertex; @@ -15,7 +17,7 @@ public class TcpConnectionRepository { this.ogf = ogf; } - public Object findByActiveWhen(long ts) { + public List findByActiveWhen(long ts) { GraphQuery gq = this.ogf.query(); gq = gq.has("@class", "TcpConnection"); @@ -42,6 +44,11 @@ public class TcpConnectionRepository { } System.out.println("----"); return null; - } + } + + public List getTotalDataVolumeBetweenHosts(String ipA, String ipB) { + // TODO! + return null; + } }