mvp baby

Author: jhrv

cmd/apiserver/main.go

@@ -0,0 +1,70 @@
+package main
+
+import (
+	"database/sql"
+	"encoding/json"
+	"fmt"
+	"net/http"
+
+	_ "github.com/lib/pq"
+)
+
+type Client struct {
+	PSK string `json:"psk"`
+	Peer
+}
+
+type Peer struct {
+	PublicKey string `json:"public_key"`
+	IP        string `json:"ip"`
+}
+
+type GatewayResponse struct {
+	Clients []Client `json:"clients"`
+}
+
+func main() {
+	http.HandleFunc("/gateways/gw0", func(w http.ResponseWriter, _ *http.Request) {
+		postgresConnection := fmt.Sprintf("user=%s password=%s dbname=%s host=%s sslmode=disable",
+			"postgres",
+			"asdf",
+			"postgres",
+			"localhost")
+
+		db, err := sql.Open("postgres", postgresConnection)
+		if err != nil {
+			panic(fmt.Sprintf("failed to connect to database, error was: %s", err))
+		}
+
+		rows, err := db.Query(`
+            SELECT public_key, ip, psk from peer
+            JOIN client c on peer.id = c.peer_id
+            JOIN ip i on peer.id = i.peer_id
+		`)
+
+		if err != nil {
+			panic(err)
+		}
+
+		var resp GatewayResponse
+
+		for rows.Next() {
+			var client Client
+
+			err := rows.Scan(&client.PublicKey, &client.IP, &client.PSK)
+
+			if err != nil {
+				panic(err)
+			}
+
+			resp.Clients = append(resp.Clients, client)
+		}
+
+		w.WriteHeader(http.StatusOK)
+		json.NewEncoder(w).Encode(resp)
+	})
+
+	bindAddr := fmt.Sprintf("%s:%d", "127.0.0.1", 6969)
+	fmt.Println("running @", bindAddr)
+	fmt.Println((&http.Server{Addr: bindAddr}).ListenAndServe())
+}

db-bootstrap.sql

@@ -0,0 +1,7 @@
+INSERT INTO public.client (peer_id, serial, psk, healthy, last_check) VALUES (1, 'serial', 'pskkk', true, '2020-03-26 12:26:32.000000');
+INSERT INTO public.gateway (peer_id, id, access_group_id, endpoint) VALUES (2, 1, '1234-asdf-aad', '1.2.3.4:1234');
+INSERT INTO public.ip (peer_id, ip) VALUES (1, '10.1.1.1');
+INSERT INTO public.ip (peer_id, ip) VALUES (2, '10.1.1.2');
+INSERT INTO public.peer (id, public_key, kind) VALUES (1, 'publickey', 'client');
+INSERT INTO public.peer (id, public_key, kind) VALUES (2, 'pk-gw', 'gateway');
+INSERT INTO public.routes (gateway_id, cidr) VALUES (1, '1.2.3.4/23');

model.sql

@@ -1,7 +1,7 @@
 CREATE TABLE peer (
   id serial PRIMARY KEY,
   public_key varchar(44) NOT NULL UNIQUE,
-  kind integer NOT NULL
+  kind varchar(7) NOT NULL
 );
 
 CREATE TABLE client (

setup-gcp.sh

@@ -0,0 +1,4 @@
+gcloud beta compute --project=nais-device instances create gateway-1 --zone=europe-north1-a --machine-type=f1-micro --tags=wireguard-gateway --image=ubuntu-1804-bionic-v20200317 --image-project=ubuntu-os-cloud
+
+gcloud compute --project=nais-device firewall-rules create allow-wireguard --direction=INGRESS --priority=1000 --network=default --action=ALLOW --rules=udp:51820 --source-ranges=0.0.0.0/0 --target-tags=wireguard-gateway # wireguard firewall
+