fluencelabs/aqua
1
0
Fork 0
mirror of https://github.com/fluencelabs/aqua.git synced 2024-12-04 22:50:18 +00:00
Code Issues Projects Releases Wiki Activity

Tiny fixes for AquaGen

Browse Source
This commit is contained in:
dmitry 2021-03-19 16:45:16 +03:00
parent dbcacebdbd
commit 36f955b17d
2 changed files with 20 additions and 24 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
src/main/scala/aqua/Aqua.scala
View File

@ -6,8 +6,6 @@ import cats.data.ValidatedNel
import aqua.parser.lift.Span
import aqua.semantics.Semantics
import scala.collection.immutable.Queue
object Aqua {
def parse(input: String): ValidatedNel[AquaError, Ast[Span.F]] =

42
src/main/scala/aqua/AquaGen.scala
View File

@ -3,12 +3,11 @@ package aqua
import cats.data.Validated
import cats.effect.{ExitCode, IO, IOApp}
import fs2.io.file.Files
import fs2.{text, Stream}
import cats.implicits._
import fs2.text
import java.io.{File, PrintWriter}
import scala.io.Source
import java.nio.file.{Path, Paths}
import java.io.File
import java.nio.file.Path
import cats.syntax.traverse._
final case class ParseArgsException(private val message: String, private val cause: Throwable = None.orNull)
extends Exception(message, cause)
@ -51,22 +50,21 @@ object AquaGen extends IOApp {
def convertAqua(files: List[File], outputDir: Path): IO[List[Unit]] = {
(for {
file <- files
} yield {
Files[IO]
.readAll(file.toPath, 4096)
.through(text.utf8Decode)
.map(text =>
Aqua.generate(text) match {
case Validated.Valid(v) ⇒
v.mkString("\n")
case Validated.Invalid(errs) ⇒
errs.map(_.showForConsole(text)).toList.mkString("\n")
}
)
.through(text.utf8Encode)
.through(Files[IO].writeAll(outputDir.resolve(file.getName + ".result")))
.compile
.drain
}).sequence
} yield Files[IO]
.readAll(file.toPath, 4096)
.through(text.utf8Decode)
.map(text =>
Aqua.generate(text) match {
case Validated.Valid(v) ⇒
v
case Validated.Invalid(errs) ⇒
errs.map(_.showForConsole(text)).map(println)
""
}
)
.through(text.utf8Encode)
.through(Files[IO].writeAll(outputDir.resolve(file.getName + ".js")))
.compile
.drain).sequence
}
}