plugin-request/main.go at master · getcasa/plugin-request · GitHub

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
package main

import (
	"encoding/json"
	"fmt"
	"net/http"
	"time"

	"github.com/getcasa/sdk"
)

func main() {}

// Config set the plugin config
var Config = sdk.Configuration{
	Name:        "request",
	Version:     "1.0.0",
	Author:      "amoinier",
	Description: "Send request",
	Discover:    false,
	Devices: []sdk.Device{
		sdk.Device{
			Name:           "get",
			DefaultTrigger: "",
			DefaultAction:  "get",
			Config: []sdk.DeviceConfig{
				sdk.DeviceConfig{
					Name: "Link",
					Type: "string",
				},
			},
			Triggers: []sdk.Trigger{},
			Actions:  []string{"get"},
		},
		sdk.Device{
			Name:           "post",
			DefaultTrigger: "",
			DefaultAction:  "post",
			Config: []sdk.DeviceConfig{
				sdk.DeviceConfig{
					Name: "Link",
					Type: "string",
				},
			},
			Triggers: []sdk.Trigger{},
			Actions:  []string{"post"},
		},
	},
	Actions: []sdk.Action{
		sdk.Action{
			Name:   "get",
			Fields: []sdk.Field{},
		},
		sdk.Action{
			Name: "post",
			Fields: []sdk.Field{
				sdk.Field{
					Name:   "CtnType",
					Type:   "string",
					Config: true,
				},
				sdk.Field{
					Name:   "Values",
					Type:   "string",
					Config: true,
				},
			},
		},
	},
}

// ConfigDevice define config for device
type ConfigDevice struct {
	Link string
}

// Params define action parameters available
type Params struct {
	CtnType string
	Values  string
}

var client http.Client

// OnStart create http client
func OnStart(config []byte) {
	client = http.Client{
		Timeout: time.Second * 5,
	}
}

// CallAction call functions from actions
func CallAction(physicalID string, name string, params []byte, config []byte) {
	if string(params) == "" {
		fmt.Println("Params must be provided")
	}
	if string(config) == "" {
		fmt.Println("Configs must be provided")
	}

	var conf ConfigDevice
	var marshalParam Params

	json.Unmarshal(config, &conf)
	json.Unmarshal(params, &marshalParam)

	// use name to call actions
	switch name {
	case "get":
		Get(conf.Link)
	case "post":
		Post(conf.Link, marshalParam.CtnType, marshalParam.Values)
	default:
		return
	}
}

// OnStop close connection
func OnStop() {
}