11 Commits

Author SHA1 Message Date
b01057e11a fix: use docker login CLI instead of login-action for Gitea compat
Some checks failed
CI / Test (push) Successful in 2m55s
CI / Lint (push) Successful in 2m49s
CI / Release (push) Successful in 1m53s
CI / Notify (push) Has been cancelled
CI / Docker Build & Push (push) Has been cancelled
docker/login-action@v3 fails with 'Username and password required' on
Gitea Actions — secrets not passed to action with: inputs. Switch to
direct docker login CLI which reliably interpolates secrets in run: steps.
2026-02-21 19:34:30 -05:00
7c0be6d00e fix: switch Docker registry to HTTPS endpoint with login-action
Some checks failed
CI / Test (push) Successful in 2m52s
CI / Lint (push) Successful in 2m48s
CI / Release (push) Successful in 1m36s
CI / Docker Build & Push (push) Failing after 8m21s
CI / Notify (push) Successful in 2s
- Replace gitea-http.gitea.svc.cluster.local:3000 with registry.lab.daviestechlabs.io
- Use docker/login-action@v3 for Gitea registry auth (proper buildx integration)
- Remove manual base64 auth to ~/.docker/config.json (not picked up by buildkit)
- Remove insecure registry daemon.json config and Docker restart
- Remove buildkitd insecure registry config
- Remove cache-from/cache-to type=gha (not supported on Gitea Actions)

Fixes 401 Unauthorized: reqPackageAccess on Docker push
2026-02-21 18:05:43 -05:00
6e498cc0d5 feat: migrate from msgpack to protobuf (handler-base v1.0.0)
Some checks failed
CI / Test (push) Successful in 3m0s
CI / Lint (push) Successful in 3m0s
CI / Release (push) Successful in 59s
CI / Notify (push) Successful in 2s
CI / Docker Build & Push (push) Failing after 8m4s
- Replace msgpack encoding with protobuf wire format
- Update field names to proto convention
- Use pointer slices for repeated message fields ([]*DocumentSource)
- Rewrite tests for proto round-trips
2026-02-21 15:30:26 -05:00
d891140817 chore: bump handler-base to v0.1.5, add netrc secret mount to Dockerfile
Some checks failed
CI / Lint (push) Successful in 2m58s
CI / Test (push) Successful in 2m58s
CI / Release (push) Successful in 1m34s
CI / Docker Build & Push (push) Failing after 8m30s
CI / Notify (push) Successful in 1s
2026-02-20 18:17:00 -05:00
d0115790e0 ci: retrigger build
Some checks failed
CI / Test (push) Successful in 2m26s
CI / Lint (push) Successful in 3m17s
CI / Release (push) Successful in 1m19s
CI / Docker Build & Push (push) Failing after 7m5s
CI / Notify (push) Successful in 2s
2026-02-20 10:06:35 -05:00
ef4ef41404 fix: unignore .gitea workflow yaml files, add build-push.yaml
Some checks failed
CI / Lint (push) Successful in 2m55s
CI / Test (push) Successful in 2m38s
CI / Release (push) Successful in 56s
CI / Docker Build & Push (push) Failing after 4m3s
CI / Notify (push) Successful in 1s
The .gitignore had *.yaml for compiled KFP pipelines which was
preventing .gitea/workflows/build-push.yaml from being tracked.
2026-02-20 09:29:29 -05:00
39b1199617 fix: add GOPRIVATE and git auth for private handler-base module
- 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:38 -05:00
3a82afd483 fix: rename GITEA_TOKEN to DISPATCH_TOKEN 2026-02-20 09:10:23 -05:00
fb2d58a87f ci: add handler-base auto-update workflow, remove old Python CI 2026-02-20 09:06:02 -05:00
653445b005 fix: use tagged handler-base v0.1.3, remove local replace directive
Some checks failed
CI / Lint (push) Failing after 1m21s
CI / Test (push) Failing after 1m20s
CI / Release (push) Has been cancelled
CI / Notify (push) Has been cancelled
2026-02-20 09:00:48 -05:00
b4ed7dd5b4 fix: resolve golangci-lint errcheck warnings
Some checks failed
CI / Lint (push) Has been cancelled
CI / Test (push) Has been cancelled
CI / Release (push) Has been cancelled
CI / Notify (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:43 -05:00
9 changed files with 183 additions and 68 deletions

View File

@@ -8,6 +8,10 @@ on:
env:
NTFY_URL: http://ntfy.observability.svc.cluster.local:80
GOPRIVATE: git.daviestechlabs.io
REGISTRY: registry.lab.daviestechlabs.io/daviestechlabs
REGISTRY_HOST: registry.lab.daviestechlabs.io
IMAGE_NAME: voice-assistant
jobs:
lint:
@@ -17,20 +21,25 @@ jobs:
- 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 Go
uses: actions/setup-go@v5
with:
go-version-file: go.mod
cache: true
- name: Set up Python
run: uv python install 3.13
- name: Configure private modules
run: git config --global url."https://gitea-actions:${{ secrets.DISPATCH_TOKEN }}@git.daviestechlabs.io/".insteadOf "https://git.daviestechlabs.io/"
- name: Install dependencies
run: uv sync --frozen --extra dev
- name: Run go vet
run: go vet ./...
- name: Run ruff check
run: uv run ruff check .
- name: Install golangci-lint
run: |
curl -sSfL https://raw.githubusercontent.com/golangci/golangci-lint/HEAD/install.sh | sh -s -- -b "$(go env GOPATH)/bin"
echo "$(go env GOPATH)/bin" >> $GITHUB_PATH
- name: Run ruff format check
run: uv run ruff format --check .
- name: Run golangci-lint
run: golangci-lint run ./...
test:
name: Test
@@ -39,23 +48,31 @@ jobs:
- 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 Go
uses: actions/setup-go@v5
with:
go-version-file: go.mod
cache: true
- name: Set up Python
run: uv python install 3.13
- name: Configure private modules
run: git config --global url."https://gitea-actions:${{ secrets.DISPATCH_TOKEN }}@git.daviestechlabs.io/".insteadOf "https://git.daviestechlabs.io/"
- name: Install dependencies
run: uv sync --frozen --extra dev
- name: Verify dependencies
run: go mod verify
- name: Build
run: go build -v ./...
- name: Run tests
run: uv run pytest -v
run: go test -v -race -coverprofile=coverage.out -covermode=atomic ./...
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
@@ -95,10 +112,48 @@ jobs:
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
- name: Login to Gitea Registry
run: echo "${{ secrets.REGISTRY_TOKEN }}" | docker login "${{ env.REGISTRY_HOST }}" -u "${{ secrets.REGISTRY_USER }}" --password-stdin
- name: Login to Docker Hub
if: vars.DOCKERHUB_USERNAME != ''
run: echo "${{ secrets.DOCKERHUB_TOKEN }}" | docker login -u "${{ vars.DOCKERHUB_USERNAME }}" --password-stdin
- 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 }}
notify:
name: Notify
runs-on: ubuntu-latest
needs: [lint, test, release]
needs: [lint, test, release, docker]
if: always()
steps:
- name: Notify on success
@@ -111,7 +166,8 @@ jobs:
-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' && 'created' || 'skipped' }}" \
Release: ${{ needs.release.result == 'success' && needs.release.outputs.version || 'skipped' }}
Docker: ${{ needs.docker.result }}" \
${{ env.NTFY_URL }}/gitea-ci
- name: Notify on failure

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

1
.gitignore vendored
View File

@@ -35,6 +35,7 @@ ENV/
# Compiled KFP pipelines
*.yaml
!.pre-commit-config.yaml
!.gitea/**/*.yaml
!pipelines/*.py
# Local

View File

@@ -3,10 +3,13 @@ FROM golang:1.25-alpine AS builder
WORKDIR /app
RUN apk add --no-cache ca-certificates
RUN apk add --no-cache ca-certificates git
ENV GOPRIVATE=git.daviestechlabs.io
ENV GONOSUMCHECK=git.daviestechlabs.io
COPY go.mod go.sum ./
RUN go mod download
RUN --mount=type=secret,id=netrc,target=/root/.netrc go mod download
COPY . .

View File

@@ -28,26 +28,26 @@ func newVoiceMocks(t *testing.T) *voiceMocks {
m := &voiceMocks{}
m.STT = httptest.NewServer(http.HandlerFunc(func(w http.ResponseWriter, r *http.Request) {
json.NewEncoder(w).Encode(map[string]string{"text": "What is the weather today?"})
_ = json.NewEncoder(w).Encode(map[string]string{"text": "What is the weather today?"})
}))
t.Cleanup(m.STT.Close)
m.Embeddings = httptest.NewServer(http.HandlerFunc(func(w http.ResponseWriter, r *http.Request) {
json.NewEncoder(w).Encode(map[string]any{
_ = json.NewEncoder(w).Encode(map[string]any{
"data": []map[string]any{{"embedding": []float64{0.5, 0.6, 0.7}}},
})
}))
t.Cleanup(m.Embeddings.Close)
m.Reranker = httptest.NewServer(http.HandlerFunc(func(w http.ResponseWriter, r *http.Request) {
json.NewEncoder(w).Encode(map[string]any{
_ = json.NewEncoder(w).Encode(map[string]any{
"results": []map[string]any{{"index": 0, "relevance_score": 0.88}},
})
}))
t.Cleanup(m.Reranker.Close)
m.LLM = httptest.NewServer(http.HandlerFunc(func(w http.ResponseWriter, r *http.Request) {
json.NewEncoder(w).Encode(map[string]any{
_ = json.NewEncoder(w).Encode(map[string]any{
"choices": []map[string]any{
{"message": map[string]any{"content": "Sunny with a high of 72."}},
},
@@ -56,7 +56,7 @@ func newVoiceMocks(t *testing.T) *voiceMocks {
t.Cleanup(m.LLM.Close)
m.TTS = httptest.NewServer(http.HandlerFunc(func(w http.ResponseWriter, r *http.Request) {
w.Write(make([]byte, 8000)) // simulated audio
_, _ = w.Write(make([]byte, 8000)) // simulated audio
}))
t.Cleanup(m.TTS.Close)
@@ -122,7 +122,7 @@ func TestVoicePipeline_FullFlow(t *testing.T) {
func TestVoicePipeline_STTFailure(t *testing.T) {
failSTT := httptest.NewServer(http.HandlerFunc(func(w http.ResponseWriter, r *http.Request) {
w.WriteHeader(500)
w.Write([]byte("model not loaded"))
_, _ = w.Write([]byte("model not loaded"))
}))
defer failSTT.Close()
@@ -136,7 +136,7 @@ func TestVoicePipeline_STTFailure(t *testing.T) {
func TestVoicePipeline_TTSLargeResponse(t *testing.T) {
// TTS that returns 1 MB of audio.
bigTTS := httptest.NewServer(http.HandlerFunc(func(w http.ResponseWriter, r *http.Request) {
w.Write(make([]byte, 1<<20))
_, _ = w.Write(make([]byte, 1<<20))
}))
defer bigTTS.Close()
@@ -156,17 +156,17 @@ func TestVoicePipeline_TTSLargeResponse(t *testing.T) {
func BenchmarkVoicePipeline_Full(b *testing.B) {
sttSrv := httptest.NewServer(http.HandlerFunc(func(w http.ResponseWriter, r *http.Request) {
w.Write([]byte(`{"text":"hello"}`))
_, _ = w.Write([]byte(`{"text":"hello"}`))
}))
defer sttSrv.Close()
llmSrv := httptest.NewServer(http.HandlerFunc(func(w http.ResponseWriter, r *http.Request) {
w.Write([]byte(`{"choices":[{"message":{"content":"answer"}}]}`))
_, _ = w.Write([]byte(`{"choices":[{"message":{"content":"answer"}}]}`))
}))
defer llmSrv.Close()
ttsSrv := httptest.NewServer(http.HandlerFunc(func(w http.ResponseWriter, r *http.Request) {
w.Write(make([]byte, 4000))
_, _ = w.Write(make([]byte, 4000))
}))
defer ttsSrv.Close()
@@ -178,8 +178,8 @@ func BenchmarkVoicePipeline_Full(b *testing.B) {
b.ResetTimer()
for b.Loop() {
stt.Transcribe(ctx, audio, "en")
llm.Generate(ctx, "question", "", "")
tts.Synthesize(ctx, "answer", "en", "")
_, _ = stt.Transcribe(ctx, audio, "en")
_, _ = llm.Generate(ctx, "question", "", "")
_, _ = tts.Synthesize(ctx, "answer", "en", "")
}
}

8
go.mod
View File

@@ -3,8 +3,9 @@ module git.daviestechlabs.io/daviestechlabs/voice-assistant
go 1.25.1
require (
git.daviestechlabs.io/daviestechlabs/handler-base v0.0.0
git.daviestechlabs.io/daviestechlabs/handler-base v1.0.0
github.com/nats-io/nats.go v1.48.0
google.golang.org/protobuf v1.36.11
)
require (
@@ -18,8 +19,6 @@ require (
github.com/klauspost/compress v1.18.0 // indirect
github.com/nats-io/nkeys v0.4.11 // indirect
github.com/nats-io/nuid v1.0.1 // indirect
github.com/vmihailenco/msgpack/v5 v5.4.1 // indirect
github.com/vmihailenco/tagparser/v2 v2.0.0 // indirect
go.opentelemetry.io/auto/sdk v1.2.1 // indirect
go.opentelemetry.io/otel v1.40.0 // indirect
go.opentelemetry.io/otel/exporters/otlp/otlpmetric/otlpmetricgrpc v1.40.0 // indirect
@@ -37,7 +36,4 @@ require (
google.golang.org/genproto/googleapis/api v0.0.0-20260128011058-8636f8732409 // indirect
google.golang.org/genproto/googleapis/rpc v0.0.0-20260128011058-8636f8732409 // indirect
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

6
go.sum
View File

@@ -1,3 +1,5 @@
git.daviestechlabs.io/daviestechlabs/handler-base v1.0.0 h1:pB3ehOKaDYQfbyRBKQXrB9curqSFteLrDveoElRKnBY=
git.daviestechlabs.io/daviestechlabs/handler-base v1.0.0/go.mod h1:zocOHFt8yY3cW4+Xi37sNr5Tw7KcjGFSZqgWYxPWyqA=
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=
@@ -31,10 +33,6 @@ github.com/pmezard/go-difflib v1.0.0 h1:4DBwDE0NGyQoBHbLQYPwSUPoCMWR5BEzIk/f1lZb
github.com/pmezard/go-difflib v1.0.0/go.mod h1:iKH77koFhYxTK1pcRnkKkqfTogsbg7gZNVY4sRDYZ/4=
github.com/stretchr/testify v1.11.1 h1:7s2iGBzp5EwR7/aIZr8ao5+dra3wiQyKjjFuvgVKu7U=
github.com/stretchr/testify v1.11.1/go.mod h1:wZwfW3scLgRK+23gO65QZefKpKQRnfz6sD981Nm4B6U=
github.com/vmihailenco/msgpack/v5 v5.4.1 h1:cQriyiUvjTwOHg8QZaPihLWeRAAVoCpE00IUPn0Bjt8=
github.com/vmihailenco/msgpack/v5 v5.4.1/go.mod h1:GaZTsDaehaPpQVyxrf5mtQlH+pc21PIudVV/E3rRQok=
github.com/vmihailenco/tagparser/v2 v2.0.0 h1:y09buUbR+b5aycVFQs/g70pqKVZNBmxwAhO7/IwNM9g=
github.com/vmihailenco/tagparser/v2 v2.0.0/go.mod h1:Wri+At7QHww0WTrCBeu4J6bNtoV6mEfg5OIWRZA9qds=
go.opentelemetry.io/auto/sdk v1.2.1 h1:jXsnJ4Lmnqd11kwkBV2LgLoFMZKizbCi5fNZ/ipaZ64=
go.opentelemetry.io/auto/sdk v1.2.1/go.mod h1:KRTj+aOaElaLi+wW1kO/DZRXwkF4C5xPbEe3ZiIhN7Y=
go.opentelemetry.io/otel v1.40.0 h1:oA5YeOcpRTXq6NN7frwmwFR0Cn3RhTVZvXsP4duvCms=

19
main.go
View File

@@ -16,6 +16,7 @@ import (
"git.daviestechlabs.io/daviestechlabs/handler-base/handler"
"git.daviestechlabs.io/daviestechlabs/handler-base/messages"
"git.daviestechlabs.io/daviestechlabs/handler-base/natsutil"
"google.golang.org/protobuf/proto"
)
func main() {
@@ -43,13 +44,13 @@ func main() {
h := handler.New("voice.request", cfg)
h.OnTypedMessage(func(ctx context.Context, msg *nats.Msg) (any, error) {
req, err := natsutil.Decode[messages.VoiceRequest](msg.Data)
if err != nil {
h.OnTypedMessage(func(ctx context.Context, msg *nats.Msg) (proto.Message, error) {
var req messages.VoiceRequest
if err := natsutil.Decode(msg.Data, &req); err != nil {
return &messages.VoiceResponse{Error: "Invalid request encoding"}, nil
}
requestID := req.RequestID
requestID := req.RequestId
if requestID == "" {
requestID = "unknown"
}
@@ -64,8 +65,8 @@ func main() {
slog.Info("processing voice request", "request_id", requestID)
errResp := func(msg string) (any, error) {
return &messages.VoiceResponse{RequestID: requestID, Error: msg}, nil
errResp := func(msg string) (proto.Message, error) {
return &messages.VoiceResponse{RequestId: requestID, Error: msg}, nil
}
// 1. Audio arrives as raw bytes — no base64 decode needed
@@ -146,7 +147,7 @@ func main() {
// Build typed response
result := &messages.VoiceResponse{
RequestID: requestID,
RequestId: requestID,
Response: responseText,
Audio: responseAudio,
}
@@ -160,13 +161,13 @@ func main() {
if len(documents) < limit {
limit = len(documents)
}
result.Sources = make([]messages.DocumentSource, limit)
result.Sources = make([]*messages.DocumentSource, limit)
for i := 0; i < limit; i++ {
text := documents[i].Document
if len(text) > 200 {
text = text[:200]
}
result.Sources[i] = messages.DocumentSource{Text: text, Score: documents[i].Score}
result.Sources[i] = &messages.DocumentSource{Text: text, Score: documents[i].Score}
}
}

View File

@@ -5,26 +5,26 @@ import (
"git.daviestechlabs.io/daviestechlabs/handler-base/messages"
"git.daviestechlabs.io/daviestechlabs/handler-base/natsutil"
"github.com/vmihailenco/msgpack/v5"
"google.golang.org/protobuf/proto"
)
func TestVoiceRequestDecode(t *testing.T) {
req := messages.VoiceRequest{
RequestID: "req-123",
req := &messages.VoiceRequest{
RequestId: "req-123",
Audio: []byte{0x01, 0x02, 0x03},
Language: "en",
Collection: "docs",
}
data, err := msgpack.Marshal(&req)
data, err := proto.Marshal(req)
if err != nil {
t.Fatal(err)
}
decoded, err := natsutil.Decode[messages.VoiceRequest](data)
if err != nil {
var decoded messages.VoiceRequest
if err := natsutil.Decode(data, &decoded); err != nil {
t.Fatal(err)
}
if decoded.RequestID != "req-123" {
t.Errorf("RequestID = %q", decoded.RequestID)
if decoded.RequestId != "req-123" {
t.Errorf("RequestId = %q", decoded.RequestId)
}
if len(decoded.Audio) != 3 {
t.Errorf("Audio len = %d", len(decoded.Audio))
@@ -32,19 +32,19 @@ func TestVoiceRequestDecode(t *testing.T) {
}
func TestVoiceResponseRoundtrip(t *testing.T) {
resp := messages.VoiceResponse{
RequestID: "req-456",
resp := &messages.VoiceResponse{
RequestId: "req-456",
Response: "It is sunny today.",
Audio: make([]byte, 8000),
Transcription: "What is the weather?",
Sources: []messages.DocumentSource{{Text: "weather doc", Score: 0.9}},
Sources: []*messages.DocumentSource{{Text: "weather doc", Score: 0.9}},
}
data, err := msgpack.Marshal(&resp)
data, err := proto.Marshal(resp)
if err != nil {
t.Fatal(err)
}
var got messages.VoiceResponse
if err := msgpack.Unmarshal(data, &got); err != nil {
if err := proto.Unmarshal(data, &got); err != nil {
t.Fatal(err)
}
if got.Response != "It is sunny today." {