/* * gsm - gsm resource for zavai * * Copyright (C) 2009--2010 Enrico Zini * * This program is free software; you can redistribute it and/or modify * it under the terms of the GNU General Public License as published by * the Free Software Foundation; either version 2 of the License, or * (at your option) any later version. * * This program is distributed in the hope that it will be useful, * but WITHOUT ANY WARRANTY; without even the implied warranty of * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the * GNU General Public License for more details. * * You should have received a copy of the GNU General Public License * along with this program; if not, write to the Free Software * Foundation, Inc., 59 Temple Place, Suite 330, Boston, MA 02111-1307 USA */ using GLib; namespace zavai { namespace gsm { [DBus (name = "org.freesmartphone.GSM.Device")] public interface FSO_GSM_Device : Object { public abstract async int test_int (int i, out int j) throws DBus.Error; public abstract async string test_string (string s, out string t) throws DBus.Error; public abstract async void set_sim_buffers_sms(bool sim_buffers_sms) throws DBus.Error; public abstract async void set_r_t_c() throws DBus.Error; public abstract async void cancel_command() throws DBus.Error; public abstract async void set_antenna_power(bool power) throws DBus.Error; public abstract async GLib.HashTable get_info() throws DBus.Error; public abstract async void set_microphone_muted(bool muted) throws DBus.Error; public signal void keypad_event(string name, bool pressed); public abstract async int get_speaker_volume() throws DBus.Error; public abstract async int get_r_t_c() throws DBus.Error; public abstract async void set_speaker_volume(int modem_volume) throws DBus.Error; public abstract async GLib.HashTable get_features() throws DBus.Error; public abstract async bool get_microphone_muted() throws DBus.Error; public abstract async bool get_antenna_power() throws DBus.Error; public abstract async void get_power_status(out string param0, out int param1) throws DBus.Error; public abstract async bool get_sim_buffers_sms() throws DBus.Error; } [DBus (name = "org.freesmartphone.GSM.SIM")] public interface FSO_GSM_SIM : GLib.Object { //public abstract async SIMParam0Struct[] retrieve_phonebook(string category) throws DBus.Error; public abstract async void send_auth_code(string code) throws DBus.Error; public abstract async string get_issuer() throws DBus.Error; public abstract async void change_auth_code(string old_pin, string new_pin) throws DBus.Error; public signal void auth_status(string status); public abstract async string send_generic_sim_command(string command) throws DBus.Error; public abstract async string[] list_phonebooks() throws DBus.Error; public abstract async void set_service_center_number(string number) throws DBus.Error; public abstract async GLib.HashTable get_provider_list() throws DBus.Error; //public abstract async SIMParam0Struct2[] get_home_zones() throws DBus.Error; public signal void ready_status(bool status); public abstract async void retrieve_entry(string category, int index, out string param0, out string param1) throws DBus.Error; public abstract async void delete_message(int index) throws DBus.Error; public abstract async void send_restricted_sim_command(int command, int fileid, int p1, int p2, int p3, string data, out int param0, out int param1, out string param2) throws DBus.Error; public abstract async GLib.HashTable get_messagebook_info() throws DBus.Error; public abstract async bool get_sim_ready() throws DBus.Error; public abstract async GLib.HashTable get_phonebook_info(string category) throws DBus.Error; public signal void memory_full(); public abstract async GLib.HashTable get_sim_info() throws DBus.Error; public abstract async void set_auth_code_required(bool required, string pin) throws DBus.Error; public abstract async string get_auth_status() throws DBus.Error; public abstract async void send_stored_message(int index, out int param0, out string param1) throws DBus.Error; public abstract async int store_message(string number, string contents, GLib.HashTable properties) throws DBus.Error; public abstract async bool get_auth_code_required() throws DBus.Error; public signal void incoming_stored_message(int index); public abstract async void retrieve_message(int index, out string param0, out string param1, out string param2, out GLib.HashTable param3) throws DBus.Error; public abstract async void store_entry(string category, int index, string name, string number) throws DBus.Error; public abstract async void unlock(string puk, string new_pin) throws DBus.Error; public abstract async string get_service_center_number() throws DBus.Error; //public abstract async SIMParam0Struct23[] retrieve_messagebook(string category) throws DBus.Error; public abstract async void delete_entry(string category, int index) throws DBus.Error; } [DBus (name = "org.freesmartphone.GSM.Network")] public interface FSO_GSM_Network : GLib.Object { public signal void status(GLib.HashTable status); public signal void signal_strength(int strength); //public abstract async NetworkParam0Struct[] list_providers() throws DBus.Error; public abstract async GLib.HashTable get_call_forwarding(string reason) throws DBus.Error; public signal void time_zone_report(int timezone); public abstract async void unregister() throws DBus.Error; public abstract async void set_calling_identification(string status) throws DBus.Error; public abstract async void register_() throws DBus.Error; public abstract async void send_ussd_request(string request) throws DBus.Error; public abstract async void disable_call_forwarding(string reason, string class_) throws DBus.Error; public signal void incoming_ussd(string mode, string message_); public abstract async int get_signal_strength() throws DBus.Error; public abstract async void enable_call_forwarding(string reason, string class_, string number, int timeout) throws DBus.Error; public abstract async string get_calling_identification() throws DBus.Error; public abstract async void register_with_provider(string operator_code) throws DBus.Error; public signal void cipher_status(string gsm, string gprs); public abstract async GLib.HashTable get_status() throws DBus.Error; public abstract async void get_country_code(out string param0, out string param1) throws DBus.Error; } [DBus (name = "org.freesmartphone.GSM.Call")] public interface FSO_GSM_Call : GLib.Object { public abstract async void activate(int index) throws DBus.Error; public abstract async void emergency(string number) throws DBus.Error; public abstract async void hold_active() throws DBus.Error; public abstract async void release_held() throws DBus.Error; public abstract async void send_dtmf(string tones) throws DBus.Error; public abstract async void release_all() throws DBus.Error; public abstract async int initiate(string number, string type_) throws DBus.Error; // public abstract async CallParam0Struct[] list_calls() throws DBus.Error; public abstract async void transfer(string number) throws DBus.Error; public abstract async void release(int index) throws DBus.Error; public signal void call_status(int index, string status, GLib.HashTable properties); public abstract async void activate_conference(int index) throws DBus.Error; } public class GSM: zavai.ScriptMonitorService { protected dynamic DBus.Object dbus; public FSO_GSM_Device device; public FSO_GSM_Network network; public FSO_GSM_SIM sim; public FSO_GSM_Call call; protected class CallInfo { public int gsm_id; public uint log_id; } protected List calls; public string info_provider; public string info_registration; public int info_signal_strength; public signal void status_changed(string message); public signal void info_changed(); protected void dump_table(HashTable vals) { vals.for_each((pk, pv) => { string k = (string)pk; Value? v = (Value?)pv; stderr.printf("K: %s V: %s\n", k, v == null ? "(null)" : v.strdup_contents()); }); } protected void acquire_new_status(HashTable status) { // NETWORK STATUS // K: provider V: "vodafone UK" // K: mode V: "automatic" // K: registration V: "roaming" // K: cid V: "157F" // K: lac V: "0031" // K: act V: "GSM" // K: code V: "23415" bool changed = false; var vprovider = status.lookup("provider"); if (vprovider != null) { if (info_provider != vprovider.get_string()) { info_provider = vprovider.get_string(); changed = true; } } var vregistration = status.lookup("registration"); if (vregistration != null) { if (info_registration != vregistration.get_string()) { info_registration = vregistration.get_string(); changed = true; } } if (changed) { stderr.printf("NOTIFY CHANGED\n"); info_changed(); } } protected void acquire_new_signal_strength(int strength) { if (info_signal_strength != strength) { info_signal_strength = strength; stderr.printf("ACQUIRE SIG %d\n", info_signal_strength); info_changed(); } } public GSM() { Object(name: "gsm"); calls = new List(); device = (FSO_GSM_Device)zavai.registry.sbus.get_object( "org.freesmartphone.ogsmd", "/org/freesmartphone/GSM/Device", "org.freesmartphone.GSM.Device"); network = (FSO_GSM_Network)zavai.registry.sbus.get_object( "org.freesmartphone.ogsmd", "/org/freesmartphone/GSM/Device", "org.freesmartphone.GSM.Network"); sim = (FSO_GSM_SIM)zavai.registry.sbus.get_object( "org.freesmartphone.ogsmd", "/org/freesmartphone/GSM/Device", "org.freesmartphone.GSM.SIM"); call = (FSO_GSM_Call)zavai.registry.sbus.get_object( "org.freesmartphone.ogsmd", "/org/freesmartphone/GSM/Device", "org.freesmartphone.GSM.Call"); dbus = zavai.registry.sbus.get_object( "org.freedesktop.DBus", "/org/freedesktop/DBus", "org.freedesktop.DBus"); dbus.NameOwnerChanged += on_name_owner_changed; info_provider = "(unknown)"; info_signal_strength = -1; network.status += (status) => { stderr.printf("NETWORK STATUS\n"); dump_table(status); acquire_new_status(status); }; network.signal_strength += (strength) => { stderr.printf("SIGNAL STRENGTH %d\n", strength); acquire_new_signal_strength(strength); }; call.call_status += on_call_status; } /// Request GPS resource public override void start() { if (started) return; status_changed("Starting"); script_start(); base.start(); } protected void on_name_owner_changed(DBus.Object sender, string name, string oldOwner, string newOwner) { zavai.log.debug("NOC " + name + " from " + oldOwner + " to " + newOwner); if (name == "org.freesmartphone.ogsmd" && newOwner != "") { status_changed("ogpsd came online"); start_gsm.begin(); } } // Release usage of GPS public override void stop() { if (!started) return; script_stop(); status_changed(""); info_provider = ""; info_signal_strength = -1; info_changed(); } protected override void cleanup_after_script_stop() { call = null; } public async void start_gsm() { status_changed("Turning on antenna"); while (true) { try { yield device.set_antenna_power(true); break; } catch (Error e) { zavai.log.warning("SetAntennaPower: " + e.message); if (e.message.str("current status is 'enabling'") != null || e.message.str("current status is 'unknown'") != null) { status_changed("Waiting for ogsmd to settle"); zavai.log.info("trying again after 2 seconds"); Timeout.add(2 * 1000, () => { start_gsm.callback(); return false; }); yield; } else { status_changed("Checking if PIN is required"); string status = yield sim.get_auth_status(); zavai.log.info("on_auth_status: " + status); if (status == "READY") status_changed("PIN ok"); else if (status == "SIM PIN") { status_changed("Sending PIN"); yield sim.send_auth_code(zavai.config.sim_pin); status_changed("PIN OK"); } else zavai.log.debug("Unknown status: " + status); } } } zavai.log.warning("on_antenna_power ok"); status_changed("Registering with network"); yield network.register_(); status_changed("Registered with network"); acquire_new_status(yield network.get_status()); acquire_new_signal_strength(yield network.get_signal_strength()); } protected CallInfo? lookup_call(int gsm_id) { for (weak List i = calls; i != null; i = i.next) if (i.data.gsm_id == gsm_id) return i.data; return null; } public void on_call_status(int index, string status, HashTable properties) { stderr.printf("CALL STATUS %d %s\n", index, status); dump_table(properties); CallInfo? info = lookup_call(index); if (info == null) { Value? v = properties.lookup("peer"); string title; if (v != null) title = "%s call from %s".printf(status, v.get_string()); else title = "%s call".printf(status); info = new CallInfo(); info.gsm_id = index; info.log_id = zavai.log.log.start("call", title); calls.append(info); } // Log a summary of all info string call_info = "status: %s\n".printf(status); properties.for_each((pk, pv) => { string k = (string)pk; Value? v = (Value?)pv; call_info = call_info + "%s: %s\n".printf(k, v == null ? "(null)" : v.strdup_contents()); }); zavai.log.log.add(info.log_id, call_info); // Remove entry when it's the last possible status if (status == "release") { zavai.log.log.end(info.log_id); for (weak List i = calls; i != null; i = i.next) if (i.data.gsm_id == index) { calls.delete_link(i); break; } } /* dbg("cbCallStatus %d, %s, %s" % (id, status, formatDict(properties))) self.status = status if status == "incoming": if "peer" in properties and properties["peer"] == "+358942832031": self.gsm_call_iface.ReleaseAll() os.system("kapula-debug-call-handler &") else: os.system("alsactl restore -f /etc/alsa-scenarios/stereoout-maxvolume.state") os.system("vibrator-start") os.system("ringtone-start") os.system("ledctrl --on-time 400 --off-time 200 gta02-aux:red"); if status == "release": os.system("ringtone-stop") os.system("vibrator-stop") os.system("ledctrl --off gta02-aux:red"); */ } } public class GPRS: zavai.Service { public dynamic DBus.Object device; public GPRS() { Object(name: "gsm.gprs"); device = zavai.registry.sbus.get_object( "org.freesmartphone.ogsmd", "/org/freesmartphone/GSM/Device", "org.freesmartphone.GSM.PDP"); } /// Request GPS resource public override void start() { if (started) return; try { //gsm.request(name); device.ActivateContext( zavai.config.gprs_apn, zavai.config.gprs_user, zavai.config.gprs_pass); zavai.log.info("Started GPRS"); base.start(); } catch (GLib.Error e) { zavai.log.error(e.message); } base.start(); } // Release usage of GPS public override void stop() { if (!started) return; try { //gsm.release(name); device.DeactivateContext(); zavai.log.info("Stopped GPRS"); base.stop(); } catch (GLib.Error e) { zavai.log.error(e.message); } base.stop(); } } public zavai.gsm.GSM gsm = null; public zavai.gsm.GPRS gprs = null; public void init() { gsm = new GSM(); gprs = new GPRS(); } } }