• 设为首页
  • 点击收藏
  • 手机版
    手机扫一扫访问
    迪恩网络手机版
  • 关注官方公众号
    微信扫一扫关注
    公众号

Scala JsonNode类代码示例

原作者: [db:作者] 来自: [db:来源] 收藏 邀请

本文整理汇总了Scala中com.fasterxml.jackson.databind.JsonNode的典型用法代码示例。如果您正苦于以下问题:Scala JsonNode类的具体用法?Scala JsonNode怎么用?Scala JsonNode使用的例子?那么恭喜您, 这里精选的类代码示例或许可以为您提供帮助。



在下文中一共展示了JsonNode类的20个代码示例,这些例子默认根据受欢迎程度排序。您可以为喜欢或者感觉有用的代码点赞,您的评价将有助于我们的系统推荐出更棒的Scala代码示例。

示例1: Truck

//设置package包名称以及导入依赖的类
package controllers

import scala.collection.JavaConverters._
import com.fasterxml.jackson.databind.{ ObjectMapper, JsonNode }
import com.fasterxml.jackson.module.scala.DefaultScalaModule
import play.api.Play
import sys.process._

case class Truck (
  name: String,
  address: String,
  cuisine: List[String],
  url: String) {
  override def toString: String = s"""$name (${cuisine.mkString(",")}) @ $address [$url]"""
}

object Truck {
  def newObjectMapper: ObjectMapper = {
    val m = new ObjectMapper()
    m.registerModule(DefaultScalaModule)
  }

  private[Truck] lazy val mapper = newObjectMapper

  val defaultLat = Play.maybeApplication.flatMap(_.configuration.getDouble("foodtrucks.latitude")).getOrElse(0.0)
  val defaultLon = Play.maybeApplication.flatMap(_.configuration.getDouble("foodtrucks.longitude")).getOrElse(0.0)

  def apply(jsonNode: JsonNode): Truck = {
    val info = jsonNode.get("obj")

    Truck(
      info.get("name").asText,
      info.get("last_seen").get("address").asText,
      info.get("cuisine").elements.asScala.map(_.asText).toList,
      info.get("url").asText
    )
  }

  def listAll(lat: Double = defaultLat, lon: Double = defaultLon): List[Truck] = {
    val result = Seq("curl", "-XGET", s"http://nyctruckfood.com/api/trucks/search?q=$lat,$lon").!!
    mapper.readTree(result).elements.asScala.map(Truck(_)).toList
  }
} 
开发者ID:andy327,项目名称:slack-foodtrucks,代码行数:44,代码来源:Truck.scala


示例2: JsonValidationResult

//设置package包名称以及导入依赖的类
package services.json

import com.fasterxml.jackson.databind.JsonNode
import com.github.fge.jsonschema.main.{JsonSchema, JsonSchemaFactory}
import services.json.MarshallableImplicits._

import scala.collection.JavaConversions._


object JsonValidationResult {
  def apply(success: Boolean, errors: Iterable[JsonNode]) = if(success) ValidJson else InvalidJson(errors)
}

sealed trait JsonValidationResult

case object ValidJson extends JsonValidationResult
case class InvalidJson(errors: Iterable[JsonNode]) extends JsonValidationResult

object JsonValidator {
  val schemaFactory = JsonSchemaFactory.byDefault()

  def validateJson(schemaAsString: String, jsonString: String): JsonValidationResult = {
    val schemaAsJsonNode = schemaAsString.fromJson[JsonNode]
    val jsonSchema = schemaFactory.getJsonSchema(schemaAsJsonNode)
    validateJson(jsonSchema, jsonString)
  }

  def validateJsonFromRemoteSchema(schemaUrl: String, jsonString: String): JsonValidationResult = {
    val jsonSchema = schemaFactory.getJsonSchema(schemaUrl)
    validateJson(jsonSchema, jsonString)
  }

  private def validateJson(jsonSchema: JsonSchema, jsonString: String): JsonValidationResult = {
    val json = jsonString.fromJson[JsonNode]
    val report = jsonSchema.validate(json)
    JsonValidationResult(report.isSuccess, report.map(_.asJson))
  }
} 
开发者ID:jeroenr,项目名称:reactive-mongo-demo,代码行数:39,代码来源:JsonValidator.scala


示例3: FakeService

//设置package包名称以及导入依赖的类
package com.github.ikhoon.app.v1.fake

import javax.inject.{ Inject, Named }

import com.fasterxml.jackson.databind.JsonNode
import com.twitter.finatra.httpclient.{ HttpClient, RequestBuilder }
import com.twitter.util.{ Await, Duration, Future }
import com.typesafe.config.Config

class FakeService @Inject() (@Named("fake") httpClient: HttpClient, config: Config) {
  def withSleepAsync(sec: Int): Future[JsonNode] = {
    val url = s"/api/?sleep=$sec"
    httpClient.executeJson[JsonNode](RequestBuilder.get(url))
  }

  def withSleepSync(sec: Int): JsonNode = {
    val url = s"/api/?sleep=$sec"
    val jsonNode = httpClient.executeJson[JsonNode](RequestBuilder.get(url))
    Await.result(jsonNode, Duration.fromSeconds(100))
  }
} 
开发者ID:ikhoon,项目名称:finatra-mysql-seed,代码行数:22,代码来源:FakeService.scala


示例4: BulkItemResponseDeserializer

//设置package包名称以及导入依赖的类
package com.github.thanhtien522.eshttpclient.entities

import com.fasterxml.jackson.core.JsonParser
import com.fasterxml.jackson.databind.{DeserializationContext, JsonDeserializer, JsonNode}


class BulkItemResponseDeserializer extends JsonDeserializer[BulkItemResponse] {

  override def deserialize(p: JsonParser, ctxt: DeserializationContext): BulkItemResponse = {
    val node = p.getCodec.readTree[JsonNode](p)
    node.fieldNames().next() match {
      case "index" => BulkItemResponse("index", p.getCodec.treeToValue(node.get("index"), classOf[IndexResponse]))
      case "create" => BulkItemResponse("create", p.getCodec.treeToValue(node.get("create"), classOf[IndexResponse]))
      case "update" => BulkItemResponse("update", p.getCodec.treeToValue(node.get("update"), classOf[UpdateResponse]))
      case "delete" => BulkItemResponse("delete", p.getCodec.treeToValue(node.get("delete"), classOf[DeleteResponse]))
      case s => throw new Exception("Deserialize BulkItemResponse failure. Unhandled action name `" + s + "`")
    }
  }
}

class ErrorDeserializer extends JsonDeserializer[Error] {
  override def deserialize(p: JsonParser, ctxt: DeserializationContext): Error = {
    val node = p.getCodec.readTree[JsonNode](p)

    if (node.isTextual) {
      Error("exception", node.asText(), null)
    } else if (node.isObject) {
      val `type` = node.get("type").asText()
      val reason = node.get("reason").asText()
      val caused = if (node.has("caused_by")) p.getCodec.treeToValue(node.get("caused_by"), classOf[Error]) else null
      Error(`type`, reason, caused)
    } else {
      throw new Exception(s"Deserialize Error failure. Expected STRING or OBJECT, actual ${node.getNodeType.toString}")
    }
  }
} 
开发者ID:thanhtien522,项目名称:es-http-client,代码行数:37,代码来源:Deserializers.scala


示例5: ELBSSLCertificateLambdaSpec

//设置package包名称以及导入依赖的类
package com.ocelotconsulting.ssl

import com.amazonaws.services.lambda.runtime.events.SNSEvent
import com.amazonaws.services.lambda.runtime.events.SNSEvent.{SNS, SNSRecord}
import com.fasterxml.jackson.databind.{DeserializationFeature, JsonNode, ObjectMapper}
import com.fasterxml.jackson.module.scala.DefaultScalaModule
import com.fasterxml.jackson.module.scala.experimental.ScalaObjectMapper
import org.scalatest.{FlatSpec, Matchers}

import scala.collection.JavaConversions._
import scala.collection.JavaConverters._
import scala.io.Source



class ELBSSLCertificateLambdaSpec extends FlatSpec with Matchers {
  val mapper = new ObjectMapper() with ScalaObjectMapper
  mapper.registerModule(DefaultScalaModule).configure(DeserializationFeature.FAIL_ON_UNKNOWN_PROPERTIES, false)

  def produceS3Event: JsonNode =
    mapper.readValue(Source.fromInputStream(getClass.getResourceAsStream("/sns_s3_event.json")).getLines.mkString, classOf[JsonNode])

  def toEvent: SNSEvent = {
    val event = new SNSEvent()
    val record = new SNSRecord()
    val sns = new SNS()
    val map = produceS3Event
    sns.setMessage(map.path("Records").get(0).path("Sns").path("Message").asText())
    record.setSns(sns)
    event.setRecords(List[SNSRecord](record))
    event
  }

  "An S3 event" should "run lambda successfully" in {
    val mainObj = new ELBSSLCertificateLambda
    val something = mainObj.configureELBCert(toEvent)
    something.asScala.head shouldBe "Status code for setting arn:aws:iam::my_acct:server-certificate/ocelotconsulting-demo.com ELB certificate for myelb is 200."
  }
} 
开发者ID:ocelotconsulting,项目名称:elb-ssl-cert-lambda,代码行数:40,代码来源:ELBSSLCertificateLambdaSpec.scala


示例6: DplaJsonTraversable

//设置package包名称以及导入依赖的类
package la.dp.sitemap

import java.io.InputStream

import com.fasterxml.jackson.core.JsonToken
import com.fasterxml.jackson.core.JsonToken._
import com.fasterxml.jackson.databind.{JsonNode, ObjectMapper}


class DplaJsonTraversable(inputStream: InputStream) extends Traversable[JsonNode] {

  override def hasDefiniteSize = false

  override def foreach[U](f: (JsonNode) => U): Unit = {

    try {
      val parser = DplaJsonTraversable.jsonFactory.createParser(inputStream)
      assume(parser.nextToken() == JsonToken.START_ARRAY)

      while (parser.nextToken() != END_ARRAY) {
        if (parser.currentToken() == START_OBJECT) {
          val node = parser.readValueAsTree[JsonNode]
          f(node)
        }
      }

    } finally {
      inputStream.close()
    }
  }

  override def toString(): String = "DplaJsonTraversable: " + inputStream.toString
}

object DplaJsonTraversable {
  private val objectMapper = new ObjectMapper()
  private val jsonFactory = objectMapper.getFactory
} 
开发者ID:dpla,项目名称:sitemap,代码行数:39,代码来源:DplaJsonTraversable.scala


示例7: Validator

//设置package包名称以及导入依赖的类
package hmrc.sdil.domain

import java.io.File
import com.github.fge.jsonschema.core.report.ProcessingReport
import com.github.fge.jsonschema.main._
import com.github.fge.jackson.JsonLoader
import com.fasterxml.jackson.databind.JsonNode

package object jsonvalidator {
  implicit class Validator(data: JsonNode) {
    val factory = JsonSchemaFactory.byDefault
    val validator = factory.getValidator

    def validateAgainst(schema: JsonNode): Either[ProcessingReport, JsonNode] = {
      val report = validator.validate(schema, data)
      if (report.isSuccess) {
        Right(data)
      } else {
        Left(report)
      }
    }
  }

  implicit class JsonHelper(val sc: StringContext) {
    def json(args: Any*): JsonNode = JsonLoader.fromString(sc.s(args))
    def jsonFile(args: Any*): JsonNode = JsonLoader.fromFile(new File(sc.parts.mkString(" ")))
  }
} 
开发者ID:hmrc,项目名称:sdil-domain,代码行数:29,代码来源:Validator.scala


示例8: Paging

//设置package包名称以及导入依赖的类
package dynamite

import com.fasterxml.jackson.databind.JsonNode

sealed abstract class Paging[+A] extends Product with Serializable

object Paging {
  def fromIterator[A](it: Iterator[A]): Paging[A] = {
    if (it.hasNext) {
      val next = Lazy(it.next())
      Page(next, Lazy {
        next()
        fromIterator(it)
      })
    } else EOF
  }

  final case class Page[A](data: Lazy[A], next: Lazy[Paging[A]]) extends Paging[A]

  case object EOF extends Paging[Nothing]
}

sealed abstract class PageType extends Product with Serializable

object PageType {
  final case class TablePaging(select: Ast.Select, data: List[JsonNode]) extends PageType
  final case class TableNamePaging(names: Seq[String]) extends PageType
} 
开发者ID:joprice,项目名称:dynamite,代码行数:29,代码来源:Paging.scala


示例9: ConfigFile

//设置package包名称以及导入依赖的类
package moe.pizza.auth.config

import com.fasterxml.jackson.annotation.JsonProperty
import com.fasterxml.jackson.databind.JsonNode
import moe.pizza.auth.adapters.GraderChain
import moe.pizza.auth.adapters.PilotGraderLike.PilotGraderFactory
import moe.pizza.auth.interfaces.PilotGrader
import moe.pizza.auth.webapp.oauth.OAuthApplication

import scala.concurrent.ExecutionContext
import org.http4s.client.Client


object ConfigFile {
  case class PingBotConfig(
      host: String,
      password: String
  )
  case class EmbeddedLdapConfig(
      instancePath: String = "./ldap",
      port: Int = 389,
      basedn: String = "ou=pizza",
      host: String = "localhost",
      password: Option[String] = None
  )
  case class AuthGroupConfig(closed: List[String],
                             open: List[String],
                             public: List[String])

  case class AuthConfig(
      domain: String,
      corporation: String,
      alliance: String,
      groupName: String,
      groupShortName: String,
      groups: AuthGroupConfig,
      graders: List[JsonNode],
      pingbot: Option[PingBotConfig],
      restkeys: List[String],
      applications: List[OAuthApplication] = List()
  ) {
    def constructGraders(c: ConfigFile)(
        implicit client: Client): PilotGrader =
      new GraderChain(
        graders.map(g => PilotGraderFactory.fromYaml(g, c)).flatten.toList)

  }
  case class CrestConfig(
      @JsonProperty("login_url") loginUrl: String,
      @JsonProperty("crest_url") crestUrl: String,
      clientID: String,
      secretKey: String,
      redirectUrl: String
  )
  case class ConfigFile(
      crest: CrestConfig,
      auth: AuthConfig,
      embeddedldap: EmbeddedLdapConfig
  )

} 
开发者ID:NoApologies420,项目名称:Alliance-Auth,代码行数:62,代码来源:ConfigFile.scala


示例10: SocketIOSessionFlowHelper

//设置package包名称以及导入依赖的类
package play.socketio.javadsl

import java.util.Optional
import java.util.concurrent.CompletionStage
import java.util.function.{ BiFunction, Function }

import akka.NotUsed
import akka.stream.Materializer
import akka.stream.javadsl.Flow
import com.fasterxml.jackson.databind.JsonNode
import play.api.libs.json.Json
import play.mvc.Http.RequestHeader
import play.socketio.{ SocketIOConfig, SocketIOEvent, SocketIOSession, SocketIOSessionFlow }

import scala.concurrent.ExecutionContext
import scala.Function.unlift
import scala.compat.java8.FutureConverters._
import scala.compat.java8.OptionConverters._


private[javadsl] object SocketIOSessionFlowHelper {

  def createEngineIOSessionHandler[SessionData](
    config:                     SocketIOConfig,
    connectCallback:            BiFunction[RequestHeader, String, CompletionStage[SessionData]],
    errorHandler:               Function[Throwable, Optional[JsonNode]],
    defaultNamespaceCallback:   Function[SocketIOSession[SessionData], Flow[SocketIOEvent, SocketIOEvent, NotUsed]],
    connectToNamespaceCallback: BiFunction[SocketIOSession[SessionData], String, Optional[Flow[SocketIOEvent, SocketIOEvent, NotUsed]]]
  )(implicit ec: ExecutionContext, mat: Materializer) = {
    SocketIOSessionFlow.createEngineIOSessionHandler[SessionData](
      config,
      (request, sid) => connectCallback(request.asJava, sid).toScala,
      unlift(t => errorHandler(t).asScala.map(Json.toJson(_))),
      session => defaultNamespaceCallback(session).asScala,
      unlift {
        case (session, sid) => connectToNamespaceCallback(session, sid).asScala.map(_.asScala)
      }
    )
  }
} 
开发者ID:playframework,项目名称:play-socket.io,代码行数:41,代码来源:SocketIOSessionFlowHelper.scala


示例11: JsonLifter

//设置package包名称以及导入依赖的类
package com.twitter.diffy.lifter

import com.fasterxml.jackson.core.JsonToken
import com.fasterxml.jackson.databind.{JsonNode, ObjectMapper}
import com.fasterxml.jackson.module.scala.DefaultScalaModule
import com.fasterxml.jackson.module.scala.experimental.ScalaObjectMapper
import com.twitter.util.{Try, NoStacktrace}

import scala.collection.JavaConversions._
import scala.language.postfixOps
import scala.reflect.runtime.universe.runtimeMirror
import scala.tools.reflect.ToolBox

object JsonLifter {
  object JsonNull
  object JsonParseError extends Exception with NoStacktrace

  val toolbox = runtimeMirror(getClass.getClassLoader).mkToolBox()

  val Mapper = new ObjectMapper with ScalaObjectMapper
  Mapper.registerModule(DefaultScalaModule)
  def apply(obj: Any): JsonNode = Mapper.valueToTree(obj)

  def lift(node: JsonNode): Any = node.asToken match {
    case JsonToken.START_ARRAY        =>
      node.elements.toSeq.map {
        element => lift(element)
      }  sortBy { _.toString }
    case JsonToken.START_OBJECT       => {
      val fields = node.fieldNames.toSet
      if (fields.exists{ field => Try(toolbox.parse(s"object ${field}123")).isThrow}) {
        node.fields map {field => (field.getKey -> lift(field.getValue))} toMap
      } else {
        FieldMap(
          node.fields map {field => (field.getKey -> lift(field.getValue))} toMap
        )
      }
    }
    case JsonToken.VALUE_FALSE        => false
    case JsonToken.VALUE_NULL         => JsonNull
    case JsonToken.VALUE_NUMBER_FLOAT => node.asDouble
    case JsonToken.VALUE_NUMBER_INT   => node.asLong
    case JsonToken.VALUE_TRUE         => true
    case JsonToken.VALUE_STRING       => node.textValue
    case _                            => throw JsonParseError
  }

  def decode(json: String): JsonNode = Mapper.readTree(json)
  def encode(item: Any): String = Mapper.writer.writeValueAsString(item)
} 
开发者ID:sachinmanchanda,项目名称:diffy_unicast,代码行数:51,代码来源:JsonLifter.scala


示例12: IAMServerCertificateLambdaFromString

//设置package包名称以及导入依赖的类
package com.ocelotconsulting.ssl

import com.amazonaws.services.lambda.runtime.events.SNSEvent
import com.amazonaws.services.lambda.runtime.events.SNSEvent.{SNS, SNSRecord}

import scala.collection.JavaConversions._
import com.amazonaws.services.s3.event.S3EventNotification.S3Entity
import com.fasterxml.jackson.databind.{DeserializationFeature, JsonNode, ObjectMapper}
import com.fasterxml.jackson.module.scala.DefaultScalaModule
import com.fasterxml.jackson.module.scala.experimental.ScalaObjectMapper
import org.scalatest.{FlatSpec, Matchers}

import scala.collection.JavaConverters._
import scala.io.Source



class IAMServerCertificateLambdaFromString(certFile: String) extends IAMServerCertificateLambda {
  override def getCertFileAsString(s3Entity: S3Entity): String = certFile
}

class IAMServerCertificateLambdaSpec  extends FlatSpec with Matchers {
  val mapper = new ObjectMapper() with ScalaObjectMapper
  mapper.registerModule(DefaultScalaModule).configure(DeserializationFeature.FAIL_ON_UNKNOWN_PROPERTIES, false)

  val mainObj = new IAMServerCertificateLambdaFromString(Source.fromInputStream(getClass.getResourceAsStream("/fake_staged_cert.json")).getLines.mkString)

  def produceS3Event: JsonNode =
    mapper.readValue(Source.fromInputStream( getClass.getResourceAsStream("/sns_s3_event.json") ).getLines.mkString, classOf[JsonNode])

  def toEvent: SNSEvent = {
    val event = new SNSEvent()
    val record = new SNSRecord()
    val sns = new SNS()
    val map = produceS3Event
    sns.setMessage(map.path("Records").get(0).path("Sns").path("Message").asText())
    record.setSns(sns)
    event.setRecords(List[SNSRecord](record))
    event
  }

  "An S3 event" should "run lambda successfully" in {
    val something = mainObj.configureIAMCert(toEvent)
    something.asScala.head shouldBe "Successfully uploaded certificate for ocelotconsulting.com."
  }
} 
开发者ID:ocelotconsulting,项目名称:iam-server-cert-lambda,代码行数:47,代码来源:IAMServerCertificateLambdaSpec.scala


示例13: parseJsValue

//设置package包名称以及导入依赖的类
package webby.form.field
import javax.annotation.Nullable

import com.fasterxml.jackson.databind.JsonNode
import webby.api.Logger
import webby.commons.text.StdStrHtml
import webby.form.{FormErrors, FormResult}

import scala.collection.mutable

trait ValueField[T] extends Field[T] {
  def parseJsValue(node: JsonNode): Either[String, T]

  
  protected def parseJsInt(node: JsonNode)(body: Int => Either[String, T]): Either[String, T] = {
    if (node.isNull || node.asText().isEmpty) Right(nullValue)
    else body(node.asInt())
  }

  def setJsValueAndValidate(@Nullable node: JsonNode): FormResult = {
    if (node != null && !node.isNull) {
      try {
        parseJsValue(node) match {
          case Right(v) => set(v); validate
          case Left(error) => FormErrors(errors = mutable.Map(shortId -> error))
        }
      } catch {
        case e: Exception =>
          Logger(getClass).warn("Error parsing js-value", e)
          FormErrors(errors = mutable.Map(shortId -> form.strings.invalidValue))
      }
    } else {
      setNull
      validate
    }
  }
} 
开发者ID:citrum,项目名称:webby,代码行数:38,代码来源:ValueField.scala


示例14: HiddenBooleanField

//设置package包名称以及导入依赖的类
package webby.form.field
import com.fasterxml.jackson.databind.JsonNode
import webby.form.Form


class HiddenBooleanField(val form: Form, val shortId: String) extends ValueField[Boolean] {
  override def jsField: String = "hidden"
  override def parseJsValue(node: JsonNode): Either[String, Boolean] = parseJsString(node) {v =>
    try Integer.parseInt(v) match {
      case 0 => Right(false)
      case 1 => Right(true)
      case _ => Left(form.strings.invalidValue)
    }
    catch {case e: NumberFormatException => Left(form.strings.enterIntegerNumber)}
  }
  override def nullValue: Boolean = false
} 
开发者ID:citrum,项目名称:webby,代码行数:18,代码来源:HiddenField.scala


示例15: UrlField

//设置package包名称以及导入依赖的类
package webby.form.field
import com.fasterxml.jackson.databind.JsonNode
import webby.commons.text.validator.UrlValidator
import webby.form.{Form, Invalid, Valid, ValidationResult}

class UrlField(val form: Form,
               val shortId: String,
               allowedDomains: Vector[String] = Vector.empty)
  extends ValueField[String] with PlaceholderField[String] {self =>

  var allowedSchemes: Array[String] = Array("http", "https")
  var defaultScheme: String = "http"

  val MaxLength = 250

  // ------------------------------- Reading data & js properties -------------------------------
  override def jsField: String = "text"
  override def parseJsValue(node: JsonNode): Either[String, String] = parseJsString(node)(Right(_))
  override def nullValue: String = null

  
  override def validateFieldOnly: ValidationResult = {
    if (get.length > MaxLength) Invalid(form.strings.noMoreThanCharsError(MaxLength))
    else UrlValidator.validate(get, allowedSchemes = allowedSchemes) match {
      case None => Invalid(form.strings.invalidUrl)
      case Some(url) =>
        if (allowedDomains.nonEmpty && !UrlValidator.validateDomain(url, allowedDomains)) {
          if (allowedDomains.size == 1) return Invalid(form.strings.urlMustContainDomain(allowedDomains.head))
          else return Invalid(form.strings.urlMustContainOneOfDomains(allowedDomains.mkString(", ")))
        }
        Valid
    }
  }
} 
开发者ID:citrum,项目名称:webby,代码行数:35,代码来源:UrlField.scala


示例16: EmailField

//设置package包名称以及导入依赖的类
package webby.form.field
import com.fasterxml.jackson.databind.JsonNode
import webby.commons.text.validator.EmailValidator
import webby.form.{Form, Invalid, Valid, ValidationResult}

class EmailField(val form: Form, val shortId: String) extends ValueField[String] with PlaceholderField[String] {self =>

  val MaxLength = 250

  // ------------------------------- Reading data & js properties -------------------------------
  override def jsField: String = "text"
  override def parseJsValue(node: JsonNode): Either[String, String] = parseJsString(node)(Right(_))
  override def nullValue: String = null

  // ------------------------------- Builder & validations -------------------------------
  
  override def validateFieldOnly: ValidationResult = {
    if (get.length > MaxLength) Invalid(form.strings.noMoreThanCharsError(MaxLength))
    else {
      if (EmailValidator.isValidFast(get)) Valid
      else Invalid(form.strings.invalidEmail)
    }
  }
} 
开发者ID:citrum,项目名称:webby,代码行数:25,代码来源:EmailField.scala


示例17: CheckField

//设置package包名称以及导入依赖的类
package webby.form.field
import com.fasterxml.jackson.databind.JsonNode
import webby.form.Form


class CheckField(val form: Form, val shortId: String, makeUniqueInputId: Boolean = false) extends ValueField[Boolean] {

  // ------------------------------- Reading data & js properties -------------------------------
  override def jsField: String = "check"
  override def parseJsValue(node: JsonNode): Either[String, Boolean] = Right(node.asBoolean())

  override def nullValue: Boolean = false
}

object CheckField {
  private var uniqueIdCounter = 0
  private[field] def nextUniqueIdCounter: Int = {uniqueIdCounter += 1; uniqueIdCounter}
} 
开发者ID:citrum,项目名称:webby,代码行数:19,代码来源:CheckField.scala


示例18: BaseSelectField

//设置package包名称以及导入依赖的类
package webby.form.field
import com.fasterxml.jackson.databind.JsonNode
import webby.form.Form

abstract class BaseSelectField[T](val form: Form, id: String)
  extends ValueField[T] {self =>
  var items: Iterable[T]
  var valueFn: T => String
  var titleFn: T => String
  var emptyTitle: Option[String]

  // ------------------------------- Reading data & js properties -------------------------------
  class SelectJsProps extends BaseJsProps {
    val values: Iterable[String] = for (value <- self.items) yield valueFn(value)
  }
  override def jsProps = new SelectJsProps
  override def parseJsValue(node: JsonNode): Either[String, T] = parseJsString(node) {v =>
    for (item <- items) if (valueFn(item) == v) return Right(item)
    Left(form.strings.invalidValue)
  }
  override def nullValue: T = null.asInstanceOf[T]
  override def toJsValue(v: T): AnyRef = if (isEmpty(v)) null else valueFn(v)
}



class EmptyStringRadioGroupField(val form: Form, val shortId: String) extends ValueField[String] {
  override def jsField: String = "radioGroup"
  override def parseJsValue(node: JsonNode): Either[String, String] = parseJsString(node)(Right(_))
  override def nullValue: String = null
} 
开发者ID:citrum,项目名称:webby,代码行数:32,代码来源:BaseSelectField.scala


示例19: AutocompleteField

//设置package包名称以及导入依赖的类
package webby.form.field.autocomplete

import com.fasterxml.jackson.databind.JsonNode
import webby.form.Form
import webby.form.field.{PlaceholderField, ValueField}


class AutocompleteField[T](val form: Form,
                           val shortId: String,
                           var jsSourceFunction: String,
                           var jsSourceArg: Any = null,
                           var toJs: T => Int,
                           var fromJs: Int => Option[T],
                           var addRendererCls: String = null)
  extends ValueField[T] with PlaceholderField[T] {self =>

  // ------------------------------- Reading data & js properties -------------------------------
  class JsProps extends BaseJsProps {
    val sourceFn = self.jsSourceFunction
    val sourceArg = self.jsSourceArg
    val addRendererCls = self.addRendererCls
  }
  override def jsProps = new JsProps
  override def jsField: String = "autocomplete"
  override def parseJsValue(node: JsonNode): Either[String, T] = parseJsInt(node) {intValue =>
    fromJs(intValue) match {
      case Some(v) => Right(v)
      case None => Left(form.strings.invalidValue)
    }
  }
  override def toJsValue(v: T): AnyRef = if (v == null) null else toJs(v).asInstanceOf[AnyRef]

  override def nullValue: T = null.asInstanceOf[T]
} 
开发者ID:citrum,项目名称:webby,代码行数:35,代码来源:AutocompleteField.scala


示例20: ReCaptchaField

//设置package包名称以及导入依赖的类
package webby.form.field.recaptcha
import com.fasterxml.jackson.databind.JsonNode
import webby.api.mvc.RequestHeader
import webby.form._
import webby.form.field.ValueField

class ReCaptchaField(val form: Form, val reCaptcha: ReCaptcha)(implicit req: RequestHeader) extends ValueField[String] { self =>
  override def shortId: String = reCaptcha.config.formParamName

  // ------------------------------- Reading data & js properties -------------------------------
  override def jsField: String = "reCaptcha"
  override def parseJsValue(node: JsonNode): Either[String, String] = parseJsString(node)(Right(_))
  override def nullValue: String = null

  // ------------------------------- Builder & validations -------------------------------

  private var lastCheckedValue: String = null
  private var lastSolveResult: Boolean = false

  // The captcha check will be executed after all checks and constraints.
  // We cannot execute the captcha check on the same data input twice. So we make sure no errors in
  // the form before the captcha check.
  form.lastConstraints ::= {_ =>
    if (isEmpty) FormSuccess
    else {
      if (get != lastCheckedValue) {
        lastSolveResult = reCaptcha.solve(get)
        lastCheckedValue = get
      }
      if (!lastSolveResult) error("?????????? ??? ???")
      else FormSuccess
    }
  }
} 
开发者ID:citrum,项目名称:webby,代码行数:35,代码来源:ReCaptchaField.scala



注:本文中的com.fasterxml.jackson.databind.JsonNode类示例整理自Github/MSDocs等源码及文档管理平台,相关代码片段筛选自各路编程大神贡献的开源项目,源码版权归原作者所有,传播和使用请参考对应项目的License;未经允许,请勿转载。


鲜花

握手

雷人

路过

鸡蛋
该文章已有0人参与评论

请发表评论

全部评论

专题导读
上一篇:
Scala ForkJoinTaskSupport类代码示例发布时间:2022-05-23
下一篇:
Scala ActorSelection类代码示例发布时间:2022-05-23
热门推荐
热门话题
阅读排行榜

扫描微信二维码

查看手机版网站

随时了解更新最新资讯

139-2527-9053

在线客服(服务时间 9:00~18:00)

在线QQ客服
地址:深圳市南山区西丽大学城创智工业园
电邮:jeky_zhao#qq.com
移动电话:139-2527-9053

Powered by 互联科技 X3.4© 2001-2213 极客世界.|Sitemap