Initial commit

internal/query/get_inbox.go

@@ -0,0 +1,63 @@
+package query
+
+import (
+	"context"
+
+	"forge.cadoles.com/wpetit/fake-smtp/internal/model"
+	"forge.cadoles.com/wpetit/fake-smtp/internal/storm"
+	"github.com/pkg/errors"
+	"gitlab.com/wpetit/goweb/cqrs"
+	"gitlab.com/wpetit/goweb/middleware/container"
+)
+
+type GetInboxRequest struct {
+	OrderBy string
+	Limit   int
+	Skip    int
+	Reverse bool
+}
+
+type InboxData struct {
+	Emails []*model.Email
+}
+
+func HandleGetInbox(ctx context.Context, qry cqrs.Query) (interface{}, error) {
+	req, ok := qry.Request().(*GetInboxRequest)
+	if !ok {
+		return nil, cqrs.ErrUnexpectedRequest
+	}
+
+	ctn, err := container.From(ctx)
+	if err != nil {
+		return nil, errors.Wrap(err, "could not retrieve service container")
+	}
+
+	db, err := storm.From(ctn)
+	if err != nil {
+		return nil, errors.Wrap(err, "could not retrieve storm service")
+	}
+
+	emails := make([]*model.Email, 0)
+
+	query := db.Select()
+
+	if req.OrderBy != "" {
+		query = query.OrderBy(req.OrderBy)
+	} else {
+		query = query.OrderBy("SentAt").Reverse()
+	}
+
+	if req.Reverse {
+		query = query.Reverse()
+	}
+
+	if err := query.Find(&emails); err != nil {
+		if err == storm.ErrNotFound {
+			return &InboxData{emails}, nil
+		}
+
+		return nil, errors.Wrap(err, "could not retrieve emails")
+	}
+
+	return &InboxData{emails}, nil
+}

internal/query/open_email.go

@@ -0,0 +1,44 @@
+package query
+
+import (
+	"context"
+
+	"forge.cadoles.com/wpetit/fake-smtp/internal/model"
+	"forge.cadoles.com/wpetit/fake-smtp/internal/storm"
+	"github.com/pkg/errors"
+	"gitlab.com/wpetit/goweb/cqrs"
+	"gitlab.com/wpetit/goweb/middleware/container"
+)
+
+type OpenEmailRequest struct {
+	EmailID int
+}
+
+type OpenEmailData struct {
+	Email *model.Email
+}
+
+func HandleOpenEmail(ctx context.Context, qry cqrs.Query) (interface{}, error) {
+	req, ok := qry.Request().(*OpenEmailRequest)
+	if !ok {
+		return nil, cqrs.ErrUnexpectedRequest
+	}
+
+	ctn, err := container.From(ctx)
+	if err != nil {
+		return nil, errors.Wrap(err, "could not retrieve service container")
+	}
+
+	db, err := storm.From(ctn)
+	if err != nil {
+		return nil, errors.Wrap(err, "could not retrieve storm service")
+	}
+
+	email := &model.Email{}
+
+	if err := db.One("ID", req.EmailID, email); err != nil {
+		return nil, errors.Wrap(err, "could not find email")
+	}
+
+	return &OpenEmailData{email}, nil
+}