package jnpf.dmsService.expiry;

import jnpf.dmsEntity.storage.expiry.DmsFileExpiryItem;
import jnpf.dmsMapper.DmsFileExpiryMapper;
import jnpf.dmsService.search.meili.DmsMeilisearchClient;
import lombok.RequiredArgsConstructor;
import lombok.extern.slf4j.Slf4j;
import org.springframework.stereotype.Service;
import org.springframework.transaction.annotation.Propagation;
import org.springframework.transaction.annotation.Transactional;

@Slf4j
@Service
@RequiredArgsConstructor
public class DmsFileExpirySearchCleanup {
    private final DmsFileExpiryMapper mapper;
    private final DmsMeilisearchClient client;
    private final DmsFileExpiryProperties properties;

    @Transactional(propagation = Propagation.REQUIRES_NEW, rollbackFor = Exception.class)
    public void process(DmsFileExpiryItem candidate) {
        DmsFileExpiryItem item = mapper.lockCleanup(candidate.getTenantId(), candidate.getFileVersionId());
        if (item == null) return;
        boolean done = false;
        String error = null;
        try {
            if (item.getSearchTaskId() == null) {
                item.setSearchTaskId(client.deleteDocument(item.getTenantId(), item.getFileVersionId()));
                done = item.getSearchTaskId() == null; // Index does not exist.
            } else {
                String status = client.taskStatus(item.getSearchTaskId());
                done = "succeeded".equals(status);
                if ("failed".equals(status) || "canceled".equals(status) || "missing".equals(status)) {
                    item.setSearchTaskId(null); // Resubmit idempotent deletion on the next scan.
                    error = "Meilisearch task " + status;
                }
            }
        } catch (Exception failure) {
            error = failure.getClass().getSimpleName() + ": " + failure.getMessage();
            log.warn("DMS expiry index cleanup pending tenant={} version={}", item.getTenantId(), item.getFileVersionId(), failure);
        }
        mapper.updateCleanup(item, done, error == null ? null : error.substring(0, Math.min(1000, error.length())),
                Math.max(1, properties.getCleanupRetrySeconds()));
    }
}