Remove active stream logic

Author: Jeff Yanta

pkg/code/server/messaging/message_handler.go

@@ -33,14 +33,6 @@ type MessageHandler interface {
 	// allowed to be sent and persisted
 	Validate(ctx context.Context, rendezvous *common.Account, message *messagingpb.Message) error
 
-	// RequiresActiveStream determines whether a message can only be sent if an
-	// active stream is available. If true, then the message must also provide
-	// the maximum time it expects the stream to be valid for, which is dependent
-	// on the use case.
-	//
-	// todo: Not implemented for multi-server
-	RequiresActiveStream() (bool, time.Duration)
-
 	// OnSuccess is called upon creating the message after validation
 	OnSuccess(ctx context.Context) error
 }
@@ -80,10 +72,6 @@ func (h *RequestToGrabBillMessageHandler) Validate(ctx context.Context, rendezvo
 	return nil
 }
 
-func (h *RequestToGrabBillMessageHandler) RequiresActiveStream() (bool, time.Duration) {
-	return true, time.Minute
-}
-
 func (h *RequestToGrabBillMessageHandler) OnSuccess(ctx context.Context) error {
 	return nil
 }
@@ -399,10 +387,6 @@ func (h *RequestToReceiveBillMessageHandler) Validate(ctx context.Context, rende
 	return nil
 }
 
-func (h *RequestToReceiveBillMessageHandler) RequiresActiveStream() (bool, time.Duration) {
-	return false, 0 * time.Minute
-}
-
 func (h *RequestToReceiveBillMessageHandler) OnSuccess(ctx context.Context) error {
 	if h.recordAlreadyExists {
 		return nil
@@ -458,10 +442,6 @@ func (h *ClientRejectedPaymentMessageHandler) Validate(ctx context.Context, rend
 	return nil
 }
 
-func (h *ClientRejectedPaymentMessageHandler) RequiresActiveStream() (bool, time.Duration) {
-	return false, 0 * time.Minute
-}
-
 func (h *ClientRejectedPaymentMessageHandler) OnSuccess(ctx context.Context) error {
 	return nil
 }
@@ -482,10 +462,6 @@ func (h *CodeScannedMessageHandler) Validate(ctx context.Context, rendezvous *co
 	return nil
 }
 
-func (h *CodeScannedMessageHandler) RequiresActiveStream() (bool, time.Duration) {
-	return false, 0 * time.Minute
-}
-
 func (h *CodeScannedMessageHandler) OnSuccess(ctx context.Context) error {
 	return nil
 }

pkg/code/server/messaging/testutil.go

@@ -505,11 +505,6 @@ func (c *sendMessageCallMetadata) assertPermissionDeniedError(t *testing.T, mess
 	assert.True(t, strings.Contains(strings.ToLower(status.Message()), strings.ToLower(message)))
 }
 
-func (c *sendMessageCallMetadata) assertNoActiveStreamError(t *testing.T) {
-	require.NoError(t, c.err)
-	require.Equal(t, messagingpb.SendMessageResponse_NO_ACTIVE_STREAM, c.resp.Result)
-}
-
 func (c *clientEnv) sendRequestToGrabBillMessage(t *testing.T, rendezvousKey *common.Account) *sendMessageCallMetadata {
 	destination := testutil.NewRandomAccount(t)