fix: special use of das-metadata-json in triton-build

Cargo.toml

@@ -7,6 +7,7 @@ members = [
   "digital_asset_types",
   "integration_tests",
   "metaplex-rpc-proxy",
+  "metadata_json",
   "migration",
   "nft_ingester",
   "ops",
@@ -48,6 +49,7 @@ cargo-lock = "9.0.0"
 chrono = "0.4.19"
 clap = "4.2.2"
 das-core = { path = "core" }
+das-metadata-json = { path = "metadata_json" }
 das-backfill = { path = "backfill" }
 das_api = { path = "das_api" }
 derive_more = { version = "0.99.17" }

core/src/metadata_json.rs

@@ -53,7 +53,7 @@ pub async fn create_download_metadata_notifier(
     })
 }
 
-#[derive(Parser, Clone, Debug)]
+#[derive(Parser, Clone, Debug, PartialEq, Eq)]
 pub struct MetadataJsonDownloadWorkerArgs {
     /// The number of worker threads
     #[arg(long, env, default_value = "25")]

grpc-ingest/src/ingester.rs

@@ -1,7 +1,7 @@
 use {
     crate::{
         config::{ConfigIngester, ConfigIngesterDownloadMetadata},
-        download_metadata::{TASK_TYPE},
+        download_metadata::TASK_TYPE,
         postgres::{create_pool as pg_create_pool, metrics_pgpool},
         prom::{
             download_metadata_inserted_total_inc, program_transformer_task_status_inc,
@@ -16,10 +16,7 @@ use {
     },
     chrono::Utc,
     crypto::{digest::Digest, sha2::Sha256},
-    das_core::{
-        DownloadMetadata, DownloadMetadataInfo,
-        DownloadMetadataNotifier,
-    },
+    das_core::{DownloadMetadata, DownloadMetadataInfo, DownloadMetadataNotifier},
     digital_asset_types::dao::{sea_orm_active_enums::TaskStatus, tasks},
     futures::{
         future::{pending, BoxFuture, FusedFuture, FutureExt},
@@ -203,8 +200,6 @@ pub async fn run_v2(config: ConfigIngester) -> anyhow::Result<()> {
                             } else {
                                 debug!("Message acknowledged successfully");
                             }
-
-
                         }
                     }
                 }

metadata_json/src/cmds/backfill.rs

@@ -30,9 +30,9 @@ pub struct BackfillArgs {
 pub async fn run(args: BackfillArgs) -> Result<(), anyhow::Error> {
     let batch_size = args.batch_size;
 
-    let pool = connect_db(args.database).await?;
+    let pool = connect_db(&args.database).await?;
 
-    setup_metrics(args.metrics)?;
+    setup_metrics(&args.metrics)?;
 
     let client = ClientBuilder::new()
         .timeout(Duration::from_millis(args.timeout))

metadata_json/src/cmds/ingest.rs

@@ -27,9 +27,9 @@ pub struct IngestArgs {
 pub async fn run(args: IngestArgs) -> Result<(), anyhow::Error> {
     let rx = Receiver::try_from_config(args.receiver.into()).await?;
 
-    let pool = connect_db(args.database).await?;
+    let pool = connect_db(&args.database).await?;
 
-    setup_metrics(args.metrics)?;
+    setup_metrics(&args.metrics)?;
 
     let client = ClientBuilder::new()
         .timeout(Duration::from_millis(args.timeout))

metadata_json/src/cmds/report.rs

@@ -21,9 +21,9 @@ pub struct ReportArgs {
 }
 
 pub async fn run(args: ReportArgs) -> Result<(), anyhow::Error> {
-    let pool = connect_db(args.database).await?;
+    let pool = connect_db(&args.database).await?;
 
-    setup_metrics(args.metrics)?;
+    setup_metrics(&args.metrics)?;
 
     loop {
         {

metadata_json/src/cmds/single.rs

@@ -20,9 +20,9 @@ pub struct SingleArgs {
 }
 
 pub async fn run(args: SingleArgs) -> Result<(), anyhow::Error> {
-    let pool = connect_db(args.database).await?;
+    let pool = connect_db(&args.database).await?;
 
-    setup_metrics(args.metrics)?;
+    setup_metrics(&args.metrics)?;
 
     let asset_data = bs58::decode(args.mint.as_str()).into_vec()?;
 

nft_ingester/Cargo.toml

@@ -15,6 +15,7 @@ cadence-macros = { workspace = true }
 chrono = { workspace = true }
 clap = { workspace = true, features = ["derive", "cargo"] }
 das-core = { workspace = true }
+das-metadata-json = { workspace = true }
 digital_asset_types = { workspace = true, features = [
   "json_types",
   "sql_types",