Compare commits

..

No commits in common. "871e26edc2293b4ffe46f83e672453169fb4b660" and "ee1b12f85f8ab71c4e14afeda47a71ed14b4c6d4" have entirely different histories.

25 changed files with 624 additions and 594 deletions

2
Cargo.lock generated

@ -1011,7 +1011,7 @@ dependencies = [
[[package]] [[package]]
name = "detee-shared" name = "detee-shared"
version = "0.1.0" version = "0.1.0"
source = "git+ssh://git@gitea.detee.cloud/testnet/proto?branch=credits_app#01e93d3a2e4502c0e8e72026e8a1c55810961815" source = "git+ssh://git@gitea.detee.cloud/testnet/proto?branch=surreal_brain_app#0b195b4589e4ec689af7ddca27dc051716ecee78"
dependencies = [ dependencies = [
"bincode 2.0.1", "bincode 2.0.1",
"prost", "prost",

@ -15,7 +15,7 @@ serde_yaml = "0.9.34"
surrealdb = "2.2.2" surrealdb = "2.2.2"
tokio = { version = "1.44.2", features = ["macros", "rt-multi-thread"] } tokio = { version = "1.44.2", features = ["macros", "rt-multi-thread"] }
tonic = { version = "0.12", features = ["tls"] } tonic = { version = "0.12", features = ["tls"] }
detee-shared = { git = "ssh://git@gitea.detee.cloud/testnet/proto", branch = "credits_app" } detee-shared = { git = "ssh://git@gitea.detee.cloud/testnet/proto", branch = "surreal_brain_app" }
ed25519-dalek = "2.1.1" ed25519-dalek = "2.1.1"
bs58 = "0.5.1" bs58 = "0.5.1"
tokio-stream = "0.1.17" tokio-stream = "0.1.17"

@ -1,12 +1,80 @@
# SPDX-License-Identifier: Apache-2.0
accounts: accounts:
fY3NNjvFTeR1FBh5nXV3ujX7zZqrm3eBUWGEiG75TK1: DXXkYSnhP3ijsHYxkedcuMomEyc122WaAbkDX7SaGuUS:
balance: 1000000000 balance: 20293420000
tmp_locked: 0 tmp_locked: 0
kicked_for: [] kicked_for: []
last_kick: 1970-01-01T00:00:00Z last_kick: 1970-01-01T00:00:00Z
banned_by: [] banned_by: []
FBMWVqME3t1i4R6zWyDQGUuiTeruZ1TxLhTmhaEcFypZ: FHuecMbeC1PfjkW2JKyoicJAuiU7khgQT16QUB3Q1XdL:
balance: 181560160000 balance: 25949200000
tmp_locked: 0
kicked_for: []
last_kick: 1970-01-01T00:00:00Z
banned_by: []
Cnkvn3WuHYfTzh1YK1TAv2VD25sNvstJNnQtxjcdQSL7:
balance: 4794480000
tmp_locked: 0
kicked_for: []
last_kick: 1970-01-01T00:00:00Z
banned_by: []
BFopWmwcZAMF1h2PFECZNdEucdZfnZZ32p6R9ZaBiVsS:
balance: 4672207240000
tmp_locked: 0
kicked_for: []
last_kick: 1970-01-01T00:00:00Z
banned_by: []
E3bgXsWvgichXeC6AqULJCZDp7FbEdTxBD67UaYVWf9y:
balance: 21121600000
tmp_locked: 0
kicked_for: []
last_kick: 1970-01-01T00:00:00Z
banned_by: []
HQyGWpiteHbxjszngZvmiX7ZFZAmF6nFjEraBa1M6bbM:
balance: 979410300000
tmp_locked: 0
kicked_for: []
last_kick: 1970-01-01T00:00:00Z
banned_by: []
H21Shi4iE7vgfjWEQNvzmpmBMJSaiZ17PYUcdNoAoKNc:
balance: 976000000
tmp_locked: 0
kicked_for: []
last_kick: 1970-01-01T00:00:00Z
banned_by: []
45Pyv9hRfub43NyRrYv95MhZs1Wrm8sj3RhBvA3F1Bvr:
balance: 1670441080000
tmp_locked: 0
kicked_for: []
last_kick: 1970-01-01T00:00:00Z
banned_by: []
49JBVzmgsQbUURHzAWax2gxo6jmukqbEQzP97YeeNQyu:
balance: 1076960680000
tmp_locked: 0
kicked_for: []
last_kick: 1970-01-01T00:00:00Z
banned_by: []
7V3rEuh6j8VuwMVB5PyGqWKLmjJ4fYSv6WtrTL51NZTB:
balance: 3271040000
tmp_locked: 0
kicked_for: []
last_kick: 1970-01-01T00:00:00Z
banned_by: []
x52w7jARC5erhWWK65VZmjdGXzBK6ZDgfv1A283d8XK:
balance: 554454460000
tmp_locked: 547200000
kicked_for: []
last_kick: 1970-01-01T00:00:00Z
banned_by: []
3BNggj8ZTsoSjfAGdPfmcU2Gobm2qcTEBg9iHXEUPe1t:
balance: 9978460000
tmp_locked: 0
kicked_for: []
last_kick: 1970-01-01T00:00:00Z
banned_by: []
B981xPHmHthfKr15J9uJ64qd9zt2KsdiEuDRR7UUCGWi:
balance: 99980200000
tmp_locked: 0 tmp_locked: 0
kicked_for: [] kicked_for: []
last_kick: 1970-01-01T00:00:00Z last_kick: 1970-01-01T00:00:00Z
@ -23,316 +91,352 @@ accounts:
kicked_for: [] kicked_for: []
last_kick: 1970-01-01T00:00:00Z last_kick: 1970-01-01T00:00:00Z
banned_by: [] banned_by: []
49JBVzmgsQbUURHzAWax2gxo6jmukqbEQzP97YeeNQyu: fY3NNjvFTeR1FBh5nXV3ujX7zZqrm3eBUWGEiG75TK1:
balance: 1076960680000 balance: 1000000000
tmp_locked: 0 tmp_locked: 0
kicked_for: [] kicked_for: []
last_kick: 1970-01-01T00:00:00Z last_kick: 1970-01-01T00:00:00Z
banned_by: [] banned_by: []
HQyGWpiteHbxjszngZvmiX7ZFZAmF6nFjEraBa1M6bbM: FBMWVqME3t1i4R6zWyDQGUuiTeruZ1TxLhTmhaEcFypZ:
balance: 979410300000 balance: 181560160000
tmp_locked: 0 tmp_locked: 0
kicked_for: [] kicked_for: []
last_kick: 1970-01-01T00:00:00Z last_kick: 1970-01-01T00:00:00Z
banned_by: [] banned_by: []
E3bgXsWvgichXeC6AqULJCZDp7FbEdTxBD67UaYVWf9y: DwfL5iFu32xh2YMCUxg63oEAThLRqehDAumiP9q6zuuX:
balance: 21121600000
tmp_locked: 0
kicked_for: []
last_kick: 1970-01-01T00:00:00Z
banned_by: []
FHuecMbeC1PfjkW2JKyoicJAuiU7khgQT16QUB3Q1XdL:
balance: 1156240000
tmp_locked: 0
kicked_for: []
last_kick: 1970-01-01T00:00:00Z
banned_by: []
45Pyv9hRfub43NyRrYv95MhZs1Wrm8sj3RhBvA3F1Bvr:
balance: 933585660000
tmp_locked: 0
kicked_for: []
last_kick: 1970-01-01T00:00:00Z
banned_by: []
H21Shi4iE7vgfjWEQNvzmpmBMJSaiZ17PYUcdNoAoKNc:
balance: 109066280000
tmp_locked: 453600000
kicked_for: []
last_kick: 1970-01-01T00:00:00Z
banned_by: []
x52w7jARC5erhWWK65VZmjdGXzBK6ZDgfv1A283d8XK:
balance: 2565079420000
tmp_locked: 547200000
kicked_for: []
last_kick: 1970-01-01T00:00:00Z
banned_by: []
7V3rEuh6j8VuwMVB5PyGqWKLmjJ4fYSv6WtrTL51NZTB:
balance: 7063640000
tmp_locked: 0
kicked_for: []
last_kick: 1970-01-01T00:00:00Z
banned_by: []
BFopWmwcZAMF1h2PFECZNdEucdZfnZZ32p6R9ZaBiVsS:
balance: 13535509680000
tmp_locked: 0
kicked_for: []
last_kick: 1970-01-01T00:00:00Z
banned_by: []
E27C967A84DEAA3339B4D57C1A7321E4906772244BBECCE25356D0EA6F851086:
balance: 100000000000
tmp_locked: 0
kicked_for: []
last_kick: 1970-01-01T00:00:00Z
banned_by: []
DwfL5iFu32xh2YMCUxg63OeaThLRqehDAumiP9q6zuuX:
balance: 74660380000 balance: 74660380000
tmp_locked: 0 tmp_locked: 0
kicked_for: [] kicked_for: []
last_kick: 1970-01-01T00:00:00Z last_kick: 1970-01-01T00:00:00Z
banned_by: [] banned_by: []
DXXkYSnhP3ijsHYxkedcuMomEyc122WaAbkDX7SaGuUS:
balance: 20293420000
tmp_locked: 0
kicked_for: []
last_kick: 1970-01-01T00:00:00Z
banned_by: []
Bb5Xfkk4fc5i4GiTEgChwMb1ToWDQ5uzGtgD6yKTQYAy:
balance: 99979600000
tmp_locked: 0
kicked_for: []
last_kick: 1970-01-01T00:00:00Z
banned_by: []
5hx2f3odEx6sXqCY6FEAv6bBm3BXdhJ97G6X7uScsLAj:
balance: 94473640000
tmp_locked: 0
kicked_for: []
last_kick: 1970-01-01T00:00:00Z
banned_by: []
3BNggj8ZTsoSjfAGdPfmcU2Gobm2qcTEBg9iHXEUPe1t:
balance: 9978460000
tmp_locked: 0
kicked_for: []
last_kick: 1970-01-01T00:00:00Z
banned_by: []
B981xPHmHthfKr15J9uJ64qd9zt2KsdiEuDRR7UUCGWi:
balance: 99980200000
tmp_locked: 0
kicked_for: []
last_kick: 1970-01-01T00:00:00Z
banned_by: []
Cnkvn3WuHYfTzh1YK1TAv2VD25sNvstJNnQtxjcdQSL7:
balance: 11021340000
tmp_locked: 0
kicked_for: []
last_kick: 1970-01-01T00:00:00Z
banned_by: []
operators: operators:
x52w7jARC5erhWWK65VZmjdGXzBK6ZDgfv1A283d8XK:
escrow: 5489633280000
email: gheo@detee.ltd
banned_users: []
vm_nodes:
- 2Uf5pxhxKTUm6gRMnpbJHYDuyA6BWUfFsdmPyWfbMV1f
- 7Xw3RxbP5pvfjZ8U6yA3HHVSS9YXjKH5Vkas3JRbQYd9
app_nodes: []
BFopWmwcZAMF1h2PFECZNdEucdZfnZZ32p6R9ZaBiVsS: BFopWmwcZAMF1h2PFECZNdEucdZfnZZ32p6R9ZaBiVsS:
escrow: 5091906400000 escrow: 5096692000000
email: first_on_detee@proton.me email: first_on_detee@proton.me
banned_users: [] banned_users: []
vm_nodes: vm_nodes:
- DgkbsrwttkZXvzxY5kDwQQoDd79GLmZ5tc7fYJUFkQQb - HiyMp21zaBVbRCjDsD5hEjQnHeHv4e1gpUR6pVfHTKqv
- 3zRxiGRnf46vd3zAEmpaYBJocTV9oJB6yXf5GZFR1Sq4 - 3zRxiGRnf46vd3zAEmpaYBJocTV9oJB6yXf5GZFR1Sq4
- Du3UfPSUUZmA5thQmc9Vrxdy7UimpygcpDsQNnwRQPtu - Du3UfPSUUZmA5thQmc9Vrxdy7UimpygcpDsQNnwRQPtu
- 4QbUXDM915RUFnHm3NiysLXFLk1WRGZvABwLNzx4tTEW
- DgkbsrwttkZXvzxY5kDwQQoDd79GLmZ5tc7fYJUFkQQb
app_nodes: []
x52w7jARC5erhWWK65VZmjdGXzBK6ZDgfv1A283d8XK:
escrow: 5499700480000
email: gheo@detee.ltd
banned_users: []
vm_nodes:
- 2Uf5pxhxKTUm6gRMnpbJHYDuyA6BWUfFsdmPyWfbMV1f
- 7Xw3RxbP5pvfjZ8U6yA3HHVSS9YXjKH5Vkas3JRbQYd9
app_nodes: [] app_nodes: []
7V3rEuh6j8VuwMVB5PyGqWKLmjJ4fYSv6WtrTL51NZTB: 7V3rEuh6j8VuwMVB5PyGqWKLmjJ4fYSv6WtrTL51NZTB:
escrow: 5500000000000 escrow: 888888888899999
email: nmohammed@detee.ltd email: ""
banned_users: [] banned_users: []
vm_nodes: [] vm_nodes: []
app_nodes: app_nodes:
- BiqoPUEoAxYxMRXUmyofoS9H1TBQgQqvLJ6MbWh88AQg - BiqoPUEoAxYxMRXUmyofoS9H1TBQgQqvLJ6MbWh88AQg
vm_nodes: vm_nodes:
- public_key: Du3UfPSUUZmA5thQmc9Vrxdy7UimpygcpDsQNnwRQPtu - public_key: 7Xw3RxbP5pvfjZ8U6yA3HHVSS9YXjKH5Vkas3JRbQYd9
operator_wallet: BFopWmwcZAMF1h2PFECZNdEucdZfnZZ32p6R9ZaBiVsS operator_wallet: x52w7jARC5erhWWK65VZmjdGXzBK6ZDgfv1A283d8XK
country: FR country: GB
region: Île-de-France region: England
city: Paris city: London
ip: 156.146.63.215 ip: 173.234.17.2
avail_mem_mb: 117000 avail_mem_mb: 26000
avail_vcpus: 40 avail_vcpus: 28
avail_storage_gbs: 410 avail_storage_gbs: 680
avail_ipv4: 2 avail_ipv4: 2
avail_ipv6: 0 avail_ipv6: 65516
avail_ports: 20000 avail_ports: 19999
max_ports_per_vm: 5 max_ports_per_vm: 5
price: 20000 price: 20000
reports: {} reports: {}
offline_minutes: 0 offline_minutes: 0
- public_key: 3zRxiGRnf46vd3zAEmpaYBJocTV9oJB6yXf5GZFR1Sq4 - public_key: Du3UfPSUUZmA5thQmc9Vrxdy7UimpygcpDsQNnwRQPtu
operator_wallet: BFopWmwcZAMF1h2PFECZNdEucdZfnZZ32p6R9ZaBiVsS operator_wallet: BFopWmwcZAMF1h2PFECZNdEucdZfnZZ32p6R9ZaBiVsS
country: US country: FR
region: California region: Île-de-France
city: San Jose city: Paris
ip: 149.36.48.99 ip: 156.146.63.215
avail_mem_mb: 121000 avail_mem_mb: 123000
avail_vcpus: 42 avail_vcpus: 46
avail_storage_gbs: 400 avail_storage_gbs: 440
avail_ipv4: 23 avail_ipv4: 2
avail_ipv6: 0 avail_ipv6: 0
avail_ports: 20000 avail_ports: 20000
max_ports_per_vm: 5 max_ports_per_vm: 5
price: 20000 price: 20000
reports: {} reports: {}
offline_minutes: 0 offline_minutes: 0
- public_key: DgkbsrwttkZXvzxY5kDwQQoDd79GLmZ5tc7fYJUFkQQb - public_key: 2Uf5pxhxKTUm6gRMnpbJHYDuyA6BWUfFsdmPyWfbMV1f
operator_wallet: BFopWmwcZAMF1h2PFECZNdEucdZfnZZ32p6R9ZaBiVsS operator_wallet: x52w7jARC5erhWWK65VZmjdGXzBK6ZDgfv1A283d8XK
country: CA country: CA
region: British Columbia region: Quebec
city: Vancouver city: Montréal
ip: 149.22.95.1 ip: 184.107.169.199
avail_mem_mb: 106400 avail_mem_mb: 30000
avail_vcpus: 42 avail_vcpus: 31
avail_storage_gbs: 400 avail_storage_gbs: 700
avail_ipv4: 25 avail_ipv4: 0
avail_ipv6: 0 avail_ipv6: 0
avail_ports: 19999 avail_ports: 20000
max_ports_per_vm: 5 max_ports_per_vm: 5
price: 20000 price: 18000
reports: {} reports: {}
offline_minutes: 0 offline_minutes: 0
- public_key: 2Uf5pxhxKTUm6gRMnpbJHYDuyA6BWUfFsdmPyWfbMV1f - public_key: DgkbsrwttkZXvzxY5kDwQQoDd79GLmZ5tc7fYJUFkQQb
operator_wallet: x52w7jARC5erhWWK65VZmjdGXzBK6ZDgfv1A283d8XK operator_wallet: BFopWmwcZAMF1h2PFECZNdEucdZfnZZ32p6R9ZaBiVsS
country: CA country: CA
region: Quebec region: British Columbia
city: Montréal city: Vancouver
ip: 184.107.169.199 ip: 149.22.95.1
avail_mem_mb: 29000 avail_mem_mb: 109000
avail_vcpus: 30 avail_vcpus: 45
avail_storage_gbs: 700 avail_storage_gbs: 400
avail_ipv4: 0 avail_ipv4: 25
avail_ipv6: 0 avail_ipv6: 0
avail_ports: 19999 avail_ports: 20000
max_ports_per_vm: 5 max_ports_per_vm: 5
price: 18000 price: 20000
reports: {} reports: {}
offline_minutes: 0 offline_minutes: 0
- public_key: 3zRxiGRnf46vd3zAEmpaYBJocTV9oJB6yXf5GZFR1Sq4
operator_wallet: BFopWmwcZAMF1h2PFECZNdEucdZfnZZ32p6R9ZaBiVsS
country: US
region: California
city: San Jose
ip: 149.36.48.99
avail_mem_mb: 120000
avail_vcpus: 41
avail_storage_gbs: 390
avail_ipv4: 23
avail_ipv6: 0
avail_ports: 19999
max_ports_per_vm: 5
price: 20000
reports: {}
offline_minutes: 0
- public_key: HiyMp21zaBVbRCjDsD5hEjQnHeHv4e1gpUR6pVfHTKqv
operator_wallet: BFopWmwcZAMF1h2PFECZNdEucdZfnZZ32p6R9ZaBiVsS
country: CA
region: British Columbia
city: Vancouver
ip: 149.22.95.28
avail_mem_mb: 125000
avail_vcpus: 46
avail_storage_gbs: 400
avail_ipv4: 26
avail_ipv6: 0
avail_ports: 20000
max_ports_per_vm: 5
price: 20000
reports: {}
offline_minutes: 0
vm_contracts: vm_contracts:
- uuid: dbe09a11-0bcf-472e-9f27-9a4939ea2226 - uuid: 958165e3-dea8-407d-8c42-dd17002ef79c
hostname: detee-fr hostname: detee-landing-fr
admin_pubkey: FHuecMbeC1PfjkW2JKyoicJAuiU7khgQT16QUB3Q1XdL admin_pubkey: FHuecMbeC1PfjkW2JKyoicJAuiU7khgQT16QUB3Q1XdL
node_pubkey: Du3UfPSUUZmA5thQmc9Vrxdy7UimpygcpDsQNnwRQPtu node_pubkey: Du3UfPSUUZmA5thQmc9Vrxdy7UimpygcpDsQNnwRQPtu
exposed_ports: [] exposed_ports: []
public_ipv4: 156.146.63.217 public_ipv4: 156.146.63.216
public_ipv6: '' public_ipv6: ""
disk_size_gb: 10 disk_size_gb: 10
vcpus: 4 vcpus: 2
memory_mb: 4000 memory_mb: 3000
kernel_sha: e765e56166ef321b53399b9638584d1279821dbe3d46191c1f66bbaa075e7919 kernel_sha: 3ec4fc5aa5729f515967ec71be4a851622785c0080f7191b1b07717149840151
dtrfs_sha: d207644ee60d54009b6ecdfb720e2ec251cde31774dd249fcc7435aca0377990 dtrfs_sha: 3f6b3e5740f249eedfb2f7248c521a551be8b2676f7fcb040f3f3bc840a5004b
created_at: 2025-05-16T11:07:53.903282009Z created_at: 2025-02-28T23:19:41.769423466Z
updated_at: 2025-05-16T11:07:53.903282959Z updated_at: 2025-04-12T12:11:58.516768949Z
price_per_unit: 20000 price_per_unit: 20000
locked_nano: 24513120000 locked_nano: 14875500000
collected_at: 2025-06-26T11:32:59.521517733Z collected_at: 2025-04-20T00:34:15.461165181Z
- uuid: 338312387c6e4e5ebec015277d27c21d - uuid: e807a2fd-cf90-4a14-bc3a-89ce6dc59033
hostname: sofenty-staging hostname: detee-landing-gb
admin_pubkey: FHuecMbeC1PfjkW2JKyoicJAuiU7khgQT16QUB3Q1XdL admin_pubkey: FHuecMbeC1PfjkW2JKyoicJAuiU7khgQT16QUB3Q1XdL
node_pubkey: DgkbsrwttkZXvzxY5kDwQQoDd79GLmZ5tc7fYJUFkQQb node_pubkey: 7Xw3RxbP5pvfjZ8U6yA3HHVSS9YXjKH5Vkas3JRbQYd9
exposed_ports: [] exposed_ports: []
public_ipv4: 149.22.95.3 public_ipv4: 173.234.136.154
public_ipv6: '' public_ipv6: ""
disk_size_gb: 10 disk_size_gb: 10
vcpus: 2 vcpus: 2
memory_mb: 4000 memory_mb: 3000
kernel_sha: e765e56166ef321b53399b9638584d1279821dbe3d46191c1f66bbaa075e7919 kernel_sha: 3ec4fc5aa5729f515967ec71be4a851622785c0080f7191b1b07717149840151
dtrfs_sha: d207644ee60d54009b6ecdfb720e2ec251cde31774dd249fcc7435aca0377990 dtrfs_sha: 3f6b3e5740f249eedfb2f7248c521a551be8b2676f7fcb040f3f3bc840a5004b
created_at: 2025-06-12T23:20:23.797184848Z created_at: 2025-03-06T19:51:39.595163157Z
updated_at: 2025-06-12T23:20:23.797185855Z updated_at: 2025-03-06T19:51:39.595163842Z
price_per_unit: 20000 price_per_unit: 20000
locked_nano: 17703920000 locked_nano: 14875500000
collected_at: 2025-06-26T11:32:59.521538185Z collected_at: 2025-04-20T00:34:15.461181545Z
- uuid: 46656273dc964fdeaec2fd1efd49fc12 - uuid: 23094406-2307-4332-a642-acee718d0186
hostname: sofenty-scraper-bot hostname: heroic-door
admin_pubkey: FHuecMbeC1PfjkW2JKyoicJAuiU7khgQT16QUB3Q1XdL admin_pubkey: DwfL5iFu32xh2YMCUxg63oEAThLRqehDAumiP9q6zuuX
node_pubkey: DgkbsrwttkZXvzxY5kDwQQoDd79GLmZ5tc7fYJUFkQQb node_pubkey: 7Xw3RxbP5pvfjZ8U6yA3HHVSS9YXjKH5Vkas3JRbQYd9
exposed_ports: exposed_ports:
- 36057 - 38288
public_ipv4: '' public_ipv4: ""
public_ipv6: '' public_ipv6: ""
disk_size_gb: 10 disk_size_gb: 10
vcpus: 2 vcpus: 1
memory_mb: 4000 memory_mb: 1000
kernel_sha: e765e56166ef321b53399b9638584d1279821dbe3d46191c1f66bbaa075e7919 kernel_sha: 14e225e4aaf84cc2e0b5f64206121186ddebc4b378b886da3b2f7515dfd41692
dtrfs_sha: d207644ee60d54009b6ecdfb720e2ec251cde31774dd249fcc7435aca0377990 dtrfs_sha: 03ce24dbbe917fdd4f6347e61036805ddbdded5044c272bab188ef9333093bee
created_at: 2025-06-17T11:12:18.659422501Z created_at: 2025-03-12T16:28:24.749161605Z
updated_at: 2025-06-17T11:12:18.659423285Z updated_at: 2025-03-12T16:28:24.749162477Z
price_per_unit: 20000 price_per_unit: 20000
locked_nano: 14299320000 locked_nano: 14134140000
collected_at: 2025-06-26T11:32:59.521547200Z collected_at: 2025-04-20T00:34:15.461191231Z
- uuid: 1b3365a15fe64b8aa283bb7883c62e09 - uuid: 1f49a71c-f68c-4c64-a82e-f50e0ba0b574
hostname: detee-us hostname: astromech-wrench
admin_pubkey: FHuecMbeC1PfjkW2JKyoicJAuiU7khgQT16QUB3Q1XdL admin_pubkey: FHuecMbeC1PfjkW2JKyoicJAuiU7khgQT16QUB3Q1XdL
node_pubkey: 3zRxiGRnf46vd3zAEmpaYBJocTV9oJB6yXf5GZFR1Sq4 node_pubkey: DgkbsrwttkZXvzxY5kDwQQoDd79GLmZ5tc7fYJUFkQQb
exposed_ports: [] exposed_ports: []
public_ipv4: 149.36.48.100 public_ipv4: 149.22.95.2
public_ipv6: '' public_ipv6: ""
disk_size_gb: 10 disk_size_gb: 10
vcpus: 4 vcpus: 2
memory_mb: 4000 memory_mb: 3000
kernel_sha: e765e56166ef321b53399b9638584d1279821dbe3d46191c1f66bbaa075e7919 kernel_sha: 3a68709138bed09c16671949cf1f03acee95a08381ba84fc70fb586001fa6767
dtrfs_sha: d207644ee60d54009b6ecdfb720e2ec251cde31774dd249fcc7435aca0377990 dtrfs_sha: 0bb93443f65c9f4379ed469f94794f5c1bf14d8905b0b2c56a125df4a9ebe83e
created_at: 2025-06-18T10:51:17.699206021Z created_at: 2025-03-20T14:40:25.557753393Z
updated_at: 2025-06-18T10:51:17.699206835Z updated_at: 2025-03-20T14:40:25.557754242Z
price_per_unit: 20000 price_per_unit: 20000
locked_nano: 26552160000 locked_nano: 11865620000
collected_at: 2025-06-26T11:32:59.521554160Z collected_at: 2025-04-20T00:34:15.461201690Z
- uuid: b11ad0fcfc194f5490d64f5a72574dc8 - uuid: 16577f1c-9867-4a17-80a8-6cf0490f1270
hostname: brain-backups hostname: sofenty
admin_pubkey: 45Pyv9hRfub43NyRrYv95MhZs1Wrm8sj3RhBvA3F1Bvr admin_pubkey: FHuecMbeC1PfjkW2JKyoicJAuiU7khgQT16QUB3Q1XdL
node_pubkey: 2Uf5pxhxKTUm6gRMnpbJHYDuyA6BWUfFsdmPyWfbMV1f node_pubkey: Du3UfPSUUZmA5thQmc9Vrxdy7UimpygcpDsQNnwRQPtu
exposed_ports: exposed_ports: []
- 38175 public_ipv4: 156.146.63.217
public_ipv4: '' public_ipv6: ""
public_ipv6: '' disk_size_gb: 10
disk_size_gb: 30 vcpus: 2
vcpus: 1 memory_mb: 3000
memory_mb: 1000 kernel_sha: e49c8587287b21df7600c04326fd7393524453918c14d67f73757dc769a13542
kernel_sha: e765e56166ef321b53399b9638584d1279821dbe3d46191c1f66bbaa075e7919 dtrfs_sha: b5f408d00e2b93dc594fed3a7f2466a9878802ff1c7ae502247471cd06728a45
dtrfs_sha: d207644ee60d54009b6ecdfb720e2ec251cde31774dd249fcc7435aca0377990 created_at: 2025-04-07T22:57:57.646151746Z
created_at: 2025-06-18T13:59:30.713579315Z updated_at: 2025-04-07T22:57:57.646152630Z
updated_at: 2025-06-18T13:59:30.713580515Z price_per_unit: 20000
price_per_unit: 20000 locked_nano: 11867500000
locked_nano: 11638260000 collected_at: 2025-04-20T00:34:15.461211040Z
collected_at: 2025-06-26T11:32:59.521562057Z - uuid: 4b6e25ca-87ac-478b-8f16-aa8f5c44c704
- uuid: 89237736b97047beac3611e25e26408e hostname: cloaked-mailbox
hostname: brain-staging admin_pubkey: DwfL5iFu32xh2YMCUxg63oEAThLRqehDAumiP9q6zuuX
admin_pubkey: 45Pyv9hRfub43NyRrYv95MhZs1Wrm8sj3RhBvA3F1Bvr node_pubkey: DgkbsrwttkZXvzxY5kDwQQoDd79GLmZ5tc7fYJUFkQQb
node_pubkey: Du3UfPSUUZmA5thQmc9Vrxdy7UimpygcpDsQNnwRQPtu exposed_ports: []
exposed_ports: [] public_ipv4: 149.22.95.2
public_ipv4: 156.146.63.216 public_ipv6: ""
public_ipv6: '' disk_size_gb: 30
disk_size_gb: 20 vcpus: 1
vcpus: 2 memory_mb: 1000
memory_mb: 4000 kernel_sha: e49c8587287b21df7600c04326fd7393524453918c14d67f73757dc769a13542
kernel_sha: e765e56166ef321b53399b9638584d1279821dbe3d46191c1f66bbaa075e7919 dtrfs_sha: b5f408d00e2b93dc594fed3a7f2466a9878802ff1c7ae502247471cd06728a45
dtrfs_sha: d207644ee60d54009b6ecdfb720e2ec251cde31774dd249fcc7435aca0377990 created_at: 2025-04-12T13:44:56.957037550Z
created_at: 2025-06-18T14:00:48.016735075Z updated_at: 2025-04-12T13:44:56.957038546Z
updated_at: 2025-06-18T14:00:48.016736647Z price_per_unit: 20000
price_per_unit: 20000 locked_nano: 11177760000
locked_nano: 32466740000 collected_at: 2025-04-20T00:34:15.461219779Z
collected_at: 2025-06-26T11:32:59.521568755Z - uuid: eb1a13ed-d782-4b71-8860-73540129cb7d
hostname: twenty
admin_pubkey: FHuecMbeC1PfjkW2JKyoicJAuiU7khgQT16QUB3Q1XdL
node_pubkey: 3zRxiGRnf46vd3zAEmpaYBJocTV9oJB6yXf5GZFR1Sq4
exposed_ports: []
public_ipv4: 149.36.48.100
public_ipv6: ""
disk_size_gb: 10
vcpus: 4
memory_mb: 4000
kernel_sha: e49c8587287b21df7600c04326fd7393524453918c14d67f73757dc769a13542
dtrfs_sha: b5f408d00e2b93dc594fed3a7f2466a9878802ff1c7ae502247471cd06728a45
created_at: 2025-04-15T00:46:35.622165457Z
updated_at: 2025-04-15T00:46:35.622166372Z
price_per_unit: 20000
locked_nano: 15570720000
collected_at: 2025-04-20T00:34:15.461230948Z
- uuid: 1bf36309-3774-4825-b023-b2a0ef0405ed
hostname: shadowy-hobo
admin_pubkey: x52w7jARC5erhWWK65VZmjdGXzBK6ZDgfv1A283d8XK
node_pubkey: 3zRxiGRnf46vd3zAEmpaYBJocTV9oJB6yXf5GZFR1Sq4
exposed_ports:
- 46393
public_ipv4: ""
public_ipv6: ""
disk_size_gb: 10
vcpus: 1
memory_mb: 1000
kernel_sha: e765e56166ef321b53399b9638584d1279821dbe3d46191c1f66bbaa075e7919
dtrfs_sha: d207644ee60d54009b6ecdfb720e2ec251cde31774dd249fcc7435aca0377990
created_at: 2025-04-16T20:37:57.176592933Z
updated_at: 2025-04-16T20:37:57.176594069Z
price_per_unit: 20000
locked_nano: 12730960000
collected_at: 2025-04-20T00:34:15.461240342Z
app_nodes: app_nodes:
- node_pubkey: BiqoPUEoAxYxMRXUmyofoS9H1TBQgQqvLJ6MbWh88AQg - node_pubkey: BiqoPUEoAxYxMRXUmyofoS9H1TBQgQqvLJ6MbWh88AQg
operator_wallet: 7V3rEuh6j8VuwMVB5PyGqWKLmjJ4fYSv6WtrTL51NZTB operator_wallet: 7V3rEuh6j8VuwMVB5PyGqWKLmjJ4fYSv6WtrTL51NZTB
country: DE country: DE
region: Hesse region: Hesse
city: Frankfurt am Main city: Frankfurt am Main
ip: 212.95.45.139 ip: 212.95.45.139
avail_mem_mb: 16000 avail_mem_mb: 16000
avail_vcpus: 16 avail_vcpus: 16
avail_storage_mb: 200000 avail_storage_mb: 200000
avail_no_of_port: 20000 avail_no_of_port: 20000
max_ports_per_app: 9 max_ports_per_app: 9
price: 20000 price: 20000
reports: {} offline_minutes: 0
offline_minutes: 0 app_contracts:
app_contracts: [] - uuid: e3d01f25-2b2a-410b-80e3-12f44e474334
package_url: https://registry.detee.ltd/sgx/packages/base_package_2025-04-17_11-01-08.tar.gz
admin_pubkey: H21Shi4iE7vgfjWEQNvzmpmBMJSaiZ17PYUcdNoAoKNc
node_pubkey: BiqoPUEoAxYxMRXUmyofoS9H1TBQgQqvLJ6MbWh88AQg
mapped_ports:
- - 27158
- 34500
- - 28667
- 8080
host_ipv4: 212.95.45.139
disk_size_mb: 1000
vcpus: 1
memory_mb: 1000
created_at: 2025-04-21T11:27:28.833236909Z
updated_at: 2025-04-21T11:27:28.833237729Z
price_per_unit: 200000
locked_nano: 121200000
collected_at: 2025-04-21T11:28:24.905665571Z
hratls_pubkey: 7E0F887AA6BB9104EEC1066F454D4C2D9063D676715F55F919D3FBCEDC63240B
public_package_mr_enclave:
- 52
- 183
- 102
- 210
- 251
- 219
- 218
- 140
- 168
- 118
- 10
- 193
- 98
- 240
- 147
- 124
- 240
- 189
- 46
- 95
- 138
- 172
- 15
- 246
- 227
- 114
- 70
- 159
- 232
- 212
- 9
- 234
app_name: diligent-seahorse

@ -12,7 +12,7 @@ server="$1"
exit 1 exit 1
} }
[[ "$server" == "testnet" ]] && server="brain-testnet" [[ "$server" == "testnet" ]] && server="root@prod-brain-1"
[[ "$server" == "staging" ]] && server="brain-staging" [[ "$server" == "staging" ]] && server="brain-staging"
cargo build --release --bin brain cargo build --release --bin brain

@ -50,6 +50,7 @@ pub const ID_ALPHABET: [char; 62] = [
]; ];
pub const TOKEN_DECIMAL: u64 = 1_000_000_000; pub const TOKEN_DECIMAL: u64 = 1_000_000_000;
pub const MIN_ESCROW: u64 = 5000 * TOKEN_DECIMAL;
pub const APP_DAEMON_TIMEOUT: u64 = 20; pub const APP_DAEMON_TIMEOUT: u64 = 20;
pub const VM_DAEMON_TIMEOUT: u64 = 10; pub const VM_DAEMON_TIMEOUT: u64 = 10;

@ -6,8 +6,9 @@ use super::Error;
use crate::constants::{ use crate::constants::{
ACCOUNT, ACTIVE_APP, APP_DAEMON_TIMEOUT, APP_NODE, DEFAULT_ENDPOINT, DELETED_APP, NEW_APP_REQ, ACCOUNT, ACTIVE_APP, APP_DAEMON_TIMEOUT, APP_NODE, DEFAULT_ENDPOINT, DELETED_APP, NEW_APP_REQ,
}; };
use crate::db;
use crate::db::general::Report; use crate::db::general::Report;
use crate::{db, old_brain}; use crate::old_brain;
use detee_shared::app_proto::{self, NewAppRes}; use detee_shared::app_proto::{self, NewAppRes};
use serde::{Deserialize, Serialize}; use serde::{Deserialize, Serialize};
use surrealdb::engine::remote::ws::Client; use surrealdb::engine::remote::ws::Client;
@ -24,14 +25,13 @@ pub struct AppNode {
pub region: String, pub region: String,
pub city: String, pub city: String,
pub ip: String, pub ip: String,
pub avail_mem_mib: u32, pub avail_mem_mb: u32,
pub avail_vcpus: u32, pub avail_vcpus: u32,
pub avail_storage_mib: u32, pub avail_storage_gbs: u32,
pub avail_ports: u32, pub avail_ports: u32,
pub max_ports_per_app: u32, pub max_ports_per_app: u32,
pub price: u64, pub price: u64,
pub connected_at: Datetime, pub offline_minutes: u64,
pub disconnected_at: Datetime,
} }
impl AppNode { impl AppNode {
@ -41,18 +41,6 @@ impl AppNode {
let app_node: Option<AppNode> = db.upsert(app_node_id.clone()).content(self).await?; let app_node: Option<AppNode> = db.upsert(app_node_id.clone()).content(self).await?;
app_node.ok_or(Error::FailedToCreateDBEntry(format!("{APP_NODE}:{app_node_id}"))) app_node.ok_or(Error::FailedToCreateDBEntry(format!("{APP_NODE}:{app_node_id}")))
} }
pub async fn set_online(db: &Surreal<Client>, app_node_id: &str) -> Result<(), Error> {
db.query(format!("UPDATE {APP_NODE}:{app_node_id} SET connected_at = time::now();"))
.await?;
Ok(())
}
pub async fn set_offline(db: &Surreal<Client>, app_node_id: &str) -> Result<(), Error> {
db.query(format!("UPDATE {APP_NODE}:{app_node_id} SET disconnected_at = time::now();"))
.await?;
Ok(())
}
} }
pub enum AppDaemonMsg { pub enum AppDaemonMsg {
@ -84,9 +72,9 @@ pub struct NewAppReq {
pub mr_enclave: String, pub mr_enclave: String,
pub hratls_pubkey: String, pub hratls_pubkey: String,
pub ports: Vec<u32>, pub ports: Vec<u32>,
pub memory_mib: u32, pub memory_mb: u32,
pub vcpus: u32, pub vcpus: u32,
pub disk_size_mib: u32, pub disk_size_gb: u32,
pub locked_nano: u64, pub locked_nano: u64,
pub price_per_unit: u64, pub price_per_unit: u64,
pub error: String, pub error: String,
@ -177,12 +165,12 @@ impl NewAppReq {
->$app_node ->$app_node
CONTENT {{ CONTENT {{
created_at: time::now(), app_name: $app_name, package_url: $package_url, created_at: time::now(), app_name: $app_name, package_url: $package_url,
mr_enclave: $mr_enclave, hratls_pubkey: $hratls_pubkey, ports: {:?}, memory_mib: {}, mr_enclave: $mr_enclave, hratls_pubkey: $hratls_pubkey, ports: {:?}, memory_mb: {},
vcpus: {}, disk_size_mib: {}, locked_nano: {locked_nano}, price_per_unit: {}, error: '', vcpus: {}, disk_size_gb: {}, locked_nano: {locked_nano}, price_per_unit: {}, error: '',
}}; }};
COMMIT TRANSACTION;", COMMIT TRANSACTION;",
self.ports, self.memory_mib, self.vcpus, self.disk_size_mib, self.price_per_unit); self.ports, self.memory_mb, self.vcpus, self.disk_size_gb, self.price_per_unit);
log::trace!("submit_new_app_req query: {tx_query}"); log::trace!("submit_new_app_req query: {tx_query}");
@ -224,12 +212,13 @@ pub struct AppNodeWithReports {
pub region: String, pub region: String,
pub city: String, pub city: String,
pub ip: String, pub ip: String,
pub avail_mem_mib: u32, pub avail_mem_mb: u32,
pub avail_vcpus: u32, pub avail_vcpus: u32,
pub avail_storage_mib: u32, pub avail_storage_gbs: u32,
pub avail_ports: u32, pub avail_ports: u32,
pub max_ports_per_app: u32, pub max_ports_per_app: u32,
pub price: u64, pub price: u64,
pub offline_minutes: u64,
pub reports: Vec<Report>, pub reports: Vec<Report>,
} }
@ -244,13 +233,13 @@ impl AppNodeWithReports {
avail_ports >= {} && avail_ports >= {} &&
max_ports_per_app >= {} && max_ports_per_app >= {} &&
avail_vcpus >= {} && avail_vcpus >= {} &&
avail_mem_mib >= {} && avail_mem_mb >= {} &&
avail_storage_mib >= {} ", avail_storage_gbs >= {} ",
filters.free_ports, filters.free_ports,
filters.free_ports, filters.free_ports,
filters.vcpus, filters.vcpus,
filters.memory_mib, filters.memory_mb,
filters.storage_mib filters.storage_gb
); );
// TODO: bind all strings // TODO: bind all strings
@ -267,8 +256,6 @@ impl AppNodeWithReports {
filter_query += &format!("&& ip = '{}' ", filters.ip); filter_query += &format!("&& ip = '{}' ", filters.ip);
} }
filter_query += " && connected_at > disconnected_at ";
if limit_one { if limit_one {
filter_query += "limit 1"; filter_query += "limit 1";
} }
@ -291,8 +278,8 @@ pub struct ActiveApp {
pub mapped_ports: Vec<(u32, u32)>, pub mapped_ports: Vec<(u32, u32)>,
pub host_ipv4: String, pub host_ipv4: String,
pub vcpus: u32, pub vcpus: u32,
pub memory_mib: u32, pub memory_mb: u32,
pub disk_size_mib: u32, pub disk_size_gb: u32,
pub created_at: Datetime, pub created_at: Datetime,
pub price_per_unit: u64, pub price_per_unit: u64,
pub locked_nano: u64, pub locked_nano: u64,
@ -312,8 +299,8 @@ impl From<ActiveApp> for DeletedApp {
mapped_ports: value.mapped_ports, mapped_ports: value.mapped_ports,
host_ipv4: value.host_ipv4, host_ipv4: value.host_ipv4,
vcpus: value.vcpus, vcpus: value.vcpus,
memory_mib: value.memory_mib, memory_mb: value.memory_mb,
disk_size_mib: value.disk_size_mib, disk_size_gb: value.disk_size_gb,
created_at: value.created_at, created_at: value.created_at,
price_per_unit: value.price_per_unit, price_per_unit: value.price_per_unit,
mr_enclave: value.mr_enclave, mr_enclave: value.mr_enclave,
@ -324,6 +311,15 @@ impl From<ActiveApp> for DeletedApp {
} }
impl ActiveApp { impl ActiveApp {
pub fn price_per_minute(&self) -> u64 {
(self.total_units() * self.price_per_unit as f64) as u64
}
fn total_units(&self) -> f64 {
// TODO: Optimize this based on price of hardware.
(self.vcpus as f64 * 5f64) + (self.memory_mb as f64 / 200f64) + (self.disk_size_gb as f64)
}
pub async fn get_by_uuid(db: &Surreal<Client>, uuid: &str) -> Result<Option<Self>, Error> { pub async fn get_by_uuid(db: &Surreal<Client>, uuid: &str) -> Result<Option<Self>, Error> {
let contract: Option<Self> = db let contract: Option<Self> = db
.query("select * from $active_app_id;".to_string()) .query("select * from $active_app_id;".to_string())
@ -356,8 +352,8 @@ impl ActiveApp {
mapped_ports, mapped_ports,
host_ipv4: new_app_res.ip_address, host_ipv4: new_app_res.ip_address,
vcpus: new_app_req.vcpus, vcpus: new_app_req.vcpus,
memory_mib: new_app_req.memory_mib, memory_mb: new_app_req.memory_mb,
disk_size_mib: new_app_req.disk_size_mib, disk_size_gb: new_app_req.disk_size_gb,
created_at: new_app_req.created_at.clone(), created_at: new_app_req.created_at.clone(),
price_per_unit: new_app_req.price_per_unit, price_per_unit: new_app_req.price_per_unit,
locked_nano: new_app_req.locked_nano, locked_nano: new_app_req.locked_nano,
@ -371,7 +367,7 @@ impl ActiveApp {
let locked_nano = active_app.locked_nano; let locked_nano = active_app.locked_nano;
let _: Vec<ActiveApp> = db.insert(()).relation(active_app).await?; let _: Vec<ActiveApp> = db.insert(()).relation(active_app).await?;
NewAppReq::delete(db, &new_app_res.uuid).await?; NewAppReq::delete(&db, &new_app_res.uuid).await?;
db.query(format!("UPDATE {ACCOUNT}:{admin_account} SET tmp_locked -= {locked_nano};")) db.query(format!("UPDATE {ACCOUNT}:{admin_account} SET tmp_locked -= {locked_nano};"))
.await?; .await?;
@ -502,8 +498,8 @@ pub struct ActiveAppWithNode {
pub mapped_ports: Vec<(u32, u32)>, pub mapped_ports: Vec<(u32, u32)>,
pub host_ipv4: String, pub host_ipv4: String,
pub vcpus: u32, pub vcpus: u32,
pub memory_mib: u32, pub memory_mb: u32,
pub disk_size_mib: u32, pub disk_size_gb: u32,
pub created_at: Datetime, pub created_at: Datetime,
pub price_per_unit: u64, pub price_per_unit: u64,
pub locked_nano: u64, pub locked_nano: u64,
@ -523,8 +519,8 @@ impl From<ActiveAppWithNode> for ActiveApp {
mapped_ports: val.mapped_ports, mapped_ports: val.mapped_ports,
host_ipv4: val.host_ipv4, host_ipv4: val.host_ipv4,
vcpus: val.vcpus, vcpus: val.vcpus,
memory_mib: val.memory_mib, memory_mb: val.memory_mb,
disk_size_mib: val.disk_size_mib, disk_size_gb: val.disk_size_gb,
created_at: val.created_at, created_at: val.created_at,
price_per_unit: val.price_per_unit, price_per_unit: val.price_per_unit,
locked_nano: val.locked_nano, locked_nano: val.locked_nano,
@ -592,17 +588,6 @@ impl ActiveAppWithNode {
} }
} }
fn total_units(&self) -> f64 {
// TODO: Optimize this based on price of hardware.
(self.vcpus as f64 * 5f64)
+ (self.memory_mib as f64 / 200f64)
+ (self.disk_size_mib as f64 / 1024f64 / 10f64)
}
pub fn price_per_minute(&self) -> u64 {
(self.total_units() * self.price_per_unit as f64) as u64
}
pub async fn list_all(db: &Surreal<Client>) -> Result<Vec<Self>, Error> { pub async fn list_all(db: &Surreal<Client>) -> Result<Vec<Self>, Error> {
let mut query_response = db.query(format!("SELECT * FROM {ACTIVE_APP} FETCH out;")).await?; let mut query_response = db.query(format!("SELECT * FROM {ACTIVE_APP} FETCH out;")).await?;
let active_apps: Vec<Self> = query_response.take(0)?; let active_apps: Vec<Self> = query_response.take(0)?;
@ -614,8 +599,8 @@ impl ActiveAppWithNode {
pub struct AppNodeResources { pub struct AppNodeResources {
pub avail_ports: u32, pub avail_ports: u32,
pub avail_vcpus: u32, pub avail_vcpus: u32,
pub avail_mem_mib: u32, pub avail_mem_mb: u32,
pub avail_storage_mib: u32, pub avail_storage_gbs: u32,
pub max_ports_per_app: u32, pub max_ports_per_app: u32,
} }
@ -643,14 +628,13 @@ impl From<&old_brain::BrainData> for Vec<AppNode> {
region: old_node.region.clone(), region: old_node.region.clone(),
city: old_node.city.clone(), city: old_node.city.clone(),
ip: old_node.ip.clone(), ip: old_node.ip.clone(),
avail_mem_mib: old_node.avail_mem_mb, avail_mem_mb: old_node.avail_mem_mb,
avail_vcpus: old_node.avail_vcpus, avail_vcpus: old_node.avail_vcpus,
avail_storage_mib: old_node.avail_storage_mb, avail_storage_gbs: old_node.avail_storage_mb,
avail_ports: old_node.avail_no_of_port, avail_ports: old_node.avail_no_of_port,
max_ports_per_app: old_node.max_ports_per_app, max_ports_per_app: old_node.max_ports_per_app,
price: old_node.price, price: old_node.price,
disconnected_at: Datetime::default(), offline_minutes: old_node.offline_minutes,
connected_at: Datetime::default(),
}); });
} }
nodes nodes
@ -680,9 +664,9 @@ impl From<&old_brain::BrainData> for Vec<ActiveApp> {
app_node: RecordId::from((APP_NODE, old_c.node_pubkey.clone())), app_node: RecordId::from((APP_NODE, old_c.node_pubkey.clone())),
mapped_ports, mapped_ports,
host_ipv4: old_c.host_ipv4.clone(), host_ipv4: old_c.host_ipv4.clone(),
disk_size_mib: old_c.disk_size_mb, disk_size_gb: old_c.disk_size_mb * 1024,
vcpus: old_c.vcpus, vcpus: old_c.vcpus,
memory_mib: old_c.memory_mb, memory_mb: old_c.memory_mb,
price_per_unit: old_c.price_per_unit, price_per_unit: old_c.price_per_unit,
locked_nano: old_c.locked_nano, locked_nano: old_c.locked_nano,
created_at: old_c.created_at.into(), created_at: old_c.created_at.into(),
@ -708,8 +692,8 @@ pub struct DeletedApp {
pub mapped_ports: Vec<(u32, u32)>, pub mapped_ports: Vec<(u32, u32)>,
pub host_ipv4: String, pub host_ipv4: String,
pub vcpus: u32, pub vcpus: u32,
pub memory_mib: u32, pub memory_mb: u32,
pub disk_size_mib: u32, pub disk_size_gb: u32,
pub created_at: Datetime, pub created_at: Datetime,
pub price_per_unit: u64, pub price_per_unit: u64,
pub mr_enclave: String, pub mr_enclave: String,

@ -1,7 +1,7 @@
// SPDX-License-Identifier: Apache-2.0 // SPDX-License-Identifier: Apache-2.0
use super::Error; use super::Error;
use crate::constants::{ACCOUNT, BAN, KICK, TOKEN_DECIMAL, VM_NODE}; use crate::constants::{ACCOUNT, BAN, KICK, MIN_ESCROW, VM_NODE};
use crate::db::prelude::*; use crate::db::prelude::*;
use crate::old_brain; use crate::old_brain;
use serde::{Deserialize, Serialize}; use serde::{Deserialize, Serialize};
@ -61,7 +61,9 @@ impl Account {
email: &str, email: &str,
escrow: u64, escrow: u64,
) -> Result<(), Error> { ) -> Result<(), Error> {
let escrow = escrow.saturating_mul(TOKEN_DECIMAL); if escrow < MIN_ESCROW {
return Err(Error::MinimalEscrow);
}
let mut op_account = Self::get(db, wallet).await?; let mut op_account = Self::get(db, wallet).await?;
let op_total_balance = op_account.balance.saturating_add(op_account.escrow); let op_total_balance = op_account.balance.saturating_add(op_account.escrow);
if op_total_balance < escrow { if op_total_balance < escrow {

@ -5,8 +5,8 @@ pub mod general;
pub mod vm; pub mod vm;
use crate::constants::{ use crate::constants::{
APP_NODE, DB_SCHEMA_FILES, DEFAULT_ENDPOINT, DELETED_APP, DELETED_VM, NEW_APP_REQ, NEW_VM_REQ, APP_NODE, DB_SCHEMA_FILES, DEFAULT_ENDPOINT, DELETED_APP, DELETED_VM, MIN_ESCROW, NEW_APP_REQ,
UPDATE_VM_REQ, NEW_VM_REQ, UPDATE_VM_REQ,
}; };
use crate::old_brain; use crate::old_brain;
use prelude::*; use prelude::*;
@ -33,6 +33,8 @@ pub enum Error {
UnknownTable(String), UnknownTable(String),
#[error("Daemon channel got closed: {0}")] #[error("Daemon channel got closed: {0}")]
AppDaemonConnection(#[from] tokio::sync::mpsc::error::SendError<AppDaemonMsg>), AppDaemonConnection(#[from] tokio::sync::mpsc::error::SendError<AppDaemonMsg>),
#[error("Minimum escrow amount is {MIN_ESCROW}")]
MinimalEscrow,
#[error("Insufficient funds, deposit more tokens")] #[error("Insufficient funds, deposit more tokens")]
InsufficientFunds, InsufficientFunds,
#[error("Contract not found")] #[error("Contract not found")]
@ -99,7 +101,7 @@ pub async fn migration0(
println!("Inserting vm nodes..."); println!("Inserting vm nodes...");
let _: Vec<VmNode> = db.insert(()).content(vm_nodes).await?; let _: Vec<VmNode> = db.insert(()).content(vm_nodes).await?;
println!("Inserting app nodes..."); println!("Inserting app nodes...");
let _: Vec<AppNode> = db.insert(()).content(app_nodes).await.unwrap(); let _: Vec<AppNode> = db.insert(()).content(app_nodes).await?;
println!("Inserting active vm contracts..."); println!("Inserting active vm contracts...");
let _: Vec<ActiveVm> = db.insert(()).relation(active_vm).await?; let _: Vec<ActiveVm> = db.insert(()).relation(active_vm).await?;
println!("Inserting app contracts..."); println!("Inserting app contracts...");

@ -26,9 +26,9 @@ pub struct VmNode {
pub region: String, pub region: String,
pub city: String, pub city: String,
pub ip: String, pub ip: String,
pub avail_mem_mib: u32, pub avail_mem_mb: u32,
pub avail_vcpus: u32, pub avail_vcpus: u32,
pub avail_storage_mib: u32, pub avail_storage_gbs: u32,
pub avail_ipv4: u32, pub avail_ipv4: u32,
pub avail_ipv6: u32, pub avail_ipv6: u32,
pub avail_ports: u32, pub avail_ports: u32,
@ -59,9 +59,9 @@ impl VmNode {
#[derive(Serialize)] #[derive(Serialize)]
pub struct VmNodeResources { pub struct VmNodeResources {
pub avail_mem_mib: u32, pub avail_mem_mb: u32,
pub avail_vcpus: u32, pub avail_vcpus: u32,
pub avail_storage_mib: u32, pub avail_storage_gbs: u32,
pub avail_ipv4: u32, pub avail_ipv4: u32,
pub avail_ipv6: u32, pub avail_ipv6: u32,
pub avail_ports: u32, pub avail_ports: u32,
@ -83,9 +83,9 @@ pub struct VmNodeWithReports {
pub region: String, pub region: String,
pub city: String, pub city: String,
pub ip: String, pub ip: String,
pub avail_mem_mib: u64, pub avail_mem_mb: u32,
pub avail_vcpus: u64, pub avail_vcpus: u32,
pub avail_storage_mib: u64, pub avail_storage_gbs: u32,
pub avail_ipv4: u32, pub avail_ipv4: u32,
pub avail_ipv6: u32, pub avail_ipv6: u32,
pub avail_ports: u32, pub avail_ports: u32,
@ -106,15 +106,15 @@ impl VmNodeWithReports {
avail_ipv4 >= {} && avail_ipv4 >= {} &&
avail_ipv6 >= {} && avail_ipv6 >= {} &&
avail_vcpus >= {} && avail_vcpus >= {} &&
avail_mem_mib >= {} && avail_mem_mb >= {} &&
avail_storage_mib >= {}\n", avail_storage_gbs >= {}\n",
filters.free_ports, filters.free_ports,
filters.free_ports, filters.free_ports,
filters.offers_ipv4 as u32, filters.offers_ipv4 as u32,
filters.offers_ipv6 as u32, filters.offers_ipv6 as u32,
filters.vcpus, filters.vcpus,
filters.memory_mib, filters.memory_mb,
filters.storage_mib filters.storage_gb
); );
if !filters.city.is_empty() { if !filters.city.is_empty() {
query += &format!("&& city = '{}' ", filters.city); query += &format!("&& city = '{}' ", filters.city);
@ -170,9 +170,9 @@ pub struct NewVmReq {
pub extra_ports: Vec<u32>, pub extra_ports: Vec<u32>,
pub public_ipv4: bool, pub public_ipv4: bool,
pub public_ipv6: bool, pub public_ipv6: bool,
pub disk_size_mib: u32, pub disk_size_gb: u32,
pub vcpus: u32, pub vcpus: u32,
pub memory_mib: u32, pub memory_mb: u32,
pub dtrfs_url: String, pub dtrfs_url: String,
pub dtrfs_sha: String, pub dtrfs_sha: String,
pub kernel_sha: String, pub kernel_sha: String,
@ -266,7 +266,7 @@ impl NewVmReq {
->$new_vm_req ->$new_vm_req
->$vm_node ->$vm_node
CONTENT {{ CONTENT {{
created_at: time::now(), hostname: $hostname, vcpus: {}, memory_mib: {}, disk_size_mib: {}, created_at: time::now(), hostname: $hostname, vcpus: {}, memory_mb: {}, disk_size_gb: {},
extra_ports: {:?}, public_ipv4: {}, public_ipv6: {}, extra_ports: {:?}, public_ipv4: {}, public_ipv6: {},
dtrfs_url: $dtrfs_url, dtrfs_sha: $dtrfs_sha, kernel_url: $kernel_url, kernel_sha: $kernel_sha, dtrfs_url: $dtrfs_url, dtrfs_sha: $dtrfs_sha, kernel_url: $kernel_url, kernel_sha: $kernel_sha,
price_per_unit: {}, locked_nano: {locked_nano}, error: '' price_per_unit: {}, locked_nano: {locked_nano}, error: ''
@ -274,8 +274,8 @@ impl NewVmReq {
COMMIT TRANSACTION;", COMMIT TRANSACTION;",
self.vcpus, self.vcpus,
self.memory_mib, self.memory_mb,
self.disk_size_mib, self.disk_size_gb,
self.extra_ports, self.extra_ports,
self.public_ipv4, self.public_ipv4,
self.public_ipv6, self.public_ipv6,
@ -334,7 +334,7 @@ impl WrappedMeasurement {
_ => NEW_VM_REQ, _ => NEW_VM_REQ,
}; };
let mut resp = db let mut resp = db
.query(format!("live select error from {table} where id = {table}:{vm_id};")) .query(format!("live select error from {table} where id = {NEW_VM_REQ}:{vm_id};"))
.query(format!( .query(format!(
"live select * from measurement_args where id = measurement_args:{vm_id};" "live select * from measurement_args where id = measurement_args:{vm_id};"
)) ))
@ -404,9 +404,9 @@ pub struct ActiveVm {
pub mapped_ports: Vec<(u32, u32)>, pub mapped_ports: Vec<(u32, u32)>,
pub public_ipv4: String, pub public_ipv4: String,
pub public_ipv6: String, pub public_ipv6: String,
pub disk_size_mib: u32, pub disk_size_gb: u32,
pub vcpus: u32, pub vcpus: u32,
pub memory_mib: u32, pub memory_mb: u32,
pub dtrfs_sha: String, pub dtrfs_sha: String,
pub kernel_sha: String, pub kernel_sha: String,
pub created_at: Datetime, pub created_at: Datetime,
@ -422,8 +422,8 @@ impl ActiveVm {
// I tried, but this can be done better. // I tried, but this can be done better.
// Storage cost should also be based on tier // Storage cost should also be based on tier
(self.vcpus as u64 * 10) (self.vcpus as u64 * 10)
+ ((self.memory_mib + 256) as u64 / 200) + ((self.memory_mb + 256) as u64 / 200)
+ (self.disk_size_mib as u64 / 10) + (self.disk_size_gb as u64 / 10)
+ (!self.public_ipv4.is_empty() as u64 * 10) + (!self.public_ipv4.is_empty() as u64 * 10)
} }
@ -483,9 +483,9 @@ impl ActiveVm {
mapped_ports, mapped_ports,
public_ipv4, public_ipv4,
public_ipv6, public_ipv6,
disk_size_mib: new_vm_req.disk_size_mib, disk_size_gb: new_vm_req.disk_size_gb,
vcpus: new_vm_req.vcpus, vcpus: new_vm_req.vcpus,
memory_mib: new_vm_req.memory_mib, memory_mb: new_vm_req.memory_mb,
dtrfs_sha: new_vm_req.dtrfs_sha, dtrfs_sha: new_vm_req.dtrfs_sha,
kernel_sha: new_vm_req.kernel_sha, kernel_sha: new_vm_req.kernel_sha,
created_at: new_vm_req.created_at.clone(), created_at: new_vm_req.created_at.clone(),
@ -517,11 +517,11 @@ impl ActiveVm {
if update_vm_req.vcpus > 0 { if update_vm_req.vcpus > 0 {
active_vm.vcpus = update_vm_req.vcpus; active_vm.vcpus = update_vm_req.vcpus;
} }
if update_vm_req.memory_mib > 0 { if update_vm_req.memory_mb > 0 {
active_vm.memory_mib = update_vm_req.memory_mib; active_vm.memory_mb = update_vm_req.memory_mb;
} }
if update_vm_req.disk_size_mib > 0 { if update_vm_req.disk_size_gb > 0 {
active_vm.disk_size_mib = update_vm_req.disk_size_mib; active_vm.disk_size_gb = update_vm_req.disk_size_gb;
} }
if !update_vm_req.dtrfs_sha.is_empty() && !update_vm_req.kernel_sha.is_empty() { if !update_vm_req.dtrfs_sha.is_empty() && !update_vm_req.kernel_sha.is_empty() {
active_vm.dtrfs_sha = update_vm_req.dtrfs_sha; active_vm.dtrfs_sha = update_vm_req.dtrfs_sha;
@ -670,9 +670,9 @@ pub struct UpdateVmReq {
pub admin: RecordId, pub admin: RecordId,
#[serde(rename = "out")] #[serde(rename = "out")]
pub vm_node: RecordId, pub vm_node: RecordId,
pub disk_size_mib: u32, pub disk_size_gb: u32,
pub vcpus: u32, pub vcpus: u32,
pub memory_mib: u32, pub memory_mb: u32,
pub dtrfs_url: String, pub dtrfs_url: String,
pub dtrfs_sha: String, pub dtrfs_sha: String,
pub kernel_sha: String, pub kernel_sha: String,
@ -688,9 +688,9 @@ pub struct UpdateVmEvent {
pub admin: RecordId, pub admin: RecordId,
#[serde(rename = "out")] #[serde(rename = "out")]
pub vm_node: RecordId, pub vm_node: RecordId,
pub disk_size_mib: u32, pub disk_size_gb: u32,
pub vcpus: u32, pub vcpus: u32,
pub memory_mib: u32, pub memory_mb: u32,
pub dtrfs_url: String, pub dtrfs_url: String,
pub dtrfs_sha: String, pub dtrfs_sha: String,
pub kernel_sha: String, pub kernel_sha: String,
@ -704,9 +704,9 @@ impl From<UpdateVmReq> for UpdateVmEvent {
vm_id: RecordId::from((VM_UPDATE_EVENT, update_vm_req.id.key().to_string())), vm_id: RecordId::from((VM_UPDATE_EVENT, update_vm_req.id.key().to_string())),
admin: update_vm_req.admin, admin: update_vm_req.admin,
vm_node: update_vm_req.vm_node, vm_node: update_vm_req.vm_node,
disk_size_mib: update_vm_req.disk_size_mib, disk_size_gb: update_vm_req.disk_size_gb,
vcpus: update_vm_req.vcpus, vcpus: update_vm_req.vcpus,
memory_mib: update_vm_req.memory_mib, memory_mb: update_vm_req.memory_mb,
dtrfs_url: update_vm_req.dtrfs_url, dtrfs_url: update_vm_req.dtrfs_url,
dtrfs_sha: update_vm_req.dtrfs_sha, dtrfs_sha: update_vm_req.dtrfs_sha,
kernel_sha: update_vm_req.kernel_sha, kernel_sha: update_vm_req.kernel_sha,
@ -743,32 +743,17 @@ impl UpdateVmReq {
return Ok(None); return Ok(None);
} }
let contract = contract.unwrap(); let contract = contract.unwrap();
let mem_per_cpu = contract.memory_mib / contract.vcpus; // this is needed cause TryFrom does not support await
let disk_per_cpu = contract.disk_size_mib / contract.vcpus;
self.vm_node = contract.vm_node; self.vm_node = contract.vm_node;
if !((self.vcpus != 0 && contract.vcpus != self.vcpus) if !((self.vcpus != 0 && contract.vcpus != self.vcpus)
|| (self.memory_mib != 0 && contract.memory_mib != self.memory_mib) || (self.memory_mb != 0 && contract.memory_mb != self.memory_mb)
|| (!self.dtrfs_sha.is_empty() && contract.dtrfs_sha != self.dtrfs_sha) || (!self.dtrfs_sha.is_empty() && contract.dtrfs_sha != self.dtrfs_sha)
|| (self.disk_size_mib != 0 && contract.disk_size_mib != self.disk_size_mib)) || (self.disk_size_gb != 0 && contract.disk_size_gb != self.disk_size_gb))
{ {
return Ok(Some(false)); return Ok(Some(false));
} }
// Do not allow user to unbalance node resources
if self.vcpus == 0 {
self.vcpus = self.memory_mib / mem_per_cpu;
}
if self.memory_mib == 0 {
self.memory_mib = self.vcpus * mem_per_cpu;
}
if self.vcpus == 0 {
self.vcpus = self.disk_size_mib / disk_per_cpu;
}
if self.disk_size_mib == 0 {
self.disk_size_mib = self.vcpus * disk_per_cpu;
}
let _: Vec<Self> = db.insert(UPDATE_VM_REQ).relation(self).await?; let _: Vec<Self> = db.insert(UPDATE_VM_REQ).relation(self).await?;
Ok(Some(true)) Ok(Some(true))
} }
@ -779,7 +764,6 @@ impl UpdateVmReq {
error: String, error: String,
} }
let _: Option<Self> = db.update((UPDATE_VM_REQ, id)).merge(UpdateVmError { error }).await?; let _: Option<Self> = db.update((UPDATE_VM_REQ, id)).merge(UpdateVmError { error }).await?;
let _: Option<Self> = db.delete((UPDATE_VM_REQ, id)).await?;
Ok(()) Ok(())
} }
} }
@ -795,9 +779,9 @@ pub struct DeletedVm {
pub mapped_ports: Vec<(u32, u32)>, pub mapped_ports: Vec<(u32, u32)>,
pub public_ipv4: String, pub public_ipv4: String,
pub public_ipv6: String, pub public_ipv6: String,
pub disk_size_mib: u32, pub disk_size_gb: u32,
pub vcpus: u32, pub vcpus: u32,
pub memory_mib: u32, pub memory_mb: u32,
pub dtrfs_sha: String, pub dtrfs_sha: String,
pub kernel_sha: String, pub kernel_sha: String,
pub created_at: Datetime, pub created_at: Datetime,
@ -815,9 +799,9 @@ impl From<ActiveVm> for DeletedVm {
mapped_ports: active_vm.mapped_ports, mapped_ports: active_vm.mapped_ports,
public_ipv4: active_vm.public_ipv4, public_ipv4: active_vm.public_ipv4,
public_ipv6: active_vm.public_ipv6, public_ipv6: active_vm.public_ipv6,
disk_size_mib: active_vm.disk_size_mib, disk_size_gb: active_vm.disk_size_gb,
vcpus: active_vm.vcpus, vcpus: active_vm.vcpus,
memory_mib: active_vm.memory_mib, memory_mb: active_vm.memory_mb,
dtrfs_sha: active_vm.dtrfs_sha, dtrfs_sha: active_vm.dtrfs_sha,
kernel_sha: active_vm.kernel_sha, kernel_sha: active_vm.kernel_sha,
created_at: active_vm.created_at, created_at: active_vm.created_at,
@ -878,8 +862,8 @@ impl DeletedVm {
// I tried, but this can be done better. // I tried, but this can be done better.
// Storage cost should also be based on tier // Storage cost should also be based on tier
(self.vcpus as u64 * 10) (self.vcpus as u64 * 10)
+ ((self.memory_mib + 256) as u64 / 200) + ((self.memory_mb + 256) as u64 / 200)
+ (self.disk_size_mib as u64 / 10) + (self.disk_size_gb as u64 / 10)
+ (!self.public_ipv4.is_empty() as u64 * 10) + (!self.public_ipv4.is_empty() as u64 * 10)
} }
@ -900,9 +884,9 @@ pub struct ActiveVmWithNode {
pub mapped_ports: Vec<(u32, u32)>, pub mapped_ports: Vec<(u32, u32)>,
pub public_ipv4: String, pub public_ipv4: String,
pub public_ipv6: String, pub public_ipv6: String,
pub disk_size_mib: u32, pub disk_size_gb: u32,
pub vcpus: u32, pub vcpus: u32,
pub memory_mib: u32, pub memory_mb: u32,
pub dtrfs_sha: String, pub dtrfs_sha: String,
pub kernel_sha: String, pub kernel_sha: String,
pub created_at: Datetime, pub created_at: Datetime,
@ -921,9 +905,9 @@ impl From<ActiveVmWithNode> for ActiveVm {
mapped_ports: val.mapped_ports, mapped_ports: val.mapped_ports,
public_ipv4: val.public_ipv4, public_ipv4: val.public_ipv4,
public_ipv6: val.public_ipv6, public_ipv6: val.public_ipv6,
disk_size_mib: val.disk_size_mib, disk_size_gb: val.disk_size_gb,
vcpus: val.vcpus, vcpus: val.vcpus,
memory_mib: val.memory_mib, memory_mb: val.memory_mb,
dtrfs_sha: val.dtrfs_sha, dtrfs_sha: val.dtrfs_sha,
kernel_sha: val.kernel_sha, kernel_sha: val.kernel_sha,
created_at: val.created_at, created_at: val.created_at,
@ -990,8 +974,8 @@ impl ActiveVmWithNode {
// I tried, but this can be done better. // I tried, but this can be done better.
// Storage cost should also be based on tier // Storage cost should also be based on tier
(self.vcpus as u64 * 10) (self.vcpus as u64 * 10)
+ ((self.memory_mib + 256) as u64 / 200) + ((self.memory_mb + 256) as u64 / 200)
+ (self.disk_size_mib as u64 / 1024 / 10) + (self.disk_size_gb as u64 / 10)
+ (!self.public_ipv4.is_empty() as u64 * 10) + (!self.public_ipv4.is_empty() as u64 * 10)
} }
@ -1021,9 +1005,9 @@ impl From<&old_brain::BrainData> for Vec<VmNode> {
region: old_node.region.clone(), region: old_node.region.clone(),
city: old_node.city.clone(), city: old_node.city.clone(),
ip: old_node.ip.clone(), ip: old_node.ip.clone(),
avail_mem_mib: old_node.avail_mem_mb, avail_mem_mb: old_node.avail_mem_mb,
avail_vcpus: old_node.avail_vcpus, avail_vcpus: old_node.avail_vcpus,
avail_storage_mib: old_node.avail_storage_gbs * 1024, avail_storage_gbs: old_node.avail_storage_gbs,
avail_ipv4: old_node.avail_ipv4, avail_ipv4: old_node.avail_ipv4,
avail_ipv6: old_node.avail_ipv6, avail_ipv6: old_node.avail_ipv6,
avail_ports: old_node.avail_ports, avail_ports: old_node.avail_ports,
@ -1053,9 +1037,9 @@ impl From<&old_brain::BrainData> for Vec<ActiveVm> {
mapped_ports, mapped_ports,
public_ipv4: old_c.public_ipv4.clone(), public_ipv4: old_c.public_ipv4.clone(),
public_ipv6: old_c.public_ipv6.clone(), public_ipv6: old_c.public_ipv6.clone(),
disk_size_mib: old_c.disk_size_gb * 1024, disk_size_gb: old_c.disk_size_gb,
vcpus: old_c.vcpus, vcpus: old_c.vcpus,
memory_mib: old_c.memory_mb, memory_mb: old_c.memory_mb,
dtrfs_sha: old_c.dtrfs_sha.clone(), dtrfs_sha: old_c.dtrfs_sha.clone(),
kernel_sha: old_c.kernel_sha.clone(), kernel_sha: old_c.kernel_sha.clone(),
price_per_unit: old_c.price_per_unit, price_per_unit: old_c.price_per_unit,

@ -12,7 +12,8 @@ use log::info;
use std::pin::Pin; use std::pin::Pin;
use std::sync::Arc; use std::sync::Arc;
use surrealdb::engine::remote::ws::Client; use surrealdb::engine::remote::ws::Client;
use surrealdb::{RecordId, Surreal}; use surrealdb::RecordId;
use surrealdb::Surreal;
use tokio::sync::mpsc; use tokio::sync::mpsc;
use tokio_stream::wrappers::ReceiverStream; use tokio_stream::wrappers::ReceiverStream;
use tokio_stream::{Stream, StreamExt}; use tokio_stream::{Stream, StreamExt};
@ -30,8 +31,8 @@ impl AppDaemonServer {
#[tonic::async_trait] #[tonic::async_trait]
impl BrainAppDaemon for AppDaemonServer { impl BrainAppDaemon for AppDaemonServer {
type BrainMessagesStream = Pin<Box<dyn Stream<Item = Result<BrainMessageApp, Status>> + Send>>;
type RegisterAppNodeStream = Pin<Box<dyn Stream<Item = Result<DelAppReq, Status>> + Send>>; type RegisterAppNodeStream = Pin<Box<dyn Stream<Item = Result<DelAppReq, Status>> + Send>>;
type BrainMessagesStream = Pin<Box<dyn Stream<Item = Result<BrainMessageApp, Status>> + Send>>;
async fn register_app_node( async fn register_app_node(
&self, &self,
@ -51,13 +52,12 @@ impl BrainAppDaemon for AppDaemonServer {
ip: req.main_ip, ip: req.main_ip,
price: req.price, price: req.price,
avail_mem_mib: 0, avail_mem_mb: 0,
avail_vcpus: 0, avail_vcpus: 0,
avail_storage_mib: 0, avail_storage_gbs: 0,
avail_ports: 0, avail_ports: 0,
max_ports_per_app: 0, max_ports_per_app: 0,
disconnected_at: surrealdb::sql::Datetime::default(), offline_minutes: 0,
connected_at: surrealdb::sql::Datetime::default(),
}; };
app_node.register(&self.db).await?; app_node.register(&self.db).await?;
@ -89,7 +89,6 @@ impl BrainAppDaemon for AppDaemonServer {
)?; )?;
info!("App Daemon {} connected to receive brain messages", pubkey); info!("App Daemon {} connected to receive brain messages", pubkey);
let _ = db::AppNode::set_online(&self.db, &pubkey).await;
let (tx, rx) = mpsc::channel(6); let (tx, rx) = mpsc::channel(6);
{ {
@ -163,8 +162,7 @@ impl BrainAppDaemon for AppDaemonServer {
}, },
Err(e) => { Err(e) => {
log::warn!("App Daemon Disconnected: {e:?}"); log::warn!("App Daemon Disconnected: {e:?}")
let _ = db::AppNode::set_offline(&self.db, &pubkey).await;
} }
} }
} }

@ -115,7 +115,7 @@ impl BrainGeneralCli for GeneralCliServer {
log::info!("Regitering new operator: {req:?}"); log::info!("Regitering new operator: {req:?}");
match db::Account::operator_reg(&self.db, &req.pubkey, &req.email, req.escrow).await { match db::Account::operator_reg(&self.db, &req.pubkey, &req.email, req.escrow).await {
Ok(()) => Ok(Response::new(Empty {})), Ok(()) => Ok(Response::new(Empty {})),
Err(e) if matches!(e, db::Error::InsufficientFunds) => { Err(e) if matches!(e, db::Error::InsufficientFunds | db::Error::MinimalEscrow) => {
Err(Status::failed_precondition(e.to_string())) Err(Status::failed_precondition(e.to_string()))
} }
Err(e) => { Err(e) => {
@ -133,7 +133,7 @@ impl BrainGeneralCli for GeneralCliServer {
match db::kick_contract(&self.db, &req.operator_wallet, &req.contract_uuid, &req.reason) match db::kick_contract(&self.db, &req.operator_wallet, &req.contract_uuid, &req.reason)
.await .await
{ {
Ok(nano_credits) => Ok(Response::new(KickResp { nano_credits })), Ok(nano_lp) => Ok(Response::new(KickResp { nano_lp })),
Err(e) Err(e)
if matches!( if matches!(
e, e,

@ -2,10 +2,10 @@
use crate::constants::{ACCOUNT, APP_NODE, ID_ALPHABET, NEW_APP_REQ, NEW_VM_REQ, VM_NODE}; use crate::constants::{ACCOUNT, APP_NODE, ID_ALPHABET, NEW_APP_REQ, NEW_VM_REQ, VM_NODE};
use crate::db::prelude as db; use crate::db::prelude as db;
use detee_shared::app_proto::*; use detee_shared::app_proto::AppNodeListResp;
use detee_shared::common_proto::MappedPort; use detee_shared::common_proto::MappedPort;
use detee_shared::general_proto::{Account, AccountBalance, ListOperatorsResp}; use detee_shared::general_proto::{Account, AccountBalance, ListOperatorsResp};
use detee_shared::vm_proto::*; use detee_shared::{app_proto::*, vm_proto::*};
use nanoid::nanoid; use nanoid::nanoid;
use surrealdb::RecordId; use surrealdb::RecordId;
@ -36,9 +36,9 @@ impl From<NewVmReq> for db::NewVmReq {
extra_ports: new_vm_req.extra_ports, extra_ports: new_vm_req.extra_ports,
public_ipv4: new_vm_req.public_ipv4, public_ipv4: new_vm_req.public_ipv4,
public_ipv6: new_vm_req.public_ipv6, public_ipv6: new_vm_req.public_ipv6,
disk_size_mib: new_vm_req.disk_size_mib, disk_size_gb: new_vm_req.disk_size_gb,
vcpus: new_vm_req.vcpus, vcpus: new_vm_req.vcpus,
memory_mib: new_vm_req.memory_mib, memory_mb: new_vm_req.memory_mb,
kernel_url: new_vm_req.kernel_url, kernel_url: new_vm_req.kernel_url,
kernel_sha: new_vm_req.kernel_sha, kernel_sha: new_vm_req.kernel_sha,
dtrfs_url: new_vm_req.dtrfs_url, dtrfs_url: new_vm_req.dtrfs_url,
@ -61,9 +61,9 @@ impl From<db::NewVmReq> for NewVmReq {
extra_ports: new_vm_req.extra_ports, extra_ports: new_vm_req.extra_ports,
public_ipv4: new_vm_req.public_ipv4, public_ipv4: new_vm_req.public_ipv4,
public_ipv6: new_vm_req.public_ipv6, public_ipv6: new_vm_req.public_ipv6,
disk_size_mib: new_vm_req.disk_size_mib, disk_size_gb: new_vm_req.disk_size_gb,
vcpus: new_vm_req.vcpus, vcpus: new_vm_req.vcpus,
memory_mib: new_vm_req.memory_mib, memory_mb: new_vm_req.memory_mb,
kernel_url: new_vm_req.kernel_url, kernel_url: new_vm_req.kernel_url,
kernel_sha: new_vm_req.kernel_sha, kernel_sha: new_vm_req.kernel_sha,
dtrfs_url: new_vm_req.dtrfs_url, dtrfs_url: new_vm_req.dtrfs_url,
@ -104,9 +104,9 @@ impl From<UpdateVmReq> for db::UpdateVmReq {
admin: RecordId::from((ACCOUNT, new_vm_req.admin_pubkey)), admin: RecordId::from((ACCOUNT, new_vm_req.admin_pubkey)),
// vm_node gets modified later, and only if the db::UpdateVmReq is required // vm_node gets modified later, and only if the db::UpdateVmReq is required
vm_node: RecordId::from((VM_NODE, String::new())), vm_node: RecordId::from((VM_NODE, String::new())),
disk_size_mib: new_vm_req.disk_size_mib, disk_size_gb: new_vm_req.disk_size_gb,
vcpus: new_vm_req.vcpus, vcpus: new_vm_req.vcpus,
memory_mib: new_vm_req.memory_mib, memory_mb: new_vm_req.memory_mb,
kernel_url: new_vm_req.kernel_url, kernel_url: new_vm_req.kernel_url,
kernel_sha: new_vm_req.kernel_sha, kernel_sha: new_vm_req.kernel_sha,
dtrfs_url: new_vm_req.dtrfs_url, dtrfs_url: new_vm_req.dtrfs_url,
@ -124,9 +124,9 @@ impl From<db::UpdateVmReq> for UpdateVmReq {
// daemon does not care about VM hostname // daemon does not care about VM hostname
hostname: String::new(), hostname: String::new(),
admin_pubkey: update_vm_req.admin.key().to_string(), admin_pubkey: update_vm_req.admin.key().to_string(),
disk_size_mib: update_vm_req.disk_size_mib, disk_size_gb: update_vm_req.disk_size_gb,
vcpus: update_vm_req.vcpus, vcpus: update_vm_req.vcpus,
memory_mib: update_vm_req.memory_mib, memory_mb: update_vm_req.memory_mb,
kernel_url: update_vm_req.kernel_url, kernel_url: update_vm_req.kernel_url,
kernel_sha: update_vm_req.kernel_sha, kernel_sha: update_vm_req.kernel_sha,
dtrfs_url: update_vm_req.dtrfs_url, dtrfs_url: update_vm_req.dtrfs_url,
@ -176,9 +176,9 @@ impl From<db::ActiveVmWithNode> for VmContract {
"{}, {}, {}", "{}, {}, {}",
db_c.vm_node.city, db_c.vm_node.region, db_c.vm_node.country db_c.vm_node.city, db_c.vm_node.region, db_c.vm_node.country
), ),
memory_mb: db_c.memory_mib, memory_mb: db_c.memory_mb,
vcpus: db_c.vcpus, vcpus: db_c.vcpus,
disk_size_gb: db_c.disk_size_mib, disk_size_gb: db_c.disk_size_gb,
mapped_ports: db_c mapped_ports: db_c
.mapped_ports .mapped_ports
.iter() .iter()
@ -230,11 +230,6 @@ impl From<db::VmNodeWithReports> for VmNodeListResp {
ip: vm_node.ip, ip: vm_node.ip,
reports: vm_node.reports.iter().map(|n| n.reason.clone()).collect(), reports: vm_node.reports.iter().map(|n| n.reason.clone()).collect(),
price: vm_node.price, price: vm_node.price,
vcpus: vm_node.avail_vcpus,
memory_mib: vm_node.avail_mem_mib,
disk_mib: vm_node.avail_storage_mib,
public_ipv4: vm_node.avail_ipv4 > 0,
public_ipv6: vm_node.avail_ipv6 > 0,
} }
} }
} }
@ -250,10 +245,6 @@ impl From<db::AppNodeWithReports> for AppNodeListResp {
ip: app_node.ip, ip: app_node.ip,
reports: app_node.reports.iter().map(|n| n.reason.clone()).collect(), reports: app_node.reports.iter().map(|n| n.reason.clone()).collect(),
price: app_node.price, price: app_node.price,
vcpus: app_node.avail_vcpus as u64,
memory_mib: app_node.avail_mem_mib as u64,
disk_mib: app_node.avail_storage_mib as u64,
} }
} }
} }
@ -261,9 +252,9 @@ impl From<db::AppNodeWithReports> for AppNodeListResp {
impl From<VmNodeResources> for db::VmNodeResources { impl From<VmNodeResources> for db::VmNodeResources {
fn from(res: VmNodeResources) -> Self { fn from(res: VmNodeResources) -> Self {
Self { Self {
avail_mem_mib: res.avail_memory_mib, avail_mem_mb: res.avail_memory_mb,
avail_vcpus: res.avail_vcpus, avail_vcpus: res.avail_vcpus,
avail_storage_mib: res.avail_storage_mib, avail_storage_gbs: res.avail_storage_gb,
avail_ipv4: res.avail_ipv4, avail_ipv4: res.avail_ipv4,
avail_ipv6: res.avail_ipv6, avail_ipv6: res.avail_ipv6,
avail_ports: res.avail_ports, avail_ports: res.avail_ports,
@ -274,7 +265,6 @@ impl From<VmNodeResources> for db::VmNodeResources {
impl From<db::ActiveAppWithNode> for AppContract { impl From<db::ActiveAppWithNode> for AppContract {
fn from(value: db::ActiveAppWithNode) -> Self { fn from(value: db::ActiveAppWithNode) -> Self {
let nano_per_minute = value.price_per_minute();
let public_package_mr_enclave = let public_package_mr_enclave =
Some(hex::decode(value.mr_enclave.clone()).unwrap_or_default()); Some(hex::decode(value.mr_enclave.clone()).unwrap_or_default());
@ -285,8 +275,8 @@ impl From<db::ActiveAppWithNode> for AppContract {
node_pubkey: value.app_node.id.key().to_string(), node_pubkey: value.app_node.id.key().to_string(),
public_ipv4: value.host_ipv4, public_ipv4: value.host_ipv4,
resource: Some(AppResource { resource: Some(AppResource {
memory_mib: value.memory_mib, memory_mb: value.memory_mb,
disk_size_mib: value.disk_size_mib, disk_size_gb: value.disk_size_gb,
vcpus: value.vcpus, vcpus: value.vcpus,
ports: value.mapped_ports.iter().map(|(_, g)| *g).collect(), ports: value.mapped_ports.iter().map(|(_, g)| *g).collect(),
}), }),
@ -298,7 +288,7 @@ impl From<db::ActiveAppWithNode> for AppContract {
created_at: value.created_at.to_rfc3339(), created_at: value.created_at.to_rfc3339(),
updated_at: value.created_at.to_rfc3339(), updated_at: value.created_at.to_rfc3339(),
nano_per_minute, nano_per_minute: value.price_per_unit,
locked_nano: value.locked_nano, locked_nano: value.locked_nano,
collected_at: value.collected_at.to_rfc3339(), collected_at: value.collected_at.to_rfc3339(),
hratls_pubkey: value.hratls_pubkey, hratls_pubkey: value.hratls_pubkey,
@ -327,9 +317,9 @@ impl From<NewAppReq> for db::NewAppReq {
mr_enclave, mr_enclave,
hratls_pubkey: val.hratls_pubkey, hratls_pubkey: val.hratls_pubkey,
ports: resource.ports, ports: resource.ports,
memory_mib: resource.memory_mib, memory_mb: resource.memory_mb,
vcpus: resource.vcpus, vcpus: resource.vcpus,
disk_size_mib: resource.disk_size_mib, disk_size_gb: resource.disk_size_gb,
locked_nano: val.locked_nano, locked_nano: val.locked_nano,
price_per_unit: val.price_per_unit, price_per_unit: val.price_per_unit,
error: String::new(), error: String::new(),
@ -342,8 +332,8 @@ impl From<db::NewAppReq> for NewAppReq {
fn from(value: db::NewAppReq) -> Self { fn from(value: db::NewAppReq) -> Self {
let resource = AppResource { let resource = AppResource {
vcpus: value.vcpus, vcpus: value.vcpus,
memory_mib: value.memory_mib, memory_mb: value.memory_mb,
disk_size_mib: value.disk_size_mib, disk_size_gb: value.disk_size_gb,
ports: value.ports, ports: value.ports,
}; };
let mr_enclave = Some(hex::decode(value.mr_enclave).unwrap_or_default()); let mr_enclave = Some(hex::decode(value.mr_enclave).unwrap_or_default());
@ -387,8 +377,8 @@ impl From<AppNodeResources> for db::AppNodeResources {
Self { Self {
avail_ports: value.avail_no_of_port, avail_ports: value.avail_no_of_port,
avail_vcpus: value.avail_vcpus, avail_vcpus: value.avail_vcpus,
avail_mem_mib: value.avail_memory_mib, avail_mem_mb: value.avail_memory_mb,
avail_storage_mib: value.avail_storage_mib, avail_storage_gbs: value.avail_storage_gb,
max_ports_per_app: value.max_ports_per_app, max_ports_per_app: value.max_ports_per_app,
} }
} }

@ -51,9 +51,9 @@ impl BrainVmDaemon for VmDaemonServer {
city: req.city, city: req.city,
ip: req.main_ip, ip: req.main_ip,
price: req.price, price: req.price,
avail_mem_mib: 0, avail_mem_mb: 0,
avail_vcpus: 0, avail_vcpus: 0,
avail_storage_mib: 0, avail_storage_gbs: 0,
avail_ipv4: 0, avail_ipv4: 0,
avail_ipv6: 0, avail_ipv6: 0,
avail_ports: 0, avail_ports: 0,
@ -273,17 +273,10 @@ impl BrainVmCli for VmCliServer {
let db_req: db::UpdateVmReq = req.clone().into(); let db_req: db::UpdateVmReq = req.clone().into();
println!("The node is {}", db_req.vm_node); if let Some(redirect) = db::check_pubsub_node(&self.db, db_req.vm_node.clone()).await? {
log::info!("redirect: {redirect}");
// TODO: vm_node is not known at this point. It is populated by `request_hw_update`. return Err(redirect);
// As such, the pubsub node cannot be checked at this stage. This code should be moved, }
// however we are not working on the redirect mechanic at the moment
//
// if let Some(redirect) = db::check_pubsub_node(&self.db, db_req.vm_node.clone()).await? {
// log::info!("redirect: {redirect}");
// return Err(redirect);
// }
let id = db_req.id.key().to_string(); let id = db_req.id.key().to_string();
let mut hostname_changed = false; let mut hostname_changed = false;

@ -6,7 +6,7 @@ DEFINE FUNCTION OVERWRITE fn::vm_price_per_minute(
LET $vm = (select * from $vm_id)[0]; LET $vm = (select * from $vm_id)[0];
LET $ip_price = IF $vm.public_ipv4.len() > 0 { 10 } ELSE { 0 }; LET $ip_price = IF $vm.public_ipv4.len() > 0 { 10 } ELSE { 0 };
RETURN ( RETURN (
($vm.vcpus * 10) + (($vm.memory_mib + 256) / 200) + ($vm.disk_size_mib / 1024 / 10) + $ip_price) ($vm.vcpus * 10) + (($vm.memory_mb + 256) / 200) + ($vm.disk_size_gb / 10) + $ip_price)
* $vm.price_per_unit; * $vm.price_per_unit;
}; };
@ -33,8 +33,8 @@ DEFINE FUNCTION OVERWRITE fn::app_price_per_minute(
LET $app = (select * from $app_id)[0]; LET $app = (select * from $app_id)[0];
RETURN RETURN
(($app.vcpus * 5) + (($app.vcpus * 5) +
($app.memory_mib / 200) + ($app.memory_mb / 200) +
($app.disk_size_mib / 10)) ($app.disk_size_gb / 10))
* $app.price_per_unit; * $app.price_per_unit;
}; };
@ -53,4 +53,4 @@ DEFINE FUNCTION OVERWRITE fn::delete_app(
}; };
INSERT RELATION INTO deleted_app ( $deleted_app ); INSERT RELATION INTO deleted_app ( $deleted_app );
RETURN DELETE $app.id RETURN BEFORE; RETURN DELETE $app.id RETURN BEFORE;
}; };

@ -13,9 +13,9 @@ DEFINE FIELD country ON TABLE vm_node TYPE string;
DEFINE FIELD region ON TABLE vm_node TYPE string; DEFINE FIELD region ON TABLE vm_node TYPE string;
DEFINE FIELD city ON TABLE vm_node TYPE string; DEFINE FIELD city ON TABLE vm_node TYPE string;
DEFINE FIELD ip ON TABLE vm_node TYPE string; DEFINE FIELD ip ON TABLE vm_node TYPE string;
DEFINE FIELD avail_mem_mib ON TABLE vm_node TYPE int; DEFINE FIELD avail_mem_mb ON TABLE vm_node TYPE int;
DEFINE FIELD avail_vcpus ON TABLE vm_node TYPE int; DEFINE FIELD avail_vcpus ON TABLE vm_node TYPE int;
DEFINE FIELD avail_storage_mib ON TABLE vm_node TYPE int; DEFINE FIELD avail_storage_gbs ON TABLE vm_node TYPE int;
DEFINE FIELD avail_ipv4 ON TABLE vm_node TYPE int; DEFINE FIELD avail_ipv4 ON TABLE vm_node TYPE int;
DEFINE FIELD avail_ipv6 ON TABLE vm_node TYPE int; DEFINE FIELD avail_ipv6 ON TABLE vm_node TYPE int;
DEFINE FIELD avail_ports ON TABLE vm_node TYPE int; DEFINE FIELD avail_ports ON TABLE vm_node TYPE int;
@ -29,9 +29,9 @@ DEFINE FIELD hostname ON TABLE new_vm_req TYPE string;
DEFINE FIELD extra_ports ON TABLE new_vm_req TYPE array<int>; DEFINE FIELD extra_ports ON TABLE new_vm_req TYPE array<int>;
DEFINE FIELD public_ipv4 ON TABLE new_vm_req TYPE bool; DEFINE FIELD public_ipv4 ON TABLE new_vm_req TYPE bool;
DEFINE FIELD public_ipv6 ON TABLE new_vm_req TYPE bool; DEFINE FIELD public_ipv6 ON TABLE new_vm_req TYPE bool;
DEFINE FIELD disk_size_mib ON TABLE new_vm_req TYPE int; DEFINE FIELD disk_size_gb ON TABLE new_vm_req TYPE int;
DEFINE FIELD vcpus ON TABLE new_vm_req TYPE int; DEFINE FIELD vcpus ON TABLE new_vm_req TYPE int;
DEFINE FIELD memory_mib ON TABLE new_vm_req TYPE int; DEFINE FIELD memory_mb ON TABLE new_vm_req TYPE int;
DEFINE FIELD dtrfs_sha ON TABLE new_vm_req TYPE string; DEFINE FIELD dtrfs_sha ON TABLE new_vm_req TYPE string;
DEFINE FIELD dtrfs_url ON TABLE new_vm_req TYPE string; DEFINE FIELD dtrfs_url ON TABLE new_vm_req TYPE string;
DEFINE FIELD kernel_sha ON TABLE new_vm_req TYPE string; DEFINE FIELD kernel_sha ON TABLE new_vm_req TYPE string;
@ -46,9 +46,9 @@ DEFINE FIELD hostname ON TABLE active_vm TYPE string;
DEFINE FIELD mapped_ports ON TABLE active_vm TYPE array<[int, int]>; DEFINE FIELD mapped_ports ON TABLE active_vm TYPE array<[int, int]>;
DEFINE FIELD public_ipv4 ON TABLE active_vm TYPE string; DEFINE FIELD public_ipv4 ON TABLE active_vm TYPE string;
DEFINE FIELD public_ipv6 ON TABLE active_vm TYPE string; DEFINE FIELD public_ipv6 ON TABLE active_vm TYPE string;
DEFINE FIELD disk_size_mib ON TABLE active_vm TYPE int; DEFINE FIELD disk_size_gb ON TABLE active_vm TYPE int;
DEFINE FIELD vcpus ON TABLE active_vm TYPE int; DEFINE FIELD vcpus ON TABLE active_vm TYPE int;
DEFINE FIELD memory_mib ON TABLE active_vm TYPE int; DEFINE FIELD memory_mb ON TABLE active_vm TYPE int;
DEFINE FIELD dtrfs_sha ON TABLE active_vm TYPE string; DEFINE FIELD dtrfs_sha ON TABLE active_vm TYPE string;
DEFINE FIELD kernel_sha ON TABLE active_vm TYPE string; DEFINE FIELD kernel_sha ON TABLE active_vm TYPE string;
DEFINE FIELD created_at ON TABLE active_vm TYPE datetime; DEFINE FIELD created_at ON TABLE active_vm TYPE datetime;
@ -58,8 +58,8 @@ DEFINE FIELD collected_at ON TABLE active_vm TYPE datetime;
DEFINE TABLE update_vm_req TYPE RELATION FROM account TO vm_node SCHEMAFULL; DEFINE TABLE update_vm_req TYPE RELATION FROM account TO vm_node SCHEMAFULL;
DEFINE FIELD vcpus ON TABLE update_vm_req TYPE int; DEFINE FIELD vcpus ON TABLE update_vm_req TYPE int;
DEFINE FIELD memory_mib ON TABLE update_vm_req TYPE int; DEFINE FIELD memory_mb ON TABLE update_vm_req TYPE int;
DEFINE FIELD disk_size_mib ON TABLE update_vm_req TYPE int; DEFINE FIELD disk_size_gb ON TABLE update_vm_req TYPE int;
DEFINE FIELD dtrfs_sha ON TABLE update_vm_req TYPE string; DEFINE FIELD dtrfs_sha ON TABLE update_vm_req TYPE string;
DEFINE FIELD dtrfs_url ON TABLE update_vm_req TYPE string; DEFINE FIELD dtrfs_url ON TABLE update_vm_req TYPE string;
DEFINE FIELD kernel_sha ON TABLE update_vm_req TYPE string; DEFINE FIELD kernel_sha ON TABLE update_vm_req TYPE string;
@ -72,9 +72,9 @@ DEFINE FIELD hostname ON TABLE deleted_vm TYPE string;
DEFINE FIELD mapped_ports ON TABLE deleted_vm TYPE array<[int, int]>; DEFINE FIELD mapped_ports ON TABLE deleted_vm TYPE array<[int, int]>;
DEFINE FIELD public_ipv4 ON TABLE deleted_vm TYPE string; DEFINE FIELD public_ipv4 ON TABLE deleted_vm TYPE string;
DEFINE FIELD public_ipv6 ON TABLE deleted_vm TYPE string; DEFINE FIELD public_ipv6 ON TABLE deleted_vm TYPE string;
DEFINE FIELD disk_size_mib ON TABLE deleted_vm TYPE int; DEFINE FIELD disk_size_gb ON TABLE deleted_vm TYPE int;
DEFINE FIELD vcpus ON TABLE deleted_vm TYPE int; DEFINE FIELD vcpus ON TABLE deleted_vm TYPE int;
DEFINE FIELD memory_mib ON TABLE deleted_vm TYPE int; DEFINE FIELD memory_mb ON TABLE deleted_vm TYPE int;
DEFINE FIELD dtrfs_sha ON TABLE deleted_vm TYPE string; DEFINE FIELD dtrfs_sha ON TABLE deleted_vm TYPE string;
DEFINE FIELD kernel_sha ON TABLE deleted_vm TYPE string; DEFINE FIELD kernel_sha ON TABLE deleted_vm TYPE string;
DEFINE FIELD created_at ON TABLE deleted_vm TYPE datetime; DEFINE FIELD created_at ON TABLE deleted_vm TYPE datetime;
@ -88,14 +88,13 @@ DEFINE FIELD country ON TABLE app_node TYPE string;
DEFINE FIELD region ON TABLE app_node TYPE string; DEFINE FIELD region ON TABLE app_node TYPE string;
DEFINE FIELD city ON TABLE app_node TYPE string; DEFINE FIELD city ON TABLE app_node TYPE string;
DEFINE FIELD ip ON TABLE app_node TYPE string; DEFINE FIELD ip ON TABLE app_node TYPE string;
DEFINE FIELD avail_mem_mib ON TABLE app_node TYPE int; DEFINE FIELD avail_mem_mb ON TABLE app_node TYPE int;
DEFINE FIELD avail_vcpus ON TABLE app_node TYPE int; DEFINE FIELD avail_vcpus ON TABLE app_node TYPE int;
DEFINE FIELD avail_storage_mib ON TABLE app_node TYPE int; DEFINE FIELD avail_storage_gbs ON TABLE app_node TYPE int;
DEFINE FIELD avail_ports ON TABLE app_node TYPE int; DEFINE FIELD avail_ports ON TABLE app_node TYPE int;
DEFINE FIELD max_ports_per_app ON TABLE app_node TYPE int; DEFINE FIELD max_ports_per_app ON TABLE app_node TYPE int;
DEFINE FIELD price ON TABLE app_node TYPE int; DEFINE FIELD price ON TABLE app_node TYPE int;
DEFINE FIELD connected_at ON TABLE app_node TYPE datetime; DEFINE FIELD offline_minutes ON TABLE app_node TYPE int;
DEFINE FIELD disconnected_at ON TABLE app_node TYPE datetime;
DEFINE TABLE new_app_req Type RELATION FROM account to app_node SCHEMAFULL; DEFINE TABLE new_app_req Type RELATION FROM account to app_node SCHEMAFULL;
DEFINE FIELD app_name ON TABLE new_app_req TYPE string; DEFINE FIELD app_name ON TABLE new_app_req TYPE string;
@ -103,9 +102,9 @@ DEFINE FIELD package_url ON TABLE new_app_req TYPE string;
DEFINE FIELD mr_enclave ON TABLE new_app_req TYPE string; DEFINE FIELD mr_enclave ON TABLE new_app_req TYPE string;
DEFINE FIELD hratls_pubkey ON TABLE new_app_req TYPE string; DEFINE FIELD hratls_pubkey ON TABLE new_app_req TYPE string;
DEFINE FIELD ports ON TABLE new_app_req TYPE array<int>; DEFINE FIELD ports ON TABLE new_app_req TYPE array<int>;
DEFINE FIELD memory_mib ON TABLE new_app_req TYPE int; DEFINE FIELD memory_mb ON TABLE new_app_req TYPE int;
DEFINE FIELD vcpus ON TABLE new_app_req TYPE int; DEFINE FIELD vcpus ON TABLE new_app_req TYPE int;
DEFINE FIELD disk_size_mib ON TABLE new_app_req TYPE int; DEFINE FIELD disk_size_gb ON TABLE new_app_req TYPE int;
DEFINE FIELD locked_nano ON TABLE new_app_req TYPE int; DEFINE FIELD locked_nano ON TABLE new_app_req TYPE int;
DEFINE FIELD price_per_unit ON TABLE new_app_req TYPE int; DEFINE FIELD price_per_unit ON TABLE new_app_req TYPE int;
DEFINE FIELD error ON TABLE new_app_req TYPE string; DEFINE FIELD error ON TABLE new_app_req TYPE string;
@ -116,8 +115,8 @@ DEFINE FIELD app_name ON TABLE active_app TYPE string;
DEFINE FIELD mapped_ports ON TABLE active_app TYPE array<[int, int]>; DEFINE FIELD mapped_ports ON TABLE active_app TYPE array<[int, int]>;
DEFINE FIELD host_ipv4 ON TABLE active_app TYPE string; DEFINE FIELD host_ipv4 ON TABLE active_app TYPE string;
DEFINE FIELD vcpus ON TABLE active_app TYPE int; DEFINE FIELD vcpus ON TABLE active_app TYPE int;
DEFINE FIELD memory_mib ON TABLE active_app TYPE int; DEFINE FIELD memory_mb ON TABLE active_app TYPE int;
DEFINE FIELD disk_size_mib ON TABLE active_app TYPE int; DEFINE FIELD disk_size_gb ON TABLE active_app TYPE int;
DEFINE FIELD created_at ON TABLE active_app TYPE datetime; DEFINE FIELD created_at ON TABLE active_app TYPE datetime;
DEFINE FIELD price_per_unit ON TABLE active_app TYPE int; DEFINE FIELD price_per_unit ON TABLE active_app TYPE int;
DEFINE FIELD locked_nano ON TABLE active_app TYPE int; DEFINE FIELD locked_nano ON TABLE active_app TYPE int;
@ -131,8 +130,8 @@ DEFINE FIELD app_name ON TABLE deleted_app TYPE string;
DEFINE FIELD mapped_ports ON TABLE deleted_app TYPE array<[int, int]>; DEFINE FIELD mapped_ports ON TABLE deleted_app TYPE array<[int, int]>;
DEFINE FIELD host_ipv4 ON TABLE deleted_app TYPE string; DEFINE FIELD host_ipv4 ON TABLE deleted_app TYPE string;
DEFINE FIELD vcpus ON TABLE deleted_app TYPE int; DEFINE FIELD vcpus ON TABLE deleted_app TYPE int;
DEFINE FIELD memory_mib ON TABLE deleted_app TYPE int; DEFINE FIELD memory_mb ON TABLE deleted_app TYPE int;
DEFINE FIELD disk_size_mib ON TABLE deleted_app TYPE int; DEFINE FIELD disk_size_gb ON TABLE deleted_app TYPE int;
DEFINE FIELD created_at ON TABLE deleted_app TYPE datetime; DEFINE FIELD created_at ON TABLE deleted_app TYPE datetime;
DEFINE FIELD deleted_at ON TABLE deleted_app TYPE datetime DEFAULT time::now(); DEFINE FIELD deleted_at ON TABLE deleted_app TYPE datetime DEFAULT time::now();
DEFINE FIELD price_per_unit ON TABLE deleted_app TYPE int; DEFINE FIELD price_per_unit ON TABLE deleted_app TYPE int;

@ -10,8 +10,9 @@ FOR $contract IN (select * from active_vm fetch out) {
} ELSE { } ELSE {
$amount_due $amount_due
}; };
LET $escrow_multiplier = IF $operator.escrow < 5_000_000_000_000 { 1 } ELSE { 5 };
IF $node_is_online { IF $node_is_online {
UPDATE $operator.id SET balance += $amount_paid; UPDATE $operator.id SET balance += $amount_paid * $escrow_multiplier;
UPDATE $contract.id SET UPDATE $contract.id SET
locked_nano -= $amount_paid, locked_nano -= $amount_paid,
collected_at = time::now(); collected_at = time::now();
@ -22,41 +23,11 @@ FOR $contract IN (select * from active_vm fetch out) {
$amount_due $amount_due
}; };
UPDATE $operator.id SET escrow -= $compensation; UPDATE $operator.id SET escrow -= $compensation;
UPDATE $contract.id SET UPDATE $contract.in SET balance += $compensation;
locked_nano += $compensation,
collected_at = time::now();
}; };
IF $amount_paid >= $contract.locked_nano { IF $amount_paid >= $contract.locked_nano {
fn::delete_vm($contract.id); fn::delete_vm($contract.id);
}; };
}; };
FOR $app_contract IN (select * from active_app fetch out) { -- TODO: implement for active_app
LET $operator = (select * from $app_contract.out.operator)[0];
LET $node_is_online = $app_contract.out.connected_at > $app_contract.out.disconnected_at;
LET $price_per_minute = fn::app_price_per_minute($app_contract.id);
LET $amount_due = (time::now() - $app_contract.collected_at).mins() * $price_per_minute;
LET $amount_paid = IF $amount_due > $app_contract.locked_nano {
$app_contract.locked_nano
} ELSE {
$amount_due
};
LET $escrow_multiplier = IF $operator.escrow < 5_000_000_000_000 { 1 } ELSE { 5 };
IF $node_is_online {
UPDATE $operator.id SET balance += $amount_paid * $escrow_multiplier;
UPDATE $app_contract.id SET
locked_nano -= $amount_paid,
collected_at = time::now();
} ELSE {
LET $compensation = IF $amount_due > $operator.escrow {
$operator.escrow
} ELSE {
$amount_due
};
UPDATE $operator.id SET escrow -= $compensation;
UPDATE $app_contract.in SET balance += $compensation;
};
IF $amount_paid >= $app_contract.locked_nano {
fn::delete_app($app_contract.id);
}
}

@ -1,8 +1,9 @@
// SPDX-License-Identifier: Apache-2.0 // SPDX-License-Identifier: Apache-2.0
use anyhow::Result; use anyhow::Result;
use detee_shared::app_proto::brain_app_cli_client::BrainAppCliClient; use detee_shared::app_proto::{
use detee_shared::app_proto::{AppResource, NewAppReq, NewAppRes}; brain_app_cli_client::BrainAppCliClient, AppResource, NewAppReq, NewAppRes,
};
use tonic::transport::Channel; use tonic::transport::Channel;
use crate::common::test_utils::Key; use crate::common::test_utils::Key;

@ -1,9 +1,10 @@
// SPDX-License-Identifier: Apache-2.0 // SPDX-License-Identifier: Apache-2.0
use anyhow::Result; use anyhow::Result;
use detee_shared::app_proto as sgx_proto;
use detee_shared::general_proto::brain_general_cli_client::BrainGeneralCliClient; use detee_shared::general_proto::brain_general_cli_client::BrainGeneralCliClient;
use detee_shared::general_proto::AirdropReq; use detee_shared::general_proto::AirdropReq;
use detee_shared::{app_proto, vm_proto}; use detee_shared::vm_proto as snp_proto;
use ed25519_dalek::{Signer, SigningKey}; use ed25519_dalek::{Signer, SigningKey};
use itertools::Itertools; use itertools::Itertools;
use rand::Rng; use rand::Rng;
@ -74,20 +75,20 @@ impl Key {
pub fn sign_stream_auth_vm( pub fn sign_stream_auth_vm(
&self, &self,
contracts: Vec<String>, contracts: Vec<String>,
) -> Result<vm_proto::DaemonStreamAuth> { ) -> Result<snp_proto::DaemonStreamAuth> {
let pubkey = self.pubkey.clone(); let pubkey = self.pubkey.clone();
let timestamp = chrono::Utc::now().to_rfc3339(); let timestamp = chrono::Utc::now().to_rfc3339();
let signature = let signature =
self.try_sign_message(&(timestamp.to_string() + &format!("{contracts:?}")))?; self.try_sign_message(&(timestamp.to_string() + &format!("{contracts:?}")))?;
Ok(vm_proto::DaemonStreamAuth { timestamp, pubkey, contracts, signature }) Ok(snp_proto::DaemonStreamAuth { timestamp, pubkey, contracts, signature })
} }
pub fn sign_stream_auth_app(&self, contracts: Vec<String>) -> Result<app_proto::DaemonAuth> { pub fn sign_stream_auth_app(&self, contracts: Vec<String>) -> Result<sgx_proto::DaemonAuth> {
let pubkey = self.pubkey.clone(); let pubkey = self.pubkey.clone();
let timestamp = chrono::Utc::now().to_rfc3339(); let timestamp = chrono::Utc::now().to_rfc3339();
let signature = let signature =
self.try_sign_message(&(timestamp.to_string() + &format!("{contracts:?}")))?; self.try_sign_message(&(timestamp.to_string() + &format!("{contracts:?}")))?;
Ok(app_proto::DaemonAuth { timestamp, pubkey, contracts, signature }) Ok(sgx_proto::DaemonAuth { timestamp, pubkey, contracts, signature })
} }
} }

@ -2,11 +2,12 @@
use super::test_utils::Key; use super::test_utils::Key;
use anyhow::{anyhow, Result}; use anyhow::{anyhow, Result};
use detee_shared::app_proto;
use detee_shared::common_proto::Empty; use detee_shared::common_proto::Empty;
use detee_shared::general_proto::brain_general_cli_client::BrainGeneralCliClient; use detee_shared::general_proto::brain_general_cli_client::BrainGeneralCliClient;
use detee_shared::general_proto::{Account, RegOperatorReq, ReportNodeReq}; use detee_shared::general_proto::{Account, RegOperatorReq, ReportNodeReq};
use detee_shared::vm_proto;
use detee_shared::vm_proto::brain_vm_cli_client::BrainVmCliClient; use detee_shared::vm_proto::brain_vm_cli_client::BrainVmCliClient;
use detee_shared::{app_proto, vm_proto};
use futures::StreamExt; use futures::StreamExt;
use surreal_brain::constants::{ACTIVE_VM, NEW_VM_REQ}; use surreal_brain::constants::{ACTIVE_VM, NEW_VM_REQ};
use surreal_brain::db::prelude as db; use surreal_brain::db::prelude as db;

@ -9,25 +9,25 @@ async fn test_new_app_db_tx() {
let db = prepare_test_db().await.unwrap(); let db = prepare_test_db().await.unwrap();
let req = NewAppReq { let req = NewAppReq {
package_url: "https://registry.detee.ltd/sgx/packages/actix-app-info_package_2025-04-16_21-59-38.tar.gz".to_string(), package_url: "https://registry.detee.ltd/sgx/packages/actix-app-info_package_2025-04-16_21-59-38.tar.gz".to_string(),
node_pubkey: "AH3SpV6ZjXMGSSe6xGH2ekUZxyUhnesAFz4LjX7PnvVn".to_string(), node_pubkey: "AH3SpV6ZjXMGSSe6xGH2ekUZxyUhnesAFz4LjX7PnvVn".to_string(),
resource: Some( resource: Some(
AppResource { AppResource {
memory_mib: 1500, memory_mb: 1500,
disk_size_mib: 2000, disk_size_gb: 2,
vcpus: 1, vcpus: 1,
ports: vec![ 8080 ], ports: vec![ 8080 ],
}, },
), ),
uuid: "".to_string(), uuid: "".to_string(),
admin_pubkey: "H21Shi4iE7vgfjWEQNvzmpmBMJSaiZ17PYUcdNoAoKNc".to_string(), admin_pubkey: "H21Shi4iE7vgfjWEQNvzmpmBMJSaiZ17PYUcdNoAoKNc".to_string(),
price_per_unit: 200000, price_per_unit: 200000,
locked_nano: 152400000, locked_nano: 152400000,
hratls_pubkey: "7E0F887AA6BB9104EEC1066F454D4C2D9063D676715F55F919D3FBCEDC63240B".to_string(), hratls_pubkey: "7E0F887AA6BB9104EEC1066F454D4C2D9063D676715F55F919D3FBCEDC63240B".to_string(),
public_package_mr_enclave: Some( public_package_mr_enclave: Some(
vec![ 128, 0, 97, 103, 165, 103, 68, 203, 240, 145, 153, 254, 34, 129, 75, 140, 8, 186, 63, 226, 144, 129, 201, 187, 175, 66, 80, 1, 151, 114, 183, 159, ], vec![ 128, 0, 97, 103, 165, 103, 68, 203, 240, 145, 153, 254, 34, 129, 75, 140, 8, 186, 63, 226, 144, 129, 201, 187, 175, 66, 80, 1, 151, 114, 183, 159, ],
), ),
app_name: "lively-ferret".to_string(), app_name: "lively-ferret".to_string(),
}; };
let db_req: db::NewAppReq = req.into(); let db_req: db::NewAppReq = req.into();

@ -93,7 +93,6 @@ async fn test_app_creation() {
db.select::<Option<db::ActiveApp>>((ACTIVE_APP, new_app_resp.uuid)).await.unwrap(); db.select::<Option<db::ActiveApp>>((ACTIVE_APP, new_app_resp.uuid)).await.unwrap();
assert!(active_app.is_some()); assert!(active_app.is_some());
tokio::time::sleep(std::time::Duration::from_millis(300)).await;
let acc_db: db::Account = db.select((ACCOUNT, key.pubkey.clone())).await.unwrap().unwrap(); let acc_db: db::Account = db.select((ACCOUNT, key.pubkey.clone())).await.unwrap().unwrap();
assert_eq!(acc_db.balance, airdrop_amount * TOKEN_DECIMAL - (locking_nano + 100)); assert_eq!(acc_db.balance, airdrop_amount * TOKEN_DECIMAL - (locking_nano + 100));
assert_eq!(acc_db.tmp_locked, 0); assert_eq!(acc_db.tmp_locked, 0);

@ -102,8 +102,8 @@ async fn test_app_daemon_resource_msg() {
node_pubkey: daemon_pubkey, node_pubkey: daemon_pubkey,
avail_no_of_port: 5, avail_no_of_port: 5,
avail_vcpus: 4, avail_vcpus: 4,
avail_memory_mib: 8192, avail_memory_mb: 8192,
avail_storage_mib: 10_0000, avail_storage_gb: 100,
max_ports_per_app: 5, max_ports_per_app: 5,
}; };
@ -123,17 +123,17 @@ async fn test_app_daemon_resource_msg() {
let app_node_opt: Option<AppNode> = db.select((APP_NODE, daemon_key.pubkey)).await.unwrap(); let app_node_opt: Option<AppNode> = db.select((APP_NODE, daemon_key.pubkey)).await.unwrap();
assert!(app_node_opt.is_some()); assert!(app_node_opt.is_some());
let db::AppNode { let db::AppNode {
avail_mem_mib, avail_mem_mb,
avail_vcpus, avail_vcpus,
avail_storage_mib, avail_storage_gbs,
avail_ports, avail_ports,
max_ports_per_app, max_ports_per_app,
.. ..
} = app_node_opt.unwrap(); } = app_node_opt.unwrap();
assert_eq!(avail_mem_mib, req_data.avail_memory_mib); assert_eq!(avail_mem_mb, req_data.avail_memory_mb);
assert_eq!(avail_vcpus, req_data.avail_vcpus); assert_eq!(avail_vcpus, req_data.avail_vcpus);
assert_eq!(avail_storage_mib, req_data.avail_storage_mib); assert_eq!(avail_storage_gbs, req_data.avail_storage_gb);
assert_eq!(avail_ports, req_data.avail_no_of_port); assert_eq!(avail_ports, req_data.avail_no_of_port);
assert_eq!(max_ports_per_app, req_data.max_ports_per_app); assert_eq!(max_ports_per_app, req_data.max_ports_per_app);
} }

@ -3,11 +3,12 @@
use common::prepare_test_env::{prepare_test_db, run_service_for_stream}; use common::prepare_test_env::{prepare_test_db, run_service_for_stream};
use common::test_utils::{airdrop, Key}; use common::test_utils::{airdrop, Key};
use common::vm_daemon_utils::register_vm_node; use common::vm_daemon_utils::register_vm_node;
use detee_shared::app_proto;
use detee_shared::app_proto::brain_app_cli_client::BrainAppCliClient; use detee_shared::app_proto::brain_app_cli_client::BrainAppCliClient;
use detee_shared::app_proto::brain_app_daemon_client::BrainAppDaemonClient; use detee_shared::app_proto::brain_app_daemon_client::BrainAppDaemonClient;
use detee_shared::vm_proto;
use detee_shared::vm_proto::brain_vm_cli_client::BrainVmCliClient; use detee_shared::vm_proto::brain_vm_cli_client::BrainVmCliClient;
use detee_shared::vm_proto::brain_vm_daemon_client::BrainVmDaemonClient; use detee_shared::vm_proto::brain_vm_daemon_client::BrainVmDaemonClient;
use detee_shared::{app_proto, vm_proto};
use crate::common::app_daemon_utils::register_app_node; use crate::common::app_daemon_utils::register_app_node;

@ -91,8 +91,8 @@ async fn test_vm_daemon_resource_msg() {
avail_ipv4: 2, avail_ipv4: 2,
avail_ipv6: 88, avail_ipv6: 88,
avail_vcpus: 4, avail_vcpus: 4,
avail_memory_mib: 8192, avail_memory_mb: 8192,
avail_storage_mib: 102400, avail_storage_gb: 100,
max_ports_per_vm: 5, max_ports_per_vm: 5,
}; };
@ -114,9 +114,9 @@ async fn test_vm_daemon_resource_msg() {
assert!(vm_node_opt.is_some()); assert!(vm_node_opt.is_some());
let db::VmNode { let db::VmNode {
avail_mem_mib, avail_mem_mb,
avail_vcpus, avail_vcpus,
avail_storage_mib, avail_storage_gbs,
avail_ports, avail_ports,
avail_ipv4, avail_ipv4,
avail_ipv6, avail_ipv6,
@ -124,9 +124,9 @@ async fn test_vm_daemon_resource_msg() {
.. ..
} = vm_node_opt.unwrap(); } = vm_node_opt.unwrap();
assert_eq!(avail_mem_mib, req_data.avail_memory_mib); assert_eq!(avail_mem_mb, req_data.avail_memory_mb);
assert_eq!(avail_vcpus, req_data.avail_vcpus); assert_eq!(avail_vcpus, req_data.avail_vcpus);
assert_eq!(avail_storage_mib, req_data.avail_storage_mib); assert_eq!(avail_storage_gbs, req_data.avail_storage_gb);
assert_eq!(avail_ports, req_data.avail_ports); assert_eq!(avail_ports, req_data.avail_ports);
assert_eq!(avail_ipv4, req_data.avail_ipv4); assert_eq!(avail_ipv4, req_data.avail_ipv4);
assert_eq!(avail_ipv6, req_data.avail_ipv6); assert_eq!(avail_ipv6, req_data.avail_ipv6);

@ -312,7 +312,7 @@ vm_contracts:
exposed_ports: [] exposed_ports: []
public_ipv4: 156.146.63.216 public_ipv4: 156.146.63.216
public_ipv6: "" public_ipv6: ""
disk_size_gb: 10240 disk_size_gb: 10
vcpus: 2 vcpus: 2
memory_mb: 3000 memory_mb: 3000
kernel_sha: 3ec4fc5aa5729f515967ec71be4a851622785c0080f7191b1b07717149840151 kernel_sha: 3ec4fc5aa5729f515967ec71be4a851622785c0080f7191b1b07717149840151
@ -329,7 +329,7 @@ vm_contracts:
exposed_ports: [] exposed_ports: []
public_ipv4: 173.234.136.154 public_ipv4: 173.234.136.154
public_ipv6: "" public_ipv6: ""
disk_size_gb: 10240 disk_size_gb: 10
vcpus: 2 vcpus: 2
memory_mb: 3000 memory_mb: 3000
kernel_sha: 3ec4fc5aa5729f515967ec71be4a851622785c0080f7191b1b07717149840151 kernel_sha: 3ec4fc5aa5729f515967ec71be4a851622785c0080f7191b1b07717149840151
@ -347,7 +347,7 @@ vm_contracts:
- 38288 - 38288
public_ipv4: "" public_ipv4: ""
public_ipv6: "" public_ipv6: ""
disk_size_gb: 10240 disk_size_gb: 10
vcpus: 1 vcpus: 1
memory_mb: 1000 memory_mb: 1000
kernel_sha: 14e225e4aaf84cc2e0b5f64206121186ddebc4b378b886da3b2f7515dfd41692 kernel_sha: 14e225e4aaf84cc2e0b5f64206121186ddebc4b378b886da3b2f7515dfd41692
@ -364,7 +364,7 @@ vm_contracts:
exposed_ports: [] exposed_ports: []
public_ipv4: 149.22.95.2 public_ipv4: 149.22.95.2
public_ipv6: "" public_ipv6: ""
disk_size_gb: 10240 disk_size_gb: 10
vcpus: 2 vcpus: 2
memory_mb: 3000 memory_mb: 3000
kernel_sha: 3a68709138bed09c16671949cf1f03acee95a08381ba84fc70fb586001fa6767 kernel_sha: 3a68709138bed09c16671949cf1f03acee95a08381ba84fc70fb586001fa6767
@ -381,7 +381,7 @@ vm_contracts:
exposed_ports: [] exposed_ports: []
public_ipv4: 156.146.63.217 public_ipv4: 156.146.63.217
public_ipv6: "" public_ipv6: ""
disk_size_gb: 10240 disk_size_gb: 10
vcpus: 2 vcpus: 2
memory_mb: 3000 memory_mb: 3000
kernel_sha: e49c8587287b21df7600c04326fd7393524453918c14d67f73757dc769a13542 kernel_sha: e49c8587287b21df7600c04326fd7393524453918c14d67f73757dc769a13542
@ -415,7 +415,7 @@ vm_contracts:
exposed_ports: [] exposed_ports: []
public_ipv4: 149.36.48.100 public_ipv4: 149.36.48.100
public_ipv6: "" public_ipv6: ""
disk_size_gb: 10240 disk_size_gb: 10
vcpus: 4 vcpus: 4
memory_mb: 4000 memory_mb: 4000
kernel_sha: e49c8587287b21df7600c04326fd7393524453918c14d67f73757dc769a13542 kernel_sha: e49c8587287b21df7600c04326fd7393524453918c14d67f73757dc769a13542
@ -433,7 +433,7 @@ vm_contracts:
- 46393 - 46393
public_ipv4: "" public_ipv4: ""
public_ipv6: "" public_ipv6: ""
disk_size_gb: 10240 disk_size_gb: 10
vcpus: 1 vcpus: 1
memory_mb: 1000 memory_mb: 1000
kernel_sha: e765e56166ef321b53399b9638584d1279821dbe3d46191c1f66bbaa075e7919 kernel_sha: e765e56166ef321b53399b9638584d1279821dbe3d46191c1f66bbaa075e7919
@ -452,7 +452,7 @@ vm_contracts:
- 46393 - 46393
public_ipv4: "" public_ipv4: ""
public_ipv6: "" public_ipv6: ""
disk_size_gb: 10240 disk_size_gb: 10
vcpus: 1 vcpus: 1
memory_mb: 1000 memory_mb: 1000
kernel_sha: e765e56166ef321b53399b9638584d1279821dbe3d46191c1f66bbaa075e7919 kernel_sha: e765e56166ef321b53399b9638584d1279821dbe3d46191c1f66bbaa075e7919
@ -470,7 +470,7 @@ vm_contracts:
- 46393 - 46393
public_ipv4: "" public_ipv4: ""
public_ipv6: "" public_ipv6: ""
disk_size_gb: 10240 disk_size_gb: 10
vcpus: 1 vcpus: 1
memory_mb: 1000 memory_mb: 1000
kernel_sha: e765e56166ef321b53399b9638584d1279821dbe3d46191c1f66bbaa075e7919 kernel_sha: e765e56166ef321b53399b9638584d1279821dbe3d46191c1f66bbaa075e7919
@ -480,7 +480,6 @@ vm_contracts:
price_per_unit: 20000 price_per_unit: 20000
locked_nano: 12730960000 locked_nano: 12730960000
collected_at: 2025-04-20T00:34:15.461240342Z collected_at: 2025-04-20T00:34:15.461240342Z
app_nodes: app_nodes:
- node_pubkey: BiqoPUEoAxYxMRXUmyofoS9H1TBQgQqvLJ6MbWh88AQg - node_pubkey: BiqoPUEoAxYxMRXUmyofoS9H1TBQgQqvLJ6MbWh88AQg
operator_wallet: 7V3rEuh6j8VuwMVB5PyGqWKLmjJ4fYSv6WtrTL51NZTB operator_wallet: 7V3rEuh6j8VuwMVB5PyGqWKLmjJ4fYSv6WtrTL51NZTB