5 Commits

Author SHA1 Message Date
b1c1a7bd6e fix: add GOPRIVATE and git auth for private handler-base module
Some checks failed
CI / Lint (push) Successful in 2m33s
CI / Test (push) Successful in 2m33s
CI / Release (push) Successful in 1m1s
CI / Docker Build & Push (push) Failing after 6m16s
CI / Notify (push) Successful in 1s
- Set GOPRIVATE=git.daviestechlabs.io to bypass public Go module proxy
- Configure git URL insteadOf with DISPATCH_TOKEN for private repo access
2026-02-20 09:22:37 -05:00
cdc551924e fix: rename GITEA_TOKEN to DISPATCH_TOKEN
Some checks failed
CI / Lint (push) Has been cancelled
CI / Test (push) Has been cancelled
CI / Docker Build & Push (push) Has been cancelled
CI / Release (push) Has been cancelled
CI / Notify (push) Has been cancelled
2026-02-20 09:10:22 -05:00
71a480dd80 ci: add handler-base auto-update workflow, remove old Python CI
Some checks failed
CI / Release (push) Has been cancelled
CI / Lint (push) Has been cancelled
CI / Test (push) Has been cancelled
CI / Docker Build & Push (push) Has been cancelled
CI / Notify (push) Has been cancelled
2026-02-20 09:06:01 -05:00
e5a3efc701 fix: use tagged handler-base v0.1.3, remove local replace directive
Some checks failed
CI / Test (push) Failing after 1m19s
CI / Release (push) Has been skipped
CI / Lint (push) Failing after 1m16s
CI / Docker Build & Push (push) Has been cancelled
CI / Notify (push) Has been cancelled
2026-02-20 09:00:47 -05:00
ef52519d4d fix: resolve golangci-lint errcheck warnings
Some checks failed
CI / Test (push) Has been cancelled
CI / Release (push) Has been cancelled
CI / Docker Build & Push (push) Has been cancelled
CI / Notify (push) Has been cancelled
CI / Lint (push) Has been cancelled
- Add error checks for unchecked return values (errcheck)
- Remove unused struct fields (unused)
- Fix gofmt formatting issues
2026-02-20 08:45:42 -05:00
8 changed files with 105 additions and 239 deletions

View File

@@ -8,6 +8,7 @@ on:
env:
NTFY_URL: http://ntfy.observability.svc.cluster.local:80
GOPRIVATE: git.daviestechlabs.io
REGISTRY: gitea-http.gitea.svc.cluster.local:3000/daviestechlabs
REGISTRY_HOST: gitea-http.gitea.svc.cluster.local:3000
IMAGE_NAME: tts-module
@@ -26,6 +27,9 @@ jobs:
go-version-file: go.mod
cache: true
- name: Configure private modules
run: git config --global url."https://gitea-actions:${{ secrets.DISPATCH_TOKEN }}@git.daviestechlabs.io/".insteadOf "https://git.daviestechlabs.io/"
- name: Run go vet
run: go vet ./...
@@ -50,6 +54,9 @@ jobs:
go-version-file: go.mod
cache: true
- name: Configure private modules
run: git config --global url."https://gitea-actions:${{ secrets.DISPATCH_TOKEN }}@git.daviestechlabs.io/".insteadOf "https://git.daviestechlabs.io/"
- name: Verify dependencies
run: go mod verify

View File

@@ -1,201 +0,0 @@
name: CI
on:
push:
branches: [main]
pull_request:
branches: [main]
env:
NTFY_URL: http://ntfy.observability.svc.cluster.local:80
REGISTRY: gitea-http.gitea.svc.cluster.local:3000/daviestechlabs
REGISTRY_HOST: gitea-http.gitea.svc.cluster.local:3000
IMAGE_NAME: tts-module
jobs:
lint:
name: Lint
runs-on: ubuntu-latest
steps:
- name: Checkout code
uses: actions/checkout@v4
- name: Set up uv
run: curl -LsSf https://astral.sh/uv/install.sh | sh && echo "$HOME/.local/bin" >> $GITHUB_PATH
- name: Set up Python
run: uv python install 3.12
- name: Install dependencies
run: uv sync --frozen --extra dev
- name: Run ruff check
run: uv run ruff check .
- name: Run ruff format check
run: uv run ruff format --check .
test:
name: Test
runs-on: ubuntu-latest
steps:
- name: Checkout code
uses: actions/checkout@v4
- name: Set up uv
run: curl -LsSf https://astral.sh/uv/install.sh | sh && echo "$HOME/.local/bin" >> $GITHUB_PATH
- name: Set up Python
run: uv python install 3.12
- name: Install dependencies
run: uv sync --frozen --extra dev
- name: Run tests
run: uv run pytest -v
release:
name: Release
runs-on: ubuntu-latest
needs: [lint, test]
if: gitea.ref == 'refs/heads/main' && gitea.event_name == 'push'
outputs:
version: ${{ steps.version.outputs.version }}
steps:
- name: Checkout
uses: actions/checkout@v4
with:
fetch-depth: 0
- name: Determine version bump
id: version
run: |
# Get latest tag or default to v0.0.0
LATEST=$(git describe --tags --abbrev=0 2>/dev/null || echo "v0.0.0")
VERSION=${LATEST#v}
IFS='.' read -r MAJOR MINOR PATCH <<< "$VERSION"
# Check commit message for keywords
MSG="${{ gitea.event.head_commit.message }}"
if echo "$MSG" | grep -qiE "^major:|BREAKING CHANGE"; then
MAJOR=$((MAJOR + 1)); MINOR=0; PATCH=0
BUMP="major"
elif echo "$MSG" | grep -qiE "^(minor:|feat:)"; then
MINOR=$((MINOR + 1)); PATCH=0
BUMP="minor"
else
PATCH=$((PATCH + 1))
BUMP="patch"
fi
NEW_VERSION="v${MAJOR}.${MINOR}.${PATCH}"
echo "version=$NEW_VERSION" >> $GITHUB_OUTPUT
echo "bump=$BUMP" >> $GITHUB_OUTPUT
echo "Bumping $LATEST → $NEW_VERSION ($BUMP)"
- name: Create and push tag
run: |
git config user.name "gitea-actions[bot]"
git config user.email "actions@git.daviestechlabs.io"
git tag -a ${{ steps.version.outputs.version }} -m "Release ${{ steps.version.outputs.version }}"
git push origin ${{ steps.version.outputs.version }}
docker:
name: Docker Build & Push
runs-on: ubuntu-latest
needs: [lint, test, release]
if: gitea.ref == 'refs/heads/main' && gitea.event_name == 'push'
steps:
- name: Checkout
uses: actions/checkout@v4
- name: Set up Docker Buildx
uses: docker/setup-buildx-action@v3
with:
buildkitd-config-inline: |
[registry."gitea-http.gitea.svc.cluster.local:3000"]
http = true
insecure = true
- name: Login to Docker Hub
if: vars.DOCKERHUB_USERNAME != ''
uses: docker/login-action@v3
with:
username: ${{ vars.DOCKERHUB_USERNAME }}
password: ${{ secrets.DOCKERHUB_TOKEN }}
- name: Configure Docker for insecure registry
run: |
sudo mkdir -p /etc/docker
echo '{"insecure-registries": ["${{ env.REGISTRY_HOST }}"]}' | sudo tee /etc/docker/daemon.json
sudo systemctl restart docker || sudo service docker restart || true
sleep 2
- name: Login to Gitea Registry
run: |
AUTH=$(echo -n "${{ secrets.REGISTRY_USER }}:${{ secrets.REGISTRY_TOKEN }}" | base64 -w0)
mkdir -p ~/.docker
cat > ~/.docker/config.json << EOF
{
"auths": {
"${{ env.REGISTRY_HOST }}": {
"auth": "$AUTH"
}
}
}
EOF
echo "Auth configured for ${{ env.REGISTRY_HOST }}"
- name: Extract metadata
id: meta
uses: docker/metadata-action@v5
with:
images: ${{ env.REGISTRY }}/${{ env.IMAGE_NAME }}
tags: |
type=semver,pattern={{version}},value=${{ needs.release.outputs.version }}
type=semver,pattern={{major}}.{{minor}},value=${{ needs.release.outputs.version }}
type=raw,value=latest,enable={{is_default_branch}}
- name: Build and push
uses: docker/build-push-action@v5
with:
context: .
push: true
tags: ${{ steps.meta.outputs.tags }}
labels: ${{ steps.meta.outputs.labels }}
cache-from: type=gha
cache-to: type=gha,mode=max
notify:
name: Notify
runs-on: ubuntu-latest
needs: [lint, test, release, docker]
if: always()
steps:
- name: Notify on success
if: needs.lint.result == 'success' && needs.test.result == 'success'
run: |
curl -s \
-H "Title: ✅ CI Passed: ${{ gitea.repository }}" \
-H "Priority: default" \
-H "Tags: white_check_mark,github" \
-H "Click: ${{ gitea.server_url }}/${{ gitea.repository }}/actions/runs/${{ gitea.run_id }}" \
-d "Branch: ${{ gitea.ref_name }}
Commit: ${{ gitea.event.head_commit.message || gitea.sha }}
Release: ${{ needs.release.result == 'success' && needs.release.outputs.version || 'skipped' }}
Docker: ${{ needs.docker.result }}" \
${{ env.NTFY_URL }}/gitea-ci
- name: Notify on failure
if: needs.lint.result == 'failure' || needs.test.result == 'failure'
run: |
curl -s \
-H "Title: ❌ CI Failed: ${{ gitea.repository }}" \
-H "Priority: high" \
-H "Tags: x,github" \
-H "Click: ${{ gitea.server_url }}/${{ gitea.repository }}/actions/runs/${{ gitea.run_id }}" \
-d "Branch: ${{ gitea.ref_name }}
Commit: ${{ gitea.event.head_commit.message || gitea.sha }}
Lint: ${{ needs.lint.result }}
Test: ${{ needs.test.result }}" \
${{ env.NTFY_URL }}/gitea-ci

View File

@@ -0,0 +1,60 @@
name: Update handler-base
on:
repository_dispatch:
types: [handler-base-release]
env:
NTFY_URL: http://ntfy.observability.svc.cluster.local:80
GOPRIVATE: git.daviestechlabs.io
jobs:
update:
name: Update handler-base dependency
runs-on: ubuntu-latest
steps:
- name: Checkout code
uses: actions/checkout@v4
with:
token: ${{ secrets.DISPATCH_TOKEN }}
- name: Set up Go
uses: actions/setup-go@v5
with:
go-version-file: go.mod
cache: true
- name: Configure Git
run: |
git config user.name "gitea-actions[bot]"
git config user.email "actions@git.daviestechlabs.io"
git config --global url."https://gitea-actions:${{ secrets.DISPATCH_TOKEN }}@git.daviestechlabs.io/".insteadOf "https://git.daviestechlabs.io/"
- name: Update handler-base
run: |
VERSION="${{ gitea.event.client_payload.version }}"
echo "Updating handler-base to ${VERSION}"
go get git.daviestechlabs.io/daviestechlabs/handler-base@${VERSION}
go mod tidy
- name: Commit and push
run: |
VERSION="${{ gitea.event.client_payload.version }}"
if git diff --quiet go.mod go.sum; then
echo "No changes to commit"
exit 0
fi
git add go.mod go.sum
git commit -m "chore(deps): bump handler-base to ${VERSION}"
git push
- name: Notify
if: success()
run: |
VERSION="${{ gitea.event.client_payload.version }}"
curl -s \
-H "Title: 📦 Dep Update: ${{ gitea.repository }}" \
-H "Priority: default" \
-H "Tags: package,github" \
-d "handler-base updated to ${VERSION}" \
${{ env.NTFY_URL }}/gitea-ci

View File

@@ -24,13 +24,13 @@ func TestSynthesisE2E_StreamChunks(t *testing.T) {
audioSize := 65536
xttsSrv := httptest.NewServer(http.HandlerFunc(func(w http.ResponseWriter, r *http.Request) {
var payload map[string]any
json.NewDecoder(r.Body).Decode(&payload)
_ = json.NewDecoder(r.Body).Decode(&payload)
if payload["text"] == nil || payload["text"] == "" {
w.WriteHeader(400)
w.Write([]byte("empty text"))
_, _ = w.Write([]byte("empty text"))
return
}
w.Write(make([]byte, audioSize))
_, _ = w.Write(make([]byte, audioSize))
}))
defer xttsSrv.Close()
@@ -42,7 +42,7 @@ func TestSynthesisE2E_StreamChunks(t *testing.T) {
if err != nil {
t.Fatal(err)
}
defer resp.Body.Close()
defer func() { _ = resp.Body.Close() }()
audioBytes, _ := io.ReadAll(resp.Body)
if len(audioBytes) != audioSize {
@@ -78,7 +78,7 @@ func TestSynthesisE2E_StreamChunks(t *testing.T) {
// Round-trip through msgpack
data, _ := msgpack.Marshal(&msg)
var decoded messages.TTSAudioChunk
msgpack.Unmarshal(data, &decoded)
_ = msgpack.Unmarshal(data, &decoded)
if decoded.SessionID != "test-session" {
t.Errorf("chunk %d: session = %v", chunkIdx, decoded.SessionID)
@@ -96,15 +96,15 @@ func TestSynthesisE2E_CustomVoice(t *testing.T) {
// Set up voice registry with temp dir
dir := t.TempDir()
voiceDir := filepath.Join(dir, "custom-en")
os.MkdirAll(voiceDir, 0o755)
_ = os.MkdirAll(voiceDir, 0o755)
info := map[string]string{
"name": "custom-en", "language": "en",
"type": "coqui-tts", "created_at": "2024-06-01",
}
infoData, _ := json.Marshal(info)
os.WriteFile(filepath.Join(voiceDir, "model_info.json"), infoData, 0o644)
os.WriteFile(filepath.Join(voiceDir, "model.pth"), []byte("fake-model"), 0o644)
os.WriteFile(filepath.Join(voiceDir, "config.json"), []byte("{}"), 0o644)
_ = os.WriteFile(filepath.Join(voiceDir, "model_info.json"), infoData, 0o644)
_ = os.WriteFile(filepath.Join(voiceDir, "model.pth"), []byte("fake-model"), 0o644)
_ = os.WriteFile(filepath.Join(voiceDir, "config.json"), []byte("{}"), 0o644)
registry := newVoiceRegistry(dir)
count := registry.refresh()
@@ -115,7 +115,7 @@ func TestSynthesisE2E_CustomVoice(t *testing.T) {
// XTTS mock that validates custom voice fields
xttsSrv := httptest.NewServer(http.HandlerFunc(func(w http.ResponseWriter, r *http.Request) {
var payload map[string]any
json.NewDecoder(r.Body).Decode(&payload)
_ = json.NewDecoder(r.Body).Decode(&payload)
// When custom voice is used, model_path should be set
if payload["model_path"] == nil {
@@ -124,7 +124,7 @@ func TestSynthesisE2E_CustomVoice(t *testing.T) {
if payload["config_path"] == nil {
t.Error("expected config_path for voice with config")
}
w.Write(make([]byte, 4000))
_, _ = w.Write(make([]byte, 4000))
}))
defer xttsSrv.Close()
@@ -152,7 +152,7 @@ func TestSynthesisE2E_CustomVoice(t *testing.T) {
if err != nil {
t.Fatal(err)
}
defer resp.Body.Close()
defer func() { _ = resp.Body.Close() }()
if resp.StatusCode != 200 {
t.Errorf("status = %d, want 200", resp.StatusCode)
}
@@ -161,7 +161,7 @@ func TestSynthesisE2E_CustomVoice(t *testing.T) {
func TestSynthesisE2E_XTTSError(t *testing.T) {
failSrv := httptest.NewServer(http.HandlerFunc(func(w http.ResponseWriter, r *http.Request) {
w.WriteHeader(503)
w.Write([]byte("model not loaded"))
_, _ = w.Write([]byte("model not loaded"))
}))
defer failSrv.Close()
@@ -170,7 +170,7 @@ func TestSynthesisE2E_XTTSError(t *testing.T) {
if err != nil {
t.Fatal(err)
}
defer resp.Body.Close()
defer func() { _ = resp.Body.Close() }()
if resp.StatusCode != 503 {
t.Errorf("status = %d, want 503", resp.StatusCode)
}
@@ -182,11 +182,11 @@ func TestVoiceRegistryMultiple(t *testing.T) {
// Create 3 voices
for _, name := range []string{"alice", "bob", "charlie"} {
vDir := filepath.Join(dir, name)
os.MkdirAll(vDir, 0o755)
_ = os.MkdirAll(vDir, 0o755)
info := map[string]string{"name": name, "language": "en"}
data, _ := json.Marshal(info)
os.WriteFile(filepath.Join(vDir, "model_info.json"), data, 0o644)
os.WriteFile(filepath.Join(vDir, "model.pth"), []byte("fake"), 0o644)
_ = os.WriteFile(filepath.Join(vDir, "model_info.json"), data, 0o644)
_ = os.WriteFile(filepath.Join(vDir, "model.pth"), []byte("fake"), 0o644)
}
registry := newVoiceRegistry(dir)
@@ -216,7 +216,7 @@ func TestVoiceRegistryMultiple(t *testing.T) {
func BenchmarkSynthesisRoundtrip(b *testing.B) {
xttsSrv := httptest.NewServer(http.HandlerFunc(func(w http.ResponseWriter, r *http.Request) {
w.Write(make([]byte, 16000))
_, _ = w.Write(make([]byte, 16000))
}))
defer xttsSrv.Close()
@@ -227,8 +227,8 @@ func BenchmarkSynthesisRoundtrip(b *testing.B) {
for b.Loop() {
resp, _ := client.Post(xttsSrv.URL+"/v1/audio/speech", "application/json",
bytes.NewReader(body))
io.ReadAll(resp.Body)
resp.Body.Close()
_, _ = io.ReadAll(resp.Body)
_ = resp.Body.Close()
}
}
@@ -237,11 +237,11 @@ func BenchmarkVoiceRegistryRefresh(b *testing.B) {
for i := 0; i < 10; i++ {
name := "voice-" + strconv.Itoa(i)
vDir := filepath.Join(dir, name)
os.MkdirAll(vDir, 0o755)
_ = os.MkdirAll(vDir, 0o755)
info := map[string]string{"name": name}
data, _ := json.Marshal(info)
os.WriteFile(filepath.Join(vDir, "model_info.json"), data, 0o644)
os.WriteFile(filepath.Join(vDir, "model.pth"), []byte("fake"), 0o644)
_ = os.WriteFile(filepath.Join(vDir, "model_info.json"), data, 0o644)
_ = os.WriteFile(filepath.Join(vDir, "model.pth"), []byte("fake"), 0o644)
}
registry := newVoiceRegistry(dir)
@@ -272,7 +272,7 @@ func BenchmarkAudioChunking(b *testing.B) {
Audio: chunk,
SampleRate: 24000,
}
msgpack.Marshal(msg)
_, _ = msgpack.Marshal(msg)
}
}
}

4
go.mod
View File

@@ -3,7 +3,7 @@ module git.daviestechlabs.io/daviestechlabs/tts-module
go 1.25.1
require (
git.daviestechlabs.io/daviestechlabs/handler-base v0.0.0
git.daviestechlabs.io/daviestechlabs/handler-base v0.1.3
github.com/nats-io/nats.go v1.48.0
github.com/vmihailenco/msgpack/v5 v5.4.1
)
@@ -39,5 +39,3 @@ require (
google.golang.org/grpc v1.78.0 // indirect
google.golang.org/protobuf v1.36.11 // indirect
)
replace git.daviestechlabs.io/daviestechlabs/handler-base => ../handler-base

2
go.sum
View File

@@ -1,3 +1,5 @@
git.daviestechlabs.io/daviestechlabs/handler-base v0.1.3 h1:uYog8B839ulqrWoht3qqCvT7CnR3e2skpaLZc2Pg3GI=
git.daviestechlabs.io/daviestechlabs/handler-base v0.1.3/go.mod h1:M3HgvUDWnRn7cX3BE8l+HvoCUYtmRr5OoumB+hnRHoE=
github.com/cenkalti/backoff/v5 v5.0.3 h1:ZN+IMa753KfX5hd8vVaMixjnqRZ3y8CuJKRKj1xcsSM=
github.com/cenkalti/backoff/v5 v5.0.3/go.mod h1:rkhZdG3JZukswDf7f0cwqPNk4K0sa+F97BxZthm/crw=
github.com/cespare/xxhash/v2 v2.3.0 h1:UL815xU9SqsFlibzuggzjXhog7bL6oX9BbNZnL2UFvs=

View File

@@ -262,7 +262,7 @@ func main() {
if err != nil {
return nil, fmt.Errorf("xtts request: %w", err)
}
defer resp.Body.Close()
defer func() { _ = resp.Body.Close() }()
if resp.StatusCode >= 400 {
respBody, _ := io.ReadAll(resp.Body)
@@ -370,7 +370,7 @@ func main() {
}
packed, _ := msgpack.Marshal(resp)
if msg.Reply != "" {
msg.Respond(packed)
_ = msg.Respond(packed)
}
}); err != nil {
slog.Error("subscribe voices list failed", "error", err)
@@ -386,7 +386,7 @@ func main() {
}
packed, _ := msgpack.Marshal(resp)
if msg.Reply != "" {
msg.Respond(packed)
_ = msg.Respond(packed)
}
slog.Info("voice registry refreshed on demand", "count", count)
}); err != nil {

View File

@@ -19,11 +19,11 @@ func TestVoiceRegistryRefresh(t *testing.T) {
// Create a voice directory
voiceDir := filepath.Join(dir, "test-voice")
os.MkdirAll(voiceDir, 0o755)
_ = os.MkdirAll(voiceDir, 0o755)
info := map[string]string{"name": "test-voice", "language": "en", "type": "coqui-tts", "created_at": "2024-01-01"}
infoData, _ := json.Marshal(info)
os.WriteFile(filepath.Join(voiceDir, "model_info.json"), infoData, 0o644)
os.WriteFile(filepath.Join(voiceDir, "model.pth"), []byte("fake"), 0o644)
_ = os.WriteFile(filepath.Join(voiceDir, "model_info.json"), infoData, 0o644)
_ = os.WriteFile(filepath.Join(voiceDir, "model.pth"), []byte("fake"), 0o644)
vr := newVoiceRegistry(dir)
count := vr.refresh()
@@ -59,10 +59,10 @@ func TestVoiceRegistryMissing(t *testing.T) {
func TestVoiceRegistryNoModel(t *testing.T) {
dir := t.TempDir()
voiceDir := filepath.Join(dir, "bad-voice")
os.MkdirAll(voiceDir, 0o755)
_ = os.MkdirAll(voiceDir, 0o755)
info := map[string]string{"name": "bad-voice"}
infoData, _ := json.Marshal(info)
os.WriteFile(filepath.Join(voiceDir, "model_info.json"), infoData, 0o644)
_ = os.WriteFile(filepath.Join(voiceDir, "model_info.json"), infoData, 0o644)
// No model.pth
vr := newVoiceRegistry(dir)
@@ -82,12 +82,12 @@ func TestSynthesizeHTTP(t *testing.T) {
}
var payload map[string]any
json.NewDecoder(r.Body).Decode(&payload)
_ = json.NewDecoder(r.Body).Decode(&payload)
if payload["text"] != "hello" {
t.Errorf("unexpected text: %v", payload["text"])
}
w.Write([]byte{0x01, 0x02, 0x03, 0x04})
_, _ = w.Write([]byte{0x01, 0x02, 0x03, 0x04})
}))
defer ts.Close()
@@ -98,7 +98,7 @@ func TestSynthesizeHTTP(t *testing.T) {
if err != nil {
t.Fatal(err)
}
defer resp.Body.Close()
defer func() { _ = resp.Body.Close() }()
if resp.StatusCode != 200 {
t.Errorf("status = %d, want 200", resp.StatusCode)
}