func()

in internal/app/adapters/inbound/file/file_inbound.go [134:148]

• 11 lines of code
• 3 McCabe index (conditional complexity)

func (f *FileInboundEndpoint) processingCycle(ctx context.Context) error {

	pattern, exists := f.config.Parameters["transport.vfs.FileNamePattern"]
	if !exists {
		pattern = ".*"
	}

	files, err := f.protocolHandler.ListFiles(pattern)
	if err != nil {
		return fmt.Errorf("failed to scan directory: %w", err)
	}

	// Process the files
	return f.processFiles(ctx, files)
}