update github issue labels
(ctx context.Context, gc *rateLimitHandlerClient, labelableID string, added, removed []common.Label)
| 745 | |
| 746 | // update github issue labels |
| 747 | func (ge *githubExporter) updateGithubIssueLabels(ctx context.Context, gc *rateLimitHandlerClient, labelableID string, added, removed []common.Label) error { |
| 748 | |
| 749 | wg, ctx := errgroup.WithContext(ctx) |
| 750 | if len(added) > 0 { |
| 751 | wg.Go(func() error { |
| 752 | addedIDs, err := ge.getLabelsIDs(ctx, gc, labelableID, added) |
| 753 | if err != nil { |
| 754 | return err |
| 755 | } |
| 756 | |
| 757 | m := &addLabelsToLabelableMutation{} |
| 758 | inputAdd := githubv4.AddLabelsToLabelableInput{ |
| 759 | LabelableID: labelableID, |
| 760 | LabelIDs: addedIDs, |
| 761 | } |
| 762 | |
| 763 | // add labels |
| 764 | if err := gc.mutate(ctx, m, inputAdd, nil, ge.out); err != nil { |
| 765 | return err |
| 766 | } |
| 767 | return nil |
| 768 | }) |
| 769 | } |
| 770 | |
| 771 | if len(removed) > 0 { |
| 772 | wg.Go(func() error { |
| 773 | removedIDs, err := ge.getLabelsIDs(ctx, gc, labelableID, removed) |
| 774 | if err != nil { |
| 775 | return err |
| 776 | } |
| 777 | |
| 778 | m2 := &removeLabelsFromLabelableMutation{} |
| 779 | inputRemove := githubv4.RemoveLabelsFromLabelableInput{ |
| 780 | LabelableID: labelableID, |
| 781 | LabelIDs: removedIDs, |
| 782 | } |
| 783 | |
| 784 | // remove label labels |
| 785 | if err := gc.mutate(ctx, m2, inputRemove, nil, ge.out); err != nil { |
| 786 | return err |
| 787 | } |
| 788 | return nil |
| 789 | }) |
| 790 | } |
| 791 | |
| 792 | return wg.Wait() |
| 793 | } |
no test coverage detected