main.go

package main

import (
	"database/sql"
	"fmt"
	"log"
	"net/http"
	"os"
	"time"

	"github.com/ahmed-khlifi/go-rss-aggregator/internal/database"
	"github.com/go-chi/chi"
	"github.com/go-chi/cors"
	"github.com/joho/godotenv"

	_ "github.com/lib/pq"
)

type apiConfig struct {
	DB *database.Queries
}

func main() {
 
	
	// Get the value of the PORT environment variable
	godotenv.Load()
	portString := os.Getenv("PORT")
	if portString == "" {
		// log.Fatal will print the error and then call os.Exit(1)
		log.Fatal("PORT environment variable not set")
	}

	db := os.Getenv("DB_URL")
	if db == "" {
		// log.Fatal will print the error and then call os.Exit(1)
		log.Fatal("Database conection URL is not set")
	}


	conn, err := sql.Open("postgres", db)
	if err != nil {
		log.Fatal("Can't connect to the database:",err)
	}
	
	dbc :=  database.New(conn)
	apiCfg := apiConfig{
		DB:  dbc,
	}

	go startScraping(dbc, 10, time.Second * 5) // Start scraping every 10 seconds for new posts with a delay of 5

	// `router := chi.NewRouter()` is creating a new instance of a router from the `chi` package. This
	// router will be used to define the routes and handle the incoming HTTP requests.
	router := chi.NewRouter()

	// The code `router.Use(cors.Handler(cors.Options{ AllowedOrigins: []string{"*"}, })` is adding a
	// middleware to the router that will handle CORS (Cross-Origin Resource Sharing) requests. This
	// middleware will allow requests from any origin.
	router.Use(cors.Handler(cors.Options{
		AllowedOrigins: []string{"*"}, // Use this to allow specific origin sites. the * will allow all sites
		AllowedMethods: []string{"GET", "POST", "PUT", "DELETE", "OPTIONS"}, // Use this to allow all methods
		AllowedHeaders: []string{"*"},
		ExposedHeaders: []string{"Link"},
		AllowCredentials : false, 
		// `MaxAge: 300` is setting the maximum age (in seconds) for the CORS preflight response.
		MaxAge: 300,	
	}))


	v1Router := chi.NewRouter()
	// API Checkers
	v1Router.Get("/status", handlerReadiness)
	v1Router.Get("/error", handleError)
	// User routes are under /v1/feeds
	v1Router.Post("/users", apiCfg.handleCreatUser)
	v1Router.Get("/users", apiCfg.middlewareAuth(apiCfg.handlerGetUser))
	// Feed routes are under /v1/feeds
	v1Router.Post("/feeds", apiCfg.middlewareAuth(apiCfg.handleCreatFeed))
	v1Router.Get("/feeds", apiCfg.handleGetFeeds)
	// Feed follow routes are under /v1/feed_follows
	v1Router.Post("/feed_follows", apiCfg.middlewareAuth(apiCfg.handleCreatFeedFollow))
	v1Router.Get("/feed_follows", apiCfg.middlewareAuth(apiCfg.handleGetFeedsFollow))
	v1Router.Delete("/feed_follows/{feedFollowID}", apiCfg.middlewareAuth(apiCfg.handleDeleteFeedsFollow))
	// Post routes are under /v1/posts
	v1Router.Get("/posts", apiCfg.middlewareAuth(apiCfg.handlerGetPostsForUser))

	router.Mount("/v1", v1Router)
	// GET : /v1/status  => Should return 200 with empty JSON response

	// The code `srv := &http.Server{ Handler: router, Addr: ":" + portString, }` is creating a new
	// instance of the `http.Server` struct.
	srv := &http.Server{
		Handler: router,
		Addr:   ":" + portString,
	}

	// The code `err := srv.ListenAndServe()` is starting the HTTP server and listening for incoming
	// requests. If there is an error starting the server, it will be assigned to the `err` variable.
	fmt.Printf("Server is listening on port %s", portString)
	err = srv.ListenAndServe()
	if err != nil {
		log.Fatal(err)
	}
  
}