restore_graph_save.bend
bendvy-ecs-core@0.1.0.0 · 50 lines · 0 definitions
1import Base
2import bendvy-ecs-core@0.1.0.0/restore_graph_data.bend as R
3import bendvy-ecs-core@0.1.0.0/world.bend as W
4import bendvy-ecs-core@0.1.0.0/relation_commands.bend as Relation
5import bendvy-ecs-core@0.1.0.0/owner_product.bend as Product
6import bendvy-ecs-core@0.1.0.0/decode_data.bend as D
7import bendvy-ecs-core@0.1.0.0/snapshot_data.bend as Basic
8import bendvy-ecs-core@0.1.0.0/entity_key.bend as Key
9import bendvy-ecs-core@0.1.0.0/relation_types.bend as G
10import bendvy-ecs-core@0.1.0.0/relation_graph.bend as Graph
11import bendvy-ecs-core@0.1.0.0/relation_failure_reader.bend as Ordinary
12
13def included(found:Bool,target:Key.Key,sources:List<&2,Key.Key>,rest:List<&2,R.Group>) -> List<&2,R.Group>:
14 match found:
15 case True{}:R.Group{target,sources} <> rest
16 case False{}:rest
17def groups(~S:Data,entries:List<&2,G.Inverse<S>>,+descriptor:G.Descriptor<S>) -> List<&2,R.Group>:
18 match entries:
19 case []:[]
20 case G.Inverse{other,target,sources} <> rest:included(U32.is_eq(Graph.key(~S,descriptor),Graph.key(~S,other)),target,sources,groups(~S,rest,descriptor))
21def relations(~S:Data,declarations:List<&2,Ordinary.Declaration<S>>,+graph:G.Graph<S>) -> List<&2,R.Relation>:
22 match declarations graph:
23 case [] _:[]
24 case Ordinary.Declaration{+descriptor} <> rest G.Graph{+edges,+inverses}:R.Relation{Graph.name(~S,descriptor),groups(~S,inverses,descriptor)} <> relations(~S,rest,G.Graph{edges,inverses})
25def machine_read_joined(~Resources:Type,~Machines:Type,resource:Resources,result:Machines & List<&2,D.Field>) -> Product.Owner<Resources,Machines> & List<&2,D.Field>:
26 match result:
27 case (machines,fields):(Product.Owner{resource,machines},fields)
28def machine_read(~Resources:Type,~Machines:Type,~readMachines:Machines -> Machines & List<&2,D.Field>,resource:Product.Owner<Resources,Machines>) -> Product.Owner<Resources,Machines> & List<&2,D.Field>:
29 match resource:
30 case Product.Owner{resource,machines}:machine_read_joined(~Resources,~Machines,resource,readMachines(machines))
31def machine_joined(~S:Data,~C:Type,~Resources:Type,~Machines:Type,~E:Data,~readMachines:Machines -> Machines & List<&2,D.Field>,basic:Basic.Snapshot,relations:List<&2,R.Relation>,result:W.World<S,Relation.Store<S,C>,Product.Owner<Resources,Machines>,E> & List<&2,D.Field>) -> W.World<S,Relation.Store<S,C>,Product.Owner<Resources,Machines>,E> & Basic.Outcome<R.Snapshot>:
32 match result:
33 case (world,machines):(world,Basic.Saved{R.Snapshot{basic,relations,machines}})
34def graph_joined(~S:Data,~C:Type,~Resources:Type,~Machines:Type,~E:Data,~readMachines:Machines -> Machines & List<&2,D.Field>,basic:Basic.Snapshot,declarations:List<&2,Ordinary.Declaration<S>>,result:W.World<S,Relation.Store<S,C>,Product.Owner<Resources,Machines>,E> & G.Graph<S>) -> W.World<S,Relation.Store<S,C>,Product.Owner<Resources,Machines>,E> & Basic.Outcome<R.Snapshot>:
35 match result:
36 case (world,graph):machine_joined(~S,~C,~Resources,~Machines,~E,~readMachines,basic,relations(~S,declarations,graph),W.observe_resource(~S,~Relation.Store<S,C>,~Product.Owner<Resources,Machines>,~E,~List<&2,D.Field>,~machine_read(~Resources,~Machines,~readMachines),world))
37def basic_joined(~S:Data,~C:Type,~Resources:Type,~Machines:Type,~E:Data,~readMachines:Machines -> Machines & List<&2,D.Field>,declarations:List<&2,Ordinary.Declaration<S>>,result:W.World<S,Relation.Store<S,C>,Product.Owner<Resources,Machines>,E> & Basic.Outcome<Basic.Snapshot>) -> W.World<S,Relation.Store<S,C>,Product.Owner<Resources,Machines>,E> & Basic.Outcome<R.Snapshot>:
38 match result:
39 case (world,Basic.RefusedPending{}):(world,Basic.RefusedPending{})
40 case (world,Basic.Saved{basic}):graph_joined(~S,~C,~Resources,~Machines,~E,~readMachines,basic,declarations,W.with_store(~S,~Relation.Store<S,C>,~Product.Owner<Resources,Machines>,~E,~G.Graph<S>,Relation.graph_read(~S,~C),world))
41def save_ready(~S:Data,~C:Type,~Resources:Type,~Machines:Type,~E:Data,~readMachines:Machines -> Machines & List<&2,D.Field>,~saveBasic:W.World<S,Relation.Store<S,C>,Product.Owner<Resources,Machines>,E> -> W.World<S,Relation.Store<S,C>,Product.Owner<Resources,Machines>,E> & Basic.Outcome<Basic.Snapshot>,declarations:List<&2,Ordinary.Declaration<S>>,result:W.World<S,Relation.Store<S,C>,Product.Owner<Resources,Machines>,E> & Bool) -> W.World<S,Relation.Store<S,C>,Product.Owner<Resources,Machines>,E> & Basic.Outcome<R.Snapshot>:
42 match result:
43 case (world,False{}):(world,Basic.RefusedPending{})
44 case (world,True{}):basic_joined(~S,~C,~Resources,~Machines,~E,~readMachines,declarations,saveBasic(world))
45# Save graph and committed machine values only after structural admission.
46# RefusedPending preserves World and skips even saveBasic/readMachines callbacks.
47# Separate queued machine transitions remain outside this committed-value snapshot;
48# this operation neither rejects them nor applies a machine marker/barrier.
49def save(~S:Data,~C:Type,~Resources:Type,~Machines:Type,~E:Data,~readMachines:Machines -> Machines & List<&2,D.Field>,~saveBasic:W.World<S,Relation.Store<S,C>,Product.Owner<Resources,Machines>,E> -> W.World<S,Relation.Store<S,C>,Product.Owner<Resources,Machines>,E> & Basic.Outcome<Basic.Snapshot>,declarations:List<&2,Ordinary.Declaration<S>>,world:W.World<S,Relation.Store<S,C>,Product.Owner<Resources,Machines>,E>) -> W.World<S,Relation.Store<S,C>,Product.Owner<Resources,Machines>,E> & Basic.Outcome<R.Snapshot>:
50 save_ready(~S,~C,~Resources,~Machines,~E,~readMachines,~saveBasic,declarations,Basic.ready(~S,~Relation.Store<S,C>,~Product.Owner<Resources,Machines>,~E,world))