Dynamodb dataloader

.vscode/settings.json

@@ -1,5 +1,5 @@
 {
   "editor.formatOnSave": true,
   "rust-analyzer.checkOnSave.command": "clippy",
-  "rust-analyzer.cargo.allFeatures": true
+  "rust-analyzer.cargo.features": "all"
 }

Cargo.toml

@@ -15,6 +15,7 @@ required-features = ["graphql"]
 [dependencies]
 anyhow = {version = "1", optional = true}
 async-graphql = {version = "4", optional = true}
+async-trait = {version = "0.1.57", optional = true}
 aws-config = {version = "0.46", optional = true}
 aws-sdk-apigateway = {version = "0.16", optional = true}
 aws-sdk-cloudformation = {version = "0.16", optional = true}
@@ -31,31 +32,47 @@ aws-sdk-sts = {version = "0.16", optional = true}
 aws-types = {version = "0.46", optional = true}
 base64 = {version = "0.13", optional = true}
 cached = {version = "0.38", optional = true}
+dataloader = {version = "0.15", optional = true, default-features = false, features = ["runtime-tokio"]}
 env_logger = {version = "0.9", optional = true}
 flate2 = {version = "1", optional = true}
+futures = {version = "0.3.23", optional = true}
 graphql_client = {version = "0.11", optional = true}
 http = {optional = true, version = "0.2.8"}
+itertools = {version = "0.10.3", optional = true}
 lazy_static = "1.4.0"
 log = {version = "0.4", optional = true}
 napi = {version = "2.4.3", default-features = false, features = ["napi4", "tokio_rt"], optional = true}
+retry = {version = "1.3.1", optional = true}
 serde = {version = "1", features = ["derive"], optional = true}
 serde_bytes = {version = "0.11", optional = true}
 serde_json = {version = "1", optional = true}
 serde_with = {version = "2", features = ["json"], optional = true}
 thiserror = {version = "1", optional = true}
+tokio = {version = "1", optional = true}
 
 [dev-dependencies]
 anyhow = "1"
 aws-config = "0.46"
 aws-sdk-dynamodb = "0.16"
 cargo-husky = {version = "1.5.0", default_features = false, features = ["precommit-hook", "run-cargo-check", "run-cargo-clippy", "run-cargo-fmt"]}
+rand = {version = "0.8.5"}
 serde_dynamo = {version = "4", features = ["aws-sdk-dynamodb+0_16"]}
 tokio = {version = "1", features = ["macros", "rt-multi-thread"]}
 
 [features]
 default = []
+dynamodb_dataloader = [
+  "services_dynamodb",
+  "dep:itertools",
+  "dep:async-trait",
+  "dep:dataloader",
+  "dep:futures",
+  "dep:retry",
+  "dep:tokio",
+  "dep:thiserror",
+]
 graphql = ["misc", "types", "base64", "aws-sdk-lambda", "serde", "serde_json", "graphql_client", "serde_with", "async-graphql"]
-misc = ["thiserror", "flate2", "base64", "env_logger", "log", "serde_bytes", "serde", "serde_json"]
+misc = ["dep:thiserror", "flate2", "base64", "env_logger", "log", "serde_bytes", "serde", "serde_json"]
 napi = ["dep:anyhow", "dep:napi"]
 services_apigateway = [
   "aws-config",
@@ -125,4 +142,4 @@ services_sts = [
   "aws-types",
   "cached",
 ]
-types = ["serde", "thiserror"]
+types = ["serde", "dep:thiserror"]