modern sync: add upload_filenodes method

Summary: Unused for now, this is prep for sending hg data

Reviewed By: markbt

Differential Revision: D67027144

fbshipit-source-id: ab046cff9d771ce720ffce5277a084940bc89410

eden/mononoke/modern_sync/src/sender.rs

@@ -7,6 +7,7 @@
 
 use anyhow::Result;
 use async_trait::async_trait;
+use edenapi_types::HgFilenodeData;
 use edenapi_types::UploadTreeEntry;
 use mononoke_types::ContentId;
 use mononoke_types::FileContents;
@@ -19,4 +20,7 @@ pub trait ModernSyncSender {
 
     #[allow(unused)]
     async fn upload_tree(&self, trees: Vec<UploadTreeEntry>) -> Result<()>;
+
+    #[allow(unused)]
+    async fn upload_filenodes(&self, filenodes: Vec<HgFilenodeData>) -> Result<()>;
 }

eden/mononoke/modern_sync/src/sender/dummy.rs

@@ -7,6 +7,7 @@
 
 use anyhow::Result;
 use async_trait::async_trait;
+use edenapi_types::HgFilenodeData;
 use edenapi_types::UploadTreeEntry;
 use mononoke_types::ContentId;
 use mononoke_types::FileContents;
@@ -39,4 +40,14 @@ impl ModernSyncSender for DummySender {
         }
         Ok(())
     }
+
+    async fn upload_filenodes(&self, filenodes: Vec<HgFilenodeData>) -> Result<()> {
+        for filenode in filenodes {
+            info!(
+                &self.logger,
+                "Uploading filenode with id {:?}", filenode.node_id
+            );
+        }
+        Ok(())
+    }
 }

eden/mononoke/modern_sync/src/sender/edenapi.rs

@@ -16,6 +16,7 @@ use edenapi::HttpClientBuilder;
 use edenapi::HttpClientConfig;
 use edenapi::SaplingRemoteApi;
 use edenapi_types::AnyFileContentId;
+use edenapi_types::HgFilenodeData;
 use edenapi_types::UploadTreeEntry;
 use futures::TryStreamExt;
 use mononoke_app::args::TLSArgs;
@@ -110,4 +111,14 @@ impl ModernSyncSender for EdenapiSender {
         );
         Ok(())
     }
+
+    async fn upload_filenodes(&self, filenodes: Vec<HgFilenodeData>) -> Result<()> {
+        let res = self.client.upload_filenodes_batch(filenodes).await?;
+        info!(
+            &self.logger,
+            "Upload filenodes response: {:?}",
+            res.entries.try_collect::<Vec<_>>().await?
+        );
+        Ok(())
+    }
 }