From 3e3492254e8a68e17673f6a65e8f674196317009 Mon Sep 17 00:00:00 2001 From: GME Date: Sat, 13 Apr 2019 21:14:26 +0200 Subject: [PATCH] update --- msp/org1/admin.context | Bin 1398 -> 1398 bytes .../java/blockchain/configuration/Config.java | 15 ++-- src/main/java/database/DatabaseHelper.java | 3 +- .../WalletImplementation.java | 5 +- src/main/java/restService/StringResponse.java | 8 +- src/main/java/restService/UserResource.java | 7 +- .../blockchain/query/User/ReadUserTest.java | 3 +- .../query/Wallet/QueryWalletByOwnerTest.java | 4 +- .../CreateDataSetProcess.java | 72 +++++++++++------- .../WalletImplementationTest.java | 2 + 10 files changed, 75 insertions(+), 44 deletions(-) diff --git a/msp/org1/admin.context b/msp/org1/admin.context index 185db9d549bfd2aef030bfd5fbaddd0c0d645882..45ce6d3204fa299f2568b20cb52a3afe0addf8a4 100644 GIT binary patch delta 526 zcmWm7Ic(EV0D$3y1d6OqEC_@ckh;`Du^Y!p1Pss5Cg*eP*d~XBkaOAb(fCN>#sjSo z&0}up+ z1`wyfg2*=Pvg(_b5Ef}(;)EXSRW-tz1g>RCxW&{(CoPZbm^vcTCsQpSxLkT5$sLV= zW4nR6(v4CyF_+A5@RG`$kvU0%O8J#fC9-+V(p{iPC*rr%eO=JZc1 zclVxT(X;Bd`5ZfQcK%_0_eLx_^MZ{rk@$nZVfb}+uAK2A8*ewZMk_wJIJQH4!%};qwz~O6UDlf|w($n&)oZm>6IeB%B4+??8jRfpl zOwUC_qo|U;Kd{>)5sw$6*SFZZ(T9$O*K$>@#sG$(V#RV9N)1y1s9VZm3QH^m4hYg+uSvUUTeEbfH0TaS zV#hY~oEW!sK2fISl%iT%N367i?D%qQvULc-1N!6icXQ$J^fvzUWG?n;bMWo_{hRZC z_3r+`yQkEtx#c^BNj4gpeU^*TQ?c-PKK1bShrwg>SLw?8=fkCKX6eh>o!zgay-P1A z=a@4uUNIPS4t^~B-X|Al?!EoIdyD^>I_4XXuD)JOW=9)Sv*n(ZL^biBX0Xw5Jn|Qz Cyu3yL diff --git a/src/main/java/blockchain/configuration/Config.java b/src/main/java/blockchain/configuration/Config.java index fff8961..c3f8938 100644 --- a/src/main/java/blockchain/configuration/Config.java +++ b/src/main/java/blockchain/configuration/Config.java @@ -21,13 +21,13 @@ public class Config { //CA - //public static final String CA_ORG1_URL = "http://vps577432.ovh.net:7054"; - public static final String CA_ORG1_URL = "http://93.30.148.59:7054"; + public static final String CA_ORG1_URL = "http://vps577432.ovh.net:7054"; + //public static final String CA_ORG1_URL = "http://93.30.148.59:7054"; //public static final String CA_ORG1_URL = "http://vps592802.ovh.net:7054"; //ORDERER - //public static final String ORDERER_URL = "grpc://vps577432.ovh.net:7050"; - public static final String ORDERER_URL = "grpc://93.30.148.59:7050"; + public static final String ORDERER_URL = "grpc://vps577432.ovh.net:7050"; + //public static final String ORDERER_URL = "grpc://93.30.148.59:7050"; //public static final String ORDERER_URL = "grpc://vps592802.ovh.net:7050"; public static final String ORDERER_NAME = "orderer.example.com"; @@ -35,14 +35,15 @@ public class Config { //CHANNEL - CHAINCODE public static final String CHANNEL_NAME = "mychannel"; - public static final String CHAINCODE_NAME = "monnethic"; + //public static final String CHAINCODE_NAME = "monnethic"; + public static final String CHAINCODE_NAME = "monnethic_qa"; //public static final String CHAINCODE_PROD = "monnethic-prod"; //PEER 0 public static final String ORG1_PEER_0 = "peer0.org1.example.com"; - //public static final String ORG1_PEER_0_URL = "grpc://vps577432.ovh.net:8051"; - public static final String ORG1_PEER_0_URL = "grpc://93.30.148.59:7051"; + public static final String ORG1_PEER_0_URL = "grpc://vps577432.ovh.net:7051"; + //public static final String ORG1_PEER_0_URL = "grpc://93.30.148.59:7051"; //public static final String ORG1_PEER_0_URL = "grpc://93.30.148.59:8051"; //ublic static final String ORG1_PEER_0_URL = "grpc://vps592802.ovh.net:7051"; diff --git a/src/main/java/database/DatabaseHelper.java b/src/main/java/database/DatabaseHelper.java index 48101f2..7ae4616 100644 --- a/src/main/java/database/DatabaseHelper.java +++ b/src/main/java/database/DatabaseHelper.java @@ -4,7 +4,8 @@ import com.j256.ormlite.jdbc.JdbcConnectionSource; import com.j256.ormlite.support.ConnectionSource; public class DatabaseHelper { - private static final String DATABASE_NAME = "monnethic_test"; + //private static final String DATABASE_NAME = "monnethic_test"; + private static final String DATABASE_NAME = "monnethic_qa"; private static final String DATABASE_USER = "monnethicadmin"; private static final String DATABASE_PWD = "vHEQszGXcJ6;/)}z!V"; private final static String DATABASE_URL = "jdbc:postgresql://37.187.101.44:5432/"+DATABASE_NAME; diff --git a/src/main/java/restImplementation/WalletImplementation.java b/src/main/java/restImplementation/WalletImplementation.java index 8f54687..fac038a 100644 --- a/src/main/java/restImplementation/WalletImplementation.java +++ b/src/main/java/restImplementation/WalletImplementation.java @@ -86,9 +86,12 @@ public class WalletImplementation { User association = userDao.getUserWithHash(associationHash); if(association != null){ System.out.println("CHECK PWD"); - if(BCrypt.checkpw(associationPwd, association.getPassword())){ + if(BCrypt.checkpw(associationPwd, association.getPassword())){ + System.out.println("OK"); double newBalance = 0.0; + System.out.println("walletHash : "+walletHash); + System.out.println("amount : "+amount); transactionWrapper.sendTransaction("setBalanceOnWallet",new String[]{walletHash,String.valueOf(amount)}); Wallet wallet = getWallet(walletHash); if(wallet!=null){ diff --git a/src/main/java/restService/StringResponse.java b/src/main/java/restService/StringResponse.java index 7d80d43..9872e90 100644 --- a/src/main/java/restService/StringResponse.java +++ b/src/main/java/restService/StringResponse.java @@ -2,7 +2,7 @@ package restService; public class StringResponse { private String response; - private String userHash; + private String user_hash; private Double userBalance; public StringResponse(String response){ @@ -16,7 +16,7 @@ public class StringResponse { public StringResponse(String response, String userHash){ this.response=response; - this.userHash=userHash; + this.user_hash=userHash; } public String getResponse() { @@ -28,11 +28,11 @@ public class StringResponse { } public String getUserHash() { - return userHash; + return user_hash; } public void setUserHash(String userHash) { - this.userHash = userHash; + this.user_hash = userHash; } public Double getUserBalance(){return userBalance;} diff --git a/src/main/java/restService/UserResource.java b/src/main/java/restService/UserResource.java index fe9891f..ea9a4fd 100644 --- a/src/main/java/restService/UserResource.java +++ b/src/main/java/restService/UserResource.java @@ -54,7 +54,7 @@ public class UserResource { @RequestMapping(value = "/login", method = RequestMethod.POST, produces = "application/json") @ResponseStatus(HttpStatus.OK) - public ResponseEntity login(@Valid @RequestBody User user){ + public ResponseEntity login(@Valid @RequestBody User user){ try{ UserImplementation userImplementation = new UserImplementation(); Map response = userImplementation.userLogger(user); @@ -72,8 +72,9 @@ public class UserResource { return ResponseEntity.status(HttpStatus.INTERNAL_SERVER_ERROR).body(responseS); } case "true":{ - StringResponse responseS = new StringResponse("Ok",response.get("user_hash")); - return ResponseEntity.status(HttpStatus.OK).body(responseS); + //StringResponse responseS = new StringResponse("Ok",response.get("user_hash")); + String r = "{\"response\":\"ok\",\"user_hash\":\""+response.get("user_hash")+"\"}"; + return ResponseEntity.status(HttpStatus.OK).body(r); } default:{ StringResponse responseS = new StringResponse("Error"); diff --git a/src/test/java/blockchain/query/User/ReadUserTest.java b/src/test/java/blockchain/query/User/ReadUserTest.java index 4ed5a75..f12c49c 100644 --- a/src/test/java/blockchain/query/User/ReadUserTest.java +++ b/src/test/java/blockchain/query/User/ReadUserTest.java @@ -22,11 +22,12 @@ public class ReadUserTest { try{ QueryWrapper queryWrapper = new QueryWrapper(); String functionName = "readUser"; - String[] args = new String[]{"$2a$10$wKfsus5O9C8.CI8JZxqeweSAzxgEOYpdaoRoHi85w05cGYGyDqTYK"}; + String[] args = new String[]{"$2a$10$r7jlPdeESPFd1dKjvrEmB.SoxOXh3jHtWiPTAFKB3lGSgvda.zMyC"}; String response = queryWrapper.sendQuery(functionName,args); if(response != null){ JsonReader reader = Json.createReader(new StringReader(response)); JsonObject userInfo = reader.readObject(); + logger.info(userInfo.toString()); logger.info("userAssociation : "+userInfo.getString("userAssociation")); logger.info("userFirstName : "+userInfo.getString("userFirstName")); } else { diff --git a/src/test/java/blockchain/query/Wallet/QueryWalletByOwnerTest.java b/src/test/java/blockchain/query/Wallet/QueryWalletByOwnerTest.java index 76f0355..f2fa729 100644 --- a/src/test/java/blockchain/query/Wallet/QueryWalletByOwnerTest.java +++ b/src/test/java/blockchain/query/Wallet/QueryWalletByOwnerTest.java @@ -24,7 +24,8 @@ public class QueryWalletByOwnerTest { try{ QueryWrapper queryWrapper = new QueryWrapper(); String functionName = "queryWalletsByOwner"; - String[] args = new String[]{"$2a$10$2H6rEnTlEUBk18xUjXx5YuTmgiUMtyRdxgTjfugVlAcZbtDfPiWky"}; + //String[] args = new String[]{"$2a$10$r7jlPdeESPFd1dKjvrEmB.SoxOXh3jHtWiPTAFKB3lGSgvda.zMyC"}; + String[] args = new String[]{"$2a$10$nXjf7raNTCe2gdUiMCsNEegqUBQ6iihgc8LtoBUux02hL8j49b1rG"}; String response = queryWrapper.sendQuery(functionName,args); logger.info("response : "+response); @@ -38,6 +39,7 @@ public class QueryWalletByOwnerTest { o = o.get("Record").asJsonObject(); logger.info("JsonObject : "+o); logger.info("walletInfo ID : "+o.getString("id")); + logger.info("walletInfo balance : "+o.getJsonNumber("balance")); } } diff --git a/src/test/java/restImplementation/CreateDataSetProcess.java b/src/test/java/restImplementation/CreateDataSetProcess.java index 3290955..d7b2b87 100644 --- a/src/test/java/restImplementation/CreateDataSetProcess.java +++ b/src/test/java/restImplementation/CreateDataSetProcess.java @@ -20,40 +20,55 @@ public class CreateDataSetProcess { //OK private static String walletHash2UserB = ""; public static void main(String [ ] args){ + BasicConfigurator.configure(); User association = new User("Gonette","Association","gonette-lyon@gmail.com","asso_GonE8977&4$*-","gonette"); User userA = new User("Meunier","Thomas","thomas.meunier@gmail.com","thomasPwd158$*","gonette"); User userB = new User("Petit","Claire","claire.petit@gmail.com","gonClaire789$*","0607080900","gonette"); + String assoPwd = association.getPassword(); String userBPwd = userB.getPassword(); - - + /* registerUser(association); association.setUser_hash(gonetteHash); registerUser(userA); userA.setUser_hash(userHashA); registerUser(userB); userB.setUser_hash(userHashB); + */ - approveUser(userA); - approveUser(userB); - - Wallet walletAUserA = new Wallet("client",userHashA); - Wallet walletBUserA = new Wallet("fournisseur",userHashA); - Wallet walletAUserB = new Wallet("client",userHashB); - Wallet walletBUserB = new Wallet("personnel",userHashB); - - createWallet(walletAUserA); - createWallet(walletBUserA); - createWallet(walletAUserB); - createWallet(walletBUserB); + userA.setUser_hash("$2a$10$r7jlPdeESPFd1dKjvrEmB.SoxOXh3jHtWiPTAFKB3lGSgvda.zMyC"); + userB.setUser_hash("$2a$10$nXjf7raNTCe2gdUiMCsNEegqUBQ6iihgc8LtoBUux02hL8j49b1rG"); + association.setUser_hash("$2a$10$otvlv9oGEbnOPuImSJDDw.XDb3Bl7TR/Qw7w1HIfX0je11R/0leiS"); + //approveUser(userA); + //approveUser(userB); + //approveUser(association); - setBalance(association.getUser_hash(), assoPwd, walletBUserA.getWallet_hash(),120); - setBalance(association.getUser_hash(), assoPwd, walletAUserB.getWallet_hash(),50); + Wallet walletAUserA = new Wallet("client",userA.getUser_hash()); + Wallet walletBUserA = new Wallet("fournisseur",userA.getUser_hash()); + Wallet walletAUserB = new Wallet("client",userB.getUser_hash()); + Wallet walletBUserB = new Wallet("personnel",userB.getUser_hash()); + + //String wHash1 = createWallet(walletAUserA); + //walletAUserA.setWallet_hash(wHash1); + //String wHash2 = createWallet(walletBUserA); + //walletBUserA.setWallet_hash(wHash2); + //String wHash3 = createWallet(walletAUserB); + //walletAUserB.setWallet_hash(wHash3); + //String wHash4 = createWallet(walletBUserB); + //walletBUserB.setWallet_hash(wHash4); + walletBUserA.setWallet_hash("$2a$10$dmrOFohMnbeVzVHMGc5JnuQ7MMTObn3lHTrMSe/IonD3VTeM.muo."); + walletAUserB.setWallet_hash("$2a$10$auM7V8D0EuftV.2TqzWgi.4MIw0EzSJ8JyE5F5GzKknzqnila.EUm"); + + + + //setBalance(association.getUser_hash(), assoPwd, walletBUserA.getWallet_hash(),120); + //setBalance(association.getUser_hash(), assoPwd, walletAUserB.getWallet_hash(),50); doTransaction(userB.getUser_hash(), userBPwd, walletAUserB.getWallet_hash(),walletBUserA.getWallet_hash(),10,userB.getAssociation()); + } private static void registerUser(User user){ @@ -87,30 +102,35 @@ public class CreateDataSetProcess { //OK } } - private static void createWallet(Wallet wallet){ + + private static String createWallet(Wallet wallet){ + String wHash=""; WalletImplementation walletImplementation = new WalletImplementation(); try{ - Map walletResponse = walletImplementation.createWallet(wallet); + Wallet walletResponse = walletImplementation.createWallet(wallet); if(wallet.getUser_hash().equals(userHashA) && wallet.getType().equals("client")){ - walletHash1UserA = walletResponse.get("walletHash"); + walletHash1UserA = walletResponse.getWallet_hash(); } else if(wallet.getUser_hash().equals(userHashA) && wallet.getType().equals("fournisseur")){ - walletHash2UserA = walletResponse.get("walletHash"); + walletHash2UserA = walletResponse.getWallet_hash(); } else if(wallet.getUser_hash().equals(userHashB) && wallet.getType().equals("personnel")){ - walletHash1UserB = walletResponse.get("walletHash"); + walletHash1UserB = walletResponse.getWallet_hash(); } else { - walletHash2UserB = walletResponse.get("walletHash"); + walletHash2UserB = walletResponse.getWallet_hash(); } - logger.info("wallet hash: "+walletResponse.get("walletHash")); - logger.info("wallet balance: "+walletResponse.get("walletBalance")); - logger.info("wallet type: "+walletResponse.get("walletType")); - logger.info("onwer: "+walletResponse.get("ownerHash")); + logger.info("wallet hash: "+walletResponse.getWallet_hash()); + logger.info("wallet balance: "+walletResponse.getBalance()); + logger.info("wallet type: "+walletResponse.getType()); + logger.info("onwer: "+walletResponse.getUser_hash()); + wHash = walletResponse.getWallet_hash(); }catch (Exception e){ logger.warn("Error approveUser : "+e); } + return wHash; } + private static void setBalance(String associationHash, String associationPwd, String walletHash, double amount){ WalletImplementation walletImplementation = new WalletImplementation(); try{ diff --git a/src/test/java/restImplementation/WalletImplementationTest.java b/src/test/java/restImplementation/WalletImplementationTest.java index 4077793..c0dc0e7 100644 --- a/src/test/java/restImplementation/WalletImplementationTest.java +++ b/src/test/java/restImplementation/WalletImplementationTest.java @@ -12,6 +12,7 @@ import java.util.Map; public class WalletImplementationTest { private static Logger logger = Logger.getLogger(WalletImplementationTest.class); + /* @Test public void CreateWalletTest() { // OK BasicConfigurator.configure(); @@ -32,6 +33,7 @@ public class WalletImplementationTest { logger.warn("Error: "+e.getMessage()); } } + */ @Test public void TestDeleteWallet() { //OK