in internal/app/adapters/inbound/inbound_factory.go [34:45]
func NewInbound(config domain.InboundConfig) (ports.InboundEndpoint, error) {
switch config.Protocol {
case "file":
return file.NewFileInboundEndpoint(
config,
nil,
), nil
default:
return nil, ErrInboundTypeNotFound
}
}