launcher basis work with af-launch

Change-Id: I5076d5be3b3c3390525bef59029890687df237f4

2 files changed, 297 insertions, 0 deletions

diff --git a/src/af-launch.c b/src/af-launch.c
new file mode 100644
index 0000000..e085138
--- /dev/null
+++ b/src/af-launch.c
@@ -0,0 +1,266 @@
+/*
+ Copyright 2015 IoT.bzh
+
+ Licensed under the Apache License, Version 2.0 (the "License");
+ you may not use this file except in compliance with the License.
+ You may obtain a copy of the License at
+
+     http://www.apache.org/licenses/LICENSE-2.0
+
+ Unless required by applicable law or agreed to in writing, software
+ distributed under the License is distributed on an "AS IS" BASIS,
+ WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ See the License for the specific language governing permissions and
+ limitations under the License.
+*/
+
+#define _GNU_SOURCE
+
+#include <unistd.h>
+#include <stdio.h>
+#include <stdlib.h>
+#include <limits.h>
+#include <errno.h>
+#include <string.h>
+#include <fcntl.h>
+#include <assert.h>
+#include <sys/stat.h>
+#include <sys/types.h>
+
+extern char **environ;
+
+#include "verbose.h"
+#include "af-launch.h"
+#include "secmgr-wrap.h"
+
+struct launchparam {
+	int port;
+	const char *secret;
+};
+
+static int launch_html(struct af_launch_desc *desc, struct launchparam *params);
+static int launch_bin(struct af_launch_desc *desc, struct launchparam *params);
+static int launch_qml(struct af_launch_desc *desc, struct launchparam *params);
+
+static int launch_master(struct af_launch_desc *desc, struct launchparam *params, int fd, pid_t child);
+
+static struct {
+	const char *type;
+	int (*launcher)(struct af_launch_desc *desc, struct launchparam *params);
+}
+known_launchers[] = {
+	{ "text/html", launch_html },
+	{ "application/x-executable", launch_bin },
+	{ "application/octet-stream", launch_bin },
+	{ "text/vnd.qt.qml", launch_qml }
+};
+
+static void mksecret(char buffer[9])
+{
+	snprintf(buffer, 9, "%08lX", (0xffffffff & random()));
+}
+
+static int mkport()
+{
+	static int port_ring = 12345;
+	int port = port_ring;
+	if (port < 12345 || port > 15432)
+		port = 12345;
+	port_ring = port + 1;
+	return port;
+}
+
+int af_launch(struct af_launch_desc *desc, pid_t children[2])
+{
+	char datadir[PATH_MAX];
+	int ikl, nkl, rc;
+	char secret[9];
+	int port;
+	char message[10];
+	int mpipe[2];
+	int spipe[2];
+	struct launchparam params;
+
+	/* what launcher ? */
+	ikl = 0;
+	if (desc->type != NULL && *desc->type) {
+		nkl = sizeof known_launchers / sizeof * known_launchers;
+		while (ikl < nkl && strcmp(desc->type, known_launchers[ikl].type))
+			ikl++;
+		if (ikl == nkl) {
+			ERROR("type %s not found!", desc->type);
+			errno = ENOENT;
+			return -1;
+		}
+	}
+
+	/* prepare paths */
+	rc = snprintf(datadir, sizeof datadir, "%s/%s", desc->home, desc->tag);
+	if (rc < 0 || rc >= sizeof datadir) {
+		ERROR("overflow for datadir");
+		errno = EINVAL;
+		return -1;
+	}
+
+	/* make the secret and port */
+	mksecret(secret);
+	port = mkport();
+
+	params.port = port;
+	params.secret = secret;
+
+	/* prepare the pipes */
+	rc = pipe2(mpipe, O_CLOEXEC);
+	if (rc < 0) {
+		ERROR("error while calling pipe2: %m");
+		return -1;
+	}
+	rc = pipe2(spipe, O_CLOEXEC);
+	if (rc < 0) {
+		ERROR("error while calling pipe2: %m");
+		close(spipe[0]);
+		close(spipe[1]);
+		return -1;
+	}
+
+	/* fork the master child */
+	children[0] = fork();
+	if (children[0] < 0) {
+		ERROR("master fork failed: %m");
+		close(mpipe[0]);
+		close(mpipe[1]);
+		close(spipe[0]);
+		close(spipe[1]);
+		return -1;
+	}
+	if (children[0]) {
+		/********* in the parent process ************/
+		close(mpipe[1]);
+		close(spipe[0]);
+		/* wait the ready signal (that transmit the slave pid) */
+		rc = read(mpipe[0], &children[1], sizeof children[1]);
+		if (rc  < 0) {
+			ERROR("reading master pipe failed: %m");
+			close(mpipe[0]);
+			close(spipe[1]);
+			return -1;
+		}
+		close(mpipe[0]);
+		assert(rc == sizeof children[1]);
+		/* start the child */
+		rc = write(spipe[1], "start", 5);
+		if (rc < 0) {
+			ERROR("writing slave pipe failed: %m");
+			close(spipe[1]);
+			return -1;
+		}
+		close(spipe[1]);
+		return 0;
+	}
+
+	/********* in the master child ************/
+	close(mpipe[0]);
+	close(spipe[1]);
+
+	/* enter the process group */
+	rc = setpgid(0, 0);
+	if (rc) {
+		ERROR("setpgid failed");
+		_exit(1);
+	}
+
+	/* enter security mode */
+	rc = secmgr_prepare_exec(desc->tag);
+	if (rc < 0) {
+		ERROR("call to secmgr_prepare_exec failed: %m");
+		_exit(1);
+	}
+
+	/* enter the datadirectory */
+	rc = mkdir(datadir, 0755);
+	if (rc && errno != EEXIST) {
+		ERROR("creation of datadir %s failed: %m", datadir);
+		_exit(1);
+	}
+	rc = chdir(datadir);
+	if (rc) {
+		ERROR("can't enter the datadir %s: %m", datadir);
+		_exit(1);
+	}
+
+	/* fork the slave child */
+	children[1] = fork();
+	if (children[1] < 0) {
+		ERROR("slave fork failed: %m");
+		_exit(1);
+	}
+	if (children[1] == 0) {
+		/********* in the slave child ************/
+		close(mpipe[0]);
+		rc = read(spipe[0], message, sizeof message);
+		if (rc < 0) {
+			ERROR("reading slave pipe failed: %m");
+			_exit(1);
+		}
+		rc = known_launchers[ikl].launcher(desc, &params);
+		ERROR("slave launch failed: %m");
+		_exit(1);
+	}
+
+	/********* still in the master child ************/
+	close(spipe[1]);
+	rc = launch_master(desc, &params, mpipe[1], children[1]);
+	ERROR("master launch failed: %m");
+	_exit(1);
+}
+
+static int launch_master(struct af_launch_desc *desc, struct launchparam *params, int fd, pid_t child)
+{
+	int rc;
+	char *argv[6];
+	argv[0] = "/bin/echo";
+	(void)asprintf(&argv[1], "--alias=/icons:%s", FWK_ICON_DIR);
+	(void)asprintf(&argv[2], "--port=%d", params->port);
+	(void)asprintf(&argv[3], "--rootdir=%s", desc->path);
+	(void)asprintf(&argv[4], "--token=%", desc->path);
+	argv[5] = NULL;
+
+	rc = write(fd, &child, sizeof child);
+	if (rc < 0) {
+		ERROR("can't write master pipe: %m");
+		return -1;
+	}
+
+	rc = execve(argv[0], argv, environ);
+	ERROR("failed to exec master %s: %m", argv[0]);
+	return rc;
+}
+
+static int launch_html(struct af_launch_desc *desc, struct launchparam *params)
+{
+/*
+	char *url = asprintf("http://localhost:%d/", params->port);
+*/
+	int rc;
+	char *argv[3];
+	argv[0] = "/usr/bin/chromium";
+	(void)asprintf(&argv[1], "file://%s/%s", desc->path, desc->content);
+	argv[2] = NULL;
+	rc = execve(argv[0], argv, environ);
+	ERROR("failed to exec slave %s: %m", argv[0]);
+	return rc;
+}
+
+static int launch_bin(struct af_launch_desc *desc, struct launchparam *params)
+{
+	ERROR("unimplemented launch_bin");
+	return -1;
+}
+
+static int launch_qml(struct af_launch_desc *desc, struct launchparam *params)
+{
+	ERROR("unimplemented launch_qml");
+	return -1;
+}
+
+
diff --git a/src/af-launch.h b/src/af-launch.h
new file mode 100644
index 0000000..253642a
--- /dev/null
+++ b/src/af-launch.h
@@ -0,0 +1,31 @@
+/*
+ Copyright 2015 IoT.bzh
+
+ Licensed under the Apache License, Version 2.0 (the "License");
+ you may not use this file except in compliance with the License.
+ You may obtain a copy of the License at
+
+     http://www.apache.org/licenses/LICENSE-2.0
+
+ Unless required by applicable law or agreed to in writing, software
+ distributed under the License is distributed on an "AS IS" BASIS,
+ WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ See the License for the specific language governing permissions and
+ limitations under the License.
+*/
+
+struct af_launch_desc {
+	const char *path;
+	const char *tag;
+	const char *appid;
+	const char *content;
+	const char *type;
+	const char *name;
+	const char *home;
+	const char **plugins;
+	int width;
+	int height;
+};
+
+int af_launch(struct af_launch_desc *desc, pid_t children[2]);
+