little bit of renaming inside the crypto reader project

Author: steevehook

mutexes/log-reader/.gitignore renamed to mutexes/crypto-reader/.gitignore

@@ -53,7 +53,7 @@ func main() {
 		}
 
 		bs := generateTransactions(cfg, now)
-		filename := fmt.Sprintf("transaction-%s", now.Format(dateFileFormat))
+		filename := fmt.Sprintf("transaction-%s.txt", now.Format(dateFileFormat))
 		file, err := os.Create(path.Join(*directoryFlag, filename))
 		if err != nil {
 			log.Fatalf("could not create file: %v", err)

mutexes/log-reader/cmd/generator/main.go renamed to mutexes/crypto-reader/cmd/generator/main.go

@@ -0,0 +1,52 @@
+package main
+
+import (
+	"context"
+	"flag"
+	"log"
+	"os"
+	"os/signal"
+	"syscall"
+	"time"
+
+	"githubc.com/steevehook/crypto-reader/crypto"
+)
+
+func main() {
+	quit := make(chan os.Signal, 1)
+	addrFlag := flag.String("addr", "", "the crypto address to look for")
+	intervalFlag := flag.Duration("interval", time.Hour, "the interval of transactions to look for")
+	dirFlag := flag.String("dir", ".", "the directory of crypto transaction files")
+	nFlag := flag.Int("n", 100, "the maximum number of transactions to read")
+
+	if *addrFlag == "" {
+		log.Fatal("provide a crypto address to read transactions for")
+	}
+
+	flag.Parse()
+	signal.Notify(quit, syscall.SIGINT, syscall.SIGTERM)
+
+	ctx, cancel := context.WithCancel(context.Background())
+	cfg := crypto.TransactionsReaderConfig{
+		Address:   *addrFlag,
+		Interval:  *intervalFlag,
+		Directory: *dirFlag,
+		Limit:     *nFlag,
+	}
+	reader, err := crypto.NewTransactionsReader(cfg)
+	if err != nil {
+		log.Fatalf("could not create crypto transactions reader: %v", err)
+	}
+
+	go func() {
+		err := reader.Read(ctx, os.Stdout)
+		if err != nil {
+			log.Fatalf("could not read crypto transactions: %v", err)
+		}
+
+		quit <- os.Interrupt
+	}()
+
+	<-quit
+	cancel()
+}

mutexes/crypto-reader/cmd/reader/main.go

@@ -0,0 +1 @@
+package crypto

mutexes/crypto-reader/crypto/file.go

@@ -0,0 +1,82 @@
+package crypto
+
+import (
+	"bufio"
+	"context"
+	"io"
+	"io/ioutil"
+	"os"
+	"sort"
+	"time"
+)
+
+// TransactionsReaderConfig represents the configuration to start the crypto transactions reader
+type TransactionsReaderConfig struct {
+	Address   string
+	Interval  time.Duration
+	Directory string
+	Limit     int
+}
+
+// NewTransactionsReader creates a new instance of log reader
+func NewTransactionsReader(cfg TransactionsReaderConfig) (*TransactionsReader, error) {
+	filesInfo, err := ioutil.ReadDir(cfg.Directory)
+	if err != nil {
+		return nil, err
+	}
+
+	info := make([]os.FileInfo, 0, len(filesInfo))
+	for _, fi := range filesInfo {
+		if fi.IsDir() {
+			continue
+		}
+
+		info = append(info, fi)
+	}
+	sort.Slice(filesInfo, func(i, j int) bool {
+		return filesInfo[i].ModTime().Sub(filesInfo[j].ModTime()) < 0
+	})
+
+	reader := &TransactionsReader{
+		cfg:       cfg,
+		filesInfo: info,
+	}
+	return reader, nil
+}
+
+// TransactionsReader represents the crypto transactions reader type
+// responsible for reading crypto transactions within a given interval for a given address
+type TransactionsReader struct {
+	cfg       TransactionsReaderConfig
+	filesInfo []os.FileInfo
+}
+
+// Read reads and streams the crypto transactions to an io.Writer using the given config
+func (r *TransactionsReader) Read(ctx context.Context, w io.Writer) error {
+	select {
+	case <-ctx.Done():
+		return nil
+	default:
+		return r.read(w)
+	}
+}
+
+func (r *TransactionsReader) read(w io.Writer) error {
+	return nil
+}
+
+func (r *TransactionsReader) stream(file io.ReadCloser) chan string {
+	out := make(chan string)
+
+	go func() {
+		defer func() { _ = file.Close() }()
+		scanner := bufio.NewScanner(file)
+		for scanner.Scan() {
+			out <- scanner.Text()
+		}
+
+		close(out)
+	}()
+
+	return out
+}

mutexes/crypto-reader/crypto/reader.go

@@ -0,0 +1,3 @@
+module githubc.com/steevehook/crypto-reader
+
+go 1.17