<- Back to shtanton's homepage
aboutsummaryrefslogtreecommitdiff
path: root/main/command.go
blob: 9554f9d900c801630e2e55b8ce8e3c22cc28603b (plain)
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
package main

import (
	"main/walk"
	"main/subex"
)

type Command interface {
	exec(*ProgramState)
}

type PrintValueCommand struct {}
func (cmd PrintValueCommand) exec(state *ProgramState) {
	path := walk.PathFromWalkValues(state.path)
	for _, value := range state.value {
		state.out <- walk.WalkItem {
			Value: value,
			Path: path,
		}
	}
}

type SequenceCommand struct {
	commands []Command
}
func (cmd SequenceCommand) exec(state *ProgramState) {
	for _, command := range cmd.commands {
		command.exec(state)
	}
}

type NextCommand struct {}
func (cmd NextCommand) exec(state *ProgramState) {
	nextItem := <- state.in
	state.value = []walk.WalkValue{nextItem.Value}
	state.path = nextItem.Path.ToWalkValues()
}

type AppendNextCommand struct {}
func (cmd AppendNextCommand) exec(state *ProgramState) {
	nextItem := <- state.in
	state.value = append(state.value, nextItem.Value)
	state.path = nextItem.Path.ToWalkValues()
}

type DeleteValueCommand struct {}
func (cmd DeleteValueCommand) exec(state *ProgramState) {
	state.value = nil
}

type DeletePathCommand struct {}
func (cmd DeletePathCommand) exec(state *ProgramState) {
	state.path = nil
}

func runSubex(state subex.SubexState, in []walk.WalkValue) (out []walk.WalkValue, error bool) {
	valueStream := make(chan walk.WalkValue)
	go func(in []walk.WalkValue, out chan<- walk.WalkValue) {
		for _, value := range in {
			out <- value
		}
		close(out)
	}(in, valueStream)
	atomStream := walk.Atomise(valueStream)
	atomsOut, error := subex.RunTransducer(state, atomStream)
	if error {
		return nil, true
	}
	valuesOut, err := walk.MemoryCompound(atomsOut)
	if err != nil {
		return nil, true
	}
	return valuesOut, false
}

type SubstituteValueCommand struct {
	subex subex.SubexState
	next Command
}
func (cmd SubstituteValueCommand) exec(state *ProgramState) {
	newValue, err := runSubex(cmd.subex, state.value)
	if err {
		return
	}
	state.value = newValue
	cmd.next.exec(state)
}

type SubstitutePathCommand struct {
	subex subex.SubexState
	next Command
}
func (cmd SubstitutePathCommand) exec(state *ProgramState) {
	newPath, err := runSubex(cmd.subex, state.path)
	if err {
		return
	}
	state.path = newPath
	cmd.next.exec(state)
}

type NoopCommand struct {}
func (cmd NoopCommand) exec(state *ProgramState) {}

type SwapXRegCommand struct {}
func (cmd SwapXRegCommand) exec(state *ProgramState) {
	v := state.value
	state.value = state.xreg
	state.xreg = v
}

type AppendXRegCommand struct {}
func (cmd AppendXRegCommand) exec(state *ProgramState) {
	state.xreg = append(state.xreg, state.value...)
}

type SwapPathCommand struct {}
func (cmd SwapPathCommand) exec(state *ProgramState) {
	v := state.value
	state.value = state.path
	state.path = v
}

type AppendPathCommand struct {}
func (cmd AppendPathCommand) exec(state *ProgramState) {
	state.path = append(state.path, state.value...)
}