First attempt, doesn't seem to work

Author: romellem

2019/23/intcode-computer-optimized.js

@@ -14,28 +14,46 @@ const IMMEDIATE_MODE = '1';
 const RELATIVE_MODE = '2';
 
 class Computer {
+	static ADD = ADD;
+	static MUL = MUL;
+	static INP = INP;
+	static OUT = OUT;
+	static JIT = JIT;
+	static JIF = JIF;
+	static LTH = LTH;
+	static EQU = EQU;
+	static ARB = ARB;
+	static STP = STP;
+
+	static POSITION_MODE = POSITION_MODE;
+	static IMMEDIATE_MODE = IMMEDIATE_MODE;
+	static RELATIVE_MODE = RELATIVE_MODE;
+
 	constructor({
 		memory,
 		inputs = [],
-		replenish_input = undefined,
-		pause_on_output = true,
-		id = 0,
+		// Called with computer as it's only arg
+		defaultInput,
+		pause_on = { [OUT]: true },
+		address,
 		clone_memory = false,
 	}) {
-		// For debugging
-		this.id = String.fromCharCode('A'.charCodeAt(0) + id);
+		// Must match initial input
+		this.address = address;
+		if (this.address !== inputs[0]) {
+			throw new Error(`Invalid address: ${address}, inputs: ${JSON.stringify(inputs)}`);
+		}
 
 		this.original_memory = clone_memory && memory.slice(0);
 		this.memory = memory.slice(0);
 		this.pointer = 0;
 		this.relative_base = 0;
-		this.pause_on_output = pause_on_output;
+		this.pause_on = pause_on;
 
 		this.inputs = Array.isArray(inputs) ? inputs.slice(0) : [inputs];
-		this.replenish_input = replenish_input;
 		this.outputs = [];
 
-		this.parseOpTime = 0;
+		this.defaultInput = defaultInput;
 
 		this.OPS = {
 			[ADD]: {
@@ -63,10 +81,11 @@ class Computer {
 				realName: 'INP',
 				params: 1,
 				fn: (a) => {
+					if (this.defaultInput && this.inputs.length === 0) {
+						let default_input_value = this.defaultInput(this);
+						this.inputs.push(default_input_value);
+					} 
 					this.memory[a] = this.inputs.shift();
-					if (this.replenish_input !== undefined) {
-						this.inputs.push(this.replenish_input);
-					}
 				},
 				write: true,
 			},
@@ -177,10 +196,10 @@ class Computer {
 			this.runOp(op);
 
 			/**
-			 * In circuits, computer execution should be paused on outout so that value can be passed to the next computer.
+			 * In circuits, computer execution should be paused on output so that value can be passed to the next computer.
 			 * Additionally, execution should immediately stopped if we have halted.
 			 */
-			if ((this.pause_on_output && op.name === OUT) || this.halted) {
+			if (this.pause_on[op.name] || this.halted) {
 				break;
 			}
 

2019/23/network.js

@@ -0,0 +1,62 @@
+const { Computer } = require('./intcode-computer-optimized');
+
+class Network {
+	constructor(program, nics_count = 50) {
+		this.original_program = [...program];
+		this.packet_queue = Array(nics_count).fill([]);
+
+		this.nics = Array(nics_count)
+			.fill()
+			.map((_, i) => {
+				return new Computer({
+					memory: program,
+					inputs: [i],
+					address: i,
+					defaultInput: (computer) => {
+						if (this.packet_queue[computer.address].length === 0) {
+							return -1;
+						} else {
+							// Take first packet
+							let packet = this.packet_queue[computer.address][0];
+							if (packet.length === 2) {
+								// First shift `x` value and keep partial packet in queue
+								let x = packet.shift();
+								return x;
+							} else {
+								// Then take the `y` value and remove the packet from the queue
+								let [y] = this.packet_queue[computer.address].shift();
+								return y;
+							}
+						}
+					},
+					pause_on: {
+						[Computer.OUT]: true,
+						[Computer.INP]: true,
+					},
+				});
+			});
+	}
+
+	run(break_on_address = 255) {
+		while (true) {
+			for (let nic of this.nics) {
+				let outputs = nic.run();
+				if (outputs.length === 3) {
+					let address = outputs.shift();
+					let x = outputs.shift();
+					let y = outputs.shift();
+
+					if (address === break_on_address) {
+						return { x, y };
+					}
+					this.packet_queue[address].push([x, y]);
+				}
+			}
+		}
+
+	}
+}
+
+module.exports = {
+	Network,
+};

2019/23/part-one.js

@@ -1 +1,6 @@
 const { input } = require('./input');
+const { Network } = require('./network');
+
+let network = new Network(input);
+let net_packet = network.run();
+console.log(net_packet);