Implemented billing driver (#123)

* feat: implemented queue EOF and basic billing cli

* feat: implemented billing driver and load it from cli

* chore: added cli config file example

* chore: removed stripe config as required

* feat: added config path in cli

* feat: improved metrics collection and billing cli

* chore: adjusted lint

* chore: adjusted lint

.gitignore

@@ -1,8 +1,11 @@
 /target
 .env
 dev.db*
+dev.billing.db*
 grpcurl*
 config.toml
+config.billing.toml
+config.daemon.toml
 rpc.toml
 test/.terraform*
 test/local.tfstate*

Cargo.toml

@@ -38,6 +38,9 @@ base64 = "0.22.1"
 json-patch = "2.0.0"
 aws-config = { version = "1.5.5", features = ["behavior-version-latest"] }
 aws-sdk-sesv2 = { version = "1.43.0", features = ["behavior-version-latest"] }
+clap = { version = "4.5.17", features = ["derive", "env"] }
+comfy-table = "7.1.1"
+csv = "1.3.0"
 
 [dev-dependencies]
 mockall = "0.12.1"
@@ -50,5 +53,9 @@ path = "src/bin/daemon.rs"
 name = "rpc"
 path = "src/bin/rpc.rs"
 
+[[bin]]
+name = "cli"
+path = "src/bin/cli.rs"
+
 [lib]
 path = "src/lib.rs"

examples/README.md

@@ -13,3 +13,7 @@ Use the [rpc config](config/rpc.toml)
 It's possible to create a toml file as config and set the file path in the env `DAEMON_CONFIG`, but it's possible to set the config using the prefix `DAEMON_`
 
 Use the [daemon config](config/daemon.toml)
+
+## cli 
+
+Use the [cli config](config/cli.toml)

examples/config/cli.toml

@@ -0,0 +1,8 @@
+db_path="dev.billing.db"
+topic="events"
+
+[kafka_consumer]
+"bootstrap.servers" = "localhost:19092"
+"group.id"= "billing-stg-local-1"
+"auto.offset.reset" = "earliest"
+"enable.partition.eof" = true