Ismael Celis ismasan

## ws_events_dispatcher.js
/*
The MIT License (MIT)

Copyright (c) 2014 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

## sourced_subtasks.rb
# The main worflow
class MarksFlow < Sourced::Actor
  include Sourced::CommandMethods

  state do |id|
    { id:, status: :new, tasks: {} }
  end

  command :start_step1 do |state, cmd|
    raise "invalid transition" unless state[:status] == :new

## exif.rb
require 'exif'
require 'geocoder'
require 'time'

def coord(deg, min, sec, _ref)
  (deg + (min / 60) + (sec / 3600)).to_f # * (ref == "S" || ref == "W") ? -1 : 1
  # %(#{deg.to_i}°#{min.to_i}'#{sec.to_f}"#{ref})
end

def coords(gos)

## 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
	/*
	The MIT License (MIT)

	Copyright (c) 2014 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
	# The main worflow
	class MarksFlow < Sourced::Actor
	include Sourced::CommandMethods

	state do \|id\|
	{ id:, status: :new, tasks: {} }
	end

	command :start_step1 do \|state, cmd\|
	raise "invalid transition" unless state[:status] == :new
	require 'exif'
	require 'geocoder'
	require 'time'

	def coord(deg, min, sec, _ref)
	(deg + (min / 60) + (sec / 3600)).to_f # * (ref == "S" \|\| ref == "W") ? -1 : 1
	# %(#{deg.to_i}°#{min.to_i}'#{sec.to_f}"#{ref})
	end

	def coords(gos)
	# 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