Compare commits
1 Commits
| Author | SHA1 | Date | |
|---|---|---|---|
| 33474ccaba |
@@ -1,33 +0,0 @@
|
|||||||
name: Build Proto
|
|
||||||
description: Install buf CLI, run buf lint and buf build
|
|
||||||
inputs:
|
|
||||||
buf_version:
|
|
||||||
description: Buf CLI version to install
|
|
||||||
required: false
|
|
||||||
default: "1.72.0"
|
|
||||||
runs:
|
|
||||||
using: composite
|
|
||||||
steps:
|
|
||||||
- name: Setup Buf CLI
|
|
||||||
shell: bash
|
|
||||||
env:
|
|
||||||
BUF_VERSION: ${{ inputs.buf_version }}
|
|
||||||
run: |
|
|
||||||
ARCH="$(uname -m)"
|
|
||||||
case "$ARCH" in
|
|
||||||
x86_64) BIN="buf-Linux-x86_64" ;;
|
|
||||||
aarch64) BIN="buf-Linux-aarch64" ;;
|
|
||||||
arm64) BIN="buf-Darwin-arm64" ;;
|
|
||||||
*) BIN="buf-Linux-x86_64" ;;
|
|
||||||
esac
|
|
||||||
curl -sSL "https://github.com/bufbuild/buf/releases/download/v${BUF_VERSION}/${BIN}.tar.gz" -o buf.tar.gz
|
|
||||||
tar -xzf buf.tar.gz
|
|
||||||
cp buf/bin/buf /usr/local/bin/buf
|
|
||||||
chmod +x /usr/local/bin/buf
|
|
||||||
rm -rf buf buf.tar.gz
|
|
||||||
- name: Lint
|
|
||||||
shell: bash
|
|
||||||
run: buf lint
|
|
||||||
- name: Build
|
|
||||||
shell: bash
|
|
||||||
run: buf build
|
|
||||||
@@ -1,151 +0,0 @@
|
|||||||
name: Setup package mirrors
|
|
||||||
description: Benchmark package mirrors and export the fastest reachable registry for each ecosystem
|
|
||||||
inputs:
|
|
||||||
npm_mirrors:
|
|
||||||
description: Newline-separated npm-compatible registries
|
|
||||||
required: false
|
|
||||||
default: |
|
|
||||||
https://npm.reg.darano.ir/
|
|
||||||
pypi_mirrors:
|
|
||||||
required: false
|
|
||||||
default: |
|
|
||||||
https://package-mirror.liara.ir/repository/pypi/simple
|
|
||||||
https://pypi.reg.darano.ir
|
|
||||||
https://pypi-iran.ir/simple/
|
|
||||||
https://pypi.org/simple/
|
|
||||||
go_mirrors:
|
|
||||||
description: Newline-separated Go module proxies
|
|
||||||
required: false
|
|
||||||
default: |
|
|
||||||
https://go.devneeds.ir/
|
|
||||||
https://package-mirror.liara.ir/repository/go/
|
|
||||||
https://go.reg.darano.ir/
|
|
||||||
https://proxy.golang.org/
|
|
||||||
debian_mirrors:
|
|
||||||
description: Newline-separated Debian package repository base URLs
|
|
||||||
required: false
|
|
||||||
default: |
|
|
||||||
http://repo.iut.ac.ir/debian/
|
|
||||||
http://deb.debian.org/debian/
|
|
||||||
connect_timeout:
|
|
||||||
description: curl connection timeout in seconds
|
|
||||||
required: false
|
|
||||||
default: "3"
|
|
||||||
max_time:
|
|
||||||
description: curl request timeout in seconds
|
|
||||||
required: false
|
|
||||||
default: "10"
|
|
||||||
outputs:
|
|
||||||
npm_registry:
|
|
||||||
description: Fastest reachable npm registry
|
|
||||||
value: ${{ steps.select.outputs.npm_registry }}
|
|
||||||
pypi_index:
|
|
||||||
description: Fastest reachable Python package index
|
|
||||||
value: ${{ steps.select.outputs.pypi_index }}
|
|
||||||
go_proxy:
|
|
||||||
description: Fastest reachable Go module proxy
|
|
||||||
value: ${{ steps.select.outputs.go_proxy }}
|
|
||||||
debian_mirror:
|
|
||||||
description: Fastest reachable Debian package repository
|
|
||||||
value: ${{ steps.select.outputs.debian_mirror }}
|
|
||||||
runs:
|
|
||||||
using: composite
|
|
||||||
steps:
|
|
||||||
- name: Rate mirrors and export package environments
|
|
||||||
id: select
|
|
||||||
shell: bash
|
|
||||||
env:
|
|
||||||
NPM_MIRRORS: ${{ inputs.npm_mirrors }}
|
|
||||||
PYPI_MIRRORS: ${{ inputs.pypi_mirrors }}
|
|
||||||
GO_MIRRORS: ${{ inputs.go_mirrors }}
|
|
||||||
DEBIAN_MIRRORS: ${{ inputs.debian_mirrors }}
|
|
||||||
CONNECT_TIMEOUT: ${{ inputs.connect_timeout }}
|
|
||||||
MAX_TIME: ${{ inputs.max_time }}
|
|
||||||
run: |
|
|
||||||
set -euo pipefail
|
|
||||||
|
|
||||||
if [[ ! "$CONNECT_TIMEOUT" =~ ^[0-9]+([.][0-9]+)?$ ]] ||
|
|
||||||
[[ ! "$MAX_TIME" =~ ^[0-9]+([.][0-9]+)?$ ]]; then
|
|
||||||
echo "Mirror timeouts must be positive numbers" >&2
|
|
||||||
exit 1
|
|
||||||
fi
|
|
||||||
|
|
||||||
select_fastest() {
|
|
||||||
local ecosystem="$1"
|
|
||||||
local mirrors="$2"
|
|
||||||
local scores mirror result status duration fallback
|
|
||||||
scores="$(mktemp)"
|
|
||||||
fallback=""
|
|
||||||
|
|
||||||
while IFS= read -r mirror; do
|
|
||||||
mirror="$(printf '%s' "$mirror" | sed -e 's/^[[:space:]]*//' -e 's/[[:space:]]*$//')"
|
|
||||||
[[ -z "$mirror" || "$mirror" == \#* ]] && continue
|
|
||||||
|
|
||||||
if [[ ! "$mirror" =~ ^https?:// ]]; then
|
|
||||||
echo "[$ecosystem] skipped invalid URL: $mirror" >&2
|
|
||||||
continue
|
|
||||||
fi
|
|
||||||
[[ -z "$fallback" ]] && fallback="$mirror"
|
|
||||||
|
|
||||||
if result="$(curl \
|
|
||||||
--location \
|
|
||||||
--silent \
|
|
||||||
--show-error \
|
|
||||||
--output /dev/null \
|
|
||||||
--connect-timeout "$CONNECT_TIMEOUT" \
|
|
||||||
--max-time "$MAX_TIME" \
|
|
||||||
--write-out '%{http_code} %{time_total}' \
|
|
||||||
"$mirror" 2>/dev/null)"; then
|
|
||||||
read -r status duration <<< "$result"
|
|
||||||
if [[ "$status" =~ ^[0-9]{3}$ ]] &&
|
|
||||||
(((10#$status >= 200 && 10#$status < 400) || 10#$status == 404)) &&
|
|
||||||
[[ "$duration" =~ ^[0-9]+([.][0-9]+)?$ ]]; then
|
|
||||||
printf '%s\t%s\t%s\n' "$duration" "$status" "$mirror" >> "$scores"
|
|
||||||
continue
|
|
||||||
fi
|
|
||||||
fi
|
|
||||||
|
|
||||||
echo "[$ecosystem] unavailable: $mirror" >&2
|
|
||||||
done <<< "$mirrors"
|
|
||||||
|
|
||||||
if [[ ! -s "$scores" ]]; then
|
|
||||||
rm -f "$scores"
|
|
||||||
if [[ -z "$fallback" ]]; then
|
|
||||||
echo "No valid $ecosystem mirror was configured" >&2
|
|
||||||
return 1
|
|
||||||
fi
|
|
||||||
echo "[$ecosystem] no mirror responded; falling back to $fallback" >&2
|
|
||||||
printf '%s\n' "$fallback"
|
|
||||||
return 0
|
|
||||||
fi
|
|
||||||
|
|
||||||
echo "[$ecosystem] mirror ranking (seconds, HTTP status, URL):" >&2
|
|
||||||
sort -n -k1,1 "$scores" >&2
|
|
||||||
sort -n -k1,1 "$scores" | head -n 1 | cut -f3-
|
|
||||||
rm -f "$scores"
|
|
||||||
}
|
|
||||||
|
|
||||||
npm_registry="$(select_fastest npm "$NPM_MIRRORS")"
|
|
||||||
pypi_index="$(select_fastest pypi "$PYPI_MIRRORS")"
|
|
||||||
go_proxy="$(select_fastest go "$GO_MIRRORS")"
|
|
||||||
debian_mirror="$(select_fastest debian "$DEBIAN_MIRRORS")"
|
|
||||||
|
|
||||||
{
|
|
||||||
echo "NPM_CONFIG_REGISTRY=$npm_registry"
|
|
||||||
echo "npm_config_registry=$npm_registry"
|
|
||||||
echo "COREPACK_NPM_REGISTRY=$npm_registry"
|
|
||||||
echo "YARN_REGISTRY=$npm_registry"
|
|
||||||
echo "PNPM_CONFIG_REGISTRY=$npm_registry"
|
|
||||||
echo "BUN_CONFIG_REGISTRY=$npm_registry"
|
|
||||||
echo "PIP_INDEX_URL=$pypi_index"
|
|
||||||
echo "UV_DEFAULT_INDEX=$pypi_index"
|
|
||||||
echo "GOPROXY=$go_proxy"
|
|
||||||
echo "DEBIAN_MIRROR=$debian_mirror"
|
|
||||||
} >> "$GITHUB_ENV"
|
|
||||||
|
|
||||||
{
|
|
||||||
echo "npm_registry=$npm_registry"
|
|
||||||
echo "pypi_index=$pypi_index"
|
|
||||||
echo "go_proxy=$go_proxy"
|
|
||||||
echo "debian_mirror=$debian_mirror"
|
|
||||||
} >> "$GITHUB_OUTPUT"
|
|
||||||
@@ -1,52 +0,0 @@
|
|||||||
---
|
|
||||||
name: CI/CD Stage
|
|
||||||
on:
|
|
||||||
push:
|
|
||||||
branches:
|
|
||||||
- stage
|
|
||||||
jobs:
|
|
||||||
stage:
|
|
||||||
runs-on: ubuntu-latest
|
|
||||||
steps:
|
|
||||||
- name: Checkout Git
|
|
||||||
uses: https://git.darano.ir/actions/checkout@v5
|
|
||||||
with:
|
|
||||||
token: ${{ gitea.token }}
|
|
||||||
path: ./
|
|
||||||
submodules: recursive
|
|
||||||
- name: Checkout Buf CLI
|
|
||||||
uses: https://git.darano.ir/actions/checkout@v5
|
|
||||||
with:
|
|
||||||
repository: actions/buf-bin
|
|
||||||
ref: main
|
|
||||||
path: buf-bin
|
|
||||||
- name: Setup package mirrors
|
|
||||||
uses: ./.gitea/actions/setup-mirrors
|
|
||||||
- name: Setup Buf CLI
|
|
||||||
run: |
|
|
||||||
BUF_VERSION=1.72.0
|
|
||||||
ARCH="$(uname -m)"
|
|
||||||
case "$ARCH" in
|
|
||||||
x86_64) BIN="buf-Linux-x86_64" ;;
|
|
||||||
aarch64) BIN="buf-Linux-aarch64" ;;
|
|
||||||
arm64) BIN="buf-Darwin-arm64" ;;
|
|
||||||
*) BIN="buf-Linux-x86_64" ;;
|
|
||||||
esac
|
|
||||||
curl -sSL "https://github.com/bufbuild/buf/releases/download/v${BUF_VERSION}/${BIN}.tar.gz" -o buf.tar.gz
|
|
||||||
tar -xzf buf.tar.gz
|
|
||||||
cp buf/bin/buf /usr/local/bin/buf
|
|
||||||
chmod +x /usr/local/bin/buf
|
|
||||||
rm -rf buf buf.tar.gz buf-bin
|
|
||||||
- name: Lint
|
|
||||||
run: buf lint
|
|
||||||
- name: Build
|
|
||||||
run: buf build
|
|
||||||
- name: Notify Telegram
|
|
||||||
if: always()
|
|
||||||
uses: ./.gitea/actions/notify-telegram
|
|
||||||
with:
|
|
||||||
bot_token: ${{ secrets.TELEGRAM_BOT_TOKEN }}
|
|
||||||
chat_id: ${{ secrets.TELEGRAM_CHAT_ID }}
|
|
||||||
status: ${{ job.status }}
|
|
||||||
repository: ${{ gitea.repository }}
|
|
||||||
sha: ${{ gitea.sha }}
|
|
||||||
+1
-6
@@ -43,7 +43,6 @@ message PermissionList {
|
|||||||
|
|
||||||
message UserSendOtpReq {
|
message UserSendOtpReq {
|
||||||
string mobile = 1;
|
string mobile = 1;
|
||||||
string referral_code = 2;
|
|
||||||
}
|
}
|
||||||
message UserSendOtpRes {
|
message UserSendOtpRes {
|
||||||
int64 expired_at = 1;
|
int64 expired_at = 1;
|
||||||
@@ -56,7 +55,6 @@ message UserSendOtpRes {
|
|||||||
message UserLoginReq {
|
message UserLoginReq {
|
||||||
string mobile = 1;
|
string mobile = 1;
|
||||||
string otp_code = 2;
|
string otp_code = 2;
|
||||||
string referral_code = 3;
|
|
||||||
}
|
}
|
||||||
message UserRefreshTokenReq {
|
message UserRefreshTokenReq {
|
||||||
string refresh_token = 1;
|
string refresh_token = 1;
|
||||||
@@ -81,7 +79,6 @@ message CheckIAMReq {
|
|||||||
message InternalIAM {
|
message InternalIAM {
|
||||||
User user = 1;
|
User user = 1;
|
||||||
IdentityBasic identity = 2;
|
IdentityBasic identity = 2;
|
||||||
repeated string role_keys = 3;
|
|
||||||
}
|
}
|
||||||
|
|
||||||
message IdReqWithIAM {
|
message IdReqWithIAM {
|
||||||
@@ -131,7 +128,6 @@ message User {
|
|||||||
string email = 4;
|
string email = 4;
|
||||||
UserStatus status = 5;
|
UserStatus status = 5;
|
||||||
repeated int64 roles = 6;
|
repeated int64 roles = 6;
|
||||||
int64 referrer_user_id = 7;
|
|
||||||
}
|
}
|
||||||
|
|
||||||
message UserAddress {
|
message UserAddress {
|
||||||
@@ -165,7 +161,7 @@ message Identity {
|
|||||||
string shenasname_number = 14;
|
string shenasname_number = 14;
|
||||||
string shenasname_seri = 15;
|
string shenasname_seri = 15;
|
||||||
string shenasname_serial = 16;
|
string shenasname_serial = 16;
|
||||||
int32 status = 17;
|
UserStatus status = 17;
|
||||||
string updated_at = 18;
|
string updated_at = 18;
|
||||||
string created_at = 19;
|
string created_at = 19;
|
||||||
string email = 20;
|
string email = 20;
|
||||||
@@ -189,7 +185,6 @@ message UserIdentityBasic {
|
|||||||
string first_name = 4;
|
string first_name = 4;
|
||||||
string last_name = 5;
|
string last_name = 5;
|
||||||
string wallet_address = 6;
|
string wallet_address = 6;
|
||||||
bool is_identity_verified = 7;
|
|
||||||
}
|
}
|
||||||
|
|
||||||
message UserUpdateIdentityReq {
|
message UserUpdateIdentityReq {
|
||||||
|
|||||||
Binary file not shown.
@@ -51,7 +51,6 @@ enum ErrCode {
|
|||||||
BANK_INFO_NOT_FOUND = 3007;
|
BANK_INFO_NOT_FOUND = 3007;
|
||||||
RECIPIENT_NOT_FOUND = 3008;
|
RECIPIENT_NOT_FOUND = 3008;
|
||||||
USER_NOT_FOUND = 3009;
|
USER_NOT_FOUND = 3009;
|
||||||
INVALID_REFERRAL_CODE = 3011;
|
|
||||||
MARKET_AGREEMENT_ALREADY_ACCEPTED = 3010;
|
MARKET_AGREEMENT_ALREADY_ACCEPTED = 3010;
|
||||||
|
|
||||||
// Resource state errors
|
// Resource state errors
|
||||||
|
|||||||
@@ -1,168 +0,0 @@
|
|||||||
syntax = "proto3";
|
|
||||||
|
|
||||||
package ledger.v1;
|
|
||||||
|
|
||||||
import "google/protobuf/timestamp.proto";
|
|
||||||
|
|
||||||
enum AccountClass {
|
|
||||||
ACCOUNT_CLASS_UNSPECIFIED = 0;
|
|
||||||
ACCOUNT_CLASS_USER_AVAILABLE = 1;
|
|
||||||
ACCOUNT_CLASS_USER_FROZEN = 2;
|
|
||||||
ACCOUNT_CLASS_EXTERNAL_BLOCKCHAIN = 3;
|
|
||||||
ACCOUNT_CLASS_TREASURY = 4;
|
|
||||||
ACCOUNT_CLASS_MARKET_CLEARING = 5;
|
|
||||||
ACCOUNT_CLASS_IPG_CLEARING = 6;
|
|
||||||
ACCOUNT_CLASS_COMMISSION_REVENUE = 7;
|
|
||||||
}
|
|
||||||
|
|
||||||
enum TransactionState {
|
|
||||||
TRANSACTION_STATE_UNSPECIFIED = 0;
|
|
||||||
TRANSACTION_STATE_CREATED = 1;
|
|
||||||
TRANSACTION_STATE_PENDING_TRANSACTION = 2;
|
|
||||||
TRANSACTION_STATE_PENDING_ADMIN = 3;
|
|
||||||
TRANSACTION_STATE_SUCCESSFUL = 4;
|
|
||||||
TRANSACTION_STATE_FAILED = 5;
|
|
||||||
TRANSACTION_STATE_SUSPENDED = 6;
|
|
||||||
}
|
|
||||||
|
|
||||||
message AccountReference {
|
|
||||||
AccountClass account_class = 1;
|
|
||||||
string owner_type = 2;
|
|
||||||
string owner_id = 3;
|
|
||||||
int64 asset_id = 4;
|
|
||||||
}
|
|
||||||
|
|
||||||
message JournalEntry {
|
|
||||||
uint32 line_number = 1;
|
|
||||||
AccountReference account = 2;
|
|
||||||
// Canonical base-10 decimal. Positive is credit and negative is debit.
|
|
||||||
string amount = 3;
|
|
||||||
string description = 4;
|
|
||||||
}
|
|
||||||
|
|
||||||
message BlockchainReference {
|
|
||||||
string network = 1;
|
|
||||||
string transaction_hash = 2;
|
|
||||||
string ledger_sequence = 3;
|
|
||||||
}
|
|
||||||
|
|
||||||
message Journal {
|
|
||||||
string journal_id = 1;
|
|
||||||
string source_service = 2;
|
|
||||||
string idempotency_key = 3;
|
|
||||||
string source_transaction_id = 4;
|
|
||||||
string tracking_code = 5;
|
|
||||||
string effect_kind = 6;
|
|
||||||
uint32 event_version = 7;
|
|
||||||
repeated JournalEntry entries = 8;
|
|
||||||
optional string reversal_of_journal_id = 9;
|
|
||||||
google.protobuf.Timestamp occurred_at = 10;
|
|
||||||
google.protobuf.Timestamp recorded_at = 11;
|
|
||||||
string correlation_id = 12;
|
|
||||||
string actor_id = 13;
|
|
||||||
BlockchainReference blockchain = 14;
|
|
||||||
map<string, string> metadata = 15;
|
|
||||||
string payload_hash = 16;
|
|
||||||
}
|
|
||||||
|
|
||||||
message AppendJournalRequest {
|
|
||||||
string source_service = 1;
|
|
||||||
string idempotency_key = 2;
|
|
||||||
string source_transaction_id = 3;
|
|
||||||
string tracking_code = 4;
|
|
||||||
string effect_kind = 5;
|
|
||||||
uint32 event_version = 6;
|
|
||||||
repeated JournalEntry entries = 7;
|
|
||||||
optional string reversal_of_journal_id = 8;
|
|
||||||
google.protobuf.Timestamp occurred_at = 9;
|
|
||||||
string correlation_id = 10;
|
|
||||||
string actor_id = 11;
|
|
||||||
BlockchainReference blockchain = 12;
|
|
||||||
map<string, string> metadata = 13;
|
|
||||||
}
|
|
||||||
|
|
||||||
message AppendJournalResponse {
|
|
||||||
Journal journal = 1;
|
|
||||||
bool already_existed = 2;
|
|
||||||
}
|
|
||||||
|
|
||||||
message AppendTransactionEventRequest {
|
|
||||||
string source_service = 1;
|
|
||||||
string idempotency_key = 2;
|
|
||||||
string source_transaction_id = 3;
|
|
||||||
string tracking_code = 4;
|
|
||||||
uint32 event_version = 5;
|
|
||||||
TransactionState state = 6;
|
|
||||||
string error_code = 7;
|
|
||||||
string error_message = 8;
|
|
||||||
google.protobuf.Timestamp occurred_at = 9;
|
|
||||||
string correlation_id = 10;
|
|
||||||
string actor_id = 11;
|
|
||||||
BlockchainReference blockchain = 12;
|
|
||||||
map<string, string> metadata = 13;
|
|
||||||
}
|
|
||||||
|
|
||||||
message TransactionEvent {
|
|
||||||
string event_id = 1;
|
|
||||||
AppendTransactionEventRequest event = 2;
|
|
||||||
google.protobuf.Timestamp recorded_at = 3;
|
|
||||||
string payload_hash = 4;
|
|
||||||
}
|
|
||||||
|
|
||||||
message AppendTransactionEventResponse {
|
|
||||||
TransactionEvent event = 1;
|
|
||||||
bool already_existed = 2;
|
|
||||||
}
|
|
||||||
|
|
||||||
message GetJournalRequest {
|
|
||||||
oneof lookup {
|
|
||||||
string journal_id = 1;
|
|
||||||
string idempotency_key = 2;
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
message ListEntriesRequest {
|
|
||||||
optional AccountReference account = 1;
|
|
||||||
optional int64 asset_id = 2;
|
|
||||||
google.protobuf.Timestamp recorded_from = 3;
|
|
||||||
google.protobuf.Timestamp recorded_to = 4;
|
|
||||||
uint32 page_size = 5;
|
|
||||||
string page_token = 6;
|
|
||||||
}
|
|
||||||
|
|
||||||
message ListEntriesResponse {
|
|
||||||
repeated Journal journals = 1;
|
|
||||||
string next_page_token = 2;
|
|
||||||
}
|
|
||||||
|
|
||||||
message GetBalanceRequest {
|
|
||||||
AccountReference account = 1;
|
|
||||||
google.protobuf.Timestamp as_of = 2;
|
|
||||||
}
|
|
||||||
|
|
||||||
message GetBalanceResponse {
|
|
||||||
AccountReference account = 1;
|
|
||||||
// Canonical base-10 decimal reconstructed from immutable entries.
|
|
||||||
string balance = 2;
|
|
||||||
google.protobuf.Timestamp as_of = 3;
|
|
||||||
}
|
|
||||||
|
|
||||||
message ReplayJournalsRequest {
|
|
||||||
// Each item is independently atomic and uses normal append idempotency.
|
|
||||||
repeated AppendJournalRequest journals = 1;
|
|
||||||
}
|
|
||||||
|
|
||||||
message ReplayJournalResult {
|
|
||||||
string idempotency_key = 1;
|
|
||||||
Journal journal = 2;
|
|
||||||
bool already_existed = 3;
|
|
||||||
}
|
|
||||||
|
|
||||||
message ReplayJournalsResponse {
|
|
||||||
repeated ReplayJournalResult results = 1;
|
|
||||||
}
|
|
||||||
|
|
||||||
message HealthResponse {
|
|
||||||
bool serving = 1;
|
|
||||||
bool database_ready = 2;
|
|
||||||
}
|
|
||||||
@@ -1,16 +0,0 @@
|
|||||||
syntax = "proto3";
|
|
||||||
|
|
||||||
package ledger.v1;
|
|
||||||
|
|
||||||
import "base/v1/msg.proto";
|
|
||||||
import "ledger/v1/msg.proto";
|
|
||||||
|
|
||||||
service GeneralLedgerService {
|
|
||||||
rpc Health(base.v1.Empty) returns (HealthResponse);
|
|
||||||
rpc AppendJournal(AppendJournalRequest) returns (AppendJournalResponse);
|
|
||||||
rpc AppendTransactionEvent(AppendTransactionEventRequest) returns (AppendTransactionEventResponse);
|
|
||||||
rpc GetJournal(GetJournalRequest) returns (Journal);
|
|
||||||
rpc ListEntries(ListEntriesRequest) returns (ListEntriesResponse);
|
|
||||||
rpc GetBalance(GetBalanceRequest) returns (GetBalanceResponse);
|
|
||||||
rpc ReplayJournals(ReplayJournalsRequest) returns (ReplayJournalsResponse);
|
|
||||||
}
|
|
||||||
@@ -71,7 +71,6 @@ message MarketOrder {
|
|||||||
repeated string tags = 20;
|
repeated string tags = 20;
|
||||||
repeated string comment = 21;
|
repeated string comment = 21;
|
||||||
optional MarketOrder source = 22; // purchase is done via this field
|
optional MarketOrder source = 22; // purchase is done via this field
|
||||||
bool is_ico = 23;
|
|
||||||
// repeated string attachments = 14; // possible files included by
|
// repeated string attachments = 14; // possible files included by
|
||||||
// seller/buyer
|
// seller/buyer
|
||||||
}
|
}
|
||||||
@@ -131,7 +130,6 @@ message NewMarketReq {
|
|||||||
MarketOrderSide side = 8;
|
MarketOrderSide side = 8;
|
||||||
// TODO: maker market order as optional
|
// TODO: maker market order as optional
|
||||||
optional uint64 maker_order_id = 9;
|
optional uint64 maker_order_id = 9;
|
||||||
bool is_ico = 10;
|
|
||||||
}
|
}
|
||||||
|
|
||||||
enum MarketOrdersSortBy {
|
enum MarketOrdersSortBy {
|
||||||
@@ -166,7 +164,6 @@ message OrderListFilter {
|
|||||||
optional MarketOrdersSortBy sort_by = 19;
|
optional MarketOrdersSortBy sort_by = 19;
|
||||||
optional uint32 page_no = 21;
|
optional uint32 page_no = 21;
|
||||||
optional uint32 page_size = 22;
|
optional uint32 page_size = 22;
|
||||||
optional bool is_ico = 23;
|
|
||||||
}
|
}
|
||||||
|
|
||||||
/* Contract */
|
/* Contract */
|
||||||
|
|||||||
@@ -5,7 +5,6 @@ package market.v1;
|
|||||||
import "auth/v1/msg.proto";
|
import "auth/v1/msg.proto";
|
||||||
import "base/v1/msg.proto";
|
import "base/v1/msg.proto";
|
||||||
import "market/v1/msg.proto";
|
import "market/v1/msg.proto";
|
||||||
import "wallet/v1/msg.proto";
|
|
||||||
|
|
||||||
service MarketplaceSrv {
|
service MarketplaceSrv {
|
||||||
rpc MarketplaceSrvHealth(base.v1.Empty) returns (base.v1.StatusRes);
|
rpc MarketplaceSrvHealth(base.v1.Empty) returns (base.v1.StatusRes);
|
||||||
@@ -17,12 +16,10 @@ service MarketplaceSrv {
|
|||||||
rpc GetMarketAssetList(MarketAssetListReq) returns (MarketAssetList); // assets that can be listed in marketplace
|
rpc GetMarketAssetList(MarketAssetListReq) returns (MarketAssetList); // assets that can be listed in marketplace
|
||||||
|
|
||||||
rpc CalcMarketOrder(CalcMarketReq) returns (CalcMarketRes);
|
rpc CalcMarketOrder(CalcMarketReq) returns (CalcMarketRes);
|
||||||
rpc CalcICOBuy(wallet.v1.BuyAssetReq) returns (wallet.v1.CalcBuyAssetRes);
|
|
||||||
|
|
||||||
rpc CancelOrder(auth.v1.IdReqWithIAMAndTFA) returns (base.v1.StatusRes); // cancel an order
|
rpc CancelOrder(auth.v1.IdReqWithIAMAndTFA) returns (base.v1.StatusRes); // cancel an order
|
||||||
|
|
||||||
rpc NewMarketOrder(NewMarketReq) returns (MarketOrder); // insert new buy order to market
|
rpc NewMarketOrder(NewMarketReq) returns (MarketOrder); // insert new buy order to market
|
||||||
rpc GenerateMarketContract(MarketContractReq) returns (ContractMarketRes);
|
rpc GenerateMarketContract(MarketContractReq) returns (ContractMarketRes);
|
||||||
rpc ConfirmMarketContract(ConfirmMarketContractReq) returns (base.v1.StatusRes);
|
rpc ConfirmMarketContract(ConfirmMarketContractReq) returns (base.v1.StatusRes);
|
||||||
rpc SettleICOBuy(wallet.v1.ConfirmBuyAssetReq) returns (wallet.v1.BuyAssetRes);
|
|
||||||
}
|
}
|
||||||
|
|||||||
@@ -17,12 +17,4 @@ service InternalWalletSrv {
|
|||||||
|
|
||||||
// Calculate stellar pub-priv key based on national id
|
// Calculate stellar pub-priv key based on national id
|
||||||
rpc GetPublicKeyByNationalID(NationalIDReq) returns (PubKeyRes);
|
rpc GetPublicKeyByNationalID(NationalIDReq) returns (PubKeyRes);
|
||||||
|
|
||||||
// Commission Logs
|
|
||||||
rpc InitReferrerCommissionLog(InitReferrerCommissionLogIn) returns (base.v1.Empty);
|
|
||||||
|
|
||||||
// Authenticated administrative asset lifecycle. Delete is represented as
|
|
||||||
// deactivation/locking so referenced financial history remains intact.
|
|
||||||
rpc AdminUpsertAsset(AdminUpsertAssetReq) returns (AdminAssetMutationRes);
|
|
||||||
rpc AdminDeactivateAsset(AdminDeactivateAssetReq) returns (base.v1.StatusRes);
|
|
||||||
}
|
}
|
||||||
|
|||||||
+64
-119
@@ -6,13 +6,34 @@ import "auth/v1/msg.proto";
|
|||||||
import "base/v1/msg.proto";
|
import "base/v1/msg.proto";
|
||||||
|
|
||||||
/*
|
/*
|
||||||
INTERNAL DATA;
|
INTERNAL DATA
|
||||||
*/
|
*/
|
||||||
|
|
||||||
message InternalTransactionData {
|
message InternalTransactionData {
|
||||||
int64 transaction_id = 1;
|
int64 transaction_id = 1;
|
||||||
}
|
}
|
||||||
|
|
||||||
|
/*
|
||||||
|
Federation
|
||||||
|
*/
|
||||||
|
|
||||||
|
message Federation {
|
||||||
|
int64 id = 1;
|
||||||
|
int64 user_id = 2;
|
||||||
|
string ed_public = 3;
|
||||||
|
string ed_public_hash = 4;
|
||||||
|
int32 status = 5;
|
||||||
|
string created_at = 6;
|
||||||
|
string system_wallet_address = 7;
|
||||||
|
}
|
||||||
|
|
||||||
|
message GetFederationReq {
|
||||||
|
optional int64 federation_id = 1;
|
||||||
|
optional int64 user_id = 2;
|
||||||
|
optional string ed_public = 3;
|
||||||
|
optional string ed_public_hash = 4;
|
||||||
|
}
|
||||||
|
|
||||||
/*
|
/*
|
||||||
Wallet
|
Wallet
|
||||||
*/
|
*/
|
||||||
@@ -38,13 +59,15 @@ message Wallet {
|
|||||||
int64 user_id = 2;
|
int64 user_id = 2;
|
||||||
int64 asset_id = 3;
|
int64 asset_id = 3;
|
||||||
Asset asset_info = 4;
|
Asset asset_info = 4;
|
||||||
double balance = 5;
|
int64 federation_id = 5;
|
||||||
double frozen_balance = 6;
|
Federation federation_info = 6;
|
||||||
string updated_at = 7;
|
double balance = 7;
|
||||||
string created_at = 8;
|
double frozen_balance = 8;
|
||||||
string wallet_code = 9;
|
string updated_at = 9;
|
||||||
bool accepted_terms = 10;
|
string created_at = 10;
|
||||||
bool is_locked = 11;
|
string wallet_code = 11;
|
||||||
|
bool accepted_terms = 12;
|
||||||
|
bool is_locked = 13;
|
||||||
}
|
}
|
||||||
|
|
||||||
message BalanceReq {
|
message BalanceReq {
|
||||||
@@ -332,7 +355,6 @@ enum TransactionType {
|
|||||||
IRT_DEPOSIT = 13;
|
IRT_DEPOSIT = 13;
|
||||||
IRT_WITHDRAWAL = 14;
|
IRT_WITHDRAWAL = 14;
|
||||||
COMMISSION = 15;
|
COMMISSION = 15;
|
||||||
REFERRAL_COMMISSION = 16;
|
|
||||||
}
|
}
|
||||||
|
|
||||||
enum TransactionStatus {
|
enum TransactionStatus {
|
||||||
@@ -351,22 +373,27 @@ message Transaction {
|
|||||||
string asset_code = 3;
|
string asset_code = 3;
|
||||||
optional int64 from_user_id = 4;
|
optional int64 from_user_id = 4;
|
||||||
optional auth.v1.UserIdentityBasic from_user_info = 5;
|
optional auth.v1.UserIdentityBasic from_user_info = 5;
|
||||||
optional int64 to_user_id = 6;
|
optional int64 from_federation_id = 6;
|
||||||
optional auth.v1.UserIdentityBasic to_user_info = 7;
|
optional Federation from_federation_info = 7;
|
||||||
double amount = 8;
|
|
||||||
TransactionStatus status = 9;
|
optional int64 to_user_id = 8;
|
||||||
TransactionType type = 10;
|
optional auth.v1.UserIdentityBasic to_user_info = 9;
|
||||||
string updated_at = 11;
|
optional int64 to_federation_id = 10;
|
||||||
string created_at = 12;
|
optional Federation to_federation_info = 11;
|
||||||
string tracking_code = 13;
|
double amount = 12;
|
||||||
optional string trx_hash = 14;
|
TransactionStatus status = 13;
|
||||||
optional string from_public_key = 15;
|
TransactionType type = 14;
|
||||||
optional string to_public_key = 16;
|
string updated_at = 15;
|
||||||
double token_price = 17;
|
string created_at = 16;
|
||||||
BalanceChange balance_change = 18;
|
string tracking_code = 17;
|
||||||
|
optional string trx_hash = 18;
|
||||||
|
optional string from_public_key = 19;
|
||||||
|
optional string to_public_key = 20;
|
||||||
|
double token_price = 21;
|
||||||
|
BalanceChange balance_change = 22;
|
||||||
}
|
}
|
||||||
|
|
||||||
enum BalanceChange {
|
enum BalanceChange{
|
||||||
NO_CHANGE = 0;
|
NO_CHANGE = 0;
|
||||||
INCREASE = 1;
|
INCREASE = 1;
|
||||||
DECREASE = 2;
|
DECREASE = 2;
|
||||||
@@ -379,14 +406,16 @@ message TransactionListFilter {
|
|||||||
optional int64 id = 4;
|
optional int64 id = 4;
|
||||||
optional int64 asset_id = 5;
|
optional int64 asset_id = 5;
|
||||||
optional int64 from_user_id = 6;
|
optional int64 from_user_id = 6;
|
||||||
optional int64 to_user_id = 7;
|
optional int64 from_federation_id = 7;
|
||||||
optional double amount_from = 8;
|
optional int64 to_user_id = 8;
|
||||||
optional double amount_to = 9;
|
optional int64 to_federation_id = 9;
|
||||||
optional string tracking_code = 10;
|
optional double amount_from = 10;
|
||||||
repeated TransactionType type = 11;
|
optional double amount_to = 11;
|
||||||
repeated TransactionStatus status = 12;
|
optional string tracking_code = 12;
|
||||||
optional string from_date = 13;
|
repeated TransactionType type = 13;
|
||||||
optional string to_date = 14;
|
repeated TransactionStatus status = 14;
|
||||||
|
optional string from_date = 15;
|
||||||
|
optional string to_date = 16;
|
||||||
}
|
}
|
||||||
|
|
||||||
/*
|
/*
|
||||||
@@ -413,7 +442,7 @@ message TransferAssetRes {
|
|||||||
}
|
}
|
||||||
|
|
||||||
/*
|
/*
|
||||||
Redeem Token;
|
Redeem Token
|
||||||
*/
|
*/
|
||||||
message RedeemTokenReq {
|
message RedeemTokenReq {
|
||||||
auth.v1.InternalIAM iam = 1;
|
auth.v1.InternalIAM iam = 1;
|
||||||
@@ -468,7 +497,7 @@ message PubKeyRes {
|
|||||||
}
|
}
|
||||||
|
|
||||||
/*
|
/*
|
||||||
Network Details;
|
Network Details
|
||||||
*/
|
*/
|
||||||
enum NetworkType {
|
enum NetworkType {
|
||||||
UNKNOWN_NETWORK_TYPE = 0;
|
UNKNOWN_NETWORK_TYPE = 0;
|
||||||
@@ -552,38 +581,6 @@ message CommissionRes {
|
|||||||
uint64 commission_log_id = 1;
|
uint64 commission_log_id = 1;
|
||||||
}
|
}
|
||||||
|
|
||||||
message InitReferrerCommissionLogIn {
|
|
||||||
int64 referrer_id = 1;
|
|
||||||
int64 user_id = 2;
|
|
||||||
double amount = 3;
|
|
||||||
}
|
|
||||||
|
|
||||||
message ReferrerCommissionLogOut {
|
|
||||||
double amount = 1;
|
|
||||||
string mobile = 2;
|
|
||||||
bool is_identity_verified = 3;
|
|
||||||
double commission_percentage = 4;
|
|
||||||
}
|
|
||||||
message ReferrerCommissionLogsList {
|
|
||||||
repeated ReferrerCommissionLogOut list = 1;
|
|
||||||
uint32 page_no = 2;
|
|
||||||
uint32 page_size = 3;
|
|
||||||
uint32 total_count = 4;
|
|
||||||
}
|
|
||||||
|
|
||||||
message TotalReferralCommissionIn {
|
|
||||||
int64 referrer_id = 1;
|
|
||||||
}
|
|
||||||
|
|
||||||
message TotalReferralCommissionOut {
|
|
||||||
double claimed = 1;
|
|
||||||
double unclaimed = 2;
|
|
||||||
}
|
|
||||||
|
|
||||||
message ClaimReferralCommissionIn {
|
|
||||||
auth.v1.User user = 1;
|
|
||||||
}
|
|
||||||
|
|
||||||
/*
|
/*
|
||||||
* IPG - Internet Payment Gateway
|
* IPG - Internet Payment Gateway
|
||||||
* 1. Get Token
|
* 1. Get Token
|
||||||
@@ -656,6 +653,7 @@ message IPGConfirmReq {
|
|||||||
// string amount = 7;
|
// string amount = 7;
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|
||||||
message WithdrawLog {
|
message WithdrawLog {
|
||||||
uint64 id = 1;
|
uint64 id = 1;
|
||||||
Accounting accounting = 2;
|
Accounting accounting = 2;
|
||||||
@@ -742,7 +740,7 @@ message WithdrawIRTReq {
|
|||||||
auth.v1.InternalIAM iam = 1;
|
auth.v1.InternalIAM iam = 1;
|
||||||
double amount = 2;
|
double amount = 2;
|
||||||
int64 bank_info_id = 3;
|
int64 bank_info_id = 3;
|
||||||
auth.v1.TFA tfa = 4;
|
auth.v1.TFA tfa = 4;
|
||||||
}
|
}
|
||||||
|
|
||||||
message WithdrawIRTRes {
|
message WithdrawIRTRes {
|
||||||
@@ -783,14 +781,12 @@ message CalcBuyAssetRes {
|
|||||||
double calculated_asset_amount = 3;
|
double calculated_asset_amount = 3;
|
||||||
EffectiveCommission commission = 4;
|
EffectiveCommission commission = 4;
|
||||||
optional AssetDiscountRes discount_detail = 5;
|
optional AssetDiscountRes discount_detail = 5;
|
||||||
uint64 maker_order_id = 6;
|
|
||||||
}
|
}
|
||||||
|
|
||||||
message BuyAssetRes {
|
message BuyAssetRes {
|
||||||
bool success = 1;
|
bool success = 1;
|
||||||
string irt_hash = 2;
|
string irt_hash = 2;
|
||||||
string asset_hash = 3;
|
string asset_hash = 3;
|
||||||
uint64 order_id = 4;
|
|
||||||
}
|
}
|
||||||
|
|
||||||
/* Contract */
|
/* Contract */
|
||||||
@@ -811,54 +807,3 @@ message ContractRes {
|
|||||||
string contract_hash = 4;
|
string contract_hash = 4;
|
||||||
string contract_content = 5;
|
string contract_content = 5;
|
||||||
}
|
}
|
||||||
|
|
||||||
// Administrative asset commands are intentionally separate from the public
|
|
||||||
// Asset response. They contain the complete persistence-owned asset aggregate
|
|
||||||
// and are accepted only by the authenticated InternalWalletSrv boundary.
|
|
||||||
message AdminAssetInput {
|
|
||||||
int64 id = 1;
|
|
||||||
string name = 2;
|
|
||||||
string code = 3;
|
|
||||||
string issuer = 4;
|
|
||||||
string distributor = 5;
|
|
||||||
string network_code = 6;
|
|
||||||
string anchor = 7;
|
|
||||||
int32 decimal = 8;
|
|
||||||
string max_supply = 9;
|
|
||||||
optional string buy_min_amount = 10;
|
|
||||||
optional string buy_max_amount = 11;
|
|
||||||
string image = 12;
|
|
||||||
repeated string images = 13;
|
|
||||||
repeated string videos = 14;
|
|
||||||
string description = 15;
|
|
||||||
string url = 16;
|
|
||||||
string meta_json = 17;
|
|
||||||
bool is_active = 18;
|
|
||||||
bool is_locked = 19;
|
|
||||||
bool is_base_asset = 20;
|
|
||||||
bool show_if_empty = 21;
|
|
||||||
bool has_policy = 22;
|
|
||||||
bool has_whitelisting = 23;
|
|
||||||
bool can_buy = 24;
|
|
||||||
bool can_sell = 25;
|
|
||||||
bool can_deposit = 26;
|
|
||||||
bool can_withdraw = 27;
|
|
||||||
bool can_trade = 28;
|
|
||||||
AssetTokenType token_type = 29;
|
|
||||||
AssetType type = 30;
|
|
||||||
AssetStatus status = 31;
|
|
||||||
}
|
|
||||||
|
|
||||||
message AdminUpsertAssetReq {
|
|
||||||
AdminAssetInput asset = 1;
|
|
||||||
uint64 actor_user_id = 2;
|
|
||||||
}
|
|
||||||
|
|
||||||
message AdminDeactivateAssetReq {
|
|
||||||
int64 asset_id = 1;
|
|
||||||
uint64 actor_user_id = 2;
|
|
||||||
}
|
|
||||||
|
|
||||||
message AdminAssetMutationRes {
|
|
||||||
int64 asset_id = 1;
|
|
||||||
}
|
|
||||||
|
|||||||
@@ -24,11 +24,6 @@ service WalletService {
|
|||||||
|
|
||||||
rpc UserGetTransactionList(TransactionListFilter) returns (TransactionList);
|
rpc UserGetTransactionList(TransactionListFilter) returns (TransactionList);
|
||||||
|
|
||||||
// Commission Logs
|
|
||||||
rpc GetReferrerCommissionLogsList(auth.v1.InternalIAM) returns (ReferrerCommissionLogsList);
|
|
||||||
rpc GetTotalReferralCommission(TotalReferralCommissionIn) returns (TotalReferralCommissionOut);
|
|
||||||
rpc ClaimReferralCommission(ClaimReferralCommissionIn) returns (base.v1.StatusRes);
|
|
||||||
|
|
||||||
// Get Token from IPG is and internal api
|
// Get Token from IPG is and internal api
|
||||||
rpc IPGGetToken(IPGGetTokenReq) returns (IPGGetTokenRes);
|
rpc IPGGetToken(IPGGetTokenReq) returns (IPGGetTokenRes);
|
||||||
// IPG Confirm is a public api
|
// IPG Confirm is a public api
|
||||||
|
|||||||
Reference in New Issue
Block a user