Compare commits
2 Commits
a804d76905
...
7fd3c3e9f7
| Author | SHA1 | Date |
|---|---|---|
|
|
7fd3c3e9f7 | |
|
|
e0799828d0 |
|
|
@ -0,0 +1,47 @@
|
||||||
|
package com.mediamanager.mapper;
|
||||||
|
|
||||||
|
import com.mediamanager.model.TrackHasArtist;
|
||||||
|
import com.mediamanager.protocol.messages.TrackHasArtistMessages;
|
||||||
|
|
||||||
|
public class TrackHasArtistMapper {
|
||||||
|
public static TrackHasArtistMessages.TrackHasArtist toProtobuf(TrackHasArtist entity) {
|
||||||
|
if (entity == null) {
|
||||||
|
return null;
|
||||||
|
}
|
||||||
|
|
||||||
|
TrackHasArtistMessages.TrackHasArtist.Builder builder = TrackHasArtistMessages.TrackHasArtist.newBuilder();
|
||||||
|
|
||||||
|
Integer id = entity.getId();
|
||||||
|
if (id != null) {
|
||||||
|
builder.setId(id);
|
||||||
|
}
|
||||||
|
|
||||||
|
// Map Track foreign key
|
||||||
|
if (entity.getTrack() != null && entity.getTrack().getId() != null) {
|
||||||
|
builder.setFkTrackId(entity.getTrack().getId());
|
||||||
|
}
|
||||||
|
|
||||||
|
// Map Artist foreign key
|
||||||
|
if (entity.getArtist() != null && entity.getArtist().getId() != null) {
|
||||||
|
builder.setFkArtistId(entity.getArtist().getId());
|
||||||
|
}
|
||||||
|
|
||||||
|
return builder.build();
|
||||||
|
}
|
||||||
|
|
||||||
|
public static TrackHasArtist toEntity(TrackHasArtistMessages.TrackHasArtist protobuf) {
|
||||||
|
if (protobuf == null) {
|
||||||
|
return null;
|
||||||
|
}
|
||||||
|
|
||||||
|
TrackHasArtist entity = new TrackHasArtist();
|
||||||
|
|
||||||
|
if (protobuf.getId() > 0) {
|
||||||
|
entity.setId(protobuf.getId());
|
||||||
|
}
|
||||||
|
|
||||||
|
// Note: Foreign key relationships (Track, Artist) are handled in the service layer
|
||||||
|
|
||||||
|
return entity;
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
@ -0,0 +1,47 @@
|
||||||
|
package com.mediamanager.mapper;
|
||||||
|
|
||||||
|
import com.mediamanager.model.TrackHasGenre;
|
||||||
|
import com.mediamanager.protocol.messages.TrackHasGenreMessages;
|
||||||
|
|
||||||
|
public class TrackHasGenreMapper {
|
||||||
|
public static TrackHasGenreMessages.TrackHasGenre toProtobuf(TrackHasGenre entity) {
|
||||||
|
if (entity == null) {
|
||||||
|
return null;
|
||||||
|
}
|
||||||
|
|
||||||
|
TrackHasGenreMessages.TrackHasGenre.Builder builder = TrackHasGenreMessages.TrackHasGenre.newBuilder();
|
||||||
|
|
||||||
|
Integer id = entity.getId();
|
||||||
|
if (id != null) {
|
||||||
|
builder.setId(id);
|
||||||
|
}
|
||||||
|
|
||||||
|
// Map Track foreign key
|
||||||
|
if (entity.getTrack() != null && entity.getTrack().getId() != null) {
|
||||||
|
builder.setFkTrackId(entity.getTrack().getId());
|
||||||
|
}
|
||||||
|
|
||||||
|
// Map Genre foreign key
|
||||||
|
if (entity.getGenre() != null && entity.getGenre().getId() != null) {
|
||||||
|
builder.setFkGenreId(entity.getGenre().getId());
|
||||||
|
}
|
||||||
|
|
||||||
|
return builder.build();
|
||||||
|
}
|
||||||
|
|
||||||
|
public static TrackHasGenre toEntity(TrackHasGenreMessages.TrackHasGenre protobuf) {
|
||||||
|
if (protobuf == null) {
|
||||||
|
return null;
|
||||||
|
}
|
||||||
|
|
||||||
|
TrackHasGenre entity = new TrackHasGenre();
|
||||||
|
|
||||||
|
if (protobuf.getId() > 0) {
|
||||||
|
entity.setId(protobuf.getId());
|
||||||
|
}
|
||||||
|
|
||||||
|
// Note: Foreign key relationships (Track, Genre) are handled in the service layer
|
||||||
|
|
||||||
|
return entity;
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
@ -0,0 +1,55 @@
|
||||||
|
package com.mediamanager.model;
|
||||||
|
|
||||||
|
import jakarta.persistence.*;
|
||||||
|
|
||||||
|
@Entity
|
||||||
|
@Table(name = "trackhasartist")
|
||||||
|
public class TrackHasArtist {
|
||||||
|
|
||||||
|
@Id
|
||||||
|
@GeneratedValue(strategy = GenerationType.IDENTITY)
|
||||||
|
private Integer id;
|
||||||
|
|
||||||
|
@ManyToOne(fetch = FetchType.LAZY)
|
||||||
|
@JoinColumn(name = "fk_track_id", nullable = false)
|
||||||
|
private Track track;
|
||||||
|
|
||||||
|
@ManyToOne(fetch = FetchType.LAZY)
|
||||||
|
@JoinColumn(name = "fk_artist_id", nullable = false)
|
||||||
|
private Artist artist;
|
||||||
|
|
||||||
|
public TrackHasArtist() {}
|
||||||
|
|
||||||
|
public Integer getId() {
|
||||||
|
return id;
|
||||||
|
}
|
||||||
|
|
||||||
|
public void setId(Integer id) {
|
||||||
|
this.id = id;
|
||||||
|
}
|
||||||
|
|
||||||
|
public Track getTrack() {
|
||||||
|
return track;
|
||||||
|
}
|
||||||
|
|
||||||
|
public void setTrack(Track track) {
|
||||||
|
this.track = track;
|
||||||
|
}
|
||||||
|
|
||||||
|
public Artist getArtist() {
|
||||||
|
return artist;
|
||||||
|
}
|
||||||
|
|
||||||
|
public void setArtist(Artist artist) {
|
||||||
|
this.artist = artist;
|
||||||
|
}
|
||||||
|
|
||||||
|
@Override
|
||||||
|
public String toString() {
|
||||||
|
return "TrackHasArtist{" +
|
||||||
|
"id=" + id +
|
||||||
|
", trackId=" + (track != null ? track.getId() : null) +
|
||||||
|
", artistId=" + (artist != null ? artist.getId() : null) +
|
||||||
|
'}';
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
@ -0,0 +1,55 @@
|
||||||
|
package com.mediamanager.model;
|
||||||
|
|
||||||
|
import jakarta.persistence.*;
|
||||||
|
|
||||||
|
@Entity
|
||||||
|
@Table(name = "trackhasgenre")
|
||||||
|
public class TrackHasGenre {
|
||||||
|
|
||||||
|
@Id
|
||||||
|
@GeneratedValue(strategy = GenerationType.IDENTITY)
|
||||||
|
private Integer id;
|
||||||
|
|
||||||
|
@ManyToOne(fetch = FetchType.LAZY)
|
||||||
|
@JoinColumn(name = "fk_track_id", nullable = false)
|
||||||
|
private Track track;
|
||||||
|
|
||||||
|
@ManyToOne(fetch = FetchType.LAZY)
|
||||||
|
@JoinColumn(name = "fk_genre_id", nullable = false)
|
||||||
|
private Genre genre;
|
||||||
|
|
||||||
|
public TrackHasGenre() {}
|
||||||
|
|
||||||
|
public Integer getId() {
|
||||||
|
return id;
|
||||||
|
}
|
||||||
|
|
||||||
|
public void setId(Integer id) {
|
||||||
|
this.id = id;
|
||||||
|
}
|
||||||
|
|
||||||
|
public Track getTrack() {
|
||||||
|
return track;
|
||||||
|
}
|
||||||
|
|
||||||
|
public void setTrack(Track track) {
|
||||||
|
this.track = track;
|
||||||
|
}
|
||||||
|
|
||||||
|
public Genre getGenre() {
|
||||||
|
return genre;
|
||||||
|
}
|
||||||
|
|
||||||
|
public void setGenre(Genre genre) {
|
||||||
|
this.genre = genre;
|
||||||
|
}
|
||||||
|
|
||||||
|
@Override
|
||||||
|
public String toString() {
|
||||||
|
return "TrackHasGenre{" +
|
||||||
|
"id=" + id +
|
||||||
|
", trackId=" + (track != null ? track.getId() : null) +
|
||||||
|
", genreId=" + (genre != null ? genre.getId() : null) +
|
||||||
|
'}';
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
@ -0,0 +1,85 @@
|
||||||
|
package com.mediamanager.repository;
|
||||||
|
|
||||||
|
|
||||||
|
import com.mediamanager.model.TrackHasArtist;
|
||||||
|
import jakarta.persistence.EntityManager;
|
||||||
|
import jakarta.persistence.EntityManagerFactory;
|
||||||
|
import org.apache.logging.log4j.LogManager;
|
||||||
|
import org.apache.logging.log4j.Logger;
|
||||||
|
|
||||||
|
|
||||||
|
import java.util.List;
|
||||||
|
import java.util.Optional;
|
||||||
|
|
||||||
|
public class TrackHasArtistRepository {
|
||||||
|
private static final Logger logger = LogManager.getLogger(TrackHasArtistRepository.class);
|
||||||
|
|
||||||
|
private final EntityManagerFactory entityManagerFactory;
|
||||||
|
|
||||||
|
public TrackHasArtistRepository(EntityManagerFactory entityManagerFactory) {
|
||||||
|
this.entityManagerFactory = entityManagerFactory;
|
||||||
|
}
|
||||||
|
|
||||||
|
public TrackHasArtist save(TrackHasArtist trackHasArtist) {
|
||||||
|
logger.debug("Saving TrackHasArtist: {}", trackHasArtist);
|
||||||
|
EntityManager em = entityManagerFactory.createEntityManager();
|
||||||
|
em.getTransaction().begin();
|
||||||
|
try {
|
||||||
|
em.persist(trackHasArtist);
|
||||||
|
em.getTransaction().commit();
|
||||||
|
logger.debug("TrackHasArtist has been saved successfully");
|
||||||
|
return trackHasArtist;
|
||||||
|
} catch (Exception e) {
|
||||||
|
em.getTransaction().rollback();
|
||||||
|
logger.error("Error while saving TrackHasArtist: {}", e.getMessage());
|
||||||
|
throw e;
|
||||||
|
} finally {
|
||||||
|
if (em.isOpen()) em.close();
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
public List<TrackHasArtist> findAll() {
|
||||||
|
logger.debug("Finding All TrackHasArtist");
|
||||||
|
EntityManager em = entityManagerFactory.createEntityManager();
|
||||||
|
try{
|
||||||
|
return em.createQuery("select t from TrackHasArtist t", TrackHasArtist.class).getResultList();
|
||||||
|
}finally {
|
||||||
|
if (em.isOpen()) em.close();
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
public Optional<TrackHasArtist> findById(Integer id) {
|
||||||
|
logger.debug("Finding TrackHasArtist with id: {}", id);
|
||||||
|
EntityManager em = entityManagerFactory.createEntityManager();
|
||||||
|
try{
|
||||||
|
TrackHasArtist trackHasArtist = em.find(TrackHasArtist.class, id);
|
||||||
|
return Optional.ofNullable(trackHasArtist);
|
||||||
|
}finally {
|
||||||
|
if (em.isOpen()) em.close();
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
public boolean deleteById(Integer id){
|
||||||
|
logger.debug("Deleting TrackHasArtist with id: {}", id);
|
||||||
|
EntityManager em = entityManagerFactory.createEntityManager();
|
||||||
|
em.getTransaction().begin();
|
||||||
|
try{
|
||||||
|
TrackHasArtist trackHasArtist = em.find(TrackHasArtist.class, id);
|
||||||
|
if (trackHasArtist == null) {
|
||||||
|
em.getTransaction().rollback();
|
||||||
|
return false;
|
||||||
|
}
|
||||||
|
em.remove(trackHasArtist);
|
||||||
|
em.getTransaction().commit();
|
||||||
|
logger.debug("TrackHasArtist has been deleted successfully");
|
||||||
|
return true;
|
||||||
|
} catch (Exception e) {
|
||||||
|
em.getTransaction().rollback();
|
||||||
|
logger.error("Error while deleting TrackHasArtist: {}", e.getMessage());
|
||||||
|
throw e;
|
||||||
|
} finally {
|
||||||
|
if (em.isOpen()) em.close();
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
}
|
||||||
|
|
@ -0,0 +1,85 @@
|
||||||
|
package com.mediamanager.repository;
|
||||||
|
|
||||||
|
|
||||||
|
import com.mediamanager.model.TrackHasGenre;
|
||||||
|
import jakarta.persistence.EntityManager;
|
||||||
|
import jakarta.persistence.EntityManagerFactory;
|
||||||
|
import org.apache.logging.log4j.LogManager;
|
||||||
|
import org.apache.logging.log4j.Logger;
|
||||||
|
|
||||||
|
|
||||||
|
import java.util.List;
|
||||||
|
import java.util.Optional;
|
||||||
|
|
||||||
|
public class TrackHasGenreRepository {
|
||||||
|
private static final Logger logger = LogManager.getLogger(TrackHasGenreRepository.class);
|
||||||
|
|
||||||
|
private final EntityManagerFactory entityManagerFactory;
|
||||||
|
|
||||||
|
public TrackHasGenreRepository(EntityManagerFactory entityManagerFactory) {
|
||||||
|
this.entityManagerFactory = entityManagerFactory;
|
||||||
|
}
|
||||||
|
|
||||||
|
public TrackHasGenre save(TrackHasGenre trackHasGenre) {
|
||||||
|
logger.debug("Saving TrackHasGenre: {}", trackHasGenre);
|
||||||
|
EntityManager em = entityManagerFactory.createEntityManager();
|
||||||
|
em.getTransaction().begin();
|
||||||
|
try {
|
||||||
|
em.persist(trackHasGenre);
|
||||||
|
em.getTransaction().commit();
|
||||||
|
logger.debug("TrackHasGenre has been saved successfully");
|
||||||
|
return trackHasGenre;
|
||||||
|
} catch (Exception e) {
|
||||||
|
em.getTransaction().rollback();
|
||||||
|
logger.error("Error while saving TrackHasGenre: {}", e.getMessage());
|
||||||
|
throw e;
|
||||||
|
} finally {
|
||||||
|
if (em.isOpen()) em.close();
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
public List<TrackHasGenre> findAll() {
|
||||||
|
logger.debug("Finding All TrackHasGenre");
|
||||||
|
EntityManager em = entityManagerFactory.createEntityManager();
|
||||||
|
try{
|
||||||
|
return em.createQuery("select t from TrackHasGenre t", TrackHasGenre.class).getResultList();
|
||||||
|
}finally {
|
||||||
|
if (em.isOpen()) em.close();
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
public Optional<TrackHasGenre> findById(Integer id) {
|
||||||
|
logger.debug("Finding TrackHasGenre with id: {}", id);
|
||||||
|
EntityManager em = entityManagerFactory.createEntityManager();
|
||||||
|
try{
|
||||||
|
TrackHasGenre trackHasGenre = em.find(TrackHasGenre.class, id);
|
||||||
|
return Optional.ofNullable(trackHasGenre);
|
||||||
|
}finally {
|
||||||
|
if (em.isOpen()) em.close();
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
public boolean deleteById(Integer id){
|
||||||
|
logger.debug("Deleting TrackHasGenre with id: {}", id);
|
||||||
|
EntityManager em = entityManagerFactory.createEntityManager();
|
||||||
|
em.getTransaction().begin();
|
||||||
|
try{
|
||||||
|
TrackHasGenre trackHasGenre = em.find(TrackHasGenre.class, id);
|
||||||
|
if (trackHasGenre == null) {
|
||||||
|
em.getTransaction().rollback();
|
||||||
|
return false;
|
||||||
|
}
|
||||||
|
em.remove(trackHasGenre);
|
||||||
|
em.getTransaction().commit();
|
||||||
|
logger.debug("TrackHasGenre has been deleted successfully");
|
||||||
|
return true;
|
||||||
|
} catch (Exception e) {
|
||||||
|
em.getTransaction().rollback();
|
||||||
|
logger.error("Error while deleting TrackHasGenre: {}", e.getMessage());
|
||||||
|
throw e;
|
||||||
|
} finally {
|
||||||
|
if (em.isOpen()) em.close();
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
}
|
||||||
|
|
@ -12,6 +12,8 @@ import com.mediamanager.service.albumtype.AlbumTypeService;
|
||||||
import com.mediamanager.service.bitdepth.BitDepthService;
|
import com.mediamanager.service.bitdepth.BitDepthService;
|
||||||
import com.mediamanager.service.bitrate.BitRateService;
|
import com.mediamanager.service.bitrate.BitRateService;
|
||||||
import com.mediamanager.service.composer.ComposerService;
|
import com.mediamanager.service.composer.ComposerService;
|
||||||
|
import com.mediamanager.service.trackhasgenre.TrackHasGenreService;
|
||||||
|
import com.mediamanager.service.trackhasartist.TrackHasArtistService;
|
||||||
|
|
||||||
import com.mediamanager.repository.GenreRepository;
|
import com.mediamanager.repository.GenreRepository;
|
||||||
import com.mediamanager.service.artist.ArtistService;
|
import com.mediamanager.service.artist.ArtistService;
|
||||||
|
|
@ -112,6 +114,14 @@ public class DelegateActionManager {
|
||||||
TrackService trackService = new TrackService(trackRepository, discRepository, composerRepository, bitDepthRepository, bitRateRepository, samplingRateRepository);
|
TrackService trackService = new TrackService(trackRepository, discRepository, composerRepository, bitDepthRepository, bitRateRepository, samplingRateRepository);
|
||||||
serviceLocator.register(TrackService.class, trackService);
|
serviceLocator.register(TrackService.class, trackService);
|
||||||
|
|
||||||
|
TrackHasGenreRepository trackHasGenreRepository = new TrackHasGenreRepository(entityManagerFactory);
|
||||||
|
TrackHasGenreService trackHasGenreService = new TrackHasGenreService(trackHasGenreRepository, trackRepository, genreRepository);
|
||||||
|
serviceLocator.register(TrackHasGenreService.class, trackHasGenreService);
|
||||||
|
|
||||||
|
TrackHasArtistRepository trackHasArtistRepository = new TrackHasArtistRepository(entityManagerFactory);
|
||||||
|
TrackHasArtistService trackHasArtistService = new TrackHasArtistService(trackHasArtistRepository, trackRepository, artistRepository);
|
||||||
|
serviceLocator.register(TrackHasArtistService.class, trackHasArtistService);
|
||||||
|
|
||||||
serviceLocator.logRegisteredServices();
|
serviceLocator.logRegisteredServices();
|
||||||
|
|
||||||
logger.info("Services initialized successfully");
|
logger.info("Services initialized successfully");
|
||||||
|
|
|
||||||
|
|
@ -0,0 +1,54 @@
|
||||||
|
package com.mediamanager.service.delegate.handler.trackhasartist;
|
||||||
|
|
||||||
|
import com.google.protobuf.ByteString;
|
||||||
|
import com.google.protobuf.InvalidProtocolBufferException;
|
||||||
|
import com.mediamanager.mapper.TrackHasArtistMapper;
|
||||||
|
import com.mediamanager.model.TrackHasArtist;
|
||||||
|
import com.mediamanager.protocol.TransportProtocol;
|
||||||
|
import com.mediamanager.protocol.messages.TrackHasArtistMessages;
|
||||||
|
import com.mediamanager.service.delegate.ActionHandler;
|
||||||
|
import com.mediamanager.service.delegate.annotation.Action;
|
||||||
|
import com.mediamanager.service.trackhasartist.TrackHasArtistService;
|
||||||
|
import org.apache.logging.log4j.LogManager;
|
||||||
|
import org.apache.logging.log4j.Logger;
|
||||||
|
|
||||||
|
@Action("trackhasartist.create")
|
||||||
|
public class CreateTrackHasArtistHandler implements ActionHandler {
|
||||||
|
private static final Logger logger = LogManager.getLogger(CreateTrackHasArtistHandler.class);
|
||||||
|
private final TrackHasArtistService trackHasArtistService;
|
||||||
|
|
||||||
|
public CreateTrackHasArtistHandler(TrackHasArtistService trackHasArtistService) {
|
||||||
|
this.trackHasArtistService = trackHasArtistService;
|
||||||
|
}
|
||||||
|
|
||||||
|
@Override
|
||||||
|
public TransportProtocol.Response.Builder handle(ByteString requestPayload) throws InvalidProtocolBufferException {
|
||||||
|
try{
|
||||||
|
TrackHasArtistMessages.CreateTrackHasArtistRequest createRequest =
|
||||||
|
TrackHasArtistMessages.CreateTrackHasArtistRequest.parseFrom(requestPayload);
|
||||||
|
|
||||||
|
TrackHasArtist trackHasArtist = trackHasArtistService.createTrackHasArtist(
|
||||||
|
createRequest.getFkTrackId() > 0 ? createRequest.getFkTrackId() : null,
|
||||||
|
createRequest.getFkArtistId() > 0 ? createRequest.getFkArtistId() : null
|
||||||
|
);
|
||||||
|
|
||||||
|
TrackHasArtistMessages.TrackHasArtist trackHasArtistProto = TrackHasArtistMapper.toProtobuf(trackHasArtist);
|
||||||
|
TrackHasArtistMessages.CreateTrackHasArtistResponse createTrackHasArtistResponse = TrackHasArtistMessages.CreateTrackHasArtistResponse.newBuilder()
|
||||||
|
.setTrackhasartist(trackHasArtistProto)
|
||||||
|
.build();
|
||||||
|
return TransportProtocol.Response.newBuilder()
|
||||||
|
.setPayload(createTrackHasArtistResponse.toByteString());
|
||||||
|
} catch (IllegalArgumentException e) {
|
||||||
|
logger.error("Validation error", e);
|
||||||
|
return TransportProtocol.Response.newBuilder()
|
||||||
|
.setStatusCode(400)
|
||||||
|
.setPayload(ByteString.copyFromUtf8("Validation error: " + e.getMessage()));
|
||||||
|
|
||||||
|
} catch (Exception e) {
|
||||||
|
logger.error("Error creating track has artist", e);
|
||||||
|
return TransportProtocol.Response.newBuilder()
|
||||||
|
.setStatusCode(500)
|
||||||
|
.setPayload(ByteString.copyFromUtf8("Error: " + e.getMessage()));
|
||||||
|
}
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
@ -0,0 +1,62 @@
|
||||||
|
package com.mediamanager.service.delegate.handler.trackhasartist;
|
||||||
|
|
||||||
|
import com.google.protobuf.ByteString;
|
||||||
|
import com.google.protobuf.InvalidProtocolBufferException;
|
||||||
|
import com.mediamanager.protocol.TransportProtocol;
|
||||||
|
import com.mediamanager.protocol.messages.TrackHasArtistMessages;
|
||||||
|
import com.mediamanager.service.delegate.ActionHandler;
|
||||||
|
import com.mediamanager.service.delegate.annotation.Action;
|
||||||
|
import com.mediamanager.service.trackhasartist.TrackHasArtistService;
|
||||||
|
import org.apache.logging.log4j.LogManager;
|
||||||
|
import org.apache.logging.log4j.Logger;
|
||||||
|
|
||||||
|
@Action("trackhasartist.delete")
|
||||||
|
public class DeleteTrackHasArtistHandler implements ActionHandler {
|
||||||
|
private static final Logger logger = LogManager.getLogger(DeleteTrackHasArtistHandler.class);
|
||||||
|
|
||||||
|
private final TrackHasArtistService trackHasArtistService;
|
||||||
|
|
||||||
|
public DeleteTrackHasArtistHandler(TrackHasArtistService trackHasArtistService) {
|
||||||
|
this.trackHasArtistService = trackHasArtistService;
|
||||||
|
}
|
||||||
|
|
||||||
|
@Override
|
||||||
|
public TransportProtocol.Response.Builder handle(ByteString requestPayload)
|
||||||
|
throws InvalidProtocolBufferException {
|
||||||
|
|
||||||
|
try {
|
||||||
|
TrackHasArtistMessages.DeleteTrackHasArtistRequest deleteRequest =
|
||||||
|
TrackHasArtistMessages.DeleteTrackHasArtistRequest.parseFrom(requestPayload);
|
||||||
|
int id = deleteRequest.getId();
|
||||||
|
boolean success = trackHasArtistService.deleteTrackHasArtist(id);
|
||||||
|
TrackHasArtistMessages.DeleteTrackHasArtistResponse deleteResponse;
|
||||||
|
if (success) {
|
||||||
|
deleteResponse = TrackHasArtistMessages.DeleteTrackHasArtistResponse.newBuilder()
|
||||||
|
.setSuccess(true)
|
||||||
|
.setMessage("Track has artist deleted successfully")
|
||||||
|
.build();
|
||||||
|
return TransportProtocol.Response.newBuilder()
|
||||||
|
.setPayload(deleteResponse.toByteString());
|
||||||
|
} else {
|
||||||
|
deleteResponse = TrackHasArtistMessages.DeleteTrackHasArtistResponse.newBuilder()
|
||||||
|
.setSuccess(false)
|
||||||
|
.setMessage("Track has artist not found")
|
||||||
|
.build();
|
||||||
|
|
||||||
|
return TransportProtocol.Response.newBuilder()
|
||||||
|
.setStatusCode(404)
|
||||||
|
.setPayload(deleteResponse.toByteString());
|
||||||
|
}
|
||||||
|
} catch (Exception e) {
|
||||||
|
logger.error("Error deleting track has artist", e);
|
||||||
|
TrackHasArtistMessages.DeleteTrackHasArtistResponse deleteResponse =
|
||||||
|
TrackHasArtistMessages.DeleteTrackHasArtistResponse.newBuilder()
|
||||||
|
.setSuccess(false)
|
||||||
|
.setMessage("Error: " + e.getMessage())
|
||||||
|
.build();
|
||||||
|
return TransportProtocol.Response.newBuilder()
|
||||||
|
.setStatusCode(500)
|
||||||
|
.setPayload(deleteResponse.toByteString());
|
||||||
|
}
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
@ -0,0 +1,56 @@
|
||||||
|
package com.mediamanager.service.delegate.handler.trackhasartist;
|
||||||
|
|
||||||
|
import com.google.protobuf.ByteString;
|
||||||
|
import com.google.protobuf.InvalidProtocolBufferException;
|
||||||
|
import com.mediamanager.mapper.TrackHasArtistMapper;
|
||||||
|
import com.mediamanager.model.TrackHasArtist;
|
||||||
|
import com.mediamanager.protocol.TransportProtocol;
|
||||||
|
import com.mediamanager.protocol.messages.TrackHasArtistMessages;
|
||||||
|
import com.mediamanager.service.delegate.ActionHandler;
|
||||||
|
import com.mediamanager.service.delegate.annotation.Action;
|
||||||
|
import com.mediamanager.service.trackhasartist.TrackHasArtistService;
|
||||||
|
import org.apache.logging.log4j.LogManager;
|
||||||
|
import org.apache.logging.log4j.Logger;
|
||||||
|
|
||||||
|
import java.util.Optional;
|
||||||
|
|
||||||
|
@Action(value = "trackhasartist.getById")
|
||||||
|
public class GetTrackHasArtistByIdHandler implements ActionHandler {
|
||||||
|
private static final Logger logger = LogManager.getLogger(GetTrackHasArtistByIdHandler.class);
|
||||||
|
private final TrackHasArtistService trackHasArtistService;
|
||||||
|
|
||||||
|
public GetTrackHasArtistByIdHandler(TrackHasArtistService trackHasArtistService) {
|
||||||
|
this.trackHasArtistService = trackHasArtistService;
|
||||||
|
}
|
||||||
|
|
||||||
|
@Override
|
||||||
|
public TransportProtocol.Response.Builder handle(ByteString requestPayload)
|
||||||
|
throws InvalidProtocolBufferException{
|
||||||
|
|
||||||
|
try{
|
||||||
|
TrackHasArtistMessages.GetTrackHasArtistByIdRequest getByIdRequest =
|
||||||
|
TrackHasArtistMessages.GetTrackHasArtistByIdRequest.parseFrom(requestPayload);
|
||||||
|
int id = getByIdRequest.getId();
|
||||||
|
|
||||||
|
Optional<TrackHasArtist> trackHasArtistOpt = trackHasArtistService.getTrackHasArtistById(id);
|
||||||
|
|
||||||
|
if (trackHasArtistOpt.isEmpty()){
|
||||||
|
logger.warn("TrackHasArtist not found with ID: {}", id);
|
||||||
|
return TransportProtocol.Response.newBuilder()
|
||||||
|
.setStatusCode(404)
|
||||||
|
.setPayload(ByteString.copyFromUtf8("TrackHasArtist not found"));
|
||||||
|
}
|
||||||
|
TrackHasArtistMessages.TrackHasArtist trackHasArtistProto = TrackHasArtistMapper.toProtobuf(trackHasArtistOpt.get());
|
||||||
|
TrackHasArtistMessages.GetTrackHasArtistByIdResponse getByIdResponse = TrackHasArtistMessages.GetTrackHasArtistByIdResponse.newBuilder()
|
||||||
|
.setTrackhasartist(trackHasArtistProto)
|
||||||
|
.build();
|
||||||
|
return TransportProtocol.Response.newBuilder()
|
||||||
|
.setPayload(getByIdResponse.toByteString());
|
||||||
|
} catch (Exception e) {
|
||||||
|
logger.error("Error getting track has artist by ID", e);
|
||||||
|
return TransportProtocol.Response.newBuilder()
|
||||||
|
.setStatusCode(500)
|
||||||
|
.setPayload(ByteString.copyFromUtf8("Error: "+ e.getMessage()));
|
||||||
|
}
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
@ -0,0 +1,48 @@
|
||||||
|
package com.mediamanager.service.delegate.handler.trackhasartist;
|
||||||
|
|
||||||
|
import com.google.protobuf.ByteString;
|
||||||
|
import com.google.protobuf.InvalidProtocolBufferException;
|
||||||
|
import com.mediamanager.mapper.TrackHasArtistMapper;
|
||||||
|
import com.mediamanager.model.TrackHasArtist;
|
||||||
|
import com.mediamanager.protocol.TransportProtocol;
|
||||||
|
import com.mediamanager.protocol.messages.TrackHasArtistMessages;
|
||||||
|
import com.mediamanager.service.delegate.ActionHandler;
|
||||||
|
import com.mediamanager.service.delegate.annotation.Action;
|
||||||
|
import com.mediamanager.service.trackhasartist.TrackHasArtistService;
|
||||||
|
import org.apache.logging.log4j.LogManager;
|
||||||
|
import org.apache.logging.log4j.Logger;
|
||||||
|
|
||||||
|
import java.util.List;
|
||||||
|
|
||||||
|
|
||||||
|
@Action("trackhasartist.getAll")
|
||||||
|
public class GetTrackHasArtistHandler implements ActionHandler {
|
||||||
|
private static final Logger logger = LogManager.getLogger(GetTrackHasArtistHandler.class);
|
||||||
|
|
||||||
|
private final TrackHasArtistService trackHasArtistService;
|
||||||
|
|
||||||
|
public GetTrackHasArtistHandler(TrackHasArtistService trackHasArtistService){this.trackHasArtistService = trackHasArtistService;}
|
||||||
|
|
||||||
|
@Override
|
||||||
|
public TransportProtocol.Response.Builder handle(ByteString requestPayload) throws InvalidProtocolBufferException {
|
||||||
|
try{
|
||||||
|
List<TrackHasArtist> trackHasArtists = trackHasArtistService.getAllTrackHasArtists();
|
||||||
|
TrackHasArtistMessages.GetTrackHasArtistsResponse.Builder responseBuilder = TrackHasArtistMessages.GetTrackHasArtistsResponse.newBuilder();
|
||||||
|
|
||||||
|
for (TrackHasArtist trackHasArtist : trackHasArtists) {
|
||||||
|
TrackHasArtistMessages.TrackHasArtist trackHasArtistProto = TrackHasArtistMapper.toProtobuf(trackHasArtist);
|
||||||
|
responseBuilder.addTrackhasartist(trackHasArtistProto);
|
||||||
|
}
|
||||||
|
TrackHasArtistMessages.GetTrackHasArtistsResponse getTrackHasArtistsResponse = responseBuilder.build();
|
||||||
|
|
||||||
|
return TransportProtocol.Response.newBuilder()
|
||||||
|
.setPayload(getTrackHasArtistsResponse.toByteString());
|
||||||
|
|
||||||
|
}catch (Exception e){
|
||||||
|
logger.error("Error getting track has artists", e);
|
||||||
|
return TransportProtocol.Response.newBuilder()
|
||||||
|
.setStatusCode(500)
|
||||||
|
.setPayload(ByteString.copyFromUtf8("Error: " + e.getMessage()));
|
||||||
|
}
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
@ -0,0 +1,54 @@
|
||||||
|
package com.mediamanager.service.delegate.handler.trackhasgenre;
|
||||||
|
|
||||||
|
import com.google.protobuf.ByteString;
|
||||||
|
import com.google.protobuf.InvalidProtocolBufferException;
|
||||||
|
import com.mediamanager.mapper.TrackHasGenreMapper;
|
||||||
|
import com.mediamanager.model.TrackHasGenre;
|
||||||
|
import com.mediamanager.protocol.TransportProtocol;
|
||||||
|
import com.mediamanager.protocol.messages.TrackHasGenreMessages;
|
||||||
|
import com.mediamanager.service.delegate.ActionHandler;
|
||||||
|
import com.mediamanager.service.delegate.annotation.Action;
|
||||||
|
import com.mediamanager.service.trackhasgenre.TrackHasGenreService;
|
||||||
|
import org.apache.logging.log4j.LogManager;
|
||||||
|
import org.apache.logging.log4j.Logger;
|
||||||
|
|
||||||
|
@Action("trackhasgenre.create")
|
||||||
|
public class CreateTrackHasGenreHandler implements ActionHandler {
|
||||||
|
private static final Logger logger = LogManager.getLogger(CreateTrackHasGenreHandler.class);
|
||||||
|
private final TrackHasGenreService trackHasGenreService;
|
||||||
|
|
||||||
|
public CreateTrackHasGenreHandler(TrackHasGenreService trackHasGenreService) {
|
||||||
|
this.trackHasGenreService = trackHasGenreService;
|
||||||
|
}
|
||||||
|
|
||||||
|
@Override
|
||||||
|
public TransportProtocol.Response.Builder handle(ByteString requestPayload) throws InvalidProtocolBufferException {
|
||||||
|
try{
|
||||||
|
TrackHasGenreMessages.CreateTrackHasGenreRequest createRequest =
|
||||||
|
TrackHasGenreMessages.CreateTrackHasGenreRequest.parseFrom(requestPayload);
|
||||||
|
|
||||||
|
TrackHasGenre trackHasGenre = trackHasGenreService.createTrackHasGenre(
|
||||||
|
createRequest.getFkTrackId() > 0 ? createRequest.getFkTrackId() : null,
|
||||||
|
createRequest.getFkGenreId() > 0 ? createRequest.getFkGenreId() : null
|
||||||
|
);
|
||||||
|
|
||||||
|
TrackHasGenreMessages.TrackHasGenre trackHasGenreProto = TrackHasGenreMapper.toProtobuf(trackHasGenre);
|
||||||
|
TrackHasGenreMessages.CreateTrackHasGenreResponse createTrackHasGenreResponse = TrackHasGenreMessages.CreateTrackHasGenreResponse.newBuilder()
|
||||||
|
.setTrackhasgenre(trackHasGenreProto)
|
||||||
|
.build();
|
||||||
|
return TransportProtocol.Response.newBuilder()
|
||||||
|
.setPayload(createTrackHasGenreResponse.toByteString());
|
||||||
|
} catch (IllegalArgumentException e) {
|
||||||
|
logger.error("Validation error", e);
|
||||||
|
return TransportProtocol.Response.newBuilder()
|
||||||
|
.setStatusCode(400)
|
||||||
|
.setPayload(ByteString.copyFromUtf8("Validation error: " + e.getMessage()));
|
||||||
|
|
||||||
|
} catch (Exception e) {
|
||||||
|
logger.error("Error creating track has genre", e);
|
||||||
|
return TransportProtocol.Response.newBuilder()
|
||||||
|
.setStatusCode(500)
|
||||||
|
.setPayload(ByteString.copyFromUtf8("Error: " + e.getMessage()));
|
||||||
|
}
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
@ -0,0 +1,62 @@
|
||||||
|
package com.mediamanager.service.delegate.handler.trackhasgenre;
|
||||||
|
|
||||||
|
import com.google.protobuf.ByteString;
|
||||||
|
import com.google.protobuf.InvalidProtocolBufferException;
|
||||||
|
import com.mediamanager.protocol.TransportProtocol;
|
||||||
|
import com.mediamanager.protocol.messages.TrackHasGenreMessages;
|
||||||
|
import com.mediamanager.service.delegate.ActionHandler;
|
||||||
|
import com.mediamanager.service.delegate.annotation.Action;
|
||||||
|
import com.mediamanager.service.trackhasgenre.TrackHasGenreService;
|
||||||
|
import org.apache.logging.log4j.LogManager;
|
||||||
|
import org.apache.logging.log4j.Logger;
|
||||||
|
|
||||||
|
@Action("trackhasgenre.delete")
|
||||||
|
public class DeleteTrackHasGenreHandler implements ActionHandler {
|
||||||
|
private static final Logger logger = LogManager.getLogger(DeleteTrackHasGenreHandler.class);
|
||||||
|
|
||||||
|
private final TrackHasGenreService trackHasGenreService;
|
||||||
|
|
||||||
|
public DeleteTrackHasGenreHandler(TrackHasGenreService trackHasGenreService) {
|
||||||
|
this.trackHasGenreService = trackHasGenreService;
|
||||||
|
}
|
||||||
|
|
||||||
|
@Override
|
||||||
|
public TransportProtocol.Response.Builder handle(ByteString requestPayload)
|
||||||
|
throws InvalidProtocolBufferException {
|
||||||
|
|
||||||
|
try {
|
||||||
|
TrackHasGenreMessages.DeleteTrackHasGenreRequest deleteRequest =
|
||||||
|
TrackHasGenreMessages.DeleteTrackHasGenreRequest.parseFrom(requestPayload);
|
||||||
|
int id = deleteRequest.getId();
|
||||||
|
boolean success = trackHasGenreService.deleteTrackHasGenre(id);
|
||||||
|
TrackHasGenreMessages.DeleteTrackHasGenreResponse deleteResponse;
|
||||||
|
if (success) {
|
||||||
|
deleteResponse = TrackHasGenreMessages.DeleteTrackHasGenreResponse.newBuilder()
|
||||||
|
.setSuccess(true)
|
||||||
|
.setMessage("Track has genre deleted successfully")
|
||||||
|
.build();
|
||||||
|
return TransportProtocol.Response.newBuilder()
|
||||||
|
.setPayload(deleteResponse.toByteString());
|
||||||
|
} else {
|
||||||
|
deleteResponse = TrackHasGenreMessages.DeleteTrackHasGenreResponse.newBuilder()
|
||||||
|
.setSuccess(false)
|
||||||
|
.setMessage("Track has genre not found")
|
||||||
|
.build();
|
||||||
|
|
||||||
|
return TransportProtocol.Response.newBuilder()
|
||||||
|
.setStatusCode(404)
|
||||||
|
.setPayload(deleteResponse.toByteString());
|
||||||
|
}
|
||||||
|
} catch (Exception e) {
|
||||||
|
logger.error("Error deleting track has genre", e);
|
||||||
|
TrackHasGenreMessages.DeleteTrackHasGenreResponse deleteResponse =
|
||||||
|
TrackHasGenreMessages.DeleteTrackHasGenreResponse.newBuilder()
|
||||||
|
.setSuccess(false)
|
||||||
|
.setMessage("Error: " + e.getMessage())
|
||||||
|
.build();
|
||||||
|
return TransportProtocol.Response.newBuilder()
|
||||||
|
.setStatusCode(500)
|
||||||
|
.setPayload(deleteResponse.toByteString());
|
||||||
|
}
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
@ -0,0 +1,56 @@
|
||||||
|
package com.mediamanager.service.delegate.handler.trackhasgenre;
|
||||||
|
|
||||||
|
import com.google.protobuf.ByteString;
|
||||||
|
import com.google.protobuf.InvalidProtocolBufferException;
|
||||||
|
import com.mediamanager.mapper.TrackHasGenreMapper;
|
||||||
|
import com.mediamanager.model.TrackHasGenre;
|
||||||
|
import com.mediamanager.protocol.TransportProtocol;
|
||||||
|
import com.mediamanager.protocol.messages.TrackHasGenreMessages;
|
||||||
|
import com.mediamanager.service.delegate.ActionHandler;
|
||||||
|
import com.mediamanager.service.delegate.annotation.Action;
|
||||||
|
import com.mediamanager.service.trackhasgenre.TrackHasGenreService;
|
||||||
|
import org.apache.logging.log4j.LogManager;
|
||||||
|
import org.apache.logging.log4j.Logger;
|
||||||
|
|
||||||
|
import java.util.Optional;
|
||||||
|
|
||||||
|
@Action(value = "trackhasgenre.getById")
|
||||||
|
public class GetTrackHasGenreByIdHandler implements ActionHandler {
|
||||||
|
private static final Logger logger = LogManager.getLogger(GetTrackHasGenreByIdHandler.class);
|
||||||
|
private final TrackHasGenreService trackHasGenreService;
|
||||||
|
|
||||||
|
public GetTrackHasGenreByIdHandler(TrackHasGenreService trackHasGenreService) {
|
||||||
|
this.trackHasGenreService = trackHasGenreService;
|
||||||
|
}
|
||||||
|
|
||||||
|
@Override
|
||||||
|
public TransportProtocol.Response.Builder handle(ByteString requestPayload)
|
||||||
|
throws InvalidProtocolBufferException{
|
||||||
|
|
||||||
|
try{
|
||||||
|
TrackHasGenreMessages.GetTrackHasGenreByIdRequest getByIdRequest =
|
||||||
|
TrackHasGenreMessages.GetTrackHasGenreByIdRequest.parseFrom(requestPayload);
|
||||||
|
int id = getByIdRequest.getId();
|
||||||
|
|
||||||
|
Optional<TrackHasGenre> trackHasGenreOpt = trackHasGenreService.getTrackHasGenreById(id);
|
||||||
|
|
||||||
|
if (trackHasGenreOpt.isEmpty()){
|
||||||
|
logger.warn("TrackHasGenre not found with ID: {}", id);
|
||||||
|
return TransportProtocol.Response.newBuilder()
|
||||||
|
.setStatusCode(404)
|
||||||
|
.setPayload(ByteString.copyFromUtf8("TrackHasGenre not found"));
|
||||||
|
}
|
||||||
|
TrackHasGenreMessages.TrackHasGenre trackHasGenreProto = TrackHasGenreMapper.toProtobuf(trackHasGenreOpt.get());
|
||||||
|
TrackHasGenreMessages.GetTrackHasGenreByIdResponse getByIdResponse = TrackHasGenreMessages.GetTrackHasGenreByIdResponse.newBuilder()
|
||||||
|
.setTrackhasgenre(trackHasGenreProto)
|
||||||
|
.build();
|
||||||
|
return TransportProtocol.Response.newBuilder()
|
||||||
|
.setPayload(getByIdResponse.toByteString());
|
||||||
|
} catch (Exception e) {
|
||||||
|
logger.error("Error getting track has genre by ID", e);
|
||||||
|
return TransportProtocol.Response.newBuilder()
|
||||||
|
.setStatusCode(500)
|
||||||
|
.setPayload(ByteString.copyFromUtf8("Error: "+ e.getMessage()));
|
||||||
|
}
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
@ -0,0 +1,48 @@
|
||||||
|
package com.mediamanager.service.delegate.handler.trackhasgenre;
|
||||||
|
|
||||||
|
import com.google.protobuf.ByteString;
|
||||||
|
import com.google.protobuf.InvalidProtocolBufferException;
|
||||||
|
import com.mediamanager.mapper.TrackHasGenreMapper;
|
||||||
|
import com.mediamanager.model.TrackHasGenre;
|
||||||
|
import com.mediamanager.protocol.TransportProtocol;
|
||||||
|
import com.mediamanager.protocol.messages.TrackHasGenreMessages;
|
||||||
|
import com.mediamanager.service.delegate.ActionHandler;
|
||||||
|
import com.mediamanager.service.delegate.annotation.Action;
|
||||||
|
import com.mediamanager.service.trackhasgenre.TrackHasGenreService;
|
||||||
|
import org.apache.logging.log4j.LogManager;
|
||||||
|
import org.apache.logging.log4j.Logger;
|
||||||
|
|
||||||
|
import java.util.List;
|
||||||
|
|
||||||
|
|
||||||
|
@Action("trackhasgenre.getAll")
|
||||||
|
public class GetTrackHasGenreHandler implements ActionHandler {
|
||||||
|
private static final Logger logger = LogManager.getLogger(GetTrackHasGenreHandler.class);
|
||||||
|
|
||||||
|
private final TrackHasGenreService trackHasGenreService;
|
||||||
|
|
||||||
|
public GetTrackHasGenreHandler(TrackHasGenreService trackHasGenreService){this.trackHasGenreService = trackHasGenreService;}
|
||||||
|
|
||||||
|
@Override
|
||||||
|
public TransportProtocol.Response.Builder handle(ByteString requestPayload) throws InvalidProtocolBufferException {
|
||||||
|
try{
|
||||||
|
List<TrackHasGenre> trackHasGenres = trackHasGenreService.getAllTrackHasGenres();
|
||||||
|
TrackHasGenreMessages.GetTrackHasGenresResponse.Builder responseBuilder = TrackHasGenreMessages.GetTrackHasGenresResponse.newBuilder();
|
||||||
|
|
||||||
|
for (TrackHasGenre trackHasGenre : trackHasGenres) {
|
||||||
|
TrackHasGenreMessages.TrackHasGenre trackHasGenreProto = TrackHasGenreMapper.toProtobuf(trackHasGenre);
|
||||||
|
responseBuilder.addTrackhasgenre(trackHasGenreProto);
|
||||||
|
}
|
||||||
|
TrackHasGenreMessages.GetTrackHasGenresResponse getTrackHasGenresResponse = responseBuilder.build();
|
||||||
|
|
||||||
|
return TransportProtocol.Response.newBuilder()
|
||||||
|
.setPayload(getTrackHasGenresResponse.toByteString());
|
||||||
|
|
||||||
|
}catch (Exception e){
|
||||||
|
logger.error("Error getting track has genres", e);
|
||||||
|
return TransportProtocol.Response.newBuilder()
|
||||||
|
.setStatusCode(500)
|
||||||
|
.setPayload(ByteString.copyFromUtf8("Error: " + e.getMessage()));
|
||||||
|
}
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
@ -0,0 +1,77 @@
|
||||||
|
package com.mediamanager.service.trackhasartist;
|
||||||
|
|
||||||
|
import com.mediamanager.model.Track;
|
||||||
|
import com.mediamanager.model.TrackHasArtist;
|
||||||
|
import com.mediamanager.model.Artist;
|
||||||
|
import com.mediamanager.repository.TrackHasArtistRepository;
|
||||||
|
import com.mediamanager.repository.TrackRepository;
|
||||||
|
import com.mediamanager.repository.ArtistRepository;
|
||||||
|
import org.apache.logging.log4j.LogManager;
|
||||||
|
import org.apache.logging.log4j.Logger;
|
||||||
|
|
||||||
|
import java.util.List;
|
||||||
|
import java.util.Optional;
|
||||||
|
|
||||||
|
public class TrackHasArtistService {
|
||||||
|
private static final Logger logger = LogManager.getLogger(TrackHasArtistService.class);
|
||||||
|
private final TrackHasArtistRepository repository;
|
||||||
|
private final TrackRepository trackRepository;
|
||||||
|
private final ArtistRepository artistRepository;
|
||||||
|
|
||||||
|
public TrackHasArtistService(TrackHasArtistRepository repository, TrackRepository trackRepository, ArtistRepository artistRepository) {
|
||||||
|
this.repository = repository;
|
||||||
|
this.trackRepository = trackRepository;
|
||||||
|
this.artistRepository = artistRepository;
|
||||||
|
}
|
||||||
|
|
||||||
|
public TrackHasArtist createTrackHasArtist(Integer trackId, Integer artistId) {
|
||||||
|
logger.debug("Creating track has artist relationship - trackId:{}, artistId:{}", trackId, artistId);
|
||||||
|
|
||||||
|
if (trackId == null || trackId <= 0) {
|
||||||
|
throw new IllegalArgumentException("Track ID cannot be null or invalid");
|
||||||
|
}
|
||||||
|
if (artistId == null || artistId <= 0) {
|
||||||
|
throw new IllegalArgumentException("Artist ID cannot be null or invalid");
|
||||||
|
}
|
||||||
|
|
||||||
|
// Verify Track exists
|
||||||
|
Optional<Track> track = trackRepository.findById(trackId);
|
||||||
|
if (track.isEmpty()) {
|
||||||
|
throw new IllegalArgumentException("Track not found with id: " + trackId);
|
||||||
|
}
|
||||||
|
|
||||||
|
// Verify Artist exists
|
||||||
|
Optional<Artist> artist = artistRepository.findById(artistId);
|
||||||
|
if (artist.isEmpty()) {
|
||||||
|
throw new IllegalArgumentException("Artist not found with id: " + artistId);
|
||||||
|
}
|
||||||
|
|
||||||
|
TrackHasArtist trackHasArtist = new TrackHasArtist();
|
||||||
|
trackHasArtist.setTrack(track.get());
|
||||||
|
trackHasArtist.setArtist(artist.get());
|
||||||
|
|
||||||
|
return repository.save(trackHasArtist);
|
||||||
|
}
|
||||||
|
|
||||||
|
public List<TrackHasArtist> getAllTrackHasArtists() {
|
||||||
|
logger.info("Getting all track has artist relationships");
|
||||||
|
return repository.findAll();
|
||||||
|
}
|
||||||
|
|
||||||
|
public Optional<TrackHasArtist> getTrackHasArtistById(Integer id) {
|
||||||
|
if (id == null) {
|
||||||
|
throw new IllegalArgumentException("ID cannot be null");
|
||||||
|
}
|
||||||
|
logger.info("Getting track has artist by id:{}", id);
|
||||||
|
return repository.findById(id);
|
||||||
|
}
|
||||||
|
|
||||||
|
public boolean deleteTrackHasArtist(Integer id) {
|
||||||
|
if (id == null) {
|
||||||
|
throw new IllegalArgumentException("Track has artist id cannot be null");
|
||||||
|
}
|
||||||
|
logger.info("Deleting track has artist:{}", id);
|
||||||
|
return repository.deleteById(id);
|
||||||
|
}
|
||||||
|
|
||||||
|
}
|
||||||
|
|
@ -0,0 +1,77 @@
|
||||||
|
package com.mediamanager.service.trackhasgenre;
|
||||||
|
|
||||||
|
import com.mediamanager.model.Track;
|
||||||
|
import com.mediamanager.model.TrackHasGenre;
|
||||||
|
import com.mediamanager.model.Genre;
|
||||||
|
import com.mediamanager.repository.TrackHasGenreRepository;
|
||||||
|
import com.mediamanager.repository.TrackRepository;
|
||||||
|
import com.mediamanager.repository.GenreRepository;
|
||||||
|
import org.apache.logging.log4j.LogManager;
|
||||||
|
import org.apache.logging.log4j.Logger;
|
||||||
|
|
||||||
|
import java.util.List;
|
||||||
|
import java.util.Optional;
|
||||||
|
|
||||||
|
public class TrackHasGenreService {
|
||||||
|
private static final Logger logger = LogManager.getLogger(TrackHasGenreService.class);
|
||||||
|
private final TrackHasGenreRepository repository;
|
||||||
|
private final TrackRepository trackRepository;
|
||||||
|
private final GenreRepository genreRepository;
|
||||||
|
|
||||||
|
public TrackHasGenreService(TrackHasGenreRepository repository, TrackRepository trackRepository, GenreRepository genreRepository) {
|
||||||
|
this.repository = repository;
|
||||||
|
this.trackRepository = trackRepository;
|
||||||
|
this.genreRepository = genreRepository;
|
||||||
|
}
|
||||||
|
|
||||||
|
public TrackHasGenre createTrackHasGenre(Integer trackId, Integer genreId) {
|
||||||
|
logger.debug("Creating track has genre relationship - trackId:{}, genreId:{}", trackId, genreId);
|
||||||
|
|
||||||
|
if (trackId == null || trackId <= 0) {
|
||||||
|
throw new IllegalArgumentException("Track ID cannot be null or invalid");
|
||||||
|
}
|
||||||
|
if (genreId == null || genreId <= 0) {
|
||||||
|
throw new IllegalArgumentException("Genre ID cannot be null or invalid");
|
||||||
|
}
|
||||||
|
|
||||||
|
// Verify Track exists
|
||||||
|
Optional<Track> track = trackRepository.findById(trackId);
|
||||||
|
if (track.isEmpty()) {
|
||||||
|
throw new IllegalArgumentException("Track not found with id: " + trackId);
|
||||||
|
}
|
||||||
|
|
||||||
|
// Verify Genre exists
|
||||||
|
Optional<Genre> genre = genreRepository.findById(genreId);
|
||||||
|
if (genre.isEmpty()) {
|
||||||
|
throw new IllegalArgumentException("Genre not found with id: " + genreId);
|
||||||
|
}
|
||||||
|
|
||||||
|
TrackHasGenre trackHasGenre = new TrackHasGenre();
|
||||||
|
trackHasGenre.setTrack(track.get());
|
||||||
|
trackHasGenre.setGenre(genre.get());
|
||||||
|
|
||||||
|
return repository.save(trackHasGenre);
|
||||||
|
}
|
||||||
|
|
||||||
|
public List<TrackHasGenre> getAllTrackHasGenres() {
|
||||||
|
logger.info("Getting all track has genre relationships");
|
||||||
|
return repository.findAll();
|
||||||
|
}
|
||||||
|
|
||||||
|
public Optional<TrackHasGenre> getTrackHasGenreById(Integer id) {
|
||||||
|
if (id == null) {
|
||||||
|
throw new IllegalArgumentException("ID cannot be null");
|
||||||
|
}
|
||||||
|
logger.info("Getting track has genre by id:{}", id);
|
||||||
|
return repository.findById(id);
|
||||||
|
}
|
||||||
|
|
||||||
|
public boolean deleteTrackHasGenre(Integer id) {
|
||||||
|
if (id == null) {
|
||||||
|
throw new IllegalArgumentException("Track has genre id cannot be null");
|
||||||
|
}
|
||||||
|
logger.info("Deleting track has genre:{}", id);
|
||||||
|
return repository.deleteById(id);
|
||||||
|
}
|
||||||
|
|
||||||
|
}
|
||||||
|
|
@ -0,0 +1,46 @@
|
||||||
|
syntax = "proto3";
|
||||||
|
|
||||||
|
option java_package = "com.mediamanager.protocol.messages";
|
||||||
|
option java_outer_classname = "TrackHasArtistMessages";
|
||||||
|
|
||||||
|
package mediamanager.messages;
|
||||||
|
|
||||||
|
message TrackHasArtist{
|
||||||
|
int32 id = 1;
|
||||||
|
int32 fk_track_id = 2;
|
||||||
|
int32 fk_artist_id =3;
|
||||||
|
}
|
||||||
|
|
||||||
|
message CreateTrackHasArtistRequest {
|
||||||
|
int32 fk_track_id = 1;
|
||||||
|
int32 fk_artist_id = 2;
|
||||||
|
}
|
||||||
|
|
||||||
|
message CreateTrackHasArtistResponse {
|
||||||
|
TrackHasArtist trackhasartist = 1;
|
||||||
|
}
|
||||||
|
|
||||||
|
message GetTrackHasArtistsRequest {
|
||||||
|
|
||||||
|
}
|
||||||
|
|
||||||
|
message GetTrackHasArtistsResponse {
|
||||||
|
repeated TrackHasArtist trackhasartist = 1;
|
||||||
|
}
|
||||||
|
|
||||||
|
message GetTrackHasArtistByIdRequest {
|
||||||
|
int32 id = 1;
|
||||||
|
}
|
||||||
|
|
||||||
|
message GetTrackHasArtistByIdResponse {
|
||||||
|
TrackHasArtist trackhasartist = 1;
|
||||||
|
}
|
||||||
|
|
||||||
|
message DeleteTrackHasArtistRequest {
|
||||||
|
int32 id = 1;
|
||||||
|
}
|
||||||
|
|
||||||
|
message DeleteTrackHasArtistResponse {
|
||||||
|
bool success = 1;
|
||||||
|
string message = 2;
|
||||||
|
}
|
||||||
|
|
@ -0,0 +1,46 @@
|
||||||
|
syntax = "proto3";
|
||||||
|
|
||||||
|
option java_package = "com.mediamanager.protocol.messages";
|
||||||
|
option java_outer_classname = "TrackHasGenreMessages";
|
||||||
|
|
||||||
|
package mediamanager.messages;
|
||||||
|
|
||||||
|
message TrackHasGenre{
|
||||||
|
int32 id = 1;
|
||||||
|
int32 fk_track_id = 2;
|
||||||
|
int32 fk_genre_id =3;
|
||||||
|
}
|
||||||
|
|
||||||
|
message CreateTrackHasGenreRequest {
|
||||||
|
int32 fk_track_id = 1;
|
||||||
|
int32 fk_genre_id = 2;
|
||||||
|
}
|
||||||
|
|
||||||
|
message CreateTrackHasGenreResponse {
|
||||||
|
TrackHasGenre trackhasgenre = 1;
|
||||||
|
}
|
||||||
|
|
||||||
|
message GetTrackHasGenresRequest {
|
||||||
|
|
||||||
|
}
|
||||||
|
|
||||||
|
message GetTrackHasGenresResponse {
|
||||||
|
repeated TrackHasGenre trackhasgenre = 1;
|
||||||
|
}
|
||||||
|
|
||||||
|
message GetTrackHasGenreByIdRequest {
|
||||||
|
int32 id = 1;
|
||||||
|
}
|
||||||
|
|
||||||
|
message GetTrackHasGenreByIdResponse {
|
||||||
|
TrackHasGenre trackhasgenre = 1;
|
||||||
|
}
|
||||||
|
|
||||||
|
message DeleteTrackHasGenreRequest {
|
||||||
|
int32 id = 1;
|
||||||
|
}
|
||||||
|
|
||||||
|
message DeleteTrackHasGenreResponse {
|
||||||
|
bool success = 1;
|
||||||
|
string message = 2;
|
||||||
|
}
|
||||||
Loading…
Reference in New Issue