D-Net

package eu.dnetlib.enabling.is.hib.objects;

import java.util.Map;

import javax.persistence.Column;

import javax.persistence.Entity;

import javax.persistence.EnumType;

import javax.persistence.Enumerated;

import javax.persistence.Id;

import javax.persistence.JoinColumn;

import javax.persistence.ManyToOne;

import javax.persistence.Table;

import org.hibernate.Session;

import com.google.gson.Gson;

import com.google.gson.reflect.TypeToken;

import eu.dnetlib.enabling.is.rmi.objects.Operation;

import eu.dnetlib.enabling.is.rmi.objects.Subcription;

@Entity(name = "subscriptions")

@Table(name = "subscriptions")

public class HibSubscription extends HibDnetObject {

	@Id

	@Column(name = "id")

	private String id;

	@Enumerated(EnumType.STRING)

	@Column(name = "operation", nullable = false)

	private Operation operation;

	@Column(name = "tbl", nullable = false)

	private String table;

	@Column(name = "condition")

	private String condition;

	@ManyToOne

	@JoinColumn(name = "subscriber", nullable = false)

	private HibService subscriber;

	public HibSubscription() {}

	public HibSubscription(final String id, final Operation operation, final String table, final String condition,

			final HibService subscriber) {

		this.id = id;

		this.operation = operation;

		this.table = table;

		this.condition = condition;

		this.subscriber = subscriber;

	}

	public String getId() {

		return id;

	}

	public void setId(final String id) {

		this.id = id;

	}

	public Operation getOperation() {

		return operation;

	}

	public void setOperation(final Operation operation) {

		this.operation = operation;

	}

	public String getTable() {

		return table;

	}

	public void setTable(final String table) {

		this.table = table;

	}

	public String getCondition() {

		return condition;

	}

	public void setCondition(final String condition) {

		this.condition = condition;

	}

	public HibService getSubscriber() {

		return subscriber;

	}

	public void setSubscriber(final HibService subscriber) {

		this.subscriber = subscriber;

	}

	public Subcription asDnetSubscription() {

		final Gson gson = new Gson();

		final Map<String, Object> map = gson.fromJson(condition, new TypeToken<Map<String, Object>>() {}.getType());

		return new Subcription(id, subscriber.getId(), operation, table, map);

	}

	@Override

	public void delete(final Session session) {

		subscriber.getSubscriptions().remove(this);

		subscriber.save(session);

		super.delete(session);

	}

	@Override

	public int hashCode() {

		return id.hashCode();

	}

}