package message

import (
	"context"

	"git.asio.asia/nixevol/NixMsg/internal/app/port"
	"git.asio.asia/nixevol/NixMsg/internal/protocol"
)

// Stub 是测试用假实现：方法返回 ErrNotImplemented 或固定空结果。
type Stub struct{}

func NewStub() *Stub { return &Stub{} }

func (s *Stub) Submit(context.Context, string, port.ConnInfo, *protocol.Send) (SubmitResult, error) {
	return SubmitResult{}, ErrNotImplemented
}

func (s *Stub) Ack(context.Context, string, *protocol.Ack) (AckResult, error) {
	return AckResult{}, ErrNotImplemented
}

func (s *Stub) Recall(context.Context, string, *protocol.Recall) (protocol.RecallData, error) {
	return protocol.RecallData{}, ErrNotImplemented
}

func (s *Stub) Status(context.Context, string, *protocol.Status) (any, error) {
	return nil, ErrNotImplemented
}

func (s *Stub) ReceiptAck(context.Context, string, *protocol.ReceiptAck) error {
	return ErrNotImplemented
}

func (s *Stub) DispatchDue(context.Context, int64, int) (int, error) {
	return 0, nil
}

func (s *Stub) PushPending(context.Context, string, port.ConnID) error {
	return nil
}

func (s *Stub) OnPublishDropped(context.Context, string, port.ConnID, []byte) error {
	return nil
}

func (s *Stub) CleanupOnce(context.Context, int64) error { return nil }

func (s *Stub) RecoverOnStart(context.Context) error { return nil }

func (s *Stub) WakePush(string) {}

var _ Service = (*Stub)(nil)