package hostops

import (
	"context"
	"strconv"
	"time"

	"github.com/carlosframework/platform/internal/hostclaim"
	"github.com/carlosframework/platform/internal/provision"
	"github.com/carlosframework/platform/internal/release"
)

func (a ProductionAuthority) TouchSidecarWake(ctx context.Context, account, app, name, appID, by, reason string) error {
	if a.Control == nil {
		return ErrContract
	}
	ctx, cancel := context.WithTimeout(ctx, 15*time.Second)
	defer cancel()
	record, err := ReadRecord(ctx, a.Store, provision.SidecarRecordKey(account, app, name))
	if err != nil {
		return err
	}
	obs, err := hostclaim.Read(ctx, a.Store, record.Holder.Host)
	if err != nil {
		return err
	}
	if obs.Absent || !matches(record, obs.Claim.Holder) || obs.Claim.Op.Kind != hostclaim.KindServing {
		return ErrPending
	}
	admission, err := ReadAdmission(ctx, a.Store, account, app, appID)
	if err != nil {
		return err
	}
	id, err := operationToken()
	if err != nil {
		return err
	}
	controller, err := operationToken()
	if err != nil {
		return err
	}
	owner := RegistrationOwner{Console: a.ConsoleID, Enrollment: a.Enrollment, Controller: controller}
	reg := Registration{Kind: "wake", Host: obs.Host, Owner: owner, AppID: appID, Epoch: admission.Value.Epoch, Claim: SavedObservation(obs), Incarnation: obs.Claim.Holder.Incarnation, CreatedAt: obs.Claim.Holder.CreatedAt}
	start, err := a.Control.RegisterStart(ctx, account, app, appID, id, reg, a.Now())
	if err != nil {
		return err
	}
	ctx = start.Lifecycle(ctx)
	if _, err = hostclaim.Update(ctx, a.Store, obs, func(*hostclaim.Claim) error { return nil }); err != nil {
		return err
	}
	key := release.SidecarWakeKey(account, app, name)
	_, err = start.Runner(a.Now).Run(ctx, Effect{ID: id, Resource: "control-object:" + key, Action: "wake", Inputs: map[string]string{"key": key, "incarnation": reg.Incarnation, "request_id": id, "admission_epoch": strconv.FormatUint(reg.Epoch, 10), "created_at": reg.CreatedAt.UTC().Format(time.RFC3339Nano)}}, func(ctx context.Context) (string, error) {
		if err := release.TouchSidecarWake(ctx, a.Store, account, app, name, by, reason, release.SidecarWakeIdentity{AppID: appID, Incarnation: reg.Incarnation, RequestID: id}); err != nil {
			return "", err
		}
		return id, nil
	})
	return err
}