1.1 --- a/com.py Tue Jun 15 14:58:05 2010 +0200
1.2 +++ b/com.py Thu Jun 17 23:24:41 2010 +0200
1.3 @@ -44,6 +44,7 @@
1.4 model.register(socket, client, eventType)
1.5 socket.sendto("observer for event type %s added: " % eventType
1.6 + str(client) + "\n", client)
1.7 + print "observer for event type %s added: " % eventType + str(client) + "\n"
1.8
1.9 def setResolution(socket, client, worker, (modelName, x, y)):
1.10 model = lookupModel(socket, client, modelName)
1.11 @@ -96,6 +97,16 @@
1.12 cells[k] = model.cells[k]
1.13 print "size: %i hash: %s" % (len(cells),
1.14 hashlib.sha256(str(cells)).hexdigest())
1.15 +
1.16 +def data(socket, client, worker, (modelName, cell_r, cell_i, value_r, value_i)):
1.17 + model = lookupModel(socket, client, modelName)
1.18 + cell = complex(float(cell_r), float(cell_i))
1.19 + value = complex(float(value_r), float(value_i))
1.20 + if model:
1.21 + print "received cell " + str(cell) + ": " + str(value)
1.22 + model.cells[complex(cell)] = complex(value)
1.23 + else:
1.24 + return (cell, value)
1.25
1.26 commands = {"help": (help, "help"),
1.27 "create model": (createModel, "creates a new model"),
1.28 @@ -106,4 +117,5 @@
1.29 "set range": (setRange, "sets the model range"),
1.30 "update": (update, "updates the model data"),
1.31 "view": (view, "shows the model data"),
1.32 + "data": (data, "sends data packets"),
1.33 "add observer": (addObserver, "adds an observer to a model's events"),}