Scaffold modules and queue layer

internal/routing/plugin/plugin.go

@@ -0,0 +1,6 @@
+package plugin
+
+type Metadata struct {
+	Name        string
+	Description string
+}

internal/routing/queue/queue.go

@@ -0,0 +1,58 @@
+package queue
+
+import (
+	"context"
+	"sync"
+)
+
+type Task func(context.Context) error
+
+type Queue struct {
+	mu     sync.Mutex
+	closed bool
+	ch     chan Task
+}
+
+func New(size int) *Queue {
+	if size < 1 {
+		size = 1
+	}
+	return &Queue{ch: make(chan Task, size)}
+}
+
+func (q *Queue) Start(ctx context.Context) {
+	for {
+		select {
+		case <-ctx.Done():
+			return
+		case task, ok := <-q.ch:
+			if !ok {
+				return
+			}
+			if task != nil {
+				_ = task(ctx)
+			}
+		}
+	}
+}
+
+func (q *Queue) Enqueue(task Task) bool {
+	q.mu.Lock()
+	defer q.mu.Unlock()
+	if q.closed {
+		return false
+	}
+	q.ch <- task
+	return true
+}
+
+func (q *Queue) Close() {
+	q.mu.Lock()
+	if q.closed {
+		q.mu.Unlock()
+		return
+	}
+	q.closed = true
+	close(q.ch)
+	q.mu.Unlock()
+}

internal/session/session.go

@@ -0,0 +1,8 @@
+package session
+
+type ID string
+
+type Context struct {
+	SessionKey string
+	RunID      string
+}

modules/audio/audio.go

@@ -0,0 +1,6 @@
+package audio
+
+type Device struct {
+	Name string
+	ID   string
+}

modules/stt/stt.go

@@ -0,0 +1,6 @@
+package stt
+
+type Transcript struct {
+	Text   string
+	Source string
+}

modules/tts/tts.go

@@ -0,0 +1,8 @@
+package tts
+
+type Request struct {
+	Text   string
+	Voice  string
+	Rate   int
+	Engine string
+}

modules/wakeword/wakeword.go

@@ -0,0 +1,5 @@
+package wakeword
+
+type Event struct {
+	Keyword string
+}