1 /*****************************************************************************\
5 **---------------------------------------------------------------------------**
6 ** Copyright: Andreas Eversberg **
8 ** answering machine port **
10 ** this is a child of the port class, which emulates the recorder function **
11 ** of an answering machine **
12 ** it will directly answer to the setup message with a connect **
14 \*****************************************************************************/
22 #include <sys/ioctl.h>
23 #include <sys/types.h>
28 /* note: recording log is written at endpoint */
31 * initialize vbox port
33 VBoxPort::VBoxPort(int type, struct port_settings *settings) : Port(type, "vbox", settings)
36 p_vbox_announce_fh = -1;
37 p_vbox_audio_start = 0;
38 p_vbox_audio_transferred = 0;
39 p_vbox_record_start = 0;
40 p_vbox_record_limit = 0;
49 if (p_vbox_announce_fh >= 0)
51 close(p_vbox_announce_fh);
52 p_vbox_announce_fh = -1;
61 int VBoxPort::handler(void)
63 struct message *message;
65 signed short buffer[128<<1];
67 class Endpoint *epoint;
69 if (p_vbox_record_start && p_vbox_record_limit)
72 if (currenttime > (p_vbox_record_limit+p_vbox_record_start))
77 message = message_create(p_serial, p_epointlist->epoint_id, PORT_TO_EPOINT, MESSAGE_RELEASE);
78 message->param.disconnectinfo.cause = 16;
79 message->param.disconnectinfo.location = LOCATION_PRIVATE_LOCAL;
82 free_epointlist(p_epointlist);
84 /* recording is close during destruction */
86 return(-1); /* must return because port is gone */
90 if (p_vbox_audio_start < 1)
92 /* set time the first time */
93 p_vbox_audio_start = now_d;
96 /* calculate the number of bytes */
97 tosend = (unsigned long)((now_d-p_vbox_audio_start)*8000) - p_vbox_audio_transferred;
103 /* too many samples, so we just process 128 bytes until the next call of handler() */
107 /* dummy read, to clock record buffer */
108 read_audio((unsigned char *)buffer, tosend, 0);
110 /* add the number of samples elapsed */
111 p_vbox_audio_transferred += tosend;
113 /* if announcement is currently played, send audio data */
114 if (p_vbox_announce_fh >=0)
116 /* read from announcement file */
117 switch(p_vbox_announce_codec)
120 tosend = read_tone(p_vbox_announce_fh, buffer, p_vbox_announce_codec, tosend, p_vbox_announce_size, &p_vbox_announce_left, 1);
126 tosend = read_tone(p_vbox_announce_fh, buffer, p_vbox_announce_codec, tosend, p_vbox_announce_size, &p_vbox_announce_left, 1);
130 PERROR("correct codec not given.\n");
136 close(p_vbox_announce_fh);
137 p_vbox_announce_fh = -1;
141 p_vbox_record_start = currenttime;
143 /* connect if not already */
144 epoint = find_epoint_id(ACTIVE_EPOINT(p_epointlist));
147 /* if we sent our announcement during ringing, we must now connect */
148 if (p_vbox_apppbx->e_ext.vbox_free)
150 /* send connect message */
151 message = message_create(p_serial, ACTIVE_EPOINT(p_epointlist), PORT_TO_EPOINT, MESSAGE_CONNECT);
152 memcpy(&message->param.connectinfo, &p_connectinfo, sizeof(struct connect_info));
153 message_put(message);
154 new_state(PORT_STATE_CONNECT);
158 /* start recording, if not already */
159 if (p_vbox_mode == VBOX_MODE_NORMAL)
161 /* send recording start message */
162 message = message_create(p_serial, ACTIVE_EPOINT(p_epointlist), PORT_TO_EPOINT, MESSAGE_VBOX_RECORD);
163 message_put(message);
165 if (p_vbox_mode == VBOX_MODE_ANNOUNCEMENT)
168 message = message_create(p_serial, ACTIVE_EPOINT(p_epointlist), PORT_TO_EPOINT, MESSAGE_RELEASE);
169 message->param.disconnectinfo.cause = 16;
170 message->param.disconnectinfo.location = LOCATION_PRIVATE_LOCAL;
171 message_put(message);
172 /* recording is close during destruction */
174 return(-1); /* must return because port is gone */
178 switch(p_vbox_announce_codec)
181 message = message_create(p_serial, ACTIVE_EPOINT(p_epointlist), PORT_TO_EPOINT, MESSAGE_DATA);
182 message->param.data.compressed = 1;
183 message->param.data.port_type = p_type;
184 message->param.data.port_id = p_serial;
185 message->param.data.len = tosend;
186 memcpy(message->param.data.data, buffer, tosend);
187 message_put(message);
193 message = message_create(p_serial, ACTIVE_EPOINT(p_epointlist), PORT_TO_EPOINT, MESSAGE_DATA);
194 message->param.data.compressed = 0;
195 message->param.data.port_type = p_type;
196 message->param.data.port_id = p_serial;
197 message->param.data.len = tosend<<1;
198 memcpy(message->param.data.data, buffer, tosend<<1);
199 message_put(message);
203 PERROR("correct announce_codec not given.\n");
215 * endpoint sends messages to the vbox port
217 int VBoxPort::message_epoint(unsigned long epoint_id, int message_id, union parameter *param)
219 struct message *message;
220 class Endpoint *epoint;
221 char filename[256], *c;
222 class EndpointAppPBX *eapp;
224 epoint = find_epoint_id(epoint_id);
227 PDEBUG(DEBUG_EPOINT|DEBUG_VBOX, "PORT(%s) no endpoint object found where the message is from.\n", p_name);
231 if (Port::message_epoint(epoint_id, message_id, param))
236 case MESSAGE_DISCONNECT: /* call has been disconnected */
237 PDEBUG(DEBUG_VBOX, "PORT(%s) vbox port with (caller id %s) received disconnect cause=%d\n", p_name, p_callerinfo.id, param->disconnectinfo.cause);
239 new_state(PORT_STATE_OUT_DISCONNECT);
243 message = message_create(p_serial, p_epointlist->epoint_id, PORT_TO_EPOINT, MESSAGE_RELEASE);
244 message->param.disconnectinfo.cause = CAUSE_NORMAL;
245 message->param.disconnectinfo.location = LOCATION_PRIVATE_LOCAL;
246 message_put(message);
248 free_epointlist(p_epointlist);
250 /* recording is close during destruction */
252 return(-1); /* must return because port is gone */
255 case MESSAGE_RELEASE: /* release vbox port */
256 PDEBUG(DEBUG_VBOX, "PORT(%s) vbox port with (caller id %s) received release\n", p_name, p_callerinfo.id);
259 /* recording is close during destruction */
261 return(-1); /* must return because port is gone */
264 case MESSAGE_SETUP: /* dial-out command received from epoint, answer with connect */
266 eapp = (class EndpointAppPBX *)(epoint->ep_app);
267 p_vbox_apppbx = eapp;
268 /* extract optional announcement file */
269 if ((c = strchr(param->setup.dialinginfo.number, ',')))
272 SPRINT(filename, c+1);
274 SPRINT(filename, "%s/%s/%s/vbox/%s", INSTALL_DATA, options.extensions_dir, p_vbox_apppbx->e_terminal);
278 SPRINT(filename, "%s/%s/%s/vbox/announcement", INSTALL_DATA, options.extensions_dir, p_vbox_apppbx->e_terminal);
280 PDEBUG(DEBUG_VBOX, "PORT(%s) vbox port received setup from '%s' to '%s'\n", p_name, param->setup.callerinfo.id, param->setup.dialinginfo.number);
281 memcpy(&p_callerinfo, ¶m->setup.callerinfo, sizeof(p_callerinfo));
282 memcpy(&p_redirinfo, ¶m->setup.redirinfo, sizeof(p_redirinfo));
286 PERROR("PORT(%s) software error: epoint pointer is set in idle state, how bad!! exitting.\n", p_name);
289 if (!(epointlist_new(epoint_id)))
291 PERROR("no memory for epointlist\n");
295 /* copy setup infos to port */
296 SCPY(p_vbox_extension, param->setup.dialinginfo.number);
298 /* create connect info */
299 SCPY(p_connectinfo.id, p_vbox_extension);
300 p_connectinfo.itype = INFO_ITYPE_VBOX;
301 p_connectinfo.present = INFO_PRESENT_ALLOWED;
302 p_connectinfo.screen = INFO_SCREEN_NETWORK;
304 /* connect unless we can send announcement while ringing */
305 if (!p_vbox_apppbx->e_ext.vbox_free)
307 /* send connect message */
308 message = message_create(p_serial, epoint_id, PORT_TO_EPOINT, MESSAGE_CONNECT);
309 memcpy(&message->param.connectinfo, &p_connectinfo, sizeof(struct connect_info));
310 message_put(message);
311 new_state(PORT_STATE_CONNECT);
314 /* send alerting message */
315 message = message_create(p_serial, epoint_id, PORT_TO_EPOINT, MESSAGE_ALERTING);
316 message_put(message);
317 new_state(PORT_STATE_IN_ALERTING);
320 /* start recording during announcement */
321 /* start parallel recording if desired */
322 p_vbox_mode = p_vbox_apppbx->e_ext.vbox_mode;
323 p_vbox_record_limit = p_vbox_apppbx->e_ext.vbox_time;
324 if (p_vbox_mode == VBOX_MODE_PARALLEL)
326 /* send recording start message */
327 message = message_create(p_serial, epoint_id, PORT_TO_EPOINT, MESSAGE_VBOX_RECORD);
328 message_put(message);
330 /* play the announcement */
331 if ((p_vbox_announce_fh = open_tone(filename, &p_vbox_announce_codec, &p_vbox_announce_size, &p_vbox_announce_left)) >= 0)
336 PDEBUG(DEBUG_VBOX, "PORT(%s) no announcement found at: '%s' so we start recording now.\n", p_name, filename);
337 /* send recording start message */
338 message = message_create(p_serial, epoint_id, PORT_TO_EPOINT, MESSAGE_VBOX_RECORD);
339 message_put(message);
344 PDEBUG(DEBUG_VBOX, "PORT(%s) vbox port with (caller id %s) received an unsupported message: %d\n", p_name, p_callerinfo.id, message_id);