cashierdesk / dili-cashier · Files

package com.diligrp.cashier.assistant.pipeline;

import com.diligrp.cashier.assistant.exception.AssistantServiceException;
import com.diligrp.cashier.shared.ErrorCode;

import java.util.List;
import java.util.Optional;

public interface SmsPipelineManager {

    void registerPipeline(SmsPipeline pipeline);

    List<SmsPipeline> pipelines();

    default SmsPipeline findPipelineByCode(int code) {
        Optional<SmsPipeline> pipeline = pipelines().stream().filter(p -> p.code == code).findAny();
        return pipeline.orElseThrow(() -> new AssistantServiceException(ErrorCode.OPERATION_NOT_ALLOWED, "系统未配置此短信服务通道"));
    }
}