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

import com.google.api.client.googleapis.auth.oauth2.GoogleCredential
import com.google.api.client.http.javanet.NetHttpTransport
import com.google.api.client.json.jackson2.JacksonFactory
import com.google.api.services.monitoring.v3.{Monitoring, MonitoringScopes}

object Googlemonitoringapiworks extends App {
  println("Hello, google-monitoring-api-works")

  val project = "your-project-name" // you should have one on google.
  val projectResource = "projects/" + project

  // Grab the Application Default Credentials from the environment.
  // Download authentication json form Google Cloud and Put conf.json into resources folder!
  val resourceAsStream = getClass.getResourceAsStream("/conf.json")
  println("ok")
  val credential = GoogleCredential.fromStream(resourceAsStream)
    .createScoped(MonitoringScopes.all())

  println(credential.getServiceAccountId) // this only works if you have a service account

  // Create and return the CloudMonitoring service object
  val httpTransport = new NetHttpTransport()
  val jsonFactory = new JacksonFactory()
  val service = new Monitoring.Builder(httpTransport,
    jsonFactory, credential)
    .setApplicationName("Monitoring Sample")
    .build()

  val res = service.projects().metricDescriptors().list(projectResource).execute()
  println(res.toPrettyString)
} 

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

import java.time.{Clock, ZoneId}

import akka.actor.{Actor, ActorRef, Props}
import com.google.api.client.googleapis.auth.oauth2.GoogleIdTokenVerifier
import com.google.api.client.http.javanet.NetHttpTransport
import com.google.api.client.json.jackson2.JacksonFactory
import com.google.api.client.util.store.AbstractDataStoreFactory
import com.google.inject.AbstractModule
import com.google.inject.name.Names
import com.google.inject.util.Providers
import controllers.AppController
import play.api.libs.concurrent.{Akka, AkkaGuiceSupport}
import services._
import services.support.SystemClock

import scala.reflect.ClassTag

class AppModule extends AbstractModule {
  def configure = {
    bind(classOf[AppController]).asEagerSingleton // in prod mode all dependencies of AppController get built at startup time
    bind(classOf[AbstractDataStoreFactory]).to(classOf[RepositoryDataStoreFactory])
    bind(classOf[GoogleIdTokenVerifier]).toInstance(new GoogleIdTokenVerifier.Builder(new NetHttpTransport, new JacksonFactory).build)
    bind(classOf[Clock]).toInstance(new SystemClock(ZoneId.systemDefault()))
  }
}

class AkkaModule extends AbstractModule with AkkaGuiceSupport {
  def configure = {
    bindActorNoEager[SuperSupervisorActor](SuperSupervisorActor.actorName)
    bindActorFactory[UserSupervisorActor, UserSupervisorActor.Factory]
  }

  private def bindActorNoEager[T <: Actor : ClassTag](name: String, props: Props => Props = identity): Unit = {
    binder.bind(classOf[ActorRef])
      .annotatedWith(Names.named(name))
      .toProvider(Providers.guicify(Akka.providerOf[T](name, props)))
  }
} 

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

import java.io.StringReader
import javax.inject.{Inject, Singleton}

import conf.AppConf
import com.google.api.client.auth.oauth2.Credential
import com.google.api.client.auth.openidconnect.IdTokenResponse
import com.google.api.client.googleapis.auth.oauth2.GoogleAuthorizationCodeFlow.Builder
import com.google.api.client.googleapis.auth.oauth2.{GoogleAuthorizationCodeFlow, GoogleAuthorizationCodeTokenRequest, GoogleClientSecrets, GoogleTokenResponse}
import com.google.api.client.http.javanet.NetHttpTransport
import com.google.api.client.json.jackson2.JacksonFactory
import com.google.api.client.util.store.AbstractDataStoreFactory
import com.google.api.services.gmail.Gmail
import com.google.api.services.gmail.GmailScopes._
import com.google.common.collect.Lists._
import common._

import scala.concurrent.{ExecutionContext, Future}

object GoogleAuthorization {
  val ApplicationName = "Connectus"
  val Scopes = newArrayList(GMAIL_COMPOSE, GMAIL_MODIFY)
  val transport = new NetHttpTransport
  val factory = new JacksonFactory
}

@Singleton
class GoogleAuthorization @Inject()(implicit exec: ExecutionContext, appConf: AppConf, dataStoreFactory: AbstractDataStoreFactory) {

  private def loadSecrets: GoogleClientSecrets =
    GoogleClientSecrets.load(GoogleAuthorization.factory, new StringReader(appConf.getGoogleClientSecret))

  private lazy val flow: GoogleAuthorizationCodeFlow = new Builder(GoogleAuthorization.transport, GoogleAuthorization.factory, loadSecrets, GoogleAuthorization.Scopes) //
    .setDataStoreFactory(dataStoreFactory)
    .setAccessType("offline") // So we can get a refresh and access the protected service while the user is gone
    .setApprovalPrompt("auto").build

  def addCredentials(userId: String, refreshToken: String) = {
    val tokenResponse: IdTokenResponse = new IdTokenResponse
    tokenResponse.setRefreshToken(refreshToken)
    flow.createAndStoreCredential(tokenResponse, userId)
  }

  def convert(authorisationCode: String): Future[GoogleTokenResponse] = {
    val request: GoogleAuthorizationCodeTokenRequest = flow.newTokenRequest(authorisationCode)
    // as specified in https://developers.google.com/identity/protocols/CrossClientAuth, the redirect_uri argument must be equal to null
    request.set("redirect_uri", null)
    Future {concurrent.blocking {request.execute()}}
  }

  def getService(accountId: String): Future[Gmail] =
    Future {concurrent.blocking {Option(flow.loadCredential(accountId))}}
      .flatMap(fromOption(_))
      .map(gmail(_))

  private def gmail(credential: Credential): Gmail =
    new Gmail.Builder(GoogleAuthorization.transport, GoogleAuthorization.factory, credential).setApplicationName(GoogleAuthorization.ApplicationName).build
} 

//设置package包名称以及导入依赖的类
package com.example.prodspark.client

import java.io.IOException

import com.example.prodspark.util.RetryUtil
import com.google.api.client.googleapis.auth.oauth2.GoogleCredential
import com.google.api.client.http.javanet.NetHttpTransport
import com.google.api.client.json.jackson2.JacksonFactory
import com.google.api.services.bigquery.{Bigquery, BigqueryScopes}
import com.google.api.services.bigquery.model._
import com.google.cloud.hadoop.io.bigquery.BigQueryStrings
import org.slf4j.LoggerFactory

import scala.collection.JavaConverters._

object BigQueryClient {
  private val SCOPES = List(BigqueryScopes.BIGQUERY).asJava

  private val bigquery: Bigquery = {
    val credential = GoogleCredential.getApplicationDefault.createScoped(SCOPES)
    new Bigquery.Builder(new NetHttpTransport, new JacksonFactory, credential)
      .setApplicationName("spark-bigquery")
      .build()
  }

  
  def streamingInsert(
    rows: Seq[TableDataInsertAllRequest.Rows],
    tableSpec: String,
    projectId: String
  ): Unit = {
    lazy val tableRef = BigQueryStrings.parseTableReference(tableSpec)

    val req = new TableDataInsertAllRequest()
      .setRows(rows.asJava)
      .setIgnoreUnknownValues(true)

    RetryUtil.retry(3) {
      val response = insertAll(tableRef, req)
      if (response.getInsertErrors != null) {
        log.error("Error inserting into BigQuery: " + response.getInsertErrors.toString)
        throw new IOException(response.getInsertErrors.toString)
      }
    }
  }

  private val log = LoggerFactory.getLogger(this.getClass)
} 

//设置package包名称以及导入依赖的类
package com.wix.pay.paymentexpress.it

import com.google.api.client.http.javanet.NetHttpTransport
import com.wix.pay.creditcard.{CreditCard, CreditCardOptionalFields, PublicCreditCardOptionalFields, YearMonth}
import com.wix.pay.model.{CurrencyAmount, Payment}
import com.wix.pay.paymentexpress.PaymentexpressGateway
import org.specs2.mutable.SpecWithJUnit
import org.specs2.specification.Scope

class RealPaymentExpressIT extends SpecWithJUnit {
  skipAll

  "Reat Payment Express" should {
    "create purchase" in new ctx {
      gateway.sale(credentials, creditCard, payment, None, None) must beSuccessfulTry
    }
  }

  trait ctx extends Scope {
    val credentials = """{"username":"******","password":"******"}"""

    val creditCard = CreditCard("4000000000000002", YearMonth(2025,2), Some(CreditCardOptionalFields(csc = Some("123"),
      Some(PublicCreditCardOptionalFields(holderId = Some("John Doe"), holderName = Some("John Doe"))))))
    val payment = Payment(CurrencyAmount("AUD", 202))
    val gateway = new PaymentexpressGateway(new NetHttpTransport().createRequestFactory())
  }
}