improved xray logs handling

web/html/index.html

@@ -598,40 +598,56 @@
             this.formattedLogs = this.logs?.length > 0 ? this.formatLogs(this.logs) : "No Record...";
         },
         formatLogs(logs) {
-            let formattedLogs = '';
+            let formattedLogs = `
+<style>
+  table {
+    border-collapse: collapse;
+    width: auto;
+  }
 
-          logs.forEach((log, index) => {
+  table td, table th {
-            if(index > 0) formattedLogs += '<br>';
+    padding: 2px 15px;
+  }
+</style>
 
-            const parts = log.split(' ');
+<table>
+    <tr>
+        <th>Date</th>
+        <th>From</th>
+        <th>To</th>
+        <th>Inbound</th>
+        <th>Outbound</th>
+        <th>Email</th>
+    </tr>
+`;
 
-            if(parts.length === 10) {
+            logs.reverse().forEach((log, index) => {
-              const dateTime = `<b>${parts[0]} ${parts[1]}</b>`;
+                let outboundColor = '';
-              const from = `<b>${parts[3]}</b>`;
+                if (log.Event === 1) {
-              const to = `<b>${parts[5].replace(/^\/+/, "")}</b>`;
+                    outboundColor = ' style="color: #e04141;"'; //red for blocked
+                }
+                else if (log.Event === 2) {
+                    outboundColor = ' style="color: #3c89e8;"'; //blue for proxies
+                }
 
-              let outboundColor = '';
+                let text = ``;
-              if (parts[9] === "b") {
+                if (log.Email !== "") {
-                outboundColor = ' style="color: #e04141;"'; //red for blocked
+                    text = `<td>${log.Email}</td>`;
-              }
+                }
-              else if (parts[9] === "p") {
-                outboundColor = ' style="color: #3c89e8;"'; //blue for proxies
-              }
 
-              formattedLogs += `<span${outboundColor}>
+                formattedLogs += `
-${dateTime}
+<tr ${outboundColor}>
- ${parts[2]}
+    <td><b>${new Date(log.DateTime).toLocaleString()}</b></td>
- ${from}
+    <td>${log.FromAddress}</td>
- ${parts[4]}
+    <td>${log.ToAddress}</td>
- ${to}
+    <td>${log.Inbound}</td>
- ${parts.slice(6, 9).join(' ')}
+    <td>${log.Outbound}</td>
-</span>`;
+    ${text}
-            } else {
+</tr>
-              formattedLogs += `<span>${log}</span>`;
+`;
-            }
+            });
-          });
 
-            return formattedLogs;
+            return formattedLogs += "</table>";
         },
         hide() {
             this.visible = false;

web/service/server.go

@@ -100,6 +100,16 @@ type ServerService struct {
 	noIPv6         bool
 }
 
+type LogEntry struct {
+	DateTime    time.Time
+	FromAddress string
+	ToAddress   string
+	Inbound     string
+	Outbound    string
+	Email       string
+	Event       int
+}
+
 func getPublicIP(url string) string {
 	client := &http.Client{
 		Timeout: 3 * time.Second,
@@ -516,19 +526,25 @@ func (s *ServerService) GetXrayLogs(
 	showBlocked string,
 	showProxy string,
 	freedoms []string,
-	blackholes []string) []string {
+	blackholes []string) []LogEntry {
+
+	const (
+		Direct = iota
+		Blocked
+		Proxied
+	)
 
 	countInt, _ := strconv.Atoi(count)
-	var lines []string
+	var entries []LogEntry
 
 	pathToAccessLog, err := xray.GetAccessLogPath()
 	if err != nil {
-		return lines
+		return nil
 	}
 
 	file, err := os.Open(pathToAccessLog)
 	if err != nil {
-		return lines
+		return nil
 	}
 	defer file.Close()
 
@@ -547,37 +563,62 @@ func (s *ServerService) GetXrayLogs(
 			continue
 		}
 
-		//adding suffixes to further distinguish entries by outbound
+		var entry LogEntry
-		if hasSuffix(line, freedoms) {
+		parts := strings.Fields(line)
+
+		for i, part := range parts {
+
+			if i == 0 {
+				dateTime, err := time.Parse("2006/01/02 15:04:05.999999", parts[0]+" "+parts[1])
+				if err != nil {
+					continue
+				}
+				entry.DateTime = dateTime
+			}
+
+			if part == "from" {
+				entry.FromAddress = parts[i+1]
+			} else if part == "accepted" {
+				entry.ToAddress = parts[i+1]
+			} else if strings.HasPrefix(part, "[") {
+				entry.Inbound = part[1:]
+			} else if strings.HasSuffix(part, "]") {
+				entry.Outbound = part[:len(part)-1]
+			} else if part == "email:" {
+				entry.Email = parts[i+1]
+			}
+		}
+
+		if logEntryContains(line, freedoms) {
 			if showDirect == "false" {
 				continue
 			}
-			line = line + " f"
+			entry.Event = Direct
-		} else if hasSuffix(line, blackholes) {
+		} else if logEntryContains(line, blackholes) {
 			if showBlocked == "false" {
 				continue
 			}
-			line = line + " b"
+			entry.Event = Blocked
 		} else {
 			if showProxy == "false" {
 				continue
 			}
-			line = line + " p"
+			entry.Event = Proxied
 		}
 
-		lines = append(lines, line)
+		entries = append(entries, entry)
 	}
 
-	if len(lines) > countInt {
+	if len(entries) > countInt {
-		lines = lines[len(lines)-countInt:]
+		entries = entries[len(entries)-countInt:]
 	}
 
-	return lines
+	return entries
 }
 
-func hasSuffix(line string, suffixes []string) bool {
+func logEntryContains(line string, suffixes []string) bool {
 	for _, sfx := range suffixes {
-		if strings.HasSuffix(line, sfx+"]") {
+		if strings.Contains(line, sfx+"]") {
 			return true
 		}
 	}