resolve comments

Signed-off-by: xxchan <xxchan22f@gmail.com>

src/connector/codec/src/common/mod.rs

@@ -0,0 +1,15 @@
+// Copyright 2024 RisingWave Labs
+//
+// Licensed under the Apache License, Version 2.0 (the "License");
+// you may not use this file except in compliance with the License.
+// You may obtain a copy of the License at
+//
+//     http://www.apache.org/licenses/LICENSE-2.0
+//
+// Unless required by applicable law or agreed to in writing, software
+// distributed under the License is distributed on an "AS IS" BASIS,
+// WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+// See the License for the specific language governing permissions and
+// limitations under the License.
+
+pub mod protobuf;

src/connector/codec/src/common/protobuf/mod.rs

@@ -0,0 +1,16 @@
+// Copyright 2024 RisingWave Labs
+//
+// Licensed under the Apache License, Version 2.0 (the "License");
+// you may not use this file except in compliance with the License.
+// You may obtain a copy of the License at
+//
+//     http://www.apache.org/licenses/LICENSE-2.0
+//
+// Unless required by applicable law or agreed to in writing, software
+// distributed under the License is distributed on an "AS IS" BASIS,
+// WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+// See the License for the specific language governing permissions and
+// limitations under the License.
+
+mod compiler;
+pub use compiler::compile_pb;

src/connector/codec/src/decoder/protobuf/mod.rs

@@ -12,12 +12,10 @@
 // See the License for the specific language governing permissions and
 // limitations under the License.
 
-mod compiler;
 pub mod parser;
 use std::borrow::Cow;
 use std::sync::LazyLock;
 
-pub use compiler::compile_pb;
 use parser::from_protobuf_value;
 use prost_reflect::{DynamicMessage, ReflectMessage};
 use risingwave_common::log::LogSuppresser;

src/connector/codec/src/lib.rs

@@ -37,6 +37,7 @@
 #![register_tool(rw)]
 #![recursion_limit = "256"]
 
+pub mod common;
 /// Converts JSON/AVRO/Protobuf data to RisingWave datum.
 /// The core API is [`decoder::Access`].
 pub mod decoder;

src/connector/codec/tests/integration_tests/main.rs

@@ -23,7 +23,7 @@
 //! ## Why not directly test the uppermost layer `AvroParserConfig` and `AvroAccessBuilder`?
 //!
 //! Because their interface are not clean enough, and have complex logic like schema registry.
-//! We might need to separate logic to make them clenaer and then we can use it directly for testing.
+//! We might need to separate logic to make them cleaner and then we can use it directly for testing.
 //!
 //! ## If we reimplement a similar logic here, what are we testing?
 //!

src/connector/codec/tests/integration_tests/protobuf.rs

@@ -23,8 +23,9 @@ use std::path::PathBuf;
 use anyhow::Context;
 use prost::Message;
 use prost_reflect::{DescriptorPool, DynamicMessage, MessageDescriptor};
+use risingwave_connector_codec::common::protobuf::compile_pb;
 use risingwave_connector_codec::decoder::protobuf::parser::*;
-use risingwave_connector_codec::decoder::protobuf::{compile_pb, ProtobufAccess};
+use risingwave_connector_codec::decoder::protobuf::ProtobufAccess;
 use risingwave_connector_codec::decoder::Access;
 use thiserror_ext::AsReport;
 

src/connector/src/schema/protobuf.rs

@@ -16,7 +16,7 @@ use std::collections::BTreeMap;
 use std::path::PathBuf;
 
 use prost_reflect::{DescriptorPool, FileDescriptor, MessageDescriptor};
-use risingwave_connector_codec::decoder::protobuf::compile_pb;
+use risingwave_connector_codec::common::protobuf::compile_pb;
 
 use super::loader::{LoadedSchema, SchemaLoader};
 use super::schema_registry::Subject;