5 个版本 (3 个破坏性更新)
0.4.1 | 2022 年 3 月 9 日 |
---|---|
0.4.0 | 2022 年 3 月 9 日 |
0.3.0 | 2021 年 12 月 17 日 |
0.2.0 | 2021 年 11 月 24 日 |
0.1.0 | 2021 年 10 月 22 日 |
#274 在 #tls
每月 25 下载
用于 fisco-bcos-cli
205KB
4K SLoC
fisco-bcos-service
Rust SDK For FISCO BCOS 2.7.0+
安装
[dependencies]
fisco-bcos-service = ">=0.4, <1"
此 crate 使用了 TASSL 来处理 TLS
连接,在 Linux
或 Macos
下无需做任何额外操作,其他环境下则需要指定以下环境变量:
TASSL_LIB_PATH
:库文件加载路径。TASSL_INCLUDE_PATH
:头文件检索路径。TASSL_LIB_KIND
:库文件类型,可用值为:static
或dylib
。
在 Linux
或 Macos
下,如果你已经编译好了 TASSL
,也可以通过指定以上环境变量来缩短编译时间。
使用
- 一、配置
- 二、Web3Service
- 三、SystemConfigService
- 四、TableCRUDService
- 五、SQLService
- 六、ConsensusService
- 七、CNSService
- 八、PermissionService
- 九、ContractLifeCycleService
- 十、ChainGovernanceService
- 十一、EventService
- 十二、注意事项
一、配置
配置文件为包含以下信息的 json
文件:
{
"service_type": "rpc",
"node": {
"host": "127.0.0.1",
"port": 8545
},
"account": "./accounts/alice.pem",
"contract": {
"solc": "./bin/solc-0.4.25",
"source": "./contracts",
"output": "./contracts/.output"
},
"authentication": {
"ca_cert": "./authentication/gm/gmca.crt",
"sign_cert": "./authentication/gm/gmsdk.crt",
"sign_key": "./authentication/gm/gmsdk.key",
"enc_key": "./authentication/gm/gmensdk.key",
"enc_cert": "./authentication/gm/gmensdk.crt"
},
"sm_crypto": false,
"group_id": 1,
"chain_id": 1,
"timeout_seconds": 10
}
每一项的解释如下:
-
service_type
:服务类型,可用值为:rpc
或channel
。 -
node
:服务节点信息,包含以下属性:host
:服务节点主机地址。port
:服务节点端口号。
-
account
:用户证书文件路径(仅支持pem
格式)。 -
contract
:合约相关配置,包含以下属性:solc
:Solidity 编译器所在路径。source
:Solidity 合约源文件所在路径。output
:Solidity 合约编译后的abi
及bin
文件输出目录(该目录需自行创建)。
-
authentication
:节点验证配置信息,包含以下属性:ca_cert
:CA 证书文件路径。sign_cert
:签名证书文件路径。sign_key
:签名密钥文件路径。enc_key
:enc 密钥文件路径(非国密
模式下无需设置)。enc_cert
:enc 证书文件路径(非国密
模式下无需设置)。
-
sm_crypto
:交易签名是否使用国密
。 -
group_id
:组 ID。 -
chain_id
:链 ID。 -
timeout_seconds
: 网络请求过期时间(单位为秒)。
注:配置项中 account
、contract
、authentication
中的路径如果使用相对路径,它的参考路径为该配置文件所在路径。
二、Web3Service
Web3Service 是对 FISCO BCOS JSON-RPC 的封装。
2.1 实例化
use fisco_bcos_service::create_web3_service;
let config_file_path = "./configs/config.json";
let web3_service = create_web3_service(config_file_path).unwrap();
2.2 接口
-
接口列表:
get_client_version
get_block_number
get_pbft_view
get_sealer_list
get_observer_list
get_consensus_status
get_sync_status
get_peers
get_group_peers
get_node_id_list
get_group_list
get_block_by_hash
get_block_by_number
get_block_header_by_hash
get_block_header_by_number
get_block_hash_by_number
get_transaction_by_hash
get_transaction_by_block_hash_and_index
get_transaction_by_block_number_and_index
get_transaction_receipt
get_pending_transactions
get_pending_tx_size
get_code
get_total_transaction_count
get_system_config_by_key
call
send_raw_transaction
send_raw_transaction_and_get_proof
deploy
compile
get_transaction_by_hash_with_proof
get_transaction_receipt_by_hash_with_proof
generate_group
start_group
stop_group
remove_group
recover_group
query_group_status
get_node_info
get_batch_receipts_by_block_number_and_range
get_batch_receipts_by_block_hash_and_range
-
接口将 FISCO BCOS JSON-RPC 返回的
error
属性转换成了fisco_bcos_service::web3::service::ServiceError::FiscoBcosError
异常并返回,包含以下属性:- code:错误类型,详情参见:错误码描述。
- message:错误信息。
-
除
call
的返回值结构与相关 JSON-RPC 方法不一致外,其余接口的返回值结构参见 FISCO BCOS JSON-RPC 中相关方法返回值中的result
属性。 -
调用
call
、send_raw_transaction
、send_raw_transaction_and_get_proof
、deploy
之前,请确保相关合约的abi
及bin
文件已存放在配置属性contract.output
中的指定目录下,你可点击以下链接 download_solc.sh 下载编译器后自行编译,也可调用compile
接口编译。 -
deploy
的返回值结构如下所示:{ "status": "0x0", "transactionHash": "0x31ad4fd454fbe72557cbcb55bde067cfcd80fa43e9d97bdf2c13d2007f066370", "contractAddress": "0x62195d0f77f66c445c4878b845f55d266875705d" }
-
接口中的
Token
实为ethabi::token::Token
,具体使用参见 ethabi token,在使用过程中无需安装ethabi
依赖,只需引用fisco_bcos_service::ethabi::token::Token
即可。
三、SystemConfigService
SystemConfigService 是对预编译合约 SystemConfigPrecompiled 的封装。
3.1 实例化
use fisco_bcos_service::{
create_web3_service,
precompiled::system_config_service::SystemConfigService,
};
let config_file_path = "./configs/config.json";
let web3_service = create_web3_service(config_file_path).unwrap();
let system_config_service = SystemConfigService::new(&web3_service);
3.2 接口
-
接口列表:
set_value_by_key
-
以上接口的返回值如果大于等于
0
,返回此值,否则返回fisco_bcos_service::precompiled::precompiled_service::PrecompiledServiceError
异常,包含以下属性:- code:错误类型。
- message:错误信息。
四、TableCRUDService
TableCRUDService 是对预编译合约 TableFactory 及 CRUDPrecompiled 的封装。
4.1 实例化
use fisco_bcos_service::{
create_web3_service,
precompiled::table_crud_service::TableCRUDService,
};
let config_file_path = "./configs/config.json";
let web3_service = create_web3_service(config_file_path).unwrap();
let table_crud_service = TableCRUDService::new(&web3_service);
4.2 接口
-
接口列表:
create_table
insert
remove
select
update
desc
-
接口
create_table
、insert
、remove
、update
的返回值如果大于等于0
,返回此值,否则返回fisco_bcos_service::precompiled::precompiled_service::PrecompiledServiceError
异常,包含以下属性:- code:错误类型。
- message:错误信息。
-
接口
select
会将返回值由string
转换成Vec<serde_json::Value>
格式。 -
接口
desc
返回(String, Vec<String>)
类型,其中第一个值为主键字段
,第二个值为普通字段
列表。
五、SQLService
通过 SQLService ,我们可以以 SQL
语句的方式来操作 TableCRUDService
相关接口。
5.1 实例化
use fisco_bcos_service::{
create_web3_service,
sql_service::SQLService,
};
let config_file_path = "./configs/config.json";
let web3_service = create_web3_service(config_file_path).unwrap();
let sql_service = SQLService::new(&web3_service);
5.2 接口
-
接口列表:
execute
-
CREATE TABLE
语句中,将忽略指定的字段类型,并且通过指定PRIMARY KEY
(有且仅有一个)来设置表单的key
字段。 -
INSERT
语句中,必须设置key
字段的值。 -
SELECT
语句中,不支持联表查询。 -
SELECT
、UPDATE
、DELETE
语句中,where
语句中必须指定key
字段的值,多个语句之间仅支持AND
操作(比如name = "Tom" and age = "18"
),单个条件仅支持=、!=、>、<、>=、<=
操作,条件的值必须为字面值。
六、ConsensusService
ConsensusService 是对预编译合约 ConsensusPrecompiled 的封装。
6.1 实例化
use fisco_bcos_service::{
create_web3_service,
precompiled::consensus_service::ConsensusService,
};
let config_file_path = "./configs/config.json";
let web3_service = create_web3_service(config_file_path).unwrap();
let consensus_service = ConsensusService::new(&web3_service);
6.2 接口
-
接口列表:
add_sealer
add_observer
remove
-
以上接口的返回值如果大于等于
0
,返回此值,否则返回fisco_bcos_service::precompiled::precompiled_service::PrecompiledServiceError
异常,包含以下属性:- code:错误类型。
- message:错误信息。
七、CNSService
CNSService 是对预编译合约 CNSPrecompiled 的封装。
7.1 实例化
use fisco_bcos_service::{
create_web3_service,
cns_service::CNSService,
};
let config_file_path = "./configs/config.json";
let web3_service = create_web3_service(config_file_path).unwrap();
let cns_service = CNSService::new(&web3_service);
7.2 接口
-
接口列表:
insert
select_by_name
select_by_name_and_version
get_contract_address
-
接口
insert
的返回值如果大于等于0
,返回此值,否则返回fisco_bcos_service::precompiled::precompiled_service::PrecompiledServiceError
异常,包含以下属性:- code:错误类型。
- message:错误信息。
-
接口
select_by_name
与select_by_name_and_version
会将返回值由string
转换成serde_json::Value
格式。 -
接口
get_contract_address
会将返回值由address
转换成String
格式。
八、PermissionService
PermissionService 是对预编译合约 PermissionPrecompiled 的封装。
8.1 实例化
use fisco_bcos_service::{
create_web3_service,
permission_service::PermissionService,
};
let config_file_path = "./configs/config.json";
let web3_service = create_web3_service(config_file_path).unwrap();
let permission_service = PermissionService::new(&web3_service);
8.2 接口
-
接口列表:
insert
remove
query_by_name
grant_write
revoke_write
query_permission
-
接口
insert
、remove
、grant_write
、revoke_write
的返回值如果大于等于0
,返回此值,否则返回fisco_bcos_service::precompiled::precompiled_service::PrecompiledServiceError
异常,包含以下属性:- code:错误类型。
- message:错误信息。
-
接口
query_by_name
与query_permission
会将返回值由string
转换成serde_json::Value
格式。
九、ContractLifeCycleService
ContractLifeCycleService 是对预编译合约 ContractLifeCyclePrecompiled 的封装。
9.1 实例化
use fisco_bcos_service::{
create_web3_service,
contract_life_cycle_service::ContractLifeCycleService,
};
let config_file_path = "./configs/config.json";
let web3_service = create_web3_service(config_file_path).unwrap();
let contract_life_cycle_service = ContractLifeCycleService::new(&web3_service);
9.2 接口
-
接口列表:
freeze
unfreeze
grant_manager
get_status
list_manager
-
接口
freeze
、unfreeze
、grant_manager
的返回值如果大于等于0
,返回此值,否则返回fisco_bcos_service::precompiled::precompiled_service::PrecompiledServiceError
异常,包含以下属性:- code:错误类型。
- message:错误信息。
-
接口
get_status
的返回值为(i32, String)
,其中如果i32
的值小于0
,将返回fisco_bcos_service::precompiled::precompiled_service::PrecompiledServiceError
异常。 -
接口
list_manager
的返回值为(i32, Vec<String>)
,其中如果i32
的值小于0
,将返回fisco_bcos_service::precompiled::precompiled_service::PrecompiledServiceError
异常。
十、ChainGovernanceService
ChainGovernanceService 是对预编译合约 ChainGovernancePrecompiled 的封装。
10.1 实例化
use fisco_bcos_service::{
create_web3_service,
chain_governance_service::ChainGovernanceService,
};
let config_file_path = "./configs/config.json";
let web3_service = create_web3_service(config_file_path).unwrap();
let chain_governance_service = ChainGovernanceService::new(&web3_service);
10.2 接口
-
接口列表:
grant_committee_member
revoke_committee_member
list_committee_members
query_committee_member_weight
update_committee_member_weight
query_votes_of_member
query_votes_of_threshold
update_threshold
query_threshold
grant_operator
revoke_operator
list_operators
freeze_account
unfreeze_account
get_account_status
-
接口
grant_committee_member
、revoke_committee_member
、update_committee_member_weight
、update_threshold
、query_threshold
、grant_operator
、revoke_operator
、freeze_account
、unfreeze_account 的返回值如果大于等于
0
,返回此值,否则返回fisco_bcos_service::precompiled::precompiled_service::PrecompiledServiceError
异常,包含以下属性:- code:错误类型。
- message:错误信息。
-
接口
query_committee_member_weight
的返回值为(bool, i32)
,其中如果i32
的值小于0
,将返回fisco_bcos_service::precompiled::precompiled_service::PrecompiledServiceError
异常。 -
接口
list_committee_members
、query_votes_of_member
、query_votes_of_threshold
、list_operators
会将返回值由string
转换成serde_json::Value
格式。
十一、EventService
通过 EventService,可对合约时间进行监听。
11.1 实例化
use fisco_bcos_service::create_event_service;
let config_file_path = "./configs/config.json";
let event_service = create_event_service(config_file_path).unwrap();
11.2 接口
-
接口列表:
register_block_notify_listener
remove_block_notify_listener
run_block_notify_loop
stop_block_notify_loop
register_event_log_listener
remove_event_log_listener
run_event_log_loop
stop_event_log_loop
-
接口
run_block_notify_loop
和run_event_log_loop
最后两个参数的意义如下:sleep_seconds
:链上数据读取失败后,进入下一轮监听前要等待的时间(单位为秒)。max_retry_times
:链上数据读取失败后,最大重试次数,如果失败次数大于指定的值,将主动终止 loop。当值为 -1 时,表示无限循环。
-
接口
run_block_notify_loop
会一直运行下去,想要终止需调用stop_block_notify_loop
接口,因此一般需要开启新的线程来运行run_block_notify_loop
,比如下面的例子:use std::sync::Arc; use std::thread; use std::time::Duration; use fisco_bcos_service::create_event_service; let event_service = create_event_service("./configs/config.json").unwrap(); event_service.register_block_notify_listener(1, |v| println!("{:?}", v)); let event_service_arc = Arc::new(event_service); let block_notify_loop_service = event_service_arc.clone(); let block_notify_loop_handle = thread::spawn(move || { block_notify_loop_service.run_block_notify_loop(1, 1, -1); }); thread::sleep(Duration::from_millis((10 * 1000) as u64)); event_service_arc.clone().stop_block_notify_loop(1); block_notify_loop_handle.join().unwrap();
-
调用
stop_block_notify_loop
后,run_block_notify_loop
并不会立即终止,而是等到当前一轮监听返回后才终止。 -
接口
run_event_log_loop
会一直运行下去,想要终止需调用stop_event_log_loop
接口,因此一般需要开启新的线程来运行run_event_log_loop
,比如下面的例子:use std::sync::Arc; use std::thread; use std::time::Duration; use fisco_bcos_service::create_event_service; use fisco_bcos_service::event::event_log_param::EventLogParam; use fisco_bcos_service::event::parse_event_log; use fisco_bcos_service::event::topic::{from_event_signature, from_integer}; let event_log_param = EventLogParam::new(); event_log_param.add_address("0xf2df2e7c2a2dc9bd23523f4272e1de1d08d1e9a9"); event_log_param.add_topic(&from_event_signature("event2(string,int256)", false)); event_log_param.add_topic(&from_integer(0)); let event_service = create_event_service("./configs/config.json").unwrap(); event_service.register_event_log_listener(&event_log_param, |v| { match v { Ok(value) => { let logs = parse_event_log( value, "event2", r#"{"anonymous":false,"inputs":[{"indexed":false,"name":"s","type":"string"},{"indexed":true,"name":"n","type":"int256"}],"name":"event2","type":"event"}"#, false, ).unwrap(); println!("{:?}", logs); }, _ => {} } }); let event_service_arc = Arc::new(event_service); let event_log_param_arc = Arc::new(event_log_param); let event_log_loop_service = event_service_arc.clone(); let event_log_loop_param = event_log_param_arc.clone(); let event_log_loop_handle = thread::spawn(move || { event_log_loop_service.run_event_log_loop(&event_log_loop_param, 1, -1); }); thread::sleep(Duration::from_millis((10 * 1000) as u64)); event_service_arc.clone().stop_event_log_loop(&event_log_param_arc.clone()); event_log_loop_handle.join().unwrap();
-
调用
stop_event_log_loop
后,run_event_log_loop
并不会立即终止,而是等到当前一轮监听返回后才终止。
十二、注意事项
- 所有接口除特殊说明外均为异步调用(使用了 Rust 的 async 特性)。
许可协议
依赖项
~18–30MB
~390K SLoC