Архитектура распределённого Scala-сервиса

import cats.effect.IO
case class PlaceOrder(customerId: String, items: Vector[String])
opaque type OrderId = String
trait OrdersApi:
  def place(cmd: PlaceOrder): IO[OrderId]

// Дополнительный контекст: Клиент повторил команду после тайм-аута, не зная, завершилась ли первая попытка.
import cats.effect.IO
case class PlaceOrder(customerId: String, items: Vector[String])
opaque type OrderId = String
trait OrdersApi:
  def place(cmd: PlaceOrder): IO[OrderId]

import cats.effect.IO
case class PlaceOrder(customerId: String, items: Vector[String])
opaque type OrderId = String
trait OrdersApi:
  def place(cmd: PlaceOrder): IO[OrderId]
// На ревью требуется устранить причину дефекта, не скрывая её приведением типа или значением по умолчанию.

case class Version(value: Long)
case class Account(id: String, balance: BigDecimal, version: Version)
def update(current: Account, expected: Version, next: BigDecimal): Option[Account] =
  Option.when(current.version == expected)(current.copy(balance = next, version = Version(expected.value + 1)))

// Дополнительный контекст: Горячий ключ остался у одного владельца, хотя число экземпляров сервиса увеличили.
case class Version(value: Long)
case class Account(id: String, balance: BigDecimal, version: Version)
def update(current: Account, expected: Version, next: BigDecimal): Option[Account] =
  Option.when(current.version == expected)(current.copy(balance = next, version = Version(expected.value + 1)))

case class Version(value: Long)
case class Account(id: String, balance: BigDecimal, version: Version)
def update(current: Account, expected: Version, next: BigDecimal): Option[Account] =
  Option.when(current.version == expected)(current.copy(balance = next, version = Version(expected.value + 1)))
// На ревью требуется устранить причину дефекта, не скрывая её приведением типа или значением по умолчанию.

case class Charge(idempotencyKey: String, account: String, amount: BigDecimal)

// Дополнительный контекст: Клиент повторил команду после тайм-аута, не зная, завершилась ли первая попытка.
case class Charge(idempotencyKey: String, account: String, amount: BigDecimal)

case class Charge(idempotencyKey: String, account: String, amount: BigDecimal)
// На ревью требуется устранить причину дефекта, не скрывая её приведением типа или значением по умолчанию.

case class LogContext(orderId: String, traceId: String, attempt: Int)
def fields(c: LogContext): Map[String, String] = Map(
  "order_id" -> c.orderId,
  "trace_id" -> c.traceId,
  "attempt" -> c.attempt.toString
)
println(fields(LogContext("o-7", "t-2", 1)))

// Дополнительный контекст: Горячий ключ остался у одного владельца, хотя число экземпляров сервиса увеличили.
case class LogContext(orderId: String, traceId: String, attempt: Int)
def fields(c: LogContext): Map[String, String] = Map(
  "order_id" -> c.orderId,
  "trace_id" -> c.traceId,
  "attempt" -> c.attempt.toString
)
println(fields(LogContext("o-7", "t-2", 1)))

case class LogContext(orderId: String, traceId: String, attempt: Int)
def fields(c: LogContext): Map[String, String] = Map(
  "order_id" -> c.orderId,
  "trace_id" -> c.traceId,
  "attempt" -> c.attempt.toString
)
println(fields(LogContext("o-7", "t-2", 1)))
// На ревью требуется устранить причину дефекта, не скрывая её приведением типа или значением по умолчанию.

import cats.effect.IO
import cats.effect.std.Queue
import scala.concurrent.duration.*
case class Command(id: String)
def call(cmd: Command): IO[String] = IO.pure(cmd.id)
val program = Queue.bounded[IO, Command](1024).flatMap { queue =>
  queue.offer(Command("c-1")) *> call(Command("c-1")).timeout(2.seconds)
}

// Дополнительный контекст: Горячий ключ остался у одного владельца, хотя число экземпляров сервиса увеличили.
import cats.effect.IO
import cats.effect.std.Queue
import scala.concurrent.duration.*
case class Command(id: String)
def call(cmd: Command): IO[String] = IO.pure(cmd.id)
val program = Queue.bounded[IO, Command](1024).flatMap { queue =>
  queue.offer(Command("c-1")) *> call(Command("c-1")).timeout(2.seconds)
}

import cats.effect.IO
import cats.effect.std.Queue
import scala.concurrent.duration.*
case class Command(id: String)
def call(cmd: Command): IO[String] = IO.pure(cmd.id)
val program = Queue.bounded[IO, Command](1024).flatMap { queue =>
  queue.offer(Command("c-1")) *> call(Command("c-1")).timeout(2.seconds)
}
// На ревью требуется устранить причину дефекта, не скрывая её приведением типа или значением по умолчанию.

def shard(orderId: String, n: Int) = (orderId.hashCode & Int.MaxValue) % n

// Дополнительный контекст: Чтение сразу после записи попало на отстающую реплику.
def shard(orderId: String, n: Int) = (orderId.hashCode & Int.MaxValue) % n

def shard(orderId: String, n: Int) = (orderId.hashCode & Int.MaxValue) % n
// На ревью требуется устранить причину дефекта, не скрывая её приведением типа или значением по умолчанию.