summaryrefslogtreecommitdiff
path: root/dice-lang/src/bjc/dicelang/v2/StreamEngine.java
blob: c17abe41d8bd0b28149bcd82ba0975570f5d35cf (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
package bjc.dicelang.v2;

import bjc.utils.funcdata.FunctionalList;
import bjc.utils.funcdata.IList;
import bjc.utils.esodata.Tape;

public class StreamEngine {
	private DiceLangEngine eng;

	private Tape<IList<String>> streams;
	private IList<String>       currStream;

	public StreamEngine(DiceLangEngine eng) {
		streams = new Tape<>();

		currStream = new FunctionalList<>();
		streams.append(currStream);
	}

	public boolean doStreams(String[] toks, IList<String> dest) {
		for(String tk : toks) {
			if(tk.startsWith("{@")) {
				if(!processCommand(tk)) return false;
			} else {
				currStream.add(tk);
			}
		}

		for(String tk : currStream.toIterable()) {
			dest.add(tk);
		}

		return true;
	}

	private boolean processCommand(String tk) {
		switch(tk.charAt(2)) {
			case '+':
				streams.append(new FunctionalList<>());
				break;
			case '>':
				if(!streams.right()) {
					System.out.println("\tERROR: Attempted to switch to non-existent stream");
					return false;
				}

				currStream = streams.item();
				break;
			case '<':
				if(!streams.left()) {
					System.out.println("\tERROR: Attempted to switch to non-existent stream");
					return false;
				}

				currStream = streams.item();
				break;
			case '-':
				if(streams.size() == 1) {
					System.out.println("\tERROR: Cannot delete last stream");
					return false;
				} else {
					streams.remove();
					currStream = streams.item();
				}
				break;
			default:
				System.out.println("\tERROR: Unknown stream control command: " + tk);
				return false;
		}

		return true;
	}
}