Merge branch 'feat/arc-broadcast' into fix/feemodel

Author: shruggr

transaction/broadcaster/arc.go

@@ -17,15 +17,19 @@ import (
 type ArcStatus string
 
 const (
-	REJECTED             ArcStatus = "REJECTED"
-	QUEUED               ArcStatus = "QUEUED"
-	RECEIVED             ArcStatus = "RECEIVED"
-	STORED               ArcStatus = "STORED"
-	ANNOUNCED_TO_NETWORK ArcStatus = "ANNOUNCED_TO_NETWORK"
-	REQUESTED_BY_NETWORK ArcStatus = "REQUESTED_BY_NETWORK"
-	SENT_TO_NETWORK      ArcStatus = "SENT_TO_NETWORK"
-	ACCEPTED_BY_NETWORK  ArcStatus = "ACCEPTED_BY_NETWORK"
-	SEEN_ON_NETWORK      ArcStatus = "SEEN_ON_NETWORK"
+	REJECTED               ArcStatus = "REJECTED"
+	QUEUED                 ArcStatus = "QUEUED"
+	RECEIVED               ArcStatus = "RECEIVED"
+	STORED                 ArcStatus = "STORED"
+	ANNOUNCED_TO_NETWORK   ArcStatus = "ANNOUNCED_TO_NETWORK"
+	REQUESTED_BY_NETWORK   ArcStatus = "REQUESTED_BY_NETWORK"
+	SENT_TO_NETWORK        ArcStatus = "SENT_TO_NETWORK"
+	ACCEPTED_BY_NETWORK    ArcStatus = "ACCEPTED_BY_NETWORK"
+	SEEN_ON_NETWORK        ArcStatus = "SEEN_ON_NETWORK"
+	MINED                  ArcStatus = "MINED"
+	CONFIRMED              ArcStatus = "CONFIRMED"
+	DOUBLE_SPEND_ATTEMPTED ArcStatus = "DOUBLE_SPEND_ATTEMPTED"
+	SEEN_IN_ORPHAN_MEMPOOL ArcStatus = "SEEN_IN_ORPHAN_MEMPOOL"
 )
 
 type Arc struct {
@@ -64,7 +68,7 @@ func (a *Arc) Broadcast(t *transaction.Transaction) (*transaction.BroadcastSucce
 	return a.BroadcastCtx(context.Background(), t)
 }
 
-func (a *Arc) BroadcastCtx(ctx context.Context, t *transaction.Transaction) (*transaction.BroadcastSuccess, *transaction.BroadcastFailure) {
+func (a *Arc) ArcBroadcast(ctx context.Context, t *transaction.Transaction) (*ArcResponse, error) {
 	var buf *bytes.Buffer
 	for _, input := range t.Inputs {
 		if input.SourceTxOutput() == nil {
@@ -74,10 +78,7 @@ func (a *Arc) BroadcastCtx(ctx context.Context, t *transaction.Transaction) (*tr
 	}
 	if buf == nil {
 		if ef, err := t.EF(); err != nil {
-			return nil, &transaction.BroadcastFailure{
-				Code:        "500",
-				Description: err.Error(),
-			}
+			return nil, err
 		} else {
 			buf = bytes.NewBuffer(ef)
 		}
@@ -90,10 +91,7 @@ func (a *Arc) BroadcastCtx(ctx context.Context, t *transaction.Transaction) (*tr
 		buf,
 	)
 	if err != nil {
-		return nil, &transaction.BroadcastFailure{
-			Code:        "500",
-			Description: err.Error(),
-		}
+		return nil, err
 	}
 
 	req.Header.Set("Content-Type", "application/octet-stream")
@@ -140,25 +138,28 @@ func (a *Arc) BroadcastCtx(ctx context.Context, t *transaction.Transaction) (*tr
 	}
 	resp, err := a.Client.Do(req)
 	if err != nil {
-		return nil, &transaction.BroadcastFailure{
-			Code:        "500",
-			Description: err.Error(),
-		}
+		return nil, err
 	}
 	defer resp.Body.Close()
 	msg, err := io.ReadAll(resp.Body)
 	if err != nil {
-		return nil, &transaction.BroadcastFailure{
-			Code:        "500",
-			Description: err.Error(),
-		}
+		return nil, err
 	}
 
 	response := &ArcResponse{}
 	if a.Verbose {
 		log.Println("msg", string(msg))
 	}
 	err = json.Unmarshal(msg, &response)
+	if err != nil {
+		return nil, err
+	}
+
+	return response, nil
+}
+
+func (a *Arc) BroadcastCtx(ctx context.Context, t *transaction.Transaction) (*transaction.BroadcastSuccess, *transaction.BroadcastFailure) {
+	response, err := a.ArcBroadcast(ctx, t)
 	if err != nil {
 		return nil, &transaction.BroadcastFailure{
 			Code:        "500",