guacamole-spice-protocol/src/protocols/rdp/guac_rdpdr/rdpdr_printer.c

97 lines
3.5 KiB
C
Raw Normal View History

2013-06-23 00:43:05 +00:00
#include <freerdp/utils/stream.h>
#include <freerdp/utils/svc_plugin.h>
2013-06-24 19:34:30 +00:00
#include <guacamole/protocol.h>
2013-06-23 00:43:05 +00:00
#include "rdpdr_messages.h"
2013-06-24 19:34:30 +00:00
#include "rdpdr_printer.h"
2013-06-23 00:43:05 +00:00
#include "rdpdr_service.h"
2013-06-24 19:34:30 +00:00
#include "client.h"
2013-06-23 00:43:05 +00:00
void guac_rdpdr_process_print_job_create(guac_rdpdrPlugin* rdpdr, STREAM* input_stream, int completion_id) {
2013-06-24 19:34:30 +00:00
rdp_guac_client_data* client_data = (rdp_guac_client_data*) rdpdr->client->data;
2013-06-23 00:43:05 +00:00
STREAM* output_stream = stream_new(24);
2013-06-24 19:34:30 +00:00
/* Open file */
2013-06-23 00:43:05 +00:00
guac_client_log_info(rdpdr->client, "Print job created");
2013-06-24 19:34:30 +00:00
pthread_mutex_lock(&(client_data->update_lock));
guac_protocol_send_file(rdpdr->client->socket,
GUAC_RDPDR_PRINTER_BLOB, "print.ps", "application/postscript");
pthread_mutex_unlock(&(client_data->update_lock));
2013-06-23 00:43:05 +00:00
/* Write header */
stream_write_uint16(output_stream, RDPDR_CTYP_CORE);
stream_write_uint16(output_stream, PAKID_CORE_DEVICE_IOCOMPLETION);
/* Write content */
stream_write_uint32(output_stream, GUAC_PRINTER_DEVICE_ID);
stream_write_uint32(output_stream, completion_id);
stream_write_uint32(output_stream, 0); /* NTSTATUS - success */
stream_write_uint32(output_stream, 0); /* fileId */
svc_plugin_send((rdpSvcPlugin*) rdpdr, output_stream);
}
void guac_rdpdr_process_print_job_write(guac_rdpdrPlugin* rdpdr, STREAM* input_stream, int completion_id) {
int length;
2013-06-24 19:34:30 +00:00
unsigned char* buffer;
2013-06-23 00:43:05 +00:00
2013-06-24 19:34:30 +00:00
rdp_guac_client_data* client_data = (rdp_guac_client_data*) rdpdr->client->data;
2013-06-23 00:43:05 +00:00
STREAM* output_stream = stream_new(24);
stream_read_uint32(input_stream, length);
stream_seek(input_stream, 8); /* Offset */
stream_seek(input_stream, 20); /* Padding */
2013-06-24 19:34:30 +00:00
buffer = stream_get_tail(input_stream);
2013-06-23 00:43:05 +00:00
2013-06-24 19:34:30 +00:00
/* Send data */
pthread_mutex_lock(&(client_data->update_lock));
guac_protocol_send_blob(rdpdr->client->socket,
GUAC_RDPDR_PRINTER_BLOB, buffer, length);
pthread_mutex_unlock(&(client_data->update_lock));
2013-06-23 00:43:05 +00:00
/* Write header */
stream_write_uint16(output_stream, RDPDR_CTYP_CORE);
stream_write_uint16(output_stream, PAKID_CORE_DEVICE_IOCOMPLETION);
/* Write content */
stream_write_uint32(output_stream, GUAC_PRINTER_DEVICE_ID);
stream_write_uint32(output_stream, completion_id);
stream_write_uint32(output_stream, 0); /* NTSTATUS - success */
stream_write_uint32(output_stream, length);
stream_write_uint8(output_stream, 0); /* padding (stated as optional in spec, but requests fail without) */
svc_plugin_send((rdpSvcPlugin*) rdpdr, output_stream);
}
void guac_rdpdr_process_print_job_close(guac_rdpdrPlugin* rdpdr, STREAM* input_stream, int completion_id) {
2013-06-24 19:34:30 +00:00
rdp_guac_client_data* client_data = (rdp_guac_client_data*) rdpdr->client->data;
2013-06-23 00:43:05 +00:00
STREAM* output_stream = stream_new(24);
2013-06-24 19:34:30 +00:00
/* Close file */
2013-06-23 00:43:05 +00:00
guac_client_log_info(rdpdr->client, "Print job closed");
2013-06-24 19:34:30 +00:00
pthread_mutex_lock(&(client_data->update_lock));
guac_protocol_send_end(rdpdr->client->socket, GUAC_RDPDR_PRINTER_BLOB);
pthread_mutex_unlock(&(client_data->update_lock));
2013-06-23 00:43:05 +00:00
/* Write header */
stream_write_uint16(output_stream, RDPDR_CTYP_CORE);
stream_write_uint16(output_stream, PAKID_CORE_DEVICE_IOCOMPLETION);
/* Write content */
stream_write_uint32(output_stream, GUAC_PRINTER_DEVICE_ID);
stream_write_uint32(output_stream, completion_id);
stream_write_uint32(output_stream, 0); /* NTSTATUS - success */
stream_write_uint32(output_stream, 0); /* padding*/
svc_plugin_send((rdpSvcPlugin*) rdpdr, output_stream);
}