// Package client - blueprints contains functions for the blueprint API

// Copyright (C) 2020 by Red Hat, Inc.

package client

import (

	"encoding/json"

	"fmt"

	"net/http"

	"strings"

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

)

// PostTOMLBlueprintV0 sends a TOML blueprint string to the API

// and returns an APIResponse

func PostTOMLBlueprintV0(socket *http.Client, blueprint string) (*APIResponse, error) {

	body, resp, err := PostTOML(socket, "/api/v0/blueprints/new", blueprint)

	if resp != nil || err != nil {

		return resp, err

	}

	return NewAPIResponse(body)

}

// PostTOMLWorkspaceV0 sends a TOML blueprint string to the API

// and returns an APIResponse

func PostTOMLWorkspaceV0(socket *http.Client, blueprint string) (*APIResponse, error) {

	body, resp, err := PostTOML(socket, "/api/v0/blueprints/workspace", blueprint)

	if resp != nil || err != nil {

		return resp, err

	}

	return NewAPIResponse(body)

}

// PostJSONBlueprintV0 sends a JSON blueprint string to the API

// and returns an APIResponse

func PostJSONBlueprintV0(socket *http.Client, blueprint string) (*APIResponse, error) {

	body, resp, err := PostJSON(socket, "/api/v0/blueprints/new", blueprint)

	if resp != nil || err != nil {

		return resp, err

	}

	return NewAPIResponse(body)

}

// PostJSONWorkspaceV0 sends a JSON blueprint string to the API

// and returns an APIResponse

func PostJSONWorkspaceV0(socket *http.Client, blueprint string) (*APIResponse, error) {

	body, resp, err := PostJSON(socket, "/api/v0/blueprints/workspace", blueprint)

	if resp != nil || err != nil {

		return resp, err

	}

	return NewAPIResponse(body)

}

// DeleteBlueprintV0 deletes the named blueprint and returns an APIResponse

func DeleteBlueprintV0(socket *http.Client, bpName string) (*APIResponse, error) {

	body, resp, err := DeleteRaw(socket, "/api/v0/blueprints/delete/"+bpName)

	if resp != nil || err != nil {

		return resp, err

	}

	return NewAPIResponse(body)

}

// DeleteWorkspaceV0 deletes the named blueprint's workspace and returns an APIResponse

func DeleteWorkspaceV0(socket *http.Client, bpName string) (*APIResponse, error) {

	body, resp, err := DeleteRaw(socket, "/api/v0/blueprints/workspace/"+bpName)

	if resp != nil || err != nil {

		return resp, err

	}

	return NewAPIResponse(body)

}

// ListBlueprintsV0 returns a list of blueprint names

func ListBlueprintsV0(socket *http.Client) ([]string, *APIResponse, error) {

	body, resp, err := GetJSONAll(socket, "/api/v0/blueprints/list")

	if resp != nil || err != nil {

		return nil, resp, err

	}

	var list weldr.BlueprintsListV0

	err = json.Unmarshal(body, &list)

	if err != nil {

		return nil, nil, err

	}

	return list.Blueprints, nil, nil

}

// GetBlueprintInfoTOMLV0 returns the requested blueprint as a TOML string

func GetBlueprintInfoTOMLV0(socket *http.Client, bpName string) (string, *APIResponse, error) {

	body, resp, err := GetRaw(socket, "GET", "/api/v0/blueprints/info/"+bpName+"?format=toml")

	if resp != nil || err != nil {

		return "", resp, err

	}

	return string(body), nil, nil

}

// GetBlueprintsInfoJSONV0 returns the requested blueprints and their changed state

func GetBlueprintsInfoJSONV0(socket *http.Client, bpName string) (weldr.BlueprintsInfoV0, *APIResponse, error) {

	body, resp, err := GetRaw(socket, "GET", "/api/v0/blueprints/info/"+bpName)

	if resp != nil || err != nil {

		return weldr.BlueprintsInfoV0{}, resp, err

	}

	var info weldr.BlueprintsInfoV0

	err = json.Unmarshal(body, &info)

	if err != nil {

		return weldr.BlueprintsInfoV0{}, nil, err

	}

	return info, nil, nil

}

// GetBlueprintsChangesV0 returns the changes to the listed blueprints

func GetBlueprintsChangesV0(socket *http.Client, bpNames []string) (weldr.BlueprintsChangesV0, *APIResponse, error) {

	names := strings.Join(bpNames, ",")

	body, resp, err := GetRaw(socket, "GET", "/api/v0/blueprints/changes/"+names)

	if resp != nil || err != nil {

		return weldr.BlueprintsChangesV0{}, resp, err

	}

	var changes weldr.BlueprintsChangesV0

	err = json.Unmarshal(body, &changes)

	if err != nil {

		return weldr.BlueprintsChangesV0{}, nil, err

	}

	return changes, nil, nil

}

// UndoBlueprintChangeV0 reverts a blueprint to a previous commit

func UndoBlueprintChangeV0(socket *http.Client, blueprint, commit string) (*APIResponse, error) {

	request := fmt.Sprintf("/api/v0/blueprints/undo/%s/%s", blueprint, commit)

	body, resp, err := PostRaw(socket, request, "", nil)

	if resp != nil || err != nil {

		return resp, err

	}

	return NewAPIResponse(body)

}

// TagBlueprintV0 tags the current blueprint commit as a new revision

func TagBlueprintV0(socket *http.Client, blueprint string) (*APIResponse, error) {

	body, resp, err := PostRaw(socket, "/api/v0/blueprints/tag/"+blueprint, "", nil)

	if resp != nil || err != nil {

		return resp, err

	}

	return NewAPIResponse(body)

}

// DepsolveBlueprintV0 depsolves the listed blueprint

func DepsolveBlueprintV0(socket *http.Client, blueprint string) (weldr.BlueprintsDepsolveV0, *APIResponse, error) {

	body, resp, err := GetRaw(socket, "GET", "/api/v0/blueprints/depsolve/"+blueprint)

	if resp != nil || err != nil {

		return weldr.BlueprintsDepsolveV0{}, resp, err

	}

	var deps weldr.BlueprintsDepsolveV0

	err = json.Unmarshal(body, &deps)

	if err != nil {

		return weldr.BlueprintsDepsolveV0{}, nil, err

	}

	return deps, nil, nil

}

// FreezeBlueprintV0 depsolves the listed blueprint and returns the blueprint with frozen package

// versions

func FreezeBlueprintV0(socket *http.Client, blueprint string) (weldr.BlueprintsFreezeV0, *APIResponse, error) {

	body, resp, err := GetRaw(socket, "GET", "/api/v0/blueprints/freeze/"+blueprint)

	if resp != nil || err != nil {

		return weldr.BlueprintsFreezeV0{}, resp, err

	}

	var frozen weldr.BlueprintsFreezeV0

	err = json.Unmarshal(body, &frozen)

	if err != nil {

		return weldr.BlueprintsFreezeV0{}, nil, err

	}

	return frozen, nil, nil

}