Add support for collections and collaborators

.gitignore

@@ -3,3 +3,4 @@
 /lib
 /build
 *.dwarf
+/Gemfile.lock

Gemfile

@@ -0,0 +1,5 @@
+# frozen_string_literal: true
+
+source 'https://rubygems.org'
+
+gem 'openssl'

Makefile

@@ -2,18 +2,20 @@ all: teletube
 
 teletube: main.cr src/**/*.cr
 	shards
-	ruby scripts/options.rb
+	bundle
+	bundle exec ruby scripts/options.rb
 	crystal build --error-trace -o teletube main.cr
 	@strip teletube
 	@du -sh teletube
 
 release: main.cr src/**/*.cr
 	shards
-	ruby scripts/options.rb
+	bundle
+	bundle exec ruby scripts/options.rb
 	crystal build main.cr --release -o teletube
 	@strip teletube
 	@du -sh teletube
-	ruby scripts/build.rb
+	bundle exec ruby scripts/build.rb
 
 clean:
 	rm -rf .crystal teletube .deps .shards libs lib *.dwarf build
@@ -22,4 +24,4 @@ PREFIX ?= /usr/local
 
 install: teletube
 	install -d $(PREFIX)/bin
-	install teletube $(PREFIX)/bin
+	install teletube $(PREFIX)/bin

scripts/options.rb

@@ -7,7 +7,12 @@
 BASE_URI = 'https://tube.switch.ch'
 RESOURCES = {
   'channel' => '/schema/v1/channel.json',
-  'video' => '/schema/v1/video.json'
+  'video' => '/schema/v1/video.json',
+  'collection' => '/schema/v1/collection.json',
+  'create_collection_item' => '/schema/v1/create_collection_item.json',
+  'update_collection_item' => '/schema/v1/update_collection_item.json',
+  'create_collaborator' => '/schema/v1/create_collaborator.json',
+  'create_collaborator_invitation' => '/schema/v1/create_collaborator_invitation.json',
 }.freeze
 
 class Property

src/teletube/cli.cr

@@ -80,6 +80,48 @@ module Teletube
         else
           @client.get_channels
         end
+      when "collaborators"
+        case context.command
+        when "create"
+          @client.create_collaborator
+        when "destroy"
+          @client.destroy_collaborator
+        else
+          @client.get_collaborators
+        end
+      when "collaborator-invitations"
+        case context.command
+        when "create"
+          @client.create_collaborator_invitation
+        when "destroy"
+          @client.destroy_collaborator_invitation
+        else
+          @client.get_collaborator_invitations
+        end
+      when "collection-items"
+        case context.command
+        when "create"
+          @client.create_collection_item
+        when "update"
+          @client.update_collection_item
+        when "destroy"
+          @client.destroy_collection_item
+        else
+          @client.get_collection_items
+        end
+      when "collections"
+        case context.command
+        when "create"
+          @client.create_collection
+        when "show"
+          @client.get_collection
+        when "update"
+          @client.update_collection
+        when "destroy"
+          @client.destroy_collection
+        else
+          @client.get_collections
+        end
       when "documents"
         case context.command
         when "create"
@@ -109,6 +151,8 @@ module Teletube
         else
           @client.get_profiles_me
         end
+      when "positions"
+        @client.update_positions
       when "progress"
         @client.get_video_progress
       when "restorations"

src/teletube/client.cr

@@ -44,6 +44,109 @@ module Teletube
       )
     end
 
+    def get_collaborators
+      handle_response(
+        @http.get(
+          path:
+            "/api/v1/#{@context.params["type"]}/#{@context.params["id"]}" \
+            "/collaborators"
+        )
+      )
+    end
+
+    def create_collaborator
+      handle_response(
+        @http.post(
+          path:
+            "/api/v1/#{@context.params["type"]}/#{@context.params["id"]}" \
+            "/collaborators",
+          params: @context.params
+        )
+      )
+    end
+
+    def destroy_collaborator
+      handle_response(@http.delete(path: "/api/v1/collaborators/#{@context.params["id"]}"))
+    end
+
+    def get_collaborator_invitations
+      handle_response(
+        @http.get(
+          path:
+            "/api/v1/#{@context.params["type"]}/#{@context.params["id"]}" \
+            "/collaborator_invitations"
+        )
+      )
+    end
+
+    def create_collaborator_invitation
+      handle_response(
+        @http.post(
+          path:
+            "/api/v1/#{@context.params["type"]}/#{@context.params["id"]}" \
+            "/collaborator_invitations",
+          params: @context.params
+        )
+      )
+    end
+
+    def destroy_collaborator_invitation
+      handle_response(
+        @http.delete(path: "/api/v1/collaborator_invitations/#{@context.params["id"]}")
+      )
+    end
+
+    def get_collection_items
+      handle_response(
+        @http.get(path: "/api/v1/collections/#{@context.params["collection_id"]}/collection_items")
+      )
+    end
+
+    def create_collection_item
+      handle_response(
+        @http.post(
+          path: "/api/v1/collections/#{@context.params["collection_id"]}/collection_items",
+          params: @context.params
+        )
+      )
+    end
+
+    def update_collection_item
+      handle_response(
+        @http.patch(
+          path: "/api/v1/collection_items/#{@context.params["id"]}", params: @context.params
+        )
+      )
+    end
+
+    def destroy_collection_item
+      handle_response(@http.delete(path: "/api/v1/collection_items/#{@context.params["id"]}"))
+    end
+
+    def get_collections
+      handle_response(@http.get(path: "/api/v1/collections"))
+    end
+
+    def create_collection
+      handle_response(@http.post(path: "/api/v1/collections", params: @context.params))
+    end
+
+    def get_collection
+      handle_response(@http.get(path: "/api/v1/collections/#{@context.params["id"]}"))
+    end
+
+    def update_collection
+      handle_response(
+        @http.patch(path: "/api/v1/collections/#{@context.params["id"]}", params: @context.params)
+      )
+    end
+
+    def destroy_collection
+      handle_response(
+        @http.delete(path: "/api/v1/collections/#{@context.params["id"]}")
+      )
+    end
+
     class Upload
       # 50 megabytes
       SEGMENT_SIZE = 52428800
@@ -205,6 +308,8 @@ module Teletube
         handle_response(@http.get(path: "/api/v1/videos/#{@context.params["video_id"]}/documents"))
       elsif @context.params.has_key?("channel_id")
         handle_response(@http.get(path: "/api/v1/channels/#{@context.params["channel_id"]}/documents"))
+      else
+        handle_response(@http.get(path: "/api/v1/documents"))
       end
     end
 
@@ -238,6 +343,18 @@ module Teletube
       handle_response(@http.get(path: "/api/v1/profiles/me"))
     end
 
+    def update_positions
+      positions = @context.params["positions"].as_s.split(",").map do |position|
+        position.to_i
+      end
+      handle_response(
+        @http.patch(
+          path: "/api/v1/#{@context.params["type"]}/#{@context.params["id"]}/positions",
+          params: positions
+        ),
+      )
+    end
+
     def get_video_progress
       handle_response(@http.get(path: "/api/v1/videos/#{@context.params["video_id"]}/progress"))
     end

src/teletube/http.cr

@@ -50,7 +50,7 @@ module Teletube
       @http.post(path: path, headers: all, body: body)
     end
 
-    def patch(path : String, params : Hash(String, JSON::Any))
+    def patch(path : String, params : Array | Hash(String, JSON::Any))
       @http.patch(path: path, headers: @headers, body: params.to_json)
     end