()
| 845 | } |
| 846 | |
| 847 | func (b JobCompleteBuilder) Do() JobCompleteResponse { |
| 848 | r := JobCompleteResponse{CompletedAt: dbtime.Now()} |
| 849 | err := b.db.UpdateProvisionerJobWithCompleteWithStartedAtByID(ownerCtx, database.UpdateProvisionerJobWithCompleteWithStartedAtByIDParams{ |
| 850 | ID: b.jobID, |
| 851 | UpdatedAt: r.CompletedAt, |
| 852 | Error: sql.NullString{}, |
| 853 | ErrorCode: sql.NullString{}, |
| 854 | CompletedAt: sql.NullTime{ |
| 855 | Time: r.CompletedAt, |
| 856 | Valid: true, |
| 857 | }, |
| 858 | StartedAt: sql.NullTime{ |
| 859 | Time: r.CompletedAt, |
| 860 | Valid: true, |
| 861 | }, |
| 862 | }) |
| 863 | require.NoError(b.t, err, "complete job") |
| 864 | if b.ps != nil { |
| 865 | data, err := json.Marshal(provisionersdk.ProvisionerJobLogsNotifyMessage{EndOfLogs: true}) |
| 866 | require.NoError(b.t, err) |
| 867 | err = b.ps.Publish(provisionersdk.ProvisionerJobLogsNotifyChannel(b.jobID), data) |
| 868 | require.NoError(b.t, err) |
| 869 | } |
| 870 | return r |
| 871 | } |
| 872 | |
| 873 | func must[V any](v V, err error) V { |
| 874 | if err != nil { |
nothing calls this directly
no test coverage detected