package database

import (
	"context"
	"database/sql"

	"git.sdf.org/jchenry/x"
)

type Func func(db *sql.DB)

type Actor struct {
	DB         *sql.DB
	ActionChan chan Func
}

func (a *Actor) Run(ctx context.Context) error {
	x.Assert(ctx != nil, "Actor.Run: context cannot be nil")
	for {
		select {
		case f := <-a.ActionChan:
			f(a.DB)
		case <-ctx.Done():
			return ctx.Err()
		}
	}
}