File eventstore.go has 760 lines of code (exceeds 500 allowed). Consider refactoring.

Open

package eventstore
 
import (
    "bytes"
    "context"

File postgres_store.go has 671 lines of code (exceeds 500 allowed). Consider refactoring.

Open

package postgresstore
 
import (
    "context"
    "database/sql"

Method structVisitor.Visit has a Cognitive Complexity of 55 (exceeds 20 allowed). Consider refactoring.

Open

func (v *structVisitor) Visit(node ast.Node) (w ast.Visitor) {
    switch n := node.(type) {
    case *ast.TypeSpec:
        if value, ok := n.Type.(*ast.StructType); ok {
            var subjectID string

• Read up
  Read up

Method eventStore.EventsByStream has a Cognitive Complexity of 49 (exceeds 20 allowed). Consider refactoring.

Open

func (s *eventStore) EventsByStream(ctx context.Context, streamSequenceNumber uint64, streamName string) rangedb.RecordIterator {
    resultRecords := make(chan rangedb.ResultRecord)
 
    go func() {
        defer close(resultRecords)

• Read up
  Read up

Method eventStore.Events has a Cognitive Complexity of 46 (exceeds 20 allowed). Consider refactoring.

Open

func (s *eventStore) Events(ctx context.Context, globalSequenceNumber uint64) rangedb.RecordIterator {
    resultRecords := make(chan rangedb.ResultRecord)
 
    go func() {
        defer close(resultRecords)

• Read up
  Read up

Method eventStore.EventsByAggregateTypes has a Cognitive Complexity of 43 (exceeds 20 allowed). Consider refactoring.

Open

func (s *eventStore) EventsByAggregateTypes(ctx context.Context, globalSequenceNumber uint64, aggregateTypes ...string) rangedb.RecordIterator {
    resultRecords := make(chan rangedb.ResultRecord)
 
    go func() {
        defer close(resultRecords)

• Read up
  Read up

Method eventStore.EventsByStream has 100 lines of code (exceeds 50 allowed). Consider refactoring.

Open

func (s *eventStore) EventsByStream(ctx context.Context, streamSequenceNumber uint64, streamName string) rangedb.RecordIterator {
    resultRecords := make(chan rangedb.ResultRecord)
 
    go func() {
        defer close(resultRecords)

Function main has 98 lines of code (exceeds 50 allowed). Consider refactoring.

Open

func main() {
    fmt.Println("RangeDB API")
    flag.CommandLine = flag.NewFlagSet(os.Args[0], flag.ExitOnError)
 
    port := flag.Int("port", 8080, "port")

postgresStore has 24 methods (exceeds 20 allowed). Consider refactoring.

Open

type postgresStore struct {
    config            *Config
    db                *sql.DB
    clock             clock.Clock
    uuidGenerator     shortuuid.Generator

Method eventStore.Events has 85 lines of code (exceeds 50 allowed). Consider refactoring.

Open

func (s *eventStore) Events(ctx context.Context, globalSequenceNumber uint64) rangedb.RecordIterator {
    resultRecords := make(chan rangedb.ResultRecord)
 
    go func() {
        defer close(resultRecords)

eventStore has 22 methods (exceeds 20 allowed). Consider refactoring.

Open

type eventStore struct {
    client              *esdb.Client
    clock               clock.Clock
    streamPrefixer      StreamPrefixer
    uuidGenerator       shortuuid.Generator

Method eventStore.EventsByAggregateTypes has 79 lines of code (exceeds 50 allowed). Consider refactoring.

Open

func (s *eventStore) EventsByAggregateTypes(ctx context.Context, globalSequenceNumber uint64, aggregateTypes ...string) rangedb.RecordIterator {
    resultRecords := make(chan rangedb.ResultRecord)
 
    go func() {
        defer close(resultRecords)

Method eventStore.saveEvents has 77 lines of code (exceeds 50 allowed). Consider refactoring.

Open

func (s *eventStore) saveEvents(ctx context.Context, expectedStreamSequenceNumber *uint64, streamName string, eventRecords ...*rangedb.EventRecord) (uint64, error) {
    if len(eventRecords) < 1 {
        return 0, fmt.Errorf("missing events")
    }
 
 

Method postgresStore.readResultRecords has 72 lines of code (exceeds 50 allowed). Consider refactoring.

Open

func (s *postgresStore) readResultRecords(ctx context.Context, rows *sql.Rows, resultRecords chan rangedb.ResultRecord) (int, error) {
    recordsRead := 0
    for rows.Next() {
        var (
            streamName           string

Method structVisitor.Visit has 66 lines of code (exceeds 50 allowed). Consider refactoring.

Open

func (v *structVisitor) Visit(node ast.Node) (w ast.Visitor) {
    switch n := node.(type) {
    case *ast.TypeSpec:
        if value, ok := n.Type.(*ast.StructType); ok {
            var subjectID string

Method inMemoryStore.saveEvents has 59 lines of code (exceeds 50 allowed). Consider refactoring.

Open

func (s *inMemoryStore) saveEvents(ctx context.Context, expectedStreamSequenceNumber *uint64, streamName string, eventRecords ...*rangedb.EventRecord) (uint64, error) {
    if len(eventRecords) < 1 {
        return 0, fmt.Errorf("missing events")
    }
 
 

Method levelDbStore.saveEvents has 59 lines of code (exceeds 50 allowed). Consider refactoring.

Open

func (s *levelDbStore) saveEvents(ctx context.Context, expectedStreamSequenceNumber *uint64, streamName string, eventRecords ...*rangedb.EventRecord) (uint64, error) {
    if len(eventRecords) < 1 {
        return 0, fmt.Errorf("missing events")
    }
 
 

Method eventStore.startSubscription has a Cognitive Complexity of 26 (exceeds 20 allowed). Consider refactoring.

Open

func (s *eventStore) startSubscription() {
    ctx := context.Background()
    opts := esdb.SubscribeToAllOptions{
        From: esdb.Start{},
    }

• Read up
  Read up

Method eventStore.startSubscription has 55 lines of code (exceeds 50 allowed). Consider refactoring.

Open

func (s *eventStore) startSubscription() {
    ctx := context.Background()
    opts := esdb.SubscribeToAllOptions{
        From: esdb.Start{},
    }

Function main has 54 lines of code (exceeds 50 allowed). Consider refactoring.

Open

func main() {
    fmt.Println("Random Event Generator")
 
    eventType := flag.String("eventType", "ThingWasDone", "event type: ThingWasDone, ThatWasDone, AnotherWasComplete, etc.")
    maxEventsPerStream := flag.Int("maxPerStream", 10, "max events per stream")