5 * Copyright (C) 2007-2010 Marcel Holtmann <marcel@holtmann.org>
8 * This program is free software; you can redistribute it and/or modify
9 * it under the terms of the GNU General Public License as published by
10 * the Free Software Foundation; either version 2 of the License, or
11 * (at your option) any later version.
13 * This program is distributed in the hope that it will be useful,
14 * but WITHOUT ANY WARRANTY; without even the implied warranty of
15 * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
16 * GNU General Public License for more details.
18 * You should have received a copy of the GNU General Public License
19 * along with this program; if not, write to the Free Software
20 * Foundation, Inc., 51 Franklin St, Fifth Floor, Boston, MA 02110-1301 USA
41 #define OBEX_FTP_UUID \
42 "\xF9\xEC\x7B\xC4\x95\x3C\x11\xD2\x98\x4E\x52\x54\x00\xDC\x9E\x09"
43 #define OBEX_FTP_UUID_LEN 16
45 #define FTP_INTERFACE "org.bluez.obex.FileTransfer"
46 #define ERROR_INTERFACE "org.bluez.obex.Error"
47 #define FTP_UUID "00001106-0000-1000-8000-00805f9b34fb"
48 #define PCSUITE_UUID "00005005-0000-1000-8000-0002ee000001"
50 static DBusConnection *conn = NULL;
53 struct obc_session *session;
56 static void async_cb(struct obc_session *session, struct obc_transfer *transfer,
57 GError *err, void *user_data)
59 DBusMessage *reply, *msg = user_data;
62 reply = g_dbus_create_error(msg, ERROR_INTERFACE ".Failed",
65 reply = dbus_message_new_method_return(msg);
67 g_dbus_send_message(conn, reply);
68 dbus_message_unref(msg);
71 static DBusMessage *change_folder(DBusConnection *connection,
72 DBusMessage *message, void *user_data)
74 struct ftp_data *ftp = user_data;
75 struct obc_session *session = ftp->session;
79 if (dbus_message_get_args(message, NULL,
80 DBUS_TYPE_STRING, &folder,
81 DBUS_TYPE_INVALID) == FALSE)
82 return g_dbus_create_error(message,
83 ERROR_INTERFACE ".InvalidArguments", NULL);
85 obc_session_setpath(session, folder, async_cb, message, &err);
88 reply = g_dbus_create_error(message,
89 ERROR_INTERFACE ".Failed",
95 dbus_message_ref(message);
100 static void xml_element(GMarkupParseContext *ctxt,
101 const gchar *element,
103 const gchar **values,
107 DBusMessageIter dict, *iter = user_data;
111 if (strcasecmp("folder", element) != 0 && strcasecmp("file", element) != 0)
114 dbus_message_iter_open_container(iter, DBUS_TYPE_ARRAY,
115 DBUS_DICT_ENTRY_BEGIN_CHAR_AS_STRING
116 DBUS_TYPE_STRING_AS_STRING DBUS_TYPE_VARIANT_AS_STRING
117 DBUS_DICT_ENTRY_END_CHAR_AS_STRING, &dict);
119 obex_dbus_dict_append(&dict, "Type", DBUS_TYPE_STRING, &element);
121 /* FIXME: User, Group, Other permission must be reviewed */
124 for (key = (gchar *) names[i]; key; key = (gchar *) names[++i]) {
125 key[0] = g_ascii_toupper(key[0]);
126 if (g_str_equal("Size", key) == TRUE) {
128 size = g_ascii_strtoll(values[i], NULL, 10);
129 obex_dbus_dict_append(&dict, key, DBUS_TYPE_UINT64,
132 obex_dbus_dict_append(&dict, key, DBUS_TYPE_STRING,
136 dbus_message_iter_close_container(iter, &dict);
139 static const GMarkupParser parser = {
147 static void list_folder_callback(struct obc_session *session,
148 struct obc_transfer *transfer,
149 GError *err, void *user_data)
151 DBusMessage *msg = user_data;
152 GMarkupParseContext *ctxt;
154 DBusMessageIter iter, array;
158 reply = dbus_message_new_method_return(msg);
160 if (obc_transfer_get_contents(transfer, &contents, &size) < 0)
163 dbus_message_iter_init_append(reply, &iter);
164 dbus_message_iter_open_container(&iter, DBUS_TYPE_ARRAY,
165 DBUS_TYPE_ARRAY_AS_STRING
166 DBUS_DICT_ENTRY_BEGIN_CHAR_AS_STRING
167 DBUS_TYPE_STRING_AS_STRING DBUS_TYPE_VARIANT_AS_STRING
168 DBUS_DICT_ENTRY_END_CHAR_AS_STRING, &array);
169 ctxt = g_markup_parse_context_new(&parser, 0, &array, NULL);
170 g_markup_parse_context_parse(ctxt, contents, size, NULL);
171 g_markup_parse_context_free(ctxt);
172 dbus_message_iter_close_container(&iter, &array);
176 g_dbus_send_message(conn, reply);
177 dbus_message_unref(msg);
180 static DBusMessage *create_folder(DBusConnection *connection,
181 DBusMessage *message, void *user_data)
183 struct ftp_data *ftp = user_data;
184 struct obc_session *session = ftp->session;
188 if (dbus_message_get_args(message, NULL,
189 DBUS_TYPE_STRING, &folder,
190 DBUS_TYPE_INVALID) == FALSE)
191 return g_dbus_create_error(message,
192 ERROR_INTERFACE ".InvalidArguments", NULL);
194 obc_session_mkdir(session, folder, async_cb, message, &err);
197 reply = g_dbus_create_error(message,
198 ERROR_INTERFACE ".Failed",
204 dbus_message_ref(message);
209 static DBusMessage *list_folder(DBusConnection *connection,
210 DBusMessage *message, void *user_data)
212 struct ftp_data *ftp = user_data;
213 struct obc_session *session = ftp->session;
214 struct obc_transfer *transfer;
218 transfer = obc_transfer_get("x-obex/folder-listing", NULL, NULL, &err);
219 if (transfer == NULL)
222 if (obc_session_queue(session, transfer, list_folder_callback,
224 dbus_message_ref(message);
229 reply = g_dbus_create_error(message, ERROR_INTERFACE ".Failed", "%s",
235 static DBusMessage *get_file(DBusConnection *connection,
236 DBusMessage *message, void *user_data)
238 struct ftp_data *ftp = user_data;
239 struct obc_session *session = ftp->session;
240 struct obc_transfer *transfer;
241 const char *target_file, *source_file;
245 if (dbus_message_get_args(message, NULL,
246 DBUS_TYPE_STRING, &target_file,
247 DBUS_TYPE_STRING, &source_file,
248 DBUS_TYPE_INVALID) == FALSE)
249 return g_dbus_create_error(message,
250 ERROR_INTERFACE ".InvalidArguments", NULL);
252 transfer = obc_transfer_get(NULL, source_file, target_file, &err);
253 if (transfer == NULL)
256 if (!obc_session_queue(session, transfer, NULL, NULL, &err))
259 return obc_transfer_create_dbus_reply(transfer, message);
262 reply = g_dbus_create_error(message, ERROR_INTERFACE ".Failed", "%s",
268 static DBusMessage *put_file(DBusConnection *connection,
269 DBusMessage *message, void *user_data)
271 struct ftp_data *ftp = user_data;
272 struct obc_session *session = ftp->session;
273 struct obc_transfer *transfer;
274 gchar *sourcefile, *targetfile;
278 if (dbus_message_get_args(message, NULL,
279 DBUS_TYPE_STRING, &sourcefile,
280 DBUS_TYPE_STRING, &targetfile,
281 DBUS_TYPE_INVALID) == FALSE)
282 return g_dbus_create_error(message,
283 ERROR_INTERFACE ".InvalidArguments",
284 "Invalid arguments in method call");
286 transfer = obc_transfer_put(NULL, targetfile, sourcefile, NULL, 0,
288 if (transfer == NULL)
291 if (!obc_session_queue(session, transfer, NULL, NULL, &err))
294 return obc_transfer_create_dbus_reply(transfer, message);
297 reply = g_dbus_create_error(message, ERROR_INTERFACE ".Failed", "%s",
303 static DBusMessage *copy_file(DBusConnection *connection,
304 DBusMessage *message, void *user_data)
306 struct ftp_data *ftp = user_data;
307 struct obc_session *session = ftp->session;
308 const char *filename, *destname;
311 if (dbus_message_get_args(message, NULL,
312 DBUS_TYPE_STRING, &filename,
313 DBUS_TYPE_STRING, &destname,
314 DBUS_TYPE_INVALID) == FALSE)
315 return g_dbus_create_error(message,
316 ERROR_INTERFACE ".InvalidArguments", NULL);
318 obc_session_copy(session, filename, destname, async_cb, message, &err);
321 reply = g_dbus_create_error(message, ERROR_INTERFACE ".Failed",
327 dbus_message_ref(message);
332 static DBusMessage *move_file(DBusConnection *connection,
333 DBusMessage *message, void *user_data)
335 struct ftp_data *ftp = user_data;
336 struct obc_session *session = ftp->session;
337 const char *filename, *destname;
340 if (dbus_message_get_args(message, NULL,
341 DBUS_TYPE_STRING, &filename,
342 DBUS_TYPE_STRING, &destname,
343 DBUS_TYPE_INVALID) == FALSE)
344 return g_dbus_create_error(message,
345 ERROR_INTERFACE ".InvalidArguments", NULL);
347 obc_session_move(session, filename, destname, async_cb, message, &err);
350 reply = g_dbus_create_error(message, ERROR_INTERFACE ".Failed",
356 dbus_message_ref(message);
361 static DBusMessage *delete(DBusConnection *connection,
362 DBusMessage *message, void *user_data)
364 struct ftp_data *ftp = user_data;
365 struct obc_session *session = ftp->session;
369 if (dbus_message_get_args(message, NULL,
370 DBUS_TYPE_STRING, &file,
371 DBUS_TYPE_INVALID) == FALSE)
372 return g_dbus_create_error(message,
373 ERROR_INTERFACE ".InvalidArguments", NULL);
375 obc_session_delete(session, file, async_cb, message, &err);
378 reply = g_dbus_create_error(message, ERROR_INTERFACE ".Failed",
384 dbus_message_ref(message);
389 static const GDBusMethodTable ftp_methods[] = {
390 { GDBUS_ASYNC_METHOD("ChangeFolder",
391 GDBUS_ARGS({ "folder", "s" }), NULL, change_folder) },
392 { GDBUS_ASYNC_METHOD("CreateFolder",
393 GDBUS_ARGS({ "folder", "s" }), NULL, create_folder) },
394 { GDBUS_ASYNC_METHOD("ListFolder",
395 NULL, GDBUS_ARGS({ "folderinfo", "aa{sv}" }), list_folder) },
396 { GDBUS_METHOD("GetFile",
397 GDBUS_ARGS({ "targetfile", "s" }, { "sourcefile", "s" }),
398 GDBUS_ARGS({ "transfer", "o" }, { "properties", "a{sv}" }),
400 { GDBUS_METHOD("PutFile",
401 GDBUS_ARGS({ "sourcefile", "s" }, { "targetfile", "s" }),
402 GDBUS_ARGS({ "transfer", "o" }, { "properties", "a{sv}" }),
404 { GDBUS_ASYNC_METHOD("CopyFile",
405 GDBUS_ARGS({ "sourcefile", "s" }, { "targetfile", "s" }), NULL,
407 { GDBUS_ASYNC_METHOD("MoveFile",
408 GDBUS_ARGS({ "sourcefile", "s" }, { "targetfile", "s" }), NULL,
410 { GDBUS_ASYNC_METHOD("Delete",
411 GDBUS_ARGS({ "file", "s" }), NULL, delete) },
415 static void ftp_free(void *data)
417 struct ftp_data *ftp = data;
419 obc_session_unref(ftp->session);
423 static int ftp_probe(struct obc_session *session)
425 struct ftp_data *ftp;
428 path = obc_session_get_path(session);
432 ftp = g_try_new0(struct ftp_data, 1);
436 ftp->session = obc_session_ref(session);
438 if (!g_dbus_register_interface(conn, path, FTP_INTERFACE, ftp_methods,
439 NULL, NULL, ftp, ftp_free)) {
447 static void ftp_remove(struct obc_session *session)
449 const char *path = obc_session_get_path(session);
453 g_dbus_unregister_interface(conn, path, FTP_INTERFACE);
456 static struct obc_driver ftp = {
459 .target = OBEX_FTP_UUID,
460 .target_len = OBEX_FTP_UUID_LEN,
465 static struct obc_driver pcsuite = {
466 .service = "PCSUITE",
467 .uuid = PCSUITE_UUID,
468 .target = OBEX_FTP_UUID,
469 .target_len = OBEX_FTP_UUID_LEN,
480 conn = dbus_bus_get(DBUS_BUS_SESSION, NULL);
484 err = obc_driver_register(&ftp);
488 err = obc_driver_register(&pcsuite);
490 obc_driver_unregister(&ftp);
497 dbus_connection_unref(conn);
506 dbus_connection_unref(conn);
509 obc_driver_unregister(&ftp);
510 obc_driver_unregister(&pcsuite);