/** * Generated by API Builder - https://www.apibuilder.io * Service version: 1.0.0 * User agent: apibuilder app.apibuilder.io/teambytes/hipchat-sns-bridge/1.0.0/ning_1_9_client */ package com.teambytes.hipchat.sns.bridge.v1.models { /** * A request semantic failure reason. */ final case class Error( description: String ) /** * @param scopes An array of scopes that are required to consume the HipChat API. * @param fromName The name that messages should be from when sent from the integration itself. */ final case class HipchatApiConsumer( scopes: Seq[com.teambytes.hipchat.sns.bridge.v1.models.HipchatScope], fromName: _root_.scala.Option[String] = None ) /** * @param configurable Most integrations will need to be configured in order to work correctly. For * this purpose, an integration can expose a 'configurable' capability that * provides an HTML page to be included as a panel in the configuration dialog. * @param hipchatApiConsumer The ability to consume the HipChat API. * @param installable The capability of receiving a synchronous installation callback during * integration installation. * @param oauth2Provider The capability of providing and accepting OAuth 2 tokens for authentication. */ final case class HipchatCapabilities( configurable: _root_.scala.Option[com.teambytes.hipchat.sns.bridge.v1.models.HipchatConfigurationPage] = None, hipchatApiConsumer: _root_.scala.Option[com.teambytes.hipchat.sns.bridge.v1.models.HipchatApiConsumer] = None, installable: _root_.scala.Option[com.teambytes.hipchat.sns.bridge.v1.models.HipchatInstallable] = None, oauth2Provider: _root_.scala.Option[com.teambytes.hipchat.sns.bridge.v1.models.HipchatOauth2Provider] = None ) /** * @param name The display name of this application. * @param description A short description of this application. * @param key The marketplace integration key that uniquely identifies the application, if * registered. * @param apiVersion The HipChat Connect API version used by this integration. Defaults to 1:1. * @param capabilities The set of capabilities this application supports. * @param links URLs to retrieve this and related integration information. * @param vendor The vendor that maintains this application. */ final case class HipchatCapabilitiesDescriptor( name: String, description: String, key: String, apiVersion: _root_.scala.Option[String] = None, capabilities: _root_.scala.Option[com.teambytes.hipchat.sns.bridge.v1.models.HipchatCapabilities] = None, links: com.teambytes.hipchat.sns.bridge.v1.models.HipchatLinks, vendor: _root_.scala.Option[com.teambytes.hipchat.sns.bridge.v1.models.HipchatVendor] = None ) /** * @param allowAccessToRoomAdmins If the add-on is installed globally, this property can allow the configuration * page to be accessed in the room administration pages making it possible to have * room specific configuration for the global add-on. This is only valid for * globally installed add-ons. * @param url The URL to embed into a configure dialog via an iframe. */ final case class HipchatConfigurationPage( allowAccessToRoomAdmins: _root_.scala.Option[String] = None, url: String ) final case class HipchatInstallData( capabilitiesUrl: String, oauthId: String, oauthSecret: String, groupId: Long, roomId: _root_.scala.Option[String] = None ) /** * @param callbackUrl The URL to receive a confirmation of an integration installation. * @param installedUrl The URL HipChat will redirect to post-installation. * @param allowGlobal Whether the integration can be installed globally or not. * @param allowRoom Whether the integration can be installed in a room or not. */ final case class HipchatInstallable( callbackUrl: _root_.scala.Option[String] = None, installedUrl: _root_.scala.Option[String] = None, allowGlobal: _root_.scala.Option[Boolean] = None, allowRoom: _root_.scala.Option[Boolean] = None ) /** * @param homepage The URL to human-viewable home page of this integration. * @param api The URL to the REST API root. * @param self The URL to this descriptor. */ final case class HipchatLinks( homepage: _root_.scala.Option[String] = None, api: _root_.scala.Option[String] = None, self: String ) /** * @param tokenUrl The OAuth 2 token endpoint for retrieving an access token. * @param authorizationUrl The OAuth 2 endpoint to direct browsers to in order to receive an authorization * code that can be later exchanged using the token URL for an access token. */ final case class HipchatOauth2Provider( tokenUrl: _root_.scala.Option[String] = None, authorizationUrl: _root_.scala.Option[String] = None ) /** * @param name The vendor display name. * @param url The vendor's home page URL. */ final case class HipchatVendor( name: String, url: String ) /** * @param name Name of this service. * @param version Version of this service. * @param scalaVersion Version of Scala this service is using. * @param sbtVersion Version of SBT used to build this service. * @param buildTime Time the service was built at. */ final case class ServiceInfo( name: String, version: String, scalaVersion: String, sbtVersion: String, buildTime: _root_.org.joda.time.DateTime ) /** * @param `type` The type of message. For a unsubscribe confirmation, the type is * UnsubscribeConfirmation. * @param messageId A Universally Unique Identifier, unique for each message published. For a * message that Amazon SNS resends during a retry, the message ID of the original * message is used. * @param topicArn The Amazon Resource Name (ARN) for the topic that this endpoint has been * unsubscribed from. * @param message A string that describes the message. * @param timestamp The time (GMT) when the unsubscribe confirmation was sent. * @param signatureVersion Version of the Amazon SNS signature used. * @param signature Base64-encoded 'SHA1withRSA' signature of the Message, MessageId, Type, * Timestamp, and TopicArn values. * @param signingCertURL The URL to the certificate that was used to sign the message. * @param token A value you can use with the ConfirmSubscription action to re-confirm the * subscription. Alternatively, you can simply visit the SubscribeURL. * @param subject The Subject parameter specified when the notification was published to the * topic. Note that this is an optional parameter. If no Subject was specified, * then this name/value pair does not appear in this JSON document. * @param subscribeURL The URL that you must visit in order to re-confirm the subscription. * Alternatively, you can instead use the Token with the ConfirmSubscription action * to re-confirm the subscription. * @param unsubscribeURL A URL that you can use to unsubscribe the endpoint from this topic. If you visit * this URL, Amazon SNS unsubscribes the endpoint and stops sending notifications * to this endpoint. */ final case class SnsNotification( `type`: String, messageId: String, topicArn: String, message: String, timestamp: String, signatureVersion: String, signature: String, signingCertURL: String, token: _root_.scala.Option[String] = None, subject: _root_.scala.Option[String] = None, subscribeURL: _root_.scala.Option[String] = None, unsubscribeURL: _root_.scala.Option[String] = None ) /** * Your add-on must declare the scopes it requires based on which API endpoints it * needs to use, via its descriptor. */ sealed trait HipchatScope extends _root_.scala.Product with _root_.scala.Serializable object HipchatScope { case object SendMessage extends HipchatScope { override def toString = "send_message" } case object SendNotification extends HipchatScope { override def toString = "send_notification" } /** * UNDEFINED captures values that are sent either in error or * that were added by the server after this library was * generated. We want to make it easy and obvious to users of * this library to handle this case gracefully. * * We use all CAPS for the variable name to avoid collisions * with the camel cased values above. */ final case class UNDEFINED(override val toString: String) extends HipchatScope /** * all returns a list of all the valid, known values. We use * lower case to avoid collisions with the camel cased values * above. */ val all: scala.List[HipchatScope] = scala.List(SendMessage, SendNotification) private val byName: Map[String, HipchatScope] = all.map(x => x.toString.toLowerCase -> x).toMap def apply(value: String): HipchatScope = fromString(value).getOrElse(UNDEFINED(value)) def fromString(value: String): _root_.scala.Option[HipchatScope] = byName.get(value.toLowerCase) } } package com.teambytes.hipchat.sns.bridge.v1.models { package object json { import play.api.libs.json.__ import play.api.libs.json.JsString import play.api.libs.json.Writes import play.api.libs.functional.syntax._ import com.teambytes.hipchat.sns.bridge.v1.models.json._ private[v1] implicit val jsonReadsUUID: play.api.libs.json.Reads[_root_.java.util.UUID] = __.read[String].map { str => _root_.java.util.UUID.fromString(str) } private[v1] implicit val jsonWritesUUID: play.api.libs.json.Writes[_root_.java.util.UUID] = (x: _root_.java.util.UUID) => play.api.libs.json.JsString(x.toString) private[v1] implicit val jsonReadsJodaDateTime: play.api.libs.json.Reads[_root_.org.joda.time.DateTime] = __.read[String].map { str => _root_.org.joda.time.format.ISODateTimeFormat.dateTimeParser.parseDateTime(str) } private[v1] implicit val jsonWritesJodaDateTime: play.api.libs.json.Writes[_root_.org.joda.time.DateTime] = (x: _root_.org.joda.time.DateTime) => { play.api.libs.json.JsString(_root_.org.joda.time.format.ISODateTimeFormat.dateTime.print(x)) } private[v1] implicit val jsonReadsJodaLocalDate: play.api.libs.json.Reads[_root_.org.joda.time.LocalDate] = __.read[String].map { str => _root_.org.joda.time.format.ISODateTimeFormat.dateTimeParser.parseLocalDate(str) } private[v1] implicit val jsonWritesJodaLocalDate: play.api.libs.json.Writes[_root_.org.joda.time.LocalDate] = (x: _root_.org.joda.time.LocalDate) => { play.api.libs.json.JsString(_root_.org.joda.time.format.ISODateTimeFormat.date.print(x)) } implicit val jsonReadsHipchatSnsBridgeHipchatScope: play.api.libs.json.Reads[com.teambytes.hipchat.sns.bridge.v1.models.HipchatScope] = new play.api.libs.json.Reads[com.teambytes.hipchat.sns.bridge.v1.models.HipchatScope] { def reads(js: play.api.libs.json.JsValue): play.api.libs.json.JsResult[com.teambytes.hipchat.sns.bridge.v1.models.HipchatScope] = { js match { case v: play.api.libs.json.JsString => play.api.libs.json.JsSuccess(com.teambytes.hipchat.sns.bridge.v1.models.HipchatScope(v.value)) case _ => { (js \ "value").validate[String] match { case play.api.libs.json.JsSuccess(v, _) => play.api.libs.json.JsSuccess(com.teambytes.hipchat.sns.bridge.v1.models.HipchatScope(v)) case _: play.api.libs.json.JsError => (js \ "hipchat_scope").validate[String] match { case play.api.libs.json.JsSuccess(v, _) => play.api.libs.json.JsSuccess(com.teambytes.hipchat.sns.bridge.v1.models.HipchatScope(v)) case err: play.api.libs.json.JsError => err } } } } } } def jsonWritesHipchatSnsBridgeHipchatScope(obj: com.teambytes.hipchat.sns.bridge.v1.models.HipchatScope) = { play.api.libs.json.JsString(obj.toString) } def jsObjectHipchatScope(obj: com.teambytes.hipchat.sns.bridge.v1.models.HipchatScope) = { play.api.libs.json.Json.obj("value" -> play.api.libs.json.JsString(obj.toString)) } implicit def jsonWritesHipchatSnsBridgeHipchatScope: play.api.libs.json.Writes[HipchatScope] = { (obj: com.teambytes.hipchat.sns.bridge.v1.models.HipchatScope) => { com.teambytes.hipchat.sns.bridge.v1.models.json.jsonWritesHipchatSnsBridgeHipchatScope(obj) } } implicit def jsonReadsHipchatSnsBridgeError: play.api.libs.json.Reads[com.teambytes.hipchat.sns.bridge.v1.models.Error] = { (__ \ "description").read[String].map { x => Error(description = x) } } def jsObjectError(obj: com.teambytes.hipchat.sns.bridge.v1.models.Error): play.api.libs.json.JsObject = { play.api.libs.json.Json.obj( "description" -> play.api.libs.json.JsString(obj.description) ) } implicit def jsonWritesHipchatSnsBridgeError: play.api.libs.json.Writes[Error] = { (obj: com.teambytes.hipchat.sns.bridge.v1.models.Error) => { com.teambytes.hipchat.sns.bridge.v1.models.json.jsObjectError(obj) } } implicit def jsonReadsHipchatSnsBridgeHipchatApiConsumer: play.api.libs.json.Reads[com.teambytes.hipchat.sns.bridge.v1.models.HipchatApiConsumer] = { for { scopes <- (__ \ "scopes").read[Seq[com.teambytes.hipchat.sns.bridge.v1.models.HipchatScope]] fromName <- (__ \ "fromName").readNullable[String] } yield HipchatApiConsumer(scopes, fromName) } def jsObjectHipchatApiConsumer(obj: com.teambytes.hipchat.sns.bridge.v1.models.HipchatApiConsumer): play.api.libs.json.JsObject = { play.api.libs.json.Json.obj( "scopes" -> play.api.libs.json.Json.toJson(obj.scopes) ) ++ (obj.fromName match { case None => play.api.libs.json.Json.obj() case Some(x) => play.api.libs.json.Json.obj("fromName" -> play.api.libs.json.JsString(x)) }) } implicit def jsonWritesHipchatSnsBridgeHipchatApiConsumer: play.api.libs.json.Writes[HipchatApiConsumer] = { (obj: com.teambytes.hipchat.sns.bridge.v1.models.HipchatApiConsumer) => { com.teambytes.hipchat.sns.bridge.v1.models.json.jsObjectHipchatApiConsumer(obj) } } implicit def jsonReadsHipchatSnsBridgeHipchatCapabilities: play.api.libs.json.Reads[com.teambytes.hipchat.sns.bridge.v1.models.HipchatCapabilities] = { for { configurable <- (__ \ "configurable").readNullable[com.teambytes.hipchat.sns.bridge.v1.models.HipchatConfigurationPage] hipchatApiConsumer <- (__ \ "hipchatApiConsumer").readNullable[com.teambytes.hipchat.sns.bridge.v1.models.HipchatApiConsumer] installable <- (__ \ "installable").readNullable[com.teambytes.hipchat.sns.bridge.v1.models.HipchatInstallable] oauth2Provider <- (__ \ "oauth2Provider").readNullable[com.teambytes.hipchat.sns.bridge.v1.models.HipchatOauth2Provider] } yield HipchatCapabilities(configurable, hipchatApiConsumer, installable, oauth2Provider) } def jsObjectHipchatCapabilities(obj: com.teambytes.hipchat.sns.bridge.v1.models.HipchatCapabilities): play.api.libs.json.JsObject = { (obj.configurable match { case None => play.api.libs.json.Json.obj() case Some(x) => play.api.libs.json.Json.obj("configurable" -> com.teambytes.hipchat.sns.bridge.v1.models.json.jsObjectHipchatConfigurationPage(x)) }) ++ (obj.hipchatApiConsumer match { case None => play.api.libs.json.Json.obj() case Some(x) => play.api.libs.json.Json.obj("hipchatApiConsumer" -> com.teambytes.hipchat.sns.bridge.v1.models.json.jsObjectHipchatApiConsumer(x)) }) ++ (obj.installable match { case None => play.api.libs.json.Json.obj() case Some(x) => play.api.libs.json.Json.obj("installable" -> com.teambytes.hipchat.sns.bridge.v1.models.json.jsObjectHipchatInstallable(x)) }) ++ (obj.oauth2Provider match { case None => play.api.libs.json.Json.obj() case Some(x) => play.api.libs.json.Json.obj("oauth2Provider" -> com.teambytes.hipchat.sns.bridge.v1.models.json.jsObjectHipchatOauth2Provider(x)) }) } implicit def jsonWritesHipchatSnsBridgeHipchatCapabilities: play.api.libs.json.Writes[HipchatCapabilities] = { (obj: com.teambytes.hipchat.sns.bridge.v1.models.HipchatCapabilities) => { com.teambytes.hipchat.sns.bridge.v1.models.json.jsObjectHipchatCapabilities(obj) } } implicit def jsonReadsHipchatSnsBridgeHipchatCapabilitiesDescriptor: play.api.libs.json.Reads[com.teambytes.hipchat.sns.bridge.v1.models.HipchatCapabilitiesDescriptor] = { for { name <- (__ \ "name").read[String] description <- (__ \ "description").read[String] key <- (__ \ "key").read[String] apiVersion <- (__ \ "apiVersion").readNullable[String] capabilities <- (__ \ "capabilities").readNullable[com.teambytes.hipchat.sns.bridge.v1.models.HipchatCapabilities] links <- (__ \ "links").read[com.teambytes.hipchat.sns.bridge.v1.models.HipchatLinks] vendor <- (__ \ "vendor").readNullable[com.teambytes.hipchat.sns.bridge.v1.models.HipchatVendor] } yield HipchatCapabilitiesDescriptor(name, description, key, apiVersion, capabilities, links, vendor) } def jsObjectHipchatCapabilitiesDescriptor(obj: com.teambytes.hipchat.sns.bridge.v1.models.HipchatCapabilitiesDescriptor): play.api.libs.json.JsObject = { play.api.libs.json.Json.obj( "name" -> play.api.libs.json.JsString(obj.name), "description" -> play.api.libs.json.JsString(obj.description), "key" -> play.api.libs.json.JsString(obj.key), "links" -> com.teambytes.hipchat.sns.bridge.v1.models.json.jsObjectHipchatLinks(obj.links) ) ++ (obj.apiVersion match { case None => play.api.libs.json.Json.obj() case Some(x) => play.api.libs.json.Json.obj("apiVersion" -> play.api.libs.json.JsString(x)) }) ++ (obj.capabilities match { case None => play.api.libs.json.Json.obj() case Some(x) => play.api.libs.json.Json.obj("capabilities" -> com.teambytes.hipchat.sns.bridge.v1.models.json.jsObjectHipchatCapabilities(x)) }) ++ (obj.vendor match { case None => play.api.libs.json.Json.obj() case Some(x) => play.api.libs.json.Json.obj("vendor" -> com.teambytes.hipchat.sns.bridge.v1.models.json.jsObjectHipchatVendor(x)) }) } implicit def jsonWritesHipchatSnsBridgeHipchatCapabilitiesDescriptor: play.api.libs.json.Writes[HipchatCapabilitiesDescriptor] = { (obj: com.teambytes.hipchat.sns.bridge.v1.models.HipchatCapabilitiesDescriptor) => { com.teambytes.hipchat.sns.bridge.v1.models.json.jsObjectHipchatCapabilitiesDescriptor(obj) } } implicit def jsonReadsHipchatSnsBridgeHipchatConfigurationPage: play.api.libs.json.Reads[com.teambytes.hipchat.sns.bridge.v1.models.HipchatConfigurationPage] = { for { allowAccessToRoomAdmins <- (__ \ "allowAccessToRoomAdmins").readNullable[String] url <- (__ \ "url").read[String] } yield HipchatConfigurationPage(allowAccessToRoomAdmins, url) } def jsObjectHipchatConfigurationPage(obj: com.teambytes.hipchat.sns.bridge.v1.models.HipchatConfigurationPage): play.api.libs.json.JsObject = { play.api.libs.json.Json.obj( "url" -> play.api.libs.json.JsString(obj.url) ) ++ (obj.allowAccessToRoomAdmins match { case None => play.api.libs.json.Json.obj() case Some(x) => play.api.libs.json.Json.obj("allowAccessToRoomAdmins" -> play.api.libs.json.JsString(x)) }) } implicit def jsonWritesHipchatSnsBridgeHipchatConfigurationPage: play.api.libs.json.Writes[HipchatConfigurationPage] = { (obj: com.teambytes.hipchat.sns.bridge.v1.models.HipchatConfigurationPage) => { com.teambytes.hipchat.sns.bridge.v1.models.json.jsObjectHipchatConfigurationPage(obj) } } implicit def jsonReadsHipchatSnsBridgeHipchatInstallData: play.api.libs.json.Reads[com.teambytes.hipchat.sns.bridge.v1.models.HipchatInstallData] = { for { capabilitiesUrl <- (__ \ "capabilitiesUrl").read[String] oauthId <- (__ \ "oauthId").read[String] oauthSecret <- (__ \ "oauthSecret").read[String] groupId <- (__ \ "groupId").read[Long] roomId <- (__ \ "roomId").readNullable[String] } yield HipchatInstallData(capabilitiesUrl, oauthId, oauthSecret, groupId, roomId) } def jsObjectHipchatInstallData(obj: com.teambytes.hipchat.sns.bridge.v1.models.HipchatInstallData): play.api.libs.json.JsObject = { play.api.libs.json.Json.obj( "capabilitiesUrl" -> play.api.libs.json.JsString(obj.capabilitiesUrl), "oauthId" -> play.api.libs.json.JsString(obj.oauthId), "oauthSecret" -> play.api.libs.json.JsString(obj.oauthSecret), "groupId" -> play.api.libs.json.JsNumber(obj.groupId) ) ++ (obj.roomId match { case None => play.api.libs.json.Json.obj() case Some(x) => play.api.libs.json.Json.obj("roomId" -> play.api.libs.json.JsString(x)) }) } implicit def jsonWritesHipchatSnsBridgeHipchatInstallData: play.api.libs.json.Writes[HipchatInstallData] = { (obj: com.teambytes.hipchat.sns.bridge.v1.models.HipchatInstallData) => { com.teambytes.hipchat.sns.bridge.v1.models.json.jsObjectHipchatInstallData(obj) } } implicit def jsonReadsHipchatSnsBridgeHipchatInstallable: play.api.libs.json.Reads[com.teambytes.hipchat.sns.bridge.v1.models.HipchatInstallable] = { for { callbackUrl <- (__ \ "callbackUrl").readNullable[String] installedUrl <- (__ \ "installedUrl").readNullable[String] allowGlobal <- (__ \ "allowGlobal").readNullable[Boolean] allowRoom <- (__ \ "allowRoom").readNullable[Boolean] } yield HipchatInstallable(callbackUrl, installedUrl, allowGlobal, allowRoom) } def jsObjectHipchatInstallable(obj: com.teambytes.hipchat.sns.bridge.v1.models.HipchatInstallable): play.api.libs.json.JsObject = { (obj.callbackUrl match { case None => play.api.libs.json.Json.obj() case Some(x) => play.api.libs.json.Json.obj("callbackUrl" -> play.api.libs.json.JsString(x)) }) ++ (obj.installedUrl match { case None => play.api.libs.json.Json.obj() case Some(x) => play.api.libs.json.Json.obj("installedUrl" -> play.api.libs.json.JsString(x)) }) ++ (obj.allowGlobal match { case None => play.api.libs.json.Json.obj() case Some(x) => play.api.libs.json.Json.obj("allowGlobal" -> play.api.libs.json.JsBoolean(x)) }) ++ (obj.allowRoom match { case None => play.api.libs.json.Json.obj() case Some(x) => play.api.libs.json.Json.obj("allowRoom" -> play.api.libs.json.JsBoolean(x)) }) } implicit def jsonWritesHipchatSnsBridgeHipchatInstallable: play.api.libs.json.Writes[HipchatInstallable] = { (obj: com.teambytes.hipchat.sns.bridge.v1.models.HipchatInstallable) => { com.teambytes.hipchat.sns.bridge.v1.models.json.jsObjectHipchatInstallable(obj) } } implicit def jsonReadsHipchatSnsBridgeHipchatLinks: play.api.libs.json.Reads[com.teambytes.hipchat.sns.bridge.v1.models.HipchatLinks] = { for { homepage <- (__ \ "homepage").readNullable[String] api <- (__ \ "api").readNullable[String] self <- (__ \ "self").read[String] } yield HipchatLinks(homepage, api, self) } def jsObjectHipchatLinks(obj: com.teambytes.hipchat.sns.bridge.v1.models.HipchatLinks): play.api.libs.json.JsObject = { play.api.libs.json.Json.obj( "self" -> play.api.libs.json.JsString(obj.self) ) ++ (obj.homepage match { case None => play.api.libs.json.Json.obj() case Some(x) => play.api.libs.json.Json.obj("homepage" -> play.api.libs.json.JsString(x)) }) ++ (obj.api match { case None => play.api.libs.json.Json.obj() case Some(x) => play.api.libs.json.Json.obj("api" -> play.api.libs.json.JsString(x)) }) } implicit def jsonWritesHipchatSnsBridgeHipchatLinks: play.api.libs.json.Writes[HipchatLinks] = { (obj: com.teambytes.hipchat.sns.bridge.v1.models.HipchatLinks) => { com.teambytes.hipchat.sns.bridge.v1.models.json.jsObjectHipchatLinks(obj) } } implicit def jsonReadsHipchatSnsBridgeHipchatOauth2Provider: play.api.libs.json.Reads[com.teambytes.hipchat.sns.bridge.v1.models.HipchatOauth2Provider] = { for { tokenUrl <- (__ \ "tokenUrl").readNullable[String] authorizationUrl <- (__ \ "authorizationUrl").readNullable[String] } yield HipchatOauth2Provider(tokenUrl, authorizationUrl) } def jsObjectHipchatOauth2Provider(obj: com.teambytes.hipchat.sns.bridge.v1.models.HipchatOauth2Provider): play.api.libs.json.JsObject = { (obj.tokenUrl match { case None => play.api.libs.json.Json.obj() case Some(x) => play.api.libs.json.Json.obj("tokenUrl" -> play.api.libs.json.JsString(x)) }) ++ (obj.authorizationUrl match { case None => play.api.libs.json.Json.obj() case Some(x) => play.api.libs.json.Json.obj("authorizationUrl" -> play.api.libs.json.JsString(x)) }) } implicit def jsonWritesHipchatSnsBridgeHipchatOauth2Provider: play.api.libs.json.Writes[HipchatOauth2Provider] = { (obj: com.teambytes.hipchat.sns.bridge.v1.models.HipchatOauth2Provider) => { com.teambytes.hipchat.sns.bridge.v1.models.json.jsObjectHipchatOauth2Provider(obj) } } implicit def jsonReadsHipchatSnsBridgeHipchatVendor: play.api.libs.json.Reads[com.teambytes.hipchat.sns.bridge.v1.models.HipchatVendor] = { for { name <- (__ \ "name").read[String] url <- (__ \ "url").read[String] } yield HipchatVendor(name, url) } def jsObjectHipchatVendor(obj: com.teambytes.hipchat.sns.bridge.v1.models.HipchatVendor): play.api.libs.json.JsObject = { play.api.libs.json.Json.obj( "name" -> play.api.libs.json.JsString(obj.name), "url" -> play.api.libs.json.JsString(obj.url) ) } implicit def jsonWritesHipchatSnsBridgeHipchatVendor: play.api.libs.json.Writes[HipchatVendor] = { (obj: com.teambytes.hipchat.sns.bridge.v1.models.HipchatVendor) => { com.teambytes.hipchat.sns.bridge.v1.models.json.jsObjectHipchatVendor(obj) } } implicit def jsonReadsHipchatSnsBridgeServiceInfo: play.api.libs.json.Reads[com.teambytes.hipchat.sns.bridge.v1.models.ServiceInfo] = { for { name <- (__ \ "name").read[String] version <- (__ \ "version").read[String] scalaVersion <- (__ \ "scala_version").read[String] sbtVersion <- (__ \ "sbt_version").read[String] buildTime <- (__ \ "build_time").read[_root_.org.joda.time.DateTime] } yield ServiceInfo(name, version, scalaVersion, sbtVersion, buildTime) } def jsObjectServiceInfo(obj: com.teambytes.hipchat.sns.bridge.v1.models.ServiceInfo): play.api.libs.json.JsObject = { play.api.libs.json.Json.obj( "name" -> play.api.libs.json.JsString(obj.name), "version" -> play.api.libs.json.JsString(obj.version), "scala_version" -> play.api.libs.json.JsString(obj.scalaVersion), "sbt_version" -> play.api.libs.json.JsString(obj.sbtVersion), "build_time" -> play.api.libs.json.JsString(_root_.org.joda.time.format.ISODateTimeFormat.dateTime.print(obj.buildTime)) ) } implicit def jsonWritesHipchatSnsBridgeServiceInfo: play.api.libs.json.Writes[ServiceInfo] = { (obj: com.teambytes.hipchat.sns.bridge.v1.models.ServiceInfo) => { com.teambytes.hipchat.sns.bridge.v1.models.json.jsObjectServiceInfo(obj) } } implicit def jsonReadsHipchatSnsBridgeSnsNotification: play.api.libs.json.Reads[com.teambytes.hipchat.sns.bridge.v1.models.SnsNotification] = { for { `type` <- (__ \ "Type").read[String] messageId <- (__ \ "MessageId").read[String] topicArn <- (__ \ "TopicArn").read[String] message <- (__ \ "Message").read[String] timestamp <- (__ \ "Timestamp").read[String] signatureVersion <- (__ \ "SignatureVersion").read[String] signature <- (__ \ "Signature").read[String] signingCertURL <- (__ \ "SigningCertURL").read[String] token <- (__ \ "Token").readNullable[String] subject <- (__ \ "Subject").readNullable[String] subscribeURL <- (__ \ "SubscribeURL").readNullable[String] unsubscribeURL <- (__ \ "UnsubscribeURL").readNullable[String] } yield SnsNotification(`type`, messageId, topicArn, message, timestamp, signatureVersion, signature, signingCertURL, token, subject, subscribeURL, unsubscribeURL) } def jsObjectSnsNotification(obj: com.teambytes.hipchat.sns.bridge.v1.models.SnsNotification): play.api.libs.json.JsObject = { play.api.libs.json.Json.obj( "Type" -> play.api.libs.json.JsString(obj.`type`), "MessageId" -> play.api.libs.json.JsString(obj.messageId), "TopicArn" -> play.api.libs.json.JsString(obj.topicArn), "Message" -> play.api.libs.json.JsString(obj.message), "Timestamp" -> play.api.libs.json.JsString(obj.timestamp), "SignatureVersion" -> play.api.libs.json.JsString(obj.signatureVersion), "Signature" -> play.api.libs.json.JsString(obj.signature), "SigningCertURL" -> play.api.libs.json.JsString(obj.signingCertURL) ) ++ (obj.token match { case None => play.api.libs.json.Json.obj() case Some(x) => play.api.libs.json.Json.obj("Token" -> play.api.libs.json.JsString(x)) }) ++ (obj.subject match { case None => play.api.libs.json.Json.obj() case Some(x) => play.api.libs.json.Json.obj("Subject" -> play.api.libs.json.JsString(x)) }) ++ (obj.subscribeURL match { case None => play.api.libs.json.Json.obj() case Some(x) => play.api.libs.json.Json.obj("SubscribeURL" -> play.api.libs.json.JsString(x)) }) ++ (obj.unsubscribeURL match { case None => play.api.libs.json.Json.obj() case Some(x) => play.api.libs.json.Json.obj("UnsubscribeURL" -> play.api.libs.json.JsString(x)) }) } implicit def jsonWritesHipchatSnsBridgeSnsNotification: play.api.libs.json.Writes[SnsNotification] = { (obj: com.teambytes.hipchat.sns.bridge.v1.models.SnsNotification) => { com.teambytes.hipchat.sns.bridge.v1.models.json.jsObjectSnsNotification(obj) } } } } package com.teambytes.hipchat.sns.bridge.v1 { import com.ning.http.client.{AsyncCompletionHandler, AsyncHttpClient, Realm, Request, RequestBuilder, Response, AsyncHttpClientConfig} object Constants { val BaseUrl = "http://hipchat-sns-bridge.common.giltaws.com" val Namespace = "com.teambytes.hipchat.sns.bridge.v1" val UserAgent = "apibuilder app.apibuilder.io/teambytes/hipchat-sns-bridge/1.0.0/ning_1_9_client" val Version = "1.0.0" val VersionMajor = 1 } class Client( val baseUrl: String = "http://hipchat-sns-bridge.common.giltaws.com", auth: scala.Option[com.teambytes.hipchat.sns.bridge.v1.Authorization] = None, defaultHeaders: Seq[(String, String)] = Nil, asyncHttpClient: AsyncHttpClient = Client.defaultAsyncHttpClient ) extends interfaces.Client { import org.slf4j.{Logger, LoggerFactory} import com.teambytes.hipchat.sns.bridge.v1.models.json._ def closeAsyncHttpClient(): Unit = { asyncHttpClient.close() } val logger = LoggerFactory.getLogger(getClass) def hipchatCapabilitiesDescriptors: HipchatCapabilitiesDescriptors = HipchatCapabilitiesDescriptors def hipchatInstallData: HipchatInstallData = HipchatInstallData def serviceInfo: ServiceInfo = ServiceInfo def snsNotifications: SnsNotifications = SnsNotifications object HipchatCapabilitiesDescriptors extends HipchatCapabilitiesDescriptors { override def get( redirectToHipchatInstall: Boolean = false, requestHeaders: Seq[(String, String)] = Nil )(implicit ec: scala.concurrent.ExecutionContext): scala.concurrent.Future[com.teambytes.hipchat.sns.bridge.v1.models.HipchatCapabilitiesDescriptor] = { val queryParameters = Seq( Some("redirect_to_hipchat_install" -> redirectToHipchatInstall.toString) ).flatten _executeRequest("GET", s"/hipchat/capabilities", queryParameters = queryParameters, requestHeaders = requestHeaders).map { case r if r.getStatusCode == 200 => _root_.com.teambytes.hipchat.sns.bridge.v1.Client.parseJson("com.teambytes.hipchat.sns.bridge.v1.models.HipchatCapabilitiesDescriptor", r, _.validate[com.teambytes.hipchat.sns.bridge.v1.models.HipchatCapabilitiesDescriptor]) case r => throw com.teambytes.hipchat.sns.bridge.v1.errors.FailedRequest(r.getStatusCode, s"Unsupported response code[${r.getStatusCode}]. Expected: 200", requestUri = Some(r.getUri.toJavaNetURI)) } } } object HipchatInstallData extends HipchatInstallData { override def get( installableUrl: String, redirectUrl: String, requestHeaders: Seq[(String, String)] = Nil )(implicit ec: scala.concurrent.ExecutionContext): scala.concurrent.Future[com.teambytes.hipchat.sns.bridge.v1.models.HipchatCapabilitiesDescriptor] = { val queryParameters = Seq( Some("installable_url" -> installableUrl), Some("redirect_url" -> redirectUrl) ).flatten _executeRequest("GET", s"/hipchat/installable", queryParameters = queryParameters, requestHeaders = requestHeaders).map { case r if r.getStatusCode == 200 => _root_.com.teambytes.hipchat.sns.bridge.v1.Client.parseJson("com.teambytes.hipchat.sns.bridge.v1.models.HipchatCapabilitiesDescriptor", r, _.validate[com.teambytes.hipchat.sns.bridge.v1.models.HipchatCapabilitiesDescriptor]) case r => throw com.teambytes.hipchat.sns.bridge.v1.errors.FailedRequest(r.getStatusCode, s"Unsupported response code[${r.getStatusCode}]. Expected: 200", requestUri = Some(r.getUri.toJavaNetURI)) } } override def post( hipchatInstallData: com.teambytes.hipchat.sns.bridge.v1.models.HipchatInstallData, requestHeaders: Seq[(String, String)] = Nil )(implicit ec: scala.concurrent.ExecutionContext): scala.concurrent.Future[Unit] = { val payload = play.api.libs.json.Json.toJson(hipchatInstallData) _executeRequest("POST", s"/hipchat/installable", body = Some(payload), requestHeaders = requestHeaders).map { case r if r.getStatusCode == 200 => () case r => throw com.teambytes.hipchat.sns.bridge.v1.errors.FailedRequest(r.getStatusCode, s"Unsupported response code[${r.getStatusCode}]. Expected: 200", requestUri = Some(r.getUri.toJavaNetURI)) } } override def deleteByOauthId( oauthId: String, requestHeaders: Seq[(String, String)] = Nil )(implicit ec: scala.concurrent.ExecutionContext): scala.concurrent.Future[Unit] = { _executeRequest("DELETE", s"/hipchat/installable/${_root_.com.teambytes.hipchat.sns.bridge.v1.PathSegment.encode(oauthId, "UTF-8")}", requestHeaders = requestHeaders).map { case r if r.getStatusCode == 200 => () case r => throw com.teambytes.hipchat.sns.bridge.v1.errors.FailedRequest(r.getStatusCode, s"Unsupported response code[${r.getStatusCode}]. Expected: 200", requestUri = Some(r.getUri.toJavaNetURI)) } } } object ServiceInfo extends ServiceInfo { override def get( requestHeaders: Seq[(String, String)] = Nil )(implicit ec: scala.concurrent.ExecutionContext): scala.concurrent.Future[com.teambytes.hipchat.sns.bridge.v1.models.ServiceInfo] = { _executeRequest("GET", s"/info", requestHeaders = requestHeaders).map { case r if r.getStatusCode == 200 => _root_.com.teambytes.hipchat.sns.bridge.v1.Client.parseJson("com.teambytes.hipchat.sns.bridge.v1.models.ServiceInfo", r, _.validate[com.teambytes.hipchat.sns.bridge.v1.models.ServiceInfo]) case r => throw com.teambytes.hipchat.sns.bridge.v1.errors.FailedRequest(r.getStatusCode, s"Unsupported response code[${r.getStatusCode}]. Expected: 200", requestUri = Some(r.getUri.toJavaNetURI)) } } } object SnsNotifications extends SnsNotifications { override def post( roomId: String, snsNotification: com.teambytes.hipchat.sns.bridge.v1.models.SnsNotification, requestHeaders: Seq[(String, String)] = Nil )(implicit ec: scala.concurrent.ExecutionContext): scala.concurrent.Future[String] = { val payload = play.api.libs.json.Json.toJson(snsNotification) _executeRequest("POST", s"/hipchat/room/${_root_.com.teambytes.hipchat.sns.bridge.v1.PathSegment.encode(roomId, "UTF-8")}/notification", body = Some(payload), requestHeaders = requestHeaders).map { case r if r.getStatusCode == 200 => _root_.com.teambytes.hipchat.sns.bridge.v1.Client.parseJson("String", r, _.validate[String]) case r => throw com.teambytes.hipchat.sns.bridge.v1.errors.FailedRequest(r.getStatusCode, s"Unsupported response code[${r.getStatusCode}]. Expected: 200", requestUri = Some(r.getUri.toJavaNetURI)) } } } def _logRequest(request: Request): Unit = { if (logger.isInfoEnabled) { logger.info("_logRequest: " + request) } } def _logResponse(response: Response): Unit = { if (logger.isInfoEnabled) { logger.info("_logResponse: status=" + response.getStatusCode + ", responseBody: " + response.getResponseBody("UTF-8")) } } def _requestBuilder(method: String, path: String, requestHeaders: Seq[(String, String)]): RequestBuilder = { val builder = new RequestBuilder(method) .setUrl(baseUrl + path) .addHeader("User-Agent", Constants.UserAgent) .addHeader("X-Apidoc-Version", Constants.Version) .addHeader("X-Apidoc-Version-Major", Constants.VersionMajor.toString) defaultHeaders.foreach { h => builder.addHeader(h._1, h._2) } requestHeaders.foreach { h => builder.addHeader(h._1, h._2) } auth.fold(builder) { case Authorization.Basic(username, passwordOpt) => { builder.setRealm( new Realm.RealmBuilder() .setPrincipal(username) .setPassword(passwordOpt.getOrElse("")) .setUsePreemptiveAuth(true) .setScheme(Realm.AuthScheme.BASIC) .build() ) } case a => sys.error("Invalid authorization scheme[" + a.getClass + "]") } } def _executeRequest( method: String, path: String, queryParameters: Seq[(String, String)] = Nil, requestHeaders: Seq[(String, String)] = Nil, body: Option[play.api.libs.json.JsValue] = None )(implicit ec: scala.concurrent.ExecutionContext): scala.concurrent.Future[com.ning.http.client.Response] = { val allHeaders = body match { case None => requestHeaders case Some(_) => _withJsonContentType(requestHeaders) } val request = _requestBuilder(method, path, allHeaders) queryParameters.foreach { pair => request.addQueryParam(pair._1, pair._2) } val requestWithParamsAndBody = body.fold(request) { b => val serialized = play.api.libs.json.Json.stringify(b) request.setBody(serialized) } val finalRequest = requestWithParamsAndBody.build() _logRequest(finalRequest) val result = scala.concurrent.Promise[com.ning.http.client.Response]() asyncHttpClient.executeRequest(finalRequest, new AsyncCompletionHandler[Unit]() { override def onCompleted(r: com.ning.http.client.Response) = { _logResponse(r) result.success(r) } override def onThrowable(t: Throwable) = result.failure(t) } ) result.future } /** * Adds a Content-Type: application/json header unless the specified requestHeaders * already contain a Content-Type header */ def _withJsonContentType(headers: Seq[(String, String)]): Seq[(String, String)] = { headers.find { _._1.toUpperCase == "CONTENT-TYPE" } match { case None => headers ++ Seq(("Content-Type" -> "application/json; charset=UTF-8")) case Some(_) => headers } } } object Client { private lazy val defaultAsyncHttpClient = { new AsyncHttpClient( new AsyncHttpClientConfig.Builder() .setExecutorService(java.util.concurrent.Executors.newCachedThreadPool()) .build() ) } def parseJson[T]( className: String, r: _root_.com.ning.http.client.Response, f: (play.api.libs.json.JsValue => play.api.libs.json.JsResult[T]) ): T = { f(play.api.libs.json.Json.parse(r.getResponseBody("UTF-8"))) match { case play.api.libs.json.JsSuccess(x, _) => x case play.api.libs.json.JsError(errors) => { throw com.teambytes.hipchat.sns.bridge.v1.errors.FailedRequest(r.getStatusCode, s"Invalid json for class[" + className + "]: " + errors.mkString(" "), requestUri = Some(r.getUri.toJavaNetURI)) } } } } sealed trait Authorization extends _root_.scala.Product with _root_.scala.Serializable object Authorization { final case class Basic(username: String, password: Option[String] = None) extends Authorization } package interfaces { trait Client { def baseUrl: String def hipchatCapabilitiesDescriptors: com.teambytes.hipchat.sns.bridge.v1.HipchatCapabilitiesDescriptors def hipchatInstallData: com.teambytes.hipchat.sns.bridge.v1.HipchatInstallData def serviceInfo: com.teambytes.hipchat.sns.bridge.v1.ServiceInfo def snsNotifications: com.teambytes.hipchat.sns.bridge.v1.SnsNotifications } } trait HipchatCapabilitiesDescriptors { /** * @param redirectToHipchatInstall Whether to redirect to Hipchat install with Base64 encoded data. */ def get( redirectToHipchatInstall: Boolean = false, requestHeaders: Seq[(String, String)] = Nil )(implicit ec: scala.concurrent.ExecutionContext): scala.concurrent.Future[com.teambytes.hipchat.sns.bridge.v1.models.HipchatCapabilitiesDescriptor] } trait HipchatInstallData { def get( installableUrl: String, redirectUrl: String, requestHeaders: Seq[(String, String)] = Nil )(implicit ec: scala.concurrent.ExecutionContext): scala.concurrent.Future[com.teambytes.hipchat.sns.bridge.v1.models.HipchatCapabilitiesDescriptor] def post( hipchatInstallData: com.teambytes.hipchat.sns.bridge.v1.models.HipchatInstallData, requestHeaders: Seq[(String, String)] = Nil )(implicit ec: scala.concurrent.ExecutionContext): scala.concurrent.Future[Unit] def deleteByOauthId( oauthId: String, requestHeaders: Seq[(String, String)] = Nil )(implicit ec: scala.concurrent.ExecutionContext): scala.concurrent.Future[Unit] } trait ServiceInfo { def get( requestHeaders: Seq[(String, String)] = Nil )(implicit ec: scala.concurrent.ExecutionContext): scala.concurrent.Future[com.teambytes.hipchat.sns.bridge.v1.models.ServiceInfo] } trait SnsNotifications { def post( roomId: String, snsNotification: com.teambytes.hipchat.sns.bridge.v1.models.SnsNotification, requestHeaders: Seq[(String, String)] = Nil )(implicit ec: scala.concurrent.ExecutionContext): scala.concurrent.Future[String] } package errors { final case class FailedRequest(responseCode: Int, message: String, requestUri: Option[_root_.java.net.URI] = None) extends _root_.java.lang.Exception(s"HTTP $responseCode: $message") } object PathSegment { // See https://github.com/playframework/playframework/blob/2.3.x/framework/src/play/src/main/scala/play/utils/UriEncoding.scala def encode(s: String, inputCharset: String): String = { val in = s.getBytes(inputCharset) val out = new java.io.ByteArrayOutputStream() for (b <- in) { val allowed = segmentChars.get(b & 0xFF) if (allowed) { out.write(b) } else { out.write('%') out.write(upperHex((b >> 4) & 0xF)) out.write(upperHex(b & 0xF)) } } out.toString("US-ASCII") } private def upperHex(x: Int): Int = { // Assume 0 <= x < 16 if (x < 10) (x + '0') else (x - 10 + 'A') } private val segmentChars: java.util.BitSet = membershipTable(pchar) private def pchar: Seq[Char] = { val alphaDigit = for ((min, max) <- Seq(('a', 'z'), ('A', 'Z'), ('0', '9')); c <- min to max) yield c val unreserved = alphaDigit ++ Seq('-', '.', '_', '~') val subDelims = Seq('!', '$', '&', '\'', '(', ')', '*', '+', ',', ';', '=') unreserved ++ subDelims ++ Seq(':', '@') } private def membershipTable(chars: Seq[Char]): java.util.BitSet = { val bits = new java.util.BitSet(256) for (c <- chars) { bits.set(c.toInt) } bits } } }