Add OnSuccess to SubmitIntentIntegration

Author: Jeff Yanta

pkg/code/server/transaction/intent.go

@@ -41,6 +41,10 @@ type SubmitIntentIntegration interface {
 	// AllowCreation determines whether the new intent creation should be allowed
 	// with app-specific validation rules
 	AllowCreation(ctx context.Context, intentRecord *intent.Record, metadata *transactionpb.Metadata, actions []*transactionpb.Action) error
+
+	// OnSuccess is a best-effort callback when an intent has been successfully
+	// submitted
+	OnSuccess(ctx context.Context, intentRecord *intent.Record) error
 }
 
 type defaultSubmitIntentIntegration struct {
@@ -55,6 +59,10 @@ func (i *defaultSubmitIntentIntegration) AllowCreation(ctx context.Context, inte
 	return nil
 }
 
+func (i *defaultSubmitIntentIntegration) OnSuccess(ctx context.Context, intentRecord *intent.Record) error {
+	return nil
+}
+
 func (s *transactionServer) SubmitIntent(streamer transactionpb.Transaction_SubmitIntentServer) error {
 	// Bound the total RPC. Keeping the timeout higher to see where we land because
 	// there's a lot of stuff happening in this method.
@@ -663,6 +671,13 @@ func (s *transactionServer) SubmitIntent(streamer transactionpb.Transaction_Subm
 		return handleSubmitIntentError(streamer, err)
 	}
 
+	go func() {
+		err := s.submitIntentIntegration.OnSuccess(context.Background(), intentRecord)
+		if err != nil {
+			log.WithError(err).Warn("failure calling integration success callback")
+		}
+	}()
+
 	//
 	// Intent is submitted, and anything beyond this point is best-effort.
 	// We must send success back to the client. Rolling back the intent is