summaryrefslogtreecommitdiffstats
path: root/src/gui
diff options
context:
space:
mode:
Diffstat (limited to 'src/gui')
-rw-r--r--src/gui/CMakeLists.txt4
-rw-r--r--src/gui/CoreConnector.vala209
-rw-r--r--src/gui/Ephraim.vala5
3 files changed, 97 insertions, 121 deletions
diff --git a/src/gui/CMakeLists.txt b/src/gui/CMakeLists.txt
index dc65a0c..ac62f9a 100644
--- a/src/gui/CMakeLists.txt
+++ b/src/gui/CMakeLists.txt
@@ -12,7 +12,9 @@ vala_precompile(VALA_C
PACKAGES
gtk+-2.0
gee-1.0
- erl_interface
+ gio-2.0
+ gio-unix-2.0
+ eva
OPTIONS
--thread
)
diff --git a/src/gui/CoreConnector.vala b/src/gui/CoreConnector.vala
index d43ab2f..2e59701 100644
--- a/src/gui/CoreConnector.vala
+++ b/src/gui/CoreConnector.vala
@@ -1,35 +1,31 @@
public class CoreConnector {
- unowned Thread thread;
- bool running;
+ //unowned Thread thread;
+ //bool running;
- Erl.Node node;
- Erl.Connection con;
- Erl.Term self;
+ //Erl.Node node;
+ //Erl.Connection con;
+ //Erl.Term self;
+ Eva.PacketHandler con;
public signal void update_contact(Contact contact);
public signal void new_conversation(string jid);
public signal void receive_message(string jid, string type, string message);
public signal void sent_message(string jid, string type, string message);
- private class TermStore {
+ /*private class TermStore {
public Erl.Term term;
- }
+ }*/
- static construct {
+ /*static construct {
Erl.init();
- }
+ }*/
public CoreConnector() {
- running = false;
+ //running = false;
}
- public bool start() {
- if(running)
- return true;
-
- running = true;
-
- node = Erl.Node("ephraim-gtk", "magiccookie", 0);
+ public void start() {
+ /*node = Erl.Node("ephraim-gtk", "magiccookie", 0);
con = node.connect("ephraim-core@avalon.local");
self = Erl.mk_self_pid(node);
@@ -41,101 +37,77 @@ public class CoreConnector {
return true;
} catch(ThreadError e) {
return false;
- }
+ }*/
+
+ con = new Eva.PacketHandler(new UnixInputStream(3, true), new UnixOutputStream(4, true), 4);
+ con.received_term.connect(handle_term);
+ con.start();
}
public void stop() {
- if(!running)
+ /*if(!running)
return;
running = false;
- thread.join();
-
- con.reg_send("ephraim", Erl.format("{unregister_ui,~w}", self));
- }
-
-
- private void* receive() {
- while(running) {
- TermStore response = new TermStore();
- Erl.ReceiveType ret = con.receive(out response.term, 1000);
-
- switch(ret) {
- case Erl.ReceiveType.ERROR:
- if(Erl.errno == Erl.Error.TIMEDOUT)
- break;
-
- running = false;
- break;
- case Erl.ReceiveType.TICK:
- // Do nothing
- break;
- case Erl.ReceiveType.MSG:
- Idle.add(() => {handle_term(response); return false;});
- break;
- }
- }
+ receive.end();*/
- return null;
+ //con.reg_send("ephraim", Erl.format("{unregister_ui,~w}", self));
+ con.send(new Eva.Atom("stop"));
}
- private Erl.Term? match(string pattern, Erl.Term term) {
- Erl.Term pattern_term = Erl.format(pattern);
-
- if(pattern_term.match(term) != 0)
- return pattern_term;
- else
- return null;
+ private static string from_utf8(Eva.Binary bin) {
+ string ret = ((string)bin.data).ndup(bin.len);
+ warn_if_fail(ret.validate());
+ return ret;
}
- private void handle_term(TermStore store) {
- unowned Erl.Term term = store.term;
- Erl.Term match_term;
+ private void handle_term(Eva.Term term) {
+ Gee.Map<string, Eva.Term> match;
- if((match_term = match("{roster_update,JID,Name,Subscription,Groups,Resources,Avatar}", term)) != null) {
- Erl.Term jid_term = match_term.var_content("JID");
- if(!jid_term.is_binary())
+ if((match = term.match(Eva.parse("{roster_update,JID,Name,Subscription,Groups,Resources,Avatar}"))) != null) {
+ Eva.Binary jid_term = match["JID"] as Eva.Binary;
+ if(jid_term == null)
// TODO Debug output
return;
- string jid = ((string)jid_term.bin_ptr()).ndup(jid_term.bin_size());
+ string jid = from_utf8(jid_term);
- Erl.Term name_term = match_term.var_content("Name");
+ Eva.Binary name_term = match["Name"] as Eva.Binary;
string? name;
- if (name_term.is_binary())
- name = ((string)name_term.bin_ptr()).ndup(name_term.bin_size());
+ if (name_term is Eva.Binary)
+ name = from_utf8(name_term);
else
name = null;
Contact contact = new Contact(jid, name);
- Erl.Term groups = match_term.var_content("Groups");
- while(groups.is_cons()) {
- Erl.Term group_term = groups.hd();
+ Eva.Cons groups = match["Groups"] as Eva.Cons;
+ while(groups != null) {
+ Eva.Binary group_term = groups.head as Eva.Binary;
- if(group_term.is_binary()) {
- string group = ((string)group_term.bin_ptr()).ndup(group_term.bin_size());
+ if(group_term != null) {
+ string group = Eva.binary_to_string(group_term.data, group_term.len);
contact.add_group(group);
}
- groups = groups.tl();
+ groups = groups.tail as Eva.Cons;
}
- Erl.Term resources = match_term.var_content("Resources");
- while(resources.is_cons()) {
- Erl.Term r;
+ Eva.Cons resources = match["Resources"] as Eva.Cons;
+ while(resources != null) {
+ Gee.Map<string, Eva.Term> r;
- if((r = match("{Name,{resource_entry,Priority,Show,Status}}", resources.hd())) != null) {
- Erl.Term rname_term = r.var_content("Name");
- Erl.Term prio_term = r.var_content("Priority");
- Erl.Term show_term = r.var_content("Show");
- Erl.Term status_term = r.var_content("Status");
+ if((r = resources.head.match(Eva.parse("{Name,{resource_entry,Priority,Show,Status}}"))) != null) {
+ Eva.Binary rname_term = r["Name"] as Eva.Binary;
+ Eva.Numeric prio_term = r["Priority"] as Eva.Numeric;
+ Eva.Atom show_term = r["Show"] as Eva.Atom;
+ Eva.Binary status_term = r["Status"] as Eva.Binary;
- if(rname_term.is_binary() && prio_term.is_integer() && show_term.is_atom()) {
- string rname = ((string)rname_term.bin_ptr()).ndup(rname_term.bin_size());
- int prio = prio_term.int_value();
+ if(rname_term != null && prio_term != null && show_term != null) {
+ string rname = from_utf8(rname_term);
+ int prio = prio_term.int_value;
Contact.Show show = Contact.Show.UNDEFINED;
- switch((string)show_term.atom_ptr()) {
+ switch(show_term.value) {
case "online":
show = Contact.Show.ONLINE;
break;
@@ -154,22 +126,22 @@ public class CoreConnector {
}
string? status = null;
- if(status_term.is_binary())
- status = ((string)status_term.bin_ptr()).ndup(status_term.bin_size());
+ if(status_term != null)
+ status = from_utf8(status_term);
contact.update_resource(rname, new Contact.Resource(prio, show, status));
}
}
- resources = resources.tl();
+ resources = resources.tail as Eva.Cons;
}
- Erl.Term avatar = match("{avatar,Data}", match_term.var_content("Avatar"));
+ Gee.Map<string, Eva.Term> avatar = match["Avatar"].match(Eva.parse("{avatar,Data}"));
if(avatar != null) {
- Erl.Term avatarData = avatar.var_content("Data");
+ Eva.Binary avatarData = avatar["Data"] as Eva.Binary;
- if(avatarData.is_binary()) {
- InputStream avatarStream = new MemoryInputStream.from_data(avatarData.bin_ptr(), avatarData.bin_size(), null);
+ if(avatarData != null) {
+ InputStream avatarStream = new MemoryInputStream.from_data(avatarData.data, avatarData.len, null);
try {
contact.avatar = new Gdk.Pixbuf.from_stream_at_scale(avatarStream, 32, 32, true, null);
avatarStream.close(null);
@@ -178,71 +150,72 @@ public class CoreConnector {
}
}
}
-
update_contact(contact);
}
- else if((match_term = match("{new_conversation,JID}", term)) != null) {
- Erl.Term jid_term = match_term.var_content("JID");
- if(!jid_term.is_binary())
+ else if((match = term.match(Eva.parse("{new_conversation,JID}"))) != null) {
+ Eva.Binary jid_term = match["JID"] as Eva.Binary;
+ if(jid_term == null)
// TODO Debug output
return;
- string jid = ((string)jid_term.bin_ptr()).ndup(jid_term.bin_size());
+ string jid = from_utf8(jid_term);
new_conversation(jid);
}
- else if((match_term = match("{receive_message,JID,Type,Body}", term)) != null) {
- Erl.Term jid_term = match_term.var_content("JID");
- if(!jid_term.is_binary())
+ else if((match = term.match(Eva.parse("{receive_message,JID,Type,Body}"))) != null) {
+ Eva.Binary jid_term = match["JID"] as Eva.Binary;
+ if(jid_term == null)
// TODO Debug output
return;
- string jid = ((string)jid_term.bin_ptr()).ndup(jid_term.bin_size());
+ string jid = from_utf8(jid_term);
- Erl.Term type_term = match_term.var_content("Type");
- if(!type_term.is_atom())
+ Eva.Atom type_term = match["Type"] as Eva.Atom;
+ if(type_term == null)
// TODO Debug output
return;
- string type = ((string)type_term.atom_ptr()).ndup(type_term.atom_size());
+ string type = type_term.value;
- Erl.Term body_term = match_term.var_content("Body");
- if(!body_term.is_binary())
+ Eva.Binary body_term = match["Body"] as Eva.Binary;
+ if(body_term == null)
// TODO Debug output
return;
- string body = ((string)body_term.bin_ptr()).ndup(body_term.bin_size());
+ string body = from_utf8(body_term);
receive_message(jid, type, body);
}
- else if((match_term = match("{sent_message,JID,Type,Body}", term)) != null) {
- Erl.Term jid_term = match_term.var_content("JID");
- if(!jid_term.is_binary())
+ else if((match = term.match(Eva.parse("{sent_message,JID,Type,Body}"))) != null) {
+ Eva.Binary jid_term = match["JID"] as Eva.Binary;
+ if(jid_term == null)
// TODO Debug output
return;
- string jid = ((string)jid_term.bin_ptr()).ndup(jid_term.bin_size());
+ string jid = from_utf8(jid_term);
- Erl.Term type_term = match_term.var_content("Type");
- if(!type_term.is_atom())
+ Eva.Atom type_term = match["Type"] as Eva.Atom;
+ if(type_term == null)
// TODO Debug output
return;
- string type = ((string)type_term.atom_ptr()).ndup(type_term.atom_size());
+ string type = type_term.value;
- Erl.Term body_term = match_term.var_content("Body");
- if(!body_term.is_binary())
+ Eva.Binary body_term = match["Body"] as Eva.Binary;
+ if(body_term == null)
// TODO Debug output
return;
- string body = ((string)body_term.bin_ptr()).ndup(body_term.bin_size());
+ string body = from_utf8(body_term);
sent_message(jid, type, body);
}
else {
- Erl.print_term(stdout, term);
- stdout.printf("\n");
+ stdout.printf("%s\n", term.to_string());
}
}
-
+
public void start_conversation(string jid) {
- con.reg_send("ephraim", Erl.format("{start_conversation,~w}", Erl.mk_binary(jid.to_utf8())));
+ char[] jid_utf8 = jid.to_utf8();
+ con.send(Eva.parse("{start_conversation,~w}", new Eva.Binary(jid_utf8)));
}
public void send_message(string jid, string type, string message) {
- con.reg_send("ephraim", Erl.format("{send_message,~w,~a,~w}", Erl.mk_binary(jid.to_utf8()), type, Erl.mk_binary(message.to_utf8())));
+ char[] jid_utf8 = jid.to_utf8();
+ char[] message_utf8 = message.to_utf8();
+ con.send(Eva.parse("{send_message,~w,~a,~w}", new Eva.Binary(jid_utf8), type, new Eva.Binary(message_utf8)));
}
}
diff --git a/src/gui/Ephraim.vala b/src/gui/Ephraim.vala
index 99a7a48..50f83e1 100644
--- a/src/gui/Ephraim.vala
+++ b/src/gui/Ephraim.vala
@@ -57,8 +57,9 @@ public class Ephraim {
conversations[jid].sent_message(type, message);
});
- if(!coreconn.start())
- return 1;
+ //if(!coreconn.start())
+ // return 1;
+ coreconn.start();
window.visible = true;
generated by cgit v1.2.3 (git 2.25.1) at 2024-11-22 00:25:28 +0100