Add Sanction List #30
Conversation
|
It takes around 35s to update fetch the latest OFAC list and extract all addresses from XML to the in memory hashmap. The logic runs in a separate non-blocking thread so it should not cause any issues. Also, they update the list every few days so it's gonna run that often |
|
I believe we should start this thread when we run the orchestrator. It should wait for the fist sync of the OFAC list before it starts |
|
BTW let me know when this is ready for review (looks like CI doesn't pass atm) |
Fixed the lint issues. You can review this :) |
| } | ||
| } | ||
|
|
||
| /// Handles bob request from A to Z. | ||
| pub async fn handle_request(&self, bob_request: &BobRequest) -> Result<BobResponse> { | ||
| // Validate transaction before forwarding it, and get smart contract | ||
| bob_request | ||
| .check_compliance(Arc::clone(&self.compliance)) | ||
| .await?; |
There was a problem hiding this comment.
wondering: should individual nodes perform that check as well? What would be the rational for not performing that check at the node level (and would node be liable if something bad happens there...)
There was a problem hiding this comment.
We could, but we've got orchestrator as a centralized entity that coordinates the entire process.
| } | ||
|
|
||
| impl Compliance { | ||
| const BTC_ID: &'static str = "344"; |
There was a problem hiding this comment.
can you document where you got that value from? (if it's possible)
There was a problem hiding this comment.
Oh I couldn't find any documentation. This is a gov document, didn't expect anything better to be honest. I had to look into the XML file and find that number.
| let last_update = Arc::clone(&self.last_update); | ||
|
|
||
| spawn(async move { | ||
| let mut interval = interval(Duration::from_secs(600)); |
There was a problem hiding this comment.
we should hardcode that value somewhere
There was a problem hiding this comment.
yes I will do that
| ); | ||
|
|
||
| // Sync sanction list in a parallel thread | ||
| compliance.start(); |
There was a problem hiding this comment.
don't you have to use the joinhandle returned?
There was a problem hiding this comment.
not if you don't want to wait for it to complete
I've added a comment regarding this. It's an XML file and is 92MB big. |
Add sanction list based to the discussion here #5.
The logic goes like this:
is_sanctionedmethod that returns true if the address is in the sanction list.