read from stdin and write logs to stderr
This commit is contained in:
@@ -2,7 +2,6 @@ package main
|
|||||||
|
|
||||||
import (
|
import (
|
||||||
"context"
|
"context"
|
||||||
"fmt"
|
|
||||||
"log/slog"
|
"log/slog"
|
||||||
"os"
|
"os"
|
||||||
"os/signal"
|
"os/signal"
|
||||||
@@ -26,12 +25,8 @@ func run(ctx context.Context) error {
|
|||||||
|
|
||||||
eg, ctx := errgroup.WithContext(ctx)
|
eg, ctx := errgroup.WithContext(ctx)
|
||||||
|
|
||||||
f, err := os.Open("test.csv")
|
slog.SetDefault(slog.New(slog.NewTextHandler(os.Stderr, nil)))
|
||||||
if err != nil {
|
reader := trading212.NewRecordReader(os.Stdin)
|
||||||
return fmt.Errorf("open statement: %w", err)
|
|
||||||
}
|
|
||||||
|
|
||||||
reader := trading212.NewRecordReader(f)
|
|
||||||
|
|
||||||
writer := internal.NewStdOutLogger()
|
writer := internal.NewStdOutLogger()
|
||||||
|
|
||||||
@@ -39,7 +34,7 @@ func run(ctx context.Context) error {
|
|||||||
return internal.BuildReport(ctx, reader, writer)
|
return internal.BuildReport(ctx, reader, writer)
|
||||||
})
|
})
|
||||||
|
|
||||||
err = eg.Wait()
|
err := eg.Wait()
|
||||||
if err != nil {
|
if err != nil {
|
||||||
return err
|
return err
|
||||||
}
|
}
|
||||||
|
|||||||
Reference in New Issue
Block a user