package im

import (
	"context"

	"gitee.com/h79/goim/session"
)

type Alarm interface {
	Alarm(ctx context.Context, code int32, level int32, title, detail string, err error)
}

type AlarmFunc func(ctx context.Context, code int32, level int32, title, detail string, err error)

func (f AlarmFunc) Alarm(ctx context.Context, code int32, level int32, title, detail string, err error) {
	f(ctx, code, level, title, detail, err)
}

const (
	MQMsg = iota + 1
	EVMsg
)

type MsgInterceptor interface {
	MsgInterceptor(ctx context.Context, from *session.Session, to *Connect, payloadType int, payload any) error
}

type MsgInterceptorFunc func(ctx context.Context, from *session.Session, to *Connect, payloadType int, payload any) error

func (f MsgInterceptorFunc) MsgInterceptor(ctx context.Context, from *session.Session, to *Connect, payloadType int, payload any) error {
	return f(ctx, from, to, payloadType, payload)
}

// RespInterceptor 回复拦截器
type RespInterceptor interface {
	RespInterceptor(req *EventReq) bool
}

type RespInterceptorFunc func(req *EventReq) bool

func (f RespInterceptorFunc) RespInterceptor(req *EventReq) bool {
	return f(req)
}

type DisposeInterceptor func(conn *Connect, req *EventReq) (interface{}, error)

type UnaryDisposeInterceptor func(conn *Connect, req *EventReq, handler DisposeInterceptor) (resp any, err error)