Method cbcPKCS5Padding.decrypt has 5 return statements (exceeds 4 allowed).

Open

func (e *cbcPKCS5Padding) decrypt(key, cipherText []byte) ([]byte, error) {
    if len(cipherText) == 0 {
        return nil, crypto.ErrInvalidCipherText
    }
 
 

Method api.saveEvents has 5 return statements (exceeds 4 allowed).

Open

func (a *api) saveEvents(w http.ResponseWriter, r *http.Request) {
    if r.Header.Get("Content-Type") != "application/json" {
        http.Error(w, "invalid content type", http.StatusBadRequest)
        return
    }

Method eventStore.saveEvents has a Cognitive Complexity of 22 (exceeds 20 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")
    }
 
 

• Read up
  Read up

Method CustomerAddedBirth.Decrypt has 5 return statements (exceeds 4 allowed).

Open

func (e *CustomerAddedBirth) Decrypt(encryptor crypto.Encryptor) error {
    decryptedBirthMonth, err := encryptor.Decrypt(e.ID, e.BirthMonthEncrypted)
    if err != nil {
        if err == crypto.ErrKeyWasDeleted {
            e.redactPersonalData("")

Method remoteStore.OptimisticDeleteStream has 5 return statements (exceeds 4 allowed).

Open

func (s *remoteStore) OptimisticDeleteStream(ctx context.Context, expectedStreamSequenceNumber uint64, streamName string) error {
    request := &rangedbpb.OptimisticDeleteStreamRequest{
        ExpectedStreamSequenceNumber: expectedStreamSequenceNumber,
        StreamName:                   streamName,
    }

Method levelDbStore.saveEvent has 5 return statements (exceeds 4 allowed).

Open

func (s *levelDbStore) saveEvent(ctx context.Context, transaction *leveldb.Transaction, streamName, aggregateType, aggregateID, eventType, eventID string, expectedStreamSequenceNumber *uint64, event, metadata interface{}) ([]byte, uint64, error) {
 
    select {
    case <-ctx.Done():
        return nil, 0, context.Canceled

Method postgresStore.eventRecordsToBatchRecords has 5 return statements (exceeds 4 allowed).

Open

func (s *postgresStore) eventRecordsToBatchRecords(eventRecords []*rangedb.EventRecord, streamName string, streamSequenceNumber uint64) ([]*batchSQLRecord, error) {
    aggregateType := eventRecords[0].Event.AggregateType()
    aggregateID := eventRecords[0].Event.AggregateID()
 
    var batchEvents []*batchSQLRecord

Method postgresStore.transactionalSaveEvents has 5 return statements (exceeds 4 allowed).

Open

func (s *postgresStore) transactionalSaveEvents(ctx context.Context, expectedStreamSequenceNumber *uint64, streamName string, eventRecords ...*rangedb.EventRecord) (uint64, error) {
    transaction, err := s.db.BeginTx(ctx, nil)
    if err != nil {
        return 0, err
    }

Similar blocks of code found in 2 locations. Consider refactoring.

Open

func (a *room) Load(recordIterator rangedb.RecordIterator) {
    for recordIterator.Next() {
        if recordIterator.Err() == nil {
            if event, ok := recordIterator.Record().Data.(rangedb.Event); ok {
                a.apply(event)

• Read up
  Read up

Similar blocks of code found in 2 locations. Consider refactoring.

Open

func (a *user) Load(recordIterator rangedb.RecordIterator) {
    for recordIterator.Next() {
        if recordIterator.Err() == nil {
            if event, ok := recordIterator.Record().Data.(rangedb.Event); ok {
                a.apply(event)

• Read up
  Read up