Add streaming profiles API

Author: Amir Tocker

lib/api.js

@@ -14,7 +14,6 @@ call_api = (method, uri, params, callback, options) ->
   api_key = options["api_key"] ? config().api_key ? throw("Must supply api_key")
   api_secret = options["api_secret"] ? config().api_secret ? throw("Must supply api_secret")
   api_url = [cloudinary, "v1_1", cloud_name].concat(uri).join("/")
-
   query_params = querystring.stringify(params)
   if method == "get"
     api_url += "?" + query_params
@@ -256,6 +255,23 @@ exports.publish_by_tag = (tag, callback, options={})->
 exports.publish_by_ids = (public_ids, callback, options={})->
   publishResource("public_ids", public_ids, callback,options)
 
+exports.list_streaming_profiles = (callback, options = {})->
+  call_api("get", "streaming_profiles", {}, callback, options)
+
+exports.get_streaming_profile = (name, callback, options = {})->
+  call_api("get", "streaming_profiles/#{name}", {}, callback, options)
+
+exports.delete_streaming_profile = (name, callback, options = {})->
+  call_api("delete", "streaming_profiles/#{name}", {}, callback, options)
+
+exports.update_streaming_profile = (name, callback, options = {})->
+  params = utils.build_streaming_profiles_param(options)
+  call_api("put", "streaming_profiles/#{name}", params, callback, options)
+
+exports.create_streaming_profile = (name, callback, options = {})->
+  params = utils.build_streaming_profiles_param(options)
+  params["name"] = name
+  call_api("post", 'streaming_profiles', params, callback, options)
 
 exports.only = (hash, keys...) ->
   result = {}

lib/api.js.map

@@ -867,6 +867,20 @@ exports.generate_responsive_breakpoints_string = (breakpoints)->
         breakpoint_settings.transformation = utils.generate_transformation_string(_.clone(transformation))
   JSON.stringify(breakpoints)
 
+exports.build_streaming_profiles_param = (options={})->
+  params = utils.only(options, "display_name", "representations")
+  if _.isArray(params["representations"])
+    params["representations"] = JSON.stringify(params["representations"].map (r)->
+      {transformation: utils.generate_transformation_string(r.transformation)}
+    )
+  params
+
+exports.only = (hash, keys...) ->
+  result = {}
+  for key in keys
+    result[key] = hash[key] if hash[key]?
+  result
+
 ###*
 # @private
 ###

lib/utils.js

@@ -35,6 +35,11 @@ utils.v1_adapters exports, api,
   delete_upload_mapping: 1,
   update_upload_mapping: 1,
   create_upload_mapping: 1,
+  list_streaming_profiles: 0,
+  get_streaming_profile: 1,
+  delete_streaming_profile: 1,
+  update_streaming_profile: 1,
+  create_streaming_profile: 1,
   publish_by_ids: 1,
   publish_by_tag: 1,
   publish_by_prefix: 1

lib/utils.js.map

@@ -60,14 +60,20 @@ sharedExamples "accepts next_cursor", (testFunc, args...)->
       sinon.assert.calledWith requestSpy, sinon.match(query: sinon.match(/next_cursor=23452342/))
 
 
-
 describe "api", ->
-  return console.warn("**** Please setup environment for api test to run!") if !cloudinary.config().api_secret?
+  before "Verify Configuration", ->
+    config = cloudinary.config(true)
+    if(!(config.api_key && config.api_secret))
+      expect().fail("Missing key and secret. Please set CLOUDINARY_URL.")
 
   after (done)->
     if cloudinary.config().keep_test_products
       done()
     else
+      config = cloudinary.config()
+      if(!(config.api_key && config.api_secret))
+        expect().fail("Missing key and secret. Please set CLOUDINARY_URL.")
+
       cloudinary.v2.api.delete_resources_by_tag helper.TEST_TAG, (error, result) ->
         if error?
           done(new Error error.message)