Merge pull request #244 from bitcoin-sv/send-rejected-callback

remove rejected transaction from store and send callback about that s…

metamorph/processor.go

@@ -451,8 +451,11 @@ func (p *Processor) SendStatusForTransaction(hash *chainhash.Hash, status metamo
 
 			case metamorph_api.Status_REJECTED:
 				p.logger.Warn("transaction rejected", slog.String("status", status.String()), slog.String("hash", hash.String()))
-
 				p.rejected.AddDuration(source, time.Since(processorResponse.Start))
+				data, _ := p.store.Get(spanCtx, hash[:])
+				if data.CallbackUrl != "" {
+					go SendCallback(p.logger, p.store, data)
+				}
 			}
 		},
 	}

metamorph/processor_test.go

@@ -458,6 +458,9 @@ func TestSendStatusForTransaction(t *testing.T) {
 			wg := &sync.WaitGroup{}
 			wg.Add(tc.expectedUpdateStatusCalls)
 			metamorphStore := &MetamorphStoreMock{
+				GetFunc: func(ctx context.Context, key []byte) (*store.StoreData, error) {
+					return &store.StoreData{Hash: testdata.TX2Hash}, nil
+				},
 				UpdateStatusFunc: func(ctx context.Context, hash *chainhash.Hash, status metamorph_api.Status, rejectReason string) error {
 					require.Equal(t, tc.txResponseHash, hash)
 					wg.Done()