module.exports = function()

in api_server/es_1_0/snapshot_restore.js [1:153]
121 lines of code
1 McCabe index (conditional complexity)

module.exports = function (api) {
  api.addEndpointDescription('restore_snapshot', {
    methods: ['POST'],
    patterns: [
      '_snapshot/{id}/{id}/_restore'
    ],
    url_params: {
      wait_for_completion: "__flag__"
    },
    data_autocomplete_rules: {
      indices: "*",
      ignore_unavailable: {__one_of: [true, false]},
      include_global_state: false,
      rename_pattern: "index_(.+)",
      rename_replacement: "restored_index_$1"
    }
  });


  api.addEndpointDescription('single_snapshot', {
    methods: ['GET', 'DELETE'],
    patterns: [
      '_snapshot/{id}/{id}'
    ]
  });

  api.addEndpointDescription('all_snapshots', {
    methods: ['GET'],
    patterns: [
      '_snapshot/{id}/_all'
    ]
  });

  api.addEndpointDescription('put_snapshot', {
    methods: ['PUT'],
    patterns: [
      '_snapshot/{id}/{id}'
    ],
    url_params: {
      wait_for_completion: "__flag__"
    },
    data_autocomplete_rules: {
      indices: "*",
      ignore_unavailable: {__one_of: [true, false]},
      include_global_state: {__one_of: [true, false]},
      partial: {__one_of: [true, false]}
    }
  });

  api.addEndpointDescription('_snapshot_status', {
    methods: ['GET'],
    patterns: [
      '_snapshot/_status',
      '_snapshot/{id}/_status',
      '_snapshot/{id}/{ids}/_status'
    ]
  });


  function getRepositoryType(context, editor) {
    var iter = editor.iterForCurrentLoc();
    // for now just iterate back to the first "type" key
    var t = iter.getCurrentToken();
    var type;
    while (t && t.type.indexOf("url") < 0) {
      if (t.type === 'variable' && t.value === '"type"') {
        t = editor.parser.nextNonEmptyToken(iter);
        if (!t || t.type !== "punctuation.colon") {
          // weird place to be in, but safe choice..
          break;
        }
        t = editor.parser.nextNonEmptyToken(iter);
        if (t && t.type === "string") {
          type = t.value.replace(/"/g, '');
        }
        break;
      }
      t = editor.parser.prevNonEmptyToken(iter);
    }
    return type;
  }

  api.addEndpointDescription('put_repository', {
    methods: ['PUT'],
    patterns: [
      '_snapshot/{id}'
    ],
    data_autocomplete_rules: {
      __template: {"type": ""},

      "type": {
        __one_of: ["fs", "url", "s3", "hdfs"]
      },
      "settings": {
        __one_of: [{
          //fs
          __condition: {
            lines_regex: String.raw`type["']\s*:\s*["']fs`
          },
          __template: {
            location: "path"
          },
          location: "path",
          compress: {__one_of: [true, false]},
          concurrent_streams: 5,
          chunk_size: "10m",
          max_restore_bytes_per_sec: "20mb",
          max_snapshot_bytes_per_sec: "20mb"
        },
          {// url
            __condition: {
              lines_regex: String.raw`type["']\s*:\s*["']url`
            },
            __template: {
              url: ""
            },
            url: "",
            concurrent_streams: 5
          },
          { //s3
            __condition: {
              lines_regex: String.raw`type["']\s*:\s*["']s3`
            },
            __template: {
              bucket: ""
            },
            bucket: "",
            region: "",
            base_path: "",
            concurrent_streams: 5,
            chunk_size: "10m",
            compress: {__one_of: [true, false]}
          },
          {// hdfs
            __condition: {
              lines_regex: String.raw`type["']\s*:\s*["']hdfs`
            },
            __template: {
              path: ""
            },
            uri: "",
            path: "some/path",
            load_defaults: {__one_of: [true, false]},
            conf_location: "cfg.xml",
            concurrent_streams: 5,
            compress: {__one_of: [true, false]},
            chunk_size: "10m"
          }
        ]
      }
    }
  });
};