--wip-- [skip ci]

Signed-off-by: nfel <nfilsaraee@gmail.com>

errors/v1/msg.proto

@@ -83,6 +83,7 @@ enum ErrCode {
   MARKET_ORDER_CANCELED = 7023;
   MARKET_ORDER_FAILED = 7024;
   MARKET_ORDER_UNKNOWN = 7025;
+  MARKET_ORDER_UNSUPPORTED_PARTICIPANT_TYPE = 7045;
   ASSET_CAN_NOT_BUY = 7026;
   ASSET_BUY_PRICE_IS_ZERO = 7019;
   MARKET_ORDER_MATCHING_ERR_REFUND = 7128;

market/v1/msg.proto

@@ -34,18 +34,16 @@ message CalcMarketReq {
   int64 counter_asset_id = 3;
   double amount = 4;
   double unit_price = 5;
-  MarketParticipantType type = 6;
-  wallet.v1.BuyAssetSide req_side =
-      7; // For Calculation : can be from asset or irt
+  MarketParticipantType participant_type = 6;
+  wallet.v1.BuyAssetSide req_side = 7; // For Calculation : can be from asset or irt
 }
 
 message CalcMarketRes {
   double calculated_irt_amount = 1;
   double calculated_asset_amount = 2;
   wallet.v1.EffectiveCommission commission = 3;
-  MarketParticipantType type = 4;
-  wallet.v1.BuyAssetSide req_side =
-      5; // For Calculation : can be from asset or irt
+  MarketParticipantType participant_type = 4;
+  wallet.v1.BuyAssetSide req_side = 5; // For Calculation : can be from asset or irt
 }
 
 message MPHistoryFilter {}
@@ -61,24 +59,25 @@ message MarketOrder {
   MarketOrderSide side = 8;
   MarketOrderStatus status = 9;
   int64 from = 10;
-  auth.v1.UserIdentityBasic from_identity = 11;
-  wallet.v1.Commission commission = 12;
-  double completed_amount = 13;
-  double available_amount = 14;
-  string created_at = 15;
-  string updated_at = 16;
-  bool is_public = 17;
-  wallet.v1.TransactionList trx = 18;
-  repeated string tags = 19;
-  repeated string comment = 20;
-  optional MarketOrder source = 21; // purchase is done via this field
+  MarketParticipantType participant_type = 11;
+  auth.v1.UserIdentityBasic from_identity = 12;
+  wallet.v1.Commission commission = 13;
+  double completed_amount = 14;
+  double available_amount = 15;
+  string created_at = 16;
+  string updated_at = 17;
+  bool is_public = 18;
+  wallet.v1.TransactionList trx = 19;
+  repeated string tags = 20;
+  repeated string comment = 21;
+  optional MarketOrder source = 22; // purchase is done via this field
+  optional uint64 maker_order_id = 23;
   // repeated string attachments = 14; // possible files included by
   // seller/buyer
 }
 
 message MarketAssetListReq {
-  optional auth.v1.InternalIAM iam =
-      1; // If not set, will returns only public orders which are limited by a
+  optional auth.v1.InternalIAM iam = 1; // If not set, will returns only public orders which are limited by a
   optional uint32 page_no = 2;
   optional uint32 page_size = 3;
 }
@@ -90,17 +89,16 @@ message MarketAssetList {
   uint32 total_count = 4;
 }
 
-message PurchaseReq {
+message MatchOrderReq {
   auth.v1.InternalIAM iam = 1;
   uint64 order_id = 2;
   double amount = 3;
-  wallet.v1.BuyAssetSide req_side =
-      7; // For Calculation : can be from asset or irt
+  wallet.v1.BuyAssetSide req_side = 7; // For Calculation : can be from asset or irt
   optional bool accepted_contract = 4;
   optional auth.v1.TFA tfa = 5;
 }
 
-message PurchaseRes {
+message MatchOrderRes {
   uint64 order_id = 1;
   double calculated_irt_amount = 2;
   double calculated_asset_amount = 3;
@@ -115,18 +113,24 @@ message MarketOrderList {
   uint32 total_count = 4;
 }
 
+/*
+ * participant_type: IS Maker/Taker
+ * side: IS Buying/Selling
+ * req_side: IS input (amount) in irt/asset 
+ * */
 message NewMarketReq {
   auth.v1.InternalIAM iam = 1;
   int64 asset_id = 2;
   int64 counter_asset_id = 3;
   double amount = 4;
   double unit_price = 5;
-  MarketParticipantType type = 6;
-  wallet.v1.BuyAssetSide req_side =
-      7; // For Calculation : can be from asset or irt
+  // TODO: Change name
+  MarketParticipantType participant_type = 6;
+  // For Calculation : can be from asset or irt
+  wallet.v1.BuyAssetSide req_side = 7;
   MarketOrderSide side = 8;
-  optional auth.v1.TFA tfa = 9;
-  optional bool accepted_contract = 10;
+  // TODO: maker market order as optional
+  optional uint64 maker_order_id = 9;
 }
 
 enum MarketOrdersSortBy {
@@ -150,7 +154,7 @@ message OrderListFilter {
   repeated string to = 7;
   optional double starting_price = 8;
   optional double ending_price = 9;
-  repeated wallet.v1.Asset asset = 10;
+  repeated uint64 asset = 10;
   optional uint64 order_id = 11;
   optional uint64 trx_id = 12;
   optional bool is_public = 13;
@@ -162,3 +166,32 @@ message OrderListFilter {
   optional uint32 page_no = 19;
   optional uint32 page_size = 20;
 }
+
+/* Contract */
+message ContractMarketRes {
+  string link = 1;
+  uint64 asset_id = 2;
+  uint64 agreement_id = 3;
+  uint64 transaction_id = 4;
+  string contract_hash = 5;
+  string contract_content = 6;
+}
+
+message DeclineMarketContractReq {
+  auth.v1.InternalIAM iam = 1;
+  uint64 agreement_id = 2;
+}
+
+message ConfirmMarketContractReq {
+  auth.v1.InternalIAM iam = 1;
+  uint64 agreement_id = 2;
+  optional auth.v1.TFA tfa = 3;
+}
+
+message MarketContractReq {
+  auth.v1.InternalIAM iam = 1;
+  // uint64 asset_id = 2;
+  uint64 order_id = 2; // Maker OrderID
+  // double amount = 4;
+  // wallet.v1.BuyAssetSide req_side = 5;
+}

market/v1/srv.proto

@@ -7,21 +7,20 @@ import "base/v1/msg.proto";
 import "market/v1/msg.proto";
 
 service MarketplaceSrv {
-  rpc CalcMarketOrder(CalcMarketReq) returns (CalcMarketRes);
 
   rpc MarketplaceSrvHealth(base.v1.Empty) returns (base.v1.StatusRes);
 
+  rpc GetMarketPubHistory(OrderListFilter) returns (MarketOrderList); // This is for public market
+  rpc GetUserMarketHistory(OrderListFilter) returns (MarketOrderList); // list of order + purchase related to buying an asset
   rpc GetMarketOrderDet(auth.v1.IdReqWithIAM) returns (MarketOrder); // details of an order by id
   rpc GetAllOrderList(OrderListFilter) returns (MarketOrderList); // list of all orders (seller and buyer combined)
-
   rpc GetMarketAssetList(MarketAssetListReq) returns (MarketAssetList); //  assets that can be listed in marketplace
 
-  rpc NewMarketOrder(NewMarketReq) returns (MarketOrder); // insert new buy order to market
-
-  rpc Purchase(PurchaseReq) returns (PurchaseRes); // purchase from an order
+  rpc CalcMarketOrder(CalcMarketReq) returns (CalcMarketRes);
 
   rpc CancelOrder(auth.v1.IdReqWithIAMAndTFA) returns (base.v1.StatusRes); // cancel an order
 
-  rpc GetMarketPubHistory(OrderListFilter) returns (MarketOrderList); // This is for public market
-  rpc GetUserMarketHistory(OrderListFilter) returns (MarketOrderList); // list of order + purchase related to buying an asset
+  rpc NewMarketOrder(NewMarketReq) returns (MarketOrder); // insert new buy order to market
+  rpc GenerateMarketContract(MarketContractReq) returns (ContractMarketRes);
+  rpc ConfirmMarketContract(ConfirmMarketContractReq) returns (base.v1.StatusRes);
 }

wallet/v1/msg.proto

@@ -9,7 +9,9 @@ import "base/v1/msg.proto";
    INTERNAL DATA
 */
 
-message InternalTransactionData { int64 transaction_id = 1; }
+message InternalTransactionData {
+  int64 transaction_id = 1;
+}
 
 /*
    Federation
@@ -99,7 +101,7 @@ message Asset {
   string image = 8;
   string description = 9;
   string url = 10;
-  int64 buy_unit_price = 11;
+  // int64 buy_unit_price = 11;
   double buy_min_amount = 12;
   double buy_max_amount = 13;
   bool is_active = 20;
@@ -163,8 +165,9 @@ message AssetFilter {
   optional bool can_sell = 7;
   optional bool can_deposit = 8;
   optional bool can_withdraw = 9;
-  optional bool is_active = 10;
-  optional string search = 11; // Not yet implemented !
+  optional bool can_trade = 10;
+  optional bool is_active = 11;
+  optional string search = 12; // Not yet implemented !
 }
 
 message AssetDiscountReq {
@@ -181,15 +184,14 @@ message AssetDiscountRes {
   double static_amount = 4;
   double percentage = 5;
   double max_amount = 6;
-  double effective_amount =
-      7; // based of asset price and discount amount in req
+  double effective_amount = 7; // based of asset price and discount amount in req
   optional int64 supported_asset = 8;
 }
 
 message AssetPrice {
   string updated_at = 1;
   double market_price = 2;
-  double platform_price = 3;
+  double ico_price = 3;
 }
 
 message GetAssetReq {
@@ -197,7 +199,9 @@ message GetAssetReq {
   optional string code = 3;
 }
 
-message AssetMeta { PropertyMeta property = 1; }
+message AssetMeta {
+  PropertyMeta property = 1;
+}
 
 message PropertyMeta {
   string description = 1;
@@ -211,11 +215,10 @@ message PropertyMeta {
   string usage_type = 9;
   string completion_date = 10;
   string user_agreement_url = 11;
-  string location_image = 12;
-  float lat = 13;
-  float lng = 14;
-  string map_link = 15;
-  PropertyDetail detail = 16;
+  float lat = 12;
+  float lng = 13;
+  string map_link = 14;
+  PropertyDetail detail = 15;
 }
 
 message PropertyDetail {
@@ -292,8 +295,7 @@ message UserBNPLReq {
   optional float amount = 7;
   optional PaymentPeriodInfo payment_period = 8;
   optional bool has_agreed_contract = 9;
-  optional int32 current_step =
-      10; // Can be useful for admin to change the current step
+  optional int32 current_step = 10; // Can be useful for admin to change the current step
   optional int64 asset_id = 11;
 }
 
@@ -481,7 +483,9 @@ message NationalIDReq {
   string national_id = 2;
 }
 
-message PubKeyRes { string pub_key = 1; }
+message PubKeyRes {
+  string pub_key = 1;
+}
 
 /*
    Network Details
@@ -609,7 +613,9 @@ message IPGConfirmReq {
   string final_amount = 7;
 }
 
-message IPGConfirmRes { string receipt_link = 1; }
+message IPGConfirmRes {
+  string receipt_link = 1;
+}
 
 message SaleManualReq {
   auth.v1.InternalIAM iam = 1;
@@ -684,9 +690,11 @@ message BuyAssetRes {
 /* Contract */
 enum ContractType {
   CONTRACT_TYPE_ICO = 0;
-  CONTRACT_TYPE_MARKET = 1;
+  CONTRACT_TYPE_MARKET = 1; //FIXME: Please remove this :)
   CONTRACT_TYPE_BNPL = 2;
   CONTRACT_TYPE_REDEEM = 3;
+  CONTRACT_TYPE_MARKET_MAKER = 4;
+  CONTRACT_TYPE_MARKET_TAKER = 5;
 }
 
 // agreement_id