lib/dor/services/client.rb in dor-services-client-0.1.0 vs lib/dor/services/client.rb in dor-services-client-0.2.0

@@ -1,77 +1,102 @@
+# frozen_string_literal: true
+
 require 'dor/services/client/version'
 require 'singleton'
 require 'faraday'
 require 'active_support/core_ext/hash/indifferent_access'
+require 'dor/services/client/files'
+require 'dor/services/client/objects'
+require 'dor/services/client/release_tags'
+require 'dor/services/client/workflow'
+require 'dor/services/client/workspace'
 
 module Dor
   module Services
     class Client
       class Error < StandardError; end
 
       include Singleton
 
+      def objects
+        @objects ||= Objects.new(connection: connection)
+      end
 
+      def files
+        @files ||= Files.new(connection: connection)
+      end
+
+      def workflow
+        @workflow ||= Workflow.new(connection: connection)
+      end
+
+      def workspace
+        @workspace ||= Workspace.new(connection: connection)
+      end
+
+      def release_tags
+        @release_tags ||= ReleaseTags.new(connection: connection)
+      end
+
       def self.configure(url:)
         instance.url = url
       end
 
       # Creates a new object in DOR
       # @return [HashWithIndifferentAccess] the response, which includes a :pid
       def self.register(params:)
-        instance.register(params: params)
+        instance.objects.register(params: params)
       end
 
       # @param [String] object the identifier for the object
       # @param [String] filename the name of the file to retrieve
       # @return [String] the file contents from the workspace
       def self.retrieve_file(object:, filename:)
-        instance.retrieve_file(object: object, filename: filename)
+        instance.files.retrieve(object: object, filename: filename)
       end
 
       # @param [String] object the identifier for the object
       # @return [Array<String>] the list of filenames in the workspace
       def self.list_files(object:)
-        instance.list_files(object: object)
+        instance.files.list(object: object)
       end
 
-      attr_writer :url
-
-      def url
-        @url || raise(Error, "url has not yet been configured")
+      # Initializes a new workflow
+      # @param object [String] the pid for the object
+      # @param wf_name [String] the name of the workflow
+      # @raises [Error] if the request is unsuccessful.
+      # @return nil
+      def self.initialize_workflow(object:, wf_name:)
+        instance.workflow.create(object: object, wf_name: wf_name)
       end
 
-      def register(params:)
-        resp = connection.post do |req|
-          req.url 'v1/objects'
-          req.headers['Content-Type'] = 'application/json'
-          req.headers['Accept'] = 'application/json' # asking the service to return JSON (else it'll be plain text)
-          req.body = params.to_json
-        end
-        raise "#{resp.reason_phrase}: #{resp.status} (#{resp.body})" unless resp.success?
-        JSON.parse(resp.body).with_indifferent_access
+      # Initializes a new workspace
+      # @param object [String] the pid for the object
+      # @param source [String] the path to the object
+      # @raises [Error] if the request is unsuccessful.
+      # @return nil
+      def self.initialize_workspace(object:, source:)
+        instance.workspace.create(object: object, source: source)
       end
 
-      def retrieve_file(object:, filename:)
-        resp = connection.get do |req|
-          req.url "v1/objects/#{object}/contents/#{filename}"
-        end
-        return unless resp.success?
-
-        resp.body
+      # Creates a new release tag for the object
+      # @param object [String] the pid for the object
+      # @param release [Boolean]
+      # @param what [String]
+      # @param to [String]
+      # @param who [String]
+      # @return [Boolean] true if successful
+      def self.create_release_tag(object:, release:, what:, to:, who:)
+        instance.release_tags.create(object: object, release: release, what: what, to: to, who: who)
       end
 
-      def list_files(object:)
-        resp = connection.get do |req|
-          req.url "v1/objects/#{object}/contents"
-        end
-        return [] unless resp.success?
+      attr_writer :url
 
-        json = JSON.parse(resp.body)
-        json['items'].map { |item| item['name'] }
-      end
-
       private
+
+      def url
+        @url || raise(Error, 'url has not yet been configured')
+      end
 
       def connection
         @connection ||= Faraday.new(url)
       end
     end