G2pc-registry changes

.gitignore

@@ -22,3 +22,6 @@
 # virtual machine crash logs, see http://www.java.com/en/download/help/error_hotspot.xml
 hs_err_pid*
 replay_pid*
+
+.vscode/
+.idea/

g2pc-core-lib/.gitignore

@@ -0,0 +1,36 @@
+HELP.md
+target/
+!.mvn/wrapper/maven-wrapper.jar
+!**/src/main/**/target/
+!**/src/test/**/target/
+
+### STS ###
+.apt_generated
+.classpath
+.factorypath
+.project
+.settings
+.springBeans
+.sts4-cache
+mvnw
+mvnw.cmd
+### IntelliJ IDEA ###
+.idea
+*.iws
+*.iml
+*.ipr
+
+### NetBeans ###
+/nbproject/private/
+/nbbuild/
+/dist/
+/nbdist/
+/.nb-gradle/
+build/
+!**/src/main/**/build/
+!**/src/test/**/build/
+
+### VS Code ###
+.vscode/
+.idea/
+

g2pc-core-lib/README.md

@@ -0,0 +1,73 @@
+# G2pc Core Lib
+
+## JSON schema validations 
+This project is an implementation of the JSON Schema Draft v4, 
+
+### When to use Json schema
+Let'+s assume that you already know what JSON Schema is, 
+and you want to utilize it in a Java application to validate JSON data. But - as you may have already discovered - there is also an other Java implementation of the JSON Schema specification. So here are some advices about which one to use:
+
+1. if you use Jackson to handle JSON in Java code, then java-json-tools/json-schema-validator is obviously a better choice, since it uses Jackson
+2. if you want to use the org.json API then this library is the better choice
+3. if you need JSON Schema Draft 6 / 7 support, then you need this library.
+
+### Maven Dependency 
+````
+<dependency>
+	<groupId>com.github.erosb</groupId>
+	<artifactId>everit-json-schema</artifactId>
+	<version>1.14.2</version>
+</dependency>
+````
+
+### Where we used the json schema
+* We have 2 end-points , /search and /on-search. 
+* In these end-points we are receiving 2 payloads respectively.
+* Each payload had header and message.
+* We are using JSON schema to validate the header and message as per G2p specifications. 
+
+#### Below are some samples schema which written in this project.
+````
+{
+  "$schema": "https://json-schema.org/draft-04/schema#",
+  "$id": "https://example.com/message.schema.json",
+  "title": "header schema",
+  "description": "",
+  "additionalProperties": false,
+  "type": "object",
+  "properties": {
+    "type": {
+      "type": "string"
+    },
+    "version" : {
+      "type": [ "string", "null" ]
+    },
+    },
+    "total_count": {
+      "type": "number"
+    },
+    "is_msg_encrypted": {
+      "type": ["boolean","null"],
+      "default": "false"
+    },
+    "meta": {
+      "type": [ "object", "null" ]
+    }
+  },
+  "required": ["message_id","message_ts","action","sender_id","total_count"],
+  "definitions": {
+    "nonEmptyString": {
+      "type": "string",
+      "minLength": 1
+    }
+  }
+}
+````
+
+Using below code we can read the above schema json
+````
+InputStream schemaStream = CommonUtils.class.getClassLoader()
+                .getResourceAsStream("schema/ResponseMessageschema.json");
+````
+
+

g2pc-core-lib/pom.xml

@@ -0,0 +1,119 @@
+<?xml version="1.0" encoding="UTF-8"?>
+<project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
+         xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 https://maven.apache.org/xsd/maven-4.0.0.xsd">
+    <modelVersion>4.0.0</modelVersion>
+    <parent>
+        <groupId>org.springframework.boot</groupId>
+        <artifactId>spring-boot-starter-parent</artifactId>
+        <version>3.0.12</version>
+        <relativePath/> <!-- lookup parent from repository -->
+    </parent>
+    <groupId>g2pc.core.lib</groupId>
+    <artifactId>g2pc-core-library</artifactId>
+    <version>0.0.1-SNAPSHOT</version>
+    <name>g2p-core</name>
+    <description>Common-g2pc-specifications-library</description>
+    <properties>
+        <java.version>17</java.version>
+    </properties>
+    <dependencies>
+        <dependency>
+            <groupId>org.projectlombok</groupId>
+            <artifactId>lombok</artifactId>
+            <optional>true</optional>
+        </dependency>
+        <dependency>
+            <groupId>com.fasterxml.jackson.dataformat</groupId>
+            <artifactId>jackson-dataformat-xml</artifactId>
+            <version>2.15.0</version>
+        </dependency>
+        <dependency>
+            <groupId>org.springframework.boot</groupId>
+            <artifactId>spring-boot-starter-web</artifactId>
+        </dependency>
+        <dependency>
+            <groupId>org.yaml</groupId>
+            <artifactId>snakeyaml</artifactId>
+            <version>2.2</version>
+        </dependency>
+        <dependency>
+            <groupId>com.networknt</groupId>
+            <artifactId>json-schema-validator</artifactId>
+            <version>1.0.82</version>
+        </dependency>
+        <dependency>
+            <groupId>javax.validation</groupId>
+            <artifactId>validation-api</artifactId>
+            <version>2.0.1.Final</version>
+        </dependency>
+        <dependency>
+            <groupId>javax.annotation</groupId>
+            <artifactId>javax.annotation-api</artifactId>
+            <version>1.3.2</version>
+        </dependency>
+        <dependency>
+            <groupId>org.springframework.security</groupId>
+            <artifactId>spring-security-web</artifactId>
+            <version>6.2.0</version>
+        </dependency>
+        <dependency>
+            <groupId>com.auth0</groupId>
+            <artifactId>java-jwt</artifactId>
+            <version>4.4.0</version>
+        </dependency>
+        <dependency>
+            <groupId>jakarta.validation</groupId>
+            <artifactId>jakarta.validation-api</artifactId>
+            <version>3.0.2</version>
+        </dependency>
+        <dependency>
+            <groupId>org.springframework.security</groupId>
+            <artifactId>spring-security-config</artifactId>
+            <version>6.1.2</version>
+        </dependency>
+        <dependency>
+            <groupId>com.konghq</groupId>
+            <artifactId>unirest-java</artifactId>
+            <version>3.14.2</version>
+        </dependency>
+        <dependency>
+            <groupId>redis.clients</groupId>
+            <artifactId>jedis</artifactId>
+            <version>5.0.0-alpha2</version>
+            <type>jar</type>
+        </dependency>
+        <dependency>
+            <groupId>org.springframework.boot</groupId>
+            <artifactId>spring-boot-starter-data-redis</artifactId>
+        </dependency>
+        <dependency>
+            <groupId>org.apache.commons</groupId>
+            <artifactId>commons-lang3</artifactId>
+            <version>3.14.0</version>
+        </dependency>
+
+        <dependency>
+            <groupId>com.jcraft</groupId>
+            <artifactId>jsch</artifactId>
+            <version>0.1.55</version>
+        </dependency>
+        <dependency>
+            <groupId>org.springframework.integration</groupId>
+            <artifactId>spring-integration-sftp</artifactId>
+        </dependency>
+        <dependency>
+            <groupId>org.springframework.integration</groupId>
+            <artifactId>spring-integration-core</artifactId>
+        </dependency>
+        <dependency>
+            <groupId>org.apache.commons</groupId>
+            <artifactId>commons-csv</artifactId>
+            <version>1.10.0</version>
+        </dependency>
+        <dependency>
+            <groupId>org.elasticsearch.client</groupId>
+            <artifactId>elasticsearch-rest-high-level-client</artifactId>
+            <version>7.10.2</version>
+        </dependency>
+    </dependencies>
+</project>

g2pc-core-lib/src/main/java/g2pc/core/lib/config/ElasticsearchConfig.java

@@ -0,0 +1,30 @@
+package g2pc.core.lib.config;
+
+import org.apache.http.HttpHost;
+import org.elasticsearch.client.RestClient;
+import org.elasticsearch.client.RestHighLevelClient;
+import org.springframework.beans.factory.annotation.Value;
+import org.springframework.context.annotation.Bean;
+import org.springframework.context.annotation.Configuration;
+
+@Configuration
+public class ElasticsearchConfig {
+
+    @Value("${sunbird.elasticsearch.host}")
+    private String elasticsearchHost;
+
+    @Value("${sunbird.elasticsearch.port}")
+    private int elasticsearchPort;
+
+    @Value("${sunbird.elasticsearch.scheme}")
+    private String elasticsearchScheme;
+
+    @Bean
+    public RestHighLevelClient client() {
+        return new RestHighLevelClient(
+                RestClient.builder(
+                        new HttpHost(elasticsearchHost, elasticsearchPort, elasticsearchScheme)
+                )
+        );
+    }
+}

g2pc-core-lib/src/main/java/g2pc/core/lib/config/G2pUnirest.java

@@ -0,0 +1,23 @@
+package g2pc.core.lib.config;
+
+
+import kong.unirest.GetRequest;
+import kong.unirest.HttpRequestWithBody;
+import kong.unirest.UnirestException;
+
+public interface G2pUnirest {
+
+    String getG2pApiCall(String uri, String token) throws UnirestException;
+
+    String getG2pApiCall(String uri) throws UnirestException;
+
+    HttpRequestWithBody g2pPost(String uri);
+
+    HttpRequestWithBody g2pPut(String uri);
+
+    HttpRequestWithBody g2pDelete(String uri);
+
+    HttpRequestWithBody g2pPatch(String uri);
+
+    GetRequest g2pGet(String uri);
+}

g2pc-core-lib/src/main/java/g2pc/core/lib/config/G2pUnirestHelper.java

@@ -0,0 +1,82 @@
+package g2pc.core.lib.config;
+
+
+import g2pc.core.lib.security.context.UnirestContext;
+import kong.unirest.GetRequest;
+import kong.unirest.HttpRequestWithBody;
+import kong.unirest.Unirest;
+import kong.unirest.UnirestException;
+import lombok.extern.slf4j.Slf4j;
+import org.apache.commons.lang3.StringUtils;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.context.annotation.Configuration;
+import org.springframework.context.annotation.Lazy;
+import org.springframework.scheduling.annotation.EnableScheduling;
+
+import java.util.Collections;
+import java.util.Map;
+
+@Configuration
+@Slf4j
+@EnableScheduling
+@Lazy
+public class G2pUnirestHelper implements G2pUnirest {
+
+    private static final String AUTH = "Authorization";
+
+
+    protected GetRequest setG2pHeaders(GetRequest request) {
+        return setG2pHeaders(request, Collections.emptyMap());
+    }
+
+    protected GetRequest setG2pHeaders(GetRequest request, Map<String, String> keyVal) {
+        if (null != keyVal)
+            keyVal.forEach((k, v) -> request.header(k, v));
+        return request;
+    }
+
+    protected HttpRequestWithBody setG2pHeaders(HttpRequestWithBody request) {
+        UnirestContext unirestContext = new UnirestContext();
+        if (null != unirestContext && StringUtils.isNotBlank(unirestContext.getJwtHeader())) {
+            request.header(AUTH, unirestContext.getJwtHeader());
+        }
+        return request;
+    }
+
+    public String getG2pApiCall(String uri, String token) throws UnirestException {
+
+        return setG2pHeaders(Unirest.get(uri), Map.of(AUTH, "Bearer " + token))
+                .asString()
+                .getBody();
+
+    }
+
+    public String getG2pApiCall(String uri) throws UnirestException {
+
+        return setG2pHeaders(Unirest.get(uri))
+                .asString()
+                .getBody();
+
+    }
+
+    public HttpRequestWithBody g2pPost(String uri) {
+        return setG2pHeaders(Unirest.post(uri));
+    }
+
+    public HttpRequestWithBody g2pPut(String uri) {
+        return setG2pHeaders(Unirest.put(uri));
+    }
+
+    public HttpRequestWithBody g2pDelete(String uri) {
+        return setG2pHeaders(Unirest.delete(uri));
+    }
+
+    public HttpRequestWithBody g2pPatch(String uri) {
+        return setG2pHeaders(Unirest.patch(uri));
+    }
+
+    public GetRequest g2pGet(String uri) {
+        return setG2pHeaders(Unirest.get(uri));
+    }
+
+}