#include <stdio.h>
#include <errno.h>
#include <string.h>
#include <limits.h>
#include <sys/types.h>
#include <libgen.h>
#include <ctype.h>
#include <stdlib.h>
#include <glusterfs/glusterfs.h>
#include <glusterfs/syscall.h>

#ifndef UUID_CANONICAL_FORM_LEN
#define UUID_CANONICAL_FORM_LEN 36
#endif

#ifndef GF_FUSE_AUX_GFID_HEAL
#define GF_FUSE_AUX_GFID_HEAL "glusterfs.gfid.heal"
#endif

#define GLFS_LINE_MAX (PATH_MAX + (2 * UUID_CANONICAL_FORM_LEN))

int
main(int argc, char *argv[])
{
    char *file = NULL;
    char *tmp = NULL;
    char *tmp1 = NULL;
    char *parent_dir = NULL;
    char *gfid = NULL;
    char *bname = NULL;
    int ret = -1;
    int len = 0;
    FILE *fp = NULL;
    char line[GLFS_LINE_MAX] = {
        0,
    };
    char *path = NULL;
    void *blob = NULL;
    void *tmp_blob = NULL;

    if (argc != 2) {
        /* each line in the file has the following format
         * uuid-in-canonical-form path-relative-to-gluster-mount.
         * Both uuid and relative path are from master mount.
         */
        fprintf(stderr, "usage: %s <file-of-paths-to-be-synced>\n", argv[0]);
        goto out;
    }

    file = argv[1];

    fp = fopen(file, "r");
    if (fp == NULL) {
        fprintf(stderr, "cannot open %s for reading (%s)\n", file,
                strerror(errno));
        goto out;
    }

    while (fgets(line, GLFS_LINE_MAX, fp) != NULL) {
        tmp = line;
        path = gfid = line;

        path += UUID_CANONICAL_FORM_LEN + 1;

        while (isspace(*path))
            path++;

        len = strlen(line);
        if ((len < GLFS_LINE_MAX) && (line[len - 1] == '\n'))
            line[len - 1] = '\0';

        line[UUID_CANONICAL_FORM_LEN] = '\0';

        tmp = strdup(path);
        tmp1 = strdup(path);
        parent_dir = dirname(tmp);
        bname = basename(tmp1);

        /* gfid + '\0' + bname + '\0' */
        len = UUID_CANONICAL_FORM_LEN + 1 + strlen(bname) + 1;

        blob = malloc(len);

        memcpy(blob, gfid, UUID_CANONICAL_FORM_LEN);

        tmp_blob = blob + UUID_CANONICAL_FORM_LEN + 1;

        memcpy(tmp_blob, bname, strlen(bname));

        ret = sys_lsetxattr(parent_dir, GF_FUSE_AUX_GFID_HEAL, blob, len, 0);
        if (ret < 0) {
            fprintf(stderr, "setxattr on %s/%s failed (%s)\n", parent_dir,
                    bname, strerror(errno));
        }
        memset(line, 0, GLFS_LINE_MAX);

        free(blob);
        free(tmp);
        free(tmp1);
        blob = NULL;
    }

    ret = 0;
out:
    if (fp)
        fclose(fp);
    return ret;
}