Changelog

All notable changes to this project will be documented in this file.

The format is based on Keep a Changelog, and this project adheres to Semantic Versioning.

[0.4.0] - 2026-03-24

Breaking Changes

All error returns now use %PubsubGrpc.Error{} struct instead of raw %GRPC.RPCError{}
- Pattern match on error.code atoms: :not_found, :already_exists, :unauthenticated, etc.
- Original gRPC error preserved in error.details for migration
PubsubGrpc.Auth.request_opts/0 now returns {:ok, opts} | {:error, %Error{}} instead of bare list
Removed deprecated 2-arity Client.execute/2 (use 1-arity operation functions)
Schema type/view enum helpers now return errors for invalid values instead of silently defaulting
Input validation added to all public functions — invalid inputs return {:error, %Error{code: :validation_error}}

Added

PubsubGrpc.Error — structured error type with code, message, details, and gRPC status
PubsubGrpc.Validation — input validation for all parameters (project IDs, topic IDs, messages, ack IDs, deadlines, etc.)
New API functions:
- get_topic/2 — get topic details
- get_subscription/2 — get subscription details
- list_subscriptions/2 — list subscriptions in a project
- modify_ack_deadline/4 — modify ack deadline for messages
- nack/3 — negatively acknowledge messages (immediate redelivery)
- validate_message/4 — validate message against existing schema
- validate_message_with_schema/5 — validate message against inline schema definition
Auth token caching — ETS-based cache with TTL, avoids re-fetching on every request
Per-request timeouts — configurable via :default_timeout app env (default: 30s)
Logging — Logger warnings/errors for auth failures, config fallbacks
Typespecs on all public functions
Unit tests for Error, Validation, and Auth modules
Validation integration tests (no emulator needed)
Integration tests for all new API functions

Fixed

Silent authentication failures now log warnings and return proper error tuples
Empty message list no longer silently sent to server (validated)
Empty ack_ids list no longer silently sent to server (validated)
Application config fallback now logs warning instead of failing silently
Dead code removed from Client module (2-arity execute with unused pool logic)

Migration Guide

# Before (v0.3.x)
case PubsubGrpc.create_topic("proj", "topic") do
  {:ok, topic} -> topic
  {:error, %GRPC.RPCError{status: 6}} -> "exists"
end

# After (v0.4.0)
case PubsubGrpc.create_topic("proj", "topic") do
  {:ok, topic} -> topic
  {:error, %PubsubGrpc.Error{code: :already_exists}} -> "exists"
  {:error, %PubsubGrpc.Error{code: :validation_error} = err} -> "invalid: #{err}"
end

# Auth.request_opts/0 now returns {:ok, opts}
{:ok, opts} = PubsubGrpc.Auth.request_opts()
# or in emulator mode: {:ok, []}

[0.3.1] - 2025-11-21

Fixed

Critical fix: Resolved FunctionClauseError during GRPC connection termination in grpc_connection_pool worker
- Modified worker cleanup logic to handle Gun-based connections safely
- Bypasses problematic pattern matching in GRPC v0.11.5's disconnect handling
- Prevents GenServer crashes with error: no function clause matching in anonymous fn/1 in GRPC.Client.Connection.handle_call/3
Improved connection pool stability during shutdown and restart cycles

Added

Comprehensive tests for disconnect behavior and connection pool lifecycle
Integration tests verifying graceful pool shutdown without errors

[0.3.0] - 2025-01-21

Changed

BREAKING: Updated grpc_connection_pool dependency from 0.1.3 to 0.1.5
- New architecture uses DynamicSupervisor with Registry-based health tracking
- Round-robin channel distribution without checkout/checkin overhead
- Improved connection reliability with exponential backoff and jitter
Upgraded grpc library from 0.10.2 to 0.11.5
Added GRPC.Client.Supervisor to application supervision tree (required by grpc 0.11.5)

Internal

Updated PubsubGrpc.Client.execute/2 to use new GrpcConnectionPool.get_channel/1 API
Improved test initialization sequence to ensure emulator is ready before pool connections
Updated tests to work with new pool architecture

Migration Notes

No changes required to public API - all existing code continues to work
Pool process name changed from PubsubGrpc.ConnectionPool to PubsubGrpc.ConnectionPool.Supervisor
Connection establishment is now asynchronous with automatic retry on failure

[0.2.5] - 2025-01-XX

Previous release with grpc_connection_pool 0.1.3

← Previous Page PubsubGrpc