You can not select more than 25 topics Topics must start with a letter or number, can include dashes ('-') and can be up to 35 characters long.
podgrab/main.go

95 lines
2.1 KiB

4 years ago
package main
import (
"fmt"
4 years ago
"log"
4 years ago
"net/http"
4 years ago
"os"
"strconv"
4 years ago
"github.com/akhilrex/podgrab/controllers"
"github.com/akhilrex/podgrab/db"
"github.com/akhilrex/podgrab/service"
"github.com/gin-gonic/gin"
"github.com/jasonlvhit/gocron"
4 years ago
_ "github.com/joho/godotenv/autoload"
4 years ago
)
func main() {
// os.Remove("./podgrab.db")
var err error
db.DB, err = db.Init()
if err != nil {
fmt.Println("statuse: ", err)
}
db.Migrate()
r := gin.Default()
4 years ago
dataPath := os.Getenv("DATA")
//r.Static("/assets", "./assets")
r.Static("/assets", dataPath)
4 years ago
r.LoadHTMLGlob("client/*")
r.GET("/podcasts", controllers.AddPodcast)
r.POST("/podcasts", controllers.GetAllPodcasts)
r.GET("/podcasts/:id", controllers.GetPodcastById)
r.GET("/podcasts/:id/items", controllers.GetPodcastItemsByPodcastId)
r.GET("/podcastitems", controllers.GetAllPodcastItems)
r.GET("/podcastitems/:id", controllers.GetPodcastItemById)
r.GET("/", func(c *gin.Context) {
//var podcasts []db.Podcast
podcasts := service.GetAllPodcasts()
4 years ago
c.HTML(http.StatusOK, "index.html", gin.H{"title": "Podgrab", "podcasts": podcasts})
4 years ago
})
4 years ago
r.POST(
"/", func(c *gin.Context) {
var addPodcastData controllers.AddPodcastData
err := c.ShouldBind(&addPodcastData)
if err == nil {
_, err = service.AddPodcast(addPodcastData.Url)
if err == nil {
go service.RefreshEpisodes()
4 years ago
c.Redirect(http.StatusFound, "/")
} else {
c.JSON(http.StatusBadRequest, err)
}
} else {
// fmt.Println(err.Error())
c.JSON(http.StatusBadRequest, err)
}
})
4 years ago
4 years ago
go assetEnv()
4 years ago
go intiCron()
r.Run() // listen and serve on 0.0.0.0:8080 (for windows "localhost:8080")
}
func intiCron() {
4 years ago
checkFrequency, err := strconv.Atoi(os.Getenv("CHECK_FREQUENCY"))
if err != nil {
checkFrequency = 10
log.Print(err)
}
//gocron.Every(uint64(checkFrequency)).Minutes().Do(service.DownloadMissingEpisodes)
gocron.Every(uint64(checkFrequency)).Minutes().Do(service.RefreshEpisodes)
4 years ago
<-gocron.Start()
}
4 years ago
func assetEnv() {
log.Println("Config Dir: ", os.Getenv("CONFIG"))
log.Println("Assets Dir: ", os.Getenv("DATA"))
log.Println("Check Frequency (mins): ", os.Getenv("CHECK_FREQUENCY"))
4 years ago
}