improve recipient

Reviewed-on: https://git.kahrobatoken.com/Kahroba/proto/pulls/4

.gitea/workflows/buf-ci.yaml

@@ -21,25 +21,57 @@ jobs:
         with:
           token: ${{ gitea.token }}
           path: ./
+
+      - name: install tea cli and init 
+        run: |
+          mkdir tmp && cd tmp
+          curl -SsOL https://dl.gitea.com/tea/main/tea-main-linux-amd64.xz
+          apt install xz-utils -y >/dev/null
+          xz -d tea-main-linux-amd64.xz
+          mv tea-main-linux-amd64 /usr/bin/tea
+          chmod +x /usr/bin/tea
+          cd ..
+          rm -rf tmp
+          tea --version
+          tea login add \
+            --name ${{ gitea.server_url }} \
+            --token ${{ secrets.PROD_REG_TOKEN }} \
+            --url ${{ gitea.server_url }}
       - run: go install google.golang.org/protobuf/cmd/protoc-gen-go@latest
       - run: go install google.golang.org/grpc/cmd/protoc-gen-go-grpc@latest
       - run: go install github.com/pseudomuto/protoc-gen-doc/cmd/protoc-gen-doc@latest
       - run: npm install --save @bufbuild/protobuf @bufbuild/protoc-gen-es @bufbuild/buf
       - run: buf --version
       - run: "export PATH=$PATH:./node_modules/.bin\nbuf generate \n"
-      - run: |
+      - name: tar files
-          if [ -n ${{ gitea.ref_name }} ]; then
+        run: |
-            mkdir .res
+            ls -l ./stub
             for out in go ts doc; do
-              echo releasing ${out} ...
               tar czf .res/${out}.tar.gz ./stub/${out}/
-              curl -Ss --user ${{ gitea.actor}}:${{ gitea.token}}\
-                --upload-file .res/${out}.tar.gz \
-                ${{ gitea.server_url }}/api/packages/Kahroba/generic/proto/${{ gitea.ref_name }}/${out}.tar.gz
             done
-              echo releasing proto ...
+            tar czf ./.res/src.tar.gz $(find -type f -name "*.proto")
-              tar czf ./.res/src.tar.gz $(find -type f -name "*.proto")
+            tea r c \
-              curl -Ss --user ${{ gitea.actor}}:${{ gitea.token}}\
+              --title "${{ gitea.ref_name }}" \
-                --upload-file ./.res/src.tar.gz \
+              --tag "${{ gitea.ref_name }}" \
-                ${{ gitea.server_url }}/api/packages/Kahroba/generic/proto/${{ gitea.ref_name }}/src.tar.gz
+              -a ./.res/src.tar.gz \
-          fi
+              -a ./.res/go.tar.gz \
+              -a ./.res/doc.tar.gz \
+              -a ./.res/ts.tar.gz \
+
+      # - run: |
+      #     if [ -n ${{ gitea.ref_name }} ]; then
+      #       mkdir .res
+      #       for out in go ts doc; do
+      #         echo releasing ${out} ...
+      #         tar czf .res/${out}.tar.gz ./stub/${out}/
+      #         curl -Ss --user nfel:${{ secrets.PROD_REG_TOKEN }}\
+      #           --upload-file .res/${out}.tar.gz \
+      #           ${{ gitea.server_url }}/api/packages/Kahroba/generic/proto/${{ gitea.ref_name }}/${out}.tar.gz
+      #       done
+      #         echo releasing proto ...
+      #         tar czf ./.res/src.tar.gz $(find -type f -name "*.proto")
+      #         curl -Ss --user nfel:${{ secrets.PROD_REG_TOKEN }}\
+      #           --upload-file ./.res/src.tar.gz \
+      #           ${{ gitea.server_url }}/api/packages/Kahroba/generic/proto/${{ gitea.ref_name }}/src.tar.gz
+      #     fi
+      # - run: | 

alert/v1/msg.proto

@@ -0,0 +1,65 @@
+syntax = "proto3";
+
+package alert.v1;
+
+import "base/v1/msg.proto";
+
+message AlertFilter {
+  base.v1.Filter base_filter = 1;
+  Importance importance = 2;
+  LogSource source = 3;
+}
+
+//Importance of given event
+enum Importance {
+  LOW = 0; // Low Severity ( unimportant and can be ignored )
+  MEDIUM = 1; // MEDIUM Severity
+  HIGH = 2; // High Severity
+  CRITICAL = 3; // CRITICAL Severity ( can cause panics and data lost )
+}
+
+enum LogSource {
+  UNKNOWN = 0;
+  USER = 1;
+  SYSTEM = 2;
+  WALLET = 3;
+}
+
+message Meta {
+  uint32 created_at_ts = 1;
+  uint32 updated_at_ts = 2;
+  uint32 blamer_id = 3; // User ID of person who made the change
+}
+
+message LogEvent {
+  optional uint64 id = 1; // Record Id of Log stored in db
+  string content = 2;
+  string effective_user = 3;
+  optional LogSource source = 5;
+  Importance importance = 6;
+  Meta meta = 7;
+}
+
+message LogEventList {
+  repeated LogEvent events = 1;
+}
+/*
+   Internal Msg
+*/
+
+message SMSChangeLog {
+  uint32 when_ts = 1;
+  string what = 2;
+}
+
+message SMS {
+  string recipient = 1; //recipient
+  string text = 2;
+  optional string sender = 3;
+  Meta meta = 4;
+  repeated SMSChangeLog change_log = 5;
+}
+
+message SMSList {
+  repeated SMS sms = 1;
+}

alert/v1/srv.proto

@@ -0,0 +1,12 @@
+syntax = "proto3";
+
+package alert.v1;
+
+import "alert/v1/msg.proto";
+import "base/v1/msg.proto";
+
+service AlertSrv {
+  rpc Emit(LogEvent) returns (base.v1.StatusRes) {}
+  rpc Update(LogEvent) returns (base.v1.StatusRes) {}
+  rpc Get(AlertFilter) returns (base.v1.StatusRes) {}
+}

auth/v1/internal_srv.proto

@@ -0,0 +1,9 @@
+syntax = "proto3";
+
+package auth.v1;
+
+import "auth/v1/msg.proto";
+
+service InternalAuthorizationService {
+    rpc LookUpName(LookUpNameReq) returns (LookUpNameRes) {}
+}

auth/v1/msg.proto

@@ -131,7 +131,7 @@ message Identity {
   string updated_at = 18;
   string created_at = 19;
   string email = 20;
-  string  mobile = 21;
+  string mobile = 21;
   optional Company company = 22;
   optional string employee_info = 23;
 }
@@ -208,3 +208,31 @@ message CheckTFAReq {
   optional string algorithm = 3;
   optional string reason = 4; // Can be later used as a lookup
 }
+
+message TFA {
+  TfaStateEnum state = 1;
+  int64 code = 2;
+  string transaction_id = 3;
+}
+
+enum TfaStateEnum {
+  TFA_STATE_ENUM_UNSPECIFIED = 0;
+  LOGIN = 1;
+  INTERNAL_TRANSFER = 2;
+  EXTERNAL_TRANSFER = 3;
+}
+
+message Recipient {
+  string key = 1;
+  optional string first_name = 2;
+  optional string last_name = 3;
+  optional string public_key = 4;
+}
+
+message LookUpNameReq {
+  Recipient recipient = 1;
+}
+
+message LookUpNameRes {
+  Recipient recipient = 1;
+}

auth/v1/srv.proto

@@ -14,8 +14,7 @@ service AuthorizationService {
 
   rpc UserLoginSendOTP(UserSendOtpReq) returns (UserSendOtpRes) {}
   rpc UserLoginWithOTP(UserLoginReq) returns (UserAccessTokenRes) {}
-  rpc UserGetAccessTokenByRefreshToken(UserRefreshTokenReq)
+  rpc UserGetAccessTokenByRefreshToken(UserRefreshTokenReq) returns (UserAccessTokenRes) {}
-      returns (UserAccessTokenRes) {}
 
   rpc UserGetUserPermission(InternalIAM) returns (PermissionList) {}
 

base/v1/msg.proto

@@ -13,3 +13,12 @@ message IdRes {
 message IdReq {
   int64 id = 1;
 }
+message Pagination {
+  uint32 page = 1; // in query param it will be p
+  uint32 page_size = 2; // in query param it will be pz
+}
+message Filter {
+  string query = 1; // q
+  string sort = 2; // s
+  optional Pagination page = 3;
+}

buf.gen.yaml

@@ -28,8 +28,11 @@ plugins:
     out: stub/doc/md
   # # NOTE: Gateway
   # # - remote: buf.build/grpc-ecosystem/gateway:v2.16.2
-  # - local: protoc-gen-grpc-gateway
+  - local: protoc-gen-grpc-gateway
-  #   out: stub/go
+    out: stub/go
+    opt:
+      - standalone=true
+      - generate_unbound_methods=true
   # # NOTE: SWAGGER json files
   # # - remote: buf.build/grpc-ecosystem/openapiv2:v2.16.2
   # - local: protoc-gen-openapiv2

wallet/v1/msg.proto

@@ -289,17 +289,21 @@ message UserBuyAssetReq {
    Transfer
 */
 
-message UserTransferAssetReq {
+message InternalTransferAssetReq {
   auth.v1.InternalIAM iam = 1;
-  int64 asset_id = 2;
+  auth.v1.Recipient recipient = 2;
   double amount = 3;
-  string to_wallet_address = 4;
+  optional int64 network_id = 4;
-  string to_wallet_memo = 5;
+  int64 asset_id = 5;
+  optional bool approval = 6;
+  optional auth.v1.TFA tfa = 7;
 }
 
-message UserTransferRes {
+message InternalTransferAssetRes {
-  int64 transaction_id = 1;
+  auth.v1.Recipient recipient = 1;
-  string tracking_code = 2;
+  double amount = 2;
+  string transaction_id = 3;
+  string transaction_hash = 4;
 }
 
 // represent the information regarding the sale of the token
@@ -377,3 +381,11 @@ message RedeemTokenRes {
 message RedeemTokenResList {
   repeated RedeemTokenRes list = 1;
 }
+
+message GetPublicKeyByNationalIDReq {
+  string national_id = 1;
+}
+
+message GetPublicKeyByNationalIDRes {
+  string pub_key = 1;
+}

wallet/v1/srv.proto

@@ -19,7 +19,6 @@ service WalletService {
 
   rpc UserInitWallet(UserInitWalletReq) returns (base.v1.StatusRes);
   rpc UserGetWalletList(auth.v1.InternalIAM) returns (WalletList);
-  rpc UserTransferAsset(UserTransferAssetReq) returns (UserTransferRes);
 
   rpc UserGetTransactionList(UserGetTransactionListReq) returns (TransactionList);
 
@@ -39,4 +38,9 @@ service WalletService {
   rpc CalculateRedeemToken(RedeemTokenReq) returns (CalculateRedeemTokenRes);
   rpc RedeemToken(RedeemTokenReq) returns (base.v1.StatusRes);
   rpc RedeemTokenList(auth.v1.ReqWithIAMAndParams) returns (RedeemTokenResList);
+
+  rpc GetPublicKeyByNationalID(GetPublicKeyByNationalIDReq) returns (GetPublicKeyByNationalIDRes);
+
+  // Assets routing
+  rpc InternalTransferAsset(InternalTransferAssetReq) returns (InternalTransferAssetRes);
 }