Compare commits

...

3 Commits

10 changed files with 42 additions and 21 deletions

View File

@@ -11,13 +11,11 @@ This tool converts the statements from brokers and exchanges into a format compa
## Install ## Install
```bash ```bash
go install git.naterciomoniz.net/applications/broker2anexoj@latest go install github.com/nmoniz/any2anexoj/cmd/any2anexoj-cli@latest
``` ```
## Usage ## Usage
```bash ```bash
broker2anexoj cat statement.csv | broker2anexoj --platform=tranding212
``` ```

View File

@@ -7,31 +7,49 @@ import (
"os" "os"
"os/signal" "os/signal"
"git.naterciomoniz.net/applications/broker2anexoj/internal" "github.com/nmoniz/any2anexoj/internal"
"git.naterciomoniz.net/applications/broker2anexoj/internal/trading212" "github.com/nmoniz/any2anexoj/internal/trading212"
"github.com/spf13/pflag"
"golang.org/x/sync/errgroup" "golang.org/x/sync/errgroup"
) )
// TODO: once we support more brokers or exchanges we should make this parameter required and
// remove/change default
var platform = pflag.StringP("platform", "p", "trading212", "one of the supported platforms")
var supportedPlatforms = map[string]func() internal.RecordReader{
"trading212": func() internal.RecordReader { return trading212.NewRecordReader(os.Stdin) },
}
func main() { func main() {
err := run(context.Background()) pflag.Parse()
if platform == nil || len(*platform) == 0 {
slog.Error("--platform flag is required")
os.Exit(1)
}
err := run(context.Background(), *platform)
if err != nil { if err != nil {
slog.Error("found a fatal issue", slog.Any("err", err)) slog.Error("found a fatal issue", slog.Any("err", err))
os.Exit(1) os.Exit(1)
} }
} }
func run(ctx context.Context) error { func run(ctx context.Context, platform string) error {
ctx, cancel := signal.NotifyContext(ctx, os.Kill, os.Interrupt) ctx, cancel := signal.NotifyContext(ctx, os.Kill, os.Interrupt)
defer cancel() defer cancel()
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 {
return fmt.Errorf("open statement: %w", err) factory, ok := supportedPlatforms[platform]
if !ok {
return fmt.Errorf("unsupported platform: %s", platform)
} }
reader := trading212.NewRecordReader(f) reader := factory()
writer := internal.NewStdOutLogger() writer := internal.NewStdOutLogger()
@@ -39,7 +57,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
} }

3
go.mod
View File

@@ -1,4 +1,4 @@
module git.naterciomoniz.net/applications/broker2anexoj module github.com/nmoniz/any2anexoj
go 1.25.3 go 1.25.3
@@ -8,6 +8,7 @@ require (
) )
require ( require (
github.com/spf13/pflag v1.0.10 // indirect
golang.org/x/mod v0.27.0 // indirect golang.org/x/mod v0.27.0 // indirect
golang.org/x/tools v0.36.0 // indirect golang.org/x/tools v0.36.0 // indirect
) )

2
go.sum
View File

@@ -4,6 +4,8 @@ github.com/google/go-cmp v0.6.0 h1:ofyhxvXcZhMsU5ulbFiLKl/XBFqE1GSq7atu8tAmTRI=
github.com/google/go-cmp v0.6.0/go.mod h1:17dUlkBOakJ0+DkrSSNjCkIjxS6bF9zb3elmeNGIjoY= github.com/google/go-cmp v0.6.0/go.mod h1:17dUlkBOakJ0+DkrSSNjCkIjxS6bF9zb3elmeNGIjoY=
github.com/pmezard/go-difflib v1.0.0 h1:4DBwDE0NGyQoBHbLQYPwSUPoCMWR5BEzIk/f1lZbAQM= github.com/pmezard/go-difflib v1.0.0 h1:4DBwDE0NGyQoBHbLQYPwSUPoCMWR5BEzIk/f1lZbAQM=
github.com/pmezard/go-difflib v1.0.0/go.mod h1:iKH77koFhYxTK1pcRnkKkqfTogsbg7gZNVY4sRDYZ/4= github.com/pmezard/go-difflib v1.0.0/go.mod h1:iKH77koFhYxTK1pcRnkKkqfTogsbg7gZNVY4sRDYZ/4=
github.com/spf13/pflag v1.0.10 h1:4EBh2KAYBwaONj6b2Ye1GiHfwjqyROoF4RwYO+vPwFk=
github.com/spf13/pflag v1.0.10/go.mod h1:McXfInJRrz4CZXVZOBLb0bTZqETkiAhM9Iw0y3An2Bg=
github.com/stretchr/testify v1.9.0 h1:HtqpIVDClZ4nwg75+f6Lvsy/wHu+3BoSGCbBAcpTsTg= github.com/stretchr/testify v1.9.0 h1:HtqpIVDClZ4nwg75+f6Lvsy/wHu+3BoSGCbBAcpTsTg=
github.com/stretchr/testify v1.9.0/go.mod h1:r2ic/lqez/lEtzL7wO/rwa5dbSLXVDPFyf8C91i36aY= github.com/stretchr/testify v1.9.0/go.mod h1:r2ic/lqez/lEtzL7wO/rwa5dbSLXVDPFyf8C91i36aY=
go.uber.org/mock v0.6.0 h1:hyF9dfmbgIX5EfOdasqLsWD6xqpNZlXblLB/Dbnwv3Y= go.uber.org/mock v0.6.0 h1:hyF9dfmbgIX5EfOdasqLsWD6xqpNZlXblLB/Dbnwv3Y=

View File

@@ -1,5 +1,5 @@
// Code generated by MockGen. DO NOT EDIT. // Code generated by MockGen. DO NOT EDIT.
// Source: git.naterciomoniz.net/applications/broker2anexoj/internal (interfaces: RecordReader,Record,ReportWriter) // Source: github.com/nmoniz/any2anexoj/internal (interfaces: RecordReader,Record,ReportWriter)
// //
// Generated by this command: // Generated by this command:
// //
@@ -15,7 +15,7 @@ import (
reflect "reflect" reflect "reflect"
time "time" time "time"
internal "git.naterciomoniz.net/applications/broker2anexoj/internal" internal "github.com/nmoniz/any2anexoj/internal"
gomock "go.uber.org/mock/gomock" gomock "go.uber.org/mock/gomock"
) )

View File

@@ -7,8 +7,8 @@ import (
"testing" "testing"
"time" "time"
"git.naterciomoniz.net/applications/broker2anexoj/internal" "github.com/nmoniz/any2anexoj/internal"
"git.naterciomoniz.net/applications/broker2anexoj/internal/mocks" "github.com/nmoniz/any2anexoj/internal/mocks"
"go.uber.org/mock/gomock" "go.uber.org/mock/gomock"
) )

View File

@@ -8,6 +8,8 @@ import (
"time" "time"
) )
// ReportLogger writes a simple, human readable, line to the provided io.Writer for each
// ReportItem received.
type ReportLogger struct { type ReportLogger struct {
counter int counter int
writer io.Writer writer io.Writer

View File

@@ -7,7 +7,7 @@ import (
"testing" "testing"
"time" "time"
"git.naterciomoniz.net/applications/broker2anexoj/internal" "github.com/nmoniz/any2anexoj/internal"
) )
func TestReportLogger_Write(t *testing.T) { func TestReportLogger_Write(t *testing.T) {

View File

@@ -9,7 +9,7 @@ import (
"strings" "strings"
"time" "time"
"git.naterciomoniz.net/applications/broker2anexoj/internal" "github.com/nmoniz/any2anexoj/internal"
) )
type Record struct { type Record struct {

View File

@@ -7,7 +7,7 @@ import (
"testing" "testing"
"time" "time"
"git.naterciomoniz.net/applications/broker2anexoj/internal" "github.com/nmoniz/any2anexoj/internal"
) )
func TestRecordReader_ReadRecord(t *testing.T) { func TestRecordReader_ReadRecord(t *testing.T) {