Added support for self signed/insecure SSL certs by introducing the --insecure flag

Author: mkherlakian

pkg/cmd/root.go

@@ -5,7 +5,7 @@ Licensed under the Apache License, Version 2.0 (the "License");
 you may not use this file except in compliance with the License.
 You may obtain a copy of the License at
 
-    http://www.apache.org/licenses/LICENSE-2.0
+	http://www.apache.org/licenses/LICENSE-2.0
 
 Unless required by applicable law or agreed to in writing, software
 distributed under the License is distributed on an "AS IS" BASIS,
@@ -94,6 +94,7 @@ func init() {
 	rootCmd.PersistentFlags().StringVar(&Config.ProfilesFile, "config", "", "config file (default is $HOME/.config/hookdeck/config.toml)")
 	rootCmd.PersistentFlags().StringVar(&Config.Profile.DeviceName, "device-name", "", "device name")
 	rootCmd.PersistentFlags().StringVar(&Config.LogLevel, "log-level", "info", "log level (debug, info, warn, error)")
+	rootCmd.PersistentFlags().BoolVar(&Config.Insecure, "insecure", false, "Allow invalid TLS certificates")
 	rootCmd.PersistentFlags().StringVarP(&Config.Profile.ProfileName, "project-name", "p", "default", "the project name to read from for config")
 
 	// Hidden configuration flags, useful for dev/debugging

pkg/config/config.go

@@ -37,6 +37,7 @@ type Config struct {
 	ProfilesFile     string
 	APIBaseURL       string
 	DashboardBaseURL string
+	Insecure         bool
 }
 
 // GetConfigFolder retrieves the folder where the profiles file is stored

pkg/listen/listen.go

@@ -5,7 +5,7 @@ Licensed under the Apache License, Version 2.0 (the "License");
 you may not use this file except in compliance with the License.
 You may obtain a copy of the License at
 
-    http://www.apache.org/licenses/LICENSE-2.0
+	http://www.apache.org/licenses/LICENSE-2.0
 
 Unless required by applicable law or agreed to in writing, software
 distributed under the License is distributed on an "AS IS" BASIS,
@@ -114,6 +114,7 @@ func Listen(URL *url.URL, source_alias string, connection_query string, flags Fl
 		NoWSS:            flags.NoWSS,
 		URL:              URL,
 		Log:              log.StandardLogger(),
+		Insecure:         config.Insecure,
 	}, source, connections)
 
 	err = p.Run(context.Background())

pkg/proxy/proxy.go

@@ -2,6 +2,7 @@ package proxy
 
 import (
 	"context"
+	"crypto/tls"
 	"encoding/json"
 	"errors"
 	"fmt"
@@ -44,7 +45,8 @@ type Config struct {
 	PrintJSON bool
 	Log       *log.Logger
 	// Force use of unencrypted ws:// protocol instead of wss://
-	NoWSS bool
+	NoWSS    bool
+	Insecure bool
 }
 
 // A Proxy opens a websocket connection with Hookdeck, listens for incoming
@@ -246,13 +248,18 @@ func (p *Proxy) processAttempt(msg websocket.IncomingMessage) {
 		fmt.Println(webhookEvent.Body.Request.DataString)
 	} else {
 		url := p.cfg.URL.Scheme + "://" + p.cfg.URL.Host + p.cfg.URL.Path + webhookEvent.Body.Path
+		tr := &http.Transport{
+			TLSClientConfig: &tls.Config{InsecureSkipVerify: p.cfg.Insecure},
+		}
 
 		timeout := webhookEvent.Body.Request.Timeout
 		if timeout == 0 {
 			timeout = 1000 * 30
 		}
+
 		client := &http.Client{
-			Timeout: time.Duration(timeout) * time.Millisecond,
+			Timeout:   time.Duration(timeout) * time.Millisecond,
+			Transport: tr,
 		}
 
 		req, err := http.NewRequest(webhookEvent.Body.Request.Method, url, nil)