Better error handling, and auto-wipe on version change.

.github/workflows/publish.yaml

@@ -80,31 +80,29 @@ jobs:
         uses: actions/checkout@v3
 
       - name: Log in to Docker Hub
-        uses:  docker/login-action@f4ef78c080cd8ba55a85445d5b36e214a81df20a
+        uses:  docker/login-action@v2
         with:
           username: ${{ secrets.DOCKER_USERNAME }}
           password: ${{ secrets.DOCKER_PASSWORD }}
 
       - name: Log in to the Container registry
-        uses: docker/login-action@f4ef78c080cd8ba55a85445d5b36e214a81df20a
+        uses: docker/login-action@v2
         with:
           registry: ghcr.io
           username: ${{ github.actor }}
-          password: ${{ secrets.GITHUB_TOKEN}}
+          password: ${{ secrets.GH_PAT }}
 
       - name: Extract metadata (tags, labels) for Docker
         id: meta
-        uses: docker/metadata-action@9ec57ed1fcdbf14dcef7dfbe97b2010124a938b7
+        uses: docker/metadata-action@v4
         with:
           images: |
             pb33f/wiretap
-            ghcr.io/pb33f/wiretap
+            ghcr.io/${{ github.repository }}
 
       - name: Build and push Docker images
-        uses: docker/build-push-action@3b5e8027fcad23fda98b2e3ac259d8d67585f671
+        uses: docker/build-push-action@v4
         with:
           context: .
           push: true
-          tags: pb33f/wiretap:latest
-          labels: ${{ steps.meta.outputs.labels }}
-          file: ./Dockerfile
+          tags: pb33f/wiretap:latest, pb33f/wiretap:${{ github.event.client_payload.new-tag }}

.goreleaser.yml

@@ -29,7 +29,7 @@ changelog:
       - '^docs:'
       - '^test:'
 brews:
-  - tap:
+  - repository:
       owner: pb33f
       name: homebrew-taps
 
@@ -44,4 +44,41 @@ brews:
       bin.install "wiretap"
 
 snapshot:
-  name_template: "{{ .Tag }}"
+  name_template: "{{ .Tag }}"
+
+upx:
+  -
+    # Whether to enable it or not.
+    enabled: true
+
+
+    # Filter by GOOS.
+    #
+    # Since: v1.19
+    goos: [ linux , darwin ]
+
+    # Filter by GOARCH.
+    #
+    # Since: v1.19
+    goarch: [ arm, amd64 ]
+
+    # Filter by GOARM.
+    #
+    # Since: v1.19
+    goarm: [ 8 ]
+
+    # Filter by GOAMD64.
+    #
+    # Since: v1.19
+    goamd64: [ v1 ]
+
+    # Compress argument.
+    # Valid options are from '1' (faster) to '9' (better), and 'best'.
+    compress: best
+
+    # Whether to try LZMA (slower).
+    lzma: true
+
+    # Whether to try all methods and filters (slow).
+    brute: true
+

cmd/root_command.go

@@ -91,6 +91,9 @@ var (
 
 			var config shared.WiretapConfiguration
 
+			// set version.
+			config.Version = Version
+
 			if configFlag == "" {
 				// see if a configuration file exists in the current directory or in the user's home directory.
 				local, _ := os.Stat("wiretap.yaml")

cmd/serve_monitor.go

@@ -47,7 +47,8 @@ func serveMonitor(wiretapConfig *shared.WiretapConfiguration) {
 		indexString := string(bytes)
 
 		// replace the port in the index.html file and serve it.
-		indexString = strings.ReplaceAll(indexString, shared.WiretapPortPlaceholder, wiretapConfig.WebSocketPort)
+		indexString = strings.ReplaceAll(strings.ReplaceAll(indexString, shared.WiretapPortPlaceholder, wiretapConfig.WebSocketPort),
+			shared.WiretapVersionPlaceholder, wiretapConfig.Version)
 
 		// handle index will serve a modified index.html from the embedded filesystem.
 		// this is so the monitor can connect to the websocket on the correct port.
@@ -65,7 +66,7 @@ func serveMonitor(wiretapConfig *shared.WiretapConfiguration) {
 		mux.HandleFunc("/", handleIndex)
 
 		// compress everything!
-		handlers.CompressHandler(fileServer)
+		fileServer = handlers.CompressHandler(fileServer)
 
 		// handle the assets
 		mux.Handle("/assets/", http.StripPrefix("/assets", fileServer))

daemon/wiretap_broadcast.go

@@ -4,9 +4,12 @@
 package daemon
 
 import (
+	"encoding/json"
+	"fmt"
 	"github.com/google/uuid"
 	"github.com/pb33f/libopenapi-validator/errors"
 	"github.com/pb33f/ranch/model"
+	"github.com/pb33f/wiretap/shared"
 	"net/http"
 )
 
@@ -52,13 +55,29 @@ func (ws *WiretapService) broadcastResponse(request *model.Request, response *ht
 
 func (ws *WiretapService) broadcastResponseError(request *model.Request, response *http.Response, err error) {
 	id, _ := uuid.NewUUID()
+	title := "Response Error"
+	code := 500
+	if response != nil {
+		title = fmt.Sprintf("Response Error %d", response.StatusCode)
+		code = response.StatusCode
+	}
+
+	respBodyString, _ := json.Marshal(&shared.WiretapError{
+		Title:  title,
+		Status: code,
+		Detail: err.Error(),
+	})
+
+	resp := buildResponse(request, response)
+	resp.Response.Body = string(respBodyString)
+
 	ws.broadcastChan.Send(&model.Message{
 		Id:            &id,
 		DestinationId: request.Id,
 		Error:         err,
 		Channel:       WiretapBroadcastChan,
 		Destination:   WiretapBroadcastChan,
-		Payload:       buildResponse(request, response),
+		Payload:       resp,
 		Direction:     model.ResponseDir,
 	})
 }

shared/config.go

@@ -29,6 +29,7 @@ type WiretapConfiguration struct {
 	Variables           map[string]string             `json:"variables,omitempty" yaml:"variables,omitempty"`
 	Spec                string                        `json:"contract,omitempty" yaml:"contract,omitempty"`
 	CompiledVariables   map[string]*CompiledVariable  `json:"-" yaml:"-"`
+	Version             string                        `json:"-" yaml:"-"`
 	StaticPathsCompiled []glob.Glob                   `json:"-" yaml:"-"`
 	CompiledPaths       map[string]*CompiledPath      `json:"-"`
 	FS                  embed.FS                      `json:"-"`
@@ -120,6 +121,7 @@ func (wpc *WiretapPathConfig) Compile(key string) *CompiledPath {
 
 const ConfigKey = "config"
 const WiretapPortPlaceholder = "%WIRETAP_PORT%"
+const WiretapVersionPlaceholder = "%WIRETAP_VERSION%"
 const IndexFile = "index.html"
 const UILocation = "ui/dist"
 const UIAssetsLocation = "ui/dist/assets"

shared/error.go

@@ -7,11 +7,11 @@ import "encoding/json"
 
 // WiretapError is an rfc7807 compliant error struct
 type WiretapError struct {
-	Type     string `json:"type,omitempty"`   // URI reference to the type of problem
-	Title    string `json:"title"`            // A short description of the issue
-	Status   int    `json:"status,omitempty"` // HTTP status code.
-	Detail   string `json:"detail"`           // explanation of the issue in detail.
-	Instance string `json:"instance"`         // URI to the specific problem.
+	Type     string `json:"type,omitempty"`     // URI reference to the type of problem
+	Title    string `json:"title"`              // A short description of the issue
+	Status   int    `json:"status,omitempty"`   // HTTP status code.
+	Detail   string `json:"detail"`             // explanation of the issue in detail.
+	Instance string `json:"instance,omitempty"` // URI to the specific problem.
 }
 
 func GenerateError(title string,

ui/index.html

@@ -8,6 +8,13 @@
     <script>
         sessionStorage.setItem('wiretapPort', '%WIRETAP_PORT%')
         //sessionStorage.setItem('wiretapPort', '9092')
+        const version = '%WIRETAP_VERSION%';
+        const existingVersion = localStorage.getItem('wiretapVersion');
+        if (existingVersion !== version) {
+            localStorage.setItem('wiretapVersion', version);
+            localStorage.setItem('wiretapWipeCache', 'true');
+        }
+
     </script>
     <script type="module" src="/src/index.ts" defer></script>
     <script type="module" src="/src/workers/link_cache_worker.ts"></script>

ui/src/components/controls/controls.ts

@@ -70,13 +70,13 @@ export class WiretapControlsComponent extends LitElement {
         this.loadControlStateFromStorage().then((controls: WiretapControls) => {
             if (!controls) {
                 this._controls = {
-                    globalDelay: -1,
+                    globalDelay: 0,
                 }
             } else {
                 this._controls = controls;
             }
             // get the delay from the backend.
-            this.changeGlobalDelay(-1) // -1 won't update anything, but will return the current delay
+            this.changeGlobalDelay(0) // -1 won't update anything, but will return the current delay
         });
 
 
@@ -125,18 +125,20 @@ export class WiretapControlsComponent extends LitElement {
     }
 
     changeGlobalDelay(delay: number) {
-        this._bus.publish({
-            destination: "/pub/queue/controls",
-            body: JSON.stringify(
-                {
-                    id: RanchUtils.genUUID(),
-                    requestCommand: ChangeDelayCommand,
-                    payload: {
-                        delay: delay
+        if (this._bus.getClient()?.connected) {
+            this._bus.publish({
+                destination: "/pub/queue/controls",
+                body: JSON.stringify(
+                    {
+                        id: RanchUtils.genUUID(),
+                        requestCommand: ChangeDelayCommand,
+                        payload: {
+                            delay: delay
+                        }
                     }
-                }
-            ),
-        });
+                ),
+            });
+        }
     }
 
     openSettings() {

ui/src/components/kv-view/kv-view.css.ts

@@ -56,7 +56,18 @@ export default css`
     font-size: 1em;
   }
 
-
+
+  pre {
+    word-wrap: break-word;
+    white-space: pre-wrap;
+    max-width: 760px;
+    overflow-x: auto;
+  }
+
+  pre > code {
+    word-wrap: break-word;
+    white-space: pre-wrap;
+  }
 
 
 

ui/src/components/kv-view/kv-view.ts

@@ -47,7 +47,7 @@ export class KVViewComponent extends LitElement {
                             <tr>
                                 <td><code>${i[0]}</code></td>
                                 <td>
-                                    <pre><code>${unsafeHTML(Prism.highlight(JSON.stringify(i[1]), Prism.languages['json'], 'json'))}</pre></code>
+                                    <pre style=""><code style="white-space: pre-wrap;  word-wrap: break-word;">${unsafeHTML(Prism.highlight(JSON.stringify(i[1], null, 2), Prism.languages['json'], 'json'))}</pre></code>
                                 </td>
                             </tr>`
                     }

ui/src/components/transaction/response-body.css.ts

@@ -7,10 +7,17 @@ export default css`
   }
 
   pre {
-    max-width: calc(100vw - 135px);
-    overflow-x: auto;
+    max-width: 960px;
+    word-wrap: break-word;
+    white-space: pre-wrap;
   }
 
 
+  pre code {
+    white-space: pre-wrap;
+    word-wrap: break-word;
+  }
+
+
 
 `

ui/src/components/transaction/response-body.ts

@@ -35,10 +35,6 @@ export class ResponseBodyViewComponent extends LitElement {
         </span>`;
 
         switch (exct) {
-            case ContentTypeJSON:
-                return html`${ct}
-                <pre><code>${unsafeHTML(Prism.highlight(JSON.stringify(JSON.parse(this._httpResponse.responseBody), null, 2),
-                        Prism.languages.json, 'json'))}</code></pre>`;
             case ContentTypeXML:
                 return html`
                     <pre><code>${unsafeHTML(Prism.highlight(JSON.stringify(JSON.parse(this._httpResponse.responseBody), null, 2),
@@ -57,7 +53,8 @@ export class ResponseBodyViewComponent extends LitElement {
 
             default:
                 return html`${ct}
-                <pre>${this._httpResponse.responseBody}</pre>`
+                <pre><code>${unsafeHTML(Prism.highlight(JSON.stringify(JSON.parse(this._httpResponse.responseBody), null, 2),
+                        Prism.languages.json, 'json'))}</code></pre>`;
         }
     }
 

ui/src/components/transaction/transaction-view.css.ts

@@ -163,4 +163,8 @@ export default css`
     color: var(--error-color);
   }
 
+  .response-code {
+    font-size: 0.8rem;
+  }
+
 `

ui/src/components/transaction/transaction-view.ts

@@ -7,7 +7,11 @@ import transactionViewComponentCss from "./transaction-view.css";
 import {KVViewComponent} from "@/components/kv-view/kv-view";
 import sharedCss from "@/components/shared.css";
 import {SlTab, SlTabGroup} from "@shoelace-style/shoelace";
-import {ExtractHTTPCodeDefinition, ExtractStatusStyleFromCode} from "@/model/extract_status";
+import {
+    ExtractHTTPCodeDefinition,
+    ExtractHTTPCodeDescription,
+    ExtractStatusStyleFromCode
+} from "@/model/extract_status";
 import {LinkMatch, TransactionLinkCache} from "@/model/link_cache";
 import {HttpTransactionItemComponent} from "@/components/transaction/transaction-item";
 import {HttpTransactionSelectedEvent, ViolationLocation} from "@/model/events";
@@ -267,7 +271,10 @@ export class HttpTransactionViewComponent extends LitElement {
                             <sl-tab slot="nav" panel="response-cookies" class="tab-secondary">Cookies</sl-tab>
                             <sl-tab-panel name="response-code">
                                 <h2 class="${ExtractStatusStyleFromCode(resp)}">${resp.statusCode}</h2>
-                                <p class="response-code">${ExtractHTTPCodeDefinition(resp)}</p>
+                                <h3>${ExtractHTTPCodeDefinition(resp)}</h3>
+                                <p class="response-code">
+                                   ${ExtractHTTPCodeDescription(resp)}
+                                </p>
                             </sl-tab-panel>
                             <sl-tab-panel name="response-headers">
                                 ${this._responseHeadersView}