Package com.eka.middleware.service

Class ServiceUtils

java.lang.Object

com.eka.middleware.service.ServiceUtils

public class ServiceUtils
extends Object

Field Summary

Fields

Modifier and Type	Field	Description
static org.apache.logging.log4j.Logger	LOGGER
static final com.fasterxml.jackson.dataformat.xml.XmlMapper	xmlMapper
static final com.fasterxml.jackson.dataformat.yaml.YAMLMapper	yamlMapper

Constructor Summary

Constructors

Constructor	Description
ServiceUtils()

Method Summary

Modifier and Type	Method	Description
static Date	addHoursToDate(Date date, int hours)
static void	afterServiceExecution(DataPipeline dp, String fqn, Map<String,Object> passThroughData)
static boolean	areBracesBalanced(String input)
static void	beforeServiceExecution(DataPipeline dp, String fqn, Map<String,Object> passThroughData)
static void	clearSession(io.undertow.server.HttpServerExchange exchange)
static final void	compileJavaCode(String fqn, DataPipeline dataPipeLine)
static byte[]	compress(byte[] data)
static Object	convertPolyglotValue(org.graalvm.polyglot.Value value)
static void	copyDirectory(String sourceDirectoryLocation, String destinationDirectoryLocation)
static Map<String,Object>	decodeJWT(String jwtToken)
static byte[]	deCompress(byte[] data)
static String	decrypt(String strToDecrypt, String tenantName)
static final String	deleteURLAlias(String alias, DataPipeline dp)
static String	encrypt(String strToEncrypt, String tenantName)
static final void	execute(String fqn, DataPipeline dataPipeLine)
static final void	executeEmbeddedService(DataPipeline dataPipeline, String apiServiceJson)
static final Map<String,Object>	extractHeaders(io.undertow.server.HttpServerExchange exchange)
static com.nimbusds.openid.connect.sdk.op.OIDCProviderMetadata	fetchMetadata(String discoveryUrl, com.nimbusds.jose.JWSAlgorithm jwsAlgo)
static final String	generateUUID(String msg)
static byte[]	getBody(DataPipeline dataPipeLine)
static final InputStream	getBodyAsStream(DataPipeline dataPipeLine)
static Object	getCaseInsensitiveKey(Map<String,Object> map, String key)
static final URL[]	getClassesURLs(String path)
static AuthAccount	getCurrentLoggedInAuthAccount(io.undertow.server.HttpServerExchange exchange)
static org.pac4j.core.profile.UserProfile	getCurrentLoggedInUserProfile(io.undertow.server.HttpServerExchange exchange)
static Object	getExceptionMap(Exception e)
static final String	getFormattedLogLine(String id, String resource, String info)
static final Map<String,Object>	getFormattedLogMap(String id, String resource, String info)
static final String[]	getJarPaths(String path, String packagePath)
static SecretKeySpec	getKey(String myKey)
static final MultiPart	getMultiPart(DataPipeline dataPipeLine)
static final String	getPathService(String requestPath, Map<String,Object> payload, Tenant tenant)
static String	getSeparator()
static final String	getServerProperty(String key)
static String	getTenantName(io.undertow.server.handlers.Cookie cookie)
static String	getToken(io.undertow.server.handlers.Cookie cookie)
static final String	getURLAlias(String fqn, Tenant tenant)
static String	initNewTenant(String name, AuthAccount account, String password)
static boolean	isApiCall(io.undertow.server.HttpServerExchange exchange)
static boolean	isMac()
static final boolean	isPublicFolder(String path)
static boolean	isSolaris()
static boolean	isUnix()
static boolean	isValid(String token)
static boolean	isWindows()
static final Map<String,Object>	jsonToMap(String json)
static void	loadCustomJar(DataPipeline dp, String path)
static void	loadCustomJar(DataPipeline dp, String packageName, String jarFileName)
static void	logInfo(String tenantName, String serviceName, String message)
static void	manipulateHeaders(io.undertow.server.HttpServerExchange exchange)
static String	normalizeApiPath(String s)
static String	normalizeApiPathName(String method, String s)
static String	normalizeUri(String s)
static final String	objectToJson(Object object)
static final void	printException(DataPipeline dp, String msg, Exception e)
static final void	printException(Tenant tenant, String msg, Exception e)
static final void	printException(String msg, Exception e)
static final byte[]	readAllBytes(File file)
static void	redirectRequest(io.undertow.server.HttpServerExchange exchange, String path)
static final String	registerURLAlias(String fqn, String alias, DataPipeline dp)
static String	replaceAllIgnoreRegx(String source, String search, String replace)
static void	saveServerProperties(DataPipeline dataPipeline)
static List<String>	searchEndpoints(String keyword, Tenant tenant)
static io.undertow.server.handlers.Cookie	setupCookie(io.undertow.server.HttpServerExchange exchange, String tenantName, String token)
static String	setupRequestPath(io.undertow.server.HttpServerExchange exchange)
static final void	startStreaming(RuntimePipeline rp, MultiPart mp)
static void	startTenantServices(String tenant)
static final String	toJson(Object obj)
static final String	toJson(Map<String,Object> map)
static final String	toPrettyJson(Map<String,Object> map)
static String	toServiceSlug(String str)
static final String	toXml(Map<String,Object> map, String rootName)
static final String	toYaml(Map<String,Object> map)
static void	unzipBuildFile(String srcZip, String destinationBasePath)
static final Map<String,Object>	xmlToMap(String json)
static final String	xmlToString(Object o, String rootName)
static final Map<String,Object>	yamlToMap(String json)
static void	zipFile(File fileToZip, String fileName, ZipOutputStream zipOut)

Methods inherited from class java.lang.Object

equals, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Details

xmlMapper

public static final com.fasterxml.jackson.dataformat.xml.XmlMapper xmlMapper

yamlMapper

public static final com.fasterxml.jackson.dataformat.yaml.YAMLMapper yamlMapper

LOGGER

public static org.apache.logging.log4j.Logger LOGGER

Constructor Details

ServiceUtils

public ServiceUtils()

Method Details

isWindows

public static boolean isWindows()

searchEndpoints

public static List<String> searchEndpoints(String keyword,
 Tenant tenant)

isMac

public static boolean isMac()

isUnix

public static boolean isUnix()

isSolaris

public static boolean isSolaris()

getSeparator

public static String getSeparator()
                           throws Exception

Throws:

Exception

generateUUID

public static final String generateUUID(String msg)

toJson

public static final String toJson(Map<String,Object> map)
                           throws Exception

Throws:

Exception

convertPolyglotValue

public static Object convertPolyglotValue(org.graalvm.polyglot.Value value)

toJson

public static final String toJson(Object obj)

toPrettyJson

public static final String toPrettyJson(Map<String,Object> map)
                                 throws Exception

Throws:

Exception

objectToJson

public static final String objectToJson(Object object)
                                 throws Exception

Throws:

Exception

readAllBytes

public static final byte[] readAllBytes(File file)
                                 throws Exception

Throws:

Exception

jsonToMap

public static final Map<String,Object> jsonToMap(String json)

toYaml

public static final String toYaml(Map<String,Object> map)
                           throws Exception

Throws:

Exception

yamlToMap

public static final Map<String,Object> yamlToMap(String json)

xmlToString

public static final String xmlToString(Object o,
 String rootName)
                                throws Exception

Throws:

Exception

toXml

public static final String toXml(Map<String,Object> map,
 String rootName)
                          throws Exception

Throws:

Exception

xmlToMap

public static final Map<String,Object> xmlToMap(String json)

getExceptionMap

public static Object getExceptionMap(Exception e)

execute

public static final void execute(String fqn,
 DataPipeline dataPipeLine)
                          throws SnippetException

Throws:

SnippetException

executeEmbeddedService

public static final void executeEmbeddedService(DataPipeline dataPipeline,
 String apiServiceJson)
                                         throws SnippetException

Throws:

SnippetException

isPublicFolder

public static final boolean isPublicFolder(String path)

compileJavaCode

public static final void compileJavaCode(String fqn,
 DataPipeline dataPipeLine)
                                  throws SnippetException

Throws:

SnippetException

printException

public static final void printException(String msg,
 Exception e)

printException

public static final void printException(Tenant tenant,
 String msg,
 Exception e)

printException

public static final void printException(DataPipeline dp,
 String msg,
 Exception e)

getServerProperty

public static final String getServerProperty(String key)

compress

public static byte[] compress(byte[] data)

deCompress

public static byte[] deCompress(byte[] data)
                         throws DataFormatException

Throws:

DataFormatException

getPathService

public static final String getPathService(String requestPath,
 Map<String,Object> payload,
 Tenant tenant)

extractHeaders

public static final Map<String,Object> extractHeaders(io.undertow.server.HttpServerExchange exchange)

getFormattedLogLine

public static final String getFormattedLogLine(String id,
 String resource,
 String info)

getFormattedLogMap

public static final Map<String,Object> getFormattedLogMap(String id,
 String resource,
 String info)

getMultiPart

public static final MultiPart getMultiPart(DataPipeline dataPipeLine)
                                    throws SnippetException

Throws:

SnippetException

getURLAlias

public static final String getURLAlias(String fqn,
 Tenant tenant)
                                throws Exception

Throws:

Exception

registerURLAlias

public static final String registerURLAlias(String fqn,
 String alias,
 DataPipeline dp)
                                     throws Exception

Throws:

Exception

deleteURLAlias

public static final String deleteURLAlias(String alias,
 DataPipeline dp)
                                   throws Exception

Throws:

Exception

areBracesBalanced

public static boolean areBracesBalanced(String input)

startStreaming

public static final void startStreaming(RuntimePipeline rp,
 MultiPart mp)
                                 throws SnippetException

Throws:

SnippetException

getBody

public static byte[] getBody(DataPipeline dataPipeLine)
                      throws SnippetException

Throws:

SnippetException

getBodyAsStream

public static final InputStream getBodyAsStream(DataPipeline dataPipeLine)
                                         throws SnippetException

Throws:

SnippetException

copyDirectory

public static void copyDirectory(String sourceDirectoryLocation,
 String destinationDirectoryLocation)
                          throws IOException

Throws:

IOException

setupRequestPath

public static String setupRequestPath(io.undertow.server.HttpServerExchange exchange)

manipulateHeaders

public static void manipulateHeaders(io.undertow.server.HttpServerExchange exchange)

setupCookie

public static io.undertow.server.handlers.Cookie setupCookie(io.undertow.server.HttpServerExchange exchange,
 String tenantName,
 String token)

clearSession

public static void clearSession(io.undertow.server.HttpServerExchange exchange)

getToken

public static String getToken(io.undertow.server.handlers.Cookie cookie)

getTenantName

public static String getTenantName(io.undertow.server.handlers.Cookie cookie)

initNewTenant

public static String initNewTenant(String name,
 AuthAccount account,
 String password)

startTenantServices

public static void startTenantServices(String tenant)
                                throws SnippetException

Throws:

SnippetException

getClassesURLs

public static final URL[] getClassesURLs(String path)
                                  throws Exception

Throws:

Exception

getCurrentLoggedInUserProfile

public static org.pac4j.core.profile.UserProfile getCurrentLoggedInUserProfile(io.undertow.server.HttpServerExchange exchange)
                                                                        throws SnippetException

Throws:

SnippetException

getCurrentLoggedInAuthAccount

public static AuthAccount getCurrentLoggedInAuthAccount(io.undertow.server.HttpServerExchange exchange)
                                                 throws SnippetException

Throws:

SnippetException

getKey

public static SecretKeySpec getKey(String myKey)

encrypt

public static String encrypt(String strToEncrypt,
 String tenantName)

decrypt

public static String decrypt(String strToDecrypt,
 String tenantName)
                      throws Exception

Throws:

Exception

addHoursToDate

public static Date addHoursToDate(Date date,
 int hours)

getJarPaths

public static final String[] getJarPaths(String path,
 String packagePath)
                                  throws Exception

Throws:

Exception

zipFile

public static void zipFile(File fileToZip,
 String fileName,
 ZipOutputStream zipOut)
                    throws IOException

Throws:

IOException

fetchMetadata

public static com.nimbusds.openid.connect.sdk.op.OIDCProviderMetadata fetchMetadata(String discoveryUrl,
 com.nimbusds.jose.JWSAlgorithm jwsAlgo)
                                                                             throws Exception

Throws:

Exception

replaceAllIgnoreRegx

public static String replaceAllIgnoreRegx(String source,
 String search,
 String replace)

redirectRequest

public static void redirectRequest(io.undertow.server.HttpServerExchange exchange,
 String path)

Parameters:

exchange -

path -

Throws:

SnippetException

isApiCall

public static boolean isApiCall(io.undertow.server.HttpServerExchange exchange)

Parameters:

exchange -

Returns:

logInfo

public static void logInfo(String tenantName,
 String serviceName,
 String message)

getCaseInsensitiveKey

public static Object getCaseInsensitiveKey(Map<String,Object> map,
 String key)

Parameters:

map -

key -

Returns:

normalizeUri

public static String normalizeUri(String s)

normalizeApiPath

public static String normalizeApiPath(String s)

normalizeApiPathName

public static String normalizeApiPathName(String method,
 String s)

toServiceSlug

public static String toServiceSlug(String str)

loadCustomJar

public static void loadCustomJar(DataPipeline dp,
 String packageName,
 String jarFileName)
                          throws Exception

Throws:

Exception

loadCustomJar

public static void loadCustomJar(DataPipeline dp,
 String path)
                          throws Exception

Throws:

Exception

unzipBuildFile

public static void unzipBuildFile(String srcZip,
 String destinationBasePath)
                           throws IOException

Throws:

IOException

beforeServiceExecution

public static void beforeServiceExecution(DataPipeline dp,
 String fqn,
 Map<String,Object> passThroughData)
                                   throws Exception

Throws:

Exception

afterServiceExecution

public static void afterServiceExecution(DataPipeline dp,
 String fqn,
 Map<String,Object> passThroughData)
                                  throws Exception

Throws:

Exception

decodeJWT

public static Map<String,Object> decodeJWT(String jwtToken)

isValid

public static boolean isValid(String token)
                       throws SystemException

Throws:

SystemException

saveServerProperties

public static void saveServerProperties(DataPipeline dataPipeline)
                                 throws Exception

Throws:

Exception