// systemtap compile-server utils
// Copyright (C) 2017-2018 Red Hat Inc.
//
// This file is part of systemtap, and is free software.  You can
// redistribute it and/or modify it under the terms of the GNU General
// Public License (GPL); either version 2, or (at your option) any
// later version.

#include <string>
#include <sstream>
#include <iomanip>
#include "utils.h"
#include "../util.h"
#include "../nsscommon.h"

extern "C" {
#include <uuid/uuid.h>
#include <sys/types.h>
#include <sys/stat.h>
#include <fcntl.h>
#include <unistd.h>
#include <spawn.h>
#include <sys/mman.h>
#include "../mdfour.h"
#include <limits.h>
}

using namespace std;

// Message handling - server_error messages are printed to stderr or
// logged.
void
server_error(const string &msg)
{
    if (log_ok())
	log(msg);
    else
	cerr << msg << endl << flush;
}

string
get_uuid()
{
    uuid_t uuid;
    ostringstream os;

    uuid_generate(uuid);
    os << hex << setfill('0');
    for (const unsigned char *ptr = uuid; ptr < uuid + sizeof(uuid_t); ptr++)
        os << setw(2) << (unsigned int)*ptr;
    return os.str();
}

// Runs a command and waits for it to finish. Command output is
// written to stdout_path and stderr_path. Returns < 0 on
// error. Returns the command return code otherwise.
int
execute_and_capture(int verbose, const vector<string> &args,
		    const vector<string> &env_vars,
		    string stdout_path, string stderr_path)
{
    // Handle capturing stdout and stderr (along with using /dev/null
    // for stdin).
    posix_spawn_file_actions_t actions;
    int rc = posix_spawn_file_actions_init(&actions);
    if (rc == 0) {
	rc = posix_spawn_file_actions_addopen(&actions, 0, "/dev/null",
					      O_RDONLY, S_IRWXU);
    }
    if (rc == 0) {
	rc = posix_spawn_file_actions_addopen(&actions, 1,
					      stdout_path.c_str(),
					      O_WRONLY|O_CREAT|O_APPEND,
					      S_IRWXU);
    }
    if (rc == 0) {
	rc = posix_spawn_file_actions_addopen(&actions, 2,
					      stderr_path.c_str(),
					      O_WRONLY|O_CREAT|O_APPEND,
					      S_IRWXU);
    }
    if (rc != 0) {
	server_error(_F("posix_spawn_file_actions failed: %s",
			strerror(errno)));
	return rc > 0 ? -rc : rc;
    }

    // Run the command.
    pid_t pid;
    if (env_vars.size() > 0)
      pid = stap_spawn(verbose, args, &actions, env_vars);
    else
      pid = stap_spawn(verbose, args, &actions);
    server_error(_F("spawn returned %d", pid));

    // If stap_spawn() failed, no need to wait.
    if (pid == -1) {
	rc = errno;
	server_error(_F("Error in spawn: %s", strerror(errno)));
	(void)posix_spawn_file_actions_destroy(&actions);
	return rc > 0 ? -rc : rc;
    }

    // Wait on the spawned process to finish.
    rc = stap_waitpid(0, pid);
    if (rc < 0) {			// stap_waitpid() failed
	server_error(_F("waitpid failed: %s", strerror(errno)));
    }
    (void)posix_spawn_file_actions_destroy(&actions);
    return rc;
}

int
get_file_hash(const string &pathname, string &result)
{
    struct mdfour md4;
    ostringstream rstream;
    unsigned char sum[16];

    result.clear();
    int fd = open(pathname.c_str(), O_RDONLY);
    if (fd == -1) {
	server_error(_F("open failed: %s", strerror(errno)));
	return -1;
    }

    struct stat sb;
    if (fstat (fd, &sb) == -1) {
	server_error(_F("fstat failed: %s", strerror(errno)));
	return -1;
    }
    if (!S_ISREG (sb.st_mode)) {
	server_error(_F("%s is not a file", pathname.c_str()));
	return -1;
    }

    // Since this is meant to be used on fairly small docker files,
    // let's just mmap the entire file (instead of trying to read it
    // into a buffer).
    unsigned char *p = (unsigned char *)mmap(NULL, sb.st_size, PROT_READ,
					     MAP_SHARED, fd, 0);
    if (p == MAP_FAILED) {
	server_error(_F("mmap failed: %s", strerror(errno)));
	return -1;
    }

    // Calculate the mdfour.
    mdfour_begin(&md4);
    mdfour_update(&md4, p, sb.st_size);
    mdfour_update(&md4, NULL, 0);
    mdfour_result(&md4, sum);

    // We're finished with the mapping and the file.
    munmap(p, sb.st_size);
    close(fd);

    // Convert the mdfour to a string.
    for (int i = 0; i < 16; i++) {
	rstream << hex << setfill('0') << setw(2) << (unsigned)sum[i];
    }
    rstream << "_" << setw(0) << dec << (unsigned)md4.totalN;
    result = rstream.str();
    return 0;
}

bool
make_temp_dir(string &path)
{
    // Create the temp directory
    char tmpdir[PATH_MAX];
    snprintf(tmpdir, PATH_MAX, "%s/stap-http.XXXXXX",
	     (getenv("TMPDIR") ?: "/tmp"));
    const char *tmpdir_name = mkdtemp(tmpdir);
    if (! tmpdir_name) {
	server_error(_F("Cannot create temporary directory (\"%s\"): %s", tmpdir, strerror(errno)));
	path.clear();
	return false;
    }
    path = tmpdir_name;
    return true;
}