Fix content type (#35)

* Fix content type

* Bump version

Cargo.toml

@@ -1,7 +1,7 @@
 [package]
 name = "ord"
 description = "◉ Ordinal wallet and block explorer"
-version = "7.1.2"
+version = "7.2.1"
 license = "CC0-1.0"
 edition = "2021"
 autotests = false

src/index/updater/inscription_updater/stream.rs

@@ -231,6 +231,30 @@ impl StreamEvent {
     Network::from_str(&env::var("NETWORK").unwrap_or("bitcoin".to_owned())).unwrap()
   }
 
+  fn is_text_related(media: Media, content_type: Option<String>) -> bool {
+    if content_type
+      .map(|ct| ct.starts_with("text/") || ct.starts_with("image/svg"))
+      .unwrap_or(false)
+    {
+      return true;
+    }
+
+    // check if inscription.media() is within a list of streamable media
+    match media {
+      Media::Text => true,
+      Media::Code => true,
+      Media::Iframe => true,
+      Media::Markdown => true,
+
+      Media::Image => false,
+      Media::Model => false,
+      Media::Pdf => false,
+      Media::Unknown => false,
+      Media::Video => false,
+      Media::Audio => false,
+    }
+  }
+
   fn enrich_content(&mut self, inscription: Inscription) -> &mut Self {
     self.metaprotocol = inscription.metaprotocol().map(|mp| mp.to_owned());
     self.metadata = inscription.metadata();
@@ -248,15 +272,9 @@ impl StreamEvent {
           .parse::<usize>()
           .unwrap();
 
-        // Text Media and Content-Type starting with "text/" are included with the content-body payload
-        let is_text = inscription.media() == Media::Text
-          || self
-            .content_type
-            .clone()
-            .map(|ct| ct.starts_with("text/") || ct.starts_with("image/svg"))
-            .unwrap_or(false);
-
-        if is_text && body.len() < kafka_body_max_bytes {
+        if Self::is_text_related(inscription.media(), self.content_type.clone())
+          && body.len() < kafka_body_max_bytes
+        {
           self.brc20 = serde_json::from_slice(body).unwrap_or(None);
           self.domain = Domain::parse(body);
           Some(general_purpose::STANDARD.encode(body))

src/subcommand/server/rpc.rs

@@ -287,7 +287,7 @@ fn get_palindromes_from_equal_length_range(start_string: String, end_string: Str
 
   let get_palindrome = |sig_digits: &str| -> u64 {
     let palindrome_string = sig_digits.to_string()
-      + &sig_digits.chars().rev().collect::<String>()[middle_digit_exists as usize..];
+      + &sig_digits.chars().rev().collect::<String>()[usize::from(middle_digit_exists)..];
     palindrome_string.parse::<u64>().unwrap()
   };