Method Add

server/build_queue.go:47–72

Add adds a new build task to the queue.

(ctx *BuildContext)

// Add adds a new build task to the queue.
func (q *BuildQueue) Add(ctx *BuildContext) chan BuildOutput {
	q.lock.Lock()
	defer q.lock.Unlock()

	ch := make(chan BuildOutput, 1)

	task, ok := q.tasks[ctx.Path()]
	if ok {
		task.waitChans = append(task.waitChans, ch)
		return ch
	}

	task = &BuildTask{
		ctx:       ctx,
		createdAt: time.Now(),
		waitChans: []chan BuildOutput{ch},
	}
	ctx.status = "pending"

	q.pending.PushBack(task)
	q.tasks[ctx.Path()] = task

	q.startSchedulerLocked()

	return ch
}

func (q *BuildQueue) Snapshot() []map[string]any {
	q.lock.Lock()