cmd

type NATSClient interface {
	// Connection management
	Connect() error
	Close()

	// Stream operations
	CreateOrUpdateStreamWithConfig(
		ctx context.Context,
		streamConfig jetstream.StreamConfig,
	) error
	GetStreamInfo(
		ctx context.Context,
		streamName string,
	) (*jetstream.StreamInfo, error)

	// KV operations
	CreateOrUpdateKVBucket(
		ctx context.Context,
		bucketName string,
	) (jetstream.KeyValue, error)
	CreateOrUpdateKVBucketWithConfig(
		ctx context.Context,
		config jetstream.KeyValueConfig,
	) (jetstream.KeyValue, error)

	// Object Store operations
	CreateOrUpdateObjectStore(
		ctx context.Context,
		cfg jetstream.ObjectStoreConfig,
	) (jetstream.ObjectStore, error)
	ObjectStore(
		ctx context.Context,
		name string,
	) (jetstream.ObjectStore, error)

	// Message publishing
	Publish(
		ctx context.Context,
		subject string,
		data []byte,
	) error

	// Message consumption
	ConsumeMessages(
		ctx context.Context,
		streamName string,
		consumerName string,
		handler natsclient.JetStreamMessageHandler,
		opts *natsclient.ConsumeOptions,
	) error
	CreateOrUpdateConsumerWithConfig(
		ctx context.Context,
		streamName string,
		consumerConfig jetstream.ConsumerConfig,
	) error

	// KV convenience operations
	KVPut(
		bucket string,
		key string,
		value []byte,
	) error

	// Core NATS operations (non-JetStream)
	Subscribe(
		subject string,
		handler nats.MsgHandler,
	) (*nats.Subscription, error)
	PublishCore(
		subject string,
		data []byte,
	) error

	// Connection inspection
	ConnectedURL() string
	ConnectedServerVersion() string

	// JetStream handle access
	KeyValue(
		ctx context.Context,
		bucket string,
	) (jetstream.KeyValue, error)
	Stream(
		ctx context.Context,
		name string,
	) (jetstream.Stream, error)
}

type ServerManager interface {
	cli.Lifecycle
	// RegisterHandlers registers a list of handlers with the Echo instance.
	RegisterHandlers(handlers []func(e *echo.Echo))
}

type TokenGenerator interface {
	Generate(
		signingKey string,
		roles []string,
		subject string,
		permissions []string,
	) (string, error)
}

type TokenValidator interface {
	Validate(
		tokenString string,
		signingKey string,
	) (*authtoken.CustomClaims, error)
}