From ec64d869884ac3217663952f934f19bda6de973a Mon Sep 17 00:00:00 2001
From: Alexandr Krylovskiy <alexandr.krylovskiy@gmail.com>
Date: Sun, 5 Oct 2014 15:40:41 +0200
Subject: [PATCH] Enable SSL/TLS communication through -ssl flag

---
 influx-cli.go | 7 +++++++
 1 file changed, 7 insertions(+)

diff --git a/influx-cli.go b/influx-cli.go
index 2b3736b..c26d5d6 100644
--- a/influx-cli.go
+++ b/influx-cli.go
@@ -56,6 +56,7 @@ var asyncInserts chan *client.Series
 var asyncInsertsCommitted chan int
 var forceInsertsFlush chan bool
 var sync_inserts_timer metrics.Timer
+var ssl bool
 
 var path_rc, path_hist string
 
@@ -123,6 +124,7 @@ type Config struct {
 	User          string
 	Pass          string
 	Db            string
+	Ssl           bool
 	AsyncCapacity int
 	AsyncMaxWait  int
 }
@@ -138,6 +140,7 @@ func init() {
 	flag.StringVar(&db, "db", "", "database to use")
 	flag.BoolVar(&recordsOnly, "recordsOnly", false, "when enabled, doesn't display header")
 	flag.BoolVar(&async, "async", false, "when enabled, asynchronously flushes inserts")
+	flag.BoolVar(&ssl, "ssl", false, "when enabled, uses SSL/TLS for communication")
 
 	flag.Usage = func() {
 		fmt.Fprintln(os.Stderr, "Usage: influx-cli [flags] [query to execute on start]")
@@ -261,6 +264,7 @@ func getClient() error {
 		Username: user,
 		Password: pass,
 		Database: db,
+		IsSecure: ssl,
 	}
 	var err error
 	cl, err = client.NewClient(cfg)
@@ -316,6 +320,9 @@ func main() {
 	if conf.Db != "" {
 		db = conf.Db
 	}
+	if conf.Ssl != false {
+		ssl = conf.Ssl
+	}
 	if conf.AsyncCapacity > 0 {
 		AsyncCapacity = conf.AsyncCapacity
 	}