Merge branches 'PAN-15' and 'master' of https://github.com/atusa17/ptp into PAN-15

# Conflicts:
#	services/build.gradle
This commit is contained in:
2019-03-20 22:28:51 -06:00
parent f35777b5a6
commit f5f959b453
3 changed files with 15 additions and 22 deletions
-3
View File
@@ -3,9 +3,6 @@ plugins {
id 'java' id 'java'
} }
apply plugin: 'io.spring.dependency-management'
apply plugin: 'org.springframework.boot'
description = 'Provides database access and connectivity' description = 'Provides database access and connectivity'
group 'edu.msudenver.tsp' group 'edu.msudenver.tsp'
version '1.0' version '1.0'
@@ -16,7 +16,6 @@ values ('admin', 'secret', true),
('BrittanyBi', 'secret', true), ('BrittanyBi', 'secret', true),
('lanlanzeliu', 'secret', true), ('lanlanzeliu', 'secret', true),
('tramanh305', 'secret', true); ('tramanh305', 'secret', true);
create table definitions ( create table definitions (
id int not null auto_increment primary key unique, id int not null auto_increment primary key unique,
name varchar(200) not null, name varchar(200) not null,
@@ -17,19 +17,16 @@ import java.util.Optional;
@Service @Service
public class UserService { public class UserService {
private final RestService restService; private final RestService restService;
@Value("${persistence.api.connection.timeout.milliseconds}") @Value("${persistence.api.connection.timeout.milliseconds}") private int connectionTimeoutMilliseconds;
private int connectionTimeoutMilliseconds; @Value("${persistence.api.socket.timeout.milliseconds}") private int socketTimeoutMilliseconds;
@Value("${persistence.api.socket.timeout.milliseconds}") @Value("${persistence.api.base.url}") private String persistenceApiBaseUrl;
private int socketTimeoutMilliseconds;
@Value("${persistence.api.base.url}")
private String persistenceApiBaseUrl;
@Autowired @Autowired
public UserService(final RestService restService) { public UserService(final RestService restService) {
this.restService = restService; this.restService = restService;
} }
public Optional<Account> createNewAccount(final Account account) { public Optional<Account> createNewAccount(final Account account) {
if (account == null) { if (account == null) {
LOG.error("Given null account, returning {}"); LOG.error("Given null account, returning {}");
return Optional.empty(); return Optional.empty();
@@ -37,8 +34,7 @@ public class UserService {
final Instant start = Instant.now(); final Instant start = Instant.now();
try { try {
final TypeToken<Account> typeToken = new TypeToken<Account>() { final TypeToken<Account> typeToken = new TypeToken<Account>() {};
};
final Optional<Account> persistenceApiResponse = restService.post(persistenceApiBaseUrl + "accounts/", final Optional<Account> persistenceApiResponse = restService.post(persistenceApiBaseUrl + "accounts/",
new GsonBuilder().setDateFormat("yyyy-MM-dd'T'HH:mm:ss.SSS'Z'").create().toJson(account), new GsonBuilder().setDateFormat("yyyy-MM-dd'T'HH:mm:ss.SSS'Z'").create().toJson(account),
typeToken, typeToken,
@@ -46,7 +42,7 @@ public class UserService {
socketTimeoutMilliseconds); socketTimeoutMilliseconds);
if (persistenceApiResponse.isPresent()) { if (persistenceApiResponse.isPresent()) {
LOG.info("Returning {}", persistenceApiResponse); LOG.info("Returning {}", persistenceApiResponse.get());
} else { } else {
LOG.info("Unable to create new account {}", account.toString()); LOG.info("Unable to create new account {}", account.toString());
} }
@@ -74,7 +70,7 @@ public class UserService {
try{ try{
final String auth = ""; final String auth = "";
final TypeToken<Account> typeToken = new TypeToken<Account>(){}; final TypeToken<Account> typeToken = new TypeToken<Account>(){};
final Optional<Account> persistenceApiResponse = restService.patch(persistenceApiBaseUrl + "accounts/"+id, final Optional<Account> persistenceApiResponse = restService.patch(persistenceApiBaseUrl + "accounts/id?id=" + id,
new GsonBuilder().setDateFormat("yyyy-MM-dd'T'HH:mm:ss.SSS'Z'").create().toJson(account), new GsonBuilder().setDateFormat("yyyy-MM-dd'T'HH:mm:ss.SSS'Z'").create().toJson(account),
typeToken, typeToken,
connectionTimeoutMilliseconds, connectionTimeoutMilliseconds,
@@ -93,7 +89,7 @@ public class UserService {
} finally { } finally {
LOG.info("Update account request took {} ms", Duration.between(start, Instant.now()).toMillis()); LOG.info("Update account request took {} ms", Duration.between(start, Instant.now()).toMillis());
} }
} }
public Optional<Account> updateUsername(final Account account , final String username){ public Optional<Account> updateUsername(final Account account , final String username){
@@ -109,7 +105,7 @@ public class UserService {
try{ try{
final String auth = ""; final String auth = "";
final TypeToken<Account> typeToken = new TypeToken<Account>(){}; final TypeToken<Account> typeToken = new TypeToken<Account>(){};
final Optional<Account> persistenceApiResponse = restService.patch(persistenceApiBaseUrl + "accounts/"+id, final Optional<Account> persistenceApiResponse = restService.patch(persistenceApiBaseUrl + "accounts/id?id="+id,
new GsonBuilder().setDateFormat("yyyy-MM-dd'T'HH:mm:ss.SSS'Z'").create().toJson(account), new GsonBuilder().setDateFormat("yyyy-MM-dd'T'HH:mm:ss.SSS'Z'").create().toJson(account),
typeToken, typeToken,
connectionTimeoutMilliseconds, connectionTimeoutMilliseconds,
@@ -129,9 +125,10 @@ public class UserService {
LOG.info("Update account request took {} ms", Duration.between(start, Instant.now()).toMillis()); LOG.info("Update account request took {} ms", Duration.between(start, Instant.now()).toMillis());
} }
} }
public boolean deleteAccount(final Account account){
if(account ==null){ public boolean deleteAccount(final Account account) {
LOG.error("Username not exist, returning{}"); if(account == null){
LOG.error("Username does not exist, returning {}");
return false; return false;
} }
final Integer id = account.getId(); final Integer id = account.getId();
@@ -139,14 +136,14 @@ public class UserService {
try{ try{
final boolean persistenceApiResponse = restService.delete(persistenceApiBaseUrl +"/accounts/"+id, final boolean persistenceApiResponse = restService.delete(persistenceApiBaseUrl + "/accounts/id?id=" + id,
connectionTimeoutMilliseconds, connectionTimeoutMilliseconds,
socketTimeoutMilliseconds, HttpStatus.NO_CONTENT ); socketTimeoutMilliseconds, HttpStatus.NO_CONTENT );
if(persistenceApiResponse){ if(persistenceApiResponse){
LOG.info("return {}", persistenceApiResponse); LOG.info("return {}", persistenceApiResponse);
} }
else { else {
LOG.info("Unable to delete user {}",account.toString()); LOG.info("Unable to delete user {}", account.toString());
} }
return persistenceApiResponse; return persistenceApiResponse;