(ctx context.Context)
| 438 | } |
| 439 | |
| 440 | func GetNonUploadedActivity(ctx context.Context) ([]*ActivityType, error) { |
| 441 | var rtn []*ActivityType |
| 442 | txErr := wstore.WithTx(ctx, func(tx *wstore.TxWrap) error { |
| 443 | query := `SELECT * FROM db_activity WHERE uploaded = 0 ORDER BY day DESC LIMIT 30` |
| 444 | tx.Select(&rtn, query) |
| 445 | return nil |
| 446 | }) |
| 447 | if txErr != nil { |
| 448 | return nil, txErr |
| 449 | } |
| 450 | return rtn, nil |
| 451 | } |
| 452 | |
| 453 | func MarkActivityAsUploaded(ctx context.Context, activityArr []*ActivityType) error { |
| 454 | dayStr := daystr.GetCurDayStr() |
no test coverage detected