messages.go

package ari

import "encoding/json"

// Package models implements the Asterisk ARI Messages structures.  See https://wiki.asterisk.org/wiki/display/AST/Asterisk+12+REST+Data+Models

type StasisStart struct {
	Event
	Args           []string
	Channel        *Channel
	ReplaceChannel *Channel `json:"replace_channel"`
}

type StasisEnd struct {
	Event
	Channel *Channel
}

type ChannelVarset struct {
	Event
	Channel  *Channel // optionnal
	Value    string
	Variable string
}

type BridgeCreated struct {
	Event
	Bridge *Bridge
}

type BridgeDestroyed struct {
	Event
	Bridge *Bridge
}

type BridgeMerged struct {
	Event
	Bridge     *Bridge
	BridgeFrom *Bridge `json:"bridge_from"`
}

type BridgeBlindTransfer struct {
	Event
	Bridge         *Bridge
	Channel        *Channel
	Context        string
	Exten          string
	IsExternal     bool     `json:"is_external"`
	ReplaceChannel *Channel `json:"replace_channel"`
	Result         string
	Transferee     *Channel
}

type BridgeAttendedTransfer struct {
	Event
	DestinationApplication     string   `json:"destination_application"`
	DestinationBridge          string   `json:"destination_bridge"`
	DestinationLinkFirstLeg    *Channel `json:"destination_link_first_leg"`
	DestinationLinkSecondLeg   *Channel `json:"destination_link_second_leg"`
	DestinationThreeWayBridge  *Bridge  `json:"destination_three_way_bridge"`
	DestinationThreeWayChannel *Channel `json:"destination_three_way_channel"`
	DestinationType            string   `json:"destination_type"`
	IsExternal                 bool     `json:"is_external"`
	ReplaceChannel             *Channel `json:"replace_channel"`
	Result                     string
	TransferTarget             *Channel `json:"transfer_target"`
	Transferee                 *Channel
	TransfererFirstLeg         *Channel `json:"transferer_first_leg"`
	TransfererFirstLegBridge   *Bridge  `json:"transferer_first_leg_bridge"`
	TransfererSecondLeg        *Channel `json:"transferer_second_leg"`
	TransfererSecondLegBridge  *Bridge  `json:"transferer_second_leg_bridge"`
}

type ChannelHangupRequest struct {
	Event
	Cause   int
	Channel *Channel
	Soft    bool
}

type ChannelDtmfReceived struct {
	Event
	Channel    *Channel
	Digit      string
	DurationMs int `json:"duration_ms"`
}

type ChannelTalkingStarted struct {
	Event
	Channel *Channel
}

type ChannelTalkingFinished struct {
	Event
	Channel  *Channel
	Duration int64
}

type ChannelStateChange struct {
	Event
	Channel *Channel
}

type ChannelEnteredBridge struct {
	Event
	Bridge  *Bridge
	Channel *Channel
}

type ChannelLeftBridge struct {
	Event
	Bridge  *Bridge
	Channel *Channel
}

type ChannelDialplan struct {
	Event
	Channel         *Channel
	DialplanApp     string `json:"dialplan_app"`
	DialplanAppData string `json:"dialplan_app_data"`
}

type ChannelCallerID struct {
	Event
	CallerPresentation    int64  `json:"caller_presentation"`
	CallerPresentationTxt string `json:"caller_presentation_txt"`
	Channel               *Channel
}

type ChannelCreated struct {
	Event
	Channel *Channel
}

type ChannelConnectedLine struct {
	Event
	Channel *Channel
}

type ChannelDestroyed struct {
	Event
	Channel  *Channel
	Cause    int64
	CauseTxt string `json:"cause_txt"`
}

type PlaybackStarted struct {
	Event
	Playback *Playback
}

type PlaybackFinished struct {
	Event
	Playback *Playback
}

type DeviceStateChanged struct {
	Event
	DeviceState *DeviceState `json:"device_state"`
}

type PeerStatusChange struct {
	Event
	Endpoint *Endpoint `json:"endpoint"`
	Peer     *Peer     `json:"peer"`
}

type RecordingFailed struct {
        Event
        Recording *LiveRecording `json:"recording"`
}

type RecordingFinished struct {
        Event
	Recording *LiveRecording `json:"recording"`
}

type RecordingStarted struct {
        Event
	Recording *LiveRecording `json:"recording"`
}

type EndpointStateChange struct {
        Event
        Endpoint *Endpoint `json:"endpoint"`
}

//
// AsteriskInfo-related
//

// AriConnected is an Go library specific message, indicating a successful WebSocket connection.
type AriConnected struct {
	Event
	Reconnections int
}

// AriDisonnected is an Go library specific message, indicating an error or a disconnection of the WebSocket connection.
type AriDisconnected struct {
	Event
}

func parseMsg(raw []byte) (Eventer, error) {
	var event Event
	err := json.Unmarshal(raw, &event)
	if err != nil {
		return nil, err
	}

	var msg Eventer
	switch event.Type {
	case "ChannelVarset":
		msg = &ChannelVarset{}
	case "ChannelDtmfReceived":
		msg = &ChannelDtmfReceived{}
	case "ChannelHangupRequest":
		msg = &ChannelHangupRequest{}
	case "ChannelConnectedLine":
		msg = &ChannelConnectedLine{}
	case "StasisStart":
		msg = &StasisStart{}
	case "PlaybackStarted":
		msg = &PlaybackStarted{}
	case "PlaybackFinished":
		msg = &PlaybackFinished{}
	case "ChannelTalkingStarted":
		msg = &ChannelTalkingStarted{}
	case "ChannelTalkingFinished":
		msg = &ChannelTalkingFinished{}
	case "ChannelDialplan":
		msg = &ChannelDialplan{}
	case "ChannelCallerId":
		msg = &ChannelCallerID{}
	case "ChannelStateChange":
		msg = &ChannelStateChange{}
	case "ChannelEnteredBridge":
		msg = &ChannelEnteredBridge{}
	case "ChannelLeftBridge":
		msg = &ChannelLeftBridge{}
	case "ChannelCreated":
		msg = &ChannelCreated{}
	case "ChannelDestroyed":
		msg = &ChannelDestroyed{}
	case "BridgeCreated":
		msg = &BridgeCreated{}
	case "BridgeDestroyed":
		msg = &BridgeDestroyed{}
	case "BridgeMerged":
		msg = &BridgeMerged{}
	case "BridgeBlindTransfer":
		msg = &BridgeBlindTransfer{}
	case "BridgeAttendedTransfer":
		msg = &BridgeAttendedTransfer{}
	case "DeviceStateChanged":
		msg = &DeviceStateChanged{}
	case "StasisEnd":
		msg = &StasisEnd{}
	case "PeerStatusChange":
		msg = &PeerStatusChange{}
	case "RecordingFailed":
    		msg = &RecordingFailed{}
 	case "RecordingFinished":
    		msg = &RecordingFinished{}
 	case "RecordingStarted":
    		msg = &RecordingStarted{}
	case "EndpointStateChange":
    		msg = &EndpointStateChange{}
	default:
		return &event, nil
	}

	return msg, json.Unmarshal(raw, msg)
}