add go-beego

Author: shahidhk

go-beego/.dockerignore

@@ -0,0 +1 @@
+vendor/

go-beego/.gitignore

@@ -0,0 +1,2 @@
+vendor/
+main-bin

go-beego/Dockerfile

@@ -0,0 +1,32 @@
+FROM golang:1.8.5-jessie
+
+# install required debian packages
+# add any package that is required after `build-essential`, end the line with \
+RUN apt-get update && apt-get install -y \
+    build-essential \
+&& rm -rf /var/lib/apt/lists/*
+
+# install glide and gin
+RUN go get github.com/Masterminds/glide
+RUN go get github.com/codegangsta/gin
+
+# setup the working directory
+WORKDIR /go/src/app
+ADD glide.yaml glide.yaml
+ADD glide.lock glide.lock
+RUN mkdir /scripts
+ADD run-local-server.sh /scripts/run-local-server.sh
+RUN chmod +x /scripts/run-local-server.sh
+
+# install dependencies
+RUN glide install --skip-test
+
+# add source code
+ADD src src
+
+# build the source
+RUN go build src/main.go
+
+# command to be executed on running the container
+CMD ["./main"]
+

go-beego/README.md

@@ -0,0 +1,98 @@
+# go-beego
+
+[Beego](https://github.com/astaxie/beego) (a powerful web framework for [Golang](https://golang.org/)) microservice with [Glide](https://glide.sh/) for package management [codegangsta/gin](https://github.com/codegangsta/gin) for live reloading in local development.
+
+## Managing dependencies
+
+### Adding a new Golang package
+
+If you need to install a package, say `github.com/gin-contrib/authz`
+```bash
+# with docker
+
+$ cd microservices/app
+$ docker build -t hello-golang-beego-app .
+$ docker run --rm -it -v $(pwd):/go/src/app \
+             hello-golang-beego-app \
+             glide get github.com/gin-contrib/authz
+
+
+# without docker
+
+$ cd microservices/app
+$ glide get github.com/gin-contrib/authz
+```
+This will update `glide.yaml` and `glide.lock`.
+
+### Adding a new system package
+
+The base image used in this boilerplate is [golang:1.8.5-jessie](https://hub.docker.com/_/golang/). Hence, all debian packages are available for installation. You can add a package by mentioning it in the `Dockerfile` among the existing apt-get install packages.
+
+```dockerfile
+FROM golang:1.8.5-jessie
+
+# install required debian packages
+# add any package that is required after `build-essential`, end the line with \
+RUN apt-get update && apt-get install -y \
+    build-essential \
+&& rm -rf /var/lib/apt/lists/*
+
+...
+```
+
+## Local development
+
+### With Docker
+
+- Install [Docker CE](https://docs.docker.com/engine/installation/)
+
+```bash
+# go to app directory
+$ cd microservices/app
+
+# build the docker image
+$ docker build -t hello-golang-beego-app .
+
+# run the image using either 1 or 2
+
+# 1) without live reloading
+$ docker run --rm -it -p 8080:8080 hello-golang-beego-app
+
+# 2) with live reloading
+# any change you make to your source code will be immediately updated on the running app
+# set CLUSTER_NAME
+$ docker run --rm -it -p 8080:8080 \
+             -v $(pwd):/go/src/app \
+             -e CLUSTER_NAME=[your-cluster-name]
+             hello-golang-beego-app \
+             /scripts/run-local-server.sh
+
+# app will be available at http://localhost:8080
+# press Ctrl+C to stop the server
+```
+
+### Without Docker
+
+- Install [Golang](https://golang.org/doc/install)
+- Move the `hello-golang-beego` directory to your `GOPATH` and cd into the directory
+
+```bash
+# change to app directory
+$ cd mircoservices/app
+
+# install glide for package management
+$ go get github.com/Masterminds/glide
+# install gin for live reloading
+$ go get github.com/codegangsta/gin
+
+# set CLUSTER_NAME
+$ export CLUSTER_NAME=[your-cluster-name]
+
+# run the local server script
+# windows users: run this in git bash
+$ ./run-local-server.sh
+
+# app will be available at http://localhost:8080
+# any change you make to your source code will be immediately updated on the running app
+# press Ctrl+C to stop the server
+```

go-beego/glide.lock

@@ -0,0 +1,8 @@
+package: .
+import:
+- package: github.com/astaxie/beego
+  version: ~1.9.2
+  subpackages:
+  - context
+- package: github.com/levigross/grequests
+  version: ~0.9.0

go-beego/glide.yaml

@@ -0,0 +1,67 @@
+apiVersion: v1
+items:
+- apiVersion: extensions/v1beta1
+  kind: Deployment
+  metadata:
+    creationTimestamp: null
+    labels:
+      app: app
+      hasuraService: custom
+    name: app
+    namespace: '{{ cluster.metadata.namespaces.user }}'
+  spec:
+    replicas: 1
+    strategy: {}
+    template:
+      metadata:
+        creationTimestamp: null
+        labels:
+          app: app
+      spec:
+        containers:
+        - image: hasura/base-git-image:0.7
+          imagePullPolicy: IfNotPresent
+          name: app
+          env:
+          - name: POSTGRES_HOSTNAME
+            value: postgres.{{ cluster.metadata.namespaces.hasura }}
+          - name: POSTGRES_PORT
+            value: "5432"
+          - name: POSTGRES_USERNAME
+            valueFrom:
+              secretKeyRef:
+                name: hasura-secrets
+                key: postgres.user
+          - name: POSTGRES_PASSWORD
+            valueFrom:
+              secretKeyRef:
+                name: hasura-secrets
+                key: postgres.password
+          ports:
+          - containerPort: 8080
+            protocol: TCP
+          resources: {}
+        securityContext: {}
+        terminationGracePeriodSeconds: 0
+  status: {}
+- apiVersion: v1
+  kind: Service
+  metadata:
+    creationTimestamp: null
+    labels:
+      app: app
+      hasuraService: custom
+    name: app
+    namespace: '{{ cluster.metadata.namespaces.user }}'
+  spec:
+    ports:
+    - port: 80
+      protocol: TCP
+      targetPort: 8080
+    selector:
+      app: app
+    type: ClusterIP
+  status:
+    loadBalancer: {}
+kind: List
+metadata: {}

go-beego/k8s.yaml

@@ -0,0 +1,4 @@
+#!/bin/bash
+
+glide install
+gin --path src --bin main-bin --port 8080 run main.go

go-beego/run-local-server.sh

@@ -0,0 +1,99 @@
+package main
+
+import (
+	"fmt"
+	"log"
+	"net/http"
+	"os"
+
+	"github.com/astaxie/beego"
+	"github.com/astaxie/beego/context"
+	"github.com/levigross/grequests"
+)
+
+func sayHello(ctx *context.Context) {
+	ctx.Output.Body([]byte("Hello from Beego on Hasura"))
+}
+
+// func sayPongJSON(ctx *context.Context) {
+// 	ctx.Output.JSON(map[string]string{"message": "pong"}, true, true)
+// }
+
+func main() {
+	beego.Get("/", sayHello)
+	// beego.Get("/ping", sayPongJSON)
+
+	beego.Get("/get_articles", getArticles)
+	beego.Get("/profile", getProfile)
+
+	// get port env var
+	port := "8080"
+	portEnv := os.Getenv("PORT")
+	if len(portEnv) > 0 {
+		port = portEnv
+	}
+
+	beego.Run(fmt.Sprintf("0.0.0.0:%s", port)) // listen and serve on 0.0.0.0:8080 by default
+	// set environment variable PORT if you want to change port
+}
+
+// Endpoints demonstrating Hasura Backend Features:
+func getArticles(ctx *context.Context) {
+	dataUrl := "http://data.hasura/v1/query"
+	// set data url as external one if CLUSTER_NAME is set
+	clusterName := os.Getenv("CLUSTER_NAME")
+	if len(clusterName) > 0 {
+		dataUrl = fmt.Sprintf("https://data.%s.hasura-app.io/v1/query", clusterName)
+	}
+	resp, err := grequests.Post(dataUrl,
+		&grequests.RequestOptions{
+			JSON: map[string]interface{}{
+				"type": "select",
+				"args": map[string]interface{}{
+					"table":   "article",
+					"columns": []string{"*"},
+				},
+			},
+		},
+	)
+	if err != nil {
+		log.Printf("error: %s", err)
+		ctx.Abort(http.StatusInternalServerError, err.Error())
+		return
+	}
+	if !resp.Ok {
+		err := fmt.Errorf("code: %d, data: %s", resp.StatusCode, string(resp.Bytes()))
+		log.Printf("error: %s", err)
+		ctx.Abort(http.StatusInternalServerError, err.Error())
+		return
+	}
+
+	var data interface{}
+	err = resp.JSON(&data)
+	if err != nil {
+		log.Printf("error: %s", err)
+		ctx.Abort(http.StatusInternalServerError, err.Error())
+		return
+	}
+	ctx.Output.JSON(map[string]interface{}{"response": data}, true, true)
+	return
+}
+
+func getProfile(ctx *context.Context) {
+	baseDomain := ctx.Input.Header("X-Hasura-Base-Domain")
+	if len(baseDomain) == 0 {
+		ctx.Abort(http.StatusInternalServerError, "This URL works only on Hasura clusters")
+		return
+	}
+	role := ctx.Input.Header("X-Hasura-Role")
+	if role == "user" {
+		userId := ctx.Input.Header("X-Hasura-User-Id")
+		ctx.Output.JSON(map[string]string{"userId": userId}, true, true)
+	} else {
+		redirectUrl := fmt.Sprintf(
+			"http://auth.%s/ui?redirect_to=http://app.%s/profile",
+			baseDomain, baseDomain,
+		)
+		ctx.Redirect(http.StatusTemporaryRedirect, redirectUrl)
+	}
+}