//go:build windows

package uvm

import (
	"context"
	"fmt"

	"github.com/Microsoft/hcsshim/internal/gcs"
	"github.com/Microsoft/hcsshim/internal/gcs/prot"
	"github.com/Microsoft/hcsshim/internal/log"
	"github.com/Microsoft/hcsshim/internal/protocol/guestrequest"
	"github.com/Microsoft/hcsshim/internal/vm/vmutils/etw"
)

func (uvm *UtilityVM) StartLogForwarding(ctx context.Context) error {
	// Implementation for starting the log forwarding service
	if uvm.OS() != "windows" || uvm.gc == nil {
		return errNotSupported
	}

	wcaps := gcs.GetWCOWCapabilities(uvm.gc.Capabilities())
	if wcaps != nil && wcaps.IsLogForwardingSupported() {
		req := guestrequest.LogForwardServiceRPCRequest{
			RPCType:  guestrequest.RPCStartLogForwarding,
			Settings: "",
		}
		err := uvm.gc.ModifyServiceSettings(ctx, prot.LogForwardService, req)
		if err != nil {
			return err
		}
	} else {
		log.G(ctx).WithField("os", uvm.operatingSystem).Error("Log forwarding not supported for this OS")
	}
	return nil
}

func (uvm *UtilityVM) StopLogForwarding(ctx context.Context) error {
	// Implementation for stopping the log forwarding service
	if uvm.OS() != "windows" || uvm.gc == nil {
		return errNotSupported
	}

	wcaps := gcs.GetWCOWCapabilities(uvm.gc.Capabilities())
	if wcaps != nil && wcaps.IsLogForwardingSupported() {
		req := guestrequest.LogForwardServiceRPCRequest{
			RPCType:  guestrequest.RPCStopLogForwarding,
			Settings: "",
		}
		err := uvm.gc.ModifyServiceSettings(ctx, prot.LogForwardService, req)
		if err != nil {
			return err
		}
	}
	return nil
}

func (uvm *UtilityVM) SetLogSources(ctx context.Context) error {
	// Implementation for setting the log sources
	if uvm.OS() != "windows" || uvm.gc == nil {
		return errNotSupported
	}

	wcaps := gcs.GetWCOWCapabilities(uvm.gc.Capabilities())
	if wcaps != nil && wcaps.IsLogForwardingSupported() {
		// Make a call to the GCS to set the ETW providers

		// Determines the log sources to be set based on the configuration. If default log sources are enabled,
		// we only include them along with user specified log sources.
		// For confidential WCOw, we skip the adding guids to the log sources as the sidecar-GCS will verify the
		// allowed log sources against policy and append the necessary GUIDs to the ones allowed. Rest are dropped.
		// For non-confidential WCOW, we include the GUIDs in the log sources as the hcsshim communicates directly with the inboxGCS.
		settings, err := etw.UpdateLogSources(uvm.logSources, uvm.defaultLogSourcesEnabled, !uvm.HasConfidentialPolicy())
		if err != nil {
			return fmt.Errorf("failed to parse log sources: %w", err)
		}
		req := guestrequest.LogForwardServiceRPCRequest{
			RPCType:  guestrequest.RPCModifyServiceSettings,
			Settings: settings,
		}
		err = uvm.gc.ModifyServiceSettings(ctx, prot.LogForwardService, req)
		if err != nil {
			return fmt.Errorf("failed to modify service settings: %w", err)
		}
	}
	return nil
}