diff --git a/README.md b/README.md index 9e9a81b..fe385aa 100644 --- a/README.md +++ b/README.md @@ -25,7 +25,7 @@ Add ProdopsEx to your mix.exs: ```elixir def deps do [ - {:prodops_ex, "~> 0.1.0"} + {:prodops_ex, "~> 0.2.0"} ] end ``` diff --git a/lib/prodops/config.ex b/lib/prodops/config.ex index 6ca6c7a..3fe6a1f 100644 --- a/lib/prodops/config.ex +++ b/lib/prodops/config.ex @@ -4,7 +4,7 @@ defmodule ProdopsEx.Config do @definition [ api_url: [ type: :string, - default: "https://app.prodops.ai" + default: "https://app.revelry.ai/" ], api_key: [ type: :string, diff --git a/lib/prodops/stream.ex b/lib/prodops/stream.ex index ce236cb..a6dc89e 100644 --- a/lib/prodops/stream.ex +++ b/lib/prodops/stream.ex @@ -63,9 +63,14 @@ defmodule ProdopsEx.Stream do %HTTPoison.AsyncChunk{chunk: chunk} -> data = chunk - |> String.split("\n") - |> Enum.filter(fn line -> String.starts_with?(line, "data: ") end) - |> Enum.map(fn line -> String.trim_leading(line, "data: ") end) + |> String.split("\n\n") + |> Enum.map(fn event -> + event + |> String.split("\n") + |> Enum.filter(fn line -> String.starts_with?(line, "data: ") end) + |> Enum.map_join("\n", fn line -> String.trim_leading(line, "data: ") end) + end) + |> Enum.filter(fn data -> data != "" end) HTTPoison.stream_next(res) {data, res} diff --git a/mix.exs b/mix.exs index ec4d878..5636278 100644 --- a/mix.exs +++ b/mix.exs @@ -8,7 +8,7 @@ defmodule ProdopsEx.MixProject do app: :prodops_ex, description: "An SDK for interacting with the ProdOps API", license: "MIT", - version: "0.1.0", + version: "0.2.0", elixir: "~> 1.12", deps: deps(), compilers: [:yecc, :leex] ++ Mix.compilers(),