Merge pull request #83 from golemcloud/error-serialization-fix

GOL-184 Tests and fixes for oplog error serialization

Author: vigoo

Cargo.lock

@@ -66,6 +66,7 @@ lazy_static = "1.4.0"
 poem = "2.0.0"
 poem-openapi = { version = "4.0.0", features = ["swagger-ui", "chrono", "time", "humantime", "uuid", "url", "websocket"] }
 prometheus = { version = "0.13.3", features = ["process"] }
+proptest = "1.4.0"
 prost = "0.12.3"
 rustls = { version = "0.22.2" }
 serde = { version = "1.0", features = ["derive"] }

Cargo.toml

@@ -26,4 +26,4 @@ tracing = { workspace = true }
 url = { workspace = true }
 
 [dev-dependencies]
-proptest = "1.4.0"
+proptest = { workspace = true }

golem-service-base/Cargo.toml

@@ -80,6 +80,7 @@ console-subscriber = { workspace = true }
 ctor = "0.2.6"
 fred = { workspace = true, features = ["metrics", "serde-json", "partial-tracing", "mocks"] }
 golem-wasm-ast = { workspace = true }
+proptest = { workspace = true }
 redis = { version = "0.24.0", features = ["default"] }
 serde_json = { workspace = true }
 tracing-subscriber = { workspace = true }

golem-worker-executor-base/Cargo.toml

@@ -6,7 +6,8 @@ use wasmtime_wasi::preview2::WasiView;
 use crate::durable_host::blobstore::types::{
     ContainerEntry, IncomingValueEntry, OutgoingValueEntry, StreamObjectNamesEntry,
 };
-use crate::durable_host::{Durability, DurableWorkerCtx, SerializableError};
+use crate::durable_host::serialized::SerializableError;
+use crate::durable_host::{Durability, DurableWorkerCtx};
 use crate::metrics::wasm::record_host_function_call;
 use crate::preview2::wasi::blobstore::container::{
     Container, ContainerMetadata, Error, Host, HostContainer, HostStreamObjectNames, IncomingValue,

golem-worker-executor-base/src/durable_host/blobstore/container.rs

@@ -7,7 +7,8 @@ use wasmtime::component::Resource;
 use wasmtime_wasi::preview2::WasiView;
 
 use crate::durable_host::blobstore::types::ContainerEntry;
-use crate::durable_host::{Durability, DurableWorkerCtx, SerializableError};
+use crate::durable_host::serialized::SerializableError;
+use crate::durable_host::{Durability, DurableWorkerCtx};
 use crate::metrics::wasm::record_host_function_call;
 use crate::preview2::wasi::blobstore::blobstore::{
     Container, ContainerName, Error, Host, ObjectId,

golem-worker-executor-base/src/durable_host/blobstore/mod.rs

@@ -1,6 +1,7 @@
 use async_trait::async_trait;
 
-use crate::durable_host::{Durability, DurableWorkerCtx, SerializableError};
+use crate::durable_host::serialized::SerializableError;
+use crate::durable_host::{Durability, DurableWorkerCtx};
 use crate::metrics::wasm::record_host_function_call;
 use crate::workerctx::WorkerCtx;
 use golem_common::model::WrappedFunctionType;

golem-worker-executor-base/src/durable_host/cli/environment.rs

@@ -1,7 +1,8 @@
 use async_trait::async_trait;
 use wasmtime::component::Resource;
 
-use crate::durable_host::{Durability, DurableWorkerCtx, SerializableError};
+use crate::durable_host::serialized::SerializableError;
+use crate::durable_host::{Durability, DurableWorkerCtx};
 use crate::metrics::wasm::record_host_function_call;
 use crate::workerctx::WorkerCtx;
 use golem_common::model::WrappedFunctionType;

golem-worker-executor-base/src/durable_host/clocks/monotonic_clock.rs

@@ -1,6 +1,7 @@
 use async_trait::async_trait;
 
-use crate::durable_host::{Durability, DurableWorkerCtx, SerializableDateTime, SerializableError};
+use crate::durable_host::serialized::{SerializableDateTime, SerializableError};
+use crate::durable_host::{Durability, DurableWorkerCtx};
 use crate::metrics::wasm::record_host_function_call;
 use crate::workerctx::WorkerCtx;
 use golem_common::model::WrappedFunctionType;

golem-worker-executor-base/src/durable_host/clocks/wall_clock.rs

@@ -2,7 +2,8 @@ use anyhow::anyhow;
 use async_trait::async_trait;
 use wasmtime::component::Resource;
 
-use crate::durable_host::{Durability, DurableWorkerCtx, SerializableError};
+use crate::durable_host::serialized::SerializableError;
+use crate::durable_host::{Durability, DurableWorkerCtx};
 use crate::metrics::wasm::record_host_function_call;
 use crate::workerctx::WorkerCtx;
 use golem_common::model::WrappedFunctionType;