rename

Author: metagn

.github/workflows/main.yml

@@ -1,4 +1,4 @@
-name: cule
+name: keten
 
 on:
   push:

cule.nimble keten.nimblecule.nimble renamed to keten.nimble

@@ -7,7 +7,7 @@ type RawRow* = seq[RawNimNode]
 
 proc addRawRow*(id: SchemaId, row: RawRow) =
   if isFrozen(id):
-    raise newException(CuleFrozenError, "schema " & $id & " is frozen, no rows can be added")
+    raise newException(FrozenError, "schema " & $id & " is frozen, no rows can be added")
   getSchemaData(id).add glaze(row)
 
 macro defineRowAdd*(id: static SchemaId, name: untyped) =
@@ -20,16 +20,37 @@ macro defineRowAdd*(id: static SchemaId, name: untyped) =
   var params: seq[NimNode] = @[newEmptyNode()]
   var row = newNimNode(nnkBracket, name)
   for field in schema.fields:
-    let typeNode = field.type.NimNode
+    var typeNode = field.type.constraint.NimNode
+    case field.type.kind
+    of ExprAtom:
+      if typeNode.isNil:
+        typeNode = bindSym"untyped"
+    of TypeAtom:
+      if typeNode.isNil:
+        typeNode = bindSym"typedesc"
+      else:
+        typeNode = newTree(nnkBracketExpr, bindSym"typedesc", typeNode)
+    of StaticAtom:
+      if typeNode.isNil:
+        typeNode = bindSym"static"
+      else:
+        typeNode = newTree(nnkBracketExpr, bindSym"static", typeNode)
     let defaultNode = field.default.NimNode
     var def = newNimNode(nnkIdentDefs, typeNode)
     def.add ident(field.name)
-    if typeNode.isNil: def.add newEmptyNode()
-    else: def.add typeNode
+    def.add typeNode
     if defaultNode.isNil: def.add newEmptyNode()
     else: def.add defaultNode
     params.add def
-    row.add newCall(bindSym"RawNimNode", ident(field.name)) # XXX needs to be different for typedescs and statics
+    var serializeNode = ident(field.name)
+    case field.type.kind
+    of ExprAtom: discard
+    of TypeAtom:
+      # maybe implement glaze for typedesc
+      serializeNode = newCall(bindSym"getTypeInst", serializeNode)
+    of StaticAtom:
+      serializeNode = newCall(bindSym("glaze", brForceOpen), serializeNode)
+    row.add newCall(bindSym"RawNimNode", serializeNode)
   result = newProc(
     procType = nnkMacroDef,
     name = name,

src/cule/schema.nim

@@ -0,0 +1,57 @@
+import glaze, std/macrocache
+
+type
+  AtomKind* = enum
+    ExprAtom
+    TypeAtom
+    StaticAtom
+  AtomType* = object
+    case kind*: AtomKind
+    of ExprAtom, TypeAtom, StaticAtom:
+      constraint*: RawNimNode
+  KetenField* = object
+    # or "strand"
+    column*: int
+    name*: string
+    `type`*: AtomType # can be untyped, typed, static, typedesc, or other typed node
+    default*: RawNimNode
+  KetenSchema* = object
+    # or "fabric"
+    fields*: seq[KetenField]
+
+proc getColumn*(schema: KetenSchema, name: string): int =
+  result = -1
+  for i, field in schema.fields:
+    if field.name == name:
+      return i
+
+proc toNode*(schema: KetenSchema): NimNode =
+  glaze(schema)
+
+proc toSchema*(node: NimNode): KetenSchema =
+  deglaze(node, result)
+
+type SchemaId* = string
+
+const schemas* = CacheTable"keten.schemas"
+
+proc addSchema*(id: SchemaId, schema: KetenSchema) =
+  schemas[id] = toNode(schema)
+
+proc getSchema*(id: SchemaId): KetenSchema =
+  toSchema(schemas[id])
+
+type FrozenError* = object of CatchableError
+
+const freezes* = CacheTable"keten.freezes"
+
+proc freeze*(id: SchemaId) {.compileTime.} =
+  freezes[id] = glaze true
+
+proc isFrozen*(id: SchemaId): bool {.compileTime.} =
+  id in freezes and deglaze(freezes[id], bool)
+
+proc getSchemaDataHandle*(id: SchemaId): string =
+  "keten.data." & id
+
+# maybe indexes?

src/cule.nim src/keten.nimsrc/cule.nim renamed to src/keten.nim

@@ -7,4 +7,4 @@ when not declared(buildDocs):
   {.error: "docs task not implemented, need nimbleutils".}
 
 # run from project root
-buildDocs(gitUrl = "https://github.com/holo-nim/cule")
+buildDocs(gitUrl = "https://github.com/holo-nim/keten")