(t *testing.T)
| 667 | } |
| 668 | |
| 669 | func TestTaskExecutionCommandsMapBoundaryRequests(t *testing.T) { |
| 670 | t.Parallel() |
| 671 | |
| 672 | tests := []struct { |
| 673 | name string |
| 674 | args []string |
| 675 | configure func(*stubClient, *TaskExecutionRequest) |
| 676 | wantAction string |
| 677 | }{ |
| 678 | { |
| 679 | name: "Should map task publish request", |
| 680 | args: []string{ |
| 681 | "task", |
| 682 | "publish", |
| 683 | "task-1", |
| 684 | "--idempotency-key", |
| 685 | "idem-publish", |
| 686 | "--channel", |
| 687 | "builders", |
| 688 | "-o", |
| 689 | "json", |
| 690 | }, |
| 691 | wantAction: "publish", |
| 692 | configure: func(client *stubClient, request *TaskExecutionRequest) { |
| 693 | client.publishTaskFn = func( |
| 694 | _ context.Context, |
| 695 | _ string, |
| 696 | got TaskExecutionRequest, |
| 697 | ) (TaskExecutionRecord, error) { |
| 698 | *request = got |
| 699 | return sampleTaskExecutionRecord(), nil |
| 700 | } |
| 701 | }, |
| 702 | }, |
| 703 | { |
| 704 | name: "Should map task start request", |
| 705 | args: []string{ |
| 706 | "task", |
| 707 | "start", |
| 708 | "task-1", |
| 709 | "--idempotency-key", |
| 710 | "idem-start", |
| 711 | "--channel", |
| 712 | "builders", |
| 713 | "-o", |
| 714 | "json", |
| 715 | }, |
| 716 | wantAction: "start", |
| 717 | configure: func(client *stubClient, request *TaskExecutionRequest) { |
| 718 | client.startTaskFn = func( |
| 719 | _ context.Context, |
| 720 | _ string, |
| 721 | got TaskExecutionRequest, |
| 722 | ) (TaskExecutionRecord, error) { |
| 723 | *request = got |
| 724 | return sampleTaskExecutionRecord(), nil |
| 725 | } |
| 726 | }, |
nothing calls this directly
no test coverage detected