update spear to v0.9.0 with ack/nack fix on projected streams

CHANGELOG.md

@@ -6,6 +6,13 @@ The format is based on [Keep a
 Changelog](https://keepachangelog.com/en/1.0.0/), and this project adheres to
 [Semantic Versioning](https://semver.org/spec/v2.0.0.html).
 
+## 0.1.2 - 2021-04-29
+
+### Changed
+
+- Updated Spear dependency to v0.9.0 with fixes for persistent subscription
+  ack/nack on projected streams
+
 ## 0.1.1 - 2021-04-28
 
 ### Changed

lib/volley/persistent_subscription/acknowledger.ex

@@ -15,8 +15,8 @@ if_broadway do
 
     @impl Broadway.Acknowledger
     def ack(subscription, successful_messages, failed_messages) do
-      successful_ids = Enum.map(successful_messages, & &1.data.id)
-      failed_ids = Enum.map(failed_messages, & &1.data.id)
+      successful_ids = Enum.map(successful_messages, &Spear.Event.id(&1.data))
+      failed_ids = Enum.map(failed_messages, &Spear.Event.id(&1.data))
 
       Spear.ack(subscription.connection, subscription.ref, successful_ids)
 

mix.exs

@@ -44,7 +44,7 @@ defmodule Volley.MixProject do
 
   defp deps do
     [
-      {:spear, "~> 0.6"},
+      {:spear, "~> 0.9"},
       {:gen_stage, "~> 1.0"},
       {:broadway, "~> 0.6", optional: true},
       # docs

mix.lock

@@ -22,7 +22,7 @@
   "mint": {:hex, :mint, "1.2.1", "369cc8fecc54afd170e11740aa7efd066709e5ef3b5a2c63f0a47d1542cbd56a", [:mix], [{:castore, "~> 0.1.0", [hex: :castore, repo: "hexpm", optional: true]}], "hexpm", "053fe2f48c965f31878a16272478d9299fa412bc4df86dee2678986f2e40e018"},
   "nimble_parsec": {:hex, :nimble_parsec, "1.1.0", "3a6fca1550363552e54c216debb6a9e95bd8d32348938e13de5eda962c0d7f89", [:mix], [], "hexpm", "08eb32d66b706e913ff748f11694b17981c0b04a33ef470e33e11b3d3ac8f54b"},
   "parse_trans": {:hex, :parse_trans, "3.3.1", "16328ab840cc09919bd10dab29e431da3af9e9e7e7e6f0089dd5a2d2820011d8", [:rebar3], [], "hexpm", "07cd9577885f56362d414e8c4c4e6bdf10d43a8767abb92d24cbe8b24c54888b"},
-  "spear": {:hex, :spear, "0.8.0", "058cb32ef682e46373e2164d72350ec944a5d5128dc9772d9b32993edaa08fb2", [:mix], [{:connection, "~> 1.0", [hex: :connection, repo: "hexpm", optional: false]}, {:gpb, "~> 4.0", [hex: :gpb, repo: "hexpm", optional: false]}, {:jason, ">= 0.0.0", [hex: :jason, repo: "hexpm", optional: true]}, {:mint, "~> 1.0", [hex: :mint, repo: "hexpm", optional: false]}], "hexpm", "9de62dc914bd1ebd4fc0ddd5e78d5fa9e7d84985c45eeb6c1b164281d60af1c1"},
+  "spear": {:hex, :spear, "0.9.0", "85912a458790ca39f1a015754344f746f4c9a6faff1497d3c8d908911a7e0443", [:mix], [{:connection, "~> 1.0", [hex: :connection, repo: "hexpm", optional: false]}, {:gpb, "~> 4.0", [hex: :gpb, repo: "hexpm", optional: false]}, {:jason, ">= 0.0.0", [hex: :jason, repo: "hexpm", optional: true]}, {:mint, "~> 1.0", [hex: :mint, repo: "hexpm", optional: false]}], "hexpm", "375cf24c0d722b6848445245c02a136f6dabe8425f45905f509bd56032633f3c"},
   "ssl_verify_fun": {:hex, :ssl_verify_fun, "1.1.6", "cf344f5692c82d2cd7554f5ec8fd961548d4fd09e7d22f5b62482e5aeaebd4b0", [:make, :mix, :rebar3], [], "hexpm", "bdb0d2471f453c88ff3908e7686f86f9be327d065cc1ec16fa4540197ea04680"},
   "telemetry": {:hex, :telemetry, "0.4.3", "a06428a514bdbc63293cd9a6263aad00ddeb66f608163bdec7c8995784080818", [:rebar3], [], "hexpm", "eb72b8365ffda5bed68a620d1da88525e326cb82a75ee61354fc24b844768041"},
   "unicode_util_compat": {:hex, :unicode_util_compat, "0.7.0", "bc84380c9ab48177092f43ac89e4dfa2c6d62b40b8bd132b1059ecc7232f9a78", [:rebar3], [], "hexpm", "25eee6d67df61960cf6a794239566599b09e17e668d3700247bc498638152521"},