split up the content into multiple files

3 files changed, 116 insertions, 114 deletions

diff --git a/http.go b/http.go
new file mode 100644
index 0000000..7aac0c7
--- /dev/null
+++ b/http.go
@@ -0,0 +1,52 @@
+package main
+
+// locationHandlerEndpoint handles requests to the /locations endpoint
+// This is used by the grafana worldmap plugin to find out where to draw the
+// fancy circles
+func locationHandlerEndpoint(w http.ResponseWriter, r *http.Request) {
+
+	// set some headers
+	w.Header().Set("Content-Type", "application/json")
+	w.Header().Set("Access-Control-Allow-Origin", "https://grafana.nbg1.emile.space")
+
+	// start building json (yes, this is not a nice implementation, PRs welcome!)
+	fmt.Fprintf(w, "%s", "[")
+
+	var i int = 0
+	for _, v := range cities {
+
+		// print the "json" object containing the metrics needed
+		fmt.Fprintf(w, "{")
+		fmt.Fprintf(w, "\"key\": \"%s\",", v.key)
+		fmt.Fprintf(w, "\"latitude\": %f,", v.latitude)
+		fmt.Fprintf(w, "\"longitude\": %f,", v.longitude)
+		fmt.Fprintf(w, "\"name\": \"%s\"", v.name)
+
+		// close the object (this handles the trailing comma problem)
+		if i == len(cities) - 1 {
+			fmt.Fprintf(w, "}")
+		} else {
+			fmt.Fprintf(w, "},")
+		}
+		i++
+	}
+	fmt.Fprintf(w, "%s", "]")
+}
+
+// indexHandler handles the request to the / endpoint
+// It simply returns a link to the /metrics page
+func indexHandler(w http.ResponseWriter, req *http.Request) {
+	_, _ = fmt.Fprintf(w, "<a href='/metrics'>metrics</a>")
+}
+
+// Handle HTTP requests to the /metrics endpoint
+func metricsHandler(w http.ResponseWriter, req *http.Request) {
+
+	// return the overall amount of passwords catched
+	fmt.Fprintf(w, "num_passwords %d\n", metrics_num_passwords)
+
+	// return the amount of passwords catched from a given city
+	for k, v := range metrics_city_num {
+		fmt.Fprintf(w, "a_metric{city=\"%s\"} %d\n", strings.ToLower(k), v)
+	}
+}
\ No newline at end of file
diff --git a/main.go b/main.go
index b4a660a..ee3938e 100644
--- a/main.go
+++ b/main.go
@@ -71,117 +71,4 @@ func main() {
 	if listenErr != nil {
 		log.Fatalln(listenErr.Error())
 	}
-}
-
-// locationHandlerEndpoint handles requests to the /locations endpoint
-// This is used by the grafana worldmap plugin to find out where to draw the
-// fancy circles
-func locationHandlerEndpoint(w http.ResponseWriter, r *http.Request) {
-
-	// set some headers
-	w.Header().Set("Content-Type", "application/json")
-	w.Header().Set("Access-Control-Allow-Origin", "https://grafana.nbg1.emile.space")
-
-	// start building json (yes, this is not a nice implementation, PRs welcome!)
-	fmt.Fprintf(w, "%s", "[")
-
-	var i int = 0
-	for _, v := range cities {
-
-		// print the "json" object containing the metrics needed
-		fmt.Fprintf(w, "{")
-		fmt.Fprintf(w, "\"key\": \"%s\",", v.key)
-		fmt.Fprintf(w, "\"latitude\": %f,", v.latitude)
-		fmt.Fprintf(w, "\"longitude\": %f,", v.longitude)
-		fmt.Fprintf(w, "\"name\": \"%s\"", v.name)
-
-		// close the object (this handles the trailing comma problem)
-		if i == len(cities) - 1 {
-			fmt.Fprintf(w, "}")
-		} else {
-			fmt.Fprintf(w, "},")
-		}
-		i++
-	}
-	fmt.Fprintf(w, "%s", "]")
-}
-
-// Handling incoming SSH connections
-func handlePass(ctx ssh.Context, pass string) bool {
-
-	// increase the counter tracking the amount of passwords catched
-	metrics_num_passwords++
-	log.Printf("%s@%s: '%s'", ctx.User(), ctx.RemoteAddr().String(), pass)
-
-	// get the ip of the remote user
-	stringip := strings.Split(ctx.RemoteAddr().String(), ":")[0]
-
-	// Define the request string for the geoip service
-	requestString := fmt.Sprintf("%s%s", "http://ip-api.com/json/", stringip)
-
-	// Send the GET request
-	resp, err := http.Get(requestString)
-	if err != nil {
-		log.Fatal(err)
-	}
-
-	// if the response status code from the geoip service is not a 200 code, return false
-	if resp.StatusCode != 200 {
-		return false
-	}
-
-	// Read the response
-	body, err := ioutil.ReadAll(resp.Body)
-	if err != nil {
-		log.Fatal(err)
-	}
-
-	// Unmarshal the response to json
-	var result geoipresult
-	err = json.Unmarshal(body, &result)
-	if err != nil {
-		fmt.Println("JSON ERROR, abort mission!")
-		log.Fatal(err)
-	}
-
-	// if an entry for the city does not exists yet, create the city
-	// if the city does allready exist, increase it's value by one
-	if metrics_city_num[result.City] == 0 {
-		metrics_city_num[result.City] = 1
-	} else {
-		metrics_city_num[result.City] += 1
-	}
-
-	// if the actual city is not known, create the city
-	// this is used for the grafana worldmap plugin
-	if (cities[result.City] == location{}) {
-		newCity := location{
-			key:       strings.ToLower(result.City),
-			latitude:  result.Lat,
-			longitude: result.Lon,
-			name:      result.City,
-		}
-
-		cities[result.City] = newCity
-	}
-
-	return false
-}
-
-// Handle HTTP requests to the /metrics endpoint
-func metricsHandler(w http.ResponseWriter, req *http.Request) {
-
-	// return the overall amount of passwords catched
-	fmt.Fprintf(w, "num_passwords %d\n", metrics_num_passwords)
-
-	// return the amount of passwords catched from a given city
-	for k, v := range metrics_city_num {
-		fmt.Fprintf(w, "a_metric{city=\"%s\"} %d\n", strings.ToLower(k), v)
-	}
-}
-
-// indexHandler handles the request to the / endpoint
-// It simply returns a link to the /metrics page
-func indexHandler(w http.ResponseWriter, req *http.Request) {
-	_, _ = fmt.Fprintf(w, "<a href='/metrics'>metrics</a>")
-}
+}
\ No newline at end of file
diff --git a/ssh.go b/ssh.go
new file mode 100644
index 0000000..fbbfc9c
--- /dev/null
+++ b/ssh.go
@@ -0,0 +1,63 @@
+package main
+
+// Handling incoming SSH connections
+func handlePass(ctx ssh.Context, pass string) bool {
+
+	// increase the counter tracking the amount of passwords catched
+	metrics_num_passwords++
+	log.Printf("%s@%s: '%s'", ctx.User(), ctx.RemoteAddr().String(), pass)
+
+	// get the ip of the remote user
+	stringip := strings.Split(ctx.RemoteAddr().String(), ":")[0]
+
+	// Define the request string for the geoip service
+	requestString := fmt.Sprintf("%s%s", "http://ip-api.com/json/", stringip)
+
+	// Send the GET request
+	resp, err := http.Get(requestString)
+	if err != nil {
+		log.Fatal(err)
+	}
+
+	// if the response status code from the geoip service is not a 200 code, return false
+	if resp.StatusCode != 200 {
+		return false
+	}
+
+	// Read the response
+	body, err := ioutil.ReadAll(resp.Body)
+	if err != nil {
+		log.Fatal(err)
+	}
+
+	// Unmarshal the response to json
+	var result geoipresult
+	err = json.Unmarshal(body, &result)
+	if err != nil {
+		fmt.Println("JSON ERROR, abort mission!")
+		log.Fatal(err)
+	}
+
+	// if an entry for the city does not exists yet, create the city
+	// if the city does allready exist, increase it's value by one
+	if metrics_city_num[result.City] == 0 {
+		metrics_city_num[result.City] = 1
+	} else {
+		metrics_city_num[result.City] += 1
+	}
+
+	// if the actual city is not known, create the city
+	// this is used for the grafana worldmap plugin
+	if (cities[result.City] == location{}) {
+		newCity := location{
+			key:       strings.ToLower(result.City),
+			latitude:  result.Lat,
+			longitude: result.Lon,
+			name:      result.City,
+		}
+
+		cities[result.City] = newCity
+	}
+
+	return false
+}
\ No newline at end of file