map.go 13.1 KB
Newer Older
1 2 3 4 5 6
package impls

import (
	"fmt"

	ipld "github.com/ipld/go-ipld-prime/_rsrch/nodesolution"
7
	"github.com/ipld/go-ipld-prime/_rsrch/nodesolution/impls/mixins"
8 9
)

10 11 12 13 14 15 16
var (
	_ ipld.Node          = &plainMap{}
	_ ipld.NodeStyle     = Style__Map{}
	_ ipld.NodeBuilder   = &plainMap__Builder{}
	_ ipld.NodeAssembler = &plainMap__Assembler{}
)

17 18 19
// plainMap is a concrete type that provides a map-kind ipld.Node.
// It can contain any kind of value.
// plainMap is also embedded in the 'any' struct and usable from there.
Eric Myhre's avatar
Eric Myhre committed
20
type plainMap struct {
21
	m map[string]ipld.Node // string key -- even if a runtime schema wrapper is using us for storage, we must have a comparable type here, and string is all we know.
22
	t []plainMap__Entry    // table for fast iteration, order keeping, and yielding pointers to enable alloc/conv amortization.
23 24
}

Eric Myhre's avatar
Eric Myhre committed
25 26
type plainMap__Entry struct {
	k plainString // address of this used when we return keys as nodes, such as in iterators.  Need in one place to amortize shifts to heap when ptr'ing for iface.
27 28
	v ipld.Node   // identical to map values.  keeping them here simplifies iteration.  (in codegen'd maps, this position is also part of amortization, but in this implementation, that's less useful.)
	// note on alternate implementations: 'v' could also use the 'any' type, and thus amortize value allocations.  the memory size trade would be large however, so we don't, here.
Eric Myhre's avatar
Eric Myhre committed
29 30
}

31 32
// -- Node interface methods -->

Eric Myhre's avatar
Eric Myhre committed
33 34 35 36 37 38 39 40 41 42 43 44 45 46 47 48 49 50
func (plainMap) ReprKind() ipld.ReprKind {
	return ipld.ReprKind_Map
}
func (n *plainMap) LookupString(key string) (ipld.Node, error) {
	v, exists := n.m[key]
	if !exists {
		return nil, ipld.ErrNotExists{ipld.PathSegmentOfString(key)}
	}
	return v, nil
}
func (n *plainMap) Lookup(key ipld.Node) (ipld.Node, error) {
	ks, err := key.AsString()
	if err != nil {
		return nil, err
	}
	return n.LookupString(ks)
}
func (plainMap) LookupIndex(idx int) (ipld.Node, error) {
51
	return mixins.Map{"map"}.LookupIndex(0)
Eric Myhre's avatar
Eric Myhre committed
52 53 54 55 56 57 58 59
}
func (n *plainMap) LookupSegment(seg ipld.PathSegment) (ipld.Node, error) {
	return n.LookupString(seg.String())
}
func (n *plainMap) MapIterator() ipld.MapIterator {
	return &plainMap_MapIterator{n, 0}
}
func (plainMap) ListIterator() ipld.ListIterator {
60
	return nil
Eric Myhre's avatar
Eric Myhre committed
61 62 63 64 65 66 67 68 69 70 71
}
func (n *plainMap) Length() int {
	return len(n.t)
}
func (plainMap) IsUndefined() bool {
	return false
}
func (plainMap) IsNull() bool {
	return false
}
func (plainMap) AsBool() (bool, error) {
72
	return mixins.Map{"map"}.AsBool()
Eric Myhre's avatar
Eric Myhre committed
73 74
}
func (plainMap) AsInt() (int, error) {
75
	return mixins.Map{"map"}.AsInt()
Eric Myhre's avatar
Eric Myhre committed
76 77
}
func (plainMap) AsFloat() (float64, error) {
78
	return mixins.Map{"map"}.AsFloat()
Eric Myhre's avatar
Eric Myhre committed
79 80
}
func (plainMap) AsString() (string, error) {
81
	return mixins.Map{"map"}.AsString()
Eric Myhre's avatar
Eric Myhre committed
82 83
}
func (plainMap) AsBytes() ([]byte, error) {
84
	return mixins.Map{"map"}.AsBytes()
Eric Myhre's avatar
Eric Myhre committed
85 86
}
func (plainMap) AsLink() (ipld.Link, error) {
87
	return mixins.Map{"map"}.AsLink()
Eric Myhre's avatar
Eric Myhre committed
88 89
}
func (plainMap) Style() ipld.NodeStyle {
90
	return Style__Map{}
Eric Myhre's avatar
Eric Myhre committed
91 92 93 94 95
}

type plainMap_MapIterator struct {
	n   *plainMap
	idx int
96 97
}

Eric Myhre's avatar
Eric Myhre committed
98 99 100 101 102 103 104 105 106 107 108 109 110
func (itr *plainMap_MapIterator) Next() (k ipld.Node, v ipld.Node, _ error) {
	if itr.Done() {
		return nil, nil, ipld.ErrIteratorOverread{}
	}
	k = &itr.n.t[itr.idx].k
	v = itr.n.t[itr.idx].v
	itr.idx++
	return
}
func (itr *plainMap_MapIterator) Done() bool {
	return itr.idx >= len(itr.n.t)
}

111 112
// -- NodeStyle -->

Eric Myhre's avatar
Eric Myhre committed
113 114 115 116 117 118
type Style__Map struct{}

func (Style__Map) NewBuilder() ipld.NodeBuilder {
	return &plainMap__Builder{plainMap__Assembler{w: &plainMap{}}}
}

119
// -- NodeBuilder -->
120

Eric Myhre's avatar
Eric Myhre committed
121 122 123 124
type plainMap__Builder struct {
	plainMap__Assembler
}

125
func (nb *plainMap__Builder) Build() ipld.Node {
126 127
	if nb.state != maState_finished {
		panic("invalid state: assembler must be 'finished' before Build can be called!")
128
	}
129
	return nb.w
Eric Myhre's avatar
Eric Myhre committed
130 131 132 133 134 135
}
func (nb *plainMap__Builder) Reset() {
	*nb = plainMap__Builder{}
	nb.w = &plainMap{}
}

136 137 138 139 140 141 142 143 144 145 146 147 148 149 150 151 152 153 154 155 156 157
// -- NodeAssembler -->

type plainMap__Assembler struct {
	w *plainMap

	ka plainMap__KeyAssembler
	va plainMap__ValueAssembler

	state maState
}
type plainMap__KeyAssembler struct {
	ma *plainMap__Assembler
}
type plainMap__ValueAssembler struct {
	ma *plainMap__Assembler
}

// maState is an enum of the state machine for a map assembler.
// (this might be something to export reusably, but it's also very much an impl detail that need not be seen, so, dubious.)
type maState uint8

const (
158 159
	maState_initial     maState = iota // also the 'expect key or finish' state
	maState_midKey                     // waiting for a 'finished' state in the KeyAssembler.
160
	maState_expectValue                // 'AssembleValue' is the only valid next step
161 162
	maState_midValue                   // waiting for a 'finished' state in the ValueAssembler.
	maState_finished                   // 'w' will also be nil, but this is a politer statement
163 164
)

Eric Myhre's avatar
Eric Myhre committed
165 166 167 168 169 170 171
func (na *plainMap__Assembler) BeginMap(sizeHint int) (ipld.MapNodeAssembler, error) {
	// Allocate storage space.
	na.w.t = make([]plainMap__Entry, 0, sizeHint)
	na.w.m = make(map[string]ipld.Node, sizeHint)
	// That's it; return self as the MapNodeAssembler.  We already have all the right methods on this structure.
	return na, nil
}
Eric Myhre's avatar
Eric Myhre committed
172 173 174 175 176 177 178 179 180 181 182 183 184 185 186 187 188 189 190 191 192
func (plainMap__Assembler) BeginList(sizeHint int) (ipld.ListNodeAssembler, error) {
	return mixins.MapAssembler{"map"}.BeginList(0)
}
func (plainMap__Assembler) AssignNull() error {
	return mixins.MapAssembler{"map"}.AssignNull()
}
func (plainMap__Assembler) AssignBool(bool) error {
	return mixins.MapAssembler{"map"}.AssignBool(false)
}
func (plainMap__Assembler) AssignInt(int) error {
	return mixins.MapAssembler{"map"}.AssignInt(0)
}
func (plainMap__Assembler) AssignFloat(float64) error {
	return mixins.MapAssembler{"map"}.AssignFloat(0)
}
func (plainMap__Assembler) AssignString(string) error {
	return mixins.MapAssembler{"map"}.AssignString("")
}
func (plainMap__Assembler) AssignBytes([]byte) error {
	return mixins.MapAssembler{"map"}.AssignBytes(nil)
}
Eric Myhre's avatar
Eric Myhre committed
193
func (na *plainMap__Assembler) AssignNode(v ipld.Node) error {
Eric Myhre's avatar
Eric Myhre committed
194 195 196
	// todo: apply a generic 'copy' function.
	// todo: probably can also shortcut to copying na.t and na.m if it's our same concrete type?
	//  (can't quite just `na.w = v`, because we don't have 'freeze' features, and we don't wanna open door to mutation of 'v'.)
197
	//   (wait... actually, probably we can?  'Assign' is a "finish" method.  we can&should invalidate the wip pointer here.)
Eric Myhre's avatar
Eric Myhre committed
198 199
	panic("later")
}
200 201 202
func (plainMap__Assembler) AssignLink(ipld.Link) error {
	return mixins.MapAssembler{"map"}.AssignLink(nil)
}
Eric Myhre's avatar
Eric Myhre committed
203
func (plainMap__Assembler) Style() ipld.NodeStyle { panic("later") }
204

205 206 207 208
// -- MapNodeAssembler -->

// AssembleDirectly is part of conforming to MapAssembler, which we do on
// plainMap__Assembler so that BeginMap can just return a retyped pointer rather than new object.
Eric Myhre's avatar
Eric Myhre committed
209
func (ma *plainMap__Assembler) AssembleDirectly(k string) (ipld.NodeAssembler, error) {
210 211
	// Sanity check, then update, assembler state.
	if ma.state != maState_initial {
212 213
		panic("misuse")
	}
214 215
	ma.state = maState_midValue
	// Check for dup keys; error if so.
216 217 218 219
	_, exists := ma.w.m[k]
	if exists {
		return nil, ipld.ErrRepeatedMapKey{String(k)}
	}
Eric Myhre's avatar
Eric Myhre committed
220
	ma.w.t = append(ma.w.t, plainMap__Entry{k: plainString(k)})
221 222
	// Make value assembler valid by giving it pointer back to whole 'ma'; yield it.
	ma.va.ma = ma
223
	return &ma.va, nil
224 225
}

226 227
// AssembleKey is part of conforming to MapAssembler, which we do on
// plainMap__Assembler so that BeginMap can just return a retyped pointer rather than new object.
Eric Myhre's avatar
Eric Myhre committed
228
func (ma *plainMap__Assembler) AssembleKey() ipld.NodeAssembler {
229 230
	// Sanity check, then update, assembler state.
	if ma.state != maState_initial {
Eric Myhre's avatar
Eric Myhre committed
231 232
		panic("misuse")
	}
233 234
	ma.state = maState_midKey
	// Extend entry table.
Eric Myhre's avatar
Eric Myhre committed
235
	ma.w.t = append(ma.w.t, plainMap__Entry{})
236 237
	// Make key assembler valid by giving it pointer back to whole 'ma'; yield it.
	ma.ka.ma = ma
Eric Myhre's avatar
Eric Myhre committed
238
	return &ma.ka
239
}
240 241 242

// AssembleValue is part of conforming to MapAssembler, which we do on
// plainMap__Assembler so that BeginMap can just return a retyped pointer rather than new object.
Eric Myhre's avatar
Eric Myhre committed
243
func (ma *plainMap__Assembler) AssembleValue() ipld.NodeAssembler {
244 245
	// Sanity check, then update, assembler state.
	if ma.state != maState_expectValue {
Eric Myhre's avatar
Eric Myhre committed
246 247
		panic("misuse")
	}
248
	ma.state = maState_midValue
249 250
	// Make value assembler valid by giving it pointer back to whole 'ma'; yield it.
	ma.va.ma = ma
Eric Myhre's avatar
Eric Myhre committed
251
	return &ma.va
252
}
253

254
// Finish is part of conforming to MapAssembler, which we do on
255
// plainMap__Assembler so that BeginMap can just return a retyped pointer rather than new object.
256
func (ma *plainMap__Assembler) Finish() error {
257 258
	// Sanity check, then update, assembler state.
	if ma.state != maState_initial {
259 260
		panic("misuse")
	}
261
	ma.state = maState_finished
262
	// validators could run and report errors promptly, if this type had any.
Eric Myhre's avatar
Eric Myhre committed
263 264 265 266 267
	return nil
}
func (plainMap__Assembler) KeyStyle() ipld.NodeStyle   { panic("later") }
func (plainMap__Assembler) ValueStyle() ipld.NodeStyle { panic("later") }

268 269
// -- MapNodeAssembler.KeyAssembler -->

270 271 272 273 274 275 276 277 278 279 280 281 282 283 284 285 286 287
func (plainMap__KeyAssembler) BeginMap(sizeHint int) (ipld.MapNodeAssembler, error) {
	return mixins.StringAssembler{"string"}.BeginMap(0)
}
func (plainMap__KeyAssembler) BeginList(sizeHint int) (ipld.ListNodeAssembler, error) {
	return mixins.StringAssembler{"string"}.BeginList(0)
}
func (plainMap__KeyAssembler) AssignNull() error {
	return mixins.StringAssembler{"string"}.AssignNull()
}
func (plainMap__KeyAssembler) AssignBool(bool) error {
	return mixins.StringAssembler{"string"}.AssignBool(false)
}
func (plainMap__KeyAssembler) AssignInt(int) error {
	return mixins.StringAssembler{"string"}.AssignInt(0)
}
func (plainMap__KeyAssembler) AssignFloat(float64) error {
	return mixins.StringAssembler{"string"}.AssignFloat(0)
}
Eric Myhre's avatar
Eric Myhre committed
288
func (mka *plainMap__KeyAssembler) AssignString(v string) error {
289
	// Check for dup keys; error if so.
Eric Myhre's avatar
Eric Myhre committed
290
	_, exists := mka.ma.w.m[v]
291
	if exists {
292
		return ipld.ErrRepeatedMapKey{plainString(v)}
293
	}
294 295 296 297
	// Assign the key into the end of the entry table;
	//  we'll be doing map insertions after we get the value in hand.
	//  (There's no need to delegate to another assembler for the key type,
	//   because we're just at Data Model level here, which only regards plain strings.)
Eric Myhre's avatar
Eric Myhre committed
298
	mka.ma.w.t[len(mka.ma.w.t)-1].k = plainString(v)
299 300
	// Update parent assembler state: clear to proceed.
	mka.ma.state = maState_expectValue
301
	mka.ma = nil // invalidate self to prevent further incorrect use.
302 303
	return nil
}
304 305 306
func (plainMap__KeyAssembler) AssignBytes([]byte) error {
	return mixins.StringAssembler{"string"}.AssignBytes(nil)
}
307 308 309
func (plainMap__KeyAssembler) AssignLink(ipld.Link) error {
	return mixins.StringAssembler{"string"}.AssignLink(nil)
}
Eric Myhre's avatar
Eric Myhre committed
310
func (mka *plainMap__KeyAssembler) AssignNode(v ipld.Node) error {
311 312 313 314 315 316
	vs, err := v.AsString()
	if err != nil {
		return fmt.Errorf("cannot assign non-string node into map key assembler") // FIXME:errors: this doesn't quite fit in ErrWrongKind cleanly; new error type?
	}
	return mka.AssignString(vs)
}
Eric Myhre's avatar
Eric Myhre committed
317
func (plainMap__KeyAssembler) Style() ipld.NodeStyle { panic("later") } // probably should give the style of plainString, which could say "only stores string kind" (though we haven't made such a feature part of the interface yet).
318

319 320
// -- MapNodeAssembler.ValueAssembler -->

Eric Myhre's avatar
Eric Myhre committed
321
func (mva *plainMap__ValueAssembler) BeginMap(sizeHint int) (ipld.MapNodeAssembler, error) {
322
	ma := plainMap__ValueAssemblerMap{}
323
	ma.ca.w = &plainMap{}
324
	ma.p = mva.ma
325
	_, err := ma.ca.BeginMap(sizeHint)
326
	return &ma, err
327
}
Eric Myhre's avatar
Eric Myhre committed
328 329
func (mva *plainMap__ValueAssembler) BeginList(sizeHint int) (ipld.ListNodeAssembler, error) {
	panic("todo") // now please
330
}
Eric Myhre's avatar
Eric Myhre committed
331 332 333 334
func (mva *plainMap__ValueAssembler) AssignNull() error     { panic("todo") }
func (mva *plainMap__ValueAssembler) AssignBool(bool) error { panic("todo") }
func (mva *plainMap__ValueAssembler) AssignInt(v int) error {
	vb := plainInt(v)
Eric Myhre's avatar
Eric Myhre committed
335
	return mva.AssignNode(&vb)
336
}
337 338 339
func (mva *plainMap__ValueAssembler) AssignFloat(float64) error { panic("todo") }
func (mva *plainMap__ValueAssembler) AssignString(v string) error {
	vb := plainString(v)
Eric Myhre's avatar
Eric Myhre committed
340
	return mva.AssignNode(&vb)
341
}
342 343
func (mva *plainMap__ValueAssembler) AssignBytes([]byte) error   { panic("todo") }
func (mva *plainMap__ValueAssembler) AssignLink(ipld.Link) error { panic("todo") }
Eric Myhre's avatar
Eric Myhre committed
344
func (mva *plainMap__ValueAssembler) AssignNode(v ipld.Node) error {
Eric Myhre's avatar
Eric Myhre committed
345 346 347
	l := len(mva.ma.w.t) - 1
	mva.ma.w.t[l].v = v
	mva.ma.w.m[string(mva.ma.w.t[l].k)] = v
348
	mva.ma.state = maState_initial
349
	mva.ma = nil // invalidate self to prevent further incorrect use.
350 351
	return nil
}
Eric Myhre's avatar
Eric Myhre committed
352
func (plainMap__ValueAssembler) Style() ipld.NodeStyle { panic("later") }
353 354

type plainMap__ValueAssemblerMap struct {
355 356 357 358
	ca plainMap__Assembler
	p  *plainMap__Assembler // pointer back to parent, for final insert and state bump
}

Eric Myhre's avatar
Eric Myhre committed
359 360 361
// we briefly state only the methods we need to delegate here.
// just embedding plainMap__Assembler also behaves correctly,
//  but causes a lot of unnecessary autogenerated functions in the final binary.
362 363 364 365 366 367 368 369 370

func (ma *plainMap__ValueAssemblerMap) AssembleDirectly(k string) (ipld.NodeAssembler, error) {
	return ma.ca.AssembleDirectly(k)
}
func (ma *plainMap__ValueAssemblerMap) AssembleKey() ipld.NodeAssembler {
	return ma.ca.AssembleKey()
}
func (ma *plainMap__ValueAssemblerMap) AssembleValue() ipld.NodeAssembler {
	return ma.ca.AssembleValue()
371
}
372 373
func (plainMap__ValueAssemblerMap) KeyStyle() ipld.NodeStyle   { panic("later") }
func (plainMap__ValueAssemblerMap) ValueStyle() ipld.NodeStyle { panic("later") }
374

375 376
func (ma *plainMap__ValueAssemblerMap) Finish() error {
	if err := ma.ca.Finish(); err != nil {
377 378
		return err
	}
Eric Myhre's avatar
Eric Myhre committed
379
	return ma.p.va.AssignNode(ma.ca.w)
380
}