Commit fd1f5d80 by amir

end of day commits

parent f00c99e6
......@@ -109,6 +109,8 @@ public class MicroserviceApp
public boolean isEnableDefaultServiceAuthorization() { return enableDefaultServiceAuthorization; }
public IServiceDiscovery getServiceDiscovery() { return serviceDiscovery; }
/*************************
* WITH SECTION
*************************/
......
......@@ -110,13 +110,29 @@ public class CommonServices {
}
public enum EnumRestServiceMode {
E_UNKNOWN,
E_CLIENT,
E_SERVER,
E_CLIENT_SERVER
}
public static abstract class IRestService extends IService {
EnumRestServiceMode serviceMode = EnumRestServiceMode.E_UNKNOWN;
protected ICommandClient restClient = null;
public EnumRestServiceMode getServiceMode() { return serviceMode; }
public void setServiceMode(EnumRestServiceMode serviceMode) { this.serviceMode = serviceMode; }
public abstract BaseRestResponse create(CommandParams cmdParams);
public abstract BaseRestResponse read(CommandParams cmdParams);
public abstract BaseRestResponse update(CommandParams cmdParams);
public abstract BaseRestResponse delete(CommandParams cmdParams);
public void setRestClient(ICommandClient restClient) {
this.restClient = restClient;
}
}
enum EnumPubSubCommands implements IServiceCommands {
......@@ -142,9 +158,9 @@ public class CommonServices {
}
}
public abstract void subscribe(String topic, Consumer<String> notifyFunc);
public abstract void subscribe(String topic, Consumer<PubSubMsgContext> notifyFunc,Consumer<String> errorFunc);
public abstract void unsubscribe(String topic);
public abstract void publish(String topic, String message);
public abstract void publish(PubSubMsgContext pubSubMsgContext);
}
enum EnumMsgQCommands {
......@@ -153,8 +169,45 @@ public class CommonServices {
}
public static abstract class IMsgQService extends IService {
public class MsgQContext implements IMsgContext {
public String header = null;
public String msg = null;
public MsgQContext(String header, String msg) {
this.header = header;
this.msg = msg;
}
@Override
public void setParameters(Map<String, String> parameters) {
}
}
public abstract void receive(Consumer<String> receiveFunc);
public abstract void send(String msg);
}
public interface IClient {
}
public interface IRestClient extends IClient {
BaseRestResponse create(CommandParams cmdParams);
BaseRestResponse read(CommandParams cmdParams);
BaseRestResponse update(CommandParams cmdParams);
BaseRestResponse delete(CommandParams cmdParams);
}
public interface IMsgQueueClient extends IClient {
boolean send(IMsgQService.MsgQContext msgQContext);
}
public interface IPubSubClient extends IClient {
void publish(IPubSubService.PubSubMsgContext pubSubContext);
void subscribe(String topic, Consumer<String> notifyFunc, Consumer<String> errorFunc);
void unsubscribe(String topic);
}
}
......@@ -224,7 +224,8 @@ public class IRestClientRestImpl implements ICommandClient
super();
if (RestClientParams.class.isInstance(params))
this.clientParams = (RestClientParams)params;
else throw new Exception("wrong initialization params" + params.getClass().getName());
else
throw new Exception("wrong initialization params" + params.getClass().getName());
httpRestClient = new SimpleRestClient(clientParams.getServiceName(), clientParams.getAddress());
httpRestClient.Initialize(clientParams.getMaxConnection());
if (clientParams.isMetricsEnabled())
......
......@@ -31,8 +31,9 @@ public class IPubSubServiceMqttImpl extends CommonServices.IPubSubService {
this.clientId = Long.toString(System.currentTimeMillis());
}
@Override
public void subscribe(String topic, Consumer<String> notifyFunc) {
public void subscribe(String topic, Consumer<PubSubMsgContext> notifyFunc, Consumer<String> errorFunc) {
}
......@@ -42,7 +43,7 @@ public class IPubSubServiceMqttImpl extends CommonServices.IPubSubService {
}
@Override
public void publish(String topic, String message) {
public void publish(PubSubMsgContext pubSubMsgContext) {
}
......
......@@ -17,6 +17,7 @@ import io.undertow.util.Headers;
import io.undertow.util.HttpString;
import io.undertow.util.MimeMappings;
import microservice.MicroserviceApp;
import microservice.MicroserviceClient;
import microservice.RestContext;
import microservice.common.EncryptionUtils;
import microservice.defs.Constants;
......@@ -26,11 +27,17 @@ import microservice.handlers.Reactor;
import microservice.io.iface.*;
import microservice.io.impl.IRequestRestImpl;
import microservice.io.impl.IResponseRestImpl;
import microservice.io.impl.IRestClientRestImpl;
import microservice.params.BaseClientParams;
import microservice.params.CommandParams;
import microservice.params.RestClientParams;
import microservice.params.RestServerParams;
import microservice.types.BaseRestResponse;
import microservice.types.UserProfile;
import java.util.function.Function;
import java.util.function.Supplier;
import static io.undertow.Handlers.resource;
import static microservice.defs.Constants.*;
......@@ -40,12 +47,13 @@ import static microservice.defs.Constants.*;
public class IRestServiceHttpImpl extends CommonServices.IRestService implements HttpHandler , IContainer{
ILogger logger = null;
RestServerParams restServerParams;
RestServerParams restServerParams = null;
Undertow restServer = null;
Thread restThread = null;
private String appName;
public ObjectMapper objMapper = null;
protected Enums.EnumAuthenticationType authType = Enums.EnumAuthenticationType.DEFAULT;
MicroserviceClient restClient = null;
/**
* is the jwt token in the Authorization header or in the request query param
......@@ -57,28 +65,50 @@ public class IRestServiceHttpImpl extends CommonServices.IRestService implements
this.objMapper = new ObjectMapper();
}
public IRestServiceHttpImpl() {
this.objMapper = new ObjectMapper();
}
public void setRestServerParams(RestServerParams restServerParams) {
this.restServerParams = restServerParams;
}
public Enums.EnumAuthenticationType getAuthType() { return authType; }
public void setAuthType(Enums.EnumAuthenticationType authType) { this.authType = authType; }
public BaseRestResponse handleSyncRespCommand(Supplier<BaseRestResponse> command) {
BaseRestResponse resp = null;
try {
if (restClient != null)
resp = command.get();
} catch (Exception e) {
resp = new BaseRestResponse(false,e.toString());
} finally {
if (resp == null)
resp = new BaseRestResponse(false, null);
}
return resp;
}
@Override
public BaseRestResponse create(CommandParams cmdParams) {
return null;
return handleSyncRespCommand(() -> restClient.create(cmdParams) );
}
@Override
public BaseRestResponse read(CommandParams cmdParams) {
return null;
return handleSyncRespCommand(() -> restClient.read(cmdParams) );
}
@Override
public BaseRestResponse update(CommandParams cmdParams) {
return null;
return handleSyncRespCommand(() -> restClient.update(cmdParams) );
}
@Override
public BaseRestResponse delete(CommandParams cmdParams) {
return null;
return handleSyncRespCommand(() -> restClient.delete(cmdParams) );
}
@Override
......@@ -112,6 +142,19 @@ public class IRestServiceHttpImpl extends CommonServices.IRestService implements
serverBuilder.setHandler(pathHandler);
// build
this.restServer = serverBuilder.build();
/**
* create client
*/
try {
BaseClientParams clientParams = new RestClientParams("", true, 10, null, null);
IRestClientRestImpl cmdClient = new IRestClientRestImpl(clientParams)
.withServiceDiscovery(MicroserviceApp.getsInstance().getServiceDiscovery());
restClient = new MicroserviceClient(cmdClient, clientParams);
} catch (Exception exp) {
logger.error(exp.toString());
return false;
}
return true;
}
......@@ -210,6 +253,9 @@ public class IRestServiceHttpImpl extends CommonServices.IRestService implements
@Override
public void run() {
if (getServiceMode().equals(CommonServices.EnumRestServiceMode.E_CLIENT))
return;
restThread = new Thread(() -> {
try
{
......
package microservice.utils;
import microservice.io.iface.CommonServices;
import microservice.io.iface.ICommandClient;
import microservice.io.impl.IRestClientRestImpl;
import microservice.io.impl.service.IRestServiceHttpImpl;
import microservice.params.RestClientParams;
import microservice.params.RestServerParams;
/**
* Created by amir on 09/05/17.
*/
public class ServiceBuilderFactory {
public static RestServiceHttpBuilder createRestServiceHttpBuilder(CommonServices.EnumRestServiceMode serviceMode){
return new RestServiceHttpBuilder(serviceMode);
}
public interface IBuilder {
CommonServices.IService build();
}
public static class RestServiceHttpBuilder implements IBuilder {
IRestServiceHttpImpl restServiceHttp = null;
RestServerParams restServerParams = null;
ICommandClient restClient = null;
RestClientParams restClientParams = null;
CommonServices.EnumRestServiceMode serviceMode = CommonServices.EnumRestServiceMode.E_UNKNOWN;
public RestServiceHttpBuilder(CommonServices.EnumRestServiceMode serviceMode) {
this.serviceMode = serviceMode;
}
public RestServiceHttpBuilder hasRestServerParams(RestServerParams restServerParams) {
this.restServerParams = restServerParams;
return this;
}
public RestServiceHttpBuilder hasRestClientParams(RestClientParams restClientParams) {
this.restClientParams = restClientParams;
return this;
}
/**
* in case you want a different client the the regular http
* @param restClient
* @return
*/
public RestServiceHttpBuilder withRestClient(ICommandClient restClient) {
this.restClient = restClient;
return this;
}
@Override
public CommonServices.IService build() {
if (validateParams()) {
try {
restServiceHttp = new IRestServiceHttpImpl();
restServiceHttp.setServiceMode(serviceMode);
switch (serviceMode) {
case E_SERVER:
restServiceHttp.setRestServerParams(restServerParams);
break;
case E_CLIENT:
if (restClient == null)
restClient = new IRestClientRestImpl(restClientParams);
restServiceHttp.setRestClient(restClient);
break;
case E_CLIENT_SERVER:
restServiceHttp.setRestServerParams(restServerParams);
if (restClient == null)
restClient = new IRestClientRestImpl(restClientParams);
restServiceHttp.setRestClient(restClient);
break;
}
} catch (Exception exp){
System.err.println(this.getClass().getName().toString() + "Exception >> " + exp);
restServiceHttp = null;
}
} else {
System.err.println(this.getClass().getName().toString() + " >> Failed in validating params");
}
return restServiceHttp;
}
private boolean validateParams() {
switch (serviceMode){
case E_UNKNOWN:
return false;
case E_SERVER:
if (this.restServerParams == null)
return false;
break;
case E_CLIENT:
if (this.restClientParams == null)
return false;
break;
case E_CLIENT_SERVER:
if (this.restServerParams == null || this.restClientParams == null)
break;
}
return true;
}
}
}
......@@ -11,6 +11,7 @@ import microservice.io.impl.service.IRestServiceHttpImpl;
import microservice.params.*;
import microservice.types.BaseRestResponse;
import microservice.utils.ServiceBuilderFactory;
import org.eclipse.paho.client.mqttv3.MqttException;
import org.junit.Test;
......@@ -75,11 +76,15 @@ public class TestMicroserviceApp {
{
System.setProperty("configFile.location","/opt/mcx/config/config.properties");
String appName = "testApp";
CommonServices.IService restService = ServiceBuilderFactory.createRestServiceHttpBuilder(CommonServices.EnumRestServiceMode.E_SERVER)
.hasRestServerParams(new RestServerParams(32000, "localhost", 2))
.build();
microservice.MicroserviceApp msApp = new microservice.MicroserviceApp(appName);
msApp.withMetrics()
.withMonitoring()
//.withDefaultServiceAuthorization()
.addService(Enums.EnumServiceType.E_REST,new IRestServiceHttpImpl(new RestServerParams(32000, "localhost", 2)),"undertowRestService")
.addService(Enums.EnumServiceType.E_REST,restService,"undertowRestService")
.addMethod(Enums.EnumServiceType.E_REST, CommonServices.EnumRestCommands.E_READ,"/resource/{rid}",(msgCtx,orgService) -> {
BaseRestResponse brr = new BaseRestResponse(true,null);
RestContext restContext = (RestContext)msgCtx;
......@@ -92,11 +97,11 @@ public class TestMicroserviceApp {
restContext.container.writeObjectToResponse(restContext.response,brr);
})
.addMethod(Enums.EnumServiceType.E_REST,CommonServices.EnumRestCommands.E_READ,"/resource/r2",(msgCtx,orgService) -> {
CommonServices.IRestService outRestService = (CommonServices.IRestService)MicroserviceApp.getsInstance().getService(Enums.EnumServiceType.E_REST,"undertowRestService");
CommonServices.IRestService restService = (CommonServices.IRestService)orgService;
CommonServices.IRestService inRestService = (CommonServices.IRestService)MicroserviceApp.getsInstance().getService(Enums.EnumServiceType.E_REST,"undertowRestService");
CommandParams cmdParams = new CommandParams();
BaseRestResponse brr = restService.read(cmdParams);
//restService.writeResponse(brr);
RestContext restContext = (RestContext)msgCtx;
BaseRestResponse brr = inRestService.read(cmdParams);
restContext.container.writeObjectToResponse(restContext.response,brr);
})
._build()
._run();
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or sign in to comment