Compare commits

...
Author SHA1 Message Date
Gustavo Henrique Santos Souza de Miranda 51a46c37e5 Rename DeleteArtistHandle to DeleteArtistHandler for consistency and update related references. Clean up Protobuf comment in UpdateArtistResponse. 2025-11-30 17:33:25 -03:00
Gustavo Henrique Santos Souza de Miranda 0df4b31a4d Fix logging messages in ArtistRepository for clarity
- Correct references from "genre" to "artist" in logging statements.
- Remove unused `Genre` import for cleanup.
2025-11-30 12:59:57 -03:00
Gustavo Henrique Mirandaandcoderabbitai[bot] <136622811+coderabbitai[bot]@users.noreply.github.com> 3c42fd9735 Update src/main/java/com/mediamanager/mapper/ArtistMapper.java
Co-authored-by: coderabbitai[bot] <136622811+coderabbitai[bot]@users.noreply.github.com>
2025-11-30 12:54:18 -03:00
Gustavo Henrique Santos Souza de Miranda 0a61f1f2fa Implement Artist Management with CRUD Operations
- Add `Artist` entity with JPA annotations and database mapping.
- Create repository, service, and delegate handlers for Artist CRUD operations.
- Register handlers (`artist.create`, `artist.getAll`, `artist.getById`, `artist.update`, `artist.delete`) in `DelegateActionManager`.
- Introduce Protobuf definitions for Artist messages.
- Update `initializeServices` in `DelegateActionManager` for Artist service support.
- Add null-safe ID handling in `ArtistMapper` to prevent potential NPEs.
2025-11-30 12:46:50 -03:00
Gustavo Henrique Miranda fecb0288d3 Merge pull request #12 from gmbrax/feature/auto-handler-scanner
Feature/auto handler scanner
2025-11-29 20:37:26 -03:00
Gustavo Henrique Santos Souza de Miranda 5ce8f4ca2a Improve DelegateActionManager error handling for invalid handlers
- Add validation to ensure classes annotated with `@Action` implement `ActionHandler`, throwing `IllegalArgumentException` for mismatches.
- Fix minor formatting issue in `@Action` annotation for `GetGenreByIdHandler`.
2025-11-29 15:33:08 -03:00
Gustavo Henrique Mirandaandcoderabbitai[bot] <136622811+coderabbitai[bot]@users.noreply.github.com> a5bd6e2c39 Update src/main/java/com/mediamanager/service/delegate/DelegateActionManager.java
Co-authored-by: coderabbitai[bot] <136622811+coderabbitai[bot]@users.noreply.github.com>
2025-11-29 09:52:54 -03:00
Gustavo Henrique Santos Souza de Miranda f87d6b1b53 Refactor DelegateActionManager for dynamic handler registration
- Replace manual handler registration with automatic scanning and registration of handlers annotated with `@Action`.
- Introduce `ServiceLocator` to enable dependency injection for dynamically instantiated handlers.
- Add `initializeServices` to centralize service initialization and registration.
- Enhance error handling and logging for handler instantiation and registration processes.
2025-11-29 08:26:58 -03:00
Gustavo Henrique Santos Souza de Miranda b715bb1bd3 Add @Action annotation and ServiceLocator for improved handler registration
- Introduce `@Action` annotation to simplify action handler identification and tagging.
- Add `ServiceLocator` for dynamic service registration and retrieval.
- Annotate handlers (`CreateGenreHandler`, `GetGenreHandler`, `UpdateGenreHandler`, `DeleteGenreHandler`, etc.) with corresponding actions.
2025-11-29 07:54:46 -03:00
Gustavo Henrique Miranda 9c3a1126a7 Merge pull request #11 from gmbrax/feature/implement-genre-management
Implement Genre Management with CRUD Operations
2025-11-29 06:09:44 -03:00
21 changed files with 792 additions and 17 deletions
@@ -0,0 +1,41 @@
package com.mediamanager.mapper;
import com.mediamanager.model.Artist;
import com.mediamanager.protocol.messages.ArtistMessages;
public class ArtistMapper {
public static ArtistMessages.Artist toProtobuf(Artist entity){
if (entity == null) {
return null;
}
String name = entity.getName();
if (name == null) {
throw new IllegalArgumentException("Artist name cannot be null");
}
ArtistMessages.Artist.Builder builder = ArtistMessages.Artist.newBuilder()
.setName(name);
// Only set ID when it's present and valid (> 0). Avoids NPE for null IDs.
Integer id = entity.getId();
if (id != null && id > 0) {
builder.setId(id);
}
return builder.build();
}
public static Artist toEntity(ArtistMessages.Artist protobuf) {
if (protobuf == null) {
return null;
}
Artist entity = new Artist();
if (protobuf.getId() > 0) {
entity.setId(protobuf.getId());
}
entity.setName(protobuf.getName());
return entity;
}
}
@@ -0,0 +1,27 @@
package com.mediamanager.model;
import jakarta.persistence.*;
@Entity
@Table(name = "artist")
public class Artist {
@Id
@GeneratedValue(strategy = GenerationType.IDENTITY)
private Integer id;
@Column(nullable = false)
private String name;
public Integer getId() {
return id;
}
public void setId(Integer id) {
this.id = id;
}
public String getName() {
return name;
}
public void setName(String name) {
this.name = name;
}
}
@@ -0,0 +1,104 @@
package com.mediamanager.repository;
import com.mediamanager.model.Artist;
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 ArtistRepository {
private static final Logger logger = LogManager.getLogger(ArtistRepository.class);
private final EntityManagerFactory entityManagerFactory;
public ArtistRepository(EntityManagerFactory entityManagerFactory) {
this.entityManagerFactory = entityManagerFactory;
}
public Artist save(Artist artist){
logger.debug("Saving Artist: {}", artist.getName());
EntityManager em = entityManagerFactory.createEntityManager();
em.getTransaction().begin();
try {
em.persist(artist);
em.getTransaction().commit();
logger.debug("Artist saved with ID: {}", artist.getId());
return artist;
} catch (Exception e) {
em.getTransaction().rollback();
logger.error("Error saving Artist", e);
throw e;
} finally {
if (em.isOpen()) em.close();
}
}
public List<Artist> findAll(){
logger.debug("Finding all Artists");
EntityManager em = entityManagerFactory.createEntityManager();
try {
return em
.createQuery("SELECT a FROM Artist a ORDER BY a.name", Artist.class)
.getResultList();
} finally {
if (em.isOpen()) em.close();
}
}
public Optional<Artist> findById(Integer id){
logger.debug("Finding artist by ID: {}", id);
EntityManager em = entityManagerFactory.createEntityManager();
try {
Artist artist = em.find(Artist.class, id);
return Optional.ofNullable(artist);
} finally {
if (em.isOpen()) em.close();
}
}
public Artist update(Artist artist){
logger.debug("Updating artist ID: {}", artist.getId());
EntityManager em = entityManagerFactory.createEntityManager();
em.getTransaction().begin();
try {
Artist updated = em.merge(artist);
em.getTransaction().commit();
logger.debug("Artist updated successfully");
return updated;
} catch (Exception e) {
em.getTransaction().rollback();
logger.error("Error updating artist", e);
throw e;
} finally {
if (em.isOpen()) em.close();
}
}
public boolean deleteById(Integer id){
logger.debug("Deleting Artist by ID: {}", id);
EntityManager em = entityManagerFactory.createEntityManager();
em.getTransaction().begin();
try {
Artist artist = em.find(Artist.class, id);
if (artist == null) {
em.getTransaction().rollback();
return false;
}
em.remove(artist);
em.getTransaction().commit();
logger.debug("Artist deleted successfully");
return true;
} catch (Exception e) {
em.getTransaction().rollback();
logger.error("Error deleting artist", e);
throw e;
} finally {
if (em.isOpen()) em.close();
}
}
}
@@ -0,0 +1,65 @@
package com.mediamanager.service.artist;
import com.mediamanager.model.Artist;
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 ArtistService {
private static final Logger logger = LogManager.getLogger(ArtistService.class);
private final ArtistRepository artistRepository;
public ArtistService(ArtistRepository artistRepository) {
this.artistRepository = artistRepository;
}
public Artist createArtist(String name){
logger.info("Creating artist: {}", name);
if (name == null || name.trim().isEmpty()) {
throw new IllegalArgumentException("Artist name cannot be empty");
}
Artist artist = new Artist();
artist.setName(name.trim());
return artistRepository.save(artist);
}
public List<Artist> getAllArtists(){
logger.info("Getting all artists");
return artistRepository.findAll();
}
public Optional<Artist> getArtistById(Integer id){
logger.info("Getting artist by ID: {}", id);
return artistRepository.findById(id);
}
public Optional<Artist> updateArtist(Integer id, String name){
logger.info("Updating artist ID {}: {}", id, name);
if (name == null || name.trim().isEmpty()) {
throw new IllegalArgumentException("Artist name cannot be empty");
}
Optional<Artist> existingArtist = artistRepository.findById(id);
if(existingArtist.isEmpty()){
logger.warn("Artist not found with ID: {}", id);
return Optional.empty();
}
Artist artist = existingArtist.get();
artist.setName(name.trim());
Artist updatedArtist = artistRepository.update(artist);
return Optional.of(updatedArtist);
}
public boolean deleteArtist(Integer id){
logger.info("Deleting artist ID: {}", id);
return artistRepository.deleteById(id);
}
}
@@ -2,47 +2,66 @@ 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.ArtistRepository;
import com.mediamanager.repository.GenreRepository; import com.mediamanager.repository.GenreRepository;
import com.mediamanager.service.delegate.handler.CloseHandler; import com.mediamanager.service.artist.ArtistService;
import com.mediamanager.service.delegate.handler.EchoHandler; import com.mediamanager.service.delegate.annotation.Action;
import com.mediamanager.service.delegate.handler.HeartbeatHandler;
import com.mediamanager.service.delegate.handler.genre.*;
import com.mediamanager.service.genre.GenreService; import com.mediamanager.service.genre.GenreService;
import jakarta.persistence.EntityManagerFactory; import jakarta.persistence.EntityManagerFactory;
import org.apache.logging.log4j.LogManager; import org.apache.logging.log4j.LogManager;
import org.apache.logging.log4j.Logger; import org.apache.logging.log4j.Logger;
import org.reflections.Reflections;
import org.reflections.scanners.Scanners;
import java.lang.reflect.Constructor;
import java.util.HashMap; import java.util.HashMap;
import java.util.Map; import java.util.Map;
import java.util.Set;
public class DelegateActionManager { public class DelegateActionManager {
private static final Logger logger = LogManager.getLogger(DelegateActionManager.class); private static final Logger logger = LogManager.getLogger(DelegateActionManager.class);
private final Map<String, ActionHandler> handlerRegistry; private final Map<String, ActionHandler> handlerRegistry;
private final ServiceLocator serviceLocator;
private final EntityManagerFactory entityManagerFactory; private final EntityManagerFactory entityManagerFactory;
private final GenreService genreService;
public DelegateActionManager(EntityManagerFactory entityManagerFactory) { public DelegateActionManager(EntityManagerFactory entityManagerFactory) {
this.entityManagerFactory = entityManagerFactory; this.entityManagerFactory = entityManagerFactory;
this.serviceLocator = new ServiceLocator();
initializeServices();
GenreRepository genreRepository = new GenreRepository(entityManagerFactory);
this.genreService = new GenreService(genreRepository);
logger.debug("DelegateActionManager created"); logger.debug("DelegateActionManager created");
this.handlerRegistry = new HashMap<>(); this.handlerRegistry = new HashMap<>();
registerHandlers(); autoRegisterHandlers();
} }
private void registerHandlers() { private void initializeServices() {
handlerRegistry.put("echo",new EchoHandler()); logger.info("Initializing services...");
handlerRegistry.put("heartbeat",new HeartbeatHandler());
handlerRegistry.put("close", new CloseHandler());
handlerRegistry.put("create_genre", new CreateGenreHandler(genreService)); GenreRepository genreRepository = new GenreRepository(entityManagerFactory);
handlerRegistry.put("get_genres", new GetGenreHandler(genreService)); GenreService genreService = new GenreService(genreRepository);
handlerRegistry.put("get_genre_by_id", new GetGenreByIdHandler(genreService));
handlerRegistry.put("update_genre", new UpdateGenreHandler(genreService));
handlerRegistry.put("delete_genre", new DeleteGenreHandler(genreService)); serviceLocator.register(GenreService.class, genreService);
ArtistRepository artistRepository = new ArtistRepository(entityManagerFactory);
ArtistService artistService = new ArtistService(artistRepository);
serviceLocator.register(ArtistService.class, artistService);
serviceLocator.logRegisteredServices();
logger.info("Services initialized successfully");
} }
public void start(){ public void start(){
logger.info("DelegateActionManager started"); logger.info("DelegateActionManager started");
} }
@@ -51,6 +70,117 @@ public class DelegateActionManager {
logger.info("DelegateActionManager stopped"); logger.info("DelegateActionManager stopped");
} }
@SuppressWarnings("unchecked")
private ActionHandler instantiateHandler(Class<?> clazz) throws Exception {
if(!ActionHandler.class.isAssignableFrom(clazz)){
throw new IllegalArgumentException(
clazz.getName() + " is annotated with @Action but does not implement ActionHandler");
}
logger.debug("Attempting to instantiate handler: {}", clazz.getSimpleName());
Constructor<?>[] constructors = clazz.getDeclaredConstructors();
// Sort constructors by parameter count (descending) to prefer DI constructors
java.util.Arrays.sort(constructors, (c1, c2) ->
Integer.compare(c2.getParameterCount(), c1.getParameterCount()));
for (Constructor<?> constructor : constructors) {
Class<?>[] paramTypes = constructor.getParameterTypes();
Object[] params = new Object[paramTypes.length];
boolean allDependenciesResolved = true;
for (int i = 0; i < paramTypes.length; i++) {
Object service = serviceLocator.get(paramTypes[i]);
if (service == null) {
allDependenciesResolved = false;
logger.debug("Cannot resolve dependency {} for {}",
paramTypes[i].getSimpleName(),
clazz.getSimpleName());
break; // Para de tentar esse construtor
}
params[i] = service;
}
if (allDependenciesResolved) {
logger.debug("Using constructor with {} params for {}",
paramTypes.length, clazz.getSimpleName());
return (ActionHandler) constructor.newInstance(params);
}
}
throw new IllegalStateException(
String.format(
"Cannot instantiate handler %s. No suitable constructor found. " +
"Make sure all required services are registered in ServiceLocator.",
clazz.getName()
)
);
}
private void autoRegisterHandlers() {
logger.info("Starting auto-registration of handlers...");
Reflections reflections = new Reflections(
"com.mediamanager.service.delegate.handler",
Scanners.TypesAnnotated
);
Set<Class<?>> annotatedClasses = reflections.getTypesAnnotatedWith(Action.class);
logger.info("Found {} handler classes with @Action annotation", annotatedClasses.size());
int successCount = 0;
int failureCount = 0;
for (Class<?> handlerClass : annotatedClasses) {
try {
Action actionAnnotation = handlerClass.getAnnotation(Action.class);
String actionName = actionAnnotation.value();
logger.debug("Processing handler: {} for action '{}'",
handlerClass.getSimpleName(),
actionName);
ActionHandler handler = instantiateHandler(handlerClass);
handlerRegistry.put(actionName, handler);
logger.info("✓ Registered handler: '{}' -> {}",
actionName,
handlerClass.getSimpleName());
successCount++;
} catch (Exception e) {
logger.error("✗ Failed to register handler: {}",
handlerClass.getName(),
e);
failureCount++;
}
}
logger.info("Auto-registration complete: {} successful, {} failed, {} total",
successCount,
failureCount,
successCount + failureCount);
if (failureCount > 0) {
logger.warn("Some handlers failed to register. Check logs above for details.");
}
}
public TransportProtocol.Response ProcessedRequest(TransportProtocol.Request request){ public TransportProtocol.Response ProcessedRequest(TransportProtocol.Request request){
String requestId = request.getRequestId(); String requestId = request.getRequestId();
logger.info("Processing request: {}", requestId); logger.info("Processing request: {}", requestId);
@@ -0,0 +1,45 @@
package com.mediamanager.service.delegate;
import org.apache.logging.log4j.LogManager;
import org.apache.logging.log4j.Logger;
import java.util.HashMap;
import java.util.Map;
public class ServiceLocator {
private static final Logger logger = LogManager.getLogger(ServiceLocator.class);
private final Map<Class<?>, Object> services = new HashMap<>();
public <T> void register(Class<T> serviceClass, T serviceInstance) {
if (serviceInstance == null) {
throw new IllegalArgumentException("Service instance cannot be null");
}
services.put(serviceClass, serviceInstance);
logger.debug("Registered service: {} -> {}",
serviceClass.getSimpleName(),
serviceInstance.getClass().getSimpleName());
}
@SuppressWarnings("unchecked")
public <T> T get(Class<T> serviceClass) {
return (T) services.get(serviceClass);
}
public boolean has(Class<?> serviceClass) {
return services.containsKey(serviceClass);
}
public int size() {
return services.size();
}
public void logRegisteredServices() {
logger.info("Registered services: {}", services.size());
services.forEach((clazz, instance) ->
logger.info(" - {} -> {}",
clazz.getSimpleName(),
instance.getClass().getSimpleName())
);
}
}
@@ -0,0 +1,13 @@
package com.mediamanager.service.delegate.annotation;
import java.lang.annotation.ElementType;
import java.lang.annotation.Retention;
import java.lang.annotation.RetentionPolicy;
import java.lang.annotation.Target;
@Retention(RetentionPolicy.RUNTIME)
@Target(ElementType.TYPE)
public @interface Action {
String value();
}
@@ -6,9 +6,11 @@ import com.mediamanager.protocol.TestProtocol.CloseCommand;
import com.mediamanager.protocol.TestProtocol.CloseResponse; import com.mediamanager.protocol.TestProtocol.CloseResponse;
import com.mediamanager.protocol.TransportProtocol; import com.mediamanager.protocol.TransportProtocol;
import com.mediamanager.service.delegate.ActionHandler; import com.mediamanager.service.delegate.ActionHandler;
import com.mediamanager.service.delegate.annotation.Action;
import org.apache.logging.log4j.LogManager; import org.apache.logging.log4j.LogManager;
import org.apache.logging.log4j.Logger; import org.apache.logging.log4j.Logger;
@Action("close")
public class CloseHandler implements ActionHandler { public class CloseHandler implements ActionHandler {
private static final Logger logger = LogManager.getLogger(CloseHandler.class); private static final Logger logger = LogManager.getLogger(CloseHandler.class);
@@ -6,9 +6,11 @@ import com.mediamanager.protocol.TestProtocol.EchoCommand; // ← Import
import com.mediamanager.protocol.TestProtocol.EchoResponse; // ← Import import com.mediamanager.protocol.TestProtocol.EchoResponse; // ← Import
import com.mediamanager.protocol.TransportProtocol; import com.mediamanager.protocol.TransportProtocol;
import com.mediamanager.service.delegate.ActionHandler; import com.mediamanager.service.delegate.ActionHandler;
import com.mediamanager.service.delegate.annotation.Action;
import org.apache.logging.log4j.LogManager; import org.apache.logging.log4j.LogManager;
import org.apache.logging.log4j.Logger; import org.apache.logging.log4j.Logger;
@Action("echo")
public class EchoHandler implements ActionHandler { public class EchoHandler implements ActionHandler {
private static final Logger logger = LogManager.getLogger(EchoHandler.class); private static final Logger logger = LogManager.getLogger(EchoHandler.class);
@@ -6,9 +6,11 @@ import com.mediamanager.protocol.TestProtocol.HeartbeatCommand;
import com.mediamanager.protocol.TestProtocol.HeartbeatResponse; import com.mediamanager.protocol.TestProtocol.HeartbeatResponse;
import com.mediamanager.protocol.TransportProtocol; import com.mediamanager.protocol.TransportProtocol;
import com.mediamanager.service.delegate.ActionHandler; import com.mediamanager.service.delegate.ActionHandler;
import com.mediamanager.service.delegate.annotation.Action;
import org.apache.logging.log4j.LogManager; import org.apache.logging.log4j.LogManager;
import org.apache.logging.log4j.Logger; import org.apache.logging.log4j.Logger;
@Action("heartbeat")
public class HeartbeatHandler implements ActionHandler { public class HeartbeatHandler implements ActionHandler {
private static final Logger logger = LogManager.getLogger(HeartbeatHandler.class); private static final Logger logger = LogManager.getLogger(HeartbeatHandler.class);
@@ -0,0 +1,50 @@
package com.mediamanager.service.delegate.handler.artist;
import com.google.protobuf.ByteString;
import com.google.protobuf.InvalidProtocolBufferException;
import com.mediamanager.mapper.ArtistMapper;
import com.mediamanager.model.Artist;
import com.mediamanager.protocol.TransportProtocol;
import com.mediamanager.protocol.messages.ArtistMessages;
import com.mediamanager.service.artist.ArtistService;
import com.mediamanager.service.delegate.ActionHandler;
import com.mediamanager.service.delegate.annotation.Action;
import org.apache.logging.log4j.LogManager;
import org.apache.logging.log4j.Logger;
@Action("artist.create")
public class CreateArtistHandler implements ActionHandler {
private static final Logger logger = LogManager.getLogger(CreateArtistHandler.class);
private final ArtistService artistService;
public CreateArtistHandler(ArtistService artistService) {
this.artistService = artistService;
}
@Override
public TransportProtocol.Response.Builder handle(ByteString requestPayload) throws InvalidProtocolBufferException {
try{
ArtistMessages.CreateArtistRequest createRequest =
ArtistMessages.CreateArtistRequest.parseFrom(requestPayload);
Artist artist = artistService.createArtist(createRequest.getName());
ArtistMessages.Artist artistProto = ArtistMapper.toProtobuf(artist);
ArtistMessages.CreateArtistResponse createArtistResponse = ArtistMessages.CreateArtistResponse.newBuilder()
.setArtist(artistProto)
.build();
return TransportProtocol.Response.newBuilder()
.setPayload(createArtistResponse.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 artist", e);
return TransportProtocol.Response.newBuilder()
.setStatusCode(500)
.setPayload(ByteString.copyFromUtf8("Error: " + e.getMessage()));
}
}
}
@@ -0,0 +1,62 @@
package com.mediamanager.service.delegate.handler.artist;
import com.google.protobuf.ByteString;
import com.google.protobuf.InvalidProtocolBufferException;
import com.mediamanager.protocol.TransportProtocol;
import com.mediamanager.protocol.messages.ArtistMessages;
import com.mediamanager.service.artist.ArtistService;
import com.mediamanager.service.delegate.ActionHandler;
import com.mediamanager.service.delegate.annotation.Action;
import org.apache.logging.log4j.LogManager;
import org.apache.logging.log4j.Logger;
@Action("artist.delete")
public class DeleteArtistHandler implements ActionHandler {
private static final Logger logger = LogManager.getLogger(DeleteArtistHandler.class);
private final ArtistService artistService;
public DeleteArtistHandler(ArtistService artistService) {
this.artistService = artistService;
}
@Override
public TransportProtocol.Response.Builder handle(ByteString requestPayload)
throws InvalidProtocolBufferException {
try {
ArtistMessages.DeleteArtistRequest deleteRequest =
ArtistMessages.DeleteArtistRequest.parseFrom(requestPayload);
int id = deleteRequest.getId();
boolean success = artistService.deleteArtist(id);
ArtistMessages.DeleteArtistResponse deleteResponse;
if (success) {
deleteResponse = ArtistMessages.DeleteArtistResponse.newBuilder()
.setSuccess(true)
.setMessage("Artist deleted successfully")
.build();
return TransportProtocol.Response.newBuilder()
.setPayload(deleteResponse.toByteString());
} else {
deleteResponse = ArtistMessages.DeleteArtistResponse.newBuilder()
.setSuccess(false)
.setMessage("Artist not found")
.build();
return TransportProtocol.Response.newBuilder()
.setStatusCode(404)
.setPayload(deleteResponse.toByteString());
}
} catch (Exception e) {
logger.error("Error deleting artist", e);
ArtistMessages.DeleteArtistResponse deleteResponse =
ArtistMessages.DeleteArtistResponse.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.artist;
import com.google.protobuf.ByteString;
import com.google.protobuf.InvalidProtocolBufferException;
import com.mediamanager.mapper.ArtistMapper;
import com.mediamanager.model.Artist;
import com.mediamanager.protocol.TransportProtocol;
import com.mediamanager.protocol.messages.ArtistMessages;
import com.mediamanager.service.artist.ArtistService;
import com.mediamanager.service.delegate.ActionHandler;
import com.mediamanager.service.delegate.annotation.Action;
import org.apache.logging.log4j.LogManager;
import org.apache.logging.log4j.Logger;
import java.util.Optional;
@Action(value = "artist.getById")
public class GetArtistByIdHandler implements ActionHandler {
private static final Logger logger = LogManager.getLogger(GetArtistByIdHandler.class);
private final ArtistService artistService;
public GetArtistByIdHandler(ArtistService artistService) {
this.artistService = artistService;
}
@Override
public TransportProtocol.Response.Builder handle(ByteString requestPayload)
throws InvalidProtocolBufferException{
try{
ArtistMessages.GetArtistByIdRequest getByIdRequest =
ArtistMessages.GetArtistByIdRequest.parseFrom(requestPayload);
int id = getByIdRequest.getId();
Optional<Artist> artistOpt = artistService.getArtistById(id);
if (artistOpt.isEmpty()){
logger.warn("Artist not found with ID: {}", id);
return TransportProtocol.Response.newBuilder()
.setStatusCode(404)
.setPayload(ByteString.copyFromUtf8("Artist not found"));
}
ArtistMessages.Artist artistProto = ArtistMapper.toProtobuf(artistOpt.get());
ArtistMessages.GetArtistByIdResponse getByIdResponse = ArtistMessages.GetArtistByIdResponse.newBuilder()
.setArtist(artistProto)
.build();
return TransportProtocol.Response.newBuilder()
.setPayload(getByIdResponse.toByteString());
} catch (Exception e) {
logger.error("Error getting 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.artist;
import com.google.protobuf.ByteString;
import com.google.protobuf.InvalidProtocolBufferException;
import com.mediamanager.mapper.ArtistMapper;
import com.mediamanager.model.Artist;
import com.mediamanager.protocol.TransportProtocol;
import com.mediamanager.protocol.messages.ArtistMessages;
import com.mediamanager.service.artist.ArtistService;
import com.mediamanager.service.delegate.ActionHandler;
import com.mediamanager.service.delegate.annotation.Action;
import org.apache.logging.log4j.LogManager;
import org.apache.logging.log4j.Logger;
import java.util.List;
@Action("artist.getAll")
public class GetArtistHandler implements ActionHandler {
private static final Logger logger = LogManager.getLogger(GetArtistHandler.class);
private final ArtistService artistService;
public GetArtistHandler(ArtistService artistService){this.artistService = artistService;}
@Override
public TransportProtocol.Response.Builder handle(ByteString requestPayload) throws InvalidProtocolBufferException {
try{
List<Artist> artists = artistService.getAllArtists();
ArtistMessages.GetArtistsResponse.Builder responseBuilder = ArtistMessages.GetArtistsResponse.newBuilder();
for (Artist artist : artists) {
ArtistMessages.Artist artistProto = ArtistMapper.toProtobuf(artist);
responseBuilder.addArtists(artistProto);
}
ArtistMessages.GetArtistsResponse getArtistsResponse = responseBuilder.build();
return TransportProtocol.Response.newBuilder()
.setPayload(getArtistsResponse.toByteString());
}catch (Exception e){
logger.error("Error getting artists", e);
return TransportProtocol.Response.newBuilder()
.setStatusCode(500)
.setPayload(ByteString.copyFromUtf8("Error: " + e.getMessage()));
}
}
}
@@ -0,0 +1,65 @@
package com.mediamanager.service.delegate.handler.artist;
import com.google.protobuf.ByteString;
import com.google.protobuf.InvalidProtocolBufferException;
import com.mediamanager.mapper.ArtistMapper;
import com.mediamanager.model.Artist;
import com.mediamanager.protocol.TransportProtocol;
import com.mediamanager.protocol.messages.ArtistMessages;
import com.mediamanager.service.artist.ArtistService;
import com.mediamanager.service.delegate.ActionHandler;
import com.mediamanager.service.delegate.annotation.Action;
import org.apache.logging.log4j.LogManager;
import org.apache.logging.log4j.Logger;
import java.util.Optional;
@Action("artist.update")
public class UpdateArtistHandler implements ActionHandler {
private static final Logger logger = LogManager.getLogger(UpdateArtistHandler.class);
private final ArtistService artistService;
public UpdateArtistHandler(ArtistService artistService) {
this.artistService = artistService;
}
@Override
public TransportProtocol.Response.Builder handle(ByteString requestPayload) throws InvalidProtocolBufferException {
try{
ArtistMessages.UpdateArtistRequest updateRequest =
ArtistMessages.UpdateArtistRequest.parseFrom(requestPayload);
int id = updateRequest.getId();
String newName = updateRequest.getName();
Optional<Artist> artistOpt = artistService.updateArtist(id, newName);
if(artistOpt.isEmpty()){
logger.warn("Artist not found with ID: {}", id);
return TransportProtocol.Response.newBuilder()
.setStatusCode(404)
.setPayload(ByteString.copyFromUtf8("Artist not found"));
}
ArtistMessages.Artist artistProto = ArtistMapper.toProtobuf(artistOpt.get());
ArtistMessages.UpdateArtistResponse updateResponse = ArtistMessages.UpdateArtistResponse.newBuilder()
.setArtist(artistProto)
.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 artist", e);
return TransportProtocol.Response.newBuilder()
.setStatusCode(500)
.setPayload(ByteString.copyFromUtf8("Error: " + e.getMessage()));
}
}
}
@@ -7,10 +7,12 @@ import com.mediamanager.model.Genre;
import com.mediamanager.protocol.TransportProtocol; import com.mediamanager.protocol.TransportProtocol;
import com.mediamanager.protocol.messages.GenreMessages; import com.mediamanager.protocol.messages.GenreMessages;
import com.mediamanager.service.delegate.ActionHandler; import com.mediamanager.service.delegate.ActionHandler;
import com.mediamanager.service.delegate.annotation.Action;
import com.mediamanager.service.genre.GenreService; import com.mediamanager.service.genre.GenreService;
import org.apache.logging.log4j.LogManager; import org.apache.logging.log4j.LogManager;
import org.apache.logging.log4j.Logger; import org.apache.logging.log4j.Logger;
@Action("genre.create")
public class CreateGenreHandler implements ActionHandler { public class CreateGenreHandler implements ActionHandler {
private static final Logger logger = LogManager.getLogger(CreateGenreHandler.class); private static final Logger logger = LogManager.getLogger(CreateGenreHandler.class);
@@ -5,10 +5,12 @@ import com.google.protobuf.InvalidProtocolBufferException;
import com.mediamanager.protocol.TransportProtocol; import com.mediamanager.protocol.TransportProtocol;
import com.mediamanager.protocol.messages.GenreMessages; import com.mediamanager.protocol.messages.GenreMessages;
import com.mediamanager.service.delegate.ActionHandler; import com.mediamanager.service.delegate.ActionHandler;
import com.mediamanager.service.delegate.annotation.Action;
import com.mediamanager.service.genre.GenreService; import com.mediamanager.service.genre.GenreService;
import org.apache.logging.log4j.LogManager; import org.apache.logging.log4j.LogManager;
import org.apache.logging.log4j.Logger; import org.apache.logging.log4j.Logger;
@Action("genre.delete")
public class DeleteGenreHandler implements ActionHandler { public class DeleteGenreHandler implements ActionHandler {
private static final Logger logger = LogManager.getLogger(DeleteGenreHandler.class); private static final Logger logger = LogManager.getLogger(DeleteGenreHandler.class);
@@ -7,12 +7,14 @@ import com.mediamanager.model.Genre;
import com.mediamanager.protocol.TransportProtocol; import com.mediamanager.protocol.TransportProtocol;
import com.mediamanager.protocol.messages.GenreMessages; import com.mediamanager.protocol.messages.GenreMessages;
import com.mediamanager.service.delegate.ActionHandler; import com.mediamanager.service.delegate.ActionHandler;
import com.mediamanager.service.delegate.annotation.Action;
import com.mediamanager.service.genre.GenreService; import com.mediamanager.service.genre.GenreService;
import org.apache.logging.log4j.LogManager; import org.apache.logging.log4j.LogManager;
import org.apache.logging.log4j.Logger; import org.apache.logging.log4j.Logger;
import java.util.Optional; import java.util.Optional;
@Action("genre.getById")
public class GetGenreByIdHandler implements ActionHandler { public class GetGenreByIdHandler implements ActionHandler {
private static final Logger logger = LogManager.getLogger(GetGenreByIdHandler.class); private static final Logger logger = LogManager.getLogger(GetGenreByIdHandler.class);
@@ -7,12 +7,14 @@ import com.mediamanager.model.Genre;
import com.mediamanager.protocol.TransportProtocol; import com.mediamanager.protocol.TransportProtocol;
import com.mediamanager.protocol.messages.GenreMessages; import com.mediamanager.protocol.messages.GenreMessages;
import com.mediamanager.service.delegate.ActionHandler; import com.mediamanager.service.delegate.ActionHandler;
import com.mediamanager.service.delegate.annotation.Action;
import com.mediamanager.service.genre.GenreService; import com.mediamanager.service.genre.GenreService;
import org.apache.logging.log4j.LogManager; import org.apache.logging.log4j.LogManager;
import org.apache.logging.log4j.Logger; import org.apache.logging.log4j.Logger;
import java.util.List; import java.util.List;
@Action("genre.getAll")
public class GetGenreHandler implements ActionHandler { public class GetGenreHandler implements ActionHandler {
private static final Logger logger = LogManager.getLogger(GetGenreHandler.class); private static final Logger logger = LogManager.getLogger(GetGenreHandler.class);
@@ -7,12 +7,14 @@ import com.mediamanager.model.Genre;
import com.mediamanager.protocol.TransportProtocol; import com.mediamanager.protocol.TransportProtocol;
import com.mediamanager.protocol.messages.GenreMessages; import com.mediamanager.protocol.messages.GenreMessages;
import com.mediamanager.service.delegate.ActionHandler; import com.mediamanager.service.delegate.ActionHandler;
import com.mediamanager.service.delegate.annotation.Action;
import com.mediamanager.service.genre.GenreService; import com.mediamanager.service.genre.GenreService;
import org.apache.logging.log4j.LogManager; import org.apache.logging.log4j.LogManager;
import org.apache.logging.log4j.Logger; import org.apache.logging.log4j.Logger;
import java.util.Optional; import java.util.Optional;
@Action("genre.update")
public class UpdateGenreHandler implements ActionHandler { public class UpdateGenreHandler implements ActionHandler {
private static final Logger logger = LogManager.getLogger(UpdateGenreHandler.class); private static final Logger logger = LogManager.getLogger(UpdateGenreHandler.class);
+53
View File
@@ -0,0 +1,53 @@
syntax = "proto3";
option java_package = "com.mediamanager.protocol.messages";
option java_outer_classname = "ArtistMessages";
package mediamanager.messages;
message Artist {
int32 id = 1;
string name = 2;
}
message CreateArtistRequest {
string name = 1;
}
message CreateArtistResponse {
Artist artist = 1;
}
message GetArtistsRequest {
}
message GetArtistsResponse {
repeated Artist artists = 1;
}
message GetArtistByIdRequest {
int32 id = 1;
}
message GetArtistByIdResponse {
Artist artist = 1;
}
message UpdateArtistRequest {
int32 id = 1;
string name = 2; // Novo nome
}
message UpdateArtistResponse {
Artist Artist = 1;
}
message DeleteArtistRequest {
int32 id = 1;
}
message DeleteArtistResponse {
bool success = 1;
string message = 2;
}