map operation names to commands

orcli

@@ -856,8 +856,7 @@ orcli_info_command() {
 # :command.function
 orcli_transform_command() {
   # src/transform_command.sh
-  # shellcheck shell=bash disable=SC2154
+  # shellcheck shell=bash disable=SC2154 disable=SC2155
-  #get_id "${args[project]}"
 
   # check if stdin is present if selected
   if [[ ${args[file]} == '-' ]] || [[ ${args[file]} == '"-"' ]]; then
@@ -866,12 +865,15 @@ orcli_transform_command() {
           exit 1
       fi
   fi
+
   # catch args, convert the space delimited string to an array
   files=()
   eval "files=(${args[file]})"
+
   # create tmp directory
   tmpdir="$(mktemp -d)"
   trap 'rm -rf "$tmpdir"' 0 2 3 15
+
   # download files if name starts with http:// or https://
   for i in "${!files[@]}"; do
       if [[ ${files[$i]} == "http://"* ]] || [[ ${files[$i]} == "https://"* ]]; then
@@ -882,16 +884,37 @@ orcli_transform_command() {
       fi
   done
 
-  # support multiple files and stdin
+  # support multiple files
-  readarray -t jsonlines < <(cat "${files[@]}" | jq --slurp --compact-output 'add | .[]')
+  for i in "${!files[@]}"; do
-  for line in "${jsonlines[@]}"; do
+      # read each operation into one line
-    declare -A data="($(echo "$line" | jq -r 'to_entries | map("[\(.key)]=" + @sh "\(.value|tostring)") | .[]'))"
+      mapfile -t jsonlines < <(jq -c '.[]' "${files[$i]}")
-    echo "${data[op]#core/}"
+      for line in "${jsonlines[@]}"; do
-    unset "data[op]"
+          # parse operation into curl options
-    unset "data[description]"
+          declare -A data="($(echo "$line" | jq -r 'to_entries | map("[\(.key)]=" + @sh "\(.value|tostring)") | .[]'))"
-    for K in "${!data[@]}"; do echo "$K" --- "${data[$K]}"; done
+          # map operation name to command
-    unset data
+          com="${data[op]#core/}"
+          if [[ $com == "row-reorder" ]]; then com="reorder-rows"; fi
+          unset "data[op]"
+          # rename engineConfig to engine
+          data[engine]="${data[engineConfig]}"
+          unset "data[engineConfig]"
+          # drop description
+          unset "data[description]"
+          mapfile -t curloptions < <(for K in "${!data[@]}"; do
+              echo "--data"
+              echo "$K=${data[$K]}"
+          done)
+          # get project id and csrf token; post data to it's individual endpoint
+          set -x
+          # debug: remove -fs
+          if ! curl --data "project=$(get_id "${args[project]}")" "${curloptions[@]}" "${OPENREFINE_URL}/command/core/${com}$(get_csrf)"; then
+              error "applying ${op} from ${files[$i]} failed!"
+          fi
+          set +x
+          unset data
+      done
   done
+
 }
 
 # :command.function

src/transform_command.sh

@@ -1,4 +1,4 @@
-# shellcheck shell=bash disable=SC2154
+# shellcheck shell=bash disable=SC2154 disable=SC2155
 
 # check if stdin is present if selected
 if [[ ${args[file]} == '-' ]] || [[ ${args[file]} == '"-"' ]]; then
@@ -33,15 +33,22 @@ for i in "${!files[@]}"; do
     for line in "${jsonlines[@]}"; do
         # parse operation into curl options
         declare -A data="($(echo "$line" | jq -r 'to_entries | map("[\(.key)]=" + @sh "\(.value|tostring)") | .[]'))"
-        op="${data[op]#core/}"
+        # map operation name to command
+        com="${data[op]#core/}"
+        if [[ $com == "row-reorder" ]]; then com="reorder-rows"; fi
         unset "data[op]"
+        # rename engineConfig to engine
+        data[engine]="${data[engineConfig]}"
+        unset "data[engineConfig]"
+        # drop description
         unset "data[description]"
         mapfile -t curloptions < <(for K in "${!data[@]}"; do
-            echo "--data-urlencode"
+            echo "--data"
-            echo "$K={data[$K]}"
+            echo "$K=${data[$K]}"
         done)
-        # get project id and csrf token; post data to it's individual endpoint 
+        # get project id and csrf token; post data to it's individual endpoint
-        if ! curl -fs --data "project=$(get_id "${args[project]}")" "${curloptions[@]}" "${OPENREFINE_URL}/command/core/${op}$(get_csrf)"; then
+        # debug: remove -fs option temporarily
+        if ! curl --data "project=$(get_id "${args[project]}")" "${curloptions[@]}" "${OPENREFINE_URL}/command/core/${com}$(get_csrf)"; then
             error "applying ${op} from ${files[$i]} failed!"
         fi
         unset data