Uploader/main.go

package main

import (
	"context"
	"fmt"
	"io"
	"log"
	"net/http"
	"os"
	"strconv"

	"github.com/gin-gonic/gin"
	"github.com/jackc/pgx/v5/pgxpool"
	"github.com/jaswdr/faker"
)

var dbpool *pgxpool.Pool

func main() {
	var err error
	dbpool, err = pgxpool.New(context.Background(), "postgresql://postgres:postgres@172.19.0.2:5432/postgres")
	if err != nil {
		log.Fatal(err)
	}
	defer dbpool.Close()

	sqlStmt := `
	DROP TABLE IF EXISTS videos;

	CREATE TABLE IF NOT EXISTS videos
	(
		id serial NOT NULL,
		filepath text,
		CONSTRAINT videos_pkey PRIMARY KEY (id)
	)
	`
	_, err = dbpool.Exec(context.Background(), sqlStmt)
	if err != nil {
		log.Fatalf("main: create table: %v\n", err)
	}

	faker := faker.New()

	for i := 0; i < 10; i++ {
		_, err = dbpool.Exec(context.Background(), "insert into videos(filepath) values($1)", faker.File().AbsoluteFilePathForUnix(2))
		if err != nil {
			log.Fatalf("main: fill with fake data: %v\n", err)
		}
	}

	router := gin.Default()
	router.SetTrustedProxies(nil)

	router.POST("/video", ReceiveChunk)
	router.POST("/video/completed", ReceiveFile)
	router.GET("/videos", listVideos)
	router.GET("/videos/:id", getVideo)
	router.DELETE("/videos/:id", deleteVideo)

	router.Run("localhost:8080")
}

func ReceiveChunk(c *gin.Context) {
	chunk, err := io.ReadAll(c.Request.Body)
	if err != nil {
		c.IndentedJSON(http.StatusBadRequest, "Couldn't read html request body")
		return
	}

	f, err := os.OpenFile(c.GetHeader("file-name"), os.O_APPEND|os.O_CREATE|os.O_WRONLY, 0644)
	if err != nil {
		log.Fatal(err)
	}
	if _, err := f.Write(chunk); err != nil {
		log.Fatal(err)
	}
	if err := f.Close(); err != nil {
		log.Fatal(err)
	}

	c.IndentedJSON(http.StatusOK, "Received chunk")
}

func ReceiveFile(c *gin.Context) {
	currentDir, err := os.Getwd()
	if err != nil {
		log.Fatalf("ReceiveFile: %v\n", err)
	}

	fileName, err := io.ReadAll(c.Request.Body)
	if err != nil {
		c.IndentedJSON(http.StatusBadRequest, "Couldn't read html request body")
		return
	}

	_, err = dbpool.Exec(context.Background(), "insert into videos(filepath) values($1)", fmt.Sprintf("%s/%s", currentDir, fileName))
	if err != nil {
		log.Fatalf("ReceiveFile: %v\n", err)
	}

	c.IndentedJSON(http.StatusOK, gin.H{}) // return list of videos
}

func listVideos(c *gin.Context) {
	var err error
	rows, _ := dbpool.Query(context.Background(), "select * from videos")
	for rows.Next() {
		var id int
		var filepath string
		err = rows.Scan(&id, &filepath)
		if err != nil {
			log.Fatalf("listVideos: %v\n", err)
		}
		fmt.Println(id, filepath)
	}
	err = rows.Err()
	if err != nil {
		log.Fatalf("listVideos: %v\n", err)
	}

	c.IndentedJSON(http.StatusOK, gin.H{})
}

func getVideo(c *gin.Context) {
	var err error
	inputId, err := strconv.Atoi(c.Param("id"))
	if err != nil {
		log.Fatal(err)
	}

	rows, _ := dbpool.Query(context.Background(), "select * from videos where id = $1", inputId)
	rows.Next()
	var id int
	var filepath string
	err = rows.Scan(&id, &filepath)
	if err != nil {
		log.Fatalf("getVideo: %v\n", err)
	}
	fmt.Println(id, filepath)
	err = rows.Err()
	if err != nil {
		log.Fatalf("getVideo: %v\n", err)
	}

	c.IndentedJSON(http.StatusOK, gin.H{})
}

func deleteVideo(c *gin.Context) {
	inputId, err := strconv.Atoi(c.Param("id"))
	if err != nil {
		log.Fatal(err)
	}

	rows, _ := dbpool.Query(context.Background(), "select filepath from videos where id = $1", inputId)
	rows.Next()
	var filepath string
	err = rows.Scan(&filepath)
	if err != nil {
		log.Printf("deleteVideo: %v\n", err)
		c.IndentedJSON(http.StatusBadRequest, gin.H{"message": "Video does not exist"})
		return
	}
	fmt.Println(filepath)
	err = rows.Err()
	if err != nil {
		log.Printf("deleteVideo: %v\n", err)
		c.IndentedJSON(http.StatusInternalServerError, gin.H{"message": "Scanning the row didn't work"})
		return
	}

	_, err = dbpool.Exec(context.Background(), "delete from videos where id = $1", inputId)
	if err != nil {
		log.Printf("deleteVideo: %v\n", err)
		c.IndentedJSON(http.StatusInternalServerError, gin.H{"message": "Couldn't delete entry from DB"})
		return
	}

	if err = os.Remove(filepath); err != nil {
		log.Printf("deleteVideo: %v\n", err)
		c.IndentedJSON(http.StatusInternalServerError, gin.H{"message": "Couldn't delete video from server"})
		return
	}

	c.IndentedJSON(http.StatusOK, gin.H{}) // return list of videos
}