Ismael Celis ismasan

## Gemfile
# frozen_string_literal: true

source "https://rubygems.org"

gem 'puma'
gem 'datastar'

## sse.go
// Copyright (c) 2017 Ismael Celis

// Permission is hereby granted, free of charge, to any person obtaining a copy
// of this software and associated documentation files (the "Software"), to deal
// in the Software without restriction, including without limitation the rights
// to use, copy, modify, merge, publish, distribute, sublicense, and/or sell
// copies of the Software, and to permit persons to whom the Software is
// furnished to do so, subject to the following conditions:

// The above copyright notice and this permission notice shall be included in all

## html_form_json_request.html
  <!DOCTYPE html>
  <html>
    <head>
      <meta charset="UTF-8">
      <title>JSON form</title>
      <script>
      function jsonForm(form) {
        form.addEventListener('submit', function(event) {
          event.preventDefault();
          var data = {};

## linearize_thread_exceptions.rb
require 'thread'

def work(queue, &block)
  Thread.new do
    block.call(queue)
    queue << :done
  rescue StandardError => e
    queue << e
  end
end

## loans.rb
# Adapter from https://gist.github.com/thedumbtechguy/9e6d9abfbd0393804f185118196ea678
require 'csv'
require 'plumb'
require 'date'
require 'debug'
require 'active_support/core_ext/string'

module Types
  include Plumb::Types

## Claude.mkd

      
              2 files
            
          
              0 forks
            
          
                0 comments
              
            
              1 star
            
          
                ismasan
                / Claude.mkd
            
            
              Created
              January 10, 2025 14:53
            
              
                Discord DDD-CQRS-ES aggregate boundaries discussion
              
          
The discussion started with a question about when to use strong consistency (aggregates) versus eventual consistency, using a dinner reservation system as an example.


Main insights about consistency and design:


Consistency boundaries should generally be kept small, ideally supporting single-concurrent-user operations
Eventual consistency can sometimes provide better business solutions, allowing for compensatory measures (like waitlists or discounts) rather than simple rejections
Consistency boundaries are discovered rather than defined, based on what decisions need to be made together


Key principles about aggregates:


## job_queue.sql
WITH next_job AS (
    SELECT
        id,
        type,
        payload,
        created_at
    FROM jobs
    WHERE created_at <= ?
    ORDER BY created_at
    FOR UPDATE SKIP LOCKED

## validations_for.rb
# class Page
#   include ValidationsFor
#
#   validations_for page_type: 'offer' do
#     validates :amount, presence: true
#   end
#
#   validations_for page_type: 'page' do
#     validates :title, presence: true
#   end

## concurrent_processing.rb
# A Pipeline extension to process steps concurrently
# Example
# class ConcurrentPipeline < Pipeline
#   include ConcurrentProcessing
# end
#
# MyPipeline = ConcurrentPipeline.new do |pl|
#   pl.step ValidateInput
#
#   # These steps run concurrently

## enumerator_io.rb
# frozen_string_literal: true

# Wraps an enumerator that yields chunks of content into an IO object. It
# The IO is NOT rewindable.
# implements some essential IO methods:
#
# * IO#read
# * IO#readpartial
# * IO#gets
# * IO#size
	# frozen_string_literal: true

	source "https://rubygems.org"

	gem 'puma'
	gem 'datastar'
	// Copyright (c) 2017 Ismael Celis

	// Permission is hereby granted, free of charge, to any person obtaining a copy
	// of this software and associated documentation files (the "Software"), to deal
	// in the Software without restriction, including without limitation the rights
	// to use, copy, modify, merge, publish, distribute, sublicense, and/or sell
	// copies of the Software, and to permit persons to whom the Software is
	// furnished to do so, subject to the following conditions:

	// The above copyright notice and this permission notice shall be included in all
	<!DOCTYPE html>
	<html>
	<head>
	<meta charset="UTF-8">
	<title>JSON form</title>
	<script>
	function jsonForm(form) {
	form.addEventListener('submit', function(event) {
	event.preventDefault();
	var data = {};
	require 'thread'

	def work(queue, &block)
	Thread.new do
	block.call(queue)
	queue << :done
	rescue StandardError => e
	queue << e
	end
	end
	# Adapter from https://gist.github.com/thedumbtechguy/9e6d9abfbd0393804f185118196ea678
	require 'csv'
	require 'plumb'
	require 'date'
	require 'debug'
	require 'active_support/core_ext/string'

	module Types
	include Plumb::Types
	WITH next_job AS (
	SELECT
	id,
	type,
	payload,
	created_at
	FROM jobs
	WHERE created_at <= ?
	ORDER BY created_at
	FOR UPDATE SKIP LOCKED
	# class Page
	# include ValidationsFor
	#
	# validations_for page_type: 'offer' do
	# validates :amount, presence: true
	# end
	#
	# validations_for page_type: 'page' do
	# validates :title, presence: true
	# end
	# A Pipeline extension to process steps concurrently
	# Example
	# class ConcurrentPipeline < Pipeline
	# include ConcurrentProcessing
	# end
	#
	# MyPipeline = ConcurrentPipeline.new do \|pl\|
	# pl.step ValidateInput
	#
	# # These steps run concurrently
	# frozen_string_literal: true

	# Wraps an enumerator that yields chunks of content into an IO object. It
	# The IO is NOT rewindable.
	# implements some essential IO methods:
	#
	# * IO#read
	# * IO#readpartial
	# * IO#gets
	# * IO#size