Merge remote-tracking branch 'origin/JAVA-45628_1' into JAVA-45628_1

Author: Bipinkumar27

algorithms-modules/algorithms-numeric/src/test/java/com/baeldung/algorithms/consecutivenumbers/ConsecutiveNumbersUnitTest.java

@@ -0,0 +1,31 @@
+package com.baeldung.algorithms.consecutivenumbers;
+
+import org.junit.jupiter.api.Test;
+import static org.junit.jupiter.api.Assertions.assertTrue;
+
+public class ConsecutiveNumbersUnitTest {
+
+    @Test
+    void whenIsSumOfConsecutiveUsingBruteForce_thenReturnsTrue() {
+        int n = 15;
+
+        boolean isSumOfConsecutive = false;
+        for (int k = 2; (k * (k - 1)) / 2 < n; k++) {
+            int diff = n - k * (k - 1) / 2;
+            if (diff % k == 0 && diff / k > 0) {
+                isSumOfConsecutive = true;
+                break;
+            }
+        }
+
+        assertTrue(isSumOfConsecutive);
+    }
+
+    @Test
+    void whenIsSumOfConsecutiveUsingBitwise_thenReturnsTrue() {
+        int n = 15;
+        boolean result = (n > 0) && ((n & (n - 1)) != 0);
+        assertTrue(result);
+    }
+
+}

apache-libraries-3/pom.xml

@@ -6,8 +6,6 @@
     <artifactId>apache-libraries-3</artifactId>
     <version>0.0.1-SNAPSHOT</version>
     <name>apache-libraries-3</name>
-
-
     <parent>
         <groupId>com.baeldung</groupId>
         <artifactId>parent-modules</artifactId>
@@ -44,6 +42,36 @@
             <artifactId>jackson-dataformat-avro</artifactId>
             <version>${jackson.version}</version>
         </dependency>
+        <dependency>
+            <groupId>org.apache.camel</groupId>
+            <artifactId>camel-jackson</artifactId>
+            <version>${camel.version}</version>
+        </dependency>
+        <dependency>
+            <groupId>com.graphql-java</groupId>
+            <artifactId>graphql-java</artifactId>
+            <version>${graphql.version}</version>
+        </dependency>
+        <dependency>
+            <groupId>org.apache.camel</groupId>
+            <artifactId>camel-core</artifactId>
+            <version>${camel.version}</version>
+        </dependency>
+        <dependency>
+            <groupId>org.apache.camel</groupId>
+            <artifactId>camel-jetty</artifactId>
+            <version>${camel.version}</version>
+        </dependency>
+        <dependency>
+            <groupId>org.apache.camel</groupId>
+            <artifactId>camel-http</artifactId>
+            <version>${camel.version}</version>
+        </dependency>
+        <dependency>
+            <groupId>org.apache.camel</groupId>
+            <artifactId>camel-graphql</artifactId>
+            <version>${camel.version}</version>
+        </dependency>
 
     </dependencies>
 
@@ -53,6 +81,8 @@
         <maven.compiler.target>17</maven.compiler.target>
         <avro.version>1.11.3</avro.version>
         <json-unit-assertj.version>3.5.0</json-unit-assertj.version>
+        <graphql.version>23.1</graphql.version>
+        <camel.version>4.11.0</camel.version>
     </properties>
 
 </project>

apache-libraries-3/src/main/java/com/baeldung/apache/camel/Book.java

@@ -0,0 +1,41 @@
+package com.baeldung.apache.camel;
+
+public class Book {
+
+    private String id;
+    private String title;
+    private String author;
+
+    public String getId() {
+        return id;
+    }
+
+    public void setId(String id) {
+        this.id = id;
+    }
+
+    public String getTitle() {
+        return title;
+    }
+
+    public void setTitle(String title) {
+        this.title = title;
+    }
+
+    public String getAuthor() {
+        return author;
+    }
+
+    public void setAuthor(String author) {
+        this.author = author;
+    }
+
+    public Book(String id, String title, String author) {
+        this.id = id;
+        this.title = title;
+        this.author = author;
+    }
+
+    public Book() {
+    }
+}

apache-libraries-3/src/main/java/com/baeldung/apache/camel/BookRoute.java

@@ -0,0 +1,95 @@
+package com.baeldung.apache.camel;
+
+import java.io.ByteArrayOutputStream;
+import java.io.IOException;
+import java.nio.charset.StandardCharsets;
+import java.util.Map;
+
+import org.apache.camel.Exchange;
+import org.apache.camel.builder.RouteBuilder;
+import org.apache.camel.component.jackson.JacksonDataFormat;
+import org.apache.camel.converter.stream.InputStreamCache;
+import org.apache.camel.model.dataformat.JsonLibrary;
+import org.apache.camel.model.rest.RestBindingMode;
+import org.apache.camel.spi.RestConfiguration;
+
+import com.fasterxml.jackson.core.JsonParseException;
+import com.fasterxml.jackson.databind.ObjectMapper;
+import com.fasterxml.jackson.databind.exc.MismatchedInputException;
+
+import graphql.ExecutionInput;
+import graphql.ExecutionResult;
+import graphql.GraphQL;
+import graphql.schema.GraphQLSchema;
+
+public class BookRoute extends RouteBuilder {
+
+    private final BookService bookService = new BookService();
+
+    @Override
+    public void configure() throws Exception {
+        JacksonDataFormat jsonDataFormat = new JacksonDataFormat(Map.class);
+        jsonDataFormat.setUnmarshalType(Object.class);
+
+        onException(Exception.class).handled(true)
+            .setHeader("Content-Type", constant("application/json"))
+            .setBody(simple("{\"error\": \"${exception.message}\"}"));
+
+        onException(IllegalArgumentException.class)
+            .handled(true)
+            .setHeader(Exchange.CONTENT_TYPE, constant("application/json"))
+            .setHeader(Exchange.HTTP_RESPONSE_CODE, constant(400))
+            .setBody(simple("{\"error\": \"${exception.message}\"}"));
+
+        onException(JsonParseException.class)
+            .handled(true)
+            .setHeader(Exchange.HTTP_RESPONSE_CODE, constant(400))
+            .setBody(simple("{\"error\": \"Invalid JSON: ${exception.message}\"}"));
+
+        restConfiguration().component("jetty")
+            .host("localhost")
+            .port(8088)
+            .contextPath("/api")
+            .bindingMode(RestBindingMode.json)
+            .dataFormatProperty("prettyPrint", "true");
+
+        rest("/books")
+            .get().to("direct:getAllBooks")
+            .get("/{id}").to("direct:getBookById")
+            .post()
+                .consumes("application/json")
+                .type(Book.class)
+                .to("direct:addBook");
+
+        from("direct:getAllBooks").bean(bookService, "getBooks");
+        from("direct:getBookById").bean(bookService, "getBookById(${header.id})");
+        from("direct:addBook").bean(bookService, "addBook");
+
+        GraphQLSchema schema = new CustomSchemaLoader().loadSchema();
+        GraphQL graphQL = GraphQL.newGraphQL(schema).build();
+
+        from("jetty:http://localhost:8088/graphql?matchOnUriPrefix=true")
+            .log("Received GraphQL request: ${body}")
+            .convertBodyTo(String.class)
+            .process(exchange -> {
+                String body = exchange.getIn().getBody(String.class);
+                try {
+                    Map<String, Object> payload = new ObjectMapper().readValue(body, Map.class);
+                    String query = (String) payload.get("query");
+                    if (query == null || query.trim().isEmpty()) {
+                        throw new IllegalArgumentException("Missing 'query' field in request body");
+                    }
+                    ExecutionInput executionInput = ExecutionInput.newExecutionInput()
+                        .query(query)
+                        .build();
+                    ExecutionResult result = graphQL.execute(executionInput);
+                    Map<String, Object> response = result.toSpecification();
+                    exchange.getIn().setBody(response);
+                } catch (Exception e) {
+                    throw new RuntimeException("GraphQL processing error", e);
+                }
+            })
+            .marshal().json(JsonLibrary.Jackson)
+            .setHeader(Exchange.CONTENT_TYPE, constant("application/json"));
+    }
+}

apache-libraries-3/src/main/java/com/baeldung/apache/camel/BookService.java

@@ -0,0 +1,31 @@
+package com.baeldung.apache.camel;
+
+import java.util.ArrayList;
+import java.util.List;
+
+public class BookService {
+
+    private final List<Book> books = new ArrayList<>();
+
+    public BookService() {
+        books.add(new Book("1", "Clean Code", "Robert"));
+        books.add(new Book("2", "Effective Java", "Joshua"));
+    }
+
+    public List<Book> getBooks() {
+        return books;
+    }
+
+    public Book getBookById(String id) {
+        return books.stream()
+            .filter(b -> b.getId()
+                .equals(id))
+            .findFirst()
+            .orElse(null);
+    }
+
+    public Book addBook(Book book) {
+        books.add(book);
+        return book;
+    }
+}

apache-libraries-3/src/main/java/com/baeldung/apache/camel/CamelRestGraphQLApp.java

@@ -0,0 +1,21 @@
+package com.baeldung.apache.camel;
+
+import org.apache.camel.CamelContext;
+import org.apache.camel.impl.DefaultCamelContext;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+
+import graphql.GraphQL;
+import graphql.schema.GraphQLSchema;
+
+public class CamelRestGraphQLApp {
+    private static final Logger logger = LoggerFactory.getLogger(CamelRestGraphQLApp.class);
+    public static void main(String[] args) throws Exception {
+        CamelContext context = new DefaultCamelContext();
+        context.addRoutes(new BookRoute());
+        context.start();
+        logger.info("Server running at http://localhost:8088");
+        Thread.sleep(Long.MAX_VALUE);
+        context.stop();
+    }
+}

apache-libraries-3/src/main/java/com/baeldung/apache/camel/CustomSchemaLoader.java

@@ -0,0 +1,55 @@
+package com.baeldung.apache.camel;
+
+import java.io.InputStream;
+import java.io.InputStreamReader;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+import graphql.schema.GraphQLSchema;
+import graphql.schema.idl.RuntimeWiring;
+import graphql.schema.idl.SchemaGenerator;
+import graphql.schema.idl.SchemaParser;
+import graphql.schema.idl.TypeDefinitionRegistry;
+
+public class CustomSchemaLoader {
+
+    private static final Logger logger = LoggerFactory.getLogger(CustomSchemaLoader.class);
+    private final BookService bookService = new BookService();
+
+    public GraphQLSchema loadSchema() {
+        logger.debug("Attempting to load schema");
+        try (InputStream schemaStream = getClass().getClassLoader().getResourceAsStream("books.graphql")) {
+            if (schemaStream == null) {
+                throw new RuntimeException("GraphQL schema file 'books.graphql' not found in classpath");
+            }
+            logger.debug("Schema file found. Parsing...");
+            TypeDefinitionRegistry registry = new SchemaParser()
+                .parse(new InputStreamReader(schemaStream));
+
+            RuntimeWiring wiring = buildRuntimeWiring();
+
+            return new SchemaGenerator().makeExecutableSchema(registry, wiring);
+
+        } catch (Exception e) {
+            logger.error("Failed to load GraphQL schema", e);
+            throw new RuntimeException("GraphQL schema initialization failed", e);
+        }
+    }
+
+    private RuntimeWiring buildRuntimeWiring() {
+        return RuntimeWiring.newRuntimeWiring()
+            .type("Query", builder -> builder
+                .dataFetcher("books", env -> bookService.getBooks())
+                .dataFetcher("bookById", env -> bookService.getBookById(env.getArgument("id"))))
+            .type("Mutation", builder -> builder
+                .dataFetcher("addBook", env -> {
+                    String id = env.getArgument("id");
+                    String title = env.getArgument("title");
+                    String author = env.getArgument("author");
+                    if (title == null || title.isEmpty()) {
+                        throw new IllegalArgumentException("Title cannot be empty");
+                    }
+                    return bookService.addBook(new Book(id, title, author));
+                }))
+            .build();
+    }
+}

apache-libraries-3/src/main/resources/books.graphql

@@ -0,0 +1,14 @@
+type Book {
+    id: String!
+    title: String!
+    author: String
+}
+
+type Query {
+    books: [Book]
+    bookById(id: String!): Book
+}
+
+type Mutation {
+    addBook(id: String!, title: String!, author: String): Book
+}