Skip to content
Snippets Groups Projects
Commit ca08c26f authored by Mirco Nasuti's avatar Mirco Nasuti
Browse files

clean code

parent dfc4a416
No related branches found
No related tags found
No related merge requests found
...@@ -97,12 +97,12 @@ public class MIPApplication extends WebSecurityConfigurerAdapter { ...@@ -97,12 +97,12 @@ public class MIPApplication extends WebSecurityConfigurerAdapter {
@Autowired @Autowired
HttpSessionCsrfTokenRepository httpSessionCsrfTokenRepository; HttpSessionCsrfTokenRepository httpSessionCsrfTokenRepository;
@Autowired @Autowired
OAuth2ClientAuthenticationProcessingFilter hbpFilter; OAuth2ClientAuthenticationProcessingFilter hbpFilter;
public static void main(String[] args) { public static void main(String[] args) {
SpringApplication.run(MIPApplication.class, args); SpringApplication.run(MIPApplication.class, args);
} }
...@@ -112,7 +112,7 @@ public static void main(String[] args) { ...@@ -112,7 +112,7 @@ public static void main(String[] args) {
return userAuthentication.getDetails().toString(); return userAuthentication.getDetails().toString();
} }
/** /**
* returns the user for the current session. * returns the user for the current session.
* *
* the "synchronized" keyword is there to avoid a bug that the transaction is supposed to protect me from. * the "synchronized" keyword is there to avoid a bug that the transaction is supposed to protect me from.
...@@ -123,20 +123,20 @@ public static void main(String[] args) { ...@@ -123,20 +123,20 @@ public static void main(String[] args) {
* - check you have no 500 error in the network logs. * - check you have no 500 error in the network logs.
* @return * @return
*/ */
public synchronized User getUser() { public synchronized User getUser() {
Session session = HibernateUtil.getSessionFactory().getCurrentSession(); Session session = HibernateUtil.getSessionFactory().getCurrentSession();
User user = new User(getUserInfos()); User user = new User(getUserInfos());
try { try {
session.beginTransaction(); session.beginTransaction();
session.merge(user); session.merge(user);
session.getTransaction().commit(); session.getTransaction().commit();
} catch (Exception e) } catch (Exception e)
{ {
if(session.getTransaction() != null) if(session.getTransaction() != null)
{ {
session.getTransaction().rollback(); session.getTransaction().rollback();
} }
} }
return user; return user;
} }
...@@ -187,18 +187,26 @@ public static void main(String[] args) { ...@@ -187,18 +187,26 @@ public static void main(String[] args) {
@ApiParam(value = "Has the user agreed on the NDA") @RequestParam(value = "agreeNDA", required = true) Boolean agreeNDA) { @ApiParam(value = "Has the user agreed on the NDA") @RequestParam(value = "agreeNDA", required = true) Boolean agreeNDA) {
ObjectMapper mapper = new ObjectMapper(); ObjectMapper mapper = new ObjectMapper();
Session session = HibernateUtil.getSessionFactory().getCurrentSession(); Session session = HibernateUtil.getSessionFactory().getCurrentSession();
session.beginTransaction(); try {
User user = (User) session session.beginTransaction();
.createQuery("from User where username= :username") User user = (User) session
.setString("username", principal.getName()) .createQuery("from User where username= :username")
.uniqueResult(); .setString("username", principal.getName())
if (user != null) { .uniqueResult();
user.setAgreeNDA(agreeNDA); if (user != null) {
session.update(user); user.setAgreeNDA(agreeNDA);
session.update(user);
}
session.getTransaction().commit();
} catch (Exception e)
{
if(session.getTransaction() != null)
{
session.getTransaction().rollback();
}
} }
session.getTransaction().commit();
return new ResponseEntity<Void>(HttpStatus.OK); return new ResponseEntity<>(HttpStatus.OK);
} }
@Override @Override
......
...@@ -28,10 +28,10 @@ import static org.springframework.http.MediaType.APPLICATION_JSON_VALUE; ...@@ -28,10 +28,10 @@ import static org.springframework.http.MediaType.APPLICATION_JSON_VALUE;
@Api(value = "/articles", description = "the articles API") @Api(value = "/articles", description = "the articles API")
public class ArticlesApi { public class ArticlesApi {
@Autowired @Autowired
MIPApplication mipApplication; MIPApplication mipApplication;
@ApiOperation(value = "Get articles", response = Article.class, responseContainer = "List") @ApiOperation(value = "Get articles", response = Article.class, responseContainer = "List")
@ApiResponses(value = { @ApiResponse(code = 200, message = "Success") }) @ApiResponses(value = { @ApiResponse(code = 200, message = "Success") })
@RequestMapping(method = RequestMethod.GET) @RequestMapping(method = RequestMethod.GET)
public ResponseEntity<List> getArticles( public ResponseEntity<List> getArticles(
...@@ -61,25 +61,28 @@ public class ArticlesApi { ...@@ -61,25 +61,28 @@ public class ArticlesApi {
Session session = HibernateUtil.getSessionFactory().getCurrentSession(); Session session = HibernateUtil.getSessionFactory().getCurrentSession();
List articles = new LinkedList<>(); List articles = new LinkedList<>();
try {
session.beginTransaction(); session.beginTransaction();
Query query = session.createQuery(queryString); Query query = session.createQuery(queryString);
if(status != null) if (status != null) {
{
query.setString("status", status); query.setString("status", status);
} }
if(own != null && own) if (own != null && own) {
{
query.setString("username", user.getUsername()); query.setString("username", user.getUsername());
} } else {
else if (team != null && team) {
{
if(team != null && team)
{
query.setString("team", user.getTeam()); query.setString("team", user.getTeam());
} }
} }
articles = query.list(); articles = query.list();
session.getTransaction().commit(); session.getTransaction().commit();
} catch (Exception e)
{
if(session.getTransaction() != null)
{
session.getTransaction().rollback();
}
}
return ResponseEntity.ok(articles); return ResponseEntity.ok(articles);
......
...@@ -29,10 +29,10 @@ import static org.springframework.http.MediaType.APPLICATION_JSON_VALUE; ...@@ -29,10 +29,10 @@ import static org.springframework.http.MediaType.APPLICATION_JSON_VALUE;
@javax.annotation.Generated(value = "class io.swagger.codegen.languages.SpringMVCServerCodegen", date = "2016-01-07T07:38:20.227Z") @javax.annotation.Generated(value = "class io.swagger.codegen.languages.SpringMVCServerCodegen", date = "2016-01-07T07:38:20.227Z")
public class ModelsApi { public class ModelsApi {
@Autowired @Autowired
MIPApplication mipApplication; MIPApplication mipApplication;
private static final String DATA_FILE = "data/values.csv"; private static final String DATA_FILE = "data/values.csv";
@ApiOperation(value = "Get models", response = Model.class, responseContainer = "List") @ApiOperation(value = "Get models", response = Model.class, responseContainer = "List")
@ApiResponses(value = { @ApiResponse(code = 200, message = "Success") }) @ApiResponses(value = { @ApiResponse(code = 200, message = "Success") })
...@@ -109,9 +109,17 @@ public class ModelsApi { ...@@ -109,9 +109,17 @@ public class ModelsApi {
Session session = HibernateUtil.getSessionFactory().getCurrentSession(); Session session = HibernateUtil.getSessionFactory().getCurrentSession();
try {
session.beginTransaction(); session.beginTransaction();
session.save(model); session.save(model);
session.getTransaction().commit(); session.getTransaction().commit();
} catch (Exception e)
{
if(session.getTransaction() != null)
{
session.getTransaction().rollback();
}
}
return new ResponseEntity<Model>(HttpStatus.OK).ok(model); return new ResponseEntity<Model>(HttpStatus.OK).ok(model);
...@@ -128,62 +136,80 @@ public class ModelsApi { ...@@ -128,62 +136,80 @@ public class ModelsApi {
Model model = null; Model model = null;
Query query; Query query;
try {
session.beginTransaction(); session.beginTransaction();
query = session.createQuery("FROM Model WHERE slug= :slug").setString("slug", slug); query = session.createQuery("FROM Model WHERE slug= :slug").setString("slug", slug);
model = (Model) query.uniqueResult(); model = (Model) query.uniqueResult();
session.getTransaction().commit(); session.getTransaction().commit();
} catch (Exception e)
{
if(session.getTransaction() != null)
{
session.getTransaction().rollback();
}
}
if(model != null) { if(model != null) {
session = HibernateUtil.getSessionFactory().getCurrentSession(); session = HibernateUtil.getSessionFactory().getCurrentSession();
org.hbp.mip.model.Query q = null;
try {
session.beginTransaction(); session.beginTransaction();
query = session.createQuery("FROM Query WHERE id= :id").setLong("id", model.getQuery().getId()); query = session.createQuery("FROM Query WHERE id= :id").setLong("id", model.getQuery().getId());
org.hbp.mip.model.Query q = (org.hbp.mip.model.Query) query.uniqueResult(); q = (org.hbp.mip.model.Query) query.uniqueResult();
session.getTransaction().commit(); session.getTransaction().commit();
} catch (Exception e)
List<Variable> vars = new LinkedList<>(); {
for (Variable var : q.getVariables()) { if(session.getTransaction() != null)
Variable v = new Variable(); {
v.setCode(var.getCode()); session.getTransaction().rollback();
vars.add(v);
} }
}
List<Variable> covs = new LinkedList<>(); List<Variable> vars = new LinkedList<>();
for (Variable cov : q.getCovariables()) { for (Variable var : q.getVariables()) {
Variable v = new Variable(); Variable v = new Variable();
v.setCode(cov.getCode()); v.setCode(var.getCode());
covs.add(v); vars.add(v);
} }
List<Variable> grps = new LinkedList<>(); List<Variable> covs = new LinkedList<>();
for (Variable grp : q.getGrouping()) { for (Variable cov : q.getCovariables()) {
Variable v = new Variable(); Variable v = new Variable();
v.setCode(grp.getCode()); v.setCode(cov.getCode());
grps.add(v); covs.add(v);
} }
List<Filter> fltrs = new LinkedList<>(); List<Variable> grps = new LinkedList<>();
for (Filter fltr : q.getFilters()) { for (Variable grp : q.getGrouping()) {
Filter f = new Filter(); Variable v = new Variable();
f.setId(fltr.getId()); v.setCode(grp.getCode());
f.setOperator(fltr.getOperator()); grps.add(v);
f.setValues(fltr.getValues()); }
f.setVariable(fltr.getVariable());
fltrs.add(f); List<Filter> fltrs = new LinkedList<>();
} for (Filter fltr : q.getFilters()) {
Filter f = new Filter();
f.setId(fltr.getId());
f.setOperator(fltr.getOperator());
f.setValues(fltr.getValues());
f.setVariable(fltr.getVariable());
fltrs.add(f);
}
org.hbp.mip.model.Query myQuery = new org.hbp.mip.model.Query(); org.hbp.mip.model.Query myQuery = new org.hbp.mip.model.Query();
myQuery.setId(q.getId()); myQuery.setId(q.getId());
myQuery.setVariables(vars); myQuery.setVariables(vars);
myQuery.setCovariables(covs); myQuery.setCovariables(covs);
myQuery.setGrouping(grps); myQuery.setGrouping(grps);
myQuery.setFilters(fltrs); myQuery.setFilters(fltrs);
model.setQuery(myQuery); model.setQuery(myQuery);
Dataset ds = CSVUtil.parseValues(DATA_FILE, model.getQuery()); Dataset ds = CSVUtil.parseValues(DATA_FILE, model.getQuery());
model.setDataset(ds); model.setDataset(ds);
} }
......
0% or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment