user.go

package main

import (
	"database/sql"
	"encoding/json"
	"fmt"
	"github.com/gin-gonic/gin"
	"github.com/google/uuid"
	"io/ioutil"
	"net/http"
	"os"
	"time"
)

type User struct {
	ID        string    `json:"id,omitempty"`
	Name      string    `json:"name,omitempty"`
	Username  string    `json:"username,omitempty"`
	Email     string    `json:"email,omitempty"`
	Password  string    `json:"password,omitempty"`
	CreatedAt time.Time `json:"created_at,omitempty"`
	UpdatedAt time.Time `json:"updated_at,omitempty"`
	Image     string    `json:"image,omitempty"`
}

func GetUserByUserName(db *sql.DB, username string) (User, error) {

	var name, id, email, createdAt, updatedAt, image string

	row := db.QueryRow(`SELECT id,name, email,created_at,
						updated_at,image FROM users WHERE username = $1`, username)
	err := row.Scan(&id, &name, &email, &createdAt, &updatedAt, &image)
	if err != nil {
		return User{}, err
	}

	CreatedAt, err := time.Parse(time.RFC3339, createdAt)

	if err != nil {
		return User{}, err
	}

	UpdatedAt, err := time.Parse(time.RFC3339, updatedAt)

	if err != nil {
		return User{}, err
	}

	user := User{
		ID:        id,
		Name:      name,
		Username:  username,
		Email:     email,
		CreatedAt: CreatedAt,
		UpdatedAt: UpdatedAt,
		Image:     image,
	}

	return user, nil
}

func GetUser(db *sql.DB, id string) (User, error) {

	var name, username, email, createdAt, updatedAt, image string

	row := db.QueryRow(`SELECT id,name, username, email,created_at,
						updated_at,image FROM users WHERE id = $1`, id)
	err := row.Scan(&id, &name, &username, &email, &createdAt, &updatedAt, &image)
	if err != nil {
		return User{}, err
	}

	CreatedAt, err := time.Parse(time.RFC3339, createdAt)

	if err != nil {
		return User{}, err
	}

	UpdatedAt, err := time.Parse(time.RFC3339, updatedAt)

	if err != nil {
		return User{}, err
	}

	user := User{
		ID:        id,
		Name:      name,
		Username:  username,
		Email:     email,
		CreatedAt: CreatedAt,
		UpdatedAt: UpdatedAt,
		Image:     image,
	}

	return user, nil
}

func CreateUser(db *sql.DB, user User) error {

	ID := uuid.New().String()

	UserImage, err := getPhoto()
	if err != nil {
		return err
	}
	// fmt.Println(UserImage)

	_, err = db.Exec(`INSERT INTO users(id,name, username, email, created_at, updated_at,password,image)
						VALUES($1,$2,$3,$4,$5,$6,$7,$8)`,
		ID,
		user.Name,
		user.Username,
		user.Email,
		time.Now().Format(time.RFC3339),
		time.Now().Format(time.RFC3339),
		user.Password,
		UserImage)

	if err != nil {
		return err
	}
	return nil
}

func UpdateUser(db *sql.DB, user User) error {

	_, err := db.Exec(`UPDATE users SET name = $1,username = $2,email =$3, updated_at = $4 WHERE id = $5`,
		user.Name, user.Username, user.Email, time.Now().Format(time.RFC3339), user.ID)

	if err != nil {
		return err
	}
	return nil
}

func DeleteUser(db *sql.DB, id string) error {

	_, err := db.Exec(`DELETE FROM users WHERE id = $1`, id)

	if err != nil {
		return err
	}

	return nil
}

func postUserHandler(c *gin.Context, db *sql.DB) {

	user := User{}
	err := c.BindJSON(&user)
	if err != nil {
		c.AbortWithStatus(http.StatusInternalServerError)
		return
	}

	err = CreateUser(db, user)
	if err != nil {
		c.AbortWithStatus(http.StatusInternalServerError)
		return
	}

	c.Status(http.StatusCreated)

}

func putUserHandler(c *gin.Context, db *sql.DB) {

	user := User{}
	err := c.BindJSON(&user)
	if err != nil {
		c.AbortWithStatus(http.StatusInternalServerError)
		return
	}

	err = UpdateUser(db, user)
	if err != nil {
		c.AbortWithStatus(http.StatusInternalServerError)
		return
	}

	c.Status(http.StatusNoContent)
}

func deleteUserHandler(c *gin.Context, db *sql.DB) {

	id := c.Param("id")

	err := DeleteUser(db, id)

	if err != nil {
		c.AbortWithStatus(http.StatusInternalServerError)
		return
	}

	c.Status(http.StatusNoContent)

}

type Image struct {
	Name     string `json:"name,omitempty"`
	Email    string `json:"email,omitempty"`
	Position string `json:"position,omitempty"`
	Photo    string `json:"photo,omitempty"`
}

func getPhoto() (string, error) {

	url := "https://uifaces.co/api?limit=1&random"

	req, err := http.NewRequest(http.MethodGet, url, nil)
	if err != nil {
		return "", err
	}
	req.Header.Add("X-API-KEY", os.Getenv("UI_FACES_KEY"))

	res, err := http.DefaultClient.Do(req)
	if err != nil {
		return "", err
	}

	body, err := ioutil.ReadAll(res.Body)
	if err != nil {
		return "", err
	}

	var data []Image
	err = json.Unmarshal(body, &data)
	if err != nil {
		return "", err
	}

	return data[0].Photo, nil
}

func getUserHandler(c *gin.Context, db *sql.DB) {

	username := c.Param("username")

	var name, id, email, createdAt, updatedAt, image string

	row := db.QueryRow(`SELECT id,name, email,created_at,
						updated_at,image FROM users WHERE username = $1`, username)
	err := row.Scan(&id, &name, &email, &createdAt, &updatedAt, &image)
	if err != nil {
		fmt.Println(err)
		c.AbortWithStatus(http.StatusInternalServerError)
		return
	}

	CreatedAt, err := time.Parse(time.RFC3339, createdAt)
	if err != nil {
		fmt.Println(err)
		return
	}

	UpdatedAt, err := time.Parse(time.RFC3339, updatedAt)
	if err != nil {
		return
	}

	user := User{
		ID:        id,
		Name:      name,
		Username:  username,
		Email:     email,
		CreatedAt: CreatedAt,
		UpdatedAt: UpdatedAt,
		Image:     image,
	}

	c.JSON(200, user)
}