package notify

import (
	"errors"
	"fmt"
	"io"
	"testing"
)

func TestIsTransportDetachedErrorRecognizesWrappedDetach(t *testing.T) {
	base := transportDetachedError("dedicated bulk read error", io.ErrUnexpectedEOF)
	for name, err := range map[string]error{
		"direct":         base,
		"wrapped":        fmt.Errorf("bulk reset: %w", base),
		"transport-send": newTransportSendError(TransportSendStageTransport, base),
	} {
		t.Run(name, func(t *testing.T) {
			if !IsTransportDetachedError(err) {
				t.Fatalf("IsTransportDetachedError(%v) = false", err)
			}
		})
	}
}

func TestIsTransportDetachedErrorRejectsOtherErrors(t *testing.T) {
	for name, err := range map[string]error{
		"nil":      nil,
		"business": errors.New("remote file became a directory"),
		"eof":      io.EOF,
	} {
		t.Run(name, func(t *testing.T) {
			if IsTransportDetachedError(err) {
				t.Fatalf("IsTransportDetachedError(%v) = true", err)
			}
		})
	}
}