feat: implement activity resource and data source

internal/client/activity.go

@@ -0,0 +1,100 @@
+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
+}