Андрей Смирдин, Лиза Василенко. HTTP прокси

HttpProxy/build.gradle

@@ -0,0 +1,21 @@
+plugins {
+    id 'org.jetbrains.kotlin.jvm' version '1.3.21'
+}
+
+group 'http-proxy'
+version '1.0-SNAPSHOT'
+
+repositories {
+    mavenCentral()
+}
+
+dependencies {
+    implementation "org.jetbrains.kotlin:kotlin-stdlib-jdk8"
+}
+
+compileKotlin {
+    kotlinOptions.jvmTarget = "1.8"
+}
+compileTestKotlin {
+    kotlinOptions.jvmTarget = "1.8"
+}

HttpProxy/gradle.properties

@@ -0,0 +1 @@
+kotlin.code.style=official

HttpProxy/settings.gradle

@@ -0,0 +1,2 @@
+rootProject.name = 'http-proxy'
+

HttpProxy/src/main/kotlin/ru/hse/Acceptor.kt

@@ -0,0 +1,42 @@
+package ru.hse
+
+import java.net.ServerSocket
+import java.util.logging.Logger
+import kotlin.concurrent.thread
+
+class Acceptor(val port: Int, clientHandler: ClientHandler) {
+
+    private val listener: Thread
+    private val workers: MutableList<Thread> = ArrayList()
+
+    init {
+        listener = thread(start = false, name = "Acceptor") {
+            try {
+                val serverSocket = ServerSocket(port)
+                serverSocket.use {
+                while (!Thread.currentThread().isInterrupted) {
+                        val socket = it.accept()
+                        workers.add(clientHandler.run(socket))
+                    }
+                }
+            } catch (e: Exception) {
+                logger.severe("Closing client acceptor: ${e.message}")
+                e.printStackTrace()
+            }
+        }
+    }
+
+    fun start() {
+        listener.start()
+        logger.info("Proxy started on port $port")
+    }
+
+    fun stop() {
+        listener.interrupt()
+        workers.forEach(Thread::interrupt)
+    }
+
+    companion object {
+        val logger: Logger = Logger.getLogger(Acceptor::class.java.name)
+    }
+}

HttpProxy/src/main/kotlin/ru/hse/Cache.kt

@@ -0,0 +1,21 @@
+package ru.hse
+
+interface Cache<K, V> {
+    fun lookUp(request: K): V?
+    fun addPage(request: K, response: V, expiration: Long = 0)
+
+    companion object {
+        fun canBeCached(headers: List<String>): Boolean {
+            val cachePolicy = headers.find { it.contains("Cache-Control") }?.split(' ')?.get(2) ?: return true
+            return !cachePolicy.contains("no-cache") && !cachePolicy.contains("no-store")
+        }
+
+        fun getExpirationTime(headers: List<String>): Long {
+            val expiration = headers.find { it.contains("Cache-Control") }?.split(' ')?.get(2) ?: return 0
+            if (expiration.contains("max-age="))
+                return expiration.split('=')[2].toLong()
+            return 0
+        }
+    }
+
+}