Skip to content
Snippets Groups Projects
Commit a9d3b860 authored by Ramin Yaghoubzadeh's avatar Ramin Yaghoubzadeh
Browse files

We implemented a few steps towards our cool "incremental printing demo with feedback"

parent d880537d
No related branches found
No related tags found
No related merge requests found
Hide whitespace changes
Inline Side-by-side
java/src/ipaacademo/TextPrinter.java
+ 93
− 28
View file @ a9d3b860
package ipaacademo; package ipaacademo;
import java.util.EnumSet;
import java.util.Map;
import java.util.HashMap;
import java.util.Set; import java.util.Set;
import com.google.common.collect.ImmutableMap;
import com.google.common.collect.ImmutableSet;
import ipaaca.AbstractIU; import ipaaca.*;
import ipaaca.Initializer;
import ipaaca.InputBuffer;
import ipaaca.LocalIU;
import ipaaca.OutputBuffer;
import ipaaca.RemotePushIU;
import javax.swing.JFrame; import javax.swing.JFrame;
import javax.swing.JLabel; import javax.swing.JLabel;
...@@ -16,6 +16,23 @@ import com.google.common.collect.ImmutableSet; ...@@ -16,6 +16,23 @@ import com.google.common.collect.ImmutableSet;
public class TextPrinter public class TextPrinter
{ {
private static final class MyEventHandler implements HandlerFunctor
{
@Override
public void handle(AbstractIU iu, IUEventType type, boolean local)
{
switch(type)
{
case ADDED: System.out.println("IU added "+iu.getPayload()); break;
case COMMITTED: System.out.println("IU committed"); break;
case UPDATED: System.out.println("IU updated "+iu.getPayload()); break;
case LINKSUPDATED: System.out.println("IU links updated"); break;
}
}
}
static static
{ {
Initializer.initializeIpaacaRsb(); Initializer.initializeIpaacaRsb();
...@@ -53,16 +70,25 @@ public class TextPrinter ...@@ -53,16 +70,25 @@ public class TextPrinter
{ {
this.inBuffer = inBuffer; this.inBuffer = inBuffer;
this.label = label; this.label = label;
EnumSet<IUEventType> types = EnumSet.of(IUEventType.ADDED,IUEventType.COMMITTED,IUEventType.UPDATED,IUEventType.LINKSUPDATED);
Set<String> categories = new ImmutableSet.Builder<String>().add(CATEGORY).build();
MyEventHandler printingEventHandler;
printingEventHandler = new MyEventHandler();
this.inBuffer.registerHandler(new IUEventHandler(printingEventHandler,types,categories));
} }
@Override @Override
public void run() public void run()
{ {
long startTime = System.currentTimeMillis(); long startTime = System.currentTimeMillis();
long nextTime = System.currentTimeMillis();
//long lastNewLetterTime = System.currentTimeMillis();
while(true) while(true)
{ {
double duration = (System.currentTimeMillis()-startTime)/1000d; //double duration = (System.currentTimeMillis()-startTime)/1000d;
long currentTime = System.currentTimeMillis();
RemotePushIU iuFirst = null; RemotePushIU iuFirst = null;
for (RemotePushIU iu : inBuffer.getIUs()) for (RemotePushIU iu : inBuffer.getIUs())
{ {
...@@ -72,26 +98,64 @@ public class TextPrinter ...@@ -72,26 +98,64 @@ public class TextPrinter
break; break;
} }
} }
if (iuFirst==null) {
int numChars = (int)(duration/RATE); startTime = System.currentTimeMillis();
continue;
AbstractIU iu = iuFirst; }
String str = ""; //int numChars = (int)(duration/RATE);
for(int i=0;i<numChars;i++)
{ if (currentTime >= nextTime) {
str += iu.getPayload().get("CONTENT"); AbstractIU iu = iuFirst;
Set<String> successor = iu.getLinks("SUCCESSOR"); String str = "";
if(successor!=null && !successor.isEmpty()) int i = 0;
{ boolean first_new_element = true;
iu = inBuffer.getIU(successor.iterator().next()); do {
} if (iu.getPayload().get("STATE") != null || first_new_element) {
else str += "<font color=\"#000000\">";
{ str += iu.getPayload().get("CONTENT");
break; str += "</font>";
if (iu.getPayload().get("STATE") == null) {
iu.getPayload().put("STATE", "REALIZED");
first_new_element = false;
nextTime = currentTime + (int)(1000.0*RATE);
}
} else {
str += "<font color=\"#909090\">";
str += iu.getPayload().get("CONTENT");
str += "</font>";
//lastNewLetterTime = System.currentTimeMillis();
}
Set<String> successor = iu.getLinks("SUCCESSOR");
if(successor!=null && !successor.isEmpty())
{
iu = inBuffer.getIU(successor.iterator().next());
}
i++;
} while(! iu.getLinks("SUCCESSOR").isEmpty());
if (iu.getPayload().get("STATE") != null || first_new_element) {
//if (i<numChars) {
str += "<font color=\"#000000\">";
str += iu.getPayload().get("CONTENT");
str += "</font>";
if (iu.getPayload().get("STATE") == null) {
iu.getPayload().put("STATE", "REALIZED");
first_new_element = false;
nextTime = currentTime + (int)(RATE*1000.0);
}
} else {
str += "<font color=\"#909090\">";
str += iu.getPayload().get("CONTENT");
str += "</font>";
//lastNewLetterTime = System.currentTimeMillis();
} }
str = "<html>"+str+"</html>";
//System.out.println(str);
label.setText(str);
} else {
// just wait until we can print some more
} }
label.setText(str);
try try
{ {
Thread.sleep(200); Thread.sleep(200);
...@@ -111,7 +175,7 @@ public class TextPrinter ...@@ -111,7 +175,7 @@ public class TextPrinter
OutputBuffer outBuffer = new OutputBuffer("componentX"); OutputBuffer outBuffer = new OutputBuffer("componentX");
String[] inputString = {"h","e","l","l","o"," ","w","o","r","l","d","!"}; /*String[] inputString = {"h","e","l","l","o"," ","w","o","r","l","d","!"};
LocalIU predIU = null; LocalIU predIU = null;
for(String str:inputString) for(String str:inputString)
{ {
...@@ -125,7 +189,8 @@ public class TextPrinter ...@@ -125,7 +189,8 @@ public class TextPrinter
predIU.setLinks("SUCCESSOR",ImmutableSet.of(localIU.getUid())); predIU.setLinks("SUCCESSOR",ImmutableSet.of(localIU.getUid()));
} }
predIU = localIU; predIU = localIU;
} }*/
tp.start(); tp.start();
} }
} }
python/test/src/textsender.py 0 → 100755
+ 95
− 0
View file @ a9d3b860
#!/usr/bin/env python
import sys
import time
import unittest
import ipaaca
RECV_CATEGORY = 'WORD'
SEND_CATEGORY = 'TEXT'
class TextSender(object):
def __init__(self):
self.ob = ipaaca.OutputBuffer('TextSenderOut')
self.ob.register_handler(self.outbuffer_handle_iu_event)
self.ib = ipaaca.InputBuffer('TextSenderIn', [RECV_CATEGORY])
self.ib.register_handler(self.inbuffer_handle_iu_event)
def outbuffer_handle_iu_event(self, iu, event_type, local):
if event_type == "UPDATED":
parent_uids = iu.get_links("GRIN")
if len(parent_uids) > 0:
parent_uid = list(parent_uids)[0]
print "updating parent ..."
next_uids = iu.get_links('SUCCESSOR')
if len(next_uids) > 0:
next_uid = list(next_uids)[0]
next_iu = self.ob.iu_store[next_uid]
next_letter_grin_links = next_iu.get_links("GRIN")
if len(next_letter_grin_links) > 0 and list(next_letter_grin_links)[0] != parent_uid:
# the next letter belongs to a new word
parent_iu = self.ib.iu_store[parent_uid]
parent_iu.payload['STATE'] = 'REALIZED'
else:
# the next letter belongs to the same word
parent_iu = self.ib.iu_store[parent_uid]
parent_iu.payload['STATE'] = 'STARTED'
else:
# there are no more letters, this is the end of the final word
parent_iu = self.ib.iu_store[parent_uid]
parent_iu.payload['STATE'] = 'REALIZED'
print " ... done."
else:
print('(own IU event '+event_type+' '+str(iu.uid)+')')
def inbuffer_handle_iu_event(self, iu, event_type, local):
if event_type == "ADDED": # and iu.category == RECV_CATEGORY:
print("Received new word: "+iu.payload['WORD'])
sender.publish_text_to_print(iu.payload['WORD'], parent_iu_uid=iu.uid)
elif event_type == "RETRACTED":
retracted_uid = iu.uid
else:
print('(IU event '+event_type+' '+str(iu.uid)+')')
pass
def find_last_iu(self):
for iu in self.ob.iu_store.values():
if len(iu.get_links('SUCCESSOR')) == 0:
return iu
return None
def publish_text_to_print(self, text, parent_iu_uid=None):
previous_iu = self.find_last_iu()
if previous_iu is not None:
# insert a blank if we already have words in the buffer
iu = ipaaca.IU( SEND_CATEGORY )
iu.payload = { 'CONTENT': ' ' }
self.ob.add(iu)
previous_iu.add_links( 'SUCCESSOR', [iu.uid] )
iu.add_links( 'PREDECESSOR', [previous_iu.uid] )
if parent_iu_uid is not None: iu.add_links( 'GRIN', [parent_iu_uid] )
previous_iu = iu
for c in text:
iu = ipaaca.IU( SEND_CATEGORY )
iu.payload = { 'CONTENT': c }
self.ob.add(iu)
if previous_iu is not None:
previous_iu.add_links( 'SUCCESSOR', [iu.uid] )
iu.add_links( 'PREDECESSOR', [previous_iu.uid] )
if parent_iu_uid is not None: iu.add_links( 'GRIN', [parent_iu_uid] )
if previous_iu is not None: print previous_iu.get_all_links()
previous_iu = iu
if __name__ == '__main__':
sender = TextSender()
time.sleep(1.0)
sender.publish_text_to_print('(INIT)')
print "Press Ctrl-C to cancel..."
while True:
time.sleep(0.1)
python/test/src/wordsender.py 0 → 100755
+ 48
− 0
View file @ a9d3b860
#!/usr/bin/env python
import sys
import time
import unittest
import ipaaca
SEND_CATEGORY = 'WORD'
class WordSender(object):
def __init__(self):
self.ob = ipaaca.OutputBuffer('WordSenderOut')
self.ob.register_handler(self.outbuffer_handle_iu_event)
def outbuffer_handle_iu_event(self, iu, event_type, local):
if event_type == "UPDATED":
print(iu.payload['WORD']+': '+iu.payload['STATE'])
else:
print('(own IU event '+event_type+' '+str(iu.uid)+')')
def find_last_iu(self):
for iu in self.ob.iu_store.values():
if len(iu.get_links('SUCCESSOR')) == 0:
return iu
return None
def publish_words(self, words):
previous_iu = self.find_last_iu()
for word in words:
iu = ipaaca.IU( SEND_CATEGORY )
iu.payload = { 'WORD': word }
self.ob.add(iu)
if previous_iu is not None:
previous_iu.add_links( 'SUCCESSOR', [iu.uid] )
iu.add_links( 'PREDECESSOR', [previous_iu.uid] )
previous_iu = iu
if __name__ == '__main__':
sender = WordSender()
sender.publish_words(['this','is','a','demonstration','of','incremental','generation'])
print sender.ob.unique_name
print "Press Ctrl-C to cancel..."
while True:
time.sleep(0.1)
0% or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment