feedback.go

// Copyright 2017-2026 Allow2 Pty Ltd. All rights reserved.
// Use of this source code is governed by the Allow2 API and SDK Licence.

package allow2service

import (
	"fmt"
	"net/url"
)

// feedbackManager manages feedback submission and discussion threads via the Allow2 API.
type feedbackManager struct {
	httpClient HTTPClient
	apiHost    string
}

// Submit submits new feedback. Returns the discussion ID.
func (m *feedbackManager) Submit(accessToken, userID string, category FeedbackCategory, message string) (string, error) {
	response, err := m.httpClient.Post(
		m.apiHost+"/feedback/submit",
		map[string]interface{}{
			"access_token": accessToken,
			"category":     category.Value(),
			"message":      message,
		},
		nil,
	)
	if err != nil {
		return "", &ApiError{
			Allow2Error: Allow2Error{Message: fmt.Sprintf("Failed to submit feedback: %v", err)},
		}
	}

	if response.IsUnauthorized() {
		return "", &UnpairedError{
			Allow2Error: Allow2Error{Message: "Service account is no longer linked. Re-pairing required."},
			UserID:      userID,
		}
	}

	if !response.IsSuccess() {
		body := response.JSON()
		return "", &ApiError{
			Allow2Error:    Allow2Error{Message: fmt.Sprintf("Failed to submit feedback: HTTP %d", response.StatusCode)},
			HTTPStatusCode: response.StatusCode,
			ResponseBody:   body,
		}
	}

	data := response.JSON()
	if data == nil {
		return "", nil
	}

	for _, key := range []string{"discussionId", "feedbackId", "id"} {
		if v, ok := data[key]; ok {
			return fmt.Sprintf("%v", v), nil
		}
	}

	return "", nil
}

// Load loads all feedback discussions for the authenticated user.
func (m *feedbackManager) Load(accessToken, userID string) ([]interface{}, error) {
	response, err := m.httpClient.Get(
		m.apiHost+"/feedback/load",
		map[string]string{"Authorization": "Bearer " + accessToken},
	)
	if err != nil {
		return nil, &ApiError{
			Allow2Error: Allow2Error{Message: fmt.Sprintf("Failed to load feedback: %v", err)},
		}
	}

	if response.IsUnauthorized() {
		return nil, &UnpairedError{
			Allow2Error: Allow2Error{Message: "Service account is no longer linked. Re-pairing required."},
			UserID:      userID,
		}
	}

	if !response.IsSuccess() {
		body := response.JSON()
		return nil, &ApiError{
			Allow2Error:    Allow2Error{Message: fmt.Sprintf("Failed to load feedback: HTTP %d", response.StatusCode)},
			HTTPStatusCode: response.StatusCode,
			ResponseBody:   body,
		}
	}

	data := response.JSON()
	if data == nil {
		return nil, nil
	}

	for _, key := range []string{"discussions", "feedback"} {
		if v, ok := data[key]; ok {
			if arr, ok := v.([]interface{}); ok {
				return arr, nil
			}
		}
	}

	return nil, nil
}

// Reply replies to an existing feedback discussion thread.
func (m *feedbackManager) Reply(accessToken, userID, discussionID, message string) error {
	response, err := m.httpClient.Post(
		m.apiHost+"/feedback/"+url.PathEscape(discussionID)+"/reply",
		map[string]interface{}{
			"access_token": accessToken,
			"message":      message,
		},
		nil,
	)
	if err != nil {
		return &ApiError{
			Allow2Error: Allow2Error{Message: fmt.Sprintf("Failed to reply to feedback: %v", err)},
		}
	}

	if response.IsUnauthorized() {
		return &UnpairedError{
			Allow2Error: Allow2Error{Message: "Service account is no longer linked. Re-pairing required."},
			UserID:      userID,
		}
	}

	if !response.IsSuccess() {
		body := response.JSON()
		return &ApiError{
			Allow2Error:    Allow2Error{Message: fmt.Sprintf("Failed to reply to feedback: HTTP %d", response.StatusCode)},
			HTTPStatusCode: response.StatusCode,
			ResponseBody:   body,
		}
	}

	return nil
}