feat(services/github): implement write returns metadata

Author: shruti2522

bindings/nodejs/package.json

@@ -73,7 +73,7 @@
     "test": "vitest",
     "bench": "node -r dotenv/config ./benchmark/node.js dotenv_config_path=./.env",
     "bench:deno": "deno bench ./benchmark/deno.ts --reload=npm:opendal --allow-read --allow-ffi --allow-net --allow-env",
-    "prepublishOnly": "napi prepublish -t npm"
+    "prepublishOnly": "napi prepublish -t npm --skip-gh-release"
   },
   "prettier": {
     "overrides": [

core/benches/types/buffer.rs

@@ -17,7 +17,8 @@
 
 use bytes::Buf;
 use bytes::Bytes;
-use divan::{black_box, Bencher};
+use divan::black_box;
+use divan::Bencher;
 use opendal::Buffer;
 
 mod chunk {

core/benches/types/tasks.rs

@@ -15,12 +15,12 @@
 // specific language governing permissions and limitations
 // under the License.
 
+use std::sync::LazyLock;
 use std::time::Duration;
 
 use divan::Bencher;
 use opendal::raw::ConcurrentTasks;
 use opendal::Executor;
-use std::sync::LazyLock;
 
 pub static TOKIO: LazyLock<tokio::runtime::Runtime> =
     LazyLock::new(|| tokio::runtime::Runtime::new().expect("build tokio runtime"));

core/src/blocking/operator.rs

@@ -361,11 +361,11 @@ impl Operator {
     ///
     /// ```no_run
     /// # use opendal::Result;
-    /// use opendal::blocking;
     /// # use opendal::blocking::Operator;
     /// # use futures::StreamExt;
     /// # use futures::SinkExt;
     /// use bytes::Bytes;
+    /// use opendal::blocking;
     ///
     /// # fn test(op: blocking::Operator) -> Result<()> {
     /// op.write("path/to/file", vec![0; 4096])?;

core/src/blocking/read/reader.rs

@@ -19,12 +19,11 @@ use std::ops::RangeBounds;
 
 use bytes::BufMut;
 
-use crate::Reader as AsyncReader;
-use crate::*;
-
 use super::BufferIterator;
 use super::StdBytesIterator;
 use super::StdReader;
+use crate::Reader as AsyncReader;
+use crate::*;
 
 /// BlockingReader is designed to read data from given path in an blocking
 /// manner.

core/src/layers/capability_check.rs

@@ -15,10 +15,12 @@
 // specific language governing permissions and limitations
 // under the License.
 
+use std::fmt::Debug;
+use std::fmt::Formatter;
+use std::sync::Arc;
+
 use crate::layers::correctness_check::new_unsupported_error;
 use crate::raw::*;
-use std::fmt::{Debug, Formatter};
-use std::sync::Arc;
 
 /// Add an extra capability check layer for every operation
 ///
@@ -141,7 +143,9 @@ impl<A: Access> LayeredAccess for CapabilityAccessor<A> {
 #[cfg(test)]
 mod tests {
     use super::*;
-    use crate::{Capability, ErrorKind, Operator};
+    use crate::Capability;
+    use crate::ErrorKind;
+    use crate::Operator;
 
     #[derive(Debug)]
     struct MockService {

core/src/layers/complete.rs

@@ -15,15 +15,16 @@
 // specific language governing permissions and limitations
 // under the License.
 
-use crate::raw::oio::FlatLister;
-use crate::raw::oio::PrefixLister;
-use crate::raw::*;
-use crate::*;
 use std::cmp::Ordering;
 use std::fmt::Debug;
 use std::fmt::Formatter;
 use std::sync::Arc;
 
+use crate::raw::oio::FlatLister;
+use crate::raw::oio::PrefixLister;
+use crate::raw::*;
+use crate::*;
+
 /// Complete underlying services features so that users can use them in
 /// the same way.
 ///
@@ -51,7 +52,6 @@ use std::sync::Arc;
 ///
 /// - If support `list_with_recursive`, return directly.
 /// - if not, wrap with [`FlatLister`].
-///
 pub struct CompleteLayer;
 
 impl<A: Access> Layer<A> for CompleteLayer {

core/src/layers/correctness_check.rs

@@ -15,7 +15,8 @@
 // specific language governing permissions and limitations
 // under the License.
 
-use std::fmt::{Debug, Formatter};
+use std::fmt::Debug;
+use std::fmt::Formatter;
 use std::future::Future;
 use std::sync::Arc;
 
@@ -252,7 +253,10 @@ impl<T: oio::Delete> oio::Delete for CheckWrapper<T> {
 mod tests {
     use super::*;
     use crate::raw::oio;
-    use crate::{Capability, EntryMode, Metadata, Operator};
+    use crate::Capability;
+    use crate::EntryMode;
+    use crate::Metadata;
+    use crate::Operator;
 
     #[derive(Debug)]
     struct MockService {

core/src/layers/mime_guess.rs

@@ -142,11 +142,12 @@ impl<A: Access> LayeredAccess for MimeGuessAccessor<A> {
 
 #[cfg(test)]
 mod tests {
+    use futures::TryStreamExt;
+
     use super::*;
     use crate::services::Memory;
     use crate::Metadata;
     use crate::Operator;
-    use futures::TryStreamExt;
 
     const DATA: &str = "<html>test</html>";
     const CUSTOM: &str = "text/custom";

core/src/layers/otelmetrics.rs

@@ -161,8 +161,7 @@ impl OtelMetricsLayerBuilder {
     /// # async fn main() -> Result<()> {
     /// let meter = opentelemetry::global::meter("opendal");
     /// let op = Operator::new(services::Memory::default())?
-    ///     .layer(OtelMetricsLayer::builder()
-    ///     .register(&meter))
+    ///     .layer(OtelMetricsLayer::builder().register(&meter))
     ///     .finish();
     ///
     /// Ok(())