Skip to content

Commit 309294c

Browse files
fix linting issues
1 parent a6f55e1 commit 309294c

File tree

2 files changed

+19
-7
lines changed

2 files changed

+19
-7
lines changed

gov2/transcribe/streaming/main.go

Lines changed: 8 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -17,7 +17,10 @@ func main() {
1717
logger := log.New(os.Stdout, "", log.Lmsgprefix)
1818
ctx := context.Background()
1919

20-
mic := NewMicProvider(logger)
20+
mic, err := NewMicProvider(logger)
21+
if err != nil {
22+
log.Fatal("failed to initialize port audio:", err)
23+
}
2124

2225
cp := aws.CredentialsProviderFunc(func(ctx context.Context) (aws.Credentials, error) {
2326
return aws.Credentials{
@@ -65,7 +68,10 @@ func startMicrophone(ctx context.Context, mic *MicProvider, stream *transcribe.S
6568
},
6669
}
6770

68-
stream.Send(ctx, audioStream)
71+
err := stream.Send(ctx, audioStream)
72+
if err != nil {
73+
log.Println("failed to send audio chunk: ", err)
74+
}
6975
}
7076
}()
7177
}

gov2/transcribe/streaming/mic_provider.go

Lines changed: 11 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -11,8 +11,11 @@ type MicProvider struct {
1111
stream *portaudio.Stream
1212
}
1313

14-
func NewMicProvider(log *log.Logger) *MicProvider {
15-
portaudio.Initialize()
14+
func NewMicProvider(log *log.Logger) (*MicProvider, error) {
15+
err := portaudio.Initialize()
16+
if err != nil {
17+
return nil, err
18+
}
1619

1720
defaultBytesToRead := 2048
1821

@@ -23,15 +26,18 @@ func NewMicProvider(log *log.Logger) *MicProvider {
2326

2427
stream, err := portaudio.OpenDefaultStream(inputChannels, 0, float64(samplingRate), len(intBuf), intBuf)
2528
if err != nil {
26-
log.Fatal("failed to initialize port audio:", err)
29+
return nil, err
2730
}
2831

29-
stream.Start()
32+
err = stream.Start()
33+
if err != nil {
34+
return nil, err
35+
}
3036

3137
return &MicProvider{
3238
intBuf: intBuf,
3339
stream: stream,
34-
}
40+
}, nil
3541
}
3642

3743
func (mp *MicProvider) Read() []int16 {

0 commit comments

Comments
 (0)