bet/beteran-server-service
3
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

events are added

Browse Source
This commit is contained in:
병준 박 2022-08-28 03:18:04 +00:00
parent 6263a3d557
commit 0803ade97b
3 changed files with 55 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
Cargo.toml
View File

@ -37,7 +37,7 @@ tokio = { version = "1", features = ["macros", "rt-multi-thread"] }
tokio-cron-scheduler = { version = "0" } tokio-cron-scheduler = { version = "0" }
uuid = { version = "0", features = ["serde", "v4", "v5"] } uuid = { version = "0", features = ["serde", "v4", "v5"] }
beteran-protobuf-rust = { git = "https://gitlab.loafle.net/bet/beteran-protobuf-rust.git", tag = "v0.1.77-snapshot" } beteran-protobuf-rust = { git = "https://gitlab.loafle.net/bet/beteran-protobuf-rust.git", tag = "v0.1.78-snapshot" }
beteran-common-rust = { git = "https://gitlab.loafle.net/bet/beteran-common-rust.git", tag = "v0.1.62-snapshot" } beteran-common-rust = { git = "https://gitlab.loafle.net/bet/beteran-common-rust.git", tag = "v0.1.63-snapshot" }
[build-dependencies] [build-dependencies]

28
src/services/member_bank_deposit/service.rs
View File

@ -787,7 +787,33 @@ impl Service {
result: Some( result: Some(
bpr::ss::member_bank_deposit::update_member_bank_deposit_response::Result { bpr::ss::member_bank_deposit::update_member_bank_deposit_response::Result {
member_bank_deposit: s member_bank_deposit: s
.map(|d| bpr::models::member_bank_deposit::MemberBankDeposit::from(&d)), .as_ref()
.map(bpr::models::member_bank_deposit::MemberBankDeposit::from),
},
),
}
.encode_to_vec(),
)
.await
.map_err(|e| {
bcr::error::rpc::Error::Server(bcr::error::rpc::Server {
code: bpr::protobuf::rpc::Error::SERVER_00,
message: format!("server {}", e),
data: None,
})
})?;
self
.connection_broker
.publish(
bpr::ss::member_bank_deposit::EVENT_SUBJECT_AFTER_UPDATE_MEMBER_BANK_DEPOSIT_FOR_STATE,
bpr::ss::member_bank_deposit::AfterUpdateMemberBankDepositForState {
client: Some(client),
event: Some(
bpr::ss::member_bank_deposit::after_update_member_bank_deposit_for_state::Event {
member_bank_deposit: s
.as_ref()
.map(bpr::models::member_bank_deposit::MemberBankDeposit::from),
}, },
), ),
} }

27
src/services/member_bank_withdraw/service.rs
View File

@ -792,8 +792,33 @@ impl Service {
error: None, error: None,
result: Some( result: Some(
bpr::ss::member_bank_withdraw::update_member_bank_withdraw_for_state_response::Result { bpr::ss::member_bank_withdraw::update_member_bank_withdraw_for_state_response::Result {
member_bank_withdraw: s.as_ref()
.map(bpr::models::member_bank_withdraw::MemberBankWithdraw::from),
},
),
}
.encode_to_vec(),
)
.await
.map_err(|e| {
bcr::error::rpc::Error::Server(bcr::error::rpc::Server {
code: bpr::protobuf::rpc::Error::SERVER_00,
message: format!("server {}", e),
data: None,
})
})?;
self
.connection_broker
.publish(
bpr::ss::member_bank_withdraw::EVENT_SUBJECT_AFTER_UPDATE_MEMBER_BANK_WITHDRAW_FOR_STATE,
bpr::ss::member_bank_withdraw::AfterUpdateMemberBankWithdrawForState {
client: Some(client),
event: Some(
bpr::ss::member_bank_withdraw::after_update_member_bank_withdraw_for_state::Event {
member_bank_withdraw: s member_bank_withdraw: s
.map(|d| bpr::models::member_bank_withdraw::MemberBankWithdraw::from(&d)), .as_ref()
.map(bpr::models::member_bank_withdraw::MemberBankWithdraw::from),
}, },
), ),
} }