socialnetworknews

commit e86ed87e8ffac1037c0af8eeb1f4ba3b62eb1035
parent cc315c70d27637ccb94050a86b98c0802a0be5b4
Author: MTRNord <mtrnord1@gmail.com>
Date:   Sun,  4 Feb 2018 13:05:45 +0100

Scalafmt config

Signed-off-by: MTRNord <mtrnord1@gmail.com>

Diffstat:
A
.scalafmt.conf
 | 
4
++++
M
src/main/scala/Main.scala
 | 
52
+++++++++++++++++++++++++++++++++++++++++-----------
M
src/main/scala/database/Database.scala
 | 
7
+++----
M
src/main/scala/twitterSender/Sender.scala
 | 
12
+++++++++---
M
src/main/scala/webServer/WebServer.scala
 | 
12
++++++++----

5 files changed, 65 insertions(+), 22 deletions(-)
diff --git a/.scalafmt.conf b/.scalafmt.conf
@@ -0,0 +1,3 @@
+style = IntelliJ
+project.git = true
+project.excludeFilters = ["target/"]
+\ No newline at end of file
diff --git a/src/main/scala/Main.scala b/src/main/scala/Main.scala
@@ -1,8 +1,15 @@
 import com.danielasfregola.twitter4s.entities.enums.AccessType
 import com.danielasfregola.twitter4s.entities.enums.AccessType.AccessType
 import com.danielasfregola.twitter4s.entities.{AccessToken, ConsumerToken}
-import com.danielasfregola.twitter4s.util.Configurations.{consumerTokenKey, consumerTokenSecret}
-import com.danielasfregola.twitter4s.{TwitterAuthenticationClient, TwitterRestClient, TwitterStreamingClient}
+import com.danielasfregola.twitter4s.util.Configurations.{
+  consumerTokenKey,
+  consumerTokenSecret
+}
+import com.danielasfregola.twitter4s.{
+  TwitterAuthenticationClient,
+  TwitterRestClient,
+  TwitterStreamingClient
+}
 
 import scala.concurrent.{Await, Future}
 import scala.concurrent.ExecutionContext.Implicits.global
@@ -11,31 +18,54 @@ import scala.util.{Failure, Success}
 
 object Main extends App {
 
-  val consumerToken = ConsumerToken(key = consumerTokenKey, secret = consumerTokenSecret)
+  val consumerToken =
+    ConsumerToken(key = consumerTokenKey, secret = consumerTokenSecret)
   val TwitterAuthClient = new TwitterAuthenticationClient(consumerToken)
 
   val write_access: AccessType = AccessType.Write
 
-  val reqToken = TwitterAuthClient.requestToken(x_auth_access_type = Some(write_access))
+  val reqToken =
+    TwitterAuthClient.requestToken(x_auth_access_type = Some(write_access))
 
   reqToken onComplete {
     case Success(token) =>
-      println(TwitterAuthClient.authenticateUrl(token = token.token, force_login = false))
+      println(
+        TwitterAuthClient
+          .authenticateUrl(token = token.token, force_login = false)
+      )
 
       val pin = scala.io.StdIn.readLine("Insert Pin: ")
 
-      val AccessTokenResp = Await.result(TwitterAuthClient.accessToken(token.token, pin), 10 seconds)
+      val AccessTokenResp =
+        Await.result(
+          TwitterAuthClient.accessToken(token.token, pin),
+          10 seconds
+        )
 
-      val consumerToken = ConsumerToken(key = consumerTokenKey, secret = consumerTokenSecret)
-      val accessToken = AccessToken(key = AccessTokenResp.accessToken.key, secret = AccessTokenResp.accessToken.secret)
+      val consumerToken =
+        ConsumerToken(key = consumerTokenKey, secret = consumerTokenSecret)
+      val accessToken = AccessToken(
+        key = AccessTokenResp.accessToken.key,
+        secret = AccessTokenResp.accessToken.secret
+      )
 
-      val streamingClient = TwitterStreamingClient.apply(accessToken = accessToken, consumerToken = consumerToken)
-      val restClient = TwitterRestClient.apply(accessToken = accessToken, consumerToken = consumerToken)
+      val streamingClient =
+        TwitterStreamingClient.apply(
+          accessToken = accessToken,
+          consumerToken = consumerToken
+        )
+      val restClient = TwitterRestClient.apply(
+        accessToken = accessToken,
+        consumerToken = consumerToken
+      )
 
       val sender = new twitterSender.Sender(restClient = restClient)
       //sender.sendHelloWorld
 
-      val stream = new twitterCrawler.StreamingApi(streamingClient = streamingClient, restClient = restClient)
+      val stream = new twitterCrawler.StreamingApi(
+        streamingClient = streamingClient,
+        restClient = restClient
+      )
       stream.fetchTweets
 
       webServer.WebServer.main()
diff --git a/src/main/scala/database/Database.scala b/src/main/scala/database/Database.scala
@@ -5,7 +5,8 @@ import java.sql.Date
 import slick.jdbc.SQLiteProfile.api._
 
 // Definition of the TWEETS table
-class Tweets(tag: Tag) extends Table[(Int, String, String, String, String, Date)](tag, "TWEETS") {
+class Tweets(tag: Tag)
+    extends Table[(Int, String, String, String, String, Date)](tag, "TWEETS") {
   def id = column[Int]("ID", O.PrimaryKey) // This is the primary key column
   def user = column[String]("USERNAME")
   def text = column[String]("TEXT")
@@ -17,6 +18,4 @@ class Tweets(tag: Tag) extends Table[(Int, String, String, String, String, Date)
   def * = (id, user, text, url, interactions, indexingDate)
 }
 
-class Database {
-
-}
+class Database {}
diff --git a/src/main/scala/twitterSender/Sender.scala b/src/main/scala/twitterSender/Sender.scala
@@ -1,11 +1,17 @@
 package twitterSender
 
 import com.danielasfregola.twitter4s.TwitterRestClient
+import com.danielasfregola.twitter4s.entities.Tweet
 
 import scala.concurrent.Await
 
-class Sender (val restClient: TwitterRestClient) {
-  def sendHelloWorld = {
-    Await.result(restClient.createTweet(status = "Hello world vom Scalar Freifunk News Projekt!"), scala.concurrent.duration.Duration.Inf)
+class Sender(val restClient: TwitterRestClient) {
+  def sendHelloWorld: Tweet = {
+    Await.result(
+      restClient.createTweet(
+        status = "Hello world vom Scalar Freifunk News Projekt!"
+      ),
+      scala.concurrent.duration.Duration.Inf
+    )
   }
 }
diff --git a/src/main/scala/webServer/WebServer.scala b/src/main/scala/webServer/WebServer.scala
@@ -19,9 +19,12 @@ object WebServer {
 
     val requestHandler: HttpRequest => HttpResponse = {
       case HttpRequest(GET, Uri.Path("/"), _, _, _) =>
-        HttpResponse(entity = HttpEntity(
-          ContentTypes.`text/html(UTF-8)`,
-          "<html><body>Hello world!</body></html>"))
+        HttpResponse(
+          entity = HttpEntity(
+            ContentTypes.`text/html(UTF-8)`,
+            "<html><body>Hello world!</body></html>"
+          )
+        )
 
       case HttpRequest(GET, Uri.Path("/ping"), _, _, _) =>
         HttpResponse(entity = "PONG!")
@@ -34,7 +37,8 @@ object WebServer {
         HttpResponse(404, entity = "Unknown resource!")
     }
 
-    val bindingFuture = Http().bindAndHandleSync(requestHandler, "localhost", 8080)
+    val bindingFuture =
+      Http().bindAndHandleSync(requestHandler, "localhost", 8080)
 
     println(s"Server online at http://localhost:8080/\nPress RETURN to stop...")
     StdIn.readLine() // let it run until user presses return