Skip to content

Instantly share code, notes, and snippets.

Avatar

Pau Carrió pauca

  • Barcelona, Spain
View GitHub Profile
@pauca
pauca / akkaQueueExample.scala
Created Mar 5, 2020
akkaQueueExample.scala
View akkaQueueExample.scala
import akka.actor._
import akka.actor.ActorLogging
import akka.actor.ActorSystem
import akka.stream._
import akka.stream.actor.ActorSubscriberMessage._
import akka.stream.actor._
import akka.stream.scaladsl._
import akka.{ NotUsed, Done }
import scala.io.Source
@pauca
pauca / fileToMd5.scala
Created Jun 14, 2019
get md5sum from path with scala
View fileToMd5.scala
//inspired by http://www.michaelpollmeier.com/2018/12/10/checksum-files-scala
import java.io.File
import java.nio.file.Files
import java.security.{DigestInputStream, MessageDigest}
import scala.collection.JavaConverters._
def md5(roots: File*): String = {
val md = MessageDigest.getInstance("MD5")
roots.foreach { root =>
View gist:24a194c867e11f1730bd4f172da97a0d
import javax.crypto._
import javax.crypto.spec._
import java.util.Base64
val message= "Hello"
val secret = "eGkmaYd3PE9x3Z221x7b2nXmJ7ACGrjf"
val ivString = "0123456789012345"
val ciper: Cipher = Cipher.getInstance("AES/CBC/PKCS5Padding")
@pauca
pauca / get_script_dir.sh
Created Jan 23, 2018
get_script_dir with bash
View get_script_dir.sh
#!/bin/bash
set -e
set +u
get_script_dir () {
SOURCE="${BASH_SOURCE[0]}"
# While $SOURCE is a symlink, resolve it
while [ -h "$SOURCE" ]; do
DIR="$( cd -P "$( dirname "$SOURCE" )" && pwd )"
SOURCE="$( readlink "$SOURCE" )"
@pauca
pauca / GzipCompressor.scala
Last active Sep 22, 2017
Gist to stream strings to a akka queue that gzips and stores
View GzipCompressor.scala
import akka.actor._
import akka.actor.ActorLogging
import akka.actor.ActorSystem
import akka.stream._
import akka.stream.actor.ActorSubscriberMessage._
import akka.stream.actor._
import akka.stream.scaladsl._
import akka.{ NotUsed, Done }
import akka.util.ByteString
import java.io._
@pauca
pauca / binaryDistances.R
Last active Jun 19, 2017
binary distances R ( tanimoto)
View binaryDistances.R
# http://www.sequentix.de/gelquest/help/distance_measures.htm
bdist <- function( x, y , method ){
a <- sum( x == 1 & y == 1)
b <- sum( x == 1 & y == 0)
c <- sum( x == 0 & y == 1)
d <- sum( x == 0 & y == 0)
switch(method,
tanimoto = (a+d)/(a+2*(b+c)+d),
@pauca
pauca / AkkaStreamTemplate.scala
Created Jun 9, 2017
Basic Akka Stream Template: read, transform, write
View AkkaStreamTemplate.scala
/*
build.sbt
name := "AkkaStreamTemplate"
version := "0.1-SNAPSHOT"
scalaVersion := "2.12.2"
libraryDependencies ++= {
Seq(
@pauca
pauca / StoreRocksDB.scala
Last active Oct 24, 2019
Template for testing: RocksDB with Scala
View StoreRocksDB.scala
import java.io.File
import org.rocksdb._
import org.rocksdb.util.SizeUnit
import scala.collection.JavaConversions._
// build.sbt
// name := "RocksDB"
// version := "0.1"
// scalaVersion := "2.12.0"
// libraryDependencies += "org.rocksdb" % "rocksdbjni" % "5.0.1"
@pauca
pauca / replaceSymLinks.sh
Last active Apr 11, 2017
replace symbolik links in current directory by originals, and remove them
View replaceSymLinks.sh
@pauca
pauca / RqcScript.R
Last active Jan 19, 2017
Rqc - memory error reproduce
View RqcScript.R
library(Rqc)
fs <- "corrupted.fastq"
qa <- rqcQA(fs,sample=F)
sessionInfo()
You can’t perform that action at this time.