From 320d1b016747ba4501da9417d9ce5f99368a5768 Mon Sep 17 00:00:00 2001 From: Frédéric Guillot Date: Tue, 2 Jan 2018 22:04:48 -0800 Subject: Refactor packages to have more idiomatic code base --- api/category.go | 103 ++++++++++++++++++++++++++++++++++++++++++++++++++++++++ 1 file changed, 103 insertions(+) create mode 100644 api/category.go (limited to 'api/category.go') diff --git a/api/category.go b/api/category.go new file mode 100644 index 0000000..67c7e52 --- /dev/null +++ b/api/category.go @@ -0,0 +1,103 @@ +// Copyright 2017 Frédéric Guillot. All rights reserved. +// Use of this source code is governed by the Apache 2.0 +// license that can be found in the LICENSE file. + +package api + +import ( + "errors" + + "github.com/miniflux/miniflux/http/handler" +) + +// CreateCategory is the API handler to create a new category. +func (c *Controller) CreateCategory(ctx *handler.Context, request *handler.Request, response *handler.Response) { + userID := ctx.UserID() + category, err := decodeCategoryPayload(request.Body()) + if err != nil { + response.JSON().BadRequest(err) + return + } + + category.UserID = userID + if err := category.ValidateCategoryCreation(); err != nil { + response.JSON().BadRequest(err) + return + } + + if c, err := c.store.CategoryByTitle(userID, category.Title); err != nil || c != nil { + response.JSON().BadRequest(errors.New("This category already exists")) + return + } + + err = c.store.CreateCategory(category) + if err != nil { + response.JSON().ServerError(errors.New("Unable to create this category")) + return + } + + response.JSON().Created(category) +} + +// UpdateCategory is the API handler to update a category. +func (c *Controller) UpdateCategory(ctx *handler.Context, request *handler.Request, response *handler.Response) { + categoryID, err := request.IntegerParam("categoryID") + if err != nil { + response.JSON().BadRequest(err) + return + } + + category, err := decodeCategoryPayload(request.Body()) + if err != nil { + response.JSON().BadRequest(err) + return + } + + category.UserID = ctx.UserID() + category.ID = categoryID + if err := category.ValidateCategoryModification(); err != nil { + response.JSON().BadRequest(err) + return + } + + err = c.store.UpdateCategory(category) + if err != nil { + response.JSON().ServerError(errors.New("Unable to update this category")) + return + } + + response.JSON().Created(category) +} + +// GetCategories is the API handler to get a list of categories for a given user. +func (c *Controller) GetCategories(ctx *handler.Context, request *handler.Request, response *handler.Response) { + categories, err := c.store.Categories(ctx.UserID()) + if err != nil { + response.JSON().ServerError(errors.New("Unable to fetch categories")) + return + } + + response.JSON().Standard(categories) +} + +// RemoveCategory is the API handler to remove a category. +func (c *Controller) RemoveCategory(ctx *handler.Context, request *handler.Request, response *handler.Response) { + userID := ctx.UserID() + categoryID, err := request.IntegerParam("categoryID") + if err != nil { + response.JSON().BadRequest(err) + return + } + + if !c.store.CategoryExists(userID, categoryID) { + response.JSON().NotFound(errors.New("Category not found")) + return + } + + if err := c.store.RemoveCategory(userID, categoryID); err != nil { + response.JSON().ServerError(errors.New("Unable to remove this category")) + return + } + + response.JSON().NoContent() +} -- cgit v1.2.3