Merge pull request #46 from threefoldtech/development-v2-tags

tags: support hub tags
threefoldtech · Sep 26, 2023 · 1f0f433 · 1f0f433
2 parents b6f95f2 + 950bf49
commit 1f0f433
Show file tree

Hide file tree

Showing 4 changed files with 179 additions and 5 deletions.
diff --git a/.github/workflows/zflist-publish b/.github/workflows/zflist-publish
@@ -98,3 +98,33 @@ if [ "$action" == "MERGE" ]; then
     zflist hub merge $filename $targetname
 fi
 
+if [ "$action" == "CROSSTAG" ]; then
+    repository=$(echo $targetname | awk -F/ '{ print $1 }')
+    tagname=$(echo $targetname | awk -F/ '{ print $2 }')
+
+    echo "Cross-tagging $filename -> $repository/tags/$tagname"
+    zflist hub crosstag $filename $repository $tagname
+fi
+
+if [ "$action" == "TAG" ]; then
+    tagname=$(echo $filename | awk -F/ '{ print $1 }')
+    linkname=$(echo $filename | awk -F/ '{ print $2 }')
+
+    repository=$(echo $targetname | awk -F/ '{ print $1 }')
+    target=$(echo $targetname | awk -F/ '{ print $2 }')
+
+    echo "Tagging $repository/$target tag '$tagname' as '$linkname'"
+    zflist hub tag $tagname $linkname $repository $target
+fi
+
+if [ "$action" == "UNTAG" ]; then
+    tagname=$(echo $filename | awk -F/ '{ print $1 }')
+    linkname=$(echo $filename | awk -F/ '{ print $2 }')
+
+    repository=$(echo $targetname | awk -F/ '{ print $1 }')
+    target=$(echo $targetname | awk -F/ '{ print $2 }')
+
+    echo "Untagging $repository/$target tag '$tagname' as '$linkname'"
+    zflist hub untag $tagname $linkname $repository $target
+fi
+
diff --git a/zflist/actions.c b/zflist/actions.c
@@ -900,6 +900,18 @@ int zf_hub(zf_callback_t *cb) {
     else if(strcmp(cb->argv[0], "readlink") == 0)
         return zf_hub_readlink(cb);
 
+    else if(strcmp(cb->argv[0], "taglink") == 0)
+        return zf_hub_taglink(cb);
+
+    else if(strcmp(cb->argv[0], "crosstag") == 0)
+        return zf_hub_crosstag(cb);
+
+    else if(strcmp(cb->argv[0], "tag") == 0)
+        return zf_hub_tag(cb);
+
+    else if(strcmp(cb->argv[0], "untag") == 0)
+        return zf_hub_untag(cb);
+
     else if(strcmp(cb->argv[0], "login") == 0)
         return zf_hub_login(cb);
 

diff --git a/zflist/actions_hub.c b/zflist/actions_hub.c
@@ -44,6 +44,15 @@
 // /api/flist/<repository>/<filename>/light
 #define ZFLIST_HUB_READLINK  "/api/flist/%s/light"
 
+// /api/flist/<repository>/<filename>/taglink
+#define ZFLIST_HUB_TAGLINK   "/api/flist/%s/taglink"
+
+// /api/flist/me/<tagname>/<name>/tag/<repository>/<flist>
+#define ZFLIST_HUB_TAG_SET   "/api/flist/me/%s/%s/tag/%s/%s"
+
+// /api/flist/me/<name>/crosstag/<repository>/<tagname>
+#define ZFLIST_HUB_XTAG      "/api/flist/me/%s/crosstag/%s/%s"
+
 // /api/flist/me
 #define ZFLIST_HUB_SELF      "/api/flist/me"
 
@@ -491,11 +500,6 @@ int zf_hub_readlink(zf_callback_t *cb) {
         return 1;
     }
 
-    if(!(zf_hub_authcheck(cb))) {
-        zf_error(cb, "hub", "hub authentication failed");
-        return 1;
-    }
-
     discard_http http_t response;
     char *linkname = cb->argv[1];
     char endpoint[1024];
@@ -602,3 +606,127 @@ int zf_hub_username(zf_callback_t *cb) {
 
     return 0;
 }
+
+// tag system
+int zf_hub_taglink(zf_callback_t *cb) {
+    if(cb->argc != 2) {
+        zf_error(cb, "hub", "missing arguments: taglink <repository>/<linkname>");
+        return 1;
+    }
+
+    discard_http http_t response;
+    char *linkname = cb->argv[1];
+    char endpoint[1024];
+
+    debug("[+] hub: taglink: %s\n", linkname);
+
+    zf_api_url(cb, endpoint, ZFLIST_HUB_TAGLINK, linkname);
+    response = zf_hub_curl(cb, endpoint, NULL, NULL);
+
+    // parse json output
+    json_t *root, *status, *target;
+    json_error_t error;
+
+    if(!(root = json_loads(response.body, 0, &error))) {
+        zf_error(cb, "taglink", "could not parse server response");
+        return 1;
+    }
+
+    if((status = json_object_get(root, "status"))) {
+        status = json_object_get(root, "message");
+        zf_error(cb, "taglink", (char *) json_string_value(status));
+        json_decref(root);
+        return 1;
+    }
+
+    if(!(target = json_object_get(root, "target"))) {
+        zf_error(cb, "readlink", "could not read link target");
+        json_decref(root);
+        return 1;
+    }
+
+    debug("[+] hub: taglink: %s\n", json_string_value(target));
+    printf("%s\n", json_string_value(target));
+
+    json_decref(root);
+
+    return 0;
+}
+
+int zf_hub_crosstag(zf_callback_t *cb) {
+    if(cb->argc != 4) {
+        zf_error(cb, "hub", "missing arguments: crosstag <linkname> <repository> <tagname>");
+        return 1;
+    }
+
+    if(!(zf_hub_authcheck(cb))) {
+        zf_error(cb, "hub", "hub authentication failed");
+        return 1;
+    }
+
+    discard_http http_t response;
+    char *linkname = cb->argv[1];
+    char *repository = cb->argv[2];
+    char *tagname = cb->argv[3];
+    char endpoint[1024];
+
+    debug("[+] hub: cross taglink: you/%s -> %s/tags/%s\n", linkname, repository, tagname);
+
+    zf_api_url(cb, endpoint, ZFLIST_HUB_XTAG, linkname, repository, tagname);
+    response = zf_hub_curl(cb, endpoint, NULL, NULL);
+
+    return zf_response_check(&response);
+}
+
+int zf_hub_tag(zf_callback_t *cb) {
+    if(cb->argc != 5) {
+        zf_error(cb, "hub", "missing arguments: tag <tagname> <name> <repository> <target>");
+        return 1;
+    }
+
+    if(!(zf_hub_authcheck(cb))) {
+        zf_error(cb, "hub", "hub authentication failed");
+        return 1;
+    }
+
+    discard_http http_t response;
+    char *tagname = cb->argv[1];
+    char *name = cb->argv[2];
+    char *repository = cb->argv[3];
+    char *target = cb->argv[4];
+    char endpoint[1024];
+
+    debug("[+] hub: tagging: you/%s/%s -> %s/tags/%s\n", tagname, name, repository, target);
+
+    zf_api_url(cb, endpoint, ZFLIST_HUB_TAG_SET, tagname, name, repository, target);
+    response = zf_hub_curl(cb, endpoint, NULL, NULL);
+
+    return zf_response_check(&response);
+}
+
+int zf_hub_untag(zf_callback_t *cb) {
+    if(cb->argc != 5) {
+        zf_error(cb, "hub", "missing arguments: untag <tagname> <name> <repository> <target>");
+        return 1;
+    }
+
+    if(!(zf_hub_authcheck(cb))) {
+        zf_error(cb, "hub", "hub authentication failed");
+        return 1;
+    }
+
+    discard_http http_t response;
+    char *tagname = cb->argv[1];
+    char *name = cb->argv[2];
+    char *repository = cb->argv[3];
+    char *target = cb->argv[4];
+    char endpoint[1024];
+
+    debug("[+] hub: untagging: you/%s/%s -> %s/tags/%s\n", tagname, name, repository, target);
+
+    zf_api_url(cb, endpoint, ZFLIST_HUB_TAG_SET, tagname, name, repository, target);
+    response = zf_hub_curl(cb, endpoint, NULL, "DELETE");
+
+    return zf_response_check(&response);
+}
+
diff --git a/zflist/actions_hub.h b/zflist/actions_hub.h
@@ -9,6 +9,10 @@
     int zf_hub_delete(zf_callback_t *cb);
     int zf_hub_merge(zf_callback_t *cb);
     int zf_hub_readlink(zf_callback_t *cb);
+    int zf_hub_taglink(zf_callback_t *cb);
+    int zf_hub_crosstag(zf_callback_t *cb);
+    int zf_hub_tag(zf_callback_t *cb);
+    int zf_hub_untag(zf_callback_t *cb);
     int zf_hub_login(zf_callback_t *cb);
     int zf_hub_username(zf_callback_t *cb);
     int zf_hub_refresh(zf_callback_t *cb);