error -> warn for broken connection

add upgrader option
upgrade workflow to match go.mod
2026-03-20 14:52:27 -07:00 · 2025-06-29 00:43:55 -07:00 · 2025-06-29 00:10:09 -07:00 · 2025-05-01 18:30:13 -07:00 · 2025-05-01 18:27:46 -07:00 · 2023-08-26 22:00:42 -07:00
13 changed files with 625 additions and 277 deletions
--- a/.github/workflows/ci.yaml
+++ b/.github/workflows/ci.yaml
@@ -0,0 +1,23 @@
+name: Go package
+
+on: [push]
+
+jobs:
+  test:
+    runs-on: ubuntu-latest
+    steps:
+      - uses: actions/checkout@v3
+
+      - name: Set up Go
+        uses: actions/setup-go@v4
+        with:
+          go-version: "1.21"
+
+      - name: Install dependencies
+        run: go get .
+
+      - name: Build
+        run: go build -v ./...
+
+      - name: Test
+        run: go test -v ./...
--- a/2
+++ b/2
@@ -1,4 +1,4 @@
-Copyright (C) 2019-2021 by Tai Groot <tai@taigrr.com>
+Copyright (C) 2019-2025 by Tai Groot <tai@taigrr.com>

 Permission to use, copy, modify, and/or distribute this software for any
 purpose with or without fee is hereby granted.
--- a/README.md
+++ b/README.md
@@ -0,0 +1,69 @@
+# Log Socket
+
+A real-time log viewer with WebSocket support, written in Go. This tool provides a web-based interface for viewing and filtering logs in real-time.
+
+## Features
+
+- Real-time log streaming via WebSocket
+- Web-based log viewer with filtering capabilities
+- Support for multiple log levels (TRACE, DEBUG, INFO, WARN, ERROR, PANIC, FATAL)
+- Color-coded log levels for better visibility
+- Auto-scrolling with toggle option
+- Log download functionality
+- Log clearing capability
+- File source tracking for each log entry
+
+## Installation
+
+```bash
+go install github.com/taigrr/log-socket@latest
+```
+
+## Example Preview
+
+1. Start the server:
+
+   ```bash
+   log-socket
+   ```
+
+   By default, the server runs on `0.0.0.0:8080`. You can specify a different address using the `-addr` flag:
+
+   ```bash
+   log-socket -addr localhost:8080
+   ```
+
+2. Open your browser and navigate to `http://localhost:8080`
+
+   ![Log Socket Web Interface](browser/screenshot.png)
+
+## Logging Interface
+
+The package provides a comprehensive logging interface with the following methods:
+
+- `Trace/Tracef/Traceln`: For trace-level logging
+- `Debug/Debugf/Debugln`: For debug-level logging
+- `Info/Infof/Infoln`: For info-level logging
+- `Notice/Noticef/Noticeln`: For notice-level logging
+- `Warn/Warnf/Warnln`: For warning-level logging
+- `Error/Errorf/Errorln`: For error-level logging
+- `Panic/Panicf/Panicln`: For panic-level logging
+- `Fatal/Fatalf/Fatalln`: For fatal-level logging
+
+## Web Interface Features
+
+- **Filtering**: Type in the search box to filter logs
+- **Auto-scroll**: Toggle auto-scrolling with the checkbox
+- **Download**: Save all logs as a JSON file
+- **Clear**: Remove all logs from the viewer
+- **Color Coding**: Different log levels are color-coded for easy identification
+
+## Dependencies
+
+- [gorilla/websocket](https://github.com/gorilla/websocket) for WebSocket support
+
+## Notes
+
+The web interface is not meant to be used as-is.
+It functions perfectly well for some scenarios, but it is broken out into a different package intentionally, such that users can add their own as they see fit.
+It's mostly here to provide an example of how to consume the websocket data and display it.
--- a/browser/browser.go
+++ b/browser/browser.go
@@ -1,11 +1,15 @@
 package browser

 import (
+	_ "embed"
 	"html/template"
 	"net/http"
 	"strings"
 )

+//go:embed viewer.html
+var webpage string
+
 func LogSocketViewHandler(w http.ResponseWriter, r *http.Request) {
 	wsResource := r.Host + r.URL.Path
 	if r.TLS != nil {
@@ -17,201 +21,4 @@ func LogSocketViewHandler(w http.ResponseWriter, r *http.Request) {
 	homeTemplate.Execute(w, wsResource)
 }

-var homeTemplate = template.Must(template.New("").Parse(`
-<!DOCTYPE html>
-<html>
-<head>
-<meta charset="utf-8">
-</head>
-<body>
-<center>
-<input type="text" id="search" onkeyup="filterTable()" placeholder="Filter...">
-<input type="checkbox" id="shouldScroll" checked>Enable Autoscroll<br>
-<table id="logHeaders" style="text-align:left; width:80%;" >
-<tbody>
-<tr class="header">
-<th style="width:20%;">TimeStamp</th>
-<th style="width:5%;">Level</th>
-<th style="width:65%;">Output</th>
-<th style="width:10%;">Source</th>
-</tr>
-</tbody>
-</table>
-
-<div id="tableWrapper">
-<table id="logs" style="text-align:left; width:100%;" >
-<tbody id="tbodylogs">
-<tr class="header">
-<th style="width:20%;"></th>
-<th style="width:5%;"></th>
-<th style="width:65%;"></th>
-<th style="width:10%;"></th>
-</tr>
-
-</tbody>
-</table>
-</div>
-<br>
-<input class="button" type="button" id="download" value="Download Logs" style="background-color:#3f51b5;"/>
-<input class="button" type="button" id="delete" value="Delete Logs" style="background-color:#f44336"/>
-</center>
-</body>
-<footer>
-<style>
-#tableWrapper{
-	overflow-y: scroll;
-	display: flow-root;
-	width: 80%;
-	height: 80vh;
-}
-td,tr{
-	height: min-content;
-}
-.button{
-	display: inline-block;
-	width: 5vw;
-	height: 5vh;
-}
-</style>
-<script>  
-var logTable = document.getElementById("logs");
-var logTableB = document.getElementById("tbodylogs");
-var ws = null;
-var application = "demo-commit"
-var logs = [];
-function sleep(ms) {
-	return new Promise(resolve => setTimeout(resolve, ms));
-}
-function download(filename, text) {
-	var element = document.createElement('a');
-	element.setAttribute('href', 'data:text/plain;charset=utf-8,' + encodeURIComponent(text));
-	element.setAttribute('download', filename);
-	element.style.display = 'none';
-	document.body.appendChild(element);
-	element.click();
-	document.body.removeChild(element);
-}
-function openSocket() {
-	if (ws) {
-		return false;
-	}
-	ws = new WebSocket("{{.}}");
-	ws.onclose = async function(evt) {
-		ws = null;
-		while(ws == null){
-			openSocket()
-			await sleep(5000);
-		}
-	}
-	ws.onmessage = function(evt) {
-		var entry = JSON.parse(evt.data)
-		logs.push(entry)
-		var row = document.createElement('tr');
-		var ts = document.createElement('td');
-		var tst = document.createTextNode(entry.timestamp);
-		ts.appendChild(tst);
-		row.appendChild(ts);
-		var ts = document.createElement('td');
-		var tst = document.createTextNode(entry.level);
-		ts.appendChild(tst);
-		row.appendChild(ts);
-		var ts = document.createElement('td');
-		var tst = document.createTextNode(entry.output);
-		ts.appendChild(tst);
-		row.appendChild(ts);
-		var ts = document.createElement('td');
-		var tst = document.createTextNode(entry.file);
-		ts.appendChild(tst);
-		row.appendChild(ts);
-		var bg="";
-		switch(entry.level){
-		case "INFO":
-			bg="white";
-			break;
-		case "ERROR":
-			bg="#f44336";
-			break;
-		case "WARN":
-			bg="#fb8c00"
-			break;
-		case "TRACE":
-			bg="#E1F5FE"
-			break;
-		case "DEBUG":
-			bg="#B3E5FC"
-			break;
-		default:
-			bg="white"
-			break;
-		}
-		row.style.backgroundColor=bg
-		logTableB.append(row)
-		filterTable()
-	}
-	ws.onerror = function(evt) {
-		if (evt != null && evt.data != null){
-			// handle error here
-		}
-	}
-}
-function clearTable(){
-	if(!window.confirm("Are you sure you want to delete all logs?")){
-		return
-	}
-	logs = []
-
-	while (logTableB.childNodes.length > 1) {
-		logTableB.removeChild(logTableB.childNodes[1]);
-	}
-}
-function filterTable() {
-	var cols, input, filter, table, tr, td, i, txtValue, w;
-	input = document.getElementById("search");
-	filter = input.value;
-	table = logTableB;
-	tr = table.getElementsByTagName("tr");
-	for (i = 1; i < tr.length; i++) {
-		cols = tr[i].getElementsByTagName("td");
-		var visible = false;
-		for (w = 0; w < cols.length; w++){
-			if (!visible && cols[w]) {
-				td = cols[w]
-				txtValue = td.textContent || td.innerText;
-				if (txtValue.indexOf(filter) > -1) {
-					visible = true
-				} 
-			}
-		}
-		if(visible){
-
-			tr[i].style.display = "";
-		} else {
-
-			tr[i].style.display = "none";
-		}
-
-	}
-}
-function pageScroll() {
-	if (document.getElementById('shouldScroll').checked) {
-		document.getElementById('tableWrapper').scrollBy(0,10);
-
-	}
-	setTimeout(pageScroll,10);
-}
-
-document.getElementById("delete").addEventListener("click", function(){
-
-	clearTable()
-}, false);
-document.getElementById("download").addEventListener("click", function(){
-
-	download(application+'.json',JSON.stringify(logs));
-}, false);
-openSocket();
-pageScroll();
-</script>
-
-</footer>
-</html>
-`))
+var homeTemplate = template.Must(template.New("").Parse(webpage))
--- a/browser/screenshot.png
+++ b/browser/screenshot.png
--- a/browser/viewer.html
+++ b/browser/viewer.html
@@ -0,0 +1,196 @@
+<!DOCTYPE html>
+<html>
+	<head>
+		<meta charset="utf-8">
+	</head>
+	<body>
+		<center>
+			<input type="text" id="search" onkeyup="filterTable()" placeholder="Filter...">
+			<input type="checkbox" id="shouldScroll" checked>Enable Autoscroll<br>
+			<table id="logHeaders" style="text-align:left; width:80%;" >
+				<tbody>
+					<tr class="header">
+						<th style="width:20%;">TimeStamp</th>
+						<th style="width:5%;">Level</th>
+						<th style="width:65%;">Output</th>
+						<th style="width:10%;">Source</th>
+					</tr>
+				</tbody>
+			</table>
+
+			<div id="tableWrapper">
+				<table id="logs" style="text-align:left; width:100%;" >
+					<tbody id="tbodylogs">
+						<tr class="header">
+							<th style="width:20%;"></th>
+							<th style="width:5%;"></th>
+							<th style="width:65%;"></th>
+							<th style="width:10%;"></th>
+						</tr>
+
+					</tbody>
+				</table>
+			</div>
+			<br>
+			<input class="button" type="button" id="download" value="Download Logs" style="background-color:#3f51b5;"/>
+			<input class="button" type="button" id="delete" value="Delete Logs" style="background-color:#f44336"/>
+		</center>
+	</body>
+	<footer>
+		<style>
+#tableWrapper{
+	overflow-y: scroll;
+	display: flow-root;
+	width: 80%;
+	height: 80vh;
+}
+td,tr{
+	height: min-content;
+}
+.button{
+	display: inline-block;
+	width: 5vw;
+	height: 5vh;
+}
+		</style>
+		<script>  
+			var logTable = document.getElementById("logs");
+			var logTableB = document.getElementById("tbodylogs");
+			var ws = null;
+			var application = "demo-commit"
+			var logs = [];
+			function sleep(ms) {
+				return new Promise(resolve => setTimeout(resolve, ms));
+			}
+			function download(filename, text) {
+				var element = document.createElement('a');
+				element.setAttribute('href', 'data:text/plain;charset=utf-8,' + encodeURIComponent(text));
+				element.setAttribute('download', filename);
+				element.style.display = 'none';
+				document.body.appendChild(element);
+				element.click();
+				document.body.removeChild(element);
+			}
+			function openSocket() {
+				if (ws) {
+					return false;
+				}
+				ws = new WebSocket("{{.}}");
+				ws.onclose = async function(evt) {
+					ws = null;
+					while(ws == null){
+						openSocket()
+						await sleep(5000);
+					}
+				}
+				ws.onmessage = function(evt) {
+					var entry = JSON.parse(evt.data)
+					logs.push(entry)
+					var row = document.createElement('tr');
+					var ts = document.createElement('td');
+					var tst = document.createTextNode(entry.timestamp);
+					ts.appendChild(tst);
+					row.appendChild(ts);
+					var ts = document.createElement('td');
+					var tst = document.createTextNode(entry.level);
+					ts.appendChild(tst);
+					row.appendChild(ts);
+					var ts = document.createElement('td');
+					var tst = document.createTextNode(entry.output);
+					ts.appendChild(tst);
+					row.appendChild(ts);
+					var ts = document.createElement('td');
+					var tst = document.createTextNode(entry.file);
+					ts.appendChild(tst);
+					row.appendChild(ts);
+					var bg="";
+					switch(entry.level){
+						case "INFO":
+							bg="white";
+							break;
+						case "ERROR":
+							bg="#f44336";
+							break;
+						case "WARN":
+							bg="#fb8c00"
+							break;
+						case "TRACE":
+							bg="#E1F5FE"
+							break;
+						case "DEBUG":
+							bg="#B3E5FC"
+							break;
+						default:
+							bg="white"
+							break;
+					}
+					row.style.backgroundColor=bg
+					logTableB.append(row)
+					filterTable()
+				}
+				ws.onerror = function(evt) {
+					if (evt != null && evt.data != null){
+						// handle error here
+					}
+				}
+			}
+			function clearTable(){
+				if(!window.confirm("Are you sure you want to delete all logs?")){
+					return
+				}
+				logs = []
+
+				while (logTableB.childNodes.length > 1) {
+					logTableB.removeChild(logTableB.childNodes[1]);
+				}
+			}
+			function filterTable() {
+				var cols, input, filter, table, tr, td, i, txtValue, w;
+				input = document.getElementById("search");
+				filter = input.value;
+				table = logTableB;
+				tr = table.getElementsByTagName("tr");
+				for (i = 1; i < tr.length; i++) {
+					cols = tr[i].getElementsByTagName("td");
+					var visible = false;
+					for (w = 0; w < cols.length; w++){
+						if (!visible && cols[w]) {
+							td = cols[w]
+							txtValue = td.textContent || td.innerText;
+							if (txtValue.indexOf(filter) > -1) {
+								visible = true
+							} 
+						}
+					}
+					if(visible){
+
+						tr[i].style.display = "";
+					} else {
+
+						tr[i].style.display = "none";
+					}
+
+				}
+			}
+			function pageScroll() {
+				if (document.getElementById('shouldScroll').checked) {
+					document.getElementById('tableWrapper').scrollBy(0,10);
+
+				}
+				setTimeout(pageScroll,10);
+			}
+
+			document.getElementById("delete").addEventListener("click", function(){
+
+				clearTable()
+			}, false);
+			document.getElementById("download").addEventListener("click", function(){
+
+				download(application+'.json',JSON.stringify(logs));
+			}, false);
+			openSocket();
+			pageScroll();
+		</script>
+
+	</footer>
+</html>
--- a/go.mod
+++ b/go.mod
@@ -1,5 +1,5 @@
 module github.com/taigrr/log-socket

-go 1.17
+go 1.21

-require github.com/gorilla/websocket v1.4.2
+require github.com/gorilla/websocket v1.5.3
--- a/go.sum
+++ b/go.sum
@@ -1,2 +1,2 @@
-github.com/gorilla/websocket v1.4.2 h1:+/TMaTYc4QFitKJxsQ7Yye35DkWvkdLcvGKqM+x0Ufc=
-github.com/gorilla/websocket v1.4.2/go.mod h1:YR8l580nyteQvAITg2hZ9XVh4b55+EU/adAjf1fMHhE=
+github.com/gorilla/websocket v1.5.3 h1:saDtZ6Pbx/0u+bgYQ3q96pZgCzfhKXGPqt7kZ72aNNg=
+github.com/gorilla/websocket v1.5.3/go.mod h1:YR8l580nyteQvAITg2hZ9XVh4b55+EU/adAjf1fMHhE=
--- a/log/log.go
+++ b/log/log.go
@@ -26,18 +26,12 @@ func init() {
 }

 func (c *Client) logStdErr() {
-	for {
-		select {
-		case e, more := <-c.writer:
-			if e.level >= c.LogLevel {
-				fmt.Fprintf(os.Stderr, "%s\t%s\t%s\t%s\n", e.Timestamp.String(), e.Level, e.Output, e.File)
-			}
-			if !more {
-				stderrFinished <- true
-				return
-			}
+	for e := range c.writer {
+		if e.level >= c.LogLevel {
+			fmt.Fprintf(os.Stderr, "%s\t%s\t%s\t%s\n", e.Timestamp.String(), e.Level, e.Output, e.File)
 		}
 	}
+	stderrFinished <- true
 }

 func CreateClient() *Client {
@@ -61,7 +55,7 @@ func Flush() {
 func (c *Client) Destroy() error {
 	var otherClients []*Client
 	if !c.initialized {
-		panic(errors.New("Cannot delete uninitialized client, did you use CreateClient?"))
+		panic(errors.New("cannot delete uninitialized client, did you use CreateClient?"))
 	}
 	sliceTex.Lock()
 	c.writer = nil
@@ -78,7 +72,7 @@ func (c *Client) Destroy() error {

 func (c *Client) GetLogLevel() Level {
 	if !c.initialized {
-		panic(errors.New("Cannot get level for uninitialized client, use CreateClient instead"))
+		panic(errors.New("cannot get level for uninitialized client, use CreateClient instead"))
 	}
 	return c.LogLevel
 }
@@ -109,20 +103,20 @@ func SetLogLevel(level Level) {
 // SetLogLevel set log level of logger
 func (c *Client) SetLogLevel(level Level) {
 	if !c.initialized {
-		panic(errors.New("Cannot set level for uninitialized client, use CreateClient instead"))
+		panic(errors.New("cannot set level for uninitialized client, use CreateClient instead"))
 	}
 	c.LogLevel = level
 }

 func (c *Client) Get() Entry {
 	if !c.initialized {
-		panic(errors.New("Cannot get logs for uninitialized client, did you use CreateClient?"))
+		panic(errors.New("cannot get logs for uninitialized client, did you use CreateClient?"))
 	}
 	return <-c.writer
 }

 // Trace prints out logs on trace level
-func Trace(args ...interface{}) {
+func Trace(args ...any) {
 	output := fmt.Sprint(args...)
 	e := Entry{
 		Timestamp: time.Now(),
@@ -135,7 +129,7 @@ func Trace(args ...interface{}) {
 }

 // Formatted print for Trace
-func Tracef(format string, args ...interface{}) {
+func Tracef(format string, args ...any) {
 	output := fmt.Sprintf(format, args...)
 	e := Entry{
 		Timestamp: time.Now(),
@@ -147,8 +141,21 @@ func Tracef(format string, args ...interface{}) {
 	createLog(e)
 }

+// Trace prints out logs on trace level with newline
+func Traceln(args ...any) {
+	output := fmt.Sprintln(args...)
+	e := Entry{
+		Timestamp: time.Now(),
+		Output:    output,
+		File:      fileInfo(2),
+		Level:     "TRACE",
+		level:     LTrace,
+	}
+	createLog(e)
+}
+
 // Debug prints out logs on debug level
-func Debug(args ...interface{}) {
+func Debug(args ...any) {
 	output := fmt.Sprint(args...)
 	e := Entry{
 		Timestamp: time.Now(),
@@ -161,7 +168,7 @@ func Debug(args ...interface{}) {
 }

 // Formatted print for Debug
-func Debugf(format string, args ...interface{}) {
+func Debugf(format string, args ...any) {
 	output := fmt.Sprintf(format, args...)
 	e := Entry{
 		Timestamp: time.Now(),
@@ -173,8 +180,21 @@ func Debugf(format string, args ...interface{}) {
 	createLog(e)
 }

+// Debug prints out logs on debug level with a newline
+func Debugln(args ...any) {
+	output := fmt.Sprintln(args...)
+	e := Entry{
+		Timestamp: time.Now(),
+		Output:    output,
+		File:      fileInfo(2),
+		Level:     "DEBUG",
+		level:     LDebug,
+	}
+	createLog(e)
+}
+
 // Info prints out logs on info level
-func Info(args ...interface{}) {
+func Info(args ...any) {
 	output := fmt.Sprint(args...)
 	e := Entry{
 		Timestamp: time.Now(),
@@ -187,7 +207,7 @@ func Info(args ...interface{}) {
 }

 // Formatted print for Info
-func Infof(format string, args ...interface{}) {
+func Infof(format string, args ...any) {
 	output := fmt.Sprintf(format, args...)
 	e := Entry{
 		Timestamp: time.Now(),
@@ -199,8 +219,21 @@ func Infof(format string, args ...interface{}) {
 	createLog(e)
 }

+// Info prints out logs on info level with a newline
+func Infoln(args ...any) {
+	output := fmt.Sprintln(args...)
+	e := Entry{
+		Timestamp: time.Now(),
+		Output:    output,
+		File:      fileInfo(2),
+		Level:     "INFO",
+		level:     LInfo,
+	}
+	createLog(e)
+}
+
 // Info prints out logs on info level
-func Notice(args ...interface{}) {
+func Notice(args ...any) {
 	output := fmt.Sprint(args...)
 	e := Entry{
 		Timestamp: time.Now(),
@@ -213,7 +246,7 @@ func Notice(args ...interface{}) {
 }

 // Formatted print for Info
-func Noticef(format string, args ...interface{}) {
+func Noticef(format string, args ...any) {
 	output := fmt.Sprintf(format, args...)
 	e := Entry{
 		Timestamp: time.Now(),
@@ -225,8 +258,21 @@ func Noticef(format string, args ...interface{}) {
 	createLog(e)
 }

+// Info prints out logs on info level with a newline
+func Noticeln(args ...any) {
+	output := fmt.Sprintln(args...)
+	e := Entry{
+		Timestamp: time.Now(),
+		Output:    output,
+		File:      fileInfo(2),
+		Level:     "NOTICE",
+		level:     LNotice,
+	}
+	createLog(e)
+}
+
 // Warn prints out logs on warn level
-func Warn(args ...interface{}) {
+func Warn(args ...any) {
 	output := fmt.Sprint(args...)
 	e := Entry{
 		Timestamp: time.Now(),
@@ -239,7 +285,7 @@ func Warn(args ...interface{}) {
 }

 // Formatted print for Warn
-func Warnf(format string, args ...interface{}) {
+func Warnf(format string, args ...any) {
 	output := fmt.Sprintf(format, args...)
 	e := Entry{
 		Timestamp: time.Now(),
@@ -251,8 +297,21 @@ func Warnf(format string, args ...interface{}) {
 	createLog(e)
 }

+// Newline print for Warn
+func Warnln(args ...any) {
+	output := fmt.Sprintln(args...)
+	e := Entry{
+		Timestamp: time.Now(),
+		Output:    output,
+		File:      fileInfo(2),
+		Level:     "WARN",
+		level:     LWarn,
+	}
+	createLog(e)
+}
+
 // Error prints out logs on error level
-func Error(args ...interface{}) {
+func Error(args ...any) {
 	output := fmt.Sprint(args...)
 	e := Entry{
 		Timestamp: time.Now(),
@@ -265,7 +324,7 @@ func Error(args ...interface{}) {
 }

 // Formatted print for error
-func Errorf(format string, args ...interface{}) {
+func Errorf(format string, args ...any) {
 	output := fmt.Sprintf(format, args...)
 	e := Entry{
 		Timestamp: time.Now(),
@@ -277,8 +336,21 @@ func Errorf(format string, args ...interface{}) {
 	createLog(e)
 }

+// Error prints out logs on error level with a newline
+func Errorln(args ...any) {
+	output := fmt.Sprintln(args...)
+	e := Entry{
+		Timestamp: time.Now(),
+		Output:    output,
+		File:      fileInfo(2),
+		Level:     "ERROR",
+		level:     LError,
+	}
+	createLog(e)
+}
+
 // Panic prints out logs on panic level
-func Panic(args ...interface{}) {
+func Panic(args ...any) {
 	output := fmt.Sprint(args...)
 	e := Entry{
 		Timestamp: time.Now(),
@@ -301,7 +373,7 @@ func Panic(args ...interface{}) {
 }

 // Formatted print for panic
-func Panicf(format string, args ...interface{}) {
+func Panicf(format string, args ...any) {
 	output := fmt.Sprintf(format, args...)
 	e := Entry{
 		Timestamp: time.Now(),
@@ -323,8 +395,30 @@ func Panicf(format string, args ...interface{}) {
 	panic(errors.New(output))
 }

+func Panicln(args ...any) {
+	output := fmt.Sprintln(args...)
+	e := Entry{
+		Timestamp: time.Now(),
+		Output:    output,
+		File:      fileInfo(2),
+		Level:     "PANIC",
+		level:     LPanic,
+	}
+	createLog(e)
+	if len(args) >= 0 {
+		switch args[0].(type) {
+		case error:
+			panic(args[0])
+		default:
+			// falls through to default below
+		}
+	}
+	Flush()
+	panic(errors.New(output))
+}
+
 // Fatal prints out logs on fatal level
-func Fatal(args ...interface{}) {
+func Fatal(args ...any) {
 	output := fmt.Sprint(args...)
 	e := Entry{
 		Timestamp: time.Now(),
@@ -339,7 +433,7 @@ func Fatal(args ...interface{}) {
 }

 // Formatted print for fatal
-func Fatalf(format string, args ...interface{}) {
+func Fatalf(format string, args ...any) {
 	output := fmt.Sprintf(format, args...)
 	e := Entry{
 		Timestamp: time.Now(),
@@ -353,6 +447,32 @@ func Fatalf(format string, args ...interface{}) {
 	os.Exit(1)
 }

+func Fatalln(args ...any) {
+	output := fmt.Sprintln(args...)
+	e := Entry{
+		Timestamp: time.Now(),
+		Output:    output,
+		File:      fileInfo(2),
+		Level:     "FATAL",
+		level:     LFatal,
+	}
+	createLog(e)
+	Flush()
+	os.Exit(1)
+}
+
+func Print(args ...any) {
+	Info(args...)
+}
+
+func Printf(format string, args ...any) {
+	Infof(format, args...)
+}
+
+func Println(args ...any) {
+	Infoln(args...)
+}
+
 // fileInfo for getting which line in which file
 func fileInfo(skip int) string {
 	_, file, line, ok := runtime.Caller(skip)
--- a/log/log_test.go
+++ b/log/log_test.go
@@ -55,8 +55,7 @@ func BenchmarkDebugSerial(b *testing.B) {
 // Trace ensure logs come out in the right order
 func TestOrder(t *testing.T) {
 	testString := "Testing trace: "
-	var c *Client
-	c = CreateClient()
+	c := CreateClient()
 	c.SetLogLevel(LTrace)

 	for i := 0; i < 5000; i++ {
@@ -86,6 +85,15 @@ func TestInfo(t *testing.T) {
 	//	}
 }

+// Print prints out logs on info level
+func TestPrint(t *testing.T) {
+	//	if logLevel >= LInfo {
+	//		entry := logger.WithFields(logrus.Fields{})
+	//		entry.Data["file"] = fileInfo(2)
+	//		entry.Info(args...)
+	//	}
+}
+
 // Warn prints out logs on warn level
 func TestWarn(t *testing.T) {
 	//	if logLevel >= LWarn {
@@ -121,6 +129,7 @@ func TestPanic(t *testing.T) {
 	//		entry.Panic(args...)
 	//	}
 }
+
 func TestFlush(t *testing.T) {
 	defer Flush()
 }
--- a/log/logger.go
+++ b/log/logger.go
@@ -7,12 +7,16 @@ import (
 	"time"
 )

-func (l Logger) SetInfoDepth(depth int) {
+func Default() *Logger {
+	return &Logger{FileInfoDepth: 0}
+}
+
+func (l *Logger) SetInfoDepth(depth int) {
 	l.FileInfoDepth = depth
 }

 // Trace prints out logs on trace level
-func (l Logger) Trace(args ...interface{}) {
+func (l Logger) Trace(args ...any) {
 	output := fmt.Sprint(args...)
 	e := Entry{
 		Timestamp: time.Now(),
@@ -25,7 +29,7 @@ func (l Logger) Trace(args ...interface{}) {
 }

 // Formatted print for Trace
-func (l Logger) Tracef(format string, args ...interface{}) {
+func (l Logger) Tracef(format string, args ...any) {
 	output := fmt.Sprintf(format, args...)
 	e := Entry{
 		Timestamp: time.Now(),
@@ -37,8 +41,21 @@ func (l Logger) Tracef(format string, args ...interface{}) {
 	createLog(e)
 }

+// Trace prints out logs on trace level with newline
+func (l Logger) Traceln(args ...any) {
+	output := fmt.Sprintln(args...)
+	e := Entry{
+		Timestamp: time.Now(),
+		Output:    output,
+		File:      fileInfo(l.FileInfoDepth),
+		Level:     "TRACE",
+		level:     LTrace,
+	}
+	createLog(e)
+}
+
 // Debug prints out logs on debug level
-func (l Logger) Debug(args ...interface{}) {
+func (l Logger) Debug(args ...any) {
 	output := fmt.Sprint(args...)
 	e := Entry{
 		Timestamp: time.Now(),
@@ -51,7 +68,7 @@ func (l Logger) Debug(args ...interface{}) {
 }

 // Formatted print for Debug
-func (l Logger) Debugf(format string, args ...interface{}) {
+func (l Logger) Debugf(format string, args ...any) {
 	output := fmt.Sprintf(format, args...)
 	e := Entry{
 		Timestamp: time.Now(),
@@ -64,7 +81,7 @@ func (l Logger) Debugf(format string, args ...interface{}) {
 }

 // Info prints out logs on info level
-func (l Logger) Info(args ...interface{}) {
+func (l Logger) Info(args ...any) {
 	output := fmt.Sprint(args...)
 	e := Entry{
 		Timestamp: time.Now(),
@@ -77,7 +94,7 @@ func (l Logger) Info(args ...interface{}) {
 }

 // Formatted print for Info
-func (l Logger) Infof(format string, args ...interface{}) {
+func (l Logger) Infof(format string, args ...any) {
 	output := fmt.Sprintf(format, args...)
 	e := Entry{
 		Timestamp: time.Now(),
@@ -89,8 +106,21 @@ func (l Logger) Infof(format string, args ...interface{}) {
 	createLog(e)
 }

-// Info prints out logs on info level
-func (l Logger) Notice(args ...interface{}) {
+// Info prints out logs on info level with newline
+func (l Logger) Infoln(args ...any) {
+	output := fmt.Sprintln(args...)
+	e := Entry{
+		Timestamp: time.Now(),
+		Output:    output,
+		File:      fileInfo(l.FileInfoDepth),
+		Level:     "INFO",
+		level:     LInfo,
+	}
+	createLog(e)
+}
+
+// Notice prints out logs on notice level
+func (l Logger) Notice(args ...any) {
 	output := fmt.Sprint(args...)
 	e := Entry{
 		Timestamp: time.Now(),
@@ -102,8 +132,8 @@ func (l Logger) Notice(args ...interface{}) {
 	createLog(e)
 }

-// Formatted print for Info
-func (l Logger) Noticef(format string, args ...interface{}) {
+// Formatted print for Notice
+func (l Logger) Noticef(format string, args ...any) {
 	output := fmt.Sprintf(format, args...)
 	e := Entry{
 		Timestamp: time.Now(),
@@ -115,8 +145,21 @@ func (l Logger) Noticef(format string, args ...interface{}) {
 	createLog(e)
 }

+// Notice prints out logs on notice level with newline
+func (l Logger) Noticeln(args ...any) {
+	output := fmt.Sprintln(args...)
+	e := Entry{
+		Timestamp: time.Now(),
+		Output:    output,
+		File:      fileInfo(l.FileInfoDepth),
+		Level:     "NOTICE",
+		level:     LNotice,
+	}
+	createLog(e)
+}
+
 // Warn prints out logs on warn level
-func (l Logger) Warn(args ...interface{}) {
+func (l Logger) Warn(args ...any) {
 	output := fmt.Sprint(args...)
 	e := Entry{
 		Timestamp: time.Now(),
@@ -129,7 +172,7 @@ func (l Logger) Warn(args ...interface{}) {
 }

 // Formatted print for Warn
-func (l Logger) Warnf(format string, args ...interface{}) {
+func (l Logger) Warnf(format string, args ...any) {
 	output := fmt.Sprintf(format, args...)
 	e := Entry{
 		Timestamp: time.Now(),
@@ -141,8 +184,21 @@ func (l Logger) Warnf(format string, args ...interface{}) {
 	createLog(e)
 }

+// Warn prints out logs on warn level with a newline
+func (l Logger) Warnln(args ...any) {
+	output := fmt.Sprintln(args...)
+	e := Entry{
+		Timestamp: time.Now(),
+		Output:    output,
+		File:      fileInfo(l.FileInfoDepth),
+		Level:     "WARN",
+		level:     LWarn,
+	}
+	createLog(e)
+}
+
 // Error prints out logs on error level
-func (l Logger) Error(args ...interface{}) {
+func (l Logger) Error(args ...any) {
 	output := fmt.Sprint(args...)
 	e := Entry{
 		Timestamp: time.Now(),
@@ -155,7 +211,7 @@ func (l Logger) Error(args ...interface{}) {
 }

 // Formatted print for error
-func (l Logger) Errorf(format string, args ...interface{}) {
+func (l Logger) Errorf(format string, args ...any) {
 	output := fmt.Sprintf(format, args...)
 	e := Entry{
 		Timestamp: time.Now(),
@@ -167,8 +223,21 @@ func (l Logger) Errorf(format string, args ...interface{}) {
 	createLog(e)
 }

+// Error prints out logs on error level with a new line
+func (l Logger) Errorln(args ...any) {
+	output := fmt.Sprintln(args...)
+	e := Entry{
+		Timestamp: time.Now(),
+		Output:    output,
+		File:      fileInfo(l.FileInfoDepth),
+		Level:     "ERROR",
+		level:     LError,
+	}
+	createLog(e)
+}
+
 // Panic prints out logs on panic level
-func (l Logger) Panic(args ...interface{}) {
+func (l Logger) Panic(args ...any) {
 	output := fmt.Sprint(args...)
 	e := Entry{
 		Timestamp: time.Now(),
@@ -191,7 +260,7 @@ func (l Logger) Panic(args ...interface{}) {
 }

 // Formatted print for panic
-func (l Logger) Panicf(format string, args ...interface{}) {
+func (l Logger) Panicf(format string, args ...any) {
 	output := fmt.Sprintf(format, args...)
 	e := Entry{
 		Timestamp: time.Now(),
@@ -213,8 +282,31 @@ func (l Logger) Panicf(format string, args ...interface{}) {
 	panic(errors.New(output))
 }

+// Panic prints out logs on panic level with a newline
+func (l Logger) Panicln(args ...any) {
+	output := fmt.Sprintln(args...)
+	e := Entry{
+		Timestamp: time.Now(),
+		Output:    output,
+		File:      fileInfo(l.FileInfoDepth),
+		Level:     "PANIC",
+		level:     LPanic,
+	}
+	createLog(e)
+	if len(args) >= 0 {
+		switch args[0].(type) {
+		case error:
+			panic(args[0])
+		default:
+			// falls through to default below
+		}
+	}
+	Flush()
+	panic(errors.New(output))
+}
+
 // Fatal prints out logs on fatal level
-func (l Logger) Fatal(args ...interface{}) {
+func (l Logger) Fatal(args ...any) {
 	output := fmt.Sprint(args...)
 	e := Entry{
 		Timestamp: time.Now(),
@@ -229,7 +321,7 @@ func (l Logger) Fatal(args ...interface{}) {
 }

 // Formatted print for fatal
-func (l Logger) Fatalf(format string, args ...interface{}) {
+func (l Logger) Fatalf(format string, args ...any) {
 	output := fmt.Sprintf(format, args...)
 	e := Entry{
 		Timestamp: time.Now(),
@@ -242,3 +334,33 @@ func (l Logger) Fatalf(format string, args ...interface{}) {
 	Flush()
 	os.Exit(1)
 }
+
+// Fatal prints fatal level with a new line
+func (l Logger) Fatalln(args ...any) {
+	output := fmt.Sprintln(args...)
+	e := Entry{
+		Timestamp: time.Now(),
+		Output:    output,
+		File:      fileInfo(l.FileInfoDepth),
+		Level:     "FATAL",
+		level:     LFatal,
+	}
+	createLog(e)
+	Flush()
+	os.Exit(1)
+}
+
+// Handles print to info
+func (l Logger) Print(args ...any) {
+	l.Info(args...)
+}
+
+// Handles formatted print to info
+func (l Logger) Printf(format string, args ...any) {
+	l.Infof(format, args...)
+}
+
+// Handles print to info with new line
+func (l Logger) Println(args ...any) {
+	l.Infoln(args...)
+}
--- a/log/types.go
+++ b/log/types.go
@@ -2,9 +2,6 @@ package log

 import "time"

-type LogWriter chan Entry
-type Level int
-
 const (
 	LTrace Level = iota
 	LDebug
@@ -16,20 +13,23 @@ const (
 	LFatal
 )

-type Client struct {
-	LogLevel    Level `json:"level"`
-	writer      LogWriter
-	initialized bool
-}
+type (
+	LogWriter chan Entry
+	Level     int

-type Entry struct {
-	Timestamp time.Time `json:"timestamp"`
-	Output    string    `json:"output"`
-	File      string    `json:"file"`
-	Level     string    `json:"level"`
-	level     Level
-}
-
-type Logger struct {
-	FileInfoDepth int
-}
+	Client struct {
+		LogLevel    Level `json:"level"`
+		writer      LogWriter
+		initialized bool
+	}
+	Entry struct {
+		Timestamp time.Time `json:"timestamp"`
+		Output    string    `json:"output"`
+		File      string    `json:"file"`
+		Level     string    `json:"level"`
+		level     Level
+	}
+	Logger struct {
+		FileInfoDepth int
+	}
+)
--- a/ws/server.go
+++ b/ws/server.go
@@ -8,10 +8,12 @@ import (
 	logger "github.com/taigrr/log-socket/log"
 )

-// var addr = flag.String("addr", "localhost:8080", "http service address")
-
 var upgrader = websocket.Upgrader{} // use default options

+func SetUpgrader(u websocket.Upgrader) {
+	upgrader = u
+}
+
 func LogSocketHandler(w http.ResponseWriter, r *http.Request) {
 	c, err := upgrader.Upgrade(w, r, nil)
 	if err != nil {
@@ -25,10 +27,10 @@ func LogSocketHandler(w http.ResponseWriter, r *http.Request) {
 	logger.Info("Websocket client attached.")
 	for {
 		logEvent := lc.Get()
-		logJSON, err := json.Marshal(logEvent)
+		logJSON, _ := json.Marshal(logEvent)
 		err = c.WriteMessage(websocket.TextMessage, logJSON)
 		if err != nil {
-			logger.Error("write:", err)
+			logger.Warn("write:", err)
 			break
 		}
 	}
Author	SHA1	Message	Date
Tai Groot	c89dda8333	error -> warn for broken connection	2025-06-29 00:43:55 -07:00
Tai Groot	41aad10e6c	add upgrader option	2025-06-29 00:10:09 -07:00
Tai Groot	64ab2564c1	upgrade workflow to match go.mod	2025-05-01 18:30:13 -07:00
Tai Groot	1c00bc90b8	upgrade deps, readme	2025-05-01 18:27:46 -07:00
Tai Groot	f114098a8c	uodate go version	2023-08-26 22:00:42 -07:00
Ethan Holz	2571dbe347	Add Github Actions for automated testing (#12 ) * ci: Added initial github action for automated testing * fix: changed go version * ci: updated to change job name to test	2023-05-13 23:27:20 -07:00
Tai Groot	80b80758de	Add Default() func	2023-03-29 14:26:06 -07:00
Tai Groot	0fa4de7961	Revert "add ability to embed other loggers of varying functionality" This reverts commit `50c507c8f4`.	2023-03-29 14:06:00 -07:00
Tai Groot	50c507c8f4	add ability to embed other loggers of varying functionality	2023-03-29 14:02:57 -07:00
Tai Groot	e21fb8a614	make pass gofumpt	2022-10-14 22:23:42 -07:00
Tai Groot	2492509b6b	extract browser from string var, upgrade deps	2022-10-14 22:14:47 -07:00
Tai Groot	a1e960366e	Merge pull request #11 from ethanholz/log-parity feat: Updated to include print and added ln variants for all logs	2022-10-13 08:05:39 -07:00
Ethan Holz	430181e3a2	feat: Updated to include print and added ln variants for all logs	2022-10-13 09:59:04 -05:00
Tai Groot	147a8cb30b	Merge pull request #10 from ethanholz/README Added a README	2022-10-10 13:38:59 -07:00
Ethan Holz	8e044e3993	docs: Updated README to include running example.	2022-10-10 12:16:52 -05:00
Ethan Holz	e97d37012e	docs: Added inital README	2022-10-10 12:09:29 -05:00
Tai Groot	ebef59a9a8	actually set value for depth	2021-08-23 21:58:05 -07:00