Gozala

Commit History Encoding

Goal

Supporting concurrent writes into database implies that multiple actors can create concurrent commits (containing assertions / retractions) than need to be reconciled by all partial replicas. Reconciliation requirements following:

1. Identifying concurrent changes.
2. Order all changes (including concurrent ones)

To make this more concrete, when query reads set of facts we need to identify if some facts are conflicting - updated same state via concurrent changes. This would enable projecting concurrent states that consumer could choose from.

Gozala

;; Type definition for the Blob. It has no inputs and two outputs
; `digest` and `size`. It is kind of like a rule without a body
(Blob : { :digest Bytes :size Int })
(Site : { :url String :headers (Map :key string :value string) })

;; ℹ️ Unlabelled parameter can be refereced by `.`
(Result :error : (:ok . :error .error))

;; Composed task is rule that maps input to tasks and maps task outputs
;; to the output of the composed task

Gozala

(Multihash : Bytes)
(Blob : {:size Integer :digest Multihash })

(blob/add
  :input {:sub DID :blob Blob }
  :address (memory/allocate
    :space .input.sub
    :blob  .input.blob)
  :content (http/put
    :url .address.out.ok.url

Gozala

stateDiagram-v2
  add: 👩‍💻 /space/content/add/blob 🤖
  add: 🧾 { ok {} }

  allocate: 🤖 /service/blob/allocate 🤖
  allocate: 🧾 { ok { size 123 } }

  wait: 🤖 /service/blob/receive 🤖
 wait: 🧾 { ok {} } 

Gozala

flowchart LR
    Add[👩‍💻 store/add 🤖]
    Allocate[🤖 blob/allocate 🤖]
    Receive[🤖 blob/receive 🤖]
    Write[🤖 blob/write 👩‍💻]
    Close[🤖 blob/close 🤖]
    Claim[🤖 assert/location 🌐]

 Add --> Allocate

Gozala

interface Account {
  plan: AccountPlan
  // ...
}

interface AccountPlan {
  customer: AccountDID

  request(): Plan
  list(): Plan[]

Gozala

interface Account {
  subscriptions: AccountSubscriptions
  // ...
}

interface AccountSubscriptions {
  customer: AccountDID

  request(): Subscription
  list(): Subscription[]

Gozala

import * as API from '@ucanto/interface'

/**
 * @typedef {number} Integer
 * @typedef {number} Float
 * @typedef {Readonly<Uint8Array>} Bytes
 * @typedef {string} UTF8
 *
 * @typedef {String} Entity
 * @typedef {Integer|Float|Bytes|UTF8} Attribute

Gozala

type ProviderDID =
  | "did:web:web.storage"
  | "did:web:nft.storage"

interface Principal {
  did(): string
}

interface Space extends Principal {

Gozala

stateDiagram-v2
direction TB

state scope {
  sig-->meta: 
  sig-->prf
  sig-->iss
  sig-->aud
  sig-->tasks