1 /*
2  *  Make.org Core API
3  *  Copyright (C) 2018 Make.org
4  *
5  * This program is free software: you can redistribute it and/or modify
6  *  it under the terms of the GNU Affero General Public License as
7  *  published by the Free Software Foundation, either version 3 of the
8  *  License, or (at your option) any later version.
9  *
10  *  This program is distributed in the hope that it will be useful,
11  *  but WITHOUT ANY WARRANTY; without even the implied warranty of
12  *  MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
13  *  GNU Affero General Public License for more details.
14  *
15  *  You should have received a copy of the GNU Affero General Public License
16  *  along with this program.  If not, see <https://www.gnu.org/licenses/>.
17  *
18  */
19 
20 package org.make.api.user.social
21 
22 import java.nio.charset.Charset
23 
24 import akka.http.scaladsl.model._
25 import akka.http.scaladsl.{Http, HttpExt}
26 import grizzled.slf4j.Logging
27 import io.circe.parser._
28 import org.make.api.technical.ActorSystemComponent
29 import org.make.api.user.social.models.facebook.{UserInfo => FacebookUserInfo}
30 import org.make.core.{ValidationError, ValidationFailedError}
31 
32 import scala.concurrent.ExecutionContext.Implicits.global
33 import scala.concurrent.Future
34 import scala.concurrent.duration.DurationInt
35 
36 trait FacebookApiComponent {
37   def facebookApi: FacebookApi
38 }
39 
40 trait FacebookApi {
41   def getUserInfo(accessToken: String): Future[FacebookUserInfo]
42 }
43 
44 trait DefaultFacebookApiComponent extends FacebookApiComponent {
45   self: ActorSystemComponent =>
46 
47   override lazy val facebookApi: FacebookApi = new DefaultFacebookApi
48 
49   class DefaultFacebookApi extends FacebookApi with Logging {
50     private val http: HttpExt = Http()
51 
52     def getUserInfo(accessToken: String): Future[FacebookUserInfo] = {
53       val url =
54         s"https://graph.facebook.com/v12.0/me?access_token=$accessToken&fields=email,first_name"
55 
56       http
57         .singleRequest(HttpRequest(method = HttpMethods.GET, uri = url))
58         .flatMap(strictToString(_))
59         .flatMap { entity =>
60           parse(entity).flatMap(_.as[FacebookUserInfo]) match {
61             case Right(userInfo) if userInfo.email.isEmpty =>
62               Future.failed(ValidationFailedError(Seq(ValidationError("email", "mandatory", Some("not valid")))))
63             case Right(userInfo) => Future.successful(userInfo)
64             case Left(e)         => Future.failed(e)
65           }
66         }
67     }
68 
69     private def strictToString(response: HttpResponse, expectedCode: StatusCode = StatusCodes.OK): Future[String] = {
70       logger.debug(s"Server answered $response")
71       response match {
72         case HttpResponse(`expectedCode`, _, entity, _) =>
73           val result = entity
74             .toStrict(2.second)
75             .map(_.data.decodeString(Charset.forName("UTF-8")))
76           result
77         case HttpResponse(code, _, entity, _) =>
78           entity.toStrict(2.second).flatMap { entity =>
79             val response = entity.data.decodeString(Charset.forName("UTF-8"))
80             Future.failed(SocialProviderException(s"Got unexpected response code: $code, with body: $response"))
81           }
82       }
83     }
84 
85   }
86 }