core

type ConsumerRequestContext interface {
	ContextCarrier
	EventBusCarrier

	EventName() string
	Payload() []byte
}

type Container interface {
	Resolve(t reflect.Type) (any, error)
}

type ContextCarrier interface {
	Context() context.Context
}

type ControllerContext interface {
	Get(key string) (any, bool)
}

type CustomTransport interface {
	// Init은 DI 컨테이너가 준비된 후 호출됩니다.
	Init(container Container) error
	// Start는 Init 이후 별도 고루틴에서 호출됩니다.
	Start() error
	// Stop은 정상 종료 시 호출됩니다.
	Stop(ctx context.Context) error
}

type EventBus interface {
	Publish(events ...publish.DomainEvent)
	Drain() []publish.DomainEvent
}

type EventBusCarrier interface {
	EventBus() EventBus
}

type ExecutionContext interface {
	ContextCarrier
	EventBusCarrier

	Method() string
	Path() string
	Params() map[string]string
	Header(name string) string
	PathKeys() []string
	Queries() map[string][]string
	Set(key string, value any)
	Get(key string) (any, bool)
}

type HandlerMeta struct {
	// 컨트롤러 타입(Container의 Resolve 대상)
	ControllerType reflect.Type
	// 호출할 메서드 이름
	Method reflect.Method
	// 라우트에 선언된 경로 매개변수 키의 순서
	PathKeys []string
	// 핸들러에 적용된 인터셉터
	Interceptors []Interceptor
}

type HttpRequestContext interface {
	ContextCarrier
	EventBusCarrier

	// 개별 접근
	Param(name string) string
	Query(name string) string
	Header(name string) string

	// 전체 뷰 접근
	Params() map[string]string
	Queries() map[string][]string
	Headers() map[string][]string

	// 요청 본문
	Bind(out any) error

	// 멀티파트
	MultipartForm() (*multipart.Form, error)
}

type Interceptor interface {
	/*
		PreHandle은 컨트롤러 호출 전에 실행된다.
		여기서 오류를 반환하면 실행을 중단한다.
	*/
	PreHandle(ctx ExecutionContext, meta HandlerMeta) error

	/*
		PostHandle은 ReturnValueHandler 처리 후 실행된다.
		실패해도 전체 파이프라인 실패로 만들지 않는다.
	*/
	PostHandle(ctx ExecutionContext, meta HandlerMeta)

	/*
		BeforeResponse는 핸들러 실행과 후속 훅이 끝난 뒤, 응답을 쓰기 전에 실행된다.
		PreHandle을 성공한 Interceptor만 역순으로 호출된다.
		executionErr는 이 시점까지 발생한 최종 오류이며, 구현체가 반환한 오류는
		최종 실행 오류에 포함된다.
	*/
	BeforeResponse(ctx ExecutionContext, meta HandlerMeta, executionErr error) error

	/*
		AfterCompletion은 성공/실패와 관계없이 마지막에 호출된다.
		err는 파이프라인 실행 중 발생한 최종 오류
	*/
	AfterCompletion(ctx ExecutionContext, meta HandlerMeta, err error)
}

type ResponseWriter interface {
	// 헤더 조작
	SetHeader(key, value string)
	AddHeader(key, value string)

	// 응답이 이미 커밋(헤더/바디 작성 시작)되었는지 여부
	IsCommitted() bool

	// 상태 코드만 기록(응답 본문 없음)
	WriteStatus(status int) error

	// 응답 본문과 상태 코드 기록
	WriteJSON(status int, value any) error
	WriteString(status int, value string) error
	WriteBytes(status int, value []byte) error
}

type WebSocketContext interface {
	ExecutionContext

	ConnID() string
	MessageType() int
	Payload() []byte
}

type WebSocketHandshakeContext interface {
	WebSocketRequestContext
}

type WebSocketHandshakeInterceptor interface {
	PreHandshake(ctx WebSocketHandshakeContext, meta HandlerMeta) error
}

type WebSocketMessageContext interface {
	WebSocketContext
	WebSocketRequestContext
}

type WebSocketRequestContext interface {
	ContextCarrier

	Path() string
	Header(name string) string
	Headers() map[string][]string
	Query(name string) string
	Queries() map[string][]string
	Cookie(name string) (string, bool)
	Cookies() map[string]string
	RemoteAddr() string
	Host() string
	RequestURI() string
}