workflow,spindle: regenerate api with new lexicon #284

+35 -295

api/tangled/cbor_gen.go

··· 2188 2189 return nil 2190 } 2191 - func (t *Pipeline_Dependencies_Elem) MarshalCBOR(w io.Writer) error { 2192 if t == nil { 2193 _, err := w.Write(cbg.CborNull) 2194 return err ··· 2258 return nil 2259 } 2260 2261 - func (t *Pipeline_Dependencies_Elem) UnmarshalCBOR(r io.Reader) (err error) { 2262 - *t = Pipeline_Dependencies_Elem{} 2263 2264 cr := cbg.NewCborReader(r) 2265 ··· 2278 } 2279 2280 if extra > cbg.MaxLength { 2281 - return fmt.Errorf("Pipeline_Dependencies_Elem: map struct too large (%d)", extra) 2282 } 2283 2284 n := extra ··· 2378 return err 2379 } 2380 2381 - // t.Inputs ([]*tangled.Pipeline_ManualTriggerData_Inputs_Elem) (slice) 2382 if t.Inputs != nil { 2383 2384 if len("inputs") > 1000000 { ··· 2450 } 2451 2452 switch string(nameBuf[:nameLen]) { 2453 - // t.Inputs ([]*tangled.Pipeline_ManualTriggerData_Inputs_Elem) (slice) 2454 case "inputs": 2455 2456 maj, extra, err = cr.ReadHeader() ··· 2467 } 2468 2469 if extra > 0 { 2470 - t.Inputs = make([]*Pipeline_ManualTriggerData_Inputs_Elem, extra) 2471 } 2472 2473 for i := 0; i < int(extra); i++ { ··· 2489 if err := cr.UnreadByte(); err != nil { 2490 return err 2491 } 2492 - t.Inputs[i] = new(Pipeline_ManualTriggerData_Inputs_Elem) 2493 if err := t.Inputs[i].UnmarshalCBOR(cr); err != nil { 2494 return xerrors.Errorf("unmarshaling t.Inputs[i] pointer: %w", err) 2495 } ··· 2510 2511 return nil 2512 } 2513 - func (t *Pipeline_ManualTriggerData_Inputs_Elem) MarshalCBOR(w io.Writer) error { 2514 if t == nil { 2515 _, err := w.Write(cbg.CborNull) 2516 return err ··· 2570 return nil 2571 } 2572 2573 - func (t *Pipeline_ManualTriggerData_Inputs_Elem) UnmarshalCBOR(r io.Reader) (err error) { 2574 - *t = Pipeline_ManualTriggerData_Inputs_Elem{} 2575 2576 cr := cbg.NewCborReader(r) 2577 ··· 2590 } 2591 2592 if extra > cbg.MaxLength { 2593 - return fmt.Errorf("Pipeline_ManualTriggerData_Inputs_Elem: map struct too large (%d)", extra) 2594 } 2595 2596 n := extra ··· 3014 3015 return nil 3016 } 3017 - 3018 - func (t *Pipeline_Step_Environment_Elem) MarshalCBOR(w io.Writer) error { 3019 - if t == nil { 3020 - _, err := w.Write(cbg.CborNull) 3021 - return err 3022 - } 3023 - 3024 - cw := cbg.NewCborWriter(w) 3025 - 3026 - if _, err := cw.Write([]byte{162}); err != nil { 3027 - return err 3028 - } 3029 - 3030 - // t.Key (string) (string) 3031 - if len("key") > 1000000 { 3032 - return xerrors.Errorf("Value in field \"key\" was too long") 3033 - } 3034 - 3035 - if err := cw.WriteMajorTypeHeader(cbg.MajTextString, uint64(len("key"))); err != nil { 3036 - return err 3037 - } 3038 - if _, err := cw.WriteString(string("key")); err != nil { 3039 - return err 3040 - } 3041 - 3042 - if len(t.Key) > 1000000 { 3043 - return xerrors.Errorf("Value in field t.Key was too long") 3044 - } 3045 - 3046 - if err := cw.WriteMajorTypeHeader(cbg.MajTextString, uint64(len(t.Key))); err != nil { 3047 - return err 3048 - } 3049 - if _, err := cw.WriteString(string(t.Key)); err != nil { 3050 - return err 3051 - } 3052 - 3053 - // t.Value (string) (string) 3054 - if len("value") > 1000000 { 3055 - return xerrors.Errorf("Value in field \"value\" was too long") 3056 - } 3057 - 3058 - if err := cw.WriteMajorTypeHeader(cbg.MajTextString, uint64(len("value"))); err != nil { 3059 - return err 3060 - } 3061 - if _, err := cw.WriteString(string("value")); err != nil { 3062 - return err 3063 - } 3064 - 3065 - if len(t.Value) > 1000000 { 3066 - return xerrors.Errorf("Value in field t.Value was too long") 3067 - } 3068 - 3069 - if err := cw.WriteMajorTypeHeader(cbg.MajTextString, uint64(len(t.Value))); err != nil { 3070 - return err 3071 - } 3072 - if _, err := cw.WriteString(string(t.Value)); err != nil { 3073 - return err 3074 - } 3075 - return nil 3076 - } 3077 - 3078 - func (t *Pipeline_Step_Environment_Elem) UnmarshalCBOR(r io.Reader) (err error) { 3079 - *t = Pipeline_Step_Environment_Elem{} 3080 - 3081 - cr := cbg.NewCborReader(r) 3082 - 3083 - maj, extra, err := cr.ReadHeader() 3084 - if err != nil { 3085 - return err 3086 - } 3087 - defer func() { 3088 - if err == io.EOF { 3089 - err = io.ErrUnexpectedEOF 3090 - } 3091 - }() 3092 - 3093 - if maj != cbg.MajMap { 3094 - return fmt.Errorf("cbor input should be of type map") 3095 - } 3096 - 3097 - if extra > cbg.MaxLength { 3098 - return fmt.Errorf("Pipeline_Step_Environment_Elem: map struct too large (%d)", extra) 3099 - } 3100 - 3101 - n := extra 3102 - 3103 - nameBuf := make([]byte, 5) 3104 - for i := uint64(0); i < n; i++ { 3105 - nameLen, ok, err := cbg.ReadFullStringIntoBuf(cr, nameBuf, 1000000) 3106 - if err != nil { 3107 - return err 3108 - } 3109 - 3110 - if !ok { 3111 - // Field doesn't exist on this type, so ignore it 3112 - if err := cbg.ScanForLinks(cr, func(cid.Cid) {}); err != nil { 3113 - return err 3114 - } 3115 - continue 3116 - } 3117 - 3118 - switch string(nameBuf[:nameLen]) { 3119 - // t.Key (string) (string) 3120 - case "key": 3121 - 3122 - { 3123 - sval, err := cbg.ReadStringWithMax(cr, 1000000) 3124 - if err != nil { 3125 - return err 3126 - } 3127 - 3128 - t.Key = string(sval) 3129 - } 3130 - // t.Value (string) (string) 3131 - case "value": 3132 - 3133 - { 3134 - sval, err := cbg.ReadStringWithMax(cr, 1000000) 3135 - if err != nil { 3136 - return err 3137 - } 3138 - 3139 - t.Value = string(sval) 3140 - } 3141 - 3142 - default: 3143 - // Field doesn't exist on this type, so ignore it 3144 - if err := cbg.ScanForLinks(r, func(cid.Cid) {}); err != nil { 3145 - return err 3146 - } 3147 - } 3148 - } 3149 - 3150 - return nil 3151 - } 3152 func (t *PipelineStatus) MarshalCBOR(w io.Writer) error { 3153 if t == nil { 3154 _, err := w.Write(cbg.CborNull) ··· 3511 3512 return nil 3513 } 3514 - 3515 func (t *Pipeline_Step) MarshalCBOR(w io.Writer) error { 3516 if t == nil { 3517 _, err := w.Write(cbg.CborNull) ··· 3575 return err 3576 } 3577 3578 - // t.Environment ([]*tangled.Pipeline_Step_Environment_Elem) (slice) 3579 if t.Environment != nil { 3580 3581 if len("environment") > 1000000 { ··· 3669 3670 t.Command = string(sval) 3671 } 3672 - // t.Environment ([]*tangled.Pipeline_Step_Environment_Elem) (slice) 3673 case "environment": 3674 3675 maj, extra, err = cr.ReadHeader() ··· 3686 } 3687 3688 if extra > 0 { 3689 - t.Environment = make([]*Pipeline_Step_Environment_Elem, extra) 3690 } 3691 3692 for i := 0; i < int(extra); i++ { ··· 3708 if err := cr.UnreadByte(); err != nil { 3709 return err 3710 } 3711 - t.Environment[i] = new(Pipeline_Step_Environment_Elem) 3712 if err := t.Environment[i].UnmarshalCBOR(cr); err != nil { 3713 return xerrors.Errorf("unmarshaling t.Environment[i] pointer: %w", err) 3714 } ··· 4274 4275 } 4276 4277 - // t.Environment ([]*tangled.Pipeline_Workflow_Environment_Elem) (slice) 4278 if len("environment") > 1000000 { 4279 return xerrors.Errorf("Value in field \"environment\" was too long") 4280 } ··· 4300 4301 } 4302 4303 - // t.Dependencies ([]tangled.Pipeline_Dependencies_Elem) (slice) 4304 if len("dependencies") > 1000000 { 4305 return xerrors.Errorf("Value in field \"dependencies\" was too long") 4306 } ··· 4449 4450 } 4451 } 4452 - // t.Environment ([]*tangled.Pipeline_Workflow_Environment_Elem) (slice) 4453 case "environment": 4454 4455 maj, extra, err = cr.ReadHeader() ··· 4466 } 4467 4468 if extra > 0 { 4469 - t.Environment = make([]*Pipeline_Workflow_Environment_Elem, extra) 4470 } 4471 4472 for i := 0; i < int(extra); i++ { ··· 4488 if err := cr.UnreadByte(); err != nil { 4489 return err 4490 } 4491 - t.Environment[i] = new(Pipeline_Workflow_Environment_Elem) 4492 if err := t.Environment[i].UnmarshalCBOR(cr); err != nil { 4493 return xerrors.Errorf("unmarshaling t.Environment[i] pointer: %w", err) 4494 } ··· 4498 4499 } 4500 } 4501 - // t.Dependencies ([]tangled.Pipeline_Dependencies_Elem) (slice) 4502 case "dependencies": 4503 4504 maj, extra, err = cr.ReadHeader() ··· 4515 } 4516 4517 if extra > 0 { 4518 - t.Dependencies = make([]Pipeline_Dependencies_Elem, extra) 4519 } 4520 4521 for i := 0; i < int(extra); i++ { ··· 4529 4530 { 4531 4532 - if err := t.Dependencies[i].UnmarshalCBOR(cr); err != nil { 4533 - return xerrors.Errorf("unmarshaling t.Dependencies[i]: %w", err) 0 0 0 0 0 0 0 0 0 0 4534 } 4535 4536 } ··· 4548 4549 return nil 4550 } 4551 - func (t *Pipeline_Workflow_Environment_Elem) MarshalCBOR(w io.Writer) error { 4552 - if t == nil { 4553 - _, err := w.Write(cbg.CborNull) 4554 - return err 4555 - } 4556 - 4557 - cw := cbg.NewCborWriter(w) 4558 - 4559 - if _, err := cw.Write([]byte{162}); err != nil { 4560 - return err 4561 - } 4562 - 4563 - // t.Key (string) (string) 4564 - if len("key") > 1000000 { 4565 - return xerrors.Errorf("Value in field \"key\" was too long") 4566 - } 4567 - 4568 - if err := cw.WriteMajorTypeHeader(cbg.MajTextString, uint64(len("key"))); err != nil { 4569 - return err 4570 - } 4571 - if _, err := cw.WriteString(string("key")); err != nil { 4572 - return err 4573 - } 4574 - 4575 - if len(t.Key) > 1000000 { 4576 - return xerrors.Errorf("Value in field t.Key was too long") 4577 - } 4578 - 4579 - if err := cw.WriteMajorTypeHeader(cbg.MajTextString, uint64(len(t.Key))); err != nil { 4580 - return err 4581 - } 4582 - if _, err := cw.WriteString(string(t.Key)); err != nil { 4583 - return err 4584 - } 4585 - 4586 - // t.Value (string) (string) 4587 - if len("value") > 1000000 { 4588 - return xerrors.Errorf("Value in field \"value\" was too long") 4589 - } 4590 - 4591 - if err := cw.WriteMajorTypeHeader(cbg.MajTextString, uint64(len("value"))); err != nil { 4592 - return err 4593 - } 4594 - if _, err := cw.WriteString(string("value")); err != nil { 4595 - return err 4596 - } 4597 - 4598 - if len(t.Value) > 1000000 { 4599 - return xerrors.Errorf("Value in field t.Value was too long") 4600 - } 4601 - 4602 - if err := cw.WriteMajorTypeHeader(cbg.MajTextString, uint64(len(t.Value))); err != nil { 4603 - return err 4604 - } 4605 - if _, err := cw.WriteString(string(t.Value)); err != nil { 4606 - return err 4607 - } 4608 - return nil 4609 - } 4610 - 4611 - func (t *Pipeline_Workflow_Environment_Elem) UnmarshalCBOR(r io.Reader) (err error) { 4612 - *t = Pipeline_Workflow_Environment_Elem{} 4613 - 4614 - cr := cbg.NewCborReader(r) 4615 - 4616 - maj, extra, err := cr.ReadHeader() 4617 - if err != nil { 4618 - return err 4619 - } 4620 - defer func() { 4621 - if err == io.EOF { 4622 - err = io.ErrUnexpectedEOF 4623 - } 4624 - }() 4625 - 4626 - if maj != cbg.MajMap { 4627 - return fmt.Errorf("cbor input should be of type map") 4628 - } 4629 - 4630 - if extra > cbg.MaxLength { 4631 - return fmt.Errorf("Pipeline_Workflow_Environment_Elem: map struct too large (%d)", extra) 4632 - } 4633 - 4634 - n := extra 4635 - 4636 - nameBuf := make([]byte, 5) 4637 - for i := uint64(0); i < n; i++ { 4638 - nameLen, ok, err := cbg.ReadFullStringIntoBuf(cr, nameBuf, 1000000) 4639 - if err != nil { 4640 - return err 4641 - } 4642 - 4643 - if !ok { 4644 - // Field doesn't exist on this type, so ignore it 4645 - if err := cbg.ScanForLinks(cr, func(cid.Cid) {}); err != nil { 4646 - return err 4647 - } 4648 - continue 4649 - } 4650 - 4651 - switch string(nameBuf[:nameLen]) { 4652 - // t.Key (string) (string) 4653 - case "key": 4654 - 4655 - { 4656 - sval, err := cbg.ReadStringWithMax(cr, 1000000) 4657 - if err != nil { 4658 - return err 4659 - } 4660 - 4661 - t.Key = string(sval) 4662 - } 4663 - // t.Value (string) (string) 4664 - case "value": 4665 - 4666 - { 4667 - sval, err := cbg.ReadStringWithMax(cr, 1000000) 4668 - if err != nil { 4669 - return err 4670 - } 4671 - 4672 - t.Value = string(sval) 4673 - } 4674 - 4675 - default: 4676 - // Field doesn't exist on this type, so ignore it 4677 - if err := cbg.ScanForLinks(r, func(cid.Cid) {}); err != nil { 4678 - return err 4679 - } 4680 - } 4681 - } 4682 - 4683 - return nil 4684 - } 4685 func (t *PublicKey) MarshalCBOR(w io.Writer) error { 4686 if t == nil { 4687 _, err := w.Write(cbg.CborNull)

··· 2188 2189 return nil 2190 } 2191 + func (t *Pipeline_Dependency) MarshalCBOR(w io.Writer) error { 2192 if t == nil { 2193 _, err := w.Write(cbg.CborNull) 2194 return err ··· 2258 return nil 2259 } 2260 2261 + func (t *Pipeline_Dependency) UnmarshalCBOR(r io.Reader) (err error) { 2262 + *t = Pipeline_Dependency{} 2263 2264 cr := cbg.NewCborReader(r) 2265 ··· 2278 } 2279 2280 if extra > cbg.MaxLength { 2281 + return fmt.Errorf("Pipeline_Dependency: map struct too large (%d)", extra) 2282 } 2283 2284 n := extra ··· 2378 return err 2379 } 2380 2381 + // t.Inputs ([]*tangled.Pipeline_Pair) (slice) 2382 if t.Inputs != nil { 2383 2384 if len("inputs") > 1000000 { ··· 2450 } 2451 2452 switch string(nameBuf[:nameLen]) { 2453 + // t.Inputs ([]*tangled.Pipeline_Pair) (slice) 2454 case "inputs": 2455 2456 maj, extra, err = cr.ReadHeader() ··· 2467 } 2468 2469 if extra > 0 { 2470 + t.Inputs = make([]*Pipeline_Pair, extra) 2471 } 2472 2473 for i := 0; i < int(extra); i++ { ··· 2489 if err := cr.UnreadByte(); err != nil { 2490 return err 2491 } 2492 + t.Inputs[i] = new(Pipeline_Pair) 2493 if err := t.Inputs[i].UnmarshalCBOR(cr); err != nil { 2494 return xerrors.Errorf("unmarshaling t.Inputs[i] pointer: %w", err) 2495 } ··· 2510 2511 return nil 2512 } 2513 + func (t *Pipeline_Pair) MarshalCBOR(w io.Writer) error { 2514 if t == nil { 2515 _, err := w.Write(cbg.CborNull) 2516 return err ··· 2570 return nil 2571 } 2572 2573 + func (t *Pipeline_Pair) UnmarshalCBOR(r io.Reader) (err error) { 2574 + *t = Pipeline_Pair{} 2575 2576 cr := cbg.NewCborReader(r) 2577 ··· 2590 } 2591 2592 if extra > cbg.MaxLength { 2593 + return fmt.Errorf("Pipeline_Pair: map struct too large (%d)", extra) 2594 } 2595 2596 n := extra ··· 3014 3015 return nil 3016 } 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 3017 func (t *PipelineStatus) MarshalCBOR(w io.Writer) error { 3018 if t == nil { 3019 _, err := w.Write(cbg.CborNull) ··· 3376 3377 return nil 3378 } 0 3379 func (t *Pipeline_Step) MarshalCBOR(w io.Writer) error { 3380 if t == nil { 3381 _, err := w.Write(cbg.CborNull) ··· 3439 return err 3440 } 3441 3442 + // t.Environment ([]*tangled.Pipeline_Pair) (slice) 3443 if t.Environment != nil { 3444 3445 if len("environment") > 1000000 { ··· 3533 3534 t.Command = string(sval) 3535 } 3536 + // t.Environment ([]*tangled.Pipeline_Pair) (slice) 3537 case "environment": 3538 3539 maj, extra, err = cr.ReadHeader() ··· 3550 } 3551 3552 if extra > 0 { 3553 + t.Environment = make([]*Pipeline_Pair, extra) 3554 } 3555 3556 for i := 0; i < int(extra); i++ { ··· 3572 if err := cr.UnreadByte(); err != nil { 3573 return err 3574 } 3575 + t.Environment[i] = new(Pipeline_Pair) 3576 if err := t.Environment[i].UnmarshalCBOR(cr); err != nil { 3577 return xerrors.Errorf("unmarshaling t.Environment[i] pointer: %w", err) 3578 } ··· 4138 4139 } 4140 4141 + // t.Environment ([]*tangled.Pipeline_Pair) (slice) 4142 if len("environment") > 1000000 { 4143 return xerrors.Errorf("Value in field \"environment\" was too long") 4144 } ··· 4164 4165 } 4166 4167 + // t.Dependencies ([]*tangled.Pipeline_Dependency) (slice) 4168 if len("dependencies") > 1000000 { 4169 return xerrors.Errorf("Value in field \"dependencies\" was too long") 4170 } ··· 4313 4314 } 4315 } 4316 + // t.Environment ([]*tangled.Pipeline_Pair) (slice) 4317 case "environment": 4318 4319 maj, extra, err = cr.ReadHeader() ··· 4330 } 4331 4332 if extra > 0 { 4333 + t.Environment = make([]*Pipeline_Pair, extra) 4334 } 4335 4336 for i := 0; i < int(extra); i++ { ··· 4352 if err := cr.UnreadByte(); err != nil { 4353 return err 4354 } 4355 + t.Environment[i] = new(Pipeline_Pair) 4356 if err := t.Environment[i].UnmarshalCBOR(cr); err != nil { 4357 return xerrors.Errorf("unmarshaling t.Environment[i] pointer: %w", err) 4358 } ··· 4362 4363 } 4364 } 4365 + // t.Dependencies ([]*tangled.Pipeline_Dependency) (slice) 4366 case "dependencies": 4367 4368 maj, extra, err = cr.ReadHeader() ··· 4379 } 4380 4381 if extra > 0 { 4382 + t.Dependencies = make([]*Pipeline_Dependency, extra) 4383 } 4384 4385 for i := 0; i < int(extra); i++ { ··· 4393 4394 { 4395 4396 + b, err := cr.ReadByte() 4397 + if err != nil { 4398 + return err 4399 + } 4400 + if b != cbg.CborNull[0] { 4401 + if err := cr.UnreadByte(); err != nil { 4402 + return err 4403 + } 4404 + t.Dependencies[i] = new(Pipeline_Dependency) 4405 + if err := t.Dependencies[i].UnmarshalCBOR(cr); err != nil { 4406 + return xerrors.Errorf("unmarshaling t.Dependencies[i] pointer: %w", err) 4407 + } 4408 } 4409 4410 } ··· 4422 4423 return nil 4424 } 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 4425 func (t *PublicKey) MarshalCBOR(w io.Writer) error { 4426 if t == nil { 4427 _, err := w.Write(cbg.CborNull)

+13 -21

api/tangled/tangledpipeline.go

··· 29 Submodules bool `json:"submodules" cborgen:"submodules"` 30 } 31 32 - type Pipeline_Dependencies_Elem struct { 0 33 Packages []string `json:"packages" cborgen:"packages"` 34 Registry string `json:"registry" cborgen:"registry"` 35 } 36 37 // Pipeline_ManualTriggerData is a "manualTriggerData" in the sh.tangled.pipeline schema. 38 type Pipeline_ManualTriggerData struct { 39 - Inputs []*Pipeline_ManualTriggerData_Inputs_Elem `json:"inputs,omitempty" cborgen:"inputs,omitempty"` 40 } 41 42 - type Pipeline_ManualTriggerData_Inputs_Elem struct { 0 43 Key string `json:"key" cborgen:"key"` 44 Value string `json:"value" cborgen:"value"` 45 } ··· 61 62 // Pipeline_Step is a "step" in the sh.tangled.pipeline schema. 63 type Pipeline_Step struct { 64 - Command string `json:"command" cborgen:"command"` 65 - Environment []*Pipeline_Step_Environment_Elem `json:"environment,omitempty" cborgen:"environment,omitempty"` 66 - Name string `json:"name" cborgen:"name"` 67 - } 68 - 69 - type Pipeline_Step_Environment_Elem struct { 70 - Key string `json:"key" cborgen:"key"` 71 - Value string `json:"value" cborgen:"value"` 72 } 73 74 // Pipeline_TriggerMetadata is a "triggerMetadata" in the sh.tangled.pipeline schema. ··· 90 91 // Pipeline_Workflow is a "workflow" in the sh.tangled.pipeline schema. 92 type Pipeline_Workflow struct { 93 - Clone *Pipeline_CloneOpts `json:"clone" cborgen:"clone"` 94 - Dependencies []Pipeline_Dependencies_Elem `json:"dependencies" cborgen:"dependencies"` 95 - Environment []*Pipeline_Workflow_Environment_Elem `json:"environment" cborgen:"environment"` 96 - Name string `json:"name" cborgen:"name"` 97 - Steps []*Pipeline_Step `json:"steps" cborgen:"steps"` 98 - } 99 - 100 - type Pipeline_Workflow_Environment_Elem struct { 101 - Key string `json:"key" cborgen:"key"` 102 - Value string `json:"value" cborgen:"value"` 103 }

··· 29 Submodules bool `json:"submodules" cborgen:"submodules"` 30 } 31 32 + // Pipeline_Dependency is a "dependency" in the sh.tangled.pipeline schema. 33 + type Pipeline_Dependency struct { 34 Packages []string `json:"packages" cborgen:"packages"` 35 Registry string `json:"registry" cborgen:"registry"` 36 } 37 38 // Pipeline_ManualTriggerData is a "manualTriggerData" in the sh.tangled.pipeline schema. 39 type Pipeline_ManualTriggerData struct { 40 + Inputs []*Pipeline_Pair `json:"inputs,omitempty" cborgen:"inputs,omitempty"` 41 } 42 43 + // Pipeline_Pair is a "pair" in the sh.tangled.pipeline schema. 44 + type Pipeline_Pair struct { 45 Key string `json:"key" cborgen:"key"` 46 Value string `json:"value" cborgen:"value"` 47 } ··· 63 64 // Pipeline_Step is a "step" in the sh.tangled.pipeline schema. 65 type Pipeline_Step struct { 66 + Command string `json:"command" cborgen:"command"` 67 + Environment []*Pipeline_Pair `json:"environment,omitempty" cborgen:"environment,omitempty"` 68 + Name string `json:"name" cborgen:"name"` 0 0 0 0 0 69 } 70 71 // Pipeline_TriggerMetadata is a "triggerMetadata" in the sh.tangled.pipeline schema. ··· 87 88 // Pipeline_Workflow is a "workflow" in the sh.tangled.pipeline schema. 89 type Pipeline_Workflow struct { 90 + Clone *Pipeline_CloneOpts `json:"clone" cborgen:"clone"` 91 + Dependencies []*Pipeline_Dependency `json:"dependencies" cborgen:"dependencies"` 92 + Environment []*Pipeline_Pair `json:"environment" cborgen:"environment"` 93 + Name string `json:"name" cborgen:"name"` 94 + Steps []*Pipeline_Step `json:"steps" cborgen:"steps"` 0 0 0 0 0 95 }

+2 -4

cmd/gen.go

··· 24 tangled.KnotMember{}, 25 tangled.Pipeline{}, 26 tangled.Pipeline_CloneOpts{}, 27 - tangled.Pipeline_Dependencies_Elem{}, 28 tangled.Pipeline_ManualTriggerData{}, 29 - tangled.Pipeline_ManualTriggerData_Inputs_Elem{}, 30 tangled.Pipeline_PullRequestTriggerData{}, 31 tangled.Pipeline_PushTriggerData{}, 32 - tangled.Pipeline_Step_Environment_Elem{}, 33 tangled.PipelineStatus{}, 34 tangled.Pipeline_Step{}, 35 tangled.Pipeline_TriggerMetadata{}, 36 tangled.Pipeline_TriggerRepo{}, 37 tangled.Pipeline_Workflow{}, 38 - tangled.Pipeline_Workflow_Environment_Elem{}, 39 tangled.PublicKey{}, 40 tangled.Repo{}, 41 tangled.RepoArtifact{},

··· 24 tangled.KnotMember{}, 25 tangled.Pipeline{}, 26 tangled.Pipeline_CloneOpts{}, 27 + tangled.Pipeline_Dependency{}, 28 tangled.Pipeline_ManualTriggerData{}, 29 + tangled.Pipeline_Pair{}, 30 tangled.Pipeline_PullRequestTriggerData{}, 31 tangled.Pipeline_PushTriggerData{}, 0 32 tangled.PipelineStatus{}, 33 tangled.Pipeline_Step{}, 34 tangled.Pipeline_TriggerMetadata{}, 35 tangled.Pipeline_TriggerRepo{}, 36 tangled.Pipeline_Workflow{}, 0 37 tangled.PublicKey{}, 38 tangled.Repo{}, 39 tangled.RepoArtifact{},

+9 -5

spindle/models/pipeline.go

··· 83 return &Pipeline{Workflows: workflows} 84 } 85 86 - func workflowEnvToMap(envs []*tangled.Pipeline_Workflow_Environment_Elem) map[string]string { 87 envMap := map[string]string{} 88 for _, env := range envs { 89 - envMap[env.Key] = env.Value 0 0 90 } 91 return envMap 92 } 93 94 - func stepEnvToMap(envs []*tangled.Pipeline_Step_Environment_Elem) map[string]string { 95 envMap := map[string]string{} 96 for _, env := range envs { 97 - envMap[env.Key] = env.Value 0 0 98 } 99 return envMap 100 } 101 102 - func workflowImage(deps []tangled.Pipeline_Dependencies_Elem, nixery string) string { 103 var dependencies string 104 for _, d := range deps { 105 if d.Registry == "nixpkgs" {

··· 83 return &Pipeline{Workflows: workflows} 84 } 85 86 + func workflowEnvToMap(envs []*tangled.Pipeline_Pair) map[string]string { 87 envMap := map[string]string{} 88 for _, env := range envs { 89 + if env != nil { 90 + envMap[env.Key] = env.Value 91 + } 92 } 93 return envMap 94 } 95 96 + func stepEnvToMap(envs []*tangled.Pipeline_Pair) map[string]string { 97 envMap := map[string]string{} 98 for _, env := range envs { 99 + if env != nil { 100 + envMap[env.Key] = env.Value 101 + } 102 } 103 return envMap 104 } 105 106 + func workflowImage(deps []*tangled.Pipeline_Dependency, nixery string) string { 107 var dependencies string 108 for _, d := range deps { 109 if d.Registry == "nixpkgs" {

+2 -2

workflow/compile.go

··· 98 Name: s.Name, 99 } 100 for k, v := range s.Environment { 101 - e := &tangled.Pipeline_Step_Environment_Elem{ 102 Key: k, 103 Value: v, 104 } ··· 107 cw.Steps = append(cw.Steps, &step) 108 } 109 for k, v := range w.Environment { 110 - e := &tangled.Pipeline_Workflow_Environment_Elem{ 111 Key: k, 112 Value: v, 113 }

··· 98 Name: s.Name, 99 } 100 for k, v := range s.Environment { 101 + e := &tangled.Pipeline_Pair{ 102 Key: k, 103 Value: v, 104 } ··· 107 cw.Steps = append(cw.Steps, &step) 108 } 109 for k, v := range w.Environment { 110 + e := &tangled.Pipeline_Pair{ 111 Key: k, 112 Value: v, 113 }

+3 -3

workflow/def.go

··· 167 } 168 169 // conversion utilities to atproto records 170 - func (d Dependencies) AsRecord() []tangled.Pipeline_Dependencies_Elem { 171 - var deps []tangled.Pipeline_Dependencies_Elem 172 for registry, packages := range d { 173 - deps = append(deps, tangled.Pipeline_Dependencies_Elem{ 174 Registry: registry, 175 Packages: packages, 176 })

··· 167 } 168 169 // conversion utilities to atproto records 170 + func (d Dependencies) AsRecord() []*tangled.Pipeline_Dependency { 171 + var deps []*tangled.Pipeline_Dependency 172 for registry, packages := range d { 173 + deps = append(deps, &tangled.Pipeline_Dependency{ 174 Registry: registry, 175 Packages: packages, 176 })