testnet/proto
3
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

surreal_brain_app (#3)

Browse Source 
add support for apps on the surreal brain

Co-authored-by: Noor <noormohammedb@protonmail.com>
Reviewed-on: #3
This commit is contained in:
ghe0 2025-05-19 21:14:42 +00:00
parent d0d4622c52
commit 7ef7068932
5 changed files with 17 additions and 24 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
build.rs
View File

@ -7,11 +7,7 @@ fn main() -> Result<(), Box<dyn std::error::Error>> {
"#[derive(serde::Serialize, serde::Deserialize)]", "#[derive(serde::Serialize, serde::Deserialize)]",
) )
.type_attribute( .type_attribute(
".vm_proto.MappedPort", ".common_proto.MappedPort",
"#[derive(serde::Serialize, serde::Deserialize)]",
)
.type_attribute(
".app_proto.MappedPort",
"#[derive(serde::Serialize, serde::Deserialize)]", "#[derive(serde::Serialize, serde::Deserialize)]",
) )
.type_attribute( .type_attribute(

16
proto/sgx/app.proto
View File

@ -11,7 +11,7 @@ message AppContract {
string node_pubkey = 4; string node_pubkey = 4;
string public_ipv4 = 5; string public_ipv4 = 5;
AppResource resource = 6; AppResource resource = 6;
repeated MappedPort mapped_ports = 7; repeated common_proto.MappedPort mapped_ports = 7;
string created_at = 8; string created_at = 8;
string updated_at = 9; string updated_at = 9;
uint64 nano_per_minute = 10; uint64 nano_per_minute = 10;
@ -44,16 +44,11 @@ message AppResource {
message NewAppRes { message NewAppRes {
string uuid = 1; string uuid = 1;
string status = 2; string ip_address = 2;
string ip_address = 3; repeated common_proto.MappedPort mapped_ports = 3;
repeated MappedPort mapped_ports = 4; string error = 4;
string error = 5;
} }
message MappedPort {
uint32 host_port = 1;
uint32 app_port = 2;
}
message DelAppReq { message DelAppReq {
string uuid= 1; string uuid= 1;
@ -76,6 +71,7 @@ message AppNodeFilters {
string city = 6; string city = 6;
string ip = 7; string ip = 7;
string node_pubkey = 8; string node_pubkey = 8;
uint32 free_ports = 9;
} }
message AppNodeListResp { message AppNodeListResp {
@ -90,7 +86,7 @@ message AppNodeListResp {
} }
service BrainAppCli { service BrainAppCli {
rpc DeployApp (NewAppReq) returns (NewAppRes); rpc NewApp (NewAppReq) returns (NewAppRes);
rpc DeleteApp (DelAppReq) returns (common_proto.Empty); rpc DeleteApp (DelAppReq) returns (common_proto.Empty);
rpc ListAppContracts (ListAppContractsReq) returns (stream AppContract); rpc ListAppContracts (ListAppContractsReq) returns (stream AppContract);
rpc ListAppNodes (AppNodeFilters) returns (stream AppNodeListResp); rpc ListAppNodes (AppNodeFilters) returns (stream AppNodeListResp);

5
proto/shared/common.proto
View File

@ -7,3 +7,8 @@ message Empty {
message Pubkey { message Pubkey {
string pubkey = 1; string pubkey = 1;
} }
message MappedPort {
uint32 host_port = 1;
uint32 guest_port = 2;
}

7
proto/snp/vm.proto
View File

@ -3,11 +3,6 @@ package vm_proto;
import "shared/common.proto"; import "shared/common.proto";
message MappedPort {
uint32 host_port = 1;
uint32 guest_port = 2;
}
message VmContract { message VmContract {
string uuid = 1; string uuid = 1;
string hostname = 2; string hostname = 2;
@ -15,7 +10,7 @@ message VmContract {
string node_pubkey = 4; string node_pubkey = 4;
string node_ip = 5; string node_ip = 5;
string location = 6; string location = 6;
repeated MappedPort mapped_ports = 7; repeated common_proto.MappedPort mapped_ports = 7;
string vm_public_ipv4 = 8; string vm_public_ipv4 = 8;
string vm_public_ipv6 = 9; string vm_public_ipv6 = 9;
uint32 disk_size_gb = 10; uint32 disk_size_gb = 10;

7
src/sgx/types/brain.rs
View File

@ -1,5 +1,6 @@
use crate::app_proto::{daemon_message_app, AppNodeResources, DaemonMessageApp}; use crate::app_proto::{daemon_message_app, AppNodeResources, DaemonMessageApp};
use crate::app_proto::{AppResource, DaemonAuth, MappedPort, NewAppReq, NewAppRes}; use crate::app_proto::{AppResource, DaemonAuth, NewAppReq, NewAppRes};
use crate::common_proto::MappedPort;
use serde::{Deserialize, Serialize}; use serde::{Deserialize, Serialize};
#[derive(Debug, Clone, Serialize, Deserialize, PartialEq, Default)] #[derive(Debug, Clone, Serialize, Deserialize, PartialEq, Default)]
@ -93,14 +94,14 @@ impl From<(u16, u16)> for MappedPort {
fn from(val: (u16, u16)) -> Self { fn from(val: (u16, u16)) -> Self {
Self { Self {
host_port: val.0 as u32, host_port: val.0 as u32,
app_port: val.1 as u32, guest_port: val.1 as u32,
} }
} }
} }
impl From<MappedPort> for (u16, u16) { impl From<MappedPort> for (u16, u16) {
fn from(val: MappedPort) -> Self { fn from(val: MappedPort) -> Self {
(val.host_port as u16, val.app_port as u16) (val.host_port as u16, val.guest_port as u16)
} }
} }