package mastodon

import (
	"bytes"
	"context"
	"encoding/json"
	"fmt"
	"io"
	"net/http"
	"time"

	"codeberg.org/snonux/gos/internal/colour"
	"codeberg.org/snonux/gos/internal/config"
	"codeberg.org/snonux/gos/internal/entry"
	"codeberg.org/snonux/gos/internal/prompt"
)

const mastodonTimeout = 10 * time.Second

func Post(ctx context.Context, args config.Args, sizeLimit int, en entry.Entry) error {
	content, _, err := en.ContentWithLimit(sizeLimit)
	if err != nil {
		return err
	}
	if args.DryRun {
		colour.Infoln("Not posting", en, "to Mastodon as dry-run enabled")
		return nil
	}
	if content, err = prompt.FileAction("Do you want to post this message to Mastodon?",
		content, en.Path, prompt.RandomOption); err != nil {
		return err
	}

	payload := map[string]string{"status": content}
	payloadBytes, err := json.Marshal(payload)
	if err != nil {
		return fmt.Errorf("failed to marshal payload: %w", err)
	}

	newCtx, cancel := context.WithTimeout(ctx, mastodonTimeout)
	defer cancel()
	req, err := http.NewRequestWithContext(newCtx, "POST", args.Config.MastodonURL, bytes.NewBuffer(payloadBytes))
	if err != nil {
		return fmt.Errorf("failed to create request: %w", err)
	}

	req.Header.Set("Authorization", "Bearer "+args.Config.MastodonAccessToken)
	req.Header.Set("Content-Type", "application/json")

	client := &http.Client{}
	resp, err := client.Do(req)
	if err != nil {
		return fmt.Errorf("request failed: %w", err)
	}
	defer func() {
		if err := resp.Body.Close(); err != nil {
			// Log the error but don't fail the operation since we've already read the data
			colour.Errorln("Error closing response body:", err)
		}
	}()
	body, err := io.ReadAll(resp.Body)
	if err != nil {
		return err
	}

	if resp.StatusCode != http.StatusOK {
		return fmt.Errorf("unexpected status code: %d\n%s\n",
			resp.StatusCode, string(body))
	}
	return nil
}