@spec apply_stream_event(
  map(),
  keyword()
) :: {:ok, term()} | {:error, term()}

@spec backfill_room(
  XmtpElixirSdk.Conversation.t(),
  keyword()
) :: {:ok, [XmtpElixirSdk.DecodedMessage.t()]} | {:error, term()}

@spec idempotency_key(
  XmtpElixirSdk.Types.Message.t()
  | XmtpElixirSdk.DecodedMessage.t()
  | map()
) ::
  String.t()

@spec message_order_key(
  XmtpElixirSdk.Types.Message.t()
  | XmtpElixirSdk.DecodedMessage.t()
  | map()
) ::
  {non_neg_integer(), String.t()}

@spec reconcile_membership(Xmtp.Room.t(), [String.t()]) :: %{
  room_key: String.t(),
  joined_inbox_ids: [String.t()]
}