payload.go RawHistoryFolder

1package common
2
3import (
4	"encoding/json"
5	"fmt"
6
7	"io"
8)
9
10type RequestPayload struct {
11	Type    string  `json:"type"`
12	Payload Payload `json:"payload"`
13}
14
15type Payload interface {
16	GetType() string
17}
18
19func (p *RequestPayload) UnmarshalJSON(data []byte) error {
20	var raw map[string]json.RawMessage
21	err := json.Unmarshal(data, &raw)
22	if err != nil {
23		return err
24	}
25
26	if err := json.Unmarshal(raw["type"], &p.Type); err != nil {
27		return err
28	}
29
30	switch p.Type {
31	case "ping":
32		var payload PingPayload
33		if err := json.Unmarshal(raw["payload"], &payload); err != nil {
34			return err
35		}
36		p.Payload = payload
37	case "deploy":
38		var payload DeployPayload
39		if err := json.Unmarshal(raw["payload"], &payload); err != nil {
40			return err
41		}
42		p.Payload = payload
43	}
44	return nil
45}
46
47type PingPayload struct {
48	Message string `json:"message"`
49}
50
51func (p PingPayload) GetType() string {
52	return "ping"
53}
54
55func (p DeployPayload) GetType() string {
56	return "deploy"
57}
58
59func NewPingPayload(data map[string]interface{}) (PingPayload, error) {
60	message, ok := data["message"].(string)
61	if !ok {
62		return PingPayload{}, fmt.Errorf("invalid data for message")
63	}
64	return PingPayload{Message: message}, nil
65}
66
67// What do we need inside the deploy payload :
68// the ports as a string (80:80/tcp, 443:443/tcp)
69// the image+tag as a string (nginx:latest)
70// the .tar container image as a byte array
71
72type DeployPayload struct {
73	Ports        string `json:"ports"`
74	TargetDomain string `json:"targetdomain"`
75	ImageName    string `json:"imagename"`
76	ImageID      string `json:"imageid"`
77	Data         io.ReadCloser
78}