From 670016e79c91e5346c98abae92fede2b4bbf3ad5 Mon Sep 17 00:00:00 2001
From: zab2 <zab2@mail.i2p>
Date: Wed, 27 Mar 2019 12:45:26 +0000
Subject: [PATCH] wip on parser of filter definitions
---
.../i2ptunnel/access/DefinitionParser.java | 121 ++++++++++++++++++
1 file changed, 121 insertions(+)
create mode 100644 apps/i2ptunnel/java/src/net/i2p/i2ptunnel/access/DefinitionParser.java
diff --git a/apps/i2ptunnel/java/src/net/i2p/i2ptunnel/access/DefinitionParser.java b/apps/i2ptunnel/java/src/net/i2p/i2ptunnel/access/DefinitionParser.java
new file mode 100644
index 0000000000..313d3e75de
--- /dev/null
+++ b/apps/i2ptunnel/java/src/net/i2p/i2ptunnel/access/DefinitionParser.java
@@ -0,0 +1,121 @@
+package net.i2p.i2ptunnel.access;
+
+import java.io.File;
+import java.io.FileReader;
+import java.io.BufferedReader;
+import java.io.IOException;
+
+import java.util.List;
+import java.util.ArrayList;
+
+class DefinitionParser {
+
+ static FilterDefinition parse(File f) throws IOException, InvalidDefinitionException {
+
+ DefinitionBuilder builder = new DefinitionBuilder();
+
+ BufferedReader reader = new BufferedReader(new FileReader(f));
+ try {
+ String line;
+ while((line = reader.readLine()) != null) {
+ line = line.trim();
+ if (line.isEmpty())
+ continue;
+ if (line.startsWith("#"))
+ continue;
+
+ String [] split = line.split(" \t");
+ split[0] = split[0].toLowerCase();
+ if ("default".equals(split[0]))
+ builder.setDefaultThreshold(parseThreshold(line.substring(7).trim()));
+ else if ("recorder".equals(split[0]))
+ builder.addRecorder(parseRecorder(line.substring(8).trim()));
+ else
+ builder.addElement(parseElement(line));
+ }
+ } finally {
+ if (reader != null) try { reader.close(); } catch (IOException ignored) {}
+ }
+
+ return builder.build();
+ }
+
+ private static Threshold parseThreshold(String s) throws InvalidDefinitionException {
+ if ("allow".equalsIgnoreCase(s))
+ return Threshold.ALLOW;
+ if ("deny".equalsIgnoreCase(s))
+ return Threshold.DENY;
+
+ String [] split = s.split("/");
+ if (split.length != 2)
+ throw new InvalidDefinitionException("Invalid threshold " + s);
+
+ try {
+ int connections = Integer.parseInt(split[0]);
+ int minutes = Integer.parseInt(split[1]);
+ if (connections < 0)
+ throw new InvalidDefinitionException("Number of connections cannot be negative " + s);
+ if (minutes < 1)
+ throw new InvalidDefinitionException("Number of minutes must be at least 1 " + s);
+ return new Threshold(connections, minutes);
+ } catch (NumberFormatException bad) {
+ throw new InvalidDefinitionException("Invalid threshold", bad);
+ }
+ }
+
+ private static Recorder parseRecorder(String line) throws InvalidDefinitionException {
+ StringBuilder thresholdBuilder = new StringBuilder();
+ int i = 0;
+ while(i < line.length()) {
+ char c = line.charAt(i);
+ if (c == ' ' || c == '\t')
+ break;
+ i++;
+ thresholdBuilder.append(c);
+ }
+
+ Threshold threshold = parseThreshold(thresholdBuilder.toString());
+
+ line = line.substring(i);
+ File file = new File(line);
+ return new Recorder(file, threshold);
+ }
+
+ private static FilterDefinitionElement parseElement(String line) {
+ // TODO: implement
+ return null;
+ }
+
+ private static class DefinitionBuilder {
+ private Threshold threshold;
+ private List<FilterDefinitionElement> elements = new ArrayList<FilterDefinitionElement>();
+ private List<Recorder> recorders = new ArrayList<Recorder>();
+
+ void setDefaultThreshold(Threshold threshold) throws InvalidDefinitionException {
+ if (this.threshold != null)
+ throw new InvalidDefinitionException("default already set!");
+ this.threshold = threshold;
+ }
+
+ void addElement(FilterDefinitionElement element) {
+ elements.add(element);
+ }
+
+ void addRecorder(Recorder recorder) {
+ recorders.add(recorder);
+ }
+
+ FilterDefinition build() {
+ if (threshold == null)
+ threshold = Threshold.ALLOW;
+
+ FilterDefinitionElement [] elArray = new FilterDefinitionElement[elements.size()];
+ elArray = elements.toArray(elArray);
+
+ Recorder [] rArray = new Recorder[recorders.size()];
+ rArray = recorders.toArray(rArray);
+
+ return new FilterDefinition(threshold, elArray, rArray);
+ }
+ }
+}
--
GitLab