From a2b924d7e9492b978ad6dc33b6c1ffcb304b4bc5 Mon Sep 17 00:00:00 2001
From: Nippy <nippy@rp1.hu>
Date: Sat, 9 May 2026 13:33:09 +0200
Subject: raveos update

---
 .../core/internal/matugen/queue.go                 | 143 ---------------------
 1 file changed, 143 deletions(-)
 delete mode 100644 raveos-hyprland-theme/theme-data/DankMaterialShell/core/internal/matugen/queue.go

(limited to 'raveos-hyprland-theme/theme-data/DankMaterialShell/core/internal/matugen/queue.go')

diff --git a/raveos-hyprland-theme/theme-data/DankMaterialShell/core/internal/matugen/queue.go b/raveos-hyprland-theme/theme-data/DankMaterialShell/core/internal/matugen/queue.go
deleted file mode 100644
index 38cf72a..0000000
--- a/raveos-hyprland-theme/theme-data/DankMaterialShell/core/internal/matugen/queue.go
+++ /dev/null
@@ -1,143 +0,0 @@
-package matugen
-
-import (
-	"context"
-	"errors"
-	"sync"
-
-	"github.com/AvengeMedia/DankMaterialShell/core/internal/log"
-)
-
-type Result struct {
-	Success bool
-	Error   error
-}
-
-type QueuedJob struct {
-	Options Options
-	Done    chan Result
-	Ctx     context.Context
-	Cancel  context.CancelFunc
-}
-
-type Queue struct {
-	mu      sync.Mutex
-	current *QueuedJob
-	pending *QueuedJob
-	jobDone chan struct{}
-}
-
-var globalQueue *Queue
-var queueOnce sync.Once
-
-func GetQueue() *Queue {
-	queueOnce.Do(func() {
-		globalQueue = &Queue{
-			jobDone: make(chan struct{}, 1),
-		}
-	})
-	return globalQueue
-}
-
-func (q *Queue) Submit(opts Options) <-chan Result {
-	result := make(chan Result, 1)
-	ctx, cancel := context.WithCancel(context.Background())
-
-	job := &QueuedJob{
-		Options: opts,
-		Done:    result,
-		Ctx:     ctx,
-		Cancel:  cancel,
-	}
-
-	q.mu.Lock()
-
-	if q.pending != nil {
-		log.Info("Cancelling pending theme request")
-		q.pending.Cancel()
-		q.pending.Done <- Result{Success: false, Error: context.Canceled}
-		close(q.pending.Done)
-	}
-
-	if q.current != nil {
-		q.pending = job
-		q.mu.Unlock()
-		log.Info("Theme request queued (worker running)")
-		return result
-	}
-
-	q.current = job
-	q.mu.Unlock()
-
-	go q.runWorker()
-	return result
-}
-
-func (q *Queue) runWorker() {
-	for {
-		q.mu.Lock()
-		job := q.current
-		if job == nil {
-			q.mu.Unlock()
-			return
-		}
-		q.mu.Unlock()
-
-		select {
-		case <-job.Ctx.Done():
-			q.finishJob(Result{Success: false, Error: context.Canceled})
-			continue
-		default:
-		}
-
-		log.Infof("Processing theme: %s %s (%s)", job.Options.Kind, job.Options.Value, job.Options.Mode)
-		err := Run(job.Options)
-
-		var result Result
-		switch {
-		case err == nil:
-			result = Result{Success: true}
-		case errors.Is(err, ErrNoChanges):
-			result = Result{Success: true}
-		default:
-			result = Result{Success: false, Error: err}
-		}
-
-		q.finishJob(result)
-	}
-}
-
-func (q *Queue) finishJob(result Result) {
-	q.mu.Lock()
-	defer q.mu.Unlock()
-
-	if q.current != nil {
-		select {
-		case q.current.Done <- result:
-		default:
-		}
-		close(q.current.Done)
-	}
-
-	q.current = q.pending
-	q.pending = nil
-
-	if q.current == nil {
-		select {
-		case q.jobDone <- struct{}{}:
-		default:
-		}
-	}
-}
-
-func (q *Queue) IsRunning() bool {
-	q.mu.Lock()
-	defer q.mu.Unlock()
-	return q.current != nil
-}
-
-func (q *Queue) HasPending() bool {
-	q.mu.Lock()
-	defer q.mu.Unlock()
-	return q.pending != nil
-}
-- 
cgit v1.3