better end points and better tests

internal/database/actual-repo.go

@@ -38,20 +38,28 @@ func (r *ActualsRepo) Ingest(ctx context.Context, req model.IngestActualsRequest
 	}
 
 	a := &model.Actual{}
+	var ingestedAt string
+
 	err = r.db.QueryRowContext(ctx, `
-		SELECT id, fiscal_year, fiscal_period, department_id, gl_account_id,
-		       amount, currency, source, ingested_at
-		FROM actuals
-		WHERE fiscal_year=? AND fiscal_period=? AND department_id=? AND gl_account_id=?`,
+    SELECT id, fiscal_year, fiscal_period, department_id, gl_account_id,
+           amount, currency, source, ingested_at
+    FROM actuals
+    WHERE fiscal_year=? AND fiscal_period=? AND department_id=? AND gl_account_id=?`,
 		req.FiscalYear, req.FiscalPeriod, deptID, glID,
 	).Scan(
 		&a.ID, &a.FiscalYear, &a.FiscalPeriod,
 		&a.DepartmentID, &a.GLAccountID,
-		&a.Amount, &a.Currency, &a.Source, &a.IngestedAt,
+		&a.Amount, &a.Currency, &a.Source, &ingestedAt,
 	)
 	if err != nil {
 		return nil, fmt.Errorf("fetch ingested actual: %w", err)
 	}
+
+	a.IngestedAt, err = parseTime(ingestedAt)
+	if err != nil {
+		return nil, fmt.Errorf("parse ingested_at %q: %w", ingestedAt, err)
+	}
+
 	return a, nil
 }
 
@@ -82,3 +90,15 @@ func (r *ActualsRepo) ListByPeriod(ctx context.Context, fiscalYear, fiscalPeriod
 	}
 	return result, rows.Err()
 }
+
+func (r *ActualsRepo) IngestBatch(ctx context.Context, reqs []model.IngestActualsRequest) ([]*model.Actual, error) {
+	out := make([]*model.Actual, 0, len(reqs))
+	for _, req := range reqs {
+		a, err := r.Ingest(ctx, req)
+		if err != nil {
+			return nil, fmt.Errorf("IngestBatch: record (dept=%s gl=%s): %w", req.DeptCode, req.GLCode, err)
+		}
+		out = append(out, a)
+	}
+	return out, nil
+}