feat: initial metadata query support (#66)

* feat: initial metadata request

* chore: clippy

* chore: fmt

.github/workflows/test.yaml

@@ -97,14 +97,10 @@ jobs:
     steps:
       - uses: actions/checkout@v4
 
-      - name: Install minimal stable with clippy and rustfmt
-        uses: actions-rs/toolchain@v1
+      - name: Setup rust toolchain
+        uses: actions-rust-lang/setup-rust-toolchain@v1
         with:
-          profile: default
-          toolchain: "stable"
-          override: true
-
-      - uses: Swatinem/rust-cache@v2
+          toolchain: stable
 
       - name: Run integration tests
         run: cargo test --tests

buf.gen.yaml

@@ -46,5 +46,5 @@ plugins:
   #   opt:
   #     - openapi_naming_strategy=simple
   #     - allow_merge=true
-  # - remote: buf.build/community/google-gnostic-openapi:v0.7.0
-  #   out: gnostic
+  - remote: buf.build/community/google-gnostic-openapi:v0.7.0
+    out: openapi

delta-sharing/client/src/gen/delta_sharing.v1.tonic.rs

@@ -271,5 +271,33 @@ pub mod delta_sharing_service_client {
                 );
             self.inner.unary(req, path, codec).await
         }
+        ///
+        pub async fn get_table_metadata(
+            &mut self,
+            request: impl tonic::IntoRequest<super::GetTableMetadataRequest>,
+        ) -> std::result::Result<tonic::Response<super::QueryResponse>, tonic::Status> {
+            self.inner
+                .ready()
+                .await
+                .map_err(|e| {
+                    tonic::Status::new(
+                        tonic::Code::Unknown,
+                        format!("Service was not ready: {}", e.into()),
+                    )
+                })?;
+            let codec = tonic::codec::ProstCodec::default();
+            let path = http::uri::PathAndQuery::from_static(
+                "/delta_sharing.v1.DeltaSharingService/GetTableMetadata",
+            );
+            let mut req = request.into_request();
+            req.extensions_mut()
+                .insert(
+                    GrpcMethod::new(
+                        "delta_sharing.v1.DeltaSharingService",
+                        "GetTableMetadata",
+                    ),
+                );
+            self.inner.unary(req, path, codec).await
+        }
     }
 }

delta-sharing/common/src/error.rs

@@ -29,6 +29,9 @@ pub enum Error {
     #[error("Failed to extract recipient from request")]
     MissingRecipient,
 
+    #[error(transparent)]
+    SerDe(#[from] serde_json::Error),
+
     #[cfg(feature = "axum")]
     #[error("Axum path: {0}")]
     AxumPath(#[from] PathRejection),
@@ -55,6 +58,7 @@ impl From<Error> for Status {
                 "The request is unauthenticated. The bearer token is missing or incorrect.",
             ),
             Error::Kernel(error) => Status::internal(error.to_string()),
+            Error::SerDe(_) => Status::internal("Encountered invalid table log."),
             Error::InvalidTableLocation(location) => {
                 Status::internal(format!("Invalid table location: {}", location))
             }
@@ -124,6 +128,10 @@ mod server {
                     error!("{}", message);
                     INTERNAL_ERROR
                 }
+                Error::SerDe(_) => {
+                    error!("Inavalid table log encountered");
+                    INTERNAL_ERROR
+                }
                 Error::Generic(message) => {
                     error!("Generic error: {}", message);
                     INTERNAL_ERROR