diff --git a/local-rest-scorer/src/main/java/ai/h2o/mojos/deploy/local/rest/Converter/ScoreMediaRequestConverter.java b/local-rest-scorer/src/main/java/ai/h2o/mojos/deploy/local/rest/Converter/ScoreMediaRequestConverter.java deleted file mode 100644 index 97b78b20..00000000 --- a/local-rest-scorer/src/main/java/ai/h2o/mojos/deploy/local/rest/Converter/ScoreMediaRequestConverter.java +++ /dev/null @@ -1,13 +0,0 @@ -package ai.h2o.mojos.deploy.local.rest.Converter; - -import ai.h2o.mojos.deploy.common.rest.v2.model.ScoreMediaRequest; -import com.google.gson.Gson; -import org.springframework.core.convert.converter.Converter; - -public class ScoreMediaRequestConverter implements Converter { - - @Override - public ScoreMediaRequest convert(String input) { - return new Gson().fromJson(input, ScoreMediaRequest.class); - } -} diff --git a/local-rest-scorer/src/main/java/ai/h2o/mojos/deploy/local/rest/config/WebConfig.java b/local-rest-scorer/src/main/java/ai/h2o/mojos/deploy/local/rest/config/WebConfig.java index 3461bfce..4f959c99 100644 --- a/local-rest-scorer/src/main/java/ai/h2o/mojos/deploy/local/rest/config/WebConfig.java +++ b/local-rest-scorer/src/main/java/ai/h2o/mojos/deploy/local/rest/config/WebConfig.java @@ -6,11 +6,12 @@ import org.springframework.format.FormatterRegistry; import org.springframework.web.servlet.config.annotation.WebMvcConfigurer; +@Configuration public class WebConfig implements WebMvcConfigurer { - @Override - public void addFormatters(FormatterRegistry registry) { - registry.addConverter(new MultipartConverter()); - registry.addConverter(new ScoreMediaRequestConverter()); - } + @Override + public void addFormatters(FormatterRegistry registry) { + registry.addConverter(new MultipartConverter()); + registry.addConverter(new ScoreMediaRequestConverter()); + } } diff --git a/local-rest-scorer/src/main/java/ai/h2o/mojos/deploy/local/rest/controller/ModelsApiController.java b/local-rest-scorer/src/main/java/ai/h2o/mojos/deploy/local/rest/controller/ModelsApiController.java index e2834cfb..f6fd49fb 100644 --- a/local-rest-scorer/src/main/java/ai/h2o/mojos/deploy/local/rest/controller/ModelsApiController.java +++ b/local-rest-scorer/src/main/java/ai/h2o/mojos/deploy/local/rest/controller/ModelsApiController.java @@ -20,7 +20,6 @@ import org.slf4j.Logger; import org.slf4j.LoggerFactory; import org.springframework.beans.factory.annotation.Autowired; -import org.springframework.core.io.Resource; import org.springframework.http.HttpStatus; import org.springframework.http.ResponseEntity; import org.springframework.stereotype.Controller; @@ -157,13 +156,6 @@ public ResponseEntity getSampleRequest() { return ResponseEntity.ok(sampleRequestBuilder.build(scorer.getPipeline().getInputMeta())); } - @Override - public ResponseEntity getScoreMedia( - ScoreMediaRequest scoreMediaRequest, List files) { - log.info("Received score media request"); - return ResponseEntity.status(HttpStatus.NOT_IMPLEMENTED).build(); - } - private String getScorerModelId() { try { String res = System.getenv(MODEL_ID); diff --git a/local-rest-scorer/src/main/java/ai/h2o/mojos/deploy/local/rest/controller/ModelsMediaController.java b/local-rest-scorer/src/main/java/ai/h2o/mojos/deploy/local/rest/controller/ModelsMediaController.java new file mode 100644 index 00000000..0cc7aa75 --- /dev/null +++ b/local-rest-scorer/src/main/java/ai/h2o/mojos/deploy/local/rest/controller/ModelsMediaController.java @@ -0,0 +1,26 @@ +package ai.h2o.mojos.deploy.local.rest.controller; + +import ai.h2o.mojos.deploy.common.rest.v1exp.api.ModelApi; +import ai.h2o.mojos.deploy.common.rest.v1exp.model.ScoreMediaRequest; +import ai.h2o.mojos.deploy.common.rest.v1exp.model.ScoreResponse; +import java.util.List; +import org.slf4j.Logger; +import org.slf4j.LoggerFactory; +import org.springframework.core.io.Resource; +import org.springframework.http.HttpStatus; +import org.springframework.http.ResponseEntity; +import org.springframework.stereotype.Controller; +import org.springframework.web.server.ResponseStatusException; + +@Controller +public class ModelsMediaController implements ModelApi { + private static final Logger log = LoggerFactory.getLogger(ModelsMediaController.class); + + @Override + public ResponseEntity getMediaScore( + ScoreMediaRequest request, List files) { + log.info("Got score media request"); + throw new ResponseStatusException(HttpStatus.NOT_IMPLEMENTED, + "score media files is not implemented"); + } +} diff --git a/local-rest-scorer/src/main/java/ai/h2o/mojos/deploy/local/rest/Converter/MultipartConverter.java b/local-rest-scorer/src/main/java/ai/h2o/mojos/deploy/local/rest/converter/MultipartConverter.java similarity index 60% rename from local-rest-scorer/src/main/java/ai/h2o/mojos/deploy/local/rest/Converter/MultipartConverter.java rename to local-rest-scorer/src/main/java/ai/h2o/mojos/deploy/local/rest/converter/MultipartConverter.java index 6d616fad..b385dc7e 100644 --- a/local-rest-scorer/src/main/java/ai/h2o/mojos/deploy/local/rest/Converter/MultipartConverter.java +++ b/local-rest-scorer/src/main/java/ai/h2o/mojos/deploy/local/rest/converter/MultipartConverter.java @@ -1,4 +1,4 @@ -package ai.h2o.mojos.deploy.local.rest.Converter; +package ai.h2o.mojos.deploy.local.rest.converter; import org.springframework.core.convert.converter.Converter; import org.springframework.core.io.Resource; @@ -6,8 +6,8 @@ public class MultipartConverter implements Converter { - @Override - public Resource convert(MultipartFile source) { - return source.getResource(); - } + @Override + public Resource convert(MultipartFile source) { + return source.getResource(); + } } diff --git a/local-rest-scorer/src/main/java/ai/h2o/mojos/deploy/local/rest/converter/ScoreMediaRequestConverter.java b/local-rest-scorer/src/main/java/ai/h2o/mojos/deploy/local/rest/converter/ScoreMediaRequestConverter.java new file mode 100644 index 00000000..b30f1181 --- /dev/null +++ b/local-rest-scorer/src/main/java/ai/h2o/mojos/deploy/local/rest/converter/ScoreMediaRequestConverter.java @@ -0,0 +1,13 @@ +package ai.h2o.mojos.deploy.local.rest.converter; + +import ai.h2o.mojos.deploy.common.rest.v1exp.model.ScoreMediaRequest; +import com.google.gson.Gson; +import org.springframework.core.convert.converter.Converter; + +public class ScoreMediaRequestConverter implements Converter { + + @Override + public ScoreMediaRequest convert(String input) { + return new Gson().fromJson(input, ScoreMediaRequest.class); + } +} diff --git a/local-rest-scorer/src/test/java/ai/h2o/mojos/deploy/local/rest/controller/ModelsApiControllerTest.java b/local-rest-scorer/src/test/java/ai/h2o/mojos/deploy/local/rest/controller/ModelsApiControllerTest.java index 41e28b7c..64f5a716 100644 --- a/local-rest-scorer/src/test/java/ai/h2o/mojos/deploy/local/rest/controller/ModelsApiControllerTest.java +++ b/local-rest-scorer/src/test/java/ai/h2o/mojos/deploy/local/rest/controller/ModelsApiControllerTest.java @@ -11,6 +11,7 @@ import ai.h2o.mojos.deploy.common.rest.model.Model; import ai.h2o.mojos.deploy.common.rest.model.ScoreRequest; import ai.h2o.mojos.deploy.common.rest.model.ScoreResponse; +import ai.h2o.mojos.deploy.common.rest.v1exp.model.ScoreMediaRequest; import ai.h2o.mojos.deploy.common.transform.MojoScorer; import ai.h2o.mojos.deploy.common.transform.SampleRequestBuilder; import ai.h2o.mojos.deploy.common.transform.ShapleyLoadOption; @@ -193,16 +194,17 @@ void verifyScore_Fails_ReturnsException() { @Test void verifyScoreMedia_ReturnsUnimplemented() { // Given - MojoScorer scorer = mock(MojoScorer.class); ScoreMediaRequest request = mock(ScoreMediaRequest.class); List files = new ArrayList<>(); - ModelsApiControllerV1Exp controller = new ModelsApiController(scorer, sampleRequestBuilder); - - // When - ResponseEntity response = - controller.getScoreMedia(request, files); + ModelsMediaController controller = new ModelsMediaController(); - // Then - assertEquals(response.getStatusCode(), HttpStatus.NOT_IMPLEMENTED); + // When & Then + try { + controller.getMediaScore(request, files); + fail("exception is expected, but fail to raise"); + } catch (Exception ex) { + assertTrue(ex instanceof ResponseStatusException); + assertEquals(HttpStatus.NOT_IMPLEMENTED, ((ResponseStatusException) ex).getStatus()); + } } }