Ping Trigger

go.mod

@@ -1,4 +1,4 @@
-module github.com/project-flogo/contrib
+module github.com/AkshayGadikar/contrib
 
 require (
 	github.com/carlescere/scheduler v0.0.0-20170109141437-ee74d2f83d82

trigger/ping/examples/ping/README.md

@@ -0,0 +1,49 @@
+# Flogo Ping Example
+
+## Install
+
+To install run the following commands:
+```
+flogo create -f flogo.json
+cd Ping
+flogo build
+```
+
+## Testing
+
+Run:
+```
+bin/Ping
+```
+
+Then open another terminal and run:
+```
+curl http://localhost:9096/ping/details
+```
+
+You should then see something like:
+```
+{
+   "Version":"1.1",
+   "Appversion":"",
+   "Appdescription":""
+}Details:{
+   "NumGoroutine":2,
+   "Alloc":762472,
+   "TotalAlloc":762472,
+   "Sys":69926912,
+   "Mallocs":1078,
+   "Frees":101,
+   "LiveObjects":977,
+   "NumGC":0
+}
+```
+#####
+```
+curl http://localhost:9096/ping
+```
+
+You should then see something like:
+```
+{"response":"Ping successful"}
+```

trigger/ping/examples/ping/flogo.json

@@ -0,0 +1,25 @@
+{
+  "name": "Ping",
+  "type": "flogo:app",
+  "version": "1.0.0",
+  "title": "Ping Trigger",
+  "description": "This is a simple ping example.",
+  "triggers": [
+    {
+      "name": "ping",
+      "id": "flogo-ping",
+      "ref": "github.com/project-flogo/contrib/trigger/ping",
+      "description": "Ping Example",
+      "settings": {
+        "port": "9096",
+        "version": "1.1",
+        "appversion":"",
+        "appdescription":"",
+        "password":"Test12345"
+      },
+      "handlers": []
+    }
+  ],
+  "actions": [],
+  "resources": []
+}

trigger/ping/metadata.go

@@ -0,0 +1,59 @@
+package ping
+
+import(
+	"runtime"
+	"encoding/json"
+	"strings"
+)
+
+const password = "Test12345"
+
+type Settings struct {
+	Port 		int 	`md:"port,required"`
+	Version 	string 	`md:"version"`
+	AppVersion 	string 	`md:"appversion"`
+	AppDescription 	string 	`md:"appdescription"`
+	Password	string	`md:"password"`
+}
+
+type MemoryStats struct{
+	NumGoroutine 	int
+	Alloc,
+	TotalAlloc,
+	Sys,
+	Mallocs,
+	Frees,
+	LiveObjects	uint64
+	NumGC		uint32
+}
+
+func PrintMemUsage() string{
+	var rtm runtime.MemStats
+	runtime.ReadMemStats(&rtm)
+	var t MemoryStats
+
+	t.NumGoroutine = runtime.NumGoroutine()
+
+	// Misc memory stats
+	t.Alloc = rtm.Alloc
+	t.TotalAlloc = rtm.TotalAlloc
+	t.Sys = rtm.Sys
+	t.Mallocs = rtm.Mallocs
+	t.Frees = rtm.Frees
+
+	// Live objects = Mallocs - Frees
+	t.LiveObjects = t.Mallocs - t.Frees
+
+	//GC stats
+	t.NumGC = rtm.NumGC
+
+	result, _ := json.Marshal(t)
+	return string(result)
+}
+
+func Valid(token string) bool{
+	if strings.Compare(token, password) == 0{
+		return true
+	}
+	return false
+}

trigger/ping/trigger.go

@@ -0,0 +1,131 @@
+package ping
+
+import (
+	"fmt"
+	"strconv"
+	"encoding/json"
+	"io"
+	"net/http"
+	"github.com/project-flogo/core/trigger"
+)
+
+// DefaultPort is the default port for Ping service
+const DefaultPort = "9096"
+
+var triggerMd = trigger.NewMetadata(&Settings{})
+var statsResult string
+
+func init() {
+	trigger.Register(&Trigger{}, &Factory{})
+}
+
+type Factory struct {
+}
+
+// Metadata implements trigger.Factory.Metadata
+func (*Factory) Metadata() *trigger.Metadata {
+	return triggerMd
+}
+
+// Trigger is the ping trigger
+type Trigger struct {
+	metadata *trigger.Metadata
+	config   *trigger.Config
+	response string
+	Server *http.Server
+}
+
+// New implements trigger.Factory.New
+func (f *Factory) New(config *trigger.Config) (trigger.Trigger, error) {
+	type PingResponse struct {
+		Version        	string
+		Appversion     	string
+		Appdescription 	string
+	}
+	response := PingResponse{
+		Version:        config.Settings["version"].(string),
+		Appversion:     config.Settings["appversion"].(string),
+		Appdescription: config.Settings["appdescription"].(string),
+	}
+
+	data, err := json.Marshal(response)
+	if err != nil {
+		fmt.Errorf("Ping service data formation error",err)
+	}
+
+	port := strconv.Itoa(config.Settings["port"].(int))
+	if len(port) == 0 {
+		port = DefaultPort
+	}
+
+	mux := http.NewServeMux()
+	server := &http.Server{
+		Addr:    ":" + port,
+		Handler: mux,
+	}
+	trigger := &Trigger{
+		metadata: f.Metadata(),
+		config:   config,
+		response: string(data),
+		Server: server,
+	}
+	mux.HandleFunc("/ping", trigger.PingResponseHandlerShort)
+	mux.HandleFunc("/ping/details", trigger.PingResponseHandlerDetail)
+	statsResult = PrintMemUsage()
+	return trigger, nil
+}
+
+// Init implements trigger.Init
+func (t *Trigger) Initialize(ctx trigger.InitContext) error {
+	return nil
+}
+
+func (t *Trigger) PingResponseHandlerShort(w http.ResponseWriter, req *http.Request) {
+	token := t.config.Settings["password"].(string)
+	if(Valid(token)) {
+		io.WriteString(w, "{\"response\":\"Ping successful\"}\n")
+	}else{
+		io.WriteString(w, "Error : Invalid User !! \n")
+	}
+}
+
+//PingResponseHandlerDetail handles simple response
+func (t *Trigger) PingResponseHandlerDetail(w http.ResponseWriter, req *http.Request) {
+	token := t.config.Settings["password"].(string)
+	if(Valid(token)) {
+		io.WriteString(w, t.response + "\n")
+		io.WriteString(w, "Details :\n")
+		io.WriteString(w, statsResult + "\n")
+	}else{
+		io.WriteString(w, "Error : Invalid User !! \n")
+	}
+
+	//Another way to get trace : more details
+	/*
+	tr := trace.New("TraceTest", req.URL.Path)
+	defer tr.Finish()
+	fmt.Println(reflect.TypeOf(tr).String())
+	fmt.Println("Trace:")
+	fmt.Printf("%+v\n", tr)
+	fmt.Println(tr)*/
+}
+
+// Start implements util.Managed.Start
+func (t *Trigger) Start() error {
+	go func() {
+		if err := t.Server.ListenAndServe(); err != http.ErrServerClosed {
+			fmt.Errorf("Ping service err:", err)
+		}
+	}()
+	return nil
+}
+
+// Stop implements util.Managed.Stop
+func (t *Trigger) Stop() error {
+	if err := t.Server.Shutdown(nil); err != nil {
+		fmt.Errorf("[mashling-ping-service] Ping service error when stopping:", err)
+		return err
+	}
+	return nil
+}
+