Compare commits

...
Author SHA1 Message Date
Gustavo Henrique Miranda f1b4033c45 Merge 80ee003fc9 into ae6f522901 2025-12-09 19:43:55 +00:00
Gustavo Henrique Santos Souza de Miranda 80ee003fc9 Implement trackhascomposer relationship management
Add complete implementation for track-composer relationship management,
  following the established trackhasgenre pattern. This enables tracking
  which composers are associated with each track in the media library.

  Changes:
  - Enhance TrackHasComposer model: Add @Entity and @Table annotations,
    nullable constraints, constructor, and toString method
  - Implement TrackHasComposerRepository with full CRUD operations
  - Implement TrackHasComposerService with business logic and validation
  - Add TrackHasComposerMapper for entity/protobuf conversion
  - Create action handlers:
    * CreateTrackHasComposerHandler (trackhascomposer.create)
    * DeleteTrackHasComposerHandler (trackhascomposer.delete)
    * GetTrackHasComposerByIdHandler (trackhascomposer.getById)
    * GetTrackHasComposerHandler (trackhascomposer.getAll)
  - Register TrackHasComposerService in DelegateActionManager for
    automatic handler discovery and dependency injection
  - Proto file (trackhascomposer.proto) was already correct

  The implementation validates track and composer 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 16:43:47 -03:00
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
Gustavo Henrique Miranda a804d76905 Merge pull request #28 from gmbrax/develop
Develop
2025-12-08 20:59:28 -03:00
Gustavo Henrique Miranda ae6f522901 Merge pull request #27 from gmbrax/fix/fix-CreateDiscHandler-Extra-Brace
Fix/fix create disc handler extra brace
2025-12-08 20:58:06 -03:00
Gustavo Henrique Santos Souza de Miranda fd71114426 Fix extra closing brace in CreateDiscHandler
Remove duplicate closing brace at end of CreateDiscHandler.java
  that was causing a syntax error.
2025-12-08 20:55:45 -03:00
Gustavo Henrique Miranda 2e0a39a455 Merge pull request #26 from gmbrax/develop
Develop
2025-12-08 20:51:38 -03:00
Gustavo Henrique Miranda eebe142b8c Merge branch 'feature/Implement-track-management' into develop 2025-12-08 20:51:21 -03:00
Gustavo Henrique Miranda 4073c53b3d Merge pull request #25 from gmbrax/feature/Implement-disc-management
Implement Disc entity with complete CRUD operations
2025-12-08 20:49:08 -03:00
Gustavo Henrique Santos Souza de Miranda 8208b58b34 Implement Track entity with complete CRUD operations
Add full Track implementation following the established pattern from Disc and Album entities.

  Components added:
  - Track entity model with relationships to Disc, Composer, BitDepth, BitRate, and SamplingRate
  - TrackRepository for data access layer with full CRUD operations
  - TrackService with business logic and validation
  - TrackMapper for protobuf/entity conversion
  - track.proto with all protobuf message definitions
  - Five action handlers: Create, GetAll, GetById, Update, Delete
  - TrackService registration in DelegateActionManager

  The Track entity supports:
  - Required fields: trackNumber, title, filepath, discId
  - Optional fields: duration, composerId, bitDepthId, bitRateId, samplingRateId
  - Full transaction management and error handling
  - Proper validation and logging throughout all layers
2025-12-08 20:43:08 -03:00
Gustavo Henrique Mirandaandcoderabbitai[bot] <136622811+coderabbitai[bot]@users.noreply.github.com> dfa4185e64 Update src/main/java/com/mediamanager/service/delegate/handler/disc/CreateDiscHandler.java
Co-authored-by: coderabbitai[bot] <136622811+coderabbitai[bot]@users.noreply.github.com>
2025-12-08 20:42:23 -03:00
Gustavo Henrique Santos Souza de Miranda 07f7405b03 Implement Disc entity with complete CRUD operations
Add full implementation for Disc entity following existing patterns:
  - Create Disc model with Album relationship
  - Add DiscRepository for data persistence
  - Implement DiscService with business logic
  - Create DiscMapper for protobuf conversion
  - Add all handler classes (Create, Get, GetById, Update, Delete)
  - Register DiscService in DelegateActionManager
  - Define disc.proto with all message types

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

  Co-Authored-By: Claude Sonnet 4.5 <noreply@anthropic.com>
2025-12-08 17:45:04 -03:00
Gustavo Henrique Miranda 61c5124d27 Merge pull request #24 from gmbrax/fix/fix-broken-album-method
Fix broken removeGenre implementation in Album entity
2025-12-08 00:39:31 -03:00
Gustavo Henrique Santos Souza de Miranda 8119530bef Fix broken removeGenre to correct logic for the null-pointer exception 2025-12-08 00:37:05 -03:00
Gustavo Henrique Santos Souza de Miranda 09d20efba6 Fix broken removeGenre to avoid possible null-pointer 2025-12-08 00:33:23 -03:00
Gustavo Henrique Santos Souza de Miranda bcd03fc7ce Fix broken removeGenre implementation in Album entity 2025-12-08 00:22:42 -03:00
Gustavo Henrique Miranda d70fae0719 Merge pull request #23 from gmbrax/feature/Implement-Album-Management
Implement Album management with full CRUD operations
2025-12-08 00:16:02 -03:00
Gustavo Henrique Miranda dccbfcf546 Merge pull request #22 from gmbrax/feature/Implement-AlbumType-Management
Implement AlbumType management with full CRUD operations
2025-12-07 20:09:01 -03:00
49 changed files with 3198 additions and 3 deletions
@@ -0,0 +1,50 @@
package com.mediamanager.mapper;
import com.mediamanager.model.Disc;
import com.mediamanager.protocol.messages.DiscMessages;
public class DiscMapper {
public static DiscMessages.Disc toProtobuf(Disc entity) {
if (entity == null) {
return null;
}
Integer discNumber = entity.getDiscNumber();
if (discNumber == null) {
throw new IllegalArgumentException("Disc number cannot be null");
}
DiscMessages.Disc.Builder builder = DiscMessages.Disc.newBuilder()
.setDiscNumber(discNumber);
Integer id = entity.getId();
if (id != null) {
builder.setId(id);
}
// Map Album foreign key
if (entity.getAlbum() != null && entity.getAlbum().getId() != null) {
builder.setFkAlbumId(entity.getAlbum().getId());
}
return builder.build();
}
public static Disc toEntity(DiscMessages.Disc protobuf) {
if (protobuf == null) {
return null;
}
Disc entity = new Disc();
if (protobuf.getId() > 0) {
entity.setId(protobuf.getId());
}
entity.setDiscNumber(protobuf.getDiscNumber());
// Note: Foreign key relationship (Album) is handled in the service layer
return entity;
}
}
@@ -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.TrackHasComposer;
import com.mediamanager.protocol.messages.TrackHasComposerMessages;
public class TrackHasComposerMapper {
public static TrackHasComposerMessages.TrackHasComposer toProtobuf(TrackHasComposer entity) {
if (entity == null) {
return null;
}
TrackHasComposerMessages.TrackHasComposer.Builder builder = TrackHasComposerMessages.TrackHasComposer.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 Composer foreign key
if (entity.getComposer() != null && entity.getComposer().getId() != null) {
builder.setFkComposerId(entity.getComposer().getId());
}
return builder.build();
}
public static TrackHasComposer toEntity(TrackHasComposerMessages.TrackHasComposer protobuf) {
if (protobuf == null) {
return null;
}
TrackHasComposer entity = new TrackHasComposer();
if (protobuf.getId() > 0) {
entity.setId(protobuf.getId());
}
// Note: Foreign key relationships (Track, Composer) 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,95 @@
package com.mediamanager.mapper;
import com.mediamanager.model.Track;
import com.mediamanager.protocol.messages.TrackMessages;
public class TrackMapper {
public static TrackMessages.Track toProtobuf(Track entity) {
if (entity == null) {
return null;
}
Integer trackNumber = entity.getTrackNumber();
if (trackNumber == null) {
throw new IllegalArgumentException("Track number cannot be null");
}
String title = entity.getTitle();
if (title == null) {
throw new IllegalArgumentException("Title cannot be null");
}
String filepath = entity.getFilepath();
if (filepath == null) {
throw new IllegalArgumentException("Filepath cannot be null");
}
TrackMessages.Track.Builder builder = TrackMessages.Track.newBuilder()
.setTrackNumber(trackNumber)
.setTitle(title)
.setFilepath(filepath);
Integer id = entity.getId();
if (id != null) {
builder.setId(id);
}
// Map duration (optional)
Integer duration = entity.getDuration();
if (duration != null) {
builder.setDuration(duration);
}
// Map Disc foreign key (required)
if (entity.getDisc() != null && entity.getDisc().getId() != null) {
builder.setFkDiscId(entity.getDisc().getId());
}
// Map Composer foreign key (optional)
if (entity.getComposer() != null && entity.getComposer().getId() != null) {
builder.setFkComposerId(entity.getComposer().getId());
}
// Map BitDepth foreign key (optional)
if (entity.getBitDepth() != null && entity.getBitDepth().getId() != null) {
builder.setFkBitdepthId(entity.getBitDepth().getId());
}
// Map BitRate foreign key (optional)
if (entity.getBitRate() != null && entity.getBitRate().getId() != null) {
builder.setFkBitrateId(entity.getBitRate().getId());
}
// Map SamplingRate foreign key (optional)
if (entity.getSamplingRate() != null && entity.getSamplingRate().getId() != null) {
builder.setFkSamplingrateId(entity.getSamplingRate().getId());
}
return builder.build();
}
public static Track toEntity(TrackMessages.Track protobuf) {
if (protobuf == null) {
return null;
}
Track entity = new Track();
if (protobuf.getId() > 0) {
entity.setId(protobuf.getId());
}
entity.setTrackNumber(protobuf.getTrackNumber());
entity.setTitle(protobuf.getTitle());
entity.setFilepath(protobuf.getFilepath());
if (protobuf.getDuration() > 0) {
entity.setDuration(protobuf.getDuration());
}
// Note: Foreign key relationships (Disc, Composer, BitDepth, BitRate, SamplingRate)
// are handled in the service layer
return entity;
}
}
@@ -98,9 +98,14 @@ public class Album {
} }
public void removeGenre(Genre genre) { public void removeGenre(Genre genre) {
if (genre == null) {
return;
}
albumGenres.removeIf(ag ->
ag.getGenre() != null && ag.getGenre() != null &&
ag.getGenre().getId() != null && ag.getGenre().getId() != null &&
ag.getGenre().getId().equals(genre.getId()) ag.getGenre().getId().equals(genre.getId())
);
} }
// Método conveniente para pegar só os gêneros // Método conveniente para pegar só os gêneros
@@ -0,0 +1,47 @@
package com.mediamanager.model;
import jakarta.persistence.*;
@Entity
@Table(name = "disc")
public class Disc {
@Id
@GeneratedValue(strategy = GenerationType.IDENTITY)
private Integer id;
@Column(name = "disc_number", nullable = false)
private Integer discNumber;
@ManyToOne(fetch = FetchType.LAZY)
@JoinColumn(name = "fk_album_id",nullable = false)
private Album album;
public Disc() {
}
public Integer getId() {
return id;
}
public void setId(Integer id) {
this.id = id;
}
public Integer getDiscNumber() {
return discNumber;
}
public void setDiscNumber(Integer discNumber) {
this.discNumber = discNumber;
}
public Album getAlbum() {
return album;
}
public void setAlbum(Album album) {
this.album = album;
}
}
@@ -0,0 +1,128 @@
package com.mediamanager.model;
import jakarta.persistence.*;
@Entity
@Table(name = "track")
public class Track {
@Id
@GeneratedValue(strategy = GenerationType.IDENTITY)
private Integer id;
@Column(name = "track_number")
private Integer trackNumber;
@Column
private String title;
@Column
private Integer duration;
@Column
private String filepath;
@ManyToOne(fetch = FetchType.LAZY)
@JoinColumn(name = "fk_disc_id")
private Disc disc;
@ManyToOne(fetch = FetchType.LAZY)
@JoinColumn(name = "fk_composer_id")
private Composer composer;
@ManyToOne(fetch = FetchType.LAZY)
@JoinColumn(name = "fk_bit_depth_id")
private BitDepth bitDepth;
@ManyToOne(fetch = FetchType.LAZY)
@JoinColumn(name = "fk_bit_rate_id")
private BitRate bitRate;
@ManyToOne(fetch = FetchType.LAZY)
@JoinColumn(name = "fk_sampling_rate_id")
private SamplingRate samplingRate;
public Track() {
}
public Integer getId() {
return id;
}
public void setId(Integer id) {
this.id = id;
}
public Integer getTrackNumber() {
return trackNumber;
}
public void setTrackNumber(Integer trackNumber) {
this.trackNumber = trackNumber;
}
public String getTitle() {
return title;
}
public void setTitle(String name) {
this.title = name;
}
public Integer getDuration() {
return duration;
}
public void setDuration(Integer duration) {
this.duration = duration;
}
public String getFilepath() {
return filepath;
}
public void setFilepath(String filepath) {
this.filepath = filepath;
}
public Disc getDisc() {
return disc;
}
public void setDisc(Disc disc) {
this.disc = disc;
}
public Composer getComposer() {
return composer;
}
public void setComposer(Composer composer) {
this.composer = composer;
}
public BitDepth getBitDepth() {
return bitDepth;
}
public void setBitDepth(BitDepth bitDepth) {
this.bitDepth = bitDepth;
}
public BitRate getBitRate() {
return bitRate;
}
public void setBitRate(BitRate bitRate) {
this.bitRate = bitRate;
}
public SamplingRate getSamplingRate() {
return samplingRate;
}
public void setSamplingRate(SamplingRate samplingRate) {
this.samplingRate = samplingRate;
}
}
@@ -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 = "trackhascomposer")
public class TrackHasComposer {
@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_composer_id", nullable = false)
private Composer composer;
public TrackHasComposer() {}
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 Composer getComposer() {
return composer;
}
public void setComposer(Composer composer) {
this.composer = composer;
}
@Override
public String toString() {
return "TrackHasComposer{" +
"id=" + id +
", trackId=" + (track != null ? track.getId() : null) +
", composerId=" + (composer != null ? composer.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,100 @@
package com.mediamanager.repository;
import com.mediamanager.model.Disc;
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 DiscRepository {
private static final Logger logger = LogManager.getLogger(DiscRepository.class);
private final EntityManagerFactory entityManagerFactory;
public DiscRepository(EntityManagerFactory entityManagerFactory) {
this.entityManagerFactory = entityManagerFactory;
}
public Disc save(Disc disc) {
logger.debug("Saving Disc: {}", disc.getDiscNumber());
EntityManager em = entityManagerFactory.createEntityManager();
em.getTransaction().begin();
try {
em.persist(disc);
em.getTransaction().commit();
logger.debug("Disc has been saved successfully");
return disc;
} catch (Exception e) {
em.getTransaction().rollback();
logger.error("Error while saving Disc: {}", e.getMessage());
throw e;
} finally {
if (em.isOpen()) em.close();
}
}
public List<Disc> findAll() {
logger.debug("Finding All Disc");
EntityManager em = entityManagerFactory.createEntityManager();
try{
return em.createQuery("select d from Disc d", Disc.class).getResultList();
}finally {
if (em.isOpen()) em.close();
}
}
public Optional<Disc> findById(Integer id) {
logger.debug("Finding Disc with id: {}", id);
EntityManager em = entityManagerFactory.createEntityManager();
try{
Disc disc = em.find(Disc.class, id);
return Optional.ofNullable(disc);
}finally {
if (em.isOpen()) em.close();
}
}
public Disc update(Disc disc) {
logger.debug("Updating Disc: {}", disc.getDiscNumber());
EntityManager em = entityManagerFactory.createEntityManager();
em.getTransaction().begin();
try {
Disc updated = em.merge(disc);
em.getTransaction().commit();
logger.debug("Disc has been updated successfully");
return updated;
} catch (Exception e) {
em.getTransaction().rollback();
logger.error("Error while updating Disc: {}", e.getMessage());
throw e;
} finally {
if (em.isOpen()) em.close();
}
}
public boolean deleteById(Integer id){
logger.debug("Deleting Disc with id: {}", id);
EntityManager em = entityManagerFactory.createEntityManager();
em.getTransaction().begin();
try{
Disc disc = em.find(Disc.class, id);
if (disc == null) {
em.getTransaction().rollback();
return false;
}
em.remove(disc);
em.getTransaction().commit();
logger.debug("Disc has been deleted successfully");
return true;
} catch (Exception e) {
em.getTransaction().rollback();
logger.error("Error while deleting Disc: {}", e.getMessage());
throw e;
} finally {
if (em.isOpen()) em.close();
}
}
}
@@ -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.TrackHasComposer;
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 TrackHasComposerRepository {
private static final Logger logger = LogManager.getLogger(TrackHasComposerRepository.class);
private final EntityManagerFactory entityManagerFactory;
public TrackHasComposerRepository(EntityManagerFactory entityManagerFactory) {
this.entityManagerFactory = entityManagerFactory;
}
public TrackHasComposer save(TrackHasComposer trackHasComposer) {
logger.debug("Saving TrackHasComposer: {}", trackHasComposer);
EntityManager em = entityManagerFactory.createEntityManager();
em.getTransaction().begin();
try {
em.persist(trackHasComposer);
em.getTransaction().commit();
logger.debug("TrackHasComposer has been saved successfully");
return trackHasComposer;
} catch (Exception e) {
em.getTransaction().rollback();
logger.error("Error while saving TrackHasComposer: {}", e.getMessage());
throw e;
} finally {
if (em.isOpen()) em.close();
}
}
public List<TrackHasComposer> findAll() {
logger.debug("Finding All TrackHasComposer");
EntityManager em = entityManagerFactory.createEntityManager();
try{
return em.createQuery("select t from TrackHasComposer t", TrackHasComposer.class).getResultList();
}finally {
if (em.isOpen()) em.close();
}
}
public Optional<TrackHasComposer> findById(Integer id) {
logger.debug("Finding TrackHasComposer with id: {}", id);
EntityManager em = entityManagerFactory.createEntityManager();
try{
TrackHasComposer trackHasComposer = em.find(TrackHasComposer.class, id);
return Optional.ofNullable(trackHasComposer);
}finally {
if (em.isOpen()) em.close();
}
}
public boolean deleteById(Integer id){
logger.debug("Deleting TrackHasComposer with id: {}", id);
EntityManager em = entityManagerFactory.createEntityManager();
em.getTransaction().begin();
try{
TrackHasComposer trackHasComposer = em.find(TrackHasComposer.class, id);
if (trackHasComposer == null) {
em.getTransaction().rollback();
return false;
}
em.remove(trackHasComposer);
em.getTransaction().commit();
logger.debug("TrackHasComposer has been deleted successfully");
return true;
} catch (Exception e) {
em.getTransaction().rollback();
logger.error("Error while deleting TrackHasComposer: {}", 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();
}
}
}
@@ -0,0 +1,100 @@
package com.mediamanager.repository;
import com.mediamanager.model.Track;
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 TrackRepository {
private static final Logger logger = LogManager.getLogger(TrackRepository.class);
private final EntityManagerFactory entityManagerFactory;
public TrackRepository(EntityManagerFactory entityManagerFactory) {
this.entityManagerFactory = entityManagerFactory;
}
public Track save(Track track) {
logger.debug("Saving Track: {}", track.getTitle());
EntityManager em = entityManagerFactory.createEntityManager();
em.getTransaction().begin();
try {
em.persist(track);
em.getTransaction().commit();
logger.debug("Track has been saved successfully");
return track;
} catch (Exception e) {
em.getTransaction().rollback();
logger.error("Error while saving Track: {}", e.getMessage());
throw e;
} finally {
if (em.isOpen()) em.close();
}
}
public List<Track> findAll() {
logger.debug("Finding All Track");
EntityManager em = entityManagerFactory.createEntityManager();
try{
return em.createQuery("select t from Track t", Track.class).getResultList();
}finally {
if (em.isOpen()) em.close();
}
}
public Optional<Track> findById(Integer id) {
logger.debug("Finding Track with id: {}", id);
EntityManager em = entityManagerFactory.createEntityManager();
try{
Track track = em.find(Track.class, id);
return Optional.ofNullable(track);
}finally {
if (em.isOpen()) em.close();
}
}
public Track update(Track track) {
logger.debug("Updating Track: {}", track.getTitle());
EntityManager em = entityManagerFactory.createEntityManager();
em.getTransaction().begin();
try {
Track updated = em.merge(track);
em.getTransaction().commit();
logger.debug("Track has been updated successfully");
return updated;
} catch (Exception e) {
em.getTransaction().rollback();
logger.error("Error while updating Track: {}", e.getMessage());
throw e;
} finally {
if (em.isOpen()) em.close();
}
}
public boolean deleteById(Integer id){
logger.debug("Deleting Track with id: {}", id);
EntityManager em = entityManagerFactory.createEntityManager();
em.getTransaction().begin();
try{
Track track = em.find(Track.class, id);
if (track == null) {
em.getTransaction().rollback();
return false;
}
em.remove(track);
em.getTransaction().commit();
logger.debug("Track has been deleted successfully");
return true;
} catch (Exception e) {
em.getTransaction().rollback();
logger.error("Error while deleting Track: {}", e.getMessage());
throw e;
} finally {
if (em.isOpen()) em.close();
}
}
}
@@ -3,6 +3,7 @@ package com.mediamanager.service.delegate;
import com.google.protobuf.ByteString; import com.google.protobuf.ByteString;
import com.mediamanager.protocol.TransportProtocol; import com.mediamanager.protocol.TransportProtocol;
import com.mediamanager.repository.*; import com.mediamanager.repository.*;
import com.mediamanager.repository.DiscRepository;
import com.mediamanager.service.album.AlbumService; import com.mediamanager.service.album.AlbumService;
import com.mediamanager.service.albumart.AlbumArtService; import com.mediamanager.service.albumart.AlbumArtService;
import com.mediamanager.service.albumhasartist.AlbumHasArtistService; import com.mediamanager.service.albumhasartist.AlbumHasArtistService;
@@ -11,10 +12,16 @@ 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.service.trackhascomposer.TrackHasComposerService;
import com.mediamanager.repository.GenreRepository; import com.mediamanager.repository.GenreRepository;
import com.mediamanager.service.artist.ArtistService; import com.mediamanager.service.artist.ArtistService;
import com.mediamanager.service.track.TrackService;
import com.mediamanager.service.delegate.annotation.Action; import com.mediamanager.service.delegate.annotation.Action;
import com.mediamanager.service.disc.DiscService;
import com.mediamanager.service.genre.GenreService; import com.mediamanager.service.genre.GenreService;
import com.mediamanager.service.samplingrate.SamplingRateService; import com.mediamanager.service.samplingrate.SamplingRateService;
import jakarta.persistence.EntityManagerFactory; import jakarta.persistence.EntityManagerFactory;
@@ -100,6 +107,26 @@ public class DelegateActionManager {
AlbumHasGenreService albumHasGenreService = new AlbumHasGenreService(albumHasGenreRepository, albumRepository, genreRepository); AlbumHasGenreService albumHasGenreService = new AlbumHasGenreService(albumHasGenreRepository, albumRepository, genreRepository);
serviceLocator.register(AlbumHasGenreService.class, albumHasGenreService); serviceLocator.register(AlbumHasGenreService.class, albumHasGenreService);
DiscRepository discRepository = new DiscRepository(entityManagerFactory);
DiscService discService = new DiscService(discRepository, albumRepository);
serviceLocator.register(DiscService.class, discService);
TrackRepository trackRepository = new TrackRepository(entityManagerFactory);
TrackService trackService = new TrackService(trackRepository, discRepository, composerRepository, bitDepthRepository, bitRateRepository, samplingRateRepository);
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);
TrackHasComposerRepository trackHasComposerRepository = new TrackHasComposerRepository(entityManagerFactory);
TrackHasComposerService trackHasComposerService = new TrackHasComposerService(trackHasComposerRepository, trackRepository, composerRepository);
serviceLocator.register(TrackHasComposerService.class, trackHasComposerService);
serviceLocator.logRegisteredServices(); serviceLocator.logRegisteredServices();
logger.info("Services initialized successfully"); logger.info("Services initialized successfully");
@@ -0,0 +1,61 @@
package com.mediamanager.service.delegate.handler.disc;
import com.google.protobuf.ByteString;
import com.google.protobuf.InvalidProtocolBufferException;
import com.mediamanager.mapper.DiscMapper;
import com.mediamanager.model.Disc;
import com.mediamanager.protocol.TransportProtocol;
import com.mediamanager.protocol.messages.DiscMessages;
import com.mediamanager.service.delegate.ActionHandler;
import com.mediamanager.service.delegate.annotation.Action;
import com.mediamanager.service.disc.DiscService;
import org.apache.logging.log4j.LogManager;
import org.apache.logging.log4j.Logger;
@Action("disc.create")
public class CreateDiscHandler implements ActionHandler {
private static final Logger logger = LogManager.getLogger(CreateDiscHandler.class);
private final DiscService discService;
public CreateDiscHandler(DiscService discService) {
this.discService = discService;
}
@Override
public TransportProtocol.Response.Builder handle(ByteString requestPayload) throws InvalidProtocolBufferException {
try {
DiscMessages.CreateDiscRequest createRequest =
DiscMessages.CreateDiscRequest.parseFrom(requestPayload);
Disc disc = discService.createDisc(
createRequest.getDiscNumber(),
createRequest.getFkAlbumId() > 0 ? createRequest.getFkAlbumId() : null
);
DiscMessages.Disc discProto = DiscMapper.toProtobuf(disc);
DiscMessages.CreateDiscResponse createDiscResponse = DiscMessages.CreateDiscResponse.newBuilder()
.setDisc(discProto)
.build();
return TransportProtocol.Response.newBuilder()
.setPayload(createDiscResponse.toByteString());
} catch (IllegalArgumentException e) {
logger.error("Validation error", e);
return TransportProtocol.Response.newBuilder()
.setStatusCode(400)
.setPayload(ByteString.copyFromUtf8("Invalid request"));
} catch (InvalidProtocolBufferException e) {
logger.error("Invalid CreateDiscRequest payload", e);
return TransportProtocol.Response.newBuilder()
.setStatusCode(400)
.setPayload(ByteString.copyFromUtf8("Invalid request payload"));
} catch (Exception e) {
logger.error("Error creating disc", e);
return TransportProtocol.Response.newBuilder()
.setStatusCode(500)
.setPayload(ByteString.copyFromUtf8("Internal server error"));
}
}
}
@@ -0,0 +1,59 @@
package com.mediamanager.service.delegate.handler.disc;
import com.google.protobuf.ByteString;
import com.google.protobuf.InvalidProtocolBufferException;
import com.mediamanager.protocol.TransportProtocol;
import com.mediamanager.protocol.messages.DiscMessages;
import com.mediamanager.service.delegate.ActionHandler;
import com.mediamanager.service.delegate.annotation.Action;
import com.mediamanager.service.disc.DiscService;
import org.apache.logging.log4j.LogManager;
import org.apache.logging.log4j.Logger;
@Action("disc.delete")
public class DeleteDiscHandler implements ActionHandler {
private static final Logger logger = LogManager.getLogger(DeleteDiscHandler.class);
private final DiscService discService;
public DeleteDiscHandler(DiscService discService) {
this.discService = discService;
}
@Override
public TransportProtocol.Response.Builder handle(ByteString requestPayload)
throws InvalidProtocolBufferException {
try {
DiscMessages.DeleteDiscRequest deleteRequest =
DiscMessages.DeleteDiscRequest.parseFrom(requestPayload);
int id = deleteRequest.getId();
boolean success = discService.deleteDisc(id);
DiscMessages.DeleteDiscResponse deleteResponse;
if (success) {
deleteResponse = DiscMessages.DeleteDiscResponse.newBuilder()
.setMessage("Disc deleted successfully")
.build();
return TransportProtocol.Response.newBuilder()
.setPayload(deleteResponse.toByteString());
} else {
deleteResponse = DiscMessages.DeleteDiscResponse.newBuilder()
.setMessage("Disc not found")
.build();
return TransportProtocol.Response.newBuilder()
.setStatusCode(404)
.setPayload(deleteResponse.toByteString());
}
} catch (Exception e) {
logger.error("Error deleting disc", e);
DiscMessages.DeleteDiscResponse deleteResponse =
DiscMessages.DeleteDiscResponse.newBuilder()
.setMessage("Error: " + e.getMessage())
.build();
return TransportProtocol.Response.newBuilder()
.setStatusCode(500)
.setPayload(deleteResponse.toByteString());
}
}
}
@@ -0,0 +1,56 @@
package com.mediamanager.service.delegate.handler.disc;
import com.google.protobuf.ByteString;
import com.google.protobuf.InvalidProtocolBufferException;
import com.mediamanager.mapper.DiscMapper;
import com.mediamanager.model.Disc;
import com.mediamanager.protocol.TransportProtocol;
import com.mediamanager.protocol.messages.DiscMessages;
import com.mediamanager.service.delegate.ActionHandler;
import com.mediamanager.service.delegate.annotation.Action;
import com.mediamanager.service.disc.DiscService;
import org.apache.logging.log4j.LogManager;
import org.apache.logging.log4j.Logger;
import java.util.Optional;
@Action(value = "disc.getById")
public class GetDiscByIdHandler implements ActionHandler {
private static final Logger logger = LogManager.getLogger(GetDiscByIdHandler.class);
private final DiscService discService;
public GetDiscByIdHandler(DiscService discService) {
this.discService = discService;
}
@Override
public TransportProtocol.Response.Builder handle(ByteString requestPayload)
throws InvalidProtocolBufferException{
try{
DiscMessages.GetDiscByIdRequest getByIdRequest =
DiscMessages.GetDiscByIdRequest.parseFrom(requestPayload);
int id = getByIdRequest.getId();
Optional<Disc> discOpt = discService.getDiscById(id);
if (discOpt.isEmpty()){
logger.warn("Disc not found with ID: {}", id);
return TransportProtocol.Response.newBuilder()
.setStatusCode(404)
.setPayload(ByteString.copyFromUtf8("Disc not found"));
}
DiscMessages.Disc discProto = DiscMapper.toProtobuf(discOpt.get());
DiscMessages.GetDiscByIdResponse getByIdResponse = DiscMessages.GetDiscByIdResponse.newBuilder()
.setDisc(discProto)
.build();
return TransportProtocol.Response.newBuilder()
.setPayload(getByIdResponse.toByteString());
} catch (Exception e) {
logger.error("Error getting disc by ID", e);
return TransportProtocol.Response.newBuilder()
.setStatusCode(500)
.setPayload(ByteString.copyFromUtf8("Error: "+ e.getMessage()));
}
}
}
@@ -0,0 +1,47 @@
package com.mediamanager.service.delegate.handler.disc;
import com.google.protobuf.ByteString;
import com.google.protobuf.InvalidProtocolBufferException;
import com.mediamanager.mapper.DiscMapper;
import com.mediamanager.model.Disc;
import com.mediamanager.protocol.TransportProtocol;
import com.mediamanager.protocol.messages.DiscMessages;
import com.mediamanager.service.delegate.ActionHandler;
import com.mediamanager.service.delegate.annotation.Action;
import com.mediamanager.service.disc.DiscService;
import org.apache.logging.log4j.LogManager;
import org.apache.logging.log4j.Logger;
import java.util.List;
@Action("disc.getAll")
public class GetDiscHandler implements ActionHandler {
private static final Logger logger = LogManager.getLogger(GetDiscHandler.class);
private final DiscService discService;
public GetDiscHandler(DiscService discService){this.discService = discService;}
@Override
public TransportProtocol.Response.Builder handle(ByteString requestPayload) throws InvalidProtocolBufferException {
try{
List<Disc> discs = discService.getAllDiscs();
DiscMessages.GetDiscsResponse.Builder responseBuilder = DiscMessages.GetDiscsResponse.newBuilder();
for (Disc disc : discs) {
DiscMessages.Disc discProto = DiscMapper.toProtobuf(disc);
responseBuilder.addDiscs(discProto);
}
DiscMessages.GetDiscsResponse getDiscsResponse = responseBuilder.build();
return TransportProtocol.Response.newBuilder()
.setPayload(getDiscsResponse.toByteString());
}catch (Exception e){
logger.error("Error getting discs", e);
return TransportProtocol.Response.newBuilder()
.setStatusCode(500)
.setPayload(ByteString.copyFromUtf8("Error: " + e.getMessage()));
}
}
}
@@ -0,0 +1,72 @@
package com.mediamanager.service.delegate.handler.disc;
import com.google.protobuf.ByteString;
import com.google.protobuf.InvalidProtocolBufferException;
import com.mediamanager.mapper.DiscMapper;
import com.mediamanager.model.Disc;
import com.mediamanager.protocol.TransportProtocol;
import com.mediamanager.protocol.messages.DiscMessages;
import com.mediamanager.service.delegate.ActionHandler;
import com.mediamanager.service.delegate.annotation.Action;
import com.mediamanager.service.disc.DiscService;
import org.apache.logging.log4j.LogManager;
import org.apache.logging.log4j.Logger;
import java.util.Optional;
@Action("disc.update")
public class UpdateDiscHandler implements ActionHandler {
private static final Logger logger = LogManager.getLogger(UpdateDiscHandler.class);
private final DiscService discService;
public UpdateDiscHandler(DiscService discService) {
this.discService = discService;
}
@Override
public TransportProtocol.Response.Builder handle(ByteString requestPayload)
throws InvalidProtocolBufferException {
try {
DiscMessages.UpdateDiscRequest updateRequest =
DiscMessages.UpdateDiscRequest.parseFrom(requestPayload);
int id = updateRequest.getId();
Integer discNumber = updateRequest.getDiscNumber();
Integer albumId = updateRequest.getFkAlbumId() > 0 ? updateRequest.getFkAlbumId() : null;
Optional<Disc> discOpt = discService.updateDisc(
id,
discNumber,
albumId
);
if (discOpt.isEmpty()) {
logger.warn("Disc not found with ID: {}", id);
return TransportProtocol.Response.newBuilder()
.setStatusCode(404)
.setPayload(ByteString.copyFromUtf8("Disc not found"));
}
DiscMessages.Disc discProto = DiscMapper.toProtobuf(discOpt.get());
DiscMessages.UpdateDiscResponse updateResponse =
DiscMessages.UpdateDiscResponse.newBuilder()
.setDisc(discProto)
.build();
return TransportProtocol.Response.newBuilder()
.setPayload(updateResponse.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 updating disc", e);
return TransportProtocol.Response.newBuilder()
.setStatusCode(500)
.setPayload(ByteString.copyFromUtf8("Error: " + e.getMessage()));
}
}
}
@@ -0,0 +1,61 @@
package com.mediamanager.service.delegate.handler.track;
import com.google.protobuf.ByteString;
import com.google.protobuf.InvalidProtocolBufferException;
import com.mediamanager.mapper.TrackMapper;
import com.mediamanager.model.Track;
import com.mediamanager.protocol.TransportProtocol;
import com.mediamanager.protocol.messages.TrackMessages;
import com.mediamanager.service.delegate.ActionHandler;
import com.mediamanager.service.delegate.annotation.Action;
import com.mediamanager.service.track.TrackService;
import org.apache.logging.log4j.LogManager;
import org.apache.logging.log4j.Logger;
@Action("track.create")
public class CreateTrackHandler implements ActionHandler {
private static final Logger logger = LogManager.getLogger(CreateTrackHandler.class);
private final TrackService trackService;
public CreateTrackHandler(TrackService trackService) {
this.trackService = trackService;
}
@Override
public TransportProtocol.Response.Builder handle(ByteString requestPayload) throws InvalidProtocolBufferException {
try{
TrackMessages.CreateTrackRequest createRequest =
TrackMessages.CreateTrackRequest.parseFrom(requestPayload);
Track track = trackService.createTrack(
createRequest.getTrackNumber(),
createRequest.getTitle(),
createRequest.hasDuration() ? createRequest.getDuration().getValue() : null,
createRequest.getFilepath(),
createRequest.getFkDiscId() > 0 ? createRequest.getFkDiscId() : null,
createRequest.hasFkComposerId() ? createRequest.getFkComposerId().getValue() : null,
createRequest.hasFkBitdepthId() ? createRequest.getFkBitdepthId().getValue() : null,
createRequest.hasFkBitrateId() ? createRequest.getFkBitrateId().getValue() : null,
createRequest.hasFkSamplingrateId() ? createRequest.getFkSamplingrateId().getValue() : null
);
TrackMessages.Track trackProto = TrackMapper.toProtobuf(track);
TrackMessages.CreateTrackResponse createTrackResponse = TrackMessages.CreateTrackResponse.newBuilder()
.setTrack(trackProto)
.build();
return TransportProtocol.Response.newBuilder()
.setPayload(createTrackResponse.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", e);
return TransportProtocol.Response.newBuilder()
.setStatusCode(500)
.setPayload(ByteString.copyFromUtf8("Error: " + e.getMessage()));
}
}
}
@@ -0,0 +1,62 @@
package com.mediamanager.service.delegate.handler.track;
import com.google.protobuf.ByteString;
import com.google.protobuf.InvalidProtocolBufferException;
import com.mediamanager.protocol.TransportProtocol;
import com.mediamanager.protocol.messages.TrackMessages;
import com.mediamanager.service.delegate.ActionHandler;
import com.mediamanager.service.delegate.annotation.Action;
import com.mediamanager.service.track.TrackService;
import org.apache.logging.log4j.LogManager;
import org.apache.logging.log4j.Logger;
@Action("track.delete")
public class DeleteTrackHandler implements ActionHandler {
private static final Logger logger = LogManager.getLogger(DeleteTrackHandler.class);
private final TrackService trackService;
public DeleteTrackHandler(TrackService trackService) {
this.trackService = trackService;
}
@Override
public TransportProtocol.Response.Builder handle(ByteString requestPayload)
throws InvalidProtocolBufferException {
try {
TrackMessages.DeleteTrackRequest deleteRequest =
TrackMessages.DeleteTrackRequest.parseFrom(requestPayload);
int id = deleteRequest.getId();
boolean success = trackService.deleteTrack(id);
TrackMessages.DeleteTrackResponse deleteResponse;
if (success) {
deleteResponse = TrackMessages.DeleteTrackResponse.newBuilder()
.setSuccess(true)
.setMessage("Track deleted successfully")
.build();
return TransportProtocol.Response.newBuilder()
.setPayload(deleteResponse.toByteString());
} else {
deleteResponse = TrackMessages.DeleteTrackResponse.newBuilder()
.setSuccess(false)
.setMessage("Track not found")
.build();
return TransportProtocol.Response.newBuilder()
.setStatusCode(404)
.setPayload(deleteResponse.toByteString());
}
} catch (Exception e) {
logger.error("Error deleting track", e);
TrackMessages.DeleteTrackResponse deleteResponse =
TrackMessages.DeleteTrackResponse.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.track;
import com.google.protobuf.ByteString;
import com.google.protobuf.InvalidProtocolBufferException;
import com.mediamanager.mapper.TrackMapper;
import com.mediamanager.model.Track;
import com.mediamanager.protocol.TransportProtocol;
import com.mediamanager.protocol.messages.TrackMessages;
import com.mediamanager.service.delegate.ActionHandler;
import com.mediamanager.service.delegate.annotation.Action;
import com.mediamanager.service.track.TrackService;
import org.apache.logging.log4j.LogManager;
import org.apache.logging.log4j.Logger;
import java.util.Optional;
@Action(value = "track.getById")
public class GetTrackByIdHandler implements ActionHandler {
private static final Logger logger = LogManager.getLogger(GetTrackByIdHandler.class);
private final TrackService trackService;
public GetTrackByIdHandler(TrackService trackService) {
this.trackService = trackService;
}
@Override
public TransportProtocol.Response.Builder handle(ByteString requestPayload)
throws InvalidProtocolBufferException{
try{
TrackMessages.GetTrackByIdRequest getByIdRequest =
TrackMessages.GetTrackByIdRequest.parseFrom(requestPayload);
int id = getByIdRequest.getId();
Optional<Track> trackOpt = trackService.getTrackById(id);
if (trackOpt.isEmpty()){
logger.warn("Track not found with ID: {}", id);
return TransportProtocol.Response.newBuilder()
.setStatusCode(404)
.setPayload(ByteString.copyFromUtf8("Track not found"));
}
TrackMessages.Track trackProto = TrackMapper.toProtobuf(trackOpt.get());
TrackMessages.GetTrackByIdResponse getByIdResponse = TrackMessages.GetTrackByIdResponse.newBuilder()
.setTrack(trackProto)
.build();
return TransportProtocol.Response.newBuilder()
.setPayload(getByIdResponse.toByteString());
} catch (Exception e) {
logger.error("Error getting track by ID", e);
return TransportProtocol.Response.newBuilder()
.setStatusCode(500)
.setPayload(ByteString.copyFromUtf8("Error: "+ e.getMessage()));
}
}
}
@@ -0,0 +1,47 @@
package com.mediamanager.service.delegate.handler.track;
import com.google.protobuf.ByteString;
import com.google.protobuf.InvalidProtocolBufferException;
import com.mediamanager.mapper.TrackMapper;
import com.mediamanager.model.Track;
import com.mediamanager.protocol.TransportProtocol;
import com.mediamanager.protocol.messages.TrackMessages;
import com.mediamanager.service.delegate.ActionHandler;
import com.mediamanager.service.delegate.annotation.Action;
import com.mediamanager.service.track.TrackService;
import org.apache.logging.log4j.LogManager;
import org.apache.logging.log4j.Logger;
import java.util.List;
@Action("track.getAll")
public class GetTrackHandler implements ActionHandler {
private static final Logger logger = LogManager.getLogger(GetTrackHandler.class);
private final TrackService trackService;
public GetTrackHandler(TrackService trackService){this.trackService = trackService;}
@Override
public TransportProtocol.Response.Builder handle(ByteString requestPayload) throws InvalidProtocolBufferException {
try{
List<Track> tracks = trackService.getAllTracks();
TrackMessages.GetTracksResponse.Builder responseBuilder = TrackMessages.GetTracksResponse.newBuilder();
for (Track track : tracks) {
TrackMessages.Track trackProto = TrackMapper.toProtobuf(track);
responseBuilder.addTracks(trackProto);
}
TrackMessages.GetTracksResponse getTracksResponse = responseBuilder.build();
return TransportProtocol.Response.newBuilder()
.setPayload(getTracksResponse.toByteString());
}catch (Exception e){
logger.error("Error getting tracks", e);
return TransportProtocol.Response.newBuilder()
.setStatusCode(500)
.setPayload(ByteString.copyFromUtf8("Error: " + e.getMessage()));
}
}
}
@@ -0,0 +1,86 @@
package com.mediamanager.service.delegate.handler.track;
import com.google.protobuf.ByteString;
import com.google.protobuf.InvalidProtocolBufferException;
import com.mediamanager.mapper.TrackMapper;
import com.mediamanager.model.Track;
import com.mediamanager.protocol.TransportProtocol;
import com.mediamanager.protocol.messages.TrackMessages;
import com.mediamanager.service.delegate.ActionHandler;
import com.mediamanager.service.delegate.annotation.Action;
import com.mediamanager.service.track.TrackService;
import org.apache.logging.log4j.LogManager;
import org.apache.logging.log4j.Logger;
import java.util.Optional;
@Action("track.update")
public class UpdateTrackHandler implements ActionHandler {
private static final Logger logger = LogManager.getLogger(UpdateTrackHandler.class);
private final TrackService trackService;
public UpdateTrackHandler(TrackService trackService) {
this.trackService = trackService;
}
@Override
public TransportProtocol.Response.Builder handle(ByteString requestPayload)
throws InvalidProtocolBufferException {
try {
TrackMessages.UpdateTrackRequest updateRequest =
TrackMessages.UpdateTrackRequest.parseFrom(requestPayload);
int id = updateRequest.getId();
Integer trackNumber = updateRequest.hasTrackNumber() ? updateRequest.getTrackNumber().getValue() : null;
String title = updateRequest.getTitle();
Integer duration = updateRequest.hasDuration() ? updateRequest.getDuration().getValue() : null;
String filepath = updateRequest.getFilepath();
Integer discId = updateRequest.hasFkDiscId() ? updateRequest.getFkDiscId().getValue() : null;
Integer composerId = updateRequest.hasFkComposerId() ? updateRequest.getFkComposerId().getValue() : null;
Integer bitDepthId = updateRequest.hasFkBitdepthId() ? updateRequest.getFkBitdepthId().getValue() : null;
Integer bitRateId = updateRequest.hasFkBitrateId() ? updateRequest.getFkBitrateId().getValue() : null;
Integer samplingRateId = updateRequest.hasFkSamplingrateId() ? updateRequest.getFkSamplingrateId().getValue() : null;
Optional<Track> trackOpt = trackService.updateTrack(
id,
trackNumber,
title,
duration,
filepath,
discId,
composerId,
bitDepthId,
bitRateId,
samplingRateId
);
if (trackOpt.isEmpty()) {
logger.warn("Track not found with ID: {}", id);
return TransportProtocol.Response.newBuilder()
.setStatusCode(404)
.setPayload(ByteString.copyFromUtf8("Track not found"));
}
TrackMessages.Track trackProto = TrackMapper.toProtobuf(trackOpt.get());
TrackMessages.UpdateTrackResponse updateResponse =
TrackMessages.UpdateTrackResponse.newBuilder()
.setTrack(trackProto)
.build();
return TransportProtocol.Response.newBuilder()
.setPayload(updateResponse.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 updating track", e);
return TransportProtocol.Response.newBuilder()
.setStatusCode(500)
.setPayload(ByteString.copyFromUtf8("Error: " + e.getMessage()));
}
}
}
@@ -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.trackhascomposer;
import com.google.protobuf.ByteString;
import com.google.protobuf.InvalidProtocolBufferException;
import com.mediamanager.mapper.TrackHasComposerMapper;
import com.mediamanager.model.TrackHasComposer;
import com.mediamanager.protocol.TransportProtocol;
import com.mediamanager.protocol.messages.TrackHasComposerMessages;
import com.mediamanager.service.delegate.ActionHandler;
import com.mediamanager.service.delegate.annotation.Action;
import com.mediamanager.service.trackhascomposer.TrackHasComposerService;
import org.apache.logging.log4j.LogManager;
import org.apache.logging.log4j.Logger;
@Action("trackhascomposer.create")
public class CreateTrackHasComposerHandler implements ActionHandler {
private static final Logger logger = LogManager.getLogger(CreateTrackHasComposerHandler.class);
private final TrackHasComposerService trackHasComposerService;
public CreateTrackHasComposerHandler(TrackHasComposerService trackHasComposerService) {
this.trackHasComposerService = trackHasComposerService;
}
@Override
public TransportProtocol.Response.Builder handle(ByteString requestPayload) throws InvalidProtocolBufferException {
try{
TrackHasComposerMessages.CreateTrackHasComposerRequest createRequest =
TrackHasComposerMessages.CreateTrackHasComposerRequest.parseFrom(requestPayload);
TrackHasComposer trackHasComposer = trackHasComposerService.createTrackHasComposer(
createRequest.getFkTrackId() > 0 ? createRequest.getFkTrackId() : null,
createRequest.getFkComposerId() > 0 ? createRequest.getFkComposerId() : null
);
TrackHasComposerMessages.TrackHasComposer trackHasComposerProto = TrackHasComposerMapper.toProtobuf(trackHasComposer);
TrackHasComposerMessages.CreateTrackHasComposerResponse createTrackHasComposerResponse = TrackHasComposerMessages.CreateTrackHasComposerResponse.newBuilder()
.setTrackhascomposer(trackHasComposerProto)
.build();
return TransportProtocol.Response.newBuilder()
.setPayload(createTrackHasComposerResponse.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 composer", e);
return TransportProtocol.Response.newBuilder()
.setStatusCode(500)
.setPayload(ByteString.copyFromUtf8("Error: " + e.getMessage()));
}
}
}
@@ -0,0 +1,62 @@
package com.mediamanager.service.delegate.handler.trackhascomposer;
import com.google.protobuf.ByteString;
import com.google.protobuf.InvalidProtocolBufferException;
import com.mediamanager.protocol.TransportProtocol;
import com.mediamanager.protocol.messages.TrackHasComposerMessages;
import com.mediamanager.service.delegate.ActionHandler;
import com.mediamanager.service.delegate.annotation.Action;
import com.mediamanager.service.trackhascomposer.TrackHasComposerService;
import org.apache.logging.log4j.LogManager;
import org.apache.logging.log4j.Logger;
@Action("trackhascomposer.delete")
public class DeleteTrackHasComposerHandler implements ActionHandler {
private static final Logger logger = LogManager.getLogger(DeleteTrackHasComposerHandler.class);
private final TrackHasComposerService trackHasComposerService;
public DeleteTrackHasComposerHandler(TrackHasComposerService trackHasComposerService) {
this.trackHasComposerService = trackHasComposerService;
}
@Override
public TransportProtocol.Response.Builder handle(ByteString requestPayload)
throws InvalidProtocolBufferException {
try {
TrackHasComposerMessages.DeleteTrackHasComposerRequest deleteRequest =
TrackHasComposerMessages.DeleteTrackHasComposerRequest.parseFrom(requestPayload);
int id = deleteRequest.getId();
boolean success = trackHasComposerService.deleteTrackHasComposer(id);
TrackHasComposerMessages.DeleteTrackHasComposerResponse deleteResponse;
if (success) {
deleteResponse = TrackHasComposerMessages.DeleteTrackHasComposerResponse.newBuilder()
.setSuccess(true)
.setMessage("Track has composer deleted successfully")
.build();
return TransportProtocol.Response.newBuilder()
.setPayload(deleteResponse.toByteString());
} else {
deleteResponse = TrackHasComposerMessages.DeleteTrackHasComposerResponse.newBuilder()
.setSuccess(false)
.setMessage("Track has composer not found")
.build();
return TransportProtocol.Response.newBuilder()
.setStatusCode(404)
.setPayload(deleteResponse.toByteString());
}
} catch (Exception e) {
logger.error("Error deleting track has composer", e);
TrackHasComposerMessages.DeleteTrackHasComposerResponse deleteResponse =
TrackHasComposerMessages.DeleteTrackHasComposerResponse.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.trackhascomposer;
import com.google.protobuf.ByteString;
import com.google.protobuf.InvalidProtocolBufferException;
import com.mediamanager.mapper.TrackHasComposerMapper;
import com.mediamanager.model.TrackHasComposer;
import com.mediamanager.protocol.TransportProtocol;
import com.mediamanager.protocol.messages.TrackHasComposerMessages;
import com.mediamanager.service.delegate.ActionHandler;
import com.mediamanager.service.delegate.annotation.Action;
import com.mediamanager.service.trackhascomposer.TrackHasComposerService;
import org.apache.logging.log4j.LogManager;
import org.apache.logging.log4j.Logger;
import java.util.Optional;
@Action(value = "trackhascomposer.getById")
public class GetTrackHasComposerByIdHandler implements ActionHandler {
private static final Logger logger = LogManager.getLogger(GetTrackHasComposerByIdHandler.class);
private final TrackHasComposerService trackHasComposerService;
public GetTrackHasComposerByIdHandler(TrackHasComposerService trackHasComposerService) {
this.trackHasComposerService = trackHasComposerService;
}
@Override
public TransportProtocol.Response.Builder handle(ByteString requestPayload)
throws InvalidProtocolBufferException{
try{
TrackHasComposerMessages.GetTrackHasComposerByIdRequest getByIdRequest =
TrackHasComposerMessages.GetTrackHasComposerByIdRequest.parseFrom(requestPayload);
int id = getByIdRequest.getId();
Optional<TrackHasComposer> trackHasComposerOpt = trackHasComposerService.getTrackHasComposerById(id);
if (trackHasComposerOpt.isEmpty()){
logger.warn("TrackHasComposer not found with ID: {}", id);
return TransportProtocol.Response.newBuilder()
.setStatusCode(404)
.setPayload(ByteString.copyFromUtf8("TrackHasComposer not found"));
}
TrackHasComposerMessages.TrackHasComposer trackHasComposerProto = TrackHasComposerMapper.toProtobuf(trackHasComposerOpt.get());
TrackHasComposerMessages.GetTrackHasComposerByIdResponse getByIdResponse = TrackHasComposerMessages.GetTrackHasComposerByIdResponse.newBuilder()
.setTrackhascomposer(trackHasComposerProto)
.build();
return TransportProtocol.Response.newBuilder()
.setPayload(getByIdResponse.toByteString());
} catch (Exception e) {
logger.error("Error getting track has composer 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.trackhascomposer;
import com.google.protobuf.ByteString;
import com.google.protobuf.InvalidProtocolBufferException;
import com.mediamanager.mapper.TrackHasComposerMapper;
import com.mediamanager.model.TrackHasComposer;
import com.mediamanager.protocol.TransportProtocol;
import com.mediamanager.protocol.messages.TrackHasComposerMessages;
import com.mediamanager.service.delegate.ActionHandler;
import com.mediamanager.service.delegate.annotation.Action;
import com.mediamanager.service.trackhascomposer.TrackHasComposerService;
import org.apache.logging.log4j.LogManager;
import org.apache.logging.log4j.Logger;
import java.util.List;
@Action("trackhascomposer.getAll")
public class GetTrackHasComposerHandler implements ActionHandler {
private static final Logger logger = LogManager.getLogger(GetTrackHasComposerHandler.class);
private final TrackHasComposerService trackHasComposerService;
public GetTrackHasComposerHandler(TrackHasComposerService trackHasComposerService){this.trackHasComposerService = trackHasComposerService;}
@Override
public TransportProtocol.Response.Builder handle(ByteString requestPayload) throws InvalidProtocolBufferException {
try{
List<TrackHasComposer> trackHasComposers = trackHasComposerService.getAllTrackHasComposers();
TrackHasComposerMessages.GetTrackHasComposersResponse.Builder responseBuilder = TrackHasComposerMessages.GetTrackHasComposersResponse.newBuilder();
for (TrackHasComposer trackHasComposer : trackHasComposers) {
TrackHasComposerMessages.TrackHasComposer trackHasComposerProto = TrackHasComposerMapper.toProtobuf(trackHasComposer);
responseBuilder.addTrackhascomposer(trackHasComposerProto);
}
TrackHasComposerMessages.GetTrackHasComposersResponse getTrackHasComposersResponse = responseBuilder.build();
return TransportProtocol.Response.newBuilder()
.setPayload(getTrackHasComposersResponse.toByteString());
}catch (Exception e){
logger.error("Error getting track has composers", 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,98 @@
package com.mediamanager.service.disc;
import com.mediamanager.model.Album;
import com.mediamanager.model.Disc;
import com.mediamanager.repository.AlbumRepository;
import com.mediamanager.repository.DiscRepository;
import org.apache.logging.log4j.LogManager;
import org.apache.logging.log4j.Logger;
import java.util.List;
import java.util.Optional;
public class DiscService {
private static final Logger logger = LogManager.getLogger(DiscService.class);
private final DiscRepository repository;
private final AlbumRepository albumRepository;
public DiscService(DiscRepository repository, AlbumRepository albumRepository) {
this.repository = repository;
this.albumRepository = albumRepository;
}
public Disc createDisc(Integer discNumber, Integer albumId) {
logger.debug("Creating disc with number: {}", discNumber);
if (discNumber == null) {
throw new IllegalArgumentException("Disc number cannot be null");
}
if (albumId == null) {
throw new IllegalArgumentException("Album ID cannot be null");
}
Disc disc = new Disc();
disc.setDiscNumber(discNumber);
// Set Album (required)
Optional<Album> album = albumRepository.findById(albumId);
if (album.isEmpty()) {
throw new IllegalArgumentException("Album not found with id: " + albumId);
}
disc.setAlbum(album.get());
return repository.save(disc);
}
public List<Disc> getAllDiscs() {
logger.info("Getting all discs");
return repository.findAll();
}
public Optional<Disc> getDiscById(Integer id) {
if (id == null) {
throw new IllegalArgumentException("ID cannot be null");
}
logger.info("Getting disc by id: {}", id);
return repository.findById(id);
}
public Optional<Disc> updateDisc(Integer id, Integer discNumber, Integer albumId) {
if (id == null) {
throw new IllegalArgumentException("ID cannot be null");
}
if (discNumber == null) {
throw new IllegalArgumentException("Disc number cannot be null");
}
if (albumId == null) {
throw new IllegalArgumentException("Album ID cannot be null");
}
logger.info("Updating disc with id: {}", id);
Optional<Disc> existingDisc = repository.findById(id);
if (existingDisc.isEmpty()) {
logger.warn("Disc not found with id: {}", id);
return Optional.empty();
}
Disc disc = existingDisc.get();
disc.setDiscNumber(discNumber);
// Update Album
Optional<Album> album = albumRepository.findById(albumId);
if (album.isEmpty()) {
throw new IllegalArgumentException("Album not found with id: " + albumId);
}
disc.setAlbum(album.get());
Disc updatedDisc = repository.update(disc);
return Optional.of(updatedDisc);
}
public boolean deleteDisc(Integer id) {
if (id == null) {
throw new IllegalArgumentException("Disc id cannot be null");
}
logger.info("Deleting disc: {}", id);
return repository.deleteById(id);
}
}
@@ -0,0 +1,213 @@
package com.mediamanager.service.track;
import com.mediamanager.model.*;
import com.mediamanager.repository.*;
import org.apache.logging.log4j.LogManager;
import org.apache.logging.log4j.Logger;
import java.util.List;
import java.util.Optional;
public class TrackService {
private static final Logger logger = LogManager.getLogger(TrackService.class);
private final TrackRepository repository;
private final DiscRepository discRepository;
private final ComposerRepository composerRepository;
private final BitDepthRepository bitDepthRepository;
private final BitRateRepository bitRateRepository;
private final SamplingRateRepository samplingRateRepository;
public TrackService(TrackRepository repository,
DiscRepository discRepository,
ComposerRepository composerRepository,
BitDepthRepository bitDepthRepository,
BitRateRepository bitRateRepository,
SamplingRateRepository samplingRateRepository) {
this.repository = repository;
this.discRepository = discRepository;
this.composerRepository = composerRepository;
this.bitDepthRepository = bitDepthRepository;
this.bitRateRepository = bitRateRepository;
this.samplingRateRepository = samplingRateRepository;
}
public Track createTrack(Integer trackNumber, String title, Integer duration,
String filepath, Integer discId, Integer composerId,
Integer bitDepthId, Integer bitRateId, Integer samplingRateId) {
logger.debug("Creating track with title: {}", title);
if (trackNumber == null) {
throw new IllegalArgumentException("Track number cannot be null");
}
if (title == null || title.isEmpty()) {
throw new IllegalArgumentException("Title cannot be null or empty");
}
if (filepath == null || filepath.isEmpty()) {
throw new IllegalArgumentException("Filepath cannot be null or empty");
}
if (discId == null) {
throw new IllegalArgumentException("Disc ID cannot be null");
}
Track track = new Track();
track.setTrackNumber(trackNumber);
track.setTitle(title);
track.setDuration(duration);
track.setFilepath(filepath);
// Set Disc (required)
Optional<Disc> disc = discRepository.findById(discId);
if (disc.isEmpty()) {
throw new IllegalArgumentException("Disc not found with id: " + discId);
}
track.setDisc(disc.get());
// Set Composer (optional)
if (composerId != null) {
Optional<Composer> composer = composerRepository.findById(composerId);
if (composer.isEmpty()) {
throw new IllegalArgumentException("Composer not found with id: " + composerId);
}
track.setComposer(composer.get());
}
// Set BitDepth (optional)
if (bitDepthId != null) {
Optional<BitDepth> bitDepth = bitDepthRepository.findById(bitDepthId);
if (bitDepth.isEmpty()) {
throw new IllegalArgumentException("BitDepth not found with id: " + bitDepthId);
}
track.setBitDepth(bitDepth.get());
}
// Set BitRate (optional)
if (bitRateId != null) {
Optional<BitRate> bitRate = bitRateRepository.findById(bitRateId);
if (bitRate.isEmpty()) {
throw new IllegalArgumentException("BitRate not found with id: " + bitRateId);
}
track.setBitRate(bitRate.get());
}
// Set SamplingRate (optional)
if (samplingRateId != null) {
Optional<SamplingRate> samplingRate = samplingRateRepository.findById(samplingRateId);
if (samplingRate.isEmpty()) {
throw new IllegalArgumentException("SamplingRate not found with id: " + samplingRateId);
}
track.setSamplingRate(samplingRate.get());
}
return repository.save(track);
}
public List<Track> getAllTracks() {
logger.info("Getting all tracks");
return repository.findAll();
}
public Optional<Track> getTrackById(Integer id) {
if (id == null) {
throw new IllegalArgumentException("ID cannot be null");
}
logger.info("Getting track by id: {}", id);
return repository.findById(id);
}
public Optional<Track> updateTrack(Integer id, Integer trackNumber, String title,
Integer duration, String filepath, Integer discId,
Integer composerId, Integer bitDepthId,
Integer bitRateId, Integer samplingRateId) {
if (id == null) {
throw new IllegalArgumentException("ID cannot be null");
}
if (trackNumber == null) {
throw new IllegalArgumentException("Track number cannot be null");
}
if (title == null || title.isEmpty()) {
throw new IllegalArgumentException("Title cannot be null or empty");
}
if (filepath == null || filepath.isEmpty()) {
throw new IllegalArgumentException("Filepath cannot be null or empty");
}
if (discId == null) {
throw new IllegalArgumentException("Disc ID cannot be null");
}
logger.info("Updating track with id: {}", id);
Optional<Track> existingTrack = repository.findById(id);
if (existingTrack.isEmpty()) {
logger.warn("Track not found with id: {}", id);
return Optional.empty();
}
Track track = existingTrack.get();
track.setTrackNumber(trackNumber);
track.setTitle(title);
track.setDuration(duration);
track.setFilepath(filepath);
// Update Disc (required)
Optional<Disc> disc = discRepository.findById(discId);
if (disc.isEmpty()) {
throw new IllegalArgumentException("Disc not found with id: " + discId);
}
track.setDisc(disc.get());
// Update Composer (optional)
if (composerId != null) {
Optional<Composer> composer = composerRepository.findById(composerId);
if (composer.isEmpty()) {
throw new IllegalArgumentException("Composer not found with id: " + composerId);
}
track.setComposer(composer.get());
} else {
track.setComposer(null);
}
// Update BitDepth (optional)
if (bitDepthId != null) {
Optional<BitDepth> bitDepth = bitDepthRepository.findById(bitDepthId);
if (bitDepth.isEmpty()) {
throw new IllegalArgumentException("BitDepth not found with id: " + bitDepthId);
}
track.setBitDepth(bitDepth.get());
} else {
track.setBitDepth(null);
}
// Update BitRate (optional)
if (bitRateId != null) {
Optional<BitRate> bitRate = bitRateRepository.findById(bitRateId);
if (bitRate.isEmpty()) {
throw new IllegalArgumentException("BitRate not found with id: " + bitRateId);
}
track.setBitRate(bitRate.get());
} else {
track.setBitRate(null);
}
// Update SamplingRate (optional)
if (samplingRateId != null) {
Optional<SamplingRate> samplingRate = samplingRateRepository.findById(samplingRateId);
if (samplingRate.isEmpty()) {
throw new IllegalArgumentException("SamplingRate not found with id: " + samplingRateId);
}
track.setSamplingRate(samplingRate.get());
} else {
track.setSamplingRate(null);
}
Track updatedTrack = repository.update(track);
return Optional.of(updatedTrack);
}
public boolean deleteTrack(Integer id) {
if (id == null) {
throw new IllegalArgumentException("Track id cannot be null");
}
logger.info("Deleting track: {}", id);
return repository.deleteById(id);
}
}
@@ -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.trackhascomposer;
import com.mediamanager.model.Track;
import com.mediamanager.model.TrackHasComposer;
import com.mediamanager.model.Composer;
import com.mediamanager.repository.TrackHasComposerRepository;
import com.mediamanager.repository.TrackRepository;
import com.mediamanager.repository.ComposerRepository;
import org.apache.logging.log4j.LogManager;
import org.apache.logging.log4j.Logger;
import java.util.List;
import java.util.Optional;
public class TrackHasComposerService {
private static final Logger logger = LogManager.getLogger(TrackHasComposerService.class);
private final TrackHasComposerRepository repository;
private final TrackRepository trackRepository;
private final ComposerRepository composerRepository;
public TrackHasComposerService(TrackHasComposerRepository repository, TrackRepository trackRepository, ComposerRepository composerRepository) {
this.repository = repository;
this.trackRepository = trackRepository;
this.composerRepository = composerRepository;
}
public TrackHasComposer createTrackHasComposer(Integer trackId, Integer composerId) {
logger.debug("Creating track has composer relationship - trackId:{}, composerId:{}", trackId, composerId);
if (trackId == null || trackId <= 0) {
throw new IllegalArgumentException("Track ID cannot be null or invalid");
}
if (composerId == null || composerId <= 0) {
throw new IllegalArgumentException("Composer 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 Composer exists
Optional<Composer> composer = composerRepository.findById(composerId);
if (composer.isEmpty()) {
throw new IllegalArgumentException("Composer not found with id: " + composerId);
}
TrackHasComposer trackHasComposer = new TrackHasComposer();
trackHasComposer.setTrack(track.get());
trackHasComposer.setComposer(composer.get());
return repository.save(trackHasComposer);
}
public List<TrackHasComposer> getAllTrackHasComposers() {
logger.info("Getting all track has composer relationships");
return repository.findAll();
}
public Optional<TrackHasComposer> getTrackHasComposerById(Integer id) {
if (id == null) {
throw new IllegalArgumentException("ID cannot be null");
}
logger.info("Getting track has composer by id:{}", id);
return repository.findById(id);
}
public boolean deleteTrackHasComposer(Integer id) {
if (id == null) {
throw new IllegalArgumentException("Track has composer id cannot be null");
}
logger.info("Deleting track has composer:{}", 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);
}
}
+54
View File
@@ -0,0 +1,54 @@
syntax = "proto3";
option java_package = "com.mediamanager.protocol.messages";
option java_outer_classname = "DiscMessages";
package mediamanager.messages;
message Disc{
int32 id = 1;
int32 disc_number = 2;
int32 fk_album_id = 3;
}
message CreateDiscRequest {
int32 disc_number = 1;
int32 fk_album_id = 2;
}
message CreateDiscResponse {
Disc disc = 1;
}
message GetDiscsRequest {
}
message GetDiscsResponse {
repeated Disc discs = 1;
}
message GetDiscByIdRequest {
int32 id = 1;
}
message GetDiscByIdResponse {
Disc disc = 1;
}
message UpdateDiscRequest {
int32 id = 1;
int32 disc_number = 2;
int32 fk_album_id = 3;
}
message UpdateDiscResponse {
Disc disc = 1;
}
message DeleteDiscRequest {
int32 id = 1;
}
message DeleteDiscResponse {
string message = 1;
}
+81
View File
@@ -0,0 +1,81 @@
syntax = "proto3";
import "google/protobuf/wrappers.proto";
option java_package = "com.mediamanager.protocol.messages";
option java_outer_classname = "TrackMessages";
package mediamanager.messages;
message Track{
int32 id = 1;
int32 track_number = 2;
string title = 3;
int32 duration = 4;
string filepath = 5;
int32 fk_disc_id = 6;
int32 fk_composer_id = 7;
int32 fk_bitdepth_id = 8;
int32 fk_bitrate_id = 9;
int32 fk_samplingrate_id = 10;
}
message CreateTrackRequest {
int32 track_number = 1;
string title = 2;
google.protobuf.Int32Value duration = 3;
string filepath = 4;
int32 fk_disc_id = 5;
google.protobuf.Int32Value fk_composer_id = 6;
google.protobuf.Int32Value fk_bitdepth_id = 7;
google.protobuf.Int32Value fk_bitrate_id = 8;
google.protobuf.Int32Value fk_samplingrate_id = 9;
}
message CreateTrackResponse {
Track track = 1;
}
message GetTracksRequest {
}
message GetTracksResponse {
repeated Track tracks = 1;
}
message GetTrackByIdRequest {
int32 id = 1;
}
message GetTrackByIdResponse {
Track track = 1;
}
message UpdateTrackRequest {
int32 id = 1;
google.protobuf.Int32Value track_number = 2;
string title = 3;
google.protobuf.Int32Value duration = 4;
string filepath = 5;
google.protobuf.Int32Value fk_disc_id = 6;
google.protobuf.Int32Value fk_composer_id = 7;
google.protobuf.Int32Value fk_bitdepth_id = 8;
google.protobuf.Int32Value fk_bitrate_id = 9;
google.protobuf.Int32Value fk_samplingrate_id = 10;
}
message UpdateTrackResponse {
Track track = 1;
}
message DeleteTrackRequest {
int32 id = 1;
}
message DeleteTrackResponse {
bool success = 1;
string message = 2;
}
+46
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;
}
+46
View File
@@ -0,0 +1,46 @@
syntax = "proto3";
option java_package = "com.mediamanager.protocol.messages";
option java_outer_classname = "TrackHasComposerMessages";
package mediamanager.messages;
message TrackHasComposer{
int32 id = 1;
int32 fk_track_id = 2;
int32 fk_composer_id =3;
}
message CreateTrackHasComposerRequest {
int32 fk_track_id = 1;
int32 fk_composer_id = 2;
}
message CreateTrackHasComposerResponse {
TrackHasComposer trackhascomposer = 1;
}
message GetTrackHasComposersRequest {
}
message GetTrackHasComposersResponse {
repeated TrackHasComposer trackhascomposer = 1;
}
message GetTrackHasComposerByIdRequest {
int32 id = 1;
}
message GetTrackHasComposerByIdResponse {
TrackHasComposer trackhascomposer = 1;
}
message DeleteTrackHasComposerRequest {
int32 id = 1;
}
message DeleteTrackHasComposerResponse {
bool success = 1;
string message = 2;
}
+46
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;
}