(ctx context.Context)
| 808 | } |
| 809 | |
| 810 | func wipeInbox(ctx context.Context) error { |
| 811 | if fileGetArgs.wait { |
| 812 | return errors.New("can't use --wait with /dev/null target") |
| 813 | } |
| 814 | wfs, err := localClient.WaitingFiles(ctx) |
| 815 | if err != nil { |
| 816 | return fmt.Errorf("getting WaitingFiles: %w", err) |
| 817 | } |
| 818 | deleted := 0 |
| 819 | for _, wf := range wfs { |
| 820 | if fileGetArgs.verbose { |
| 821 | log.Printf("deleting %v ...", wf.Name) |
| 822 | } |
| 823 | if err := localClient.DeleteWaitingFile(ctx, wf.Name); err != nil { |
| 824 | return fmt.Errorf("deleting %q: %v", wf.Name, err) |
| 825 | } |
| 826 | deleted++ |
| 827 | } |
| 828 | if fileGetArgs.verbose { |
| 829 | log.Printf("deleted %d files", deleted) |
| 830 | } |
| 831 | return nil |
| 832 | } |
| 833 | |
| 834 | func waitForFile(ctx context.Context) error { |
| 835 | for { |
no test coverage detected
searching dependent graphs…