lib/apiv1/events.go

   1 package apiv1
   2
   3 import (
   4         "encoding/json"
   5         "fmt"
   6 )
   7
   8 // EventRegisterArgs is the parameters (json format) of /events/register command
   9 type EventRegisterArgs struct {
  10         Name      string `json:"name"`
  11         ProjectID string `json:"filterProjectID"`
  12 }
  13
  14 // EventUnRegisterArgs is the parameters (json format) of /events/unregister command
  15 type EventUnRegisterArgs struct {
  16         Name string `json:"name"`
  17         ID   int    `json:"id"`
  18 }
  19
  20 // Events Type definitions
  21 const (
  22         // EventTypePrefix Used as event prefix
  23         EventTypePrefix = "event:" // following by event type
  24
  25         // Supported Events type
  26         EVTAll           = EventTypePrefix + "all"
  27         EVTServerConfig  = EventTypePrefix + "server-config"        // type EventMsg with Data type apiv1.ServerCfg
  28         EVTProjectAdd    = EventTypePrefix + "project-add"          // type EventMsg with Data type apiv1.ProjectConfig
  29         EVTProjectDelete = EventTypePrefix + "project-delete"       // type EventMsg with Data type apiv1.ProjectConfig
  30         EVTProjectChange = EventTypePrefix + "project-state-change" // type EventMsg with Data type apiv1.ProjectConfig
  31 )
  32
  33 // EVTAllList List of all supported events
  34 var EVTAllList = []string{
  35         EVTServerConfig,
  36         EVTProjectAdd,
  37         EVTProjectDelete,
  38         EVTProjectChange,
  39 }
  40
  41 // EventMsg Event message send over Websocket, data format depend to Type (see DecodeXXX function)
  42 type EventMsg struct {
  43         Time string      `json:"time"`
  44         Type string      `json:"type"`
  45         Data interface{} `json:"data"`
  46 }
  47
  48 // DecodeServerCfg Helper to decode Data field type ServerCfg
  49 func (e *EventMsg) DecodeServerCfg() (ServerCfg, error) {
  50         p := ServerCfg{}
  51         if e.Type != EVTServerConfig {
  52                 return p, fmt.Errorf("Invalid type")
  53         }
  54         d, err := json.Marshal(e.Data)
  55         if err == nil {
  56                 err = json.Unmarshal(d, &p)
  57         }
  58         return p, err
  59 }
  60
  61 // DecodeProjectConfig Helper to decode Data field type ProjectConfig
  62 func (e *EventMsg) DecodeProjectConfig() (ProjectConfig, error) {
  63         var err error
  64         p := ProjectConfig{}
  65         switch e.Type {
  66         case EVTProjectAdd, EVTProjectChange, EVTProjectDelete:
  67                 d := []byte{}
  68                 d, err = json.Marshal(e.Data)
  69                 if err == nil {
  70                         err = json.Unmarshal(d, &p)
  71                 }
  72         default:
  73                 err = fmt.Errorf("Invalid type")
  74         }
  75         return p, err
  76 }