Method Create

internal/docsbatch/repository.go:148–179

(state State)

}

func (r *Repository) Create(state State) (*State, error) {
	var created *State

	err := r.lock.WithExclusive(func() error {
		id, err := r.newID()
		if err != nil {
			return fmt.Errorf("create batch ID: %w", err)
		}

		if err := ValidateID(id); err != nil {
			return fmt.Errorf("create batch ID: %w", err)
		}

		now := r.now().UTC()
		state.BatchID = id
		state.CreatedAt = now
		state.UpdatedAt = now
		state.Requests = []RequestEntry{}

		if err := r.writeUnlocked(&state); err != nil {
			return err
		}
		created = &state

		return nil
	})
	if err != nil {
		return nil, fmt.Errorf("create batch: %w", err)
	}

	return created, nil
}

func (r *Repository) List() ([]Summary, error) {
	states, err := r.listStatesUnlocked()