Merge pull request #33 from splitio/development

Release v1.0.0

Author: EmilianoSanchez

.github/hooks/pre-push

@@ -0,0 +1,7 @@
+#!/bin/sh
+
+elixir scripts/validate_version.exs
+
+if [ $? -ne 0 ]; then
+    exit 1
+fi

CHANGES.txt

@@ -1,3 +1,8 @@
+1.0.0 (February 25, 2025):
+ - Fixed the SDK language version to correctly reflect the package version when it's installed from hex.pm.
+ - BREAKING CHANGES:
+    - Renamed the `:socket_path` option to `:address` in `Split.Supervisor.start_link/1`.
+
 0.2.0 (February 14, 2025):
  - Added new variations of the get treatment functions to support evaluating flags in given flag set/s: `Split.get_treatments_by_flag_set/3`, `Split.get_treatments_by_flag_sets/3`, `Split.get_treatments_with_config_by_flag_set/3`, and `Split.get_treatments_with_config_by_flag_sets/3`.
  - Updated the `:socket_path` option for `Split.Supervisor.start_link/1` to be optional, defaulting to `"/var/run/splitd.sock"`.

README.md

@@ -1,6 +1,6 @@
 # Split SDK for Elixir
 
-[![hex.pm version](https://img.shields.io/hexpm/v/split_thin_sdk)](https://img.shields.io/hexpm/v/split_thin_sdk) [![Build Status](https://github.com/splitio/elixir-thin-client/actions/workflows/ci-cd.yml/badge.svg)](https://github.com/splitio/elixir-thin-client/actions/workflows/ci-cd.yml) [![Greenkeeper badge](https://badges.greenkeeper.io/splitio/elixir-thin-client.svg)](https://greenkeeper.io/)
+[![hex.pm version](https://img.shields.io/hexpm/v/split_thin_sdk)](https://img.shields.io/hexpm/v/split_thin_sdk) [![Build Status](https://github.com/splitio/elixir-thin-client/actions/workflows/ci.yml/badge.svg)](https://github.com/splitio/elixir-thin-client/actions/workflows/ci-cd.yml) [![Greenkeeper badge](https://badges.greenkeeper.io/splitio/elixir-thin-client.svg)](https://greenkeeper.io/)
 
 ## Overview
 This SDK is designed to work with Split, the platform for controlled rollouts, which serves features to your users via feature flags to manage your complete customer experience.
@@ -36,7 +36,7 @@ Below is a simple example that describes the instantiation and most basic usage
 
 ```elixir
 # Start the SDK supervisor
-Split.Supervisor.start_link(socket_path: "/var/run/splitd.sock")
+Split.Supervisor.start_link(address: "/var/run/splitd.sock")
 
 # Get treatment for a user
 case Split.get_treatment(user_id, feature_flag_name) do

lib/split.ex

@@ -16,7 +16,7 @@ defmodule Split do
         def start(_type, _args) do
           children = [
             # ... other children ...
-            {Split, [socket_path: "/var/run/split.sock"]}
+            {Split, [address: "/var/run/split.sock"]}
           ]
 
           opts = [strategy: :one_for_one, name: MyApp.Supervisor]
@@ -32,7 +32,7 @@ defmodule Split do
 
   `Split` takes a number of keyword arguments as options when starting. The following options are available:
 
-  - `:socket_path`: **OPTIONAL** The path to the splitd socket file. Default is `"/var/run/splitd.sock"`.
+  - `:address`: **OPTIONAL** The path to the splitd socket file. Default is `"/var/run/splitd.sock"`.
   - `:pool_size`: **OPTIONAL** The size of the pool of connections to the splitd daemon. Default is the number of online schedulers in the Erlang VM (See: https://www.erlang.org/doc/apps/erts/erl_cmd.html).
   - `:connect_timeout`: **OPTIONAL** The timeout in milliseconds to connect to the splitd daemon. Default is `1000`.
 
@@ -52,7 +52,7 @@ defmodule Split do
 
   @typedoc "An option that can be provided when starting `Split`. See [options](#module-options) for more information."
   @type option ::
-          {:socket_path, String.t()}
+          {:address, String.t()}
           | {:pool_size, non_neg_integer()}
           | {:connect_timeout, non_neg_integer()}
 

lib/split/rpc/message.ex

@@ -5,7 +5,7 @@ defmodule Split.RPC.Message do
   use Split.RPC.Opcodes
 
   @protocol_version 0x01
-  @client_id "Splitd_Elixir-" <> to_string(Application.spec(:split, :vsn))
+  @client_id "Splitd_Elixir-1.0.0"
 
   @type opcode :: unquote(Enum.reduce(@opcodes, &{:|, [], [&1, &2]}))
   @type protocol_version :: unquote(@protocol_version)
@@ -37,7 +37,7 @@ defmodule Split.RPC.Message do
   ## Examples
 
       iex> Message.register()
-      %Message{v: 1, o: 0, a: ["123", "Splitd_Elixir-", 1]}
+      %Message{v: 1, o: 0, a: ["123", "Splitd_Elixir-1.0.0", 1]}
   """
   @spec register() :: t()
   def register, do: %__MODULE__{o: @register_opcode, a: ["123", @client_id, 1]}

lib/split/sockets/conn.ex

@@ -9,13 +9,13 @@ defmodule Split.Sockets.Conn do
 
   @type t :: %__MODULE__{
           socket: port() | nil,
-          socket_path: String.t(),
+          address: String.t(),
           opts: keyword()
         }
 
   defstruct [
     :socket,
-    :socket_path,
+    :address,
     :opts
   ]
 
@@ -31,20 +31,20 @@ defmodule Split.Sockets.Conn do
   @default_rcv_timeout 1000
 
   @spec new(String.t(), keyword()) :: t
-  def new(socket_path, opts \\ []) do
+  def new(address, opts \\ []) do
     %__MODULE__{
       socket: nil,
-      socket_path: socket_path,
+      address: address,
       opts: opts
     }
   end
 
   @spec connect(t) :: {:ok, t()} | {:error, t(), term()}
-  def connect(%__MODULE__{socket: nil, socket_path: socket_path, opts: opts} = conn) do
+  def connect(%__MODULE__{socket: nil, address: address, opts: opts} = conn) do
     connect_timeout = Keyword.get(opts, :connect_timeout, @default_connect_timeout)
 
-    Telemetry.span(:connect, %{socket_path: socket_path, pool_name: opts[:pool_name]}, fn ->
-      case :gen_tcp.connect({:local, socket_path}, 0, @connect_opts, connect_timeout) do
+    Telemetry.span(:connect, %{address: address, pool_name: opts[:pool_name]}, fn ->
+      case :gen_tcp.connect({:local, address}, 0, @connect_opts, connect_timeout) do
         {:ok, socket} ->
           conn = %{conn | socket: socket}
 

lib/split/sockets/pool.ex

@@ -17,13 +17,13 @@ defmodule Split.Sockets.Pool do
   end
 
   def start_link(opts) do
-    socket_path = Keyword.get(opts, :socket_path, "/var/run/splitd.sock")
+    address = Keyword.get(opts, :address, "/var/run/splitd.sock")
     pool_name = Keyword.get(opts, :pool_name, __MODULE__)
     pool_size = Keyword.get(opts, :pool_size, System.schedulers_online())
 
     opts =
       opts
-      |> Keyword.put_new(:socket_path, socket_path)
+      |> Keyword.put_new(:address, address)
       |> Keyword.put_new(:pool_size, pool_size)
       |> Keyword.put_new(:pool_name, pool_name)
 
@@ -100,11 +100,11 @@ defmodule Split.Sockets.Pool do
 
   @impl NimblePool
   def init_pool(opts) do
-    socket_path = Keyword.get(opts, :socket_path)
+    address = Keyword.get(opts, :address)
 
-    unless File.exists?(socket_path) do
+    unless File.exists?(address) do
       Logger.error("""
-      The Split Daemon (splitd) socket was not found at #{socket_path}.
+      The Split Daemon (splitd) socket was not found at address #{address}.
 
       This is likely because the Splitd daemon is not running.
       """)
@@ -117,7 +117,7 @@ defmodule Split.Sockets.Pool do
 
   @impl NimblePool
   def init_worker({opts, _metrics_ref} = pool_state) do
-    {:ok, Conn.new(Keyword.get(opts, :socket_path), opts), pool_state}
+    {:ok, Conn.new(Keyword.get(opts, :address), opts), pool_state}
   end
 
   @impl NimblePool

lib/split/telemetry.ex

@@ -100,7 +100,7 @@ defmodule Split.Telemetry do
 
   #### Metadata
 
-    * `socket_path` - The path to the socket file.
+    * `address` - The path to the socket file.
     * `pool_name` - The name of the pool being used.
 
   ### Connect Stop
@@ -114,7 +114,7 @@ defmodule Split.Telemetry do
 
   #### Metadata
 
-    * `socket_path` - The path to the socket file.
+    * `address` - The path to the socket file.
     * `pool_name` - The name of the pool being used.
     * `error` - The error message if the connection fails.
 

mix.exs

@@ -4,7 +4,7 @@ defmodule SplitThinElixir.MixProject do
   def project do
     [
       app: :split,
-      version: "0.2.0",
+      version: "1.0.0",
       elixir: "~> 1.14",
       elixirc_paths: elixirc_paths(Mix.env()),
       start_permanent: Mix.env() == :prod,

scripts/validate_version.exs

@@ -0,0 +1,22 @@
+#!/usr/bin/env elixir
+
+# Read mix.exs version
+{:ok, mix_content} = File.read("mix.exs")
+version = Regex.run(~r/version: "([^"]+)"/, mix_content)
+|> Enum.at(1)
+
+# Read message.ex @client_id
+{:ok, message_content} = File.read("lib/split/rpc/message.ex")
+client_id_version = Regex.run(~r/@client_id "Splitd_Elixir-([^"]+)"/, message_content)
+|> Enum.at(1)
+
+if version != client_id_version do
+  IO.puts :stderr, """
+  Error: Version mismatch!
+  mix.exs version: #{version}
+  message.ex @client_id version: #{client_id_version}
+
+  Please update the @client_id in lib/split/rpc/message.ex to match the version in mix.exs
+  """
+  System.halt(1)
+end