| author | Stiletto <blasux@blasux.ru> |
| Wed, 24 Oct 2012 00:37:31 +0400 | |
| changeset 7 | a49fb1ec5e2a |
| parent 3 | dd7a02c6d476 |
| child 12 | d3e36b368fc5 |
| permissions | -rw-r--r-- |
| 0 | 1 |
|
|
1
76caf6a3f413
Somehow compiles and even joins a conference
Stiletto <blasux@blasux.ru>
parents:
0
diff
changeset
|
2 |
class Connection : Object { |
|
76caf6a3f413
Somehow compiles and even joins a conference
Stiletto <blasux@blasux.ru>
parents:
0
diff
changeset
|
3 |
public Lm.Connection cn; |
|
76caf6a3f413
Somehow compiles and even joins a conference
Stiletto <blasux@blasux.ru>
parents:
0
diff
changeset
|
4 |
public string jid; |
|
76caf6a3f413
Somehow compiles and even joins a conference
Stiletto <blasux@blasux.ru>
parents:
0
diff
changeset
|
5 |
public string password; |
|
76caf6a3f413
Somehow compiles and even joins a conference
Stiletto <blasux@blasux.ru>
parents:
0
diff
changeset
|
6 |
public string resource; |
|
76caf6a3f413
Somehow compiles and even joins a conference
Stiletto <blasux@blasux.ru>
parents:
0
diff
changeset
|
7 |
public string server; |
|
76caf6a3f413
Somehow compiles and even joins a conference
Stiletto <blasux@blasux.ru>
parents:
0
diff
changeset
|
8 |
public int port; |
|
76caf6a3f413
Somehow compiles and even joins a conference
Stiletto <blasux@blasux.ru>
parents:
0
diff
changeset
|
9 |
public bool ssl; |
| 0 | 10 |
|
11 |
public enum State { |
|
12 |
DISCONNECTED, |
|
13 |
CONNECTING, |
|
14 |
AUTHENTICATING, |
|
15 |
CONNECTED |
|
16 |
} |
|
|
1
76caf6a3f413
Somehow compiles and even joins a conference
Stiletto <blasux@blasux.ru>
parents:
0
diff
changeset
|
17 |
|
| 0 | 18 |
protected State _state; |
19 |
||
20 |
public State state { |
|
21 |
get { return _state; } |
|
22 |
} |
|
23 |
||
| 3 | 24 |
public Gee.ArrayList<Module> modules; |
|
1
76caf6a3f413
Somehow compiles and even joins a conference
Stiletto <blasux@blasux.ru>
parents:
0
diff
changeset
|
25 |
|
| 0 | 26 |
public signal void state_changed(State old_state, State new_state, string description); |
|
2
4e050075fab9
Level of stubbornness skyrocketed
Stiletto <blasux@blasux.ru>
parents:
1
diff
changeset
|
27 |
public signal void check_time(); |
| 0 | 28 |
protected void _change_state(State new_state, string description) { |
29 |
var old_state = this._state; |
|
30 |
if (old_state != new_state) { |
|
31 |
this._state = new_state; |
|
32 |
stderr.printf("State changed %s -> %s : %s\n",old_state.to_string(), new_state.to_string(), description); |
|
33 |
state_changed(old_state, new_state, description); |
|
34 |
} else |
|
35 |
stderr.printf("State not changed %s : %s\n",old_state.to_string(), description); |
|
36 |
} |
|
37 |
||
|
1
76caf6a3f413
Somehow compiles and even joins a conference
Stiletto <blasux@blasux.ru>
parents:
0
diff
changeset
|
38 |
public Connection(Config cfg) { |
| 3 | 39 |
this.modules = new Gee.ArrayList<Module>(); |
|
1
76caf6a3f413
Somehow compiles and even joins a conference
Stiletto <blasux@blasux.ru>
parents:
0
diff
changeset
|
40 |
this.jid = cfg["server","jid"]; |
|
76caf6a3f413
Somehow compiles and even joins a conference
Stiletto <blasux@blasux.ru>
parents:
0
diff
changeset
|
41 |
this.password = cfg["server","password"]; |
| 0 | 42 |
|
|
1
76caf6a3f413
Somehow compiles and even joins a conference
Stiletto <blasux@blasux.ru>
parents:
0
diff
changeset
|
43 |
this.server = cfg.get_default("server", "server", this.jid.split("@",2)[1]); |
| 0 | 44 |
|
|
1
76caf6a3f413
Somehow compiles and even joins a conference
Stiletto <blasux@blasux.ru>
parents:
0
diff
changeset
|
45 |
if (cfg.has_key("server", "port")) |
|
76caf6a3f413
Somehow compiles and even joins a conference
Stiletto <blasux@blasux.ru>
parents:
0
diff
changeset
|
46 |
this.port = cfg["server", "port"].to_int(); |
| 0 | 47 |
else |
48 |
this.port = Lm.Connection.DEFAULT_PORT; |
|
49 |
||
|
1
76caf6a3f413
Somehow compiles and even joins a conference
Stiletto <blasux@blasux.ru>
parents:
0
diff
changeset
|
50 |
this.ssl = (cfg.get_default("server", "ssl", "yes")=="yes"); |
| 0 | 51 |
|
|
1
76caf6a3f413
Somehow compiles and even joins a conference
Stiletto <blasux@blasux.ru>
parents:
0
diff
changeset
|
52 |
this.resource = cfg.get_default("server", "resource", "iswydt"); |
| 0 | 53 |
|
54 |
cn = new Lm.Connection(this.server); |
|
55 |
cn.set_disconnect_function((connection, reason) => { |
|
56 |
stderr.printf("Disconnected: %s\n",reason.to_string()); |
|
57 |
_change_state(State.DISCONNECTED,reason.to_string()); |
|
58 |
}, null); |
|
|
1
76caf6a3f413
Somehow compiles and even joins a conference
Stiletto <blasux@blasux.ru>
parents:
0
diff
changeset
|
59 |
var msg_handler = new Lm.MessageHandler((handler, connection, message) => { |
|
76caf6a3f413
Somehow compiles and even joins a conference
Stiletto <blasux@blasux.ru>
parents:
0
diff
changeset
|
60 |
stdout.printf("Got msg\n"); |
|
76caf6a3f413
Somehow compiles and even joins a conference
Stiletto <blasux@blasux.ru>
parents:
0
diff
changeset
|
61 |
var node = message.get_node(); |
|
76caf6a3f413
Somehow compiles and even joins a conference
Stiletto <blasux@blasux.ru>
parents:
0
diff
changeset
|
62 |
var body = node.find_child("body"); |
|
76caf6a3f413
Somehow compiles and even joins a conference
Stiletto <blasux@blasux.ru>
parents:
0
diff
changeset
|
63 |
if (body!=null) { |
|
76caf6a3f413
Somehow compiles and even joins a conference
Stiletto <blasux@blasux.ru>
parents:
0
diff
changeset
|
64 |
stdout.printf("MSG %s to %s: %s\n", node.get_attribute("from"), node.get_attribute("to"), body.get_value()); |
|
76caf6a3f413
Somehow compiles and even joins a conference
Stiletto <blasux@blasux.ru>
parents:
0
diff
changeset
|
65 |
} |
|
76caf6a3f413
Somehow compiles and even joins a conference
Stiletto <blasux@blasux.ru>
parents:
0
diff
changeset
|
66 |
return Lm.HandlerResult.ALLOW_MORE_HANDLERS; |
|
76caf6a3f413
Somehow compiles and even joins a conference
Stiletto <blasux@blasux.ru>
parents:
0
diff
changeset
|
67 |
}, null); |
|
76caf6a3f413
Somehow compiles and even joins a conference
Stiletto <blasux@blasux.ru>
parents:
0
diff
changeset
|
68 |
cn.register_message_handler(msg_handler, Lm.MessageType.MESSAGE, Lm.HandlerPriority.NORMAL); |
|
76caf6a3f413
Somehow compiles and even joins a conference
Stiletto <blasux@blasux.ru>
parents:
0
diff
changeset
|
69 |
/*var muc_handler = new Lm.MessageHandler((handler, connection, message) => { |
|
76caf6a3f413
Somehow compiles and even joins a conference
Stiletto <blasux@blasux.ru>
parents:
0
diff
changeset
|
70 |
var node = message.node; |
|
76caf6a3f413
Somehow compiles and even joins a conference
Stiletto <blasux@blasux.ru>
parents:
0
diff
changeset
|
71 |
var from = node.get_attribute("from"); |
|
76caf6a3f413
Somehow compiles and even joins a conference
Stiletto <blasux@blasux.ru>
parents:
0
diff
changeset
|
72 |
if (from != null) { |
|
76caf6a3f413
Somehow compiles and even joins a conference
Stiletto <blasux@blasux.ru>
parents:
0
diff
changeset
|
73 |
var froms = from.split("/",2); |
|
76caf6a3f413
Somehow compiles and even joins a conference
Stiletto <blasux@blasux.ru>
parents:
0
diff
changeset
|
74 |
//stdout.printf("From: %s %s\n",node.to_string(),message.get_type().to_string()); |
|
76caf6a3f413
Somehow compiles and even joins a conference
Stiletto <blasux@blasux.ru>
parents:
0
diff
changeset
|
75 |
if (rooms.has_key(froms[0])) { |
|
76caf6a3f413
Somehow compiles and even joins a conference
Stiletto <blasux@blasux.ru>
parents:
0
diff
changeset
|
76 |
return rooms[froms[0]].muc_handler(handler, connection, message); |
|
76caf6a3f413
Somehow compiles and even joins a conference
Stiletto <blasux@blasux.ru>
parents:
0
diff
changeset
|
77 |
} |
|
76caf6a3f413
Somehow compiles and even joins a conference
Stiletto <blasux@blasux.ru>
parents:
0
diff
changeset
|
78 |
} |
|
76caf6a3f413
Somehow compiles and even joins a conference
Stiletto <blasux@blasux.ru>
parents:
0
diff
changeset
|
79 |
return Lm.HandlerResult.ALLOW_MORE_HANDLERS; |
|
76caf6a3f413
Somehow compiles and even joins a conference
Stiletto <blasux@blasux.ru>
parents:
0
diff
changeset
|
80 |
}, null); |
|
76caf6a3f413
Somehow compiles and even joins a conference
Stiletto <blasux@blasux.ru>
parents:
0
diff
changeset
|
81 |
cn.register_message_handler(muc_handler, Lm.MessageType.MESSAGE, Lm.HandlerPriority.NORMAL); |
|
76caf6a3f413
Somehow compiles and even joins a conference
Stiletto <blasux@blasux.ru>
parents:
0
diff
changeset
|
82 |
cn.register_message_handler(muc_handler, Lm.MessageType.PRESENCE, Lm.HandlerPriority.NORMAL); |
|
76caf6a3f413
Somehow compiles and even joins a conference
Stiletto <blasux@blasux.ru>
parents:
0
diff
changeset
|
83 |
cn.register_message_handler(muc_handler, Lm.MessageType.IQ, Lm.HandlerPriority.NORMAL);*/ |
|
76caf6a3f413
Somehow compiles and even joins a conference
Stiletto <blasux@blasux.ru>
parents:
0
diff
changeset
|
84 |
state_changed.connect( (olds, news, desc) => { |
|
76caf6a3f413
Somehow compiles and even joins a conference
Stiletto <blasux@blasux.ru>
parents:
0
diff
changeset
|
85 |
if (news == Connection.State.CONNECTED) { |
|
76caf6a3f413
Somehow compiles and even joins a conference
Stiletto <blasux@blasux.ru>
parents:
0
diff
changeset
|
86 |
cn.send_raw("<message to='stiletto@stiletto.name'><body>ТХБ</body></message>"); |
|
76caf6a3f413
Somehow compiles and even joins a conference
Stiletto <blasux@blasux.ru>
parents:
0
diff
changeset
|
87 |
/*var room = new Conference(this, "говнохост@conference.blasux.ru", "Ζαλυπα"); |
|
76caf6a3f413
Somehow compiles and even joins a conference
Stiletto <blasux@blasux.ru>
parents:
0
diff
changeset
|
88 |
room.join("Oh hai"); |
|
76caf6a3f413
Somehow compiles and even joins a conference
Stiletto <blasux@blasux.ru>
parents:
0
diff
changeset
|
89 |
this.rooms[room.jid] = room;*/ |
|
76caf6a3f413
Somehow compiles and even joins a conference
Stiletto <blasux@blasux.ru>
parents:
0
diff
changeset
|
90 |
} |
|
76caf6a3f413
Somehow compiles and even joins a conference
Stiletto <blasux@blasux.ru>
parents:
0
diff
changeset
|
91 |
}); |
|
2
4e050075fab9
Level of stubbornness skyrocketed
Stiletto <blasux@blasux.ru>
parents:
1
diff
changeset
|
92 |
check_time.connect( () => { |
|
4e050075fab9
Level of stubbornness skyrocketed
Stiletto <blasux@blasux.ru>
parents:
1
diff
changeset
|
93 |
if (_state == State.DISCONNECTED) |
|
4e050075fab9
Level of stubbornness skyrocketed
Stiletto <blasux@blasux.ru>
parents:
1
diff
changeset
|
94 |
open(); |
|
4e050075fab9
Level of stubbornness skyrocketed
Stiletto <blasux@blasux.ru>
parents:
1
diff
changeset
|
95 |
}); |
| 0 | 96 |
} |
| 3 | 97 |
public void add_module(Module module) { |
98 |
modules.add(module); |
|
99 |
} |
|
| 0 | 100 |
public void open() { |
101 |
||
102 |
stderr.printf("Connecting to %s:%d as %s\n",server,port,jid); |
|
103 |
cn.set_port(port); |
|
104 |
cn.set_jid(jid); |
|
105 |
_change_state(State.CONNECTING,""); |
|
106 |
try { |
|
107 |
var result = cn.open((connection, consuc) => { |
|
108 |
stderr.printf("Connection success: %s\n",consuc.to_string()); |
|
109 |
if (consuc) { |
|
110 |
_change_state(State.AUTHENTICATING,""); |
|
111 |
stderr.printf("Authing\n"); |
|
112 |
cn.authenticate(jid.split("@",2)[0],password, resource, (connection, authsuc) => { |
|
113 |
stderr.printf("Auth success: %s\n",authsuc.to_string()); |
|
114 |
if (authsuc) { |
|
115 |
_change_state(State.CONNECTED,""); |
|
116 |
} else |
|
117 |
cn.close(); |
|
118 |
}, null); |
|
119 |
} else { |
|
120 |
_change_state(State.DISCONNECTED, "Connection not successful"); |
|
121 |
} |
|
122 |
}, null); |
|
123 |
if (!result) |
|
124 |
_change_state(State.DISCONNECTED, "Open failed"); |
|
125 |
} catch (Error e) { |
|
126 |
stderr.printf("Error: %s\n", e.message); |
|
127 |
_change_state(State.DISCONNECTED, e.message); |
|
128 |
} |
|
129 |
} |
|
|
7
a49fb1ec5e2a
Send a reason when interrupted by sigint
Stiletto <blasux@blasux.ru>
parents:
3
diff
changeset
|
130 |
public void close(string reason) { |
|
a49fb1ec5e2a
Send a reason when interrupted by sigint
Stiletto <blasux@blasux.ru>
parents:
3
diff
changeset
|
131 |
if ((state==State.CONNECTED)&&(reason != null)) { |
|
a49fb1ec5e2a
Send a reason when interrupted by sigint
Stiletto <blasux@blasux.ru>
parents:
3
diff
changeset
|
132 |
var prs = new Lm.Message(null, Lm.MessageType.PRESENCE); |
|
a49fb1ec5e2a
Send a reason when interrupted by sigint
Stiletto <blasux@blasux.ru>
parents:
3
diff
changeset
|
133 |
prs.node.set_attribute("type","unavailable"); |
|
a49fb1ec5e2a
Send a reason when interrupted by sigint
Stiletto <blasux@blasux.ru>
parents:
3
diff
changeset
|
134 |
prs.node.add_child("status",reason); |
|
a49fb1ec5e2a
Send a reason when interrupted by sigint
Stiletto <blasux@blasux.ru>
parents:
3
diff
changeset
|
135 |
cn.send(prs); |
|
a49fb1ec5e2a
Send a reason when interrupted by sigint
Stiletto <blasux@blasux.ru>
parents:
3
diff
changeset
|
136 |
} |
| 3 | 137 |
cn.close(); |
138 |
} |
|
| 0 | 139 |
} |
140 |
|
|
141 |
||
| 3 | 142 |
static Connection account; |
143 |
static MainLoop loop; |
|
144 |
||
| 0 | 145 |
int main(string[] args) { |
146 |
if (args.length<2) { |
|
147 |
stderr.printf("Usage: %s <config file>\n",args[0]); |
|
148 |
return 1; |
|
149 |
} |
|
|
1
76caf6a3f413
Somehow compiles and even joins a conference
Stiletto <blasux@blasux.ru>
parents:
0
diff
changeset
|
150 |
Log.set_handler("Muc", (LogLevelFlags)65535, (domain, levels, message) => { |
| 0 | 151 |
stderr.printf("--- %s\n", message); |
|
1
76caf6a3f413
Somehow compiles and even joins a conference
Stiletto <blasux@blasux.ru>
parents:
0
diff
changeset
|
152 |
}); |
| 3 | 153 |
Log.set_handler("muc_log", (LogLevelFlags)65535, (domain, levels, message) => { |
154 |
stderr.printf("--- %s\n", message); |
|
155 |
}); |
|
| 0 | 156 |
log("LM", LogLevelFlags.LEVEL_DEBUG, "HATE HATE"); |
157 |
var cfg = new Config.from_file(args[1]); |
|
| 3 | 158 |
loop = new MainLoop(); |
159 |
account = new Connection(cfg); |
|
|
2
4e050075fab9
Level of stubbornness skyrocketed
Stiletto <blasux@blasux.ru>
parents:
1
diff
changeset
|
160 |
//account.open(); |
| 0 | 161 |
stdout.printf("Fuck yeah\n"); |
|
2
4e050075fab9
Level of stubbornness skyrocketed
Stiletto <blasux@blasux.ru>
parents:
1
diff
changeset
|
162 |
var checktimer = new TimeoutSource(2000); |
|
4e050075fab9
Level of stubbornness skyrocketed
Stiletto <blasux@blasux.ru>
parents:
1
diff
changeset
|
163 |
checktimer.set_callback(() => { |
|
4e050075fab9
Level of stubbornness skyrocketed
Stiletto <blasux@blasux.ru>
parents:
1
diff
changeset
|
164 |
account.check_time(); |
|
4e050075fab9
Level of stubbornness skyrocketed
Stiletto <blasux@blasux.ru>
parents:
1
diff
changeset
|
165 |
//stderr.printf("TimeoutSource OLOLO\n"); |
|
4e050075fab9
Level of stubbornness skyrocketed
Stiletto <blasux@blasux.ru>
parents:
1
diff
changeset
|
166 |
return true; |
|
4e050075fab9
Level of stubbornness skyrocketed
Stiletto <blasux@blasux.ru>
parents:
1
diff
changeset
|
167 |
}); |
|
4e050075fab9
Level of stubbornness skyrocketed
Stiletto <blasux@blasux.ru>
parents:
1
diff
changeset
|
168 |
checktimer.attach(loop.get_context()); |
| 3 | 169 |
|
170 |
account.add_module(new ModuleMuc(cfg, account)); |
|
171 |
account.add_module(new ModuleMucLog(cfg, account)); |
|
172 |
||
173 |
Posix.sigaction_t action = Posix.sigaction_t(); |
|
174 |
action.sa_handler = ((i) => { |
|
175 |
if (account.state != Connection.State.CONNECTED) |
|
176 |
loop.quit(); |
|
177 |
else { |
|
178 |
account.state_changed.connect( (olds, news, desc) => { |
|
179 |
if (news == Connection.State.DISCONNECTED) |
|
180 |
loop.quit(); |
|
181 |
}); |
|
|
7
a49fb1ec5e2a
Send a reason when interrupted by sigint
Stiletto <blasux@blasux.ru>
parents:
3
diff
changeset
|
182 |
account.close("Received SIGINT"); |
| 3 | 183 |
} |
184 |
}); |
|
185 |
Posix.sigaction(Posix.SIGINT, action, null); |
|
186 |
||
| 0 | 187 |
loop.run(); |
188 |
return 0; |
|
189 |
} |