cloudfoundry/cf-k8s-controllers

package payloads

import (
    "net/url"
    "strconv"
    "strings"

    "code.cloudfoundry.org/korifi/api/repositories"
    "github.com/jellydator/validation"
)

type TaskCreate struct {
    Command  string   `json:"command"`
    Metadata Metadata `json:"metadata"`
}

func (c TaskCreate) Validate() error {
    return validation.ValidateStruct(&c,
        validation.Field(&c.Command, validation.Required),
        validation.Field(&c.Metadata),
    )
}

func (p TaskCreate) ToMessage(appRecord repositories.AppRecord) repositories.CreateTaskMessage {
    return repositories.CreateTaskMessage{
        Command:   p.Command,
        SpaceGUID: appRecord.SpaceGUID,
        AppGUID:   appRecord.GUID,
        Metadata:  repositories.Metadata(p.Metadata),
    }
}

type TaskList struct {
    SequenceIDs []int64
}

func (t *TaskList) ToMessage() repositories.ListTaskMessage {
    return repositories.ListTaskMessage{
        SequenceIDs: t.SequenceIDs,
    }
}

func (t *TaskList) SupportedKeys() []string {
    return []string{"sequence_ids", "per_page", "page"}
}

func (a *TaskList) DecodeFromURLValues(values url.Values) error {
    idsStr := values.Get("sequence_ids")

    var ids []int64
    for _, idStr := range strings.Split(idsStr, ",") {
        if idStr == "" {
            continue
        }
        id, err := strconv.ParseInt(idStr, 10, 64)
        if err != nil {
            return err
        }
        ids = append(ids, id)
    }

    a.SequenceIDs = ids
    return nil
}

type TaskUpdate struct {
    Metadata MetadataPatch `json:"metadata"`
}

func (u TaskUpdate) Validate() error {
    return validation.ValidateStruct(&u,
        validation.Field(&u.Metadata),
    )
}

func (u *TaskUpdate) ToMessage(taskGUID, spaceGUID string) repositories.PatchTaskMetadataMessage {
    return repositories.PatchTaskMetadataMessage{
        TaskGUID:  taskGUID,
        SpaceGUID: spaceGUID,
        MetadataPatch: repositories.MetadataPatch{
            Annotations: u.Metadata.Annotations,
            Labels:      u.Metadata.Labels,
        },
    }
}