Skip to content

Instantly share code, notes, and snippets.

View solverit's full-sized avatar

Andrey Mikheev solverit

16 followers · 39 following
View GitHub Profile
@solverit
solverit / Context.scala
Created August 29, 2018 19:45 — forked from notxcain/Context.scala
import cats.implicits._
import cats.{ Applicative, Monad }
// Операции над контекстом
trait ContextWriter[F[_]] {
def put(key: String, value: String): F[Unit]
}
@solverit
solverit / TestModule.scala
Created March 14, 2018 12:49 — forked from Odomontois/TestModule.scala
package ru.tinkoff.tschema.examples
import java.util.{Locale, ResourceBundle}
import akka.actor.ActorSystem
import akka.stream.ActorMaterializer
import de.heikoseeberger.akkahttpcirce.FailFastCirceSupport._
import ru.tinkoff.tschema.FromQueryParam
import ru.tinkoff.tschema.akkaHttp.MkRoute
import ru.tinkoff.tschema.limits.LimitHandler.LimitRate
@solverit
solverit / collectFirst.scala
Created January 10, 2018 19:22 — forked from Odomontois/collectFirst.scala
package notes
import cats.data.{OptionT, Writer}
import cats.free.Free
import cats.instances.option._
import cats.instances.stream._
import cats.instances.vector._
import cats.syntax.applicative._
import cats.syntax.coflatMap._
import cats.syntax.either._
@solverit
solverit / DocumentRepositoryTest.scala
Created December 7, 2017 12:19
class DocumentRepositoryTest extends FunSuite with DbSpec {
val repository = new DocumentRepository(connection)
val newDoc = Document(Some(UUID.randomUUID()), LocalDateTime.now(), "1", "P", "R", BigDecimal(1.0))
override def beforeAll(): Unit =
Await.result(repository.createTables(), Duration.Inf)
test("Add new Document") {
@solverit
solverit / DBSupport.scala
Last active October 14, 2017 16:33
Scala Slick
import slick.driver.JdbcProfile
/**
* Base DB support component
*
* @author Solverit
*/
trait DBSupport {
val driver: JdbcProfile
@solverit
solverit / deploy
Last active June 12, 2016 13:11 — forked from JMBattista/install_gradle
Upgrade Gradle Codeship
#sftp -b deploy/production root@127.0.0.1
scp -rp ~/clone/* root@127.0.0.1:/opt/app/
ssh root@127.0.0.1 'sudo chmod +x /opt/app/bin/stop.sh'
ssh root@127.0.0.1 'sudo /opt/app/bin/stop.sh'
ssh root@127.0.0.1 'sudo /opt/app/bin/ags-starter'
@solverit
solverit / ImplicitSenderTest.scala
Last active September 11, 2015 22:38 — forked from mguillermin/ImplicitSenderTest.scala
Sample showing basic usage of Akka TestKit and TestActorRef
package sample.akka.testkit
import akka.actor.ActorSystem
import akka.actor.Actor
import akka.testkit.{TestKit, TestActorRef}
import org.scalatest.matchers.MustMatchers
import org.scalatest.WordSpec
class ImplicitSenderTest extends TestKit(ActorSystem("testSystem"))
// Using the ImplicitSender trait will automatically set `testActor` as the sender
@solverit
solverit / akka-io-tcp-echo-server-using-iteratee.scala
Last active September 9, 2015 13:41 — forked from masahitojp/akka-io-tcp-echo-server-using-iteratee.scala
akka-io-tcp-echo-server.scala
import akka.actor.IO._
import akka.actor.{Props, IO, IOManager, Actor, ActorSystem}
import akka.event.Logging
import akka.util.ByteString
import java.net.InetSocketAddress
class TCPEchoServer(port: Int) extends Actor {
val log = Logging(context.system, this)
val state = IterateeRef.Map.async[IO.Handle]()(context.dispatcher)
@solverit
solverit / Exp.scala
Created August 4, 2015 23:50
import scala.util.Try
import scala.util.Success
import scala.util.Failure
db.run(myAction.asTry).map {result =>
result match {
case Success(res) => DBResult(DBStatus.Success, res)
case Failure(e: MySQLIntegrityConstraintViolationException) => {
//code: 1062, status: 23000, e: Duplicate entry 'foo' for key 'name'
@solverit
solverit / tcp_server.rs
Last active August 29, 2015 14:23 — forked from seriyps/tcp_server.rs
#![feature(phase)]
#[phase(plugin, link)] extern crate log;
extern crate green;
extern crate rustuv;
use std::io;
use std::os;
use std::io::{Listener,Acceptor,TcpStream};
#[start]