Skip to content
Open
Show file tree
Hide file tree
Changes from all commits
Commits
File filter

Filter by extension

Filter by extension


Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
2 changes: 1 addition & 1 deletion Gemfile
Original file line number Diff line number Diff line change
@@ -1,3 +1,3 @@
source 'https://rubygems.org'
source "https://rubygems.org"

gemspec
4 changes: 2 additions & 2 deletions init.rb
Original file line number Diff line number Diff line change
@@ -1,3 +1,3 @@
require_relative './load_path'
require_relative "./load_path"

require 'messaging'
require "messaging"
36 changes: 18 additions & 18 deletions lib/messaging.rb
Original file line number Diff line number Diff line change
@@ -1,25 +1,25 @@
require 'message_store'
require 'settings'
require "message_store"
require "settings"

require 'messaging/log'
require "messaging/log"

require 'messaging/stream_name'
require "messaging/stream_name"

require 'messaging/message'
require 'messaging/message/metadata'
require 'messaging/message/copy'
require 'messaging/message/follow'
require 'messaging/message/sequence_accessor'
require "messaging/message"
require "messaging/message/metadata"
require "messaging/message/copy"
require "messaging/message/follow"
require "messaging/message/sequence_accessor"

require 'messaging/message/transform'
require 'messaging/message/import'
require 'messaging/message/export'
require "messaging/message/transform"
require "messaging/message/import"
require "messaging/message/export"

require 'messaging/category'
require "messaging/category"

require 'messaging/write'
require 'messaging/write/substitute'
require "messaging/write"
require "messaging/write/substitute"

require 'messaging/message_registry'
require 'messaging/handle'
require 'messaging/handle/defaults'
require "messaging/message_registry"
require "messaging/handle"
require "messaging/handle/defaults"
32 changes: 16 additions & 16 deletions lib/messaging/controls.rb
Original file line number Diff line number Diff line change
@@ -1,18 +1,18 @@
require 'securerandom'
require "securerandom"

require 'clock/controls'
require 'message_store/controls'
require "clock/controls"
require "message_store/controls"

require 'messaging/controls/random'
require 'messaging/controls/time'
require 'messaging/controls/id'
require 'messaging/controls/stream_name'
require 'messaging/controls/properties'
require 'messaging/controls/local_properties'
require 'messaging/controls/metadata'
require 'messaging/controls/message_data'
require 'messaging/controls/message'
require 'messaging/controls/batch'
require 'messaging/controls/write'
require 'messaging/controls/settings'
require 'messaging/controls/handler'
require "messaging/controls/random"
require "messaging/controls/time"
require "messaging/controls/id"
require "messaging/controls/stream_name"
require "messaging/controls/properties"
require "messaging/controls/local_properties"
require "messaging/controls/metadata"
require "messaging/controls/message_data"
require "messaging/controls/message"
require "messaging/controls/batch"
require "messaging/controls/write"
require "messaging/controls/settings"
require "messaging/controls/handler"
8 changes: 4 additions & 4 deletions lib/messaging/controls/handler.rb
Original file line number Diff line number Diff line change
Expand Up @@ -10,7 +10,7 @@ class Example
include Controls::Message

handle SomeMessage do |some_message|
some_message.some_attribute = 'some value set by handler'
some_message.some_attribute = "some value set by handler"
end
end

Expand All @@ -24,7 +24,7 @@ def handle(message_data)
end

def self.data
{ attribute: 'some value set by handle method' }
{ attribute: "some value set by handle method" }
end
end

Expand All @@ -44,11 +44,11 @@ class Example
include Controls::Message

handle SomeMessage do |some_message|
some_message.some_attribute = 'some attribute value set by handler'
some_message.some_attribute = "some attribute value set by handler"
end

def handle(message_data)
message_data.data = { attribute: 'some data value set by handler' }
message_data.data = { attribute: "some data value set by handler" }
end
end
end
Expand Down
2 changes: 1 addition & 1 deletion lib/messaging/controls/local_properties.rb
Original file line number Diff line number Diff line change
Expand Up @@ -13,7 +13,7 @@ def self.name
end

def self.value
'some local property value'
"some local property value"
end
end

Expand Down
6 changes: 3 additions & 3 deletions lib/messaging/controls/message.rb
Original file line number Diff line number Diff line change
Expand Up @@ -67,15 +67,15 @@ def self.id
end

def self.type
'SomeMessage'
"SomeMessage"
end

def self.attribute
'some value'
"some value"
end

def self.other_attribute
'other value'
"other value"
end

def self.data
Expand Down
4 changes: 2 additions & 2 deletions lib/messaging/controls/metadata.rb
Original file line number Diff line number Diff line change
Expand Up @@ -8,7 +8,7 @@ def self.example
end

def self.stream_name
'someSource'
"someSource"
end

def self.position
Expand Down Expand Up @@ -40,7 +40,7 @@ def self.reply_stream_name
end

def self.schema_version
'1.1'
"1.1"
end

def self.identifier
Expand Down
2 changes: 1 addition & 1 deletion lib/messaging/controls/properties.rb
Original file line number Diff line number Diff line change
Expand Up @@ -13,7 +13,7 @@ def self.name
end

def self.value
'some property value'
"some property value"
end
end

Expand Down
4 changes: 2 additions & 2 deletions lib/messaging/controls/settings.rb
Original file line number Diff line number Diff line change
Expand Up @@ -7,8 +7,8 @@ def self.example

def self.data
{
some_setting: 'some setting value',
some_other_setting: 'some other setting value'
some_setting: "some setting value",
some_other_setting: "some other setting value"
}
end
end
Expand Down
10 changes: 5 additions & 5 deletions lib/messaging/handle/defaults.rb
Original file line number Diff line number Diff line change
Expand Up @@ -2,7 +2,7 @@ module Messaging
module Handle
module Defaults
def self.strict
Strict.get == 'on'
Strict.get == "on"
end

module Strict
Expand All @@ -15,20 +15,20 @@ def self.set(val)
end

def self.env_var
'HANDLE_STRICT'
"HANDLE_STRICT"
end

def self.default
'off'
"off"
end

module Set
def self.on
Strict.set('on')
Strict.set("on")
end

def self.off
Strict.set('off')
Strict.set("off")
end
end
end
Expand Down
2 changes: 1 addition & 1 deletion lib/messaging/message.rb
Original file line number Diff line number Diff line change
Expand Up @@ -40,7 +40,7 @@ module Info
extend self

def message_type(msg=self)
Info.class_name(msg).split('::').last
Info.class_name(msg).split("::").last
end

def message_type?(type)
Expand Down
4 changes: 2 additions & 2 deletions lib/messaging/stream_name.rb
Original file line number Diff line number Diff line change
Expand Up @@ -42,15 +42,15 @@ def command_stream_name(id, category=nil, type: nil, types: nil)

category ||= self.category
types ||= []
types.unshift('command')
types.unshift("command")
types << type unless type == nil
MessageStore::StreamName.stream_name(category, id, types: types)
end

def command_category_stream_name(category=nil, type: nil, types: nil)
category ||= self.category
types ||= []
types.unshift('command')
types.unshift("command")
types << type unless type == nil
MessageStore::StreamName.stream_name(category, types: types)
end
Expand Down
4 changes: 2 additions & 2 deletions lib/messaging/write.rb
Original file line number Diff line number Diff line change
Expand Up @@ -50,7 +50,7 @@ def call(message_or_batch, stream_name, expected_version: nil, reply_stream_name
logger.trace(tag: :write) { "Writing message (Type: #{message_or_batch.class.message_type}, Stream Name: #{stream_name}, Expected Version: #{expected_version.inspect}, Reply Stream Name: #{reply_stream_name.inspect})" }
else
logger.trace(tag: :write) do
message_types = message_or_batch.map {|message| message.class.message_type }.uniq.join(', ')
message_types = message_or_batch.map {|message| message.class.message_type }.uniq.join(", ")
"Writing batch (Types: #{message_types}, Stream Name: #{stream_name}, Expected Version: #{expected_version.inspect}, Reply Stream Name: #{reply_stream_name.inspect})"
end
end
Expand All @@ -66,7 +66,7 @@ def call(message_or_batch, stream_name, expected_version: nil, reply_stream_name
logger.info(tag: :write) { "Wrote message (Type: #{message_or_batch.class.message_type}, Stream Name: #{stream_name}, Position: #{last_position}, Expected Version: #{expected_version.inspect}, Reply Stream Name: #{reply_stream_name.inspect})" }
else
logger.info(tag: :write) do
message_types = message_or_batch.map {|message| message.class.message_type }.uniq.join(', ')
message_types = message_or_batch.map {|message| message.class.message_type }.uniq.join(", ")
"Wrote batch (Types: #{message_types}, Stream Name: #{stream_name}, Position: #{last_position}, Expected Version: #{expected_version.inspect}, Reply Stream Name: #{reply_stream_name.inspect})"
end
end
Expand Down
6 changes: 3 additions & 3 deletions load_path.rb
Original file line number Diff line number Diff line change
@@ -1,4 +1,4 @@
bundler_standalone_loader = 'gems/bundler/setup'
bundler_standalone_loader = "gems/bundler/setup"

begin
require_relative bundler_standalone_loader
Expand All @@ -8,10 +8,10 @@
Bundler.require
end

lib_dir = File.expand_path('lib', __dir__)
lib_dir = File.expand_path("lib", __dir__)
$LOAD_PATH.unshift(lib_dir) unless $LOAD_PATH.include?(lib_dir)

libraries_dir = ENV['LIBRARIES_HOME']
libraries_dir = ENV["LIBRARIES_HOME"]
unless libraries_dir.nil?
libraries_dir = File.expand_path(libraries_dir)
$LOAD_PATH.unshift libraries_dir unless $LOAD_PATH.include?(libraries_dir)
Expand Down
28 changes: 14 additions & 14 deletions messaging.gemspec
Original file line number Diff line number Diff line change
@@ -1,22 +1,22 @@
# -*- encoding: utf-8 -*-
Gem::Specification.new do |s|
s.name = 'evt-messaging'
s.version = '2.7.0.3'
s.summary = 'Common primitives for platform-specific messaging implementations for Eventide'
s.description = ' '
s.name = "evt-messaging"
s.version = "2.7.0.3"
s.summary = "Common primitives for platform-specific messaging implementations for Eventide"
s.description = " "

s.authors = ['The Eventide Project']
s.email = 'opensource@eventide-project.org'
s.homepage = 'https://github.com/eventide-project/messaging'
s.licenses = ['MIT']
s.authors = ["The Eventide Project"]
s.email = "opensource@eventide-project.org"
s.homepage = "https://github.com/eventide-project/messaging"
s.licenses = ["MIT"]

s.require_paths = ['lib']
s.files = Dir.glob('{lib}/**/*')
s.require_paths = ["lib"]
s.files = Dir.glob("{lib}/**/*")
s.platform = Gem::Platform::RUBY
s.required_ruby_version = '>= 2.4.0'
s.required_ruby_version = ">= 2.4.0"

s.add_runtime_dependency 'evt-message_store'
s.add_runtime_dependency 'evt-settings'
s.add_runtime_dependency "evt-message_store"
s.add_runtime_dependency "evt-settings"

s.add_development_dependency 'test_bench'
s.add_development_dependency "test_bench"
end
2 changes: 1 addition & 1 deletion test.rb
Original file line number Diff line number Diff line change
@@ -1 +1 @@
require_relative 'test/automated'
require_relative "test/automated"
6 changes: 3 additions & 3 deletions test/automated.rb
Original file line number Diff line number Diff line change
@@ -1,6 +1,6 @@
require_relative './test_init'
require_relative "./test_init"

TestBench::Run.(
'test/automated',
exclude: '{_*,*sketch*,*_init,*_tests}.rb'
"test/automated",
exclude: "{_*,*sketch*,*_init,*_tests}.rb"
) or exit(false)
2 changes: 1 addition & 1 deletion test/automated/automated_init.rb
Original file line number Diff line number Diff line change
@@ -1 +1 @@
require_relative '../test_init'
require_relative "../test_init"
2 changes: 1 addition & 1 deletion test/automated/category_macro.rb
Original file line number Diff line number Diff line change
@@ -1,4 +1,4 @@
require_relative 'automated_init'
require_relative "automated_init"

context "Stream Name" do
example = Controls::StreamName::NamedCategory.example
Expand Down
Original file line number Diff line number Diff line change
@@ -1,4 +1,4 @@
require_relative '../../../automated_init'
require_relative "../../../automated_init"

context "Handle" do
context "Configure" do
Expand Down
Original file line number Diff line number Diff line change
@@ -1,4 +1,4 @@
require_relative '../../../automated_init'
require_relative "../../../automated_init"

context "Handle" do
context "Configure" do
Expand Down
Original file line number Diff line number Diff line change
@@ -1,4 +1,4 @@
require_relative '../../../automated_init'
require_relative "../../../automated_init"

context "Handle" do
context "Configure" do
Expand Down
2 changes: 1 addition & 1 deletion test/automated/handle/configure/session_and_settings.rb
Original file line number Diff line number Diff line change
@@ -1,4 +1,4 @@
require_relative '../../automated_init'
require_relative "../../automated_init"

context "Handle" do
context "Configure" do
Expand Down
Original file line number Diff line number Diff line change
@@ -1,4 +1,4 @@
require_relative '../../../automated_init'
require_relative "../../../automated_init"

context "Handle" do
context "Configure" do
Expand Down
Original file line number Diff line number Diff line change
@@ -1,4 +1,4 @@
require_relative '../../../automated_init'
require_relative "../../../automated_init"

context "Handle" do
context "Configure" do
Expand Down
Original file line number Diff line number Diff line change
@@ -1,4 +1,4 @@
require_relative '../../../automated_init'
require_relative "../../../automated_init"

context "Handle" do
context "Configure" do
Expand Down
2 changes: 1 addition & 1 deletion test/automated/handle/handles/message.rb
Original file line number Diff line number Diff line change
@@ -1,4 +1,4 @@
require_relative '../../automated_init'
require_relative "../../automated_init"

context "Handles" do
context "Message" do
Expand Down
Loading