First endpoint to add movies

.gitignore

@@ -0,0 +1 @@
+movies.json

api/api.go

@@ -0,0 +1,41 @@
+package api
+
+import (
+	"encoding/json"
+	"io/ioutil"
+	"net/http"
+
+	"gogs.gildas.ch/gildas/movies"
+)
+
+type Error struct {
+	Error string `json: "error"`
+}
+
+func returnError(w http.ResponseWriter, status int, err error) {
+	w.Header().Set("Content-Type", "application/json")
+	w.WriteHeader(status)
+	json.NewEncoder(w).Encode(Error{Error: err.Error()})
+}
+
+func AddMovieHandler(c *movies.Collection) http.HandlerFunc {
+	return http.HandlerFunc(func(w http.ResponseWriter, r *http.Request) {
+		if r.Method != "POST" {
+			return
+		}
+
+		b, err := ioutil.ReadAll(r.Body)
+		if err != nil {
+			returnError(w, http.StatusBadRequest, err)
+			return
+		}
+
+		m, err := movies.Unmarshal(b)
+		if err != nil {
+			returnError(w, http.StatusBadRequest, err)
+			return
+		}
+
+		c.Add(m)
+	})
+}

cmd/movies/main.go

@@ -0,0 +1,62 @@
+package main
+
+import (
+	"fmt"
+	"log"
+	"net/http"
+	"os"
+	"time"
+
+	"gogs.gildas.ch/gildas/movies"
+	"gogs.gildas.ch/gildas/movies/api"
+)
+
+const (
+	dataFile = "movies.json"
+)
+
+func main() {
+	var collection *movies.Collection
+	if _, err := os.Stat(dataFile); !os.IsNotExist(err) {
+		c, err := movies.Import(dataFile)
+		if err != nil {
+			log.Fatal(err)
+		}
+		collection = c
+	} else {
+		collection = &movies.Collection{}
+	}
+
+	http.Handle("/add-movie", api.AddMovieHandler(collection))
+
+	port := "8080"
+	if p := os.Getenv("PORT"); p != "" {
+		port = p
+	}
+
+	stopExport := make(chan bool)
+	go export(collection, stopExport)
+	defer func() { stopExport <- true }()
+
+	fmt.Println("Listening...")
+	err := http.ListenAndServe(":"+port, nil)
+	fmt.Println("Server stopped with error:", err)
+}
+
+func export(c *movies.Collection, stop <-chan bool) {
+	for {
+		select {
+		case <-time.After(30 * time.Second):
+			if c.HasChanged() {
+				err := c.Export(dataFile)
+				if err != nil {
+					log.Fatal(err)
+					return
+				}
+				fmt.Printf("Exported fresh data to %q.\n", dataFile)
+			}
+		case <-stop:
+			return
+		}
+	}
+}

collection.go

@@ -0,0 +1,58 @@
+package movies
+
+import (
+	"encoding/json"
+	"io/ioutil"
+	"sync"
+)
+
+type Collection struct {
+	Movies []*Movie
+
+	mutex      sync.RWMutex
+	hasChanged bool
+}
+
+func Import(filename string) (*Collection, error) {
+	b, err := ioutil.ReadFile(filename)
+	if err != nil {
+		return nil, err
+	}
+
+	var c Collection
+	if err := json.Unmarshal(b, &c); err != nil {
+		return nil, err
+	}
+
+	return &c, nil
+}
+
+func (c *Collection) Export(filename string) error {
+	c.mutex.RLock()
+	defer c.mutex.RUnlock()
+
+	b, err := json.Marshal(c)
+	if err != nil {
+		return err
+	}
+
+	err = ioutil.WriteFile(filename, b, 0644)
+	if err != nil {
+		return err
+	}
+
+	c.hasChanged = false
+	return nil
+}
+
+func (c *Collection) Add(m *Movie) {
+	c.mutex.Lock()
+	defer c.mutex.Unlock()
+
+	c.Movies = append(c.Movies, m)
+	c.hasChanged = true
+}
+
+func (c *Collection) HasChanged() bool {
+	return c.hasChanged
+}

movies.go

@@ -0,0 +1,82 @@
+package movies
+
+import (
+	"encoding/json"
+	"fmt"
+	"strconv"
+	"strings"
+)
+
+type Movie struct {
+	Title    string
+	Director string
+	Poster   string
+	Rating   Rating
+
+	OMDB OMDBMovie
+}
+
+type Rating struct {
+	Note  float64
+	Votes int64
+}
+
+type OMDBMovie struct {
+	Title      string
+	Year       string
+	Rated      string
+	Released   string
+	Runtime    string
+	Genre      string
+	Director   string
+	Writer     string
+	Actors     string
+	Plot       string
+	Language   string
+	Country    string
+	Awards     string
+	Poster     string
+	Ratings    []OMDBRating
+	Metascore  string
+	IMDBRating string `json: "imdbRating"`
+	IMDBVotes  string `json: "imdbVotes"`
+	IMDBID     string `json: "imdbID"`
+	Type       string
+	DVD        string
+	BoxOffice  string
+	Production string
+	Website    string
+	Response   string
+}
+
+type OMDBRating struct {
+	Source, Value string
+}
+
+func Unmarshal(b []byte) (*Movie, error) {
+	var omdb OMDBMovie
+	if err := json.Unmarshal(b, &omdb); err != nil {
+		return nil, err
+	}
+
+	note, err := strconv.ParseFloat(omdb.IMDBRating, 64)
+	if err != nil {
+		return nil, fmt.Errorf("cannot convert %q to float64: %w", omdb.IMDBRating, err)
+	}
+
+	votes, err := strconv.ParseInt(strings.ReplaceAll(omdb.IMDBVotes, ",", ""), 10, 64)
+	if err != nil {
+		return nil, fmt.Errorf("cannot convert %q to int: %w", omdb.IMDBVotes, err)
+	}
+
+	return &Movie{
+		Title:    omdb.Title,
+		Director: omdb.Director,
+		Poster:   omdb.Poster,
+		Rating: Rating{
+			Note:  note,
+			Votes: votes,
+		},
+		OMDB: omdb,
+	}, nil
+}

movies_test.go

@@ -0,0 +1,21 @@
+package movies
+
+import (
+	"fmt"
+	"io/ioutil"
+	"testing"
+)
+
+func TestUnmarshal(t *testing.T) {
+	b, err := ioutil.ReadFile("omdb/trop-belle-pour-toi.json")
+	if err != nil {
+		t.Fatal(err)
+	}
+
+	m, err := Unmarshal(b)
+	if err != nil {
+		t.Fatal(err)
+	}
+
+	fmt.Println(m)
+}