wip

Author: kvz

lib/transloadit.rb

@@ -11,6 +11,7 @@ class Transloadit
   autoload :Exception, "transloadit/exception"
   autoload :Request, "transloadit/request"
   autoload :Response, "transloadit/response"
+  autoload :SmartCDN, "transloadit/smart_cdn"
   autoload :Step, "transloadit/step"
   autoload :Template, "transloadit/template"
   autoload :VERSION, "transloadit/version"

lib/transloadit/smart_cdn.rb

@@ -0,0 +1,62 @@
+require 'openssl'
+require 'uri'
+require 'cgi'
+
+class Transloadit
+  class SmartCDN
+    # @param workspace [String] Workspace slug
+    # @param template [String] Template slug or template ID
+    # @param input [String] Input value that is provided as `${fields.input}` in the template
+    # @param auth_key [String] Authentication key
+    # @param auth_secret [String] Authentication secret
+    # @param url_params [Hash] Additional parameters for the URL query string (optional)
+    # @param expire_in_ms [Integer] Expiration time in milliseconds from now (optional)
+    # @param expire_at_ms [Integer] Expiration time as Unix timestamp in milliseconds (optional)
+    # @return [String] Signed Smart CDN URL
+    def self.signed_url(workspace:, template:, input:, auth_key:, auth_secret:, url_params: {}, expire_in_ms: nil, expire_at_ms: nil)
+      raise ArgumentError, 'workspace is required' if workspace.nil? || workspace.empty?
+      raise ArgumentError, 'template is required' if template.nil? || template.empty?
+      raise ArgumentError, 'input is required' if input.nil?
+
+      workspace_slug = CGI.escape(workspace)
+      template_slug = CGI.escape(template)
+      input_field = CGI.escape(input)
+
+      expire_at = if expire_at_ms
+                   expire_at_ms
+                 elsif expire_in_ms
+                   (Time.now.to_f * 1000).to_i + expire_in_ms
+                 else
+                   (Time.now.to_f * 1000).to_i + (1 * 60 * 60 * 1000) # 1 hour default
+                 end
+
+      query_params = {}
+      url_params.each do |key, value|
+        next if value.nil?
+        if value.is_a?(Array)
+          value.each do |val|
+            next if val.nil?
+            (query_params[key.to_s] ||= []) << val.to_s
+          end
+        else
+          query_params[key.to_s] = [value.to_s]
+        end
+      end
+
+      query_params['auth_key'] = [auth_key]
+      query_params['exp'] = [expire_at.to_s]
+
+      # Sort parameters to ensure consistent ordering
+      sorted_params = query_params.sort.map do |key, values|
+        values.compact.map { |v| "#{CGI.escape(key)}=#{CGI.escape(v)}" }
+      end.flatten.reject(&:empty?).join('&')
+
+      string_to_sign = "#{workspace_slug}/#{template_slug}/#{input_field}?#{sorted_params}"
+
+      signature = OpenSSL::HMAC.hexdigest('sha256', auth_secret, string_to_sign)
+
+      final_params = "#{sorted_params}&sig=#{CGI.escape("sha256:#{signature}")}"
+      "https://#{workspace_slug}.tlcdn.com/#{template_slug}/#{input_field}?#{final_params}"
+    end
+  end
+end

test/smart_cdn_compare.rb

@@ -0,0 +1,47 @@
+#!/usr/bin/env ruby
+puts "Current directory: #{Dir.pwd}"
+puts "Load path: #{$LOAD_PATH}"
+$LOAD_PATH.unshift File.expand_path('../lib', __dir__)
+puts "Updated load path: #{$LOAD_PATH}"
+require 'bundler/setup'
+puts "Loaded bundler/setup"
+require 'transloadit'
+puts "Loaded transloadit"
+puts "Loading smart_cdn..."
+require_relative '../lib/transloadit/smart_cdn'
+puts "Loaded smart_cdn"
+
+# Get CLI arguments
+expire_at = ARGV[0]
+workspace = ARGV[1]
+template = ARGV[2]
+input = ARGV[3]
+
+puts "Environment variables:"
+puts "TRANSLOADIT_KEY: #{ENV['TRANSLOADIT_KEY']}"
+puts "TRANSLOADIT_SECRET: #{ENV['TRANSLOADIT_SECRET']}"
+
+# Generate URL using Ruby implementation
+url = Transloadit::SmartCDN.signed_url(
+  workspace: workspace,
+  template: template,
+  input: input,
+  auth_key: ENV['TRANSLOADIT_KEY'],
+  auth_secret: ENV['TRANSLOADIT_SECRET'],
+  expire_at_ms: expire_at.to_i
+)
+
+puts "Ruby: #{url}"
+
+# Execute Node.js implementation and capture output
+node_url = `tsx dev/smartcdn-sig.ts #{expire_at} #{workspace} #{template} #{input}`.strip
+puts "Node: #{node_url}"
+
+# Compare outputs
+if url == node_url
+  puts "\n✅ Outputs match!"
+  exit 0
+else
+  puts "\n❌ Outputs differ!"
+  exit 1
+end

test/unit/transloadit/test_smart_cdn.rb

@@ -0,0 +1,56 @@
+require 'test_helper'
+
+describe Transloadit::SmartCDN do
+  before do
+    @auth_key = 'my-key'
+    @auth_secret = 'my-secret'
+    @workspace = 'my-app'
+    @template = 'test-smart-cdn'
+    @input = 'inputs/prinsengracht.jpg'
+    @expire_at = 1732550672867
+  end
+
+  it 'generates correct signed urls' do
+    url = Transloadit::SmartCDN.signed_url(
+      workspace: @workspace,
+      template: @template,
+      input: @input,
+      auth_key: @auth_key,
+      auth_secret: @auth_secret,
+      expire_at_ms: @expire_at
+    )
+
+    expected_url = 'https://my-app.tlcdn.com/test-smart-cdn/inputs%2Fprinsengracht.jpg?auth_key=my-app&exp=1732550672867&sig=sha256%3A44e74094d8eb12598640ca339b773e1e0366365f9ba652ec2099da79d6efae1b'
+    assert_equal expected_url, url
+  end
+
+  it 'handles url parameters' do
+    url = Transloadit::SmartCDN.signed_url(
+      workspace: @workspace,
+      template: @template,
+      input: @input,
+      auth_key: @auth_key,
+      auth_secret: @auth_secret,
+      expire_at_ms: @expire_at,
+      url_params: {
+        width: 100,
+        height: 200
+      }
+    )
+
+    assert_match(/width=100/, url)
+    assert_match(/height=200/, url)
+  end
+
+  it 'requires workspace' do
+    assert_raises(ArgumentError) do
+      Transloadit::SmartCDN.signed_url(
+        workspace: '',
+        template: @template,
+        input: @input,
+        auth_key: @auth_key,
+        auth_secret: @auth_secret
+      )
+    end
+  end
+end

test/unit/transloadit/test_smart_cdn_node_parity.rb

@@ -0,0 +1,51 @@
+require 'test_helper'
+
+describe Transloadit::SmartCDN do
+  # Only run these tests if we're in CI or explicitly requested
+  if ENV['CI'] == 'true' || ENV['TEST_NODE_PARITY'] == 'true'
+    before do
+      @auth_key = 'my-key'
+      @auth_secret = 'my-secret'
+      @workspace = 'my-app'
+      @template = 'test-smart-cdn'
+      @input = 'inputs/prinsengracht.jpg'
+      @expire_at = 1732550672867
+
+      # Skip if tsx is not available
+      skip 'tsx not available' unless system('which tsx > /dev/null 2>&1')
+    end
+
+    it 'generates urls that match node implementation' do
+      url = Transloadit::SmartCDN.signed_url(
+        workspace: @workspace,
+        template: @template,
+        input: @input,
+        auth_key: @auth_key,
+        auth_secret: @auth_secret,
+        expire_at_ms: @expire_at
+      )
+
+      node_url = `tsx #{File.expand_path('../../../dev/smartcdn-sig.ts', __dir__)} #{@expire_at} #{@workspace} #{@template} #{@input}`.strip
+      assert_equal node_url, url
+    end
+
+    it 'handles url parameters the same as node' do
+      url = Transloadit::SmartCDN.signed_url(
+        workspace: @workspace,
+        template: @template,
+        input: @input,
+        auth_key: @auth_key,
+        auth_secret: @auth_secret,
+        expire_at_ms: @expire_at,
+        url_params: {
+          width: 100,
+          height: 200
+        }
+      )
+
+      node_url = `tsx #{File.expand_path('../../../dev/smartcdn-sig.ts', __dir__)} #{@expire_at} #{@workspace} #{@template} #{@input} width=100 height=200`.strip
+      assert_equal node_url, url
+    end
+  end
+end
+    it 'handles nil values in parameters the same as node' do