linkis-commons/linkis-storage/src/main/scala/com/webank/wedatasphere/linkis/storage/script/VariableParser.scala

/*
 * Copyright 2019 WeBank
 *
 * Licensed under the Apache License, Version 2.0 (the "License");
 *  you may not use this file except in compliance with the License.
 * You may obtain a copy of the License at
 *
 * http://www.apache.org/licenses/LICENSE-2.0
 *
 * Unless required by applicable law or agreed to in writing, software
 * distributed under the License is distributed on an "AS IS" BASIS,
 * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
 * See the License for the specific language governing permissions and
 * limitations under the License.
 */

package com.webank.wedatasphere.linkis.storage.script

import java.util

import scala.collection.mutable.ArrayBuffer

object VariableParser {

  val CONFIGURATION: String = "configuration"
  val VARIABLE: String = "variable"
  val RUNTIME: String = "runtime"
  val STARTUP: String = "startup"
  val SPECIAL: String = "special"

  def getVariables(params: util.Map[String, Object]): Array[Variable] = {
    import scala.collection.JavaConversions._
    val variables = new ArrayBuffer[Variable]
    params.getOrDefault(VARIABLE, new util.HashMap[String, Object])
      .asInstanceOf[util.Map[String, Object]]
      .foreach(f => variables += Variable(VARIABLE, null, f._1, f._2.toString))
    params.getOrDefault(CONFIGURATION, new util.HashMap[String, Object])
      .asInstanceOf[util.Map[String, Object]]
      .foreach {
        f => f._2.asInstanceOf[util.Map[String, Object]].filter(s => ! isContextIDINFO(s._1)).foreach(p => p._2 match {
          case e: util.Map[String, Object] => {
            e.filter(s => ! isContextIDINFO(s._1)).foreach(s => variables += Variable(f._1, p._1, s._1, s._2.toString))
          }
          case _ => variables += Variable(CONFIGURATION, f._1, p._1, p._2.toString)
        })
      }
    variables.toArray
  }

  //TODO need delete 20200321 update by peaceWong
  def isContextIDINFO(key : String): Boolean ={
    "contextID".equalsIgnoreCase(key) || "nodeName".equalsIgnoreCase(key)
  }

  def getMap(variables: Array[Variable]): util.Map[String, Object] = {
    import scala.collection.JavaConversions._
    val vars = new util.HashMap[String, String]
    val confs = new util.HashMap[String, Object]
    variables.filter(_.sort == null).foreach(f => vars += f.key -> f.value)
    variables.filter(_.sort != null).foreach {
      f => f.sort match {
        case STARTUP | RUNTIME | SPECIAL =>
          if (confs.get(f.sort) == null)
            confs += f.sort -> createMap(f)
          else
            confs.get(f.sort).asInstanceOf[util.HashMap[String, Object]] += f.key -> f.value
        case _ =>
          if (confs.get(f.sortParent) == null) {
            confs += f.sortParent -> new util.HashMap[String, Object]
            confs.get(f.sortParent).asInstanceOf[util.HashMap[String, Object]] += f.sort -> createMap(f)
          } else {
            val subMap = confs.get(f.sortParent).asInstanceOf[util.HashMap[String, Object]]
            if (subMap.get(f.sort) == null) subMap += f.sort -> createMap(f) else subMap.get(f.sort).asInstanceOf[util.HashMap[String, Object]] += f.key -> f.value
          }
      }
    }
    val params = new util.HashMap[String, Object]
    if(vars.size() >0)params += VARIABLE -> vars
    if(vars.size() >0)params += CONFIGURATION -> confs
    params
  }

  private def createMap(variable: Variable): util.Map[String, Object] = {
    import scala.collection.JavaConversions._
    val map = new util.HashMap[String, Object]
    map += variable.key -> variable.value
  }

 /* def main(args: Array[String]): Unit = {
    val a = Array(
      Variable("variable", null, "a", "b"),
      Variable("variable", null, "a1", "b1"),
      Variable("configuration", "startup", "e", "f"),
      Variable("configuration", "runtime", "a", "b"),
      Variable("runtime", "env", "g2", "h3"),
      Variable("startup", "hello", "g2", "h3"))
    //val a = Array[Variable]()
    //println(new GsonBuilder().setDateFormat("yyyy-MM-dd'T'HH:mm:ssZ").serializeNulls.create.toJson(getMap(a)))
    //val variables: Array[Variable] = getVariables(getMap(a))
    //val variables: Array[Variable] = getVariables(getMap(a))
    //print(variables)
   /* val writer = ScriptFsWriter.getScriptFsWriter(new FsPath("file:///tmp/hello.py"), "utf-8", new FileOutputStream("E:\\aaa.py"))

    writer.addMetaData(new ScriptMetaData(a))
    writer.addRecord(new ScriptRecord("hello"))
    writer.addRecord(new ScriptRecord("hello"))
    writer.addRecord(new ScriptRecord("hello"))
    writer.addRecord(new ScriptRecord("hello"))*/
    val reader = ScriptFsReader.getScriptFsReader(new FsPath("file:///tmp/aaa.py"),"utf-8",new FileInputStream("E:\\aaa.py"))
    reader.getMetaData.asInstanceOf[ScriptMetaData].getMetaData
    val map = getMap(reader.getMetaData.asInstanceOf[ScriptMetaData].getMetaData)
    println(new GsonBuilder().setDateFormat("yyyy-MM-dd'T'HH:mm:ssZ").serializeNulls.create.toJson(map))
    print(reader.getRecord.asInstanceOf[ScriptRecord].getLine)

  }*/

}