101 lines
2.6 KiB
Go
101 lines
2.6 KiB
Go
package client
|
|
|
|
import (
|
|
"bytes"
|
|
"encoding/json"
|
|
"fmt"
|
|
"net/http"
|
|
)
|
|
|
|
type Activity struct {
|
|
ID string `json:"id"`
|
|
Type string `json:"type"` // COMMENT or LIKE
|
|
AssetId string `json:"assetId,omitempty"`
|
|
AlbumId string `json:"albumId"`
|
|
User User `json:"user"`
|
|
Comment string `json:"comment,omitempty"`
|
|
CreatedAt string `json:"createdAt"`
|
|
}
|
|
|
|
type CreateActivityRequest struct {
|
|
Type string `json:"type"` // comment or like
|
|
AlbumId string `json:"albumId"`
|
|
AssetId string `json:"assetId,omitempty"`
|
|
Comment string `json:"comment,omitempty"`
|
|
}
|
|
|
|
func (c *Client) GetActivities(albumId string, assetId string) ([]Activity, error) {
|
|
url := fmt.Sprintf("%s/activities?albumId=%s", c.HostURL, albumId)
|
|
if assetId != "" {
|
|
url = fmt.Sprintf("%s&assetId=%s", url, assetId)
|
|
}
|
|
req, err := http.NewRequest("GET", url, nil)
|
|
if err != nil {
|
|
return nil, err
|
|
}
|
|
|
|
body, err := c.doRequest(req)
|
|
if err != nil {
|
|
return nil, err
|
|
}
|
|
|
|
var activities []Activity
|
|
err = json.Unmarshal(body, &activities)
|
|
if err != nil {
|
|
return nil, err
|
|
}
|
|
|
|
return activities, nil
|
|
}
|
|
|
|
func (c *Client) GetActivity(id string) (*Activity, error) {
|
|
// Immich doesn't seem to have a direct GET /activities/{id} based on research.
|
|
// We might have to find it in the list if we want to "Read" it by ID alone.
|
|
// But usually Terraform Read has the ID.
|
|
// If the API doesn't support GET by ID, we'll have to return an error or handle it.
|
|
// Wait, some research showed DELETE /activities/{id}.
|
|
// If there's no GET /activities/{id}, we might have a problem with pure Terraform Read.
|
|
// However, we can probably use a data source or just return the state if we can't refresh it easily.
|
|
// Actually, let's assume it doesn't exist for now and see if we can find a workaround.
|
|
return nil, fmt.Errorf("GET /activities/{id} is not supported by Immich API")
|
|
}
|
|
|
|
func (c *Client) CreateActivity(activity CreateActivityRequest) (*Activity, error) {
|
|
rb, err := json.Marshal(activity)
|
|
if err != nil {
|
|
return nil, err
|
|
}
|
|
|
|
req, err := http.NewRequest("POST", fmt.Sprintf("%s/activities", c.HostURL), bytes.NewBuffer(rb))
|
|
if err != nil {
|
|
return nil, err
|
|
}
|
|
|
|
body, err := c.doRequest(req)
|
|
if err != nil {
|
|
return nil, err
|
|
}
|
|
|
|
var newActivity Activity
|
|
err = json.Unmarshal(body, &newActivity)
|
|
if err != nil {
|
|
return nil, err
|
|
}
|
|
|
|
return &newActivity, nil
|
|
}
|
|
|
|
func (c *Client) DeleteActivity(id string) error {
|
|
req, err := http.NewRequest("DELETE", fmt.Sprintf("%s/activities/%s", c.HostURL, id), nil)
|
|
if err != nil {
|
|
return err
|
|
}
|
|
|
|
_, err = c.doRequest(req)
|
|
if err != nil {
|
|
return err
|
|
}
|
|
|
|
return nil
|
|
}
|