package api import ( "context" "time" "github.com/aarondl/opt/omit" "github.com/stephenafamo/bob" "github.com/tigorlazuardi/redmage/models" "github.com/tigorlazuardi/redmage/pkg/errs" ) func (api *API) ScheduleHistoryInsert(ctx context.Context, params ScheduleSetParams) (history *models.ScheduleHistory, err error) { ctx, span := tracer.Start(ctx, "*API.ScheduleHistoryInsert") defer span.End() return api.scheduleHistoryInsert(ctx, api.db, params) } func (api *API) scheduleHistoryInsert(ctx context.Context, exec bob.Executor, params ScheduleSetParams) (history *models.ScheduleHistory, err error) { ctx, span := tracer.Start(ctx, "*API.scheduleHistoryInsert") defer span.End() now := time.Now() history, err = models.ScheduleHistories.Insert(ctx, exec, &models.ScheduleHistorySetter{ Subreddit: omit.FromCond(params.Subreddit, params.Subreddit != ""), Status: omit.From(params.Status.Int8()), ErrorMessage: omit.FromCond(params.ErrorMessage, params.Status == ScheduleStatusError), CreatedAt: omit.From(now.Unix()), }) if err != nil { return history, errs.Wrapw(err, "failed to insert schedule history", "params", params) } return history, err }