Implement LoadPhotos and DownloadPhoto

main.go

@@ -10,6 +10,7 @@ import (
 	"io"
 	"io/fs"
 	"net/http"
+	"net/url"
 	"os"
 	"path"
 	"regexp"
@@ -23,29 +24,47 @@ import (
 )
 
 var (
-	imagesDir      string
+	imagesDir       string
-	collageDir     string
+	collageDir      string
-	devMode        bool
+	photosDir       string
-	collageNameGen *nameGen
+	devMode         bool
-	imagesDirFs    fs.FS
+	collageNameGen  *nameGen
-	listenAddr     string
+	imagesDirFs     fs.FS
+	listenAddr      string
+	photoPrismURL   *url.URL
+	photoPrismToken string
 
 	//go:embed web
 	webFS embed.FS
 )
 
 func main() {
+	var ppURL string
+
 	flag.StringVar(&imagesDir, "images-dir", "images", "Sets the images dir")
 	flag.StringVar(&collageDir, "collages-dir", "collages", "Sets the collages dir")
+	flag.StringVar(&photosDir, "photos-dir", "photos", "Cache directory for downloaded photos")
 	flag.BoolVar(&devMode, "dev", false, "Serve local assets during development")
 	flag.StringVar(&listenAddr, "addr", "127.0.0.1:8767", "Web listen address, see https://pkg.go.dev/go.balki.me/anyhttp#readme-address-syntax")
+	flag.StringVar(&ppURL, "pp-url", "", "Base url for photoprism")
+	flag.StringVar(&photoPrismToken, "pp-token", "", "API token for photoprism")
 
 	flag.Parse()
 
+	photoPrismURL = func() *url.URL {
+		photoPrismURL, err := url.Parse(ppURL)
+		if err != nil {
+			panic(err)
+		}
+		return photoPrismURL
+	}()
+	copy := *photoPrismURL
+	fmt.Println(copy)
 	collageNameGen = NewNameGen()
 	imagesDirFs = os.DirFS(imagesDir)
 	imagesURLPath := "images"
 	collagesPath := "collages"
+	photosPath := "photos"
 
 	addFileServer := func(path, dir string) {
 		httpFileServer := http.FileServer(http.Dir(dir))
@@ -54,6 +73,7 @@ func main() {
 
 	addFileServer(imagesURLPath, imagesDir)
 	addFileServer(collagesPath, collageDir)
+	addFileServer(photosPath, photosDir)
 
 	if devMode {
 		httpFileServer := http.FileServer(http.Dir("web"))
@@ -100,16 +120,33 @@ func main() {
 			w.WriteHeader(http.StatusInternalServerError)
 			return
 		}
-		collageFile, err := MakeCollage(&collageReq)
+		collageFilePath, err := MakeCollage(&collageReq)
 		if err != nil {
 			slog.Error("failed to make collage", "error", err)
 			w.WriteHeader(http.StatusInternalServerError)
 			return
 		}
-		if _, err := w.Write([]byte(collageFile)); err != nil {
+		if _, err := w.Write([]byte(collageFilePath)); err != nil {
 			slog.Error("Failed to write collageFile", "error", err)
 		}
 	})
+
+	http.HandleFunc("/get-albums", func(w http.ResponseWriter, r *http.Request) {
+		albums, err := GetAlbums()
+		if err != nil {
+			slog.Error("failed to get albums", "error", err)
+			w.WriteHeader(http.StatusInternalServerError)
+			return
+		}
+		jData, err := json.Marshal(albums)
+		if err != nil {
+			slog.Error("failed to marshal albums", "error", err)
+			w.WriteHeader(http.StatusInternalServerError)
+			return
+		}
+		w.Header().Set("Content-Type", "application/json")
+		w.Write(jData)
+	})
 	addrType, server, done, err := anyhttp.Serve(listenAddr, idle.WrapHandler(nil))
 	if err != nil {
 		slog.Error("anyhttp Serve failed", "error", err)
@@ -141,3 +178,120 @@ func MakeCollage(req *collage.Request) (string, error) {
 	}
 	return collageFile, nil
 }
+
+type Album struct {
+	Title string `json:"Title"`
+	UID   string `json:"UID"`
+}
+
+func GetAlbums() ([]Album, error) {
+	albumURL := func() string {
+		u := *photoPrismURL
+		u.Path = "/api/v1/albums"
+		v := url.Values{}
+		v.Add("count", "20")
+		v.Add("type", "album")
+		u.RawQuery = v.Encode()
+		return u.String()
+	}()
+
+	req, err := http.NewRequest("GET", albumURL, nil)
+	if err != nil {
+		return nil, err
+	}
+	req.Header.Set("Authorization", fmt.Sprintf("Bearer %s", photoPrismToken))
+	resp, err := http.DefaultClient.Do(req)
+	if err != nil {
+		return nil, err
+	}
+
+	respBytes, err := io.ReadAll(resp.Body)
+	if err != nil {
+		return nil, err
+	}
+	albums := []Album{}
+
+	err = json.Unmarshal(respBytes, &albums)
+	if err != nil {
+		return nil, err
+	}
+
+	return albums, nil
+}
+
+type Photo struct {
+	Hash    string `json:"Hash"`
+	FileUID string `json:"FileUID"`
+}
+
+func LoadPhotos(albumID string) ([]Photo, error) {
+	loadPhotosURL := func() string {
+		u := *photoPrismURL
+		u.Path = "/api/v1/photos"
+		v := url.Values{}
+		v.Add("count", "50")
+		v.Add("s", albumID)
+		v.Add("merged", "true")
+		v.Add("video", "false")
+		u.RawQuery = v.Encode()
+		return u.String()
+
+	}()
+
+	req, err := http.NewRequest("GET", loadPhotosURL, nil)
+	if err != nil {
+		return nil, err
+	}
+	req.Header.Set("Authorization", fmt.Sprintf("Bearer %s", photoPrismToken))
+	resp, err := http.DefaultClient.Do(req)
+	if err != nil {
+		return nil, err
+	}
+	respBytes, err := io.ReadAll(resp.Body)
+	if err != nil {
+		return nil, err
+	}
+	photos := []Photo{}
+	err = json.Unmarshal(respBytes, &photos)
+	if err != nil {
+		return nil, err
+	}
+
+	return photos, nil
+}
+
+func DownloadPhoto(photo *Photo) (string, error) {
+	photoPath := path.Join(photosDir, fmt.Sprintf("%s.jpg", photo.FileUID))
+	_, err := os.Stat(photoPath)
+	if err == nil {
+		return photoPath, nil
+	} else if !os.IsNotExist(err) {
+		return "", err
+	}
+	out, err := os.Create(photoPath)
+	if err != nil {
+		return "", fmt.Errorf("failed to create collage output file, err: %w", err)
+	}
+	defer out.Close()
+	downloadPhotoURL := func() string {
+		u := *photoPrismURL
+		u.Path = fmt.Sprintf("/api/v1/dl/%s", photo.Hash)
+		return u.String()
+	}()
+	req, err := http.NewRequest("GET", downloadPhotoURL, nil)
+	if err != nil {
+		return "", err
+	}
+	req.Header.Set("Authorization", fmt.Sprintf("Bearer %s", photoPrismToken))
+	resp, err := http.DefaultClient.Do(req)
+	if err != nil {
+		return "", err
+	}
+
+	_, err = io.Copy(out, resp.Body)
+	if err != nil {
+		return "", err
+	}
+
+	return photoPath, nil
+}

web/choose.html

@@ -0,0 +1,23 @@
+<!doctype html>
+<html>
+  <head>
+    <link rel="icon" href="data:;base64,iVBORw0KGgo=" />
+    <!-- DEVONLY --> <script src="http://localhost:35729/livereload.js"></script>
+    <script src="choose.js" defer></script>
+  </head>
+  <body>
+      <dialog id="notice_dialog">
+      <p id="notice_p"></p>
+      <form><button type="submit" formmethod="dialog">X</button></form>
+      </dialog>
+      <label>
+        <span>Select Album</span>
+        <select id="album_selector" size="8">
+        </select>
+      </label>
+      <button id="load_albums_button">Load Albums</button>
+      <button id="load_photos_button">Load Photos</button>
+      <div id="selected_photos"></div>
+      <div id="album_photos"></div>
+  </body>
+</html>

web/choose.js

@@ -0,0 +1,76 @@
+"use strict";
+
+// elements
+
+/** @type {HTMLButtonElement} */
+let loadAlbumsBtn
+
+/** @type {HTMLButtonElement} */
+let loadPhotosBtn
+
+/** @type {HTMLSelectElement} */
+let albumSelect
+
+/** @type {HTMLParagraphElement} */
+let noticeP
+
+/** @type {HTMLDialogElement} */
+let noticeDialog
+
+function main() {
+    albumSelect = document.getElementById("album_selector")
+    loadAlbumsBtn = document.getElementById("load_albums_button")
+    loadPhotosBtn = document.getElementById("load_photos_button")
+    noticeDialog = document.getElementById("notice_dialog")
+    noticeP = document.getElementById("notice_p")
+    loadAlbumsBtn.onclick = () => loadAlbums()
+    loadPhotosBtn.onclick = () => loadPhotos()
+}
+
+function loadAlbums() {
+    (async () => {
+        try {
+            closeNotice()
+            const resp = await fetch("get-albums")
+            const albums = await resp.json()
+            if(albums.length == 0) {
+                showNotice("No Albums found")
+                return
+            }
+            albumSelect.replaceChildren() // This empties existing options
+            for(const album of albums) {
+                albumSelect.add(new Option(album.Title, album.UID))
+            }
+        } catch(e) {
+            console.log(e)
+        }
+    })();
+}
+
+function closeNotice() {
+    noticeDialog.close()
+}
+
+/**
+ * @param {string} notice
+ */
+function showNotice(notice) {
+    noticeP.textContent = notice
+    noticeDialog.show()
+}
+
+function loadPhotos() {
+    closeNotice()
+    const selected = albumSelect.selectedOptions
+    if(selected.length != 1) {
+        showNotice("Select an album to load photos")
+        return
+    }
+    const [elem] = selected
+    console.log(elem)
+    console.log(elem.text)
+    console.log(elem.value)
+}
+
+
+main()