Skip to content
Snippets Groups Projects
Commit 0993085d authored by OZGCloud's avatar OZGCloud
Browse files

add user profile service

parent e249f99b
No related branches found
No related tags found
No related merge requests found
...@@ -42,11 +42,11 @@ ...@@ -42,11 +42,11 @@
<version>${vorgang-manager.version}</version> <version>${vorgang-manager.version}</version>
</dependency> </dependency>
<!-- <dependency>--> <dependency>
<!-- <groupId>de.ozgcloud.user</groupId>--> <groupId>de.ozgcloud.user</groupId>
<!-- <artifactId>user-manager-interface</artifactId>--> <artifactId>user-manager-interface</artifactId>
<!-- <version>${user-manager.version}</version>--> <version>${user-manager.version}</version>
<!-- </dependency>--> </dependency>
<!--spring --> <!--spring -->
<dependency> <dependency>
......
package de.ozgcloud.apilib.user; package de.ozgcloud.apilib.user;
import de.ozgcloud.user.grpc.userprofile.UserProfileServiceGrpc.UserProfileServiceBlockingStub;
import de.ozgcloud.user.userprofile.GrpcGetUserProfileRequest;
import lombok.RequiredArgsConstructor; import lombok.RequiredArgsConstructor;
import net.devh.boot.grpc.client.inject.GrpcClient;
@RequiredArgsConstructor @RequiredArgsConstructor
public class GrpcOzgCloudUserProfileService { public class GrpcOzgCloudUserProfileService
//implements OzgCloudUserProfileService { implements OzgCloudUserProfileService {
/*
* @GrpcClient("user-manager") private final UserProfileServiceBlockingStub @GrpcClient("user-manager")
* serviceStub; private final UserProfileServiceBlockingStub serviceStub;
*
* private final UserProfileMapper mapper; private final UserProfileMapper mapper;
*
* @Override public OzgCloudUserProfile getById(OzgCloudUserId userId) { var @Override
* grpcUserProfileResponse = serviceStub.getById(buildGetUserRequest(userId)); public OzgCloudUserProfile getById(OzgCloudUserId userId) {
* var grpcUserProfileResponse = serviceStub.getById(buildGetUserRequest(userId));
* return mapper.mapFromGrpc(grpcUserProfileResponse.getUserProfile()); }
* return mapper.mapFromGrpc(grpcUserProfileResponse.getUserProfile());
* private GrpcGetUserProfileRequest buildGetUserRequest(OzgCloudUserId id) { }
* return GrpcGetUserProfileRequest.newBuilder() .setUserId(id.toString())
* .build(); } private GrpcGetUserProfileRequest buildGetUserRequest(OzgCloudUserId id) {
*/ return GrpcGetUserProfileRequest.newBuilder().setUserId(id.toString())
.build();
}
} }
package de.ozgcloud.apilib.user; package de.ozgcloud.apilib.user;
import org.mapstruct.Mapper; import org.mapstruct.Mapper;
import org.mapstruct.Mapping;
import de.ozgcloud.user.userprofile.GrpcUserProfile;
import lombok.NonNull;
@Mapper @Mapper
public interface UserProfileMapper { public interface UserProfileMapper {
/*
* OzgCloudUserProfile mapFromGrpc(GrpcUserProfile userProfile); @Mapping(target = "email", source = "email")
* OzgCloudUserProfile mapFromGrpc(GrpcUserProfile userProfile);
* default OzgCloudUserId toOzgCloudUserId(@NonNull String id) { return
* OzgCloudUserId.from(id); } default OzgCloudUserId toOzgCloudUserId(@NonNull String id) {
*/ return OzgCloudUserId.from(id);
}
} }
...@@ -31,12 +31,12 @@ import de.ozgcloud.apilib.vorgang.dummy.DummyVorgangService; ...@@ -31,12 +31,12 @@ import de.ozgcloud.apilib.vorgang.dummy.DummyVorgangService;
import de.ozgcloud.apilib.vorgang.grpc.GrpcOzgCloudVorgangService; import de.ozgcloud.apilib.vorgang.grpc.GrpcOzgCloudVorgangService;
import de.ozgcloud.apilib.vorgang.grpc.OzgCloudVorgangMapper; import de.ozgcloud.apilib.vorgang.grpc.OzgCloudVorgangMapper;
import de.ozgcloud.apilib.vorgang.grpc.OzgCloudVorgangStubMapper; import de.ozgcloud.apilib.vorgang.grpc.OzgCloudVorgangStubMapper;
import de.ozgcloud.vorgang.grpc.command.CommandServiceGrpc.CommandServiceBlockingStub; import de.ozgcloud.vorgang.grpc.command.CommandServiceGrpc;
import de.ozgcloud.vorgang.vorgang.VorgangServiceGrpc.VorgangServiceBlockingStub; import de.ozgcloud.vorgang.vorgang.VorgangServiceGrpc.VorgangServiceBlockingStub;
import io.grpc.ManagedChannelBuilder;
import net.devh.boot.grpc.client.autoconfigure.GrpcClientAutoConfiguration; import net.devh.boot.grpc.client.autoconfigure.GrpcClientAutoConfiguration;
import net.devh.boot.grpc.client.config.GrpcChannelProperties; import net.devh.boot.grpc.client.config.GrpcChannelProperties;
import net.devh.boot.grpc.client.config.GrpcChannelsProperties; import net.devh.boot.grpc.client.config.GrpcChannelsProperties;
import net.devh.boot.grpc.client.inject.GrpcClient;
@AutoConfiguration(before = GrpcClientAutoConfiguration.class) @AutoConfiguration(before = GrpcClientAutoConfiguration.class)
@ComponentScan("de.ozgcloud.client.autoconfigure") @ComponentScan("de.ozgcloud.client.autoconfigure")
...@@ -169,8 +169,11 @@ public class OzgCloudClientAutoConfiguration { ...@@ -169,8 +169,11 @@ public class OzgCloudClientAutoConfiguration {
@Bean @Bean
@ConditionalOnProperty("ozgcloud.command-manager.address") @ConditionalOnProperty("ozgcloud.command-manager.address")
OzgCloudCommandService grpcOzgCloudCommandService(@GrpcClient("ozgcloud-command-manager") CommandServiceBlockingStub commandServiceStub, OzgCloudCommandService grpcOzgCloudCommandService(CommandMapper commandMapper, OzgCloudCallContextProvider contextProvider) {
CommandMapper commandMapper, OzgCloudCallContextProvider contextProvider) { var channel = ManagedChannelBuilder.forTarget(commandManagerProperties.getAddress()).usePlaintext().build();
var commandServiceStub = CommandServiceGrpc.newBlockingStub(channel);
return new GrpcOzgCloudCommandService(commandServiceStub, commandMapper, contextProvider, return new GrpcOzgCloudCommandService(commandServiceStub, commandMapper, contextProvider,
GrpcOzgCloudCommandService.DEFAULT_COMMAND_REQUEST_THRESHOLD_MILLIS); GrpcOzgCloudCommandService.DEFAULT_COMMAND_REQUEST_THRESHOLD_MILLIS);
} }
......
...@@ -28,8 +28,8 @@ ...@@ -28,8 +28,8 @@
<failsafe-plugin.version>3.2.2</failsafe-plugin.version> <failsafe-plugin.version>3.2.2</failsafe-plugin.version>
<maven-jar-plugin.version>3.3.0</maven-jar-plugin.version> <maven-jar-plugin.version>3.3.0</maven-jar-plugin.version>
<vorgang-manager.version>2.0.0-SNAPSHOT</vorgang-manager.version> <vorgang-manager.version>2.0.0</vorgang-manager.version>
<user-manager.version>2.0.0-SNAPSHOT</user-manager.version> <user-manager.version>2.1.0-SNAPSHOT</user-manager.version>
</properties> </properties>
<build> <build>
......
0% Loading or .
You are about to add 0 people to the discussion. Proceed with caution.
Please register or to comment