// Package client - source contains functions for the source API
// Copyright (C) 2020 by Red Hat, Inc.
package client

import (
	"encoding/json"
	//	"fmt"
	"net/http"
	//	"strings"

	"github.com/osbuild/osbuild-composer/internal/weldr"
)

// ListSourcesV0 returns a list of source names
func ListSourcesV0(socket *http.Client) ([]string, *APIResponse, error) {
	body, resp, err := GetRaw(socket, "GET", "/api/v0/projects/source/list")
	if resp != nil || err != nil {
		return nil, resp, err
	}
	var list weldr.SourceListV0
	err = json.Unmarshal(body, &list)
	if err != nil {
		return nil, nil, err
	}
	return list.Sources, nil, nil
}

// ListSourcesV1 returns a list of source ids
func ListSourcesV1(socket *http.Client) ([]string, *APIResponse, error) {
	body, resp, err := GetRaw(socket, "GET", "/api/v1/projects/source/list")
	if resp != nil || err != nil {
		return nil, resp, err
	}
	var list weldr.SourceListV1
	err = json.Unmarshal(body, &list)
	if err != nil {
		return nil, nil, err
	}
	return list.Sources, nil, nil
}

// GetSourceInfoV0 returns detailed information on the named sources
func GetSourceInfoV0(socket *http.Client, sourceNames string) (map[string]weldr.SourceConfigV0, *APIResponse, error) {
	body, resp, err := GetRaw(socket, "GET", "/api/v0/projects/source/info/"+sourceNames)
	if resp != nil || err != nil {
		return nil, resp, err
	}
	var info weldr.SourceInfoResponseV0
	err = json.Unmarshal(body, &info)
	if err != nil {
		return nil, nil, err
	}
	return info.Sources, nil, nil
}

// GetSourceInfoV1 returns detailed information on the named sources
func GetSourceInfoV1(socket *http.Client, sourceNames string) (map[string]weldr.SourceConfigV1, *APIResponse, error) {
	body, resp, err := GetRaw(socket, "GET", "/api/v1/projects/source/info/"+sourceNames)
	if resp != nil || err != nil {
		return nil, resp, err
	}
	var info weldr.SourceInfoResponseV1
	err = json.Unmarshal(body, &info)
	if err != nil {
		return nil, nil, err
	}
	return info.Sources, nil, nil
}

// PostJSONSourceV0 sends a JSON source string to the API
// and returns an APIResponse
func PostJSONSourceV0(socket *http.Client, source string) (*APIResponse, error) {
	body, resp, err := PostJSON(socket, "/api/v0/projects/source/new", source)
	if resp != nil || err != nil {
		return resp, err
	}
	return NewAPIResponse(body)
}

// PostJSONSourceV1 sends a JSON source string to the API
// and returns an APIResponse
func PostJSONSourceV1(socket *http.Client, source string) (*APIResponse, error) {
	body, resp, err := PostJSON(socket, "/api/v1/projects/source/new", source)
	if resp != nil || err != nil {
		return resp, err
	}
	return NewAPIResponse(body)
}

// PostTOMLSourceV0 sends a TOML source string to the API
// and returns an APIResponse
func PostTOMLSourceV0(socket *http.Client, source string) (*APIResponse, error) {
	body, resp, err := PostTOML(socket, "/api/v0/projects/source/new", source)
	if resp != nil || err != nil {
		return resp, err
	}
	return NewAPIResponse(body)
}

// PostTOMLSourceV1 sends a TOML source string to the API
// and returns an APIResponse
func PostTOMLSourceV1(socket *http.Client, source string) (*APIResponse, error) {
	body, resp, err := PostTOML(socket, "/api/v1/projects/source/new", source)
	if resp != nil || err != nil {
		return resp, err
	}
	return NewAPIResponse(body)
}

// DeleteSourceV0 deletes the named source and returns an APIResponse
func DeleteSourceV0(socket *http.Client, sourceName string) (*APIResponse, error) {
	body, resp, err := DeleteRaw(socket, "/api/v0/projects/source/delete/"+sourceName)
	if resp != nil || err != nil {
		return resp, err
	}
	return NewAPIResponse(body)
}

// DeleteSourceV1 deletes the named source and returns an APIResponse
func DeleteSourceV1(socket *http.Client, sourceName string) (*APIResponse, error) {
	body, resp, err := DeleteRaw(socket, "/api/v1/projects/source/delete/"+sourceName)
	if resp != nil || err != nil {
		return resp, err
	}
	return NewAPIResponse(body)
}