chore: carrierwave rails implemented

Author: mrasif

lib/carrierwave/storage/ik_file.rb

@@ -0,0 +1,50 @@
+module CarrierWave
+    module Storage
+      class IKFile
+        # Initialize as required.
+        
+        def initialize(identifier)
+          @identifier=JSON.parse(identifier)
+          ik_config=Rails.application.config.imagekit
+          @imagekit=ImageKit::ImageKitClient.new(ik_config[:private_key],ik_config[:public_key],ik_config[:url_endpoint])
+        end
+
+        # Duck-type methods for CarrierWave::SanitizedFile. 
+        def content_type
+            "image/jpg"
+        end
+        def public_url
+          @identifier['url']
+        end
+        def url(options = {})
+          @identifier['url']
+        end
+
+        def fileId
+          @identifier['fileId']
+        end
+        def filename(options = {})
+          @identifier['name']
+        end
+        def read
+        end
+        def size
+        end
+        def delete
+          # file_id=@identifier['fileId']
+          begin
+            @imagekit.delete_file(fileId)
+          rescue
+            fileId
+          end
+          # binding.pry
+          # return nil
+        end
+        def exists?
+        end
+        # Others... ?
+      end
+
+    end
+
+end

lib/carrierwave/storage/imagekit_store.rb

@@ -0,0 +1,68 @@
+require 'uri'
+require 'net/http'
+require 'base64'
+module CarrierWave
+    module Storage
+        class ImageKitStore < Abstract
+
+          def initialize(*)
+              super
+              @cache_called = nil
+          end
+          
+          def store!(file)
+            file.delete
+          end
+
+          def retrieve!(identifier)
+            
+            IKFile.new(identifier)
+          end
+
+          def cache!(new_file)
+            new_file.move_to(::File.expand_path(uploader.cache_path, uploader.root), uploader.permissions, uploader.directory_permissions, true)
+            rescue Errno::EMLINK, Errno::ENOSPC => e
+              raise(e) if @cache_called
+              @cache_called = true
+      
+              # NOTE: Remove cached files older than 10 minutes
+              clean_cache!(600)
+      
+              cache!(new_file)
+          end
+
+          def retrieve_from_cache!(identifier)
+              CarrierWave::SanitizedFile.new(::File.expand_path(uploader.cache_path(identifier), uploader.root))
+              resp=@client.get(identifier)
+            # binding.pry
+              IKFile.new(resp)
+          end
+
+          def delete_dir!(path)
+              if path
+                begin
+                  Dir.rmdir(::File.expand_path(path, uploader.root))
+                rescue Errno::ENOENT
+                  # Ignore: path does not exist
+                rescue Errno::ENOTDIR
+                  # Ignore: path is not a dir
+                rescue Errno::ENOTEMPTY, Errno::EEXIST
+                  # Ignore: dir is not empty
+                end
+              end
+          end
+
+          def clean_cache!(seconds)
+              Dir.glob(::File.expand_path(::File.join(uploader.cache_dir, '*'), CarrierWave.root)).each do |dir|
+                # generate_cache_id returns key formated TIMEINT-PID(-COUNTER)-RND
+                time = dir.scan(/(\d+)-\d+-\d+(?:-\d+)?/).first.map(&:to_i)
+                time = Time.at(*time)
+                if time < (Time.now.utc - seconds)
+                  FileUtils.rm_rf(dir)
+                end
+              end
+          end
+            
+        end
+    end
+end

lib/carrierwave/support/uri_filename.rb

@@ -0,0 +1,10 @@
+module CarrierWave
+    module Support
+        module UriFilename
+            def self.filename(url)
+                path = url.split('?').first
+                URI.decode(path).gsub(%r{.*/(.*?$)}, '\1')
+            end
+        end
+    end
+end