Compare commits

...

2 Commits

Author SHA1 Message Date
Gustavo Henrique Santos Souza de Miranda 7fd3c3e9f7 Implement trackhasartist relationship management
Add complete implementation for track-artist relationship management,
  following the established albumhasgenre pattern. This enables tracking
  which artists are associated with each track in the media library.

  Changes:
  - Fix TrackHasArtist model: Rename from TrackHasArtistt.java (typo)
    and correct table name from "trackhasgenre" to "trackhasartist"
  - Implement TrackHasArtistRepository with full CRUD operations
  - Implement TrackHasArtistService with business logic and validation
  - Add TrackHasArtistMapper for entity/protobuf conversion
  - Create action handlers:
    * CreateTrackHasArtistHandler (trackhasartist.create)
    * DeleteTrackHasArtistHandler (trackhasartist.delete)
    * GetTrackHasArtistByIdHandler (trackhasartist.getById)
    * GetTrackHasArtistHandler (trackhasartist.getAll)
  - Register TrackHasArtistService in DelegateActionManager for
    automatic handler discovery and dependency injection
  - Proto file (trackhasartist.proto) was already correct

  The implementation validates track and artist existence before creating
  relationships and provides proper error handling with appropriate HTTP
  status codes.

  🤖 Generated with [Claude Code](https://claude.com/claude-code)

  Co-Authored-By: Claude Sonnet 4.5 <noreply@anthropic.com>
2025-12-09 02:44:57 -03:00
Gustavo Henrique Santos Souza de Miranda e0799828d0 Implement trackhasgenre relationship management
Add complete implementation for track-genre relationship management,
  following the established albumhasgenre pattern. This enables tracking
  which genres are associated with each track in the media library.

  Changes:
  - Fix trackhasgenre.proto: Correct CreateTrackHasGenreRequest to use
    fk_track_id instead of fk_album_id
  - Enhance TrackHasGenre model with nullable constraints, constructor,
    and toString method
  - Implement TrackHasGenreRepository with full CRUD operations
  - Implement TrackHasGenreService with business logic and validation
  - Add TrackHasGenreMapper for entity/protobuf conversion
  - Create action handlers:
    * CreateTrackHasGenreHandler (trackhasgenre.create)
    * DeleteTrackHasGenreHandler (trackhasgenre.delete)
    * GetTrackHasGenreByIdHandler (trackhasgenre.getById)
    * GetTrackHasGenreHandler (trackhasgenre.getAll)
  - Register TrackHasGenreService in DelegateActionManager for
    automatic handler discovery and dependency injection

  The implementation validates track and genre existence before creating
  relationships and provides proper error handling with appropriate HTTP
  status codes.

  🤖 Generated with [Claude Code](https://claude.com/claude-code)

  Co-Authored-By: Claude Sonnet 4.5 <noreply@anthropic.com>
2025-12-09 02:24:40 -03:00
19 changed files with 1070 additions and 0 deletions

View File

@ -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;
}
}

View File

@ -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;
}
}

View File

@ -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) +
'}';
}
}

View File

@ -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) +
'}';
}
}

View File

@ -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();
}
}
}

View File

@ -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();
}
}
}

View File

@ -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");

View File

@ -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()));
}
}
}

View File

@ -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());
}
}
}

View File

@ -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()));
}
}
}

View File

@ -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()));
}
}
}

View File

@ -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()));
}
}
}

View File

@ -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());
}
}
}

View File

@ -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()));
}
}
}

View File

@ -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()));
}
}
}

View File

@ -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);
}
}

View File

@ -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);
}
}

View File

@ -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;
}

View File

@ -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;
}