package jnpf.limsService.provider;

import com.fasterxml.jackson.databind.ObjectMapper;
import jnpf.database.util.TenantDataSourceUtil;
import jnpf.exception.DataException;
import jnpf.lims.api.model.ElnSourceActorRequest;
import jnpf.lims.api.model.ElnSourceSnapshot;
import org.springframework.stereotype.Service;

import java.util.List;
import java.util.stream.Collectors;

/** Only exposed through the SameToken-protected internal endpoint. */
@Service
public class LimsElnSourceActorService {
    private final LimsElnReadonlyResolver resolver;
    private final ObjectMapper json = new ObjectMapper();

    public LimsElnSourceActorService(LimsElnReadonlyResolver resolver) {
        this.resolver = resolver;
    }

    public List<ElnSourceSnapshot> resolve(ElnSourceActorRequest request) {
        if (request == null) throw new DataException("Source request is required");
        LimsElnSourceCatalog.Actor actor = LimsElnSourceCatalog.requireActor(
                new LimsElnSourceCatalog.Actor(request.getTenantId(), request.getUserId(), false));
        if (request.getProperties() == null || request.getProperties().size() > 50
                || request.getProperties().stream().anyMatch(ref -> ref == null || ref.getRevision() == null)) {
            throw new DataException("Invalid source references");
        }
        try {
            TenantDataSourceUtil.switchTenant(actor.getTenantId());
            return resolver.resolve(request.getTestWorkItemIds(), request.getProperties().stream()
                    .map(ref -> new LimsElnReadonlyResolver.PropertyRef(ref.getPropertyCode(), ref.getRevision()))
                    .collect(Collectors.toList()), actor).stream()
                    .map(value -> json.convertValue(value, ElnSourceSnapshot.class)).collect(Collectors.toList());
        } finally {
            TenantDataSourceUtil.clearLocalTenantInfo();
        }
    }
}