thomas/multiarch-docker-images
1
0
Fork 0
mirror of https://github.com/napnap75/multiarch-docker-images.git synced 2025-12-16 03:34:18 +01:00
Code Issues Projects Releases Wiki Activity

Updated to immich 1.106

Browse Source
This commit is contained in:
napnap75
2024-06-15 12:11:34 +02:00
parent 07c387ddbb
commit 28bc2b92bc
2 changed files with 74 additions and 60 deletions
Download Patch File Download Diff File Expand all files Collapse all files

7
immich-souvenirs/README.md Normal file
View File

@@ -0,0 +1,7 @@
## Development env
docker run --rm -it -v $PWD:/go/src/napnap75/immich-souvenirs -v immich-souvenirs_config:/config golang:1.21-alpine /bin/sh
apk add --no-cache git gcc musl-dev nano
cd src/napnap75/immich-souvenirs/
go mod init github.com/napnap75/multiarch-docker-files/immich-souvenirs
go get -d -v
go run immich-souvenirs.go --immich-url="https://immich.nappez.com" --immich-key="wRJWYUGlEfWGQ3a5lckHivLCU40s7ldEZSmikpmsE30" --whatsapp-session-file=/config/ws.gob --whatsapp-group="120363288639885954@g.us" --run-once

127
immich-souvenirs/immich-souvenirs.go
View File

@@ -11,7 +11,6 @@ import (
"os/signal" "os/signal"
"net/http" "net/http"
"time" "time"
_ "github.com/go-sql-driver/mysql"
"github.com/mdp/qrterminal/v3" "github.com/mdp/qrterminal/v3"
_ "github.com/mattn/go-sqlite3" _ "github.com/mattn/go-sqlite3"
"google.golang.org/protobuf/proto" "google.golang.org/protobuf/proto"
@@ -27,6 +26,7 @@ type parameters struct {
immichKey string immichKey string
whatsappSessionFile string whatsappSessionFile string
whatsappGroup string whatsappGroup string
runOnce bool
} }
func loadParameters() (parameters) { func loadParameters() (parameters) {
@@ -35,6 +35,7 @@ func loadParameters() (parameters) {
flag.StringVar(&param.immichKey, "immich-key", "", "The API KEY to use with Immich") flag.StringVar(&param.immichKey, "immich-key", "", "The API KEY to use with Immich")
flag.StringVar(&param.whatsappSessionFile, "whatsapp-session-file", "", "The file to save the WhatsApp session to") flag.StringVar(&param.whatsappSessionFile, "whatsapp-session-file", "", "The file to save the WhatsApp session to")
flag.StringVar(&param.whatsappGroup, "whatsapp-group", "", "The ID of the WhatsApp group to send the message to") flag.StringVar(&param.whatsappGroup, "whatsapp-group", "", "The ID of the WhatsApp group to send the message to")
flag.BoolVar(&param.runOnce, "run-once", false, "Run once and exits (default to false)")
flag.Parse() flag.Parse()
return *param return *param
} }
@@ -137,25 +138,25 @@ func testConnexions(param parameters) error {
spaceClient := http.Client{ spaceClient := http.Client{
Timeout: time.Second * 10, Timeout: time.Second * 10,
} }
req, err := http.NewRequest(http.MethodGet, param.immichURL + "/api/album", nil) req, err := http.NewRequest(http.MethodGet, param.immichURL + "/api/albums", nil)
if err != nil { if err != nil {
return fmt.Errorf("Error connecting to Immich with URL '%s': %v", param.immichURL, err) return fmt.Errorf("Error connecting to Immich with URL '%s': %v", param.immichURL, err)
} }
req.Header.Set("x-api-key", param.immichKey) req.Header.Set("x-api-key", param.immichKey)
req.Header.Set("Accept", "application/json") req.Header.Set("Accept", "application/json")
res, getErr := spaceClient.Do(req) res, err := spaceClient.Do(req)
if getErr != nil { if err != nil {
return fmt.Errorf("Error connecting to Immich with URL '%s': %v", param.immichURL, err) return fmt.Errorf("Error connecting to Immich with URL '%s': %v", param.immichURL, err)
} }
if res.Body != nil { if res.Body != nil {
defer res.Body.Close() defer res.Body.Close()
} }
if res.StatusCode != 200 { if res.StatusCode != 200 {
return fmt.Errorf("Error connecting to Immich with URL '%s': Status code %n", param.immichURL, res.StatusCode) return fmt.Errorf("Error connecting to Immich with URL '%s': Status code %d", param.immichURL, res.StatusCode)
} }
body, readErr := ioutil.ReadAll(res.Body) body, err := ioutil.ReadAll(res.Body)
if readErr != nil { if err != nil {
return fmt.Errorf("Error connecting to Immich with URL '%s': %v", param.immichURL, err) return fmt.Errorf("Error connecting to Immich with URL '%s': %v", param.immichURL, err)
} }
var albums []map[string]interface{} var albums []map[string]interface{}
@@ -175,24 +176,24 @@ func getSharingKey(album map[string]interface{}, param parameters) (string, erro
albumName := album["albumName"].(string) albumName := album["albumName"].(string)
if (album["hasSharedLink"].(bool)) { if (album["hasSharedLink"].(bool)) {
// Retrieve the existing key // Retrieve the existing key
req, err := http.NewRequest(http.MethodGet, param.immichURL + "/api/shared-link", nil) req, err := http.NewRequest(http.MethodGet, param.immichURL + "/api/shared-links", nil)
if err != nil { if err != nil {
return "", fmt.Errorf("Error retrieving sharing key for album '%s': %v", albumName, err) return "", fmt.Errorf("Error retrieving sharing key for album '%s': %v", albumName, err)
} }
req.Header.Set("x-api-key", param.immichKey) req.Header.Set("x-api-key", param.immichKey)
req.Header.Set("Accept", "application/json") req.Header.Set("Accept", "application/json")
res, getErr := spaceClient.Do(req) res, err := spaceClient.Do(req)
if getErr != nil { if err != nil {
return "", fmt.Errorf("Error retrieving sharing key for album '%s': %v", albumName, err) return "", fmt.Errorf("Error retrieving sharing key for album '%s': %v", albumName, err)
} }
if res.Body != nil { if res.Body != nil {
defer res.Body.Close() defer res.Body.Close()
} }
if res.StatusCode != 200 { if res.StatusCode != 200 {
return "", fmt.Errorf("Error retrieving sharing key for album '%s': Status code %n", albumName, res.StatusCode) return "", fmt.Errorf("Error retrieving sharing key for album '%s': Status code %d", albumName, res.StatusCode)
} }
body, readErr := ioutil.ReadAll(res.Body) body, err := ioutil.ReadAll(res.Body)
if readErr != nil { if err != nil {
return "", fmt.Errorf("Error retrieving sharing key for album '%s': %v", albumName, err) return "", fmt.Errorf("Error retrieving sharing key for album '%s': %v", albumName, err)
} }
var keys []map[string]interface{} var keys []map[string]interface{}
@@ -217,25 +218,25 @@ func getSharingKey(album map[string]interface{}, param parameters) (string, erro
"showMetadata": true, "showMetadata": true,
"type": "ALBUM" "type": "ALBUM"
}`) }`)
req, err := http.NewRequest(http.MethodPost, param.immichURL + "/api/shared-link", bytes.NewBuffer(jsonData)) req, err := http.NewRequest(http.MethodPost, param.immichURL + "/api/shared-links", bytes.NewBuffer(jsonData))
if err != nil { if err != nil {
return "", fmt.Errorf("Error creating missing key for album '%s': %v", albumName, err) return "", fmt.Errorf("Error creating missing key for album '%s': %v", albumName, err)
} }
req.Header.Set("x-api-key", param.immichKey) req.Header.Set("x-api-key", param.immichKey)
req.Header.Set("Content-Type", "application/json") req.Header.Set("Content-Type", "application/json")
req.Header.Set("Accept", "application/octet-stream") req.Header.Set("Accept", "application/octet-stream")
res, getErr := spaceClient.Do(req) res, err := spaceClient.Do(req)
if getErr != nil { if err != nil {
return "", fmt.Errorf("Error creating missing key for album '%s': %v", albumName, err) return "", fmt.Errorf("Error creating missing key for album '%s': %v", albumName, err)
} }
if res.Body != nil { if res.Body != nil {
defer res.Body.Close() defer res.Body.Close()
} }
if res.StatusCode != 201 { if res.StatusCode != 201 {
return "", fmt.Errorf("Error creating missing key for album '%s': Status code %n", albumName, res.StatusCode) return "", fmt.Errorf("Error creating missing key for album '%s': Status code %d", albumName, res.StatusCode)
} }
body, readErr := ioutil.ReadAll(res.Body) body, err := ioutil.ReadAll(res.Body)
if readErr != nil { if err != nil {
return "", fmt.Errorf("Error creating missing key for album '%s': %v", albumName, err) return "", fmt.Errorf("Error creating missing key for album '%s': %v", albumName, err)
} }
var key map[string]interface{} var key map[string]interface{}
@@ -253,24 +254,24 @@ func getThumbnail(album map[string]interface{}, param parameters) ([]byte, error
} }
albumName := album["albumName"].(string) albumName := album["albumName"].(string)
req, err := http.NewRequest(http.MethodGet, param.immichURL + "/api/asset/thumbnail/" + album["albumThumbnailAssetId"].(string), nil) req, err := http.NewRequest(http.MethodGet, param.immichURL + "/api/assets/" + album["albumThumbnailAssetId"].(string) + "/thumbnail?size=preview", nil)
if err != nil { if err != nil {
return nil, fmt.Errorf("Error retrieving thumbnail for album '%s': %v", albumName, err) return nil, fmt.Errorf("Error retrieving thumbnail for album '%s': %v", albumName, err)
} }
req.Header.Set("x-api-key", param.immichKey) req.Header.Set("x-api-key", param.immichKey)
req.Header.Set("Accept", "application/octet-stream") req.Header.Set("Accept", "application/octet-stream")
res, getErr := spaceClient.Do(req) res, err := spaceClient.Do(req)
if getErr != nil { if err != nil {
return nil, fmt.Errorf("Error retrieving thumbnail for album '%s': %v", albumName, err) return nil, fmt.Errorf("Error retrieving thumbnail for album '%s': %v", albumName, err)
} }
if res.Body != nil { if res.Body != nil {
defer res.Body.Close() defer res.Body.Close()
} }
if res.StatusCode != 200 { if res.StatusCode != 200 {
return nil, fmt.Errorf("Error retrieving thumbnail for album '%s': Status code %n", albumName, res.StatusCode) return nil, fmt.Errorf("Error retrieving thumbnail for album '%s': Status code %d", albumName, res.StatusCode)
} }
thumbnail, readErr := ioutil.ReadAll(res.Body) thumbnail, err := ioutil.ReadAll(res.Body)
if readErr != nil { if err != nil {
return nil, fmt.Errorf("Error retrieving thumbnail for album '%s': %v", albumName, err) return nil, fmt.Errorf("Error retrieving thumbnail for album '%s': %v", albumName, err)
} }
@@ -291,25 +292,25 @@ func runLoop(param parameters) error {
spaceClient := http.Client{ spaceClient := http.Client{
Timeout: time.Second * 10, Timeout: time.Second * 10,
} }
req, err := http.NewRequest(http.MethodGet, param.immichURL + "/api/album", nil) req, err := http.NewRequest(http.MethodGet, param.immichURL + "/api/albums", nil)
if err != nil { if err != nil {
return fmt.Errorf("Error connecting to Immich with URL '%s': %v", param.immichURL, err) return fmt.Errorf("Error connecting to Immich with URL '%s': %v", param.immichURL, err)
} }
req.Header.Set("x-api-key", param.immichKey) req.Header.Set("x-api-key", param.immichKey)
req.Header.Set("Accept", "application/json") req.Header.Set("Accept", "application/json")
res, getErr := spaceClient.Do(req) res, err := spaceClient.Do(req)
if getErr != nil { if err != nil {
return fmt.Errorf("Error connecting to Immich with URL '%s': %v", param.immichURL, err) return fmt.Errorf("Error connecting to Immich with URL '%s': %v", param.immichURL, err)
} }
if res.Body != nil { if res.Body != nil {
defer res.Body.Close() defer res.Body.Close()
} }
if res.StatusCode != 200 { if res.StatusCode != 200 {
return fmt.Errorf("Error connecting to Immich with URL '%s': Status code %n", param.immichURL, res.StatusCode) return fmt.Errorf("Error connecting to Immich with URL '%s': Status code %d", param.immichURL, res.StatusCode)
} }
body, readErr := ioutil.ReadAll(res.Body) body, err := ioutil.ReadAll(res.Body)
if readErr != nil { if err != nil {
return fmt.Errorf("Error connecting to Immich with URL '%s': %v", param.immichURL, err) return fmt.Errorf("Error connecting to Immich with URL '%s': %v", param.immichURL, err)
} }
var albums []map[string]interface{} var albums []map[string]interface{}
@@ -334,19 +335,19 @@ func runLoop(param parameters) error {
if isShared && (albumDate.Month() == time.Now().Month()) && (albumDate.Day() == time.Now().Day()) { if isShared && (albumDate.Month() == time.Now().Month()) && (albumDate.Day() == time.Now().Day()) {
// Retrieve the sharing key // Retrieve the sharing key
sharingKey, err := getSharingKey(album, param) sharingKey, err := getSharingKey(album, param)
if readErr != nil { if err != nil {
return fmt.Errorf("Error retrieving the sharing key for album '%s': %v", albumName, err) return fmt.Errorf("Error retrieving the sharing key for album '%s': %v", albumName, err)
} }
// Retrieve the thumbnail // Retrieve the thumbnail
thumbnail, err := getThumbnail(album, param) thumbnail, err := getThumbnail(album, param)
if readErr != nil { if err != nil {
return fmt.Errorf("Error retrieving thumbnail for album '%s': %v", albumName, err) return fmt.Errorf("Error retrieving thumbnail for album '%s': %v", albumName, err)
} }
// Send the message // Send the message
link := param.immichURL + "/share/" + sharingKey link := param.immichURL + "/share/" + sharingKey
sendMessage(client, param.whatsappGroup, fmt.Sprintf("Il y a %d an(s) : %s", time.Now().Year()-albumDate.Year(), link), link, albumName, thumbnail) err = sendMessage(client, param.whatsappGroup, fmt.Sprintf("Il y a %d an(s) : %s", time.Now().Year()-albumDate.Year(), link), link, albumName, thumbnail)
if err != nil { if err != nil {
fmt.Fprintf(os.Stderr, "Error sending message to WhatsApp for album '%s': %v\n", albumName, err) fmt.Fprintf(os.Stderr, "Error sending message to WhatsApp for album '%s': %v\n", albumName, err)
continue continue
@@ -357,19 +358,19 @@ func runLoop(param parameters) error {
if isShared && (createDate.Year() == time.Now().AddDate(0, 0, -1).Year()) && (createDate.Month() == time.Now().AddDate(0, 0, -1).Month()) && (createDate.Day() == time.Now().AddDate(0, 0, -1).Day()) { if isShared && (createDate.Year() == time.Now().AddDate(0, 0, -1).Year()) && (createDate.Month() == time.Now().AddDate(0, 0, -1).Month()) && (createDate.Day() == time.Now().AddDate(0, 0, -1).Day()) {
// Retrieve the sharing key // Retrieve the sharing key
sharingKey, err := getSharingKey(album, param) sharingKey, err := getSharingKey(album, param)
if readErr != nil { if err != nil {
return fmt.Errorf("Error retrieving the sharing key for album '%s': %v", albumName, err) return fmt.Errorf("Error retrieving the sharing key for album '%s': %v", albumName, err)
} }
// Retrieve the thumbnail // Retrieve the thumbnail
thumbnail, err := getThumbnail(album, param) thumbnail, err := getThumbnail(album, param)
if readErr != nil { if err != nil {
return fmt.Errorf("Error retrieving thumbnail for album '%s': %v", albumName, err) return fmt.Errorf("Error retrieving thumbnail for album '%s': %v", albumName, err)
} }
// Send the message // Send the message
link := param.immichURL + "/share/" + sharingKey link := param.immichURL + "/share/" + sharingKey
sendMessage(client, param.whatsappGroup, fmt.Sprintf("Nouvel album : %s", link), link, albumName, thumbnail) err = sendMessage(client, param.whatsappGroup, fmt.Sprintf("Nouvel album : %s", link), link, albumName, thumbnail)
if err != nil { if err != nil {
fmt.Fprintf(os.Stderr, "Error sending message to WhatsApp for album '%s': %v\n", albumName, err) fmt.Fprintf(os.Stderr, "Error sending message to WhatsApp for album '%s': %v\n", albumName, err)
continue continue
@@ -395,30 +396,36 @@ func main() {
// Load the parameters // Load the parameters
param := loadParameters() param := loadParameters()
if param.runOnce {
// Test the connexion on startup
err := testConnexions(param)
if err != nil {
fmt.Fprintf(os.Stderr, "Unable to connect: %v\n", err)
return
}
// Run the loop everyday at 7
for {
t := time.Now()
n := time.Date(t.Year(), t.Month(), t.Day(), 7, 0, 0, 0, t.Location())
d := n.Sub(t)
if d < 0 {
n = n.Add(24 * time.Hour)
d = n.Sub(t)
}
fmt.Fprintf(os.Stderr, "Sleeping for: %s\n", d)
time.Sleep(d)
err := runLoop(param) err := runLoop(param)
if err != nil { if err != nil {
fmt.Fprintf(os.Stderr, "Error: %v\n", err) fmt.Fprintf(os.Stderr, "Error: %v\n", err)
continue }
} else {
// Test the connexion on startup
err := testConnexions(param)
if err != nil {
fmt.Fprintf(os.Stderr, "Unable to connect: %v\n", err)
return
}
// Run the loop everyday at 7
for {
t := time.Now()
n := time.Date(t.Year(), t.Month(), t.Day(), 7, 0, 0, 0, t.Location())
d := n.Sub(t)
if d < 0 {
n = n.Add(24 * time.Hour)
d = n.Sub(t)
}
fmt.Fprintf(os.Stderr, "Sleeping for: %s\n", d)
time.Sleep(d)
err := runLoop(param)
if err != nil {
fmt.Fprintf(os.Stderr, "Error: %v\n", err)
continue
}
} }
} }
} }