Something went wrong. Try again.
small gleam coding and (not yet) persistent agent daemon with a detachable cli forked from okami.mom/albedo
Something went wrong. Try again.
123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475package daemon
import ( "encoding/json" "strings"
"albedo/cli/internal/daemon/protocol")
type CommandArgument struct { Name, Description, Type string Choices []string Required bool field protocol.FormField}type SessionCommand struct { Page *bool Name, Description, Method, ID, Delivery, CommandID string Arguments []CommandArgument UserTurn bool Operation protocol.ActionOperation}
func decodeSessionCommand(raw json.RawMessage) (SessionCommand, error) { var discriminator struct { Delivery string `json:"delivery"` } if err := decodeRequired(raw, &discriminator, "delivery"); err != nil { return SessionCommand{}, err } var command protocol.HTTPCommand var commandID string if discriminator.Delivery == "input" { var input protocol.InputCommand if err := decodeRequired(raw, &input); err != nil { return SessionCommand{}, err } command = protocol.HTTPCommand{ID: input.ID, SlashName: input.SlashName, Description: input.Description, Arguments: input.Arguments, CallerPermissions: input.CallerPermissions, Delivery: input.Delivery} commandID = input.CommandID } else if err := decodeRequired(raw, &command); err != nil { return SessionCommand{}, err } return sessionCommandValue(command, commandID)}
func sessionCommandValue(command protocol.HTTPCommand, commandID string) (SessionCommand, error) { if command.ID == "" || !strings.HasPrefix(command.SlashName, "/") || command.Arguments == nil { return SessionCommand{}, fieldError("command") } result := SessionCommand{ID: command.ID, Name: command.SlashName, Description: command.Description, Delivery: command.Delivery, Operation: command.Operation} if command.Delivery == "input" { if commandID == "" { return SessionCommand{}, fieldError("command ID") } result.CommandID = commandID result.Method = "PUT" result.UserTurn = true } else if command.Delivery != "read" && command.Delivery != "mutation" { return SessionCommand{}, fieldError("command delivery") } if !result.UserTurn { result.Method = command.Operation.Method } page := command.Delivery == "read" && len(command.Arguments) == 0 && (strings.HasPrefix(command.Operation.PathTemplate, "/extensions/") || command.SlashName == "/ttl" || command.SlashName == "/requests") result.Page = &page for _, field := range command.Arguments { argument := CommandArgument{Name: field.Name, Description: field.Description, Required: field.Required, Type: field.Type, field: field} for _, choice := range field.Choices { argument.Choices = append(argument.Choices, choice.Label) } result.Arguments = append(result.Arguments, argument) } return result, nil}