Implemented logging of user actions

models/user.go

@@ -2,6 +2,8 @@ package models
 
 import (
 	"fmt"
+	"github.com/dgrijalva/jwt-go"
+	"github.com/labstack/echo"
 	"golang.org/x/crypto/bcrypt"
 )
 
@@ -22,6 +24,15 @@ type User struct {
 	Updated  int64  `xorm:"updated"`
 }
 
+// UserLog logs user actions
+type UserLog struct {
+	ID     int64  `xorm:"int(11) autoincr not null unique pk"`
+	UserID int64  `xorm:"int(11)"`
+	Log    string `xorm:"varchar(250)"`
+	ItemID int64  `xorm:"int(11)"`
+	Time   int64  `xorm:"created"`
+}
+
 // TableName returns the table name for users
 func (User) TableName() string {
 	return "users"
@@ -102,3 +113,38 @@ func CheckUserCredentials(u *UserLogin) (User, error) {
 
 	return user, nil
 }
+
+// GetCurrentUser returns the current user based on its jwt token
+func GetCurrentUser(c echo.Context) (user User, err error) {
+	jwtinf := c.Get("user").(*jwt.Token)
+	claims := jwtinf.Claims.(jwt.MapClaims)
+	userID, ok := claims["id"].(float64)
+	if !ok {
+		return user, fmt.Errorf("Error getting UserID")
+	}
+	user = User{
+		ID:       int64(userID),
+		Name:     claims["name"].(string),
+		Email:    claims["email"].(string),
+		Username: claims["username"].(string),
+	}
+
+	return
+}
+
+// LogAction logs a user action
+func logAction(action string, user User, itemID int64) (err error) {
+	_, err = x.Insert(UserLog{Log: action, UserID: user.ID, ItemID: itemID})
+	return
+}
+
+// LogAction logs a user action
+func LogAction(action string, itemID int64, c echo.Context) (err error) {
+	// Get the user options
+	user, err := GetCurrentUser(c)
+	if err != nil {
+		return err
+	}
+
+	return logAction(action, user, itemID)
+}

routes/api/v1/author_delete.go

@@ -37,5 +37,11 @@ func AuthorDelete(c echo.Context) error {
 		return c.JSON(http.StatusInternalServerError, models.Message{"Could not delete author"})
 	}
 
+	// Log the action
+	err = models.LogAction("Deleted an author", authorID, c)
+	if err != nil {
+		return c.JSON(http.StatusInternalServerError, models.Message{"Could not log"})
+	}
+
 	return c.JSON(http.StatusOK, models.Message{"success"})
 }

routes/api/v1/authors_add_update.go

@@ -59,5 +59,11 @@ func AuthorAddOrUpdate(c echo.Context) error {
 		return c.JSON(http.StatusInternalServerError, models.Message{"Error"})
 	}
 
+	// Log the action
+	err = models.LogAction("Added or updated an author", newAuthor.ID, c)
+	if err != nil {
+		return c.JSON(http.StatusInternalServerError, models.Message{"Could not log"})
+	}
+
 	return c.JSON(http.StatusOK, newAuthor)
 }

routes/api/v1/book_delete.go

@@ -37,5 +37,11 @@ func BookDelete(c echo.Context) error {
 		return c.JSON(http.StatusInternalServerError, models.Message{"Could not delete book"})
 	}
 
+	// Log the action
+	err = models.LogAction("Deleted a book", bookID, c)
+	if err != nil {
+		return c.JSON(http.StatusInternalServerError, models.Message{"Could not log"})
+	}
+
 	return c.JSON(http.StatusOK, models.Message{"success"})
 }

routes/api/v1/books_add_update.go

@@ -59,5 +59,11 @@ func BookAddOrUpdate(c echo.Context) error {
 		return c.JSON(http.StatusInternalServerError, models.Message{"Error"})
 	}
 
+	// Log the action
+	err = models.LogAction("Added or updated a book", newBook.ID, c)
+	if err != nil {
+		return c.JSON(http.StatusInternalServerError, models.Message{"Could not log"})
+	}
+
 	return c.JSON(http.StatusOK, newBook)
 }

routes/api/v1/items_add_update.go

@@ -54,5 +54,11 @@ func ItemAddOrUpdate(c echo.Context) error {
 		return c.JSON(http.StatusInternalServerError, models.Message{"Error"})
 	}
 
+	// Log the action
+	err = models.LogAction("Added or updated an item", newItem.ID, c)
+	if err != nil {
+		return c.JSON(http.StatusInternalServerError, models.Message{"Could not log"})
+	}
+
 	return c.JSON(http.StatusOK, newItem)
 }

routes/api/v1/items_delete.go

@@ -37,5 +37,11 @@ func ItemDelete(c echo.Context) error {
 		return c.JSON(http.StatusInternalServerError, models.Message{"Could not delete item"})
 	}
 
+	// Log the action
+	err = models.LogAction("Deleted an item", itemID, c)
+	if err != nil {
+		return c.JSON(http.StatusInternalServerError, models.Message{"Could not log"})
+	}
+
 	return c.JSON(http.StatusOK, models.Message{"success"})
 }

routes/api/v1/publishers_add_update.go

@@ -54,5 +54,11 @@ func PublisherAddOrUpdate(c echo.Context) error {
 		return c.JSON(http.StatusInternalServerError, models.Message{"Error"})
 	}
 
+	// Log the action
+	err = models.LogAction("Added or updated a publisher",newPublisher.ID, c)
+	if err != nil {
+		return c.JSON(http.StatusInternalServerError, models.Message{"Could not log"})
+	}
+
 	return c.JSON(http.StatusOK, newPublisher)
 }

routes/api/v1/publishers_delete.go

@@ -37,5 +37,11 @@ func PublisherDelete(c echo.Context) error {
 		return c.JSON(http.StatusInternalServerError, models.Message{"Could not delete publisher"})
 	}
 
+	// Log the action
+	err = models.LogAction("Deleted a publisher", publisherID, c)
+	if err != nil {
+		return c.JSON(http.StatusInternalServerError, models.Message{"Could not log"})
+	}
+
 	return c.JSON(http.StatusOK, models.Message{"success"})
 }