knownerrors.go

package common

import (
	"fmt"
	"net"
	"strings"
)

var (
	suppressErrors = []string{
		"http2",
		"wsasend",
		"tls: unknown certificate",
		"tls handshake error",
		"use of closed network connection",
		"eof",
	}
)

func IsErrExit(err error) bool {
	if err == nil {
		return false
	}

	_, ok := err.(*ErrExit)

	return ok
}

func IsErrTimeout(err error) bool {
	if err == nil {
		return false
	}

	errTimeout, ok := err.(net.Error)

	return ok && errTimeout.Timeout()
}

func IsErrOp(err error) bool {
	if err == nil {
		return false
	}

	_, ok := err.(*net.OpError)

	return ok
}

func IsErrNetClosing(err error) bool {
	if err == nil {
		return false
	}

	return strings.Index(strings.ToLower(err.Error()), "use of closed network connection") != -1
}

func IsErrUnexpectedEOF(err error) bool {
	if err == nil {
		return false
	}

	return strings.Index(strings.ToLower(err.Error()), "unexpected eof") != -1
}

func IsSuppressedError(err error) bool {
	if err == nil {
		return false
	}

	return IsSuppressedErrorMessage(err.Error())
}

func IsSuppressedErrorMessage(err string) bool {
	msg := strings.ToLower(err)
	for _, se := range suppressErrors {
		if strings.Contains(msg, se) {
			return true
		}
	}

	return false
}

func HandleCopyBufferError(written int64, err error) (int64, error) {
	if err == nil {
		return written, nil
	}

	if IsErrTimeout(err) {
		return written, fmt.Errorf("Timeout error: %s", err.Error())
	}

	if IsErrOp(err) {
		return written, fmt.Errorf("Operation error: %s", err.Error())
	}

	if IsErrNetClosing(err) || IsErrUnexpectedEOF(err) {
		return written, nil
	}

	return written, err
}