Refiner-DTM-RC:v0.5.5

.github/dependabot.yml

@@ -17,6 +17,7 @@ updates:
     directory: "/"
     schedule:
       interval: "weekly"
+    target-branch: "develop"
     reviewers:
       - "noslav"
-      - "rogarcia"
+      - "rogarcia"

.github/workflows/tag-release.yaml

@@ -25,7 +25,7 @@ jobs:
 
       - name: Build & Publish the Docker image
         run: |
-          docker buildx create --name builder --use --platform=linux/amd64,linux/arm64 && docker buildx build --platform=linux/amd64,linux/arm64 . -t us-docker.pkg.dev/covalent-project/network/refiner:stable -t us-docker.pkg.dev/covalent-project/network/refiner:"${{ env.TAG }}" --push
+          docker buildx create --name builder --use --platform=linux/amd64 && docker buildx build --platform=linux/amd64 . -t us-docker.pkg.dev/covalent-project/network/refiner:stable -t us-docker.pkg.dev/covalent-project/network/refiner:"${{ env.TAG }}" --push
 
       - uses: "marvinpinto/action-automatic-releases@latest"
         with:

lib/refiner/ipfs/ipfs_interactor.ex

@@ -1,9 +1,12 @@
 defmodule Refiner.IPFSInteractor do
   use GenServer
+  use Tesla
 
   alias Multipart.Part
   alias Refiner.Events
 
+  plug(Tesla.Middleware.JSON)
+
   require Logger
 
   @spec start_link([
@@ -27,20 +30,19 @@ defmodule Refiner.IPFSInteractor do
   def handle_call({:pin, file_path}, _from, state) do
     start_pin_ms = System.monotonic_time(:millisecond)
     ipfs_url = Application.get_env(:refiner, :ipfs_pinner_url)
-    url = "#{ipfs_url}/upload"
-
-    multipart = Multipart.new() |> Multipart.add_part(Part.file_body(file_path))
-    body_stream = Multipart.body_stream(multipart)
-    content_length = Multipart.content_length(multipart)
-    content_type = Multipart.content_type(multipart, "multipart/form-data")
-    headers = [{"Content-Type", content_type}, {"Content-Length", to_string(content_length)}]
-
-    resp =
-      Finch.build("POST", url, headers, {:stream, body_stream})
-      |> Finch.request(Refiner.Finch)
 
-    case resp do
-      {:ok, %Finch.Response{body: body, headers: _, status: _}} ->
+    # Create a multipart request
+    multipart =
+      Tesla.Multipart.new()
+      |> Tesla.Multipart.add_file(file_path,
+        filename: Path.basename(file_path),
+        headers: [
+          {"Content-Type", "multipart/form-data"}
+        ]
+      )
+
+    case post("#{ipfs_url}/upload", multipart) do
+      {:ok, %Tesla.Env{body: body, headers: _, status: _}} ->
         body_map = body |> Poison.decode!()
 
         end_pin_ms = System.monotonic_time(:millisecond)

mix.exs

@@ -4,7 +4,7 @@ defmodule Refiner.MixProject do
   def project do
     [
       app: :refiner,
-      version: "0.5.2",
+      version: "0.5.5",
       elixir: "~> 1.17.1",
       start_permanent: Mix.env() == :prod,
       deps: deps(),
@@ -63,7 +63,7 @@ defmodule Refiner.MixProject do
       # networking
       {:certifi, "~> 2.9", override: true},
       {:cors_plug, "~> 3.0"},
-      {:finch, "~> 0.18.0"},
+      {:finch, "~> 0.19.0"},
       {:downstream, "~> 1.0"},
       {:websockex, "~> 0.4.3"},
       {:multipart, "~> 0.4.0"},
@@ -81,14 +81,18 @@ defmodule Refiner.MixProject do
       {:etfs, "~> 0.2.0"},
 
       # tracing metrics
-      {:telemetry, "~> 1.2.1", override: true},
+      {:telemetry, "~> 1.3.0", override: true},
       {:telemetry_metrics, "~> 0.3.0"},
       {:telemetry_metrics_prometheus, "~> 0.3.1"},
       {:telemetry_metrics_prometheus_core, "~>0.2.2"},
 
       # utils
       {:briefly, "~> 0.5.0"},
-      {:rustler, ">= 0.0.0", optional: true}
+      {:rustler, ">= 0.0.0", optional: true},
+
+      # Tesla for multipart
+      {:tesla, "~> 1.12"},
+      {:hackney, "~> 1.17"}
 
       # Unused
       # {:erlexec, "~> 2.0"},