event_resource.go

package api

import (
	"encoding/json"

	"github.com/DataDog/datadog-go/statsd"
	"github.com/MEDIGO/laika/models"
	"github.com/MEDIGO/laika/notifier"
	"github.com/MEDIGO/laika/store"
	"github.com/labstack/echo"
)

type EventResource struct {
	store    store.Store
	stats    *statsd.Client
	notifier notifier.Notifier
}

func NewEventResource(store store.Store, stats *statsd.Client, notifier notifier.Notifier) *EventResource {
	return &EventResource{store, stats, notifier}
}

func (r *EventResource) Create(c echo.Context) error {
	eventType := c.Param("type")
	event, err := models.EventForType(eventType)
	if err != nil {
		return Invalid(c, err.Error())
	}

	if err := c.Bind(&event); err != nil {
		return BadRequest(c, "Body must be a valid JSON object")
	}

	state, err := r.store.State()
	if err != nil {
		return InternalServerError(c, err)
	}

	valErr, err := event.Validate(state)
	if err != nil {
		return InternalServerError(c, err)
	} else if valErr != nil {
		return BadRequest(c, valErr.Error())
	}

	event, err = event.PrePersist(state)
	if err != nil {
		return InternalServerError(c, err)
	}

	cleanEvent, err := json.Marshal(event)
	if err != nil {
		return InternalServerError(c, err)
	}

	id, err := r.store.Persist(eventType, string(cleanEvent))
	if err != nil {
		return InternalServerError(c, err)
	}

	event.Notify(state, r.notifier)

	return Created(c, struct {
		ID int64 `json:"id"`
	}{ID: id})
}