D-Net

package eu.dnetlib.data.mdstore.model;

import java.time.Duration;

import java.time.LocalDate;

import java.time.ZoneId;

import java.util.Date;

import java.util.List;

import java.util.Map;

import java.util.stream.Collectors;

import com.google.common.collect.Lists;

import com.google.common.collect.Maps;

import org.springframework.data.mongodb.core.index.CompoundIndex;

import org.springframework.data.mongodb.core.index.CompoundIndexes;

import org.springframework.data.mongodb.core.index.Indexed;

import org.springframework.data.mongodb.core.mapping.Document;

@Document

@CompoundIndexes({

		@CompoundIndex(name = "fli_idx", def = "{'format': 1, 'layout': 1, 'interpretation': 1}")

})

public class Metadata {

	@Indexed(unique = true)

	private String mdId;

	@Indexed

	private String currentId;

	private String format;

	private String layout;

	private String interpretation;

	private long size;

	private List<ReadLock> readLocks;

	private List<Transaction> transactions;

	public Metadata() {}

	public static Metadata create() {

		return new Metadata()

				.setSize(0)

				.setReadLocks(Lists.newArrayList())

				.setTransactions(Lists.newArrayList());

	}

	public List<String> getExpired(final int retainDays) {

		return getReadLocks().stream()

				.filter(r -> !r.getId().equals(getCurrentId()))

				.filter(r -> getExpiringDays(r) >= retainDays)

				.map(r -> r.getId())

				.collect(Collectors.toList());

	}

	public Map<String, Transaction> getTransactionMap() {

		final Map<String, Transaction> txs = Maps.newHashMap();

		getTransactions().forEach(t -> txs.put(t.getId(), t));

		return txs;

	}

	/**

	 * Gets the expiring days.

	 *

	 * @param info     the value

	 * @return the expiring days

	 */

	private long getExpiringDays(final ReadLock info) {

		final Long lastRead = info.getLastUpdate();

		final LocalDate readDate = new Date(lastRead).toInstant().atZone(ZoneId.systemDefault()).toLocalDate();

		return Duration.between(LocalDate.now().atTime(0, 0), readDate.atTime(0, 0)).toDays();

	}

	public String getMdId() {

		return mdId;

	}

	public String getFormat() {

		return format;

	}

	public String getLayout() {

		return layout;

	}

	public String getInterpretation() {

		return interpretation;

	}

	public long getSize() {

		return size;

	}

	public Metadata setMdId(final String mdId) {

		this.mdId = mdId;

		return this;

	}

	public Metadata setFormat(final String format) {

		this.format = format;

		return this;

	}

	public Metadata setLayout(final String layout) {

		this.layout = layout;

		return this;

	}

	public Metadata setInterpretation(final String interpretation) {

		this.interpretation = interpretation;

		return this;

	}

	public Metadata setSize(final long size) {

		this.size = size;

		return this;

	}

	public String getCurrentId() {

		return this.currentId;

	}

	public List<ReadLock> getReadLocks() {

		return this.readLocks;

	}

	public List<Transaction> getTransactions() {

		return this.transactions;

	}

	public Metadata setCurrentId(final String currentId) {

		this.currentId = currentId;

		return this;

	}

	public Metadata setReadLocks(final List<ReadLock> readLocks) {

		this.readLocks = readLocks;

		return this;

	}

	public Metadata setTransactions(final List<Transaction> transactions) {

		this.transactions = transactions;

		return this;

	}

}